host_test.go 1.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. package logic
  2. import (
  3. "context"
  4. "fmt"
  5. "net"
  6. "os"
  7. "testing"
  8. "github.com/google/uuid"
  9. "github.com/gravitl/netmaker/database"
  10. "github.com/gravitl/netmaker/models"
  11. "github.com/matryer/is"
  12. )
  13. func TestCheckPorts(t *testing.T) {
  14. database.InitializeDatabase()
  15. defer database.CloseDB()
  16. peerUpdate := make(chan *models.Node)
  17. go ManageZombies(context.Background(), peerUpdate)
  18. go func() {
  19. for y := range peerUpdate {
  20. fmt.Printf("Pointless %v\n", y)
  21. //do nothing
  22. }
  23. }()
  24. os.Exit(m.Run())
  25. }
  26. h := models.Host{
  27. ID: uuid.New(),
  28. EndpointIP: net.ParseIP("192.168.1.1"),
  29. ListenPort: 51821,
  30. ProxyListenPort: maxPort,
  31. }
  32. testHost := models.Host{
  33. ID: uuid.New(),
  34. EndpointIP: net.ParseIP("192.168.1.1"),
  35. ListenPort: 51830,
  36. ProxyListenPort: 51730,
  37. }
  38. CreateHost(&h)
  39. t.Run("no change", func(t *testing.T) {
  40. is := is.New(t)
  41. CheckHostPorts(&testHost)
  42. is.Equal(testHost.ListenPort, 51830)
  43. is.Equal(testHost.ProxyListenPort, 51730)
  44. })
  45. t.Run("same listen port", func(t *testing.T) {
  46. is := is.New(t)
  47. testHost.ListenPort = 51821
  48. CheckHostPorts(&testHost)
  49. is.Equal(testHost.ListenPort, 51822)
  50. is.Equal(testHost.ProxyListenPort, 51730)
  51. })
  52. t.Run("same proxy port", func(t *testing.T) {
  53. is := is.New(t)
  54. testHost.ProxyListenPort = 65535
  55. CheckHostPorts(&testHost)
  56. is.Equal(testHost.ListenPort, 51822)
  57. is.Equal(testHost.ProxyListenPort, minPort)
  58. })
  59. t.Run("listenport equals proxy port", func(t *testing.T) {
  60. is := is.New(t)
  61. testHost.ListenPort = maxPort
  62. CheckHostPorts(&testHost)
  63. is.Equal(testHost.ListenPort, minPort)
  64. is.Equal(testHost.ProxyListenPort, minPort+1)
  65. })
  66. t.Run("proxyport equals listenport", func(t *testing.T) {
  67. is := is.New(t)
  68. testHost.ProxyListenPort = 51821
  69. CheckHostPorts(&testHost)
  70. is.Equal(testHost.ListenPort, minPort)
  71. is.Equal(testHost.ProxyListenPort, 51822)
  72. })
  73. }