common_test.go 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129
  1. package controller
  2. import (
  3. "testing"
  4. "github.com/gravitl/netmaker/database"
  5. "github.com/gravitl/netmaker/models"
  6. "github.com/stretchr/testify/assert"
  7. )
  8. func TestGetPeerList(t *testing.T) {
  9. database.InitializeDatabase()
  10. deleteAllNetworks()
  11. createNet()
  12. t.Run("NoNodes", func(t *testing.T) {
  13. peers, err := GetPeersList("skynet")
  14. assert.Nil(t, err)
  15. assert.Nil(t, peers)
  16. })
  17. node := createTestNode()
  18. t.Run("One Node", func(t *testing.T) {
  19. peers, err := GetPeersList("skynet")
  20. assert.Nil(t, err)
  21. assert.Equal(t, node.Address, peers[0].Address)
  22. })
  23. t.Run("Multiple Nodes", func(t *testing.T) {
  24. createnode := models.Node{PublicKey: "RM5qhLAE20PG9BbfBCger+Ac9D2NDOwCtY1rbYDLf34=", Endpoint: "10.0.0.2", MacAddress: "02:02:03:04:05:06", Password: "password", Network: "skynet"}
  25. CreateNode(createnode, "skynet")
  26. peers, err := GetPeersList("skynet")
  27. assert.Nil(t, err)
  28. assert.Equal(t, len(peers), 2)
  29. foundNodeEndpoint := false
  30. for _, peer := range peers {
  31. if foundNodeEndpoint = peer.Endpoint == createnode.Endpoint; foundNodeEndpoint {
  32. break
  33. }
  34. }
  35. assert.True(t, foundNodeEndpoint)
  36. })
  37. }
  38. func TestDeleteNode(t *testing.T) {
  39. database.InitializeDatabase()
  40. deleteAllNetworks()
  41. createNet()
  42. node := createTestNode()
  43. t.Run("NodeExists", func(t *testing.T) {
  44. err := DeleteNode(node.MacAddress, true)
  45. assert.Nil(t, err)
  46. })
  47. t.Run("NonExistantNode", func(t *testing.T) {
  48. err := DeleteNode(node.MacAddress, true)
  49. assert.Nil(t, err)
  50. })
  51. }
  52. func TestGetNode(t *testing.T) {
  53. database.InitializeDatabase()
  54. deleteAllNetworks()
  55. t.Run("NoNode", func(t *testing.T) {
  56. response, err := GetNode("01:02:03:04:05:06", "skynet")
  57. assert.Equal(t, models.Node{}, response)
  58. assert.EqualError(t, err, "unexpected end of JSON input")
  59. })
  60. createNet()
  61. node := createTestNode()
  62. t.Run("NodeExists", func(t *testing.T) {
  63. response, err := GetNode(node.MacAddress, node.Network)
  64. assert.Nil(t, err)
  65. assert.Equal(t, "10.0.0.1", response.Endpoint)
  66. assert.Equal(t, "DM5qhLAE20PG9BbfBCger+Ac9D2NDOwCtY1rbYDLf34=", response.PublicKey)
  67. assert.Equal(t, "01:02:03:04:05:06", response.MacAddress)
  68. assert.Equal(t, int32(51821), response.ListenPort)
  69. assert.NotNil(t, response.Name)
  70. assert.Equal(t, "skynet", response.Network)
  71. assert.Equal(t, "nm-skynet", response.Interface)
  72. })
  73. t.Run("BadMac", func(t *testing.T) {
  74. response, err := GetNode("01:02:03:04:05:07", node.Network)
  75. assert.Equal(t, models.Node{}, response)
  76. assert.EqualError(t, err, "unexpected end of JSON input")
  77. })
  78. t.Run("BadNetwork", func(t *testing.T) {
  79. response, err := GetNode(node.MacAddress, "badnet")
  80. assert.Equal(t, models.Node{}, response)
  81. assert.EqualError(t, err, "unexpected end of JSON input")
  82. })
  83. }
  84. func TestCreateNode(t *testing.T) {
  85. t.Skip()
  86. database.InitializeDatabase()
  87. deleteAllNetworks()
  88. createNet()
  89. createnode := models.Node{PublicKey: "DM5qhLAE20PG9BbfBCger+Ac9D2NDOwCtY1rbYDLf34=", Endpoint: "10.0.0.1", MacAddress: "01:02:03:04:05:06", Password: "password", Network: "skynet"}
  90. //err := ValidateNodeCreate("skynet", createnode)
  91. //assert.Nil(t, err)
  92. node, err := CreateNode(createnode, "skynet")
  93. assert.Nil(t, err)
  94. assert.Equal(t, "10.0.0.1", node.Endpoint)
  95. assert.Equal(t, "DM5qhLAE20PG9BbfBCger+Ac9D2NDOwCtY1rbYDLf34=", node.PublicKey)
  96. assert.Equal(t, "01:02:03:04:05:06", node.MacAddress)
  97. assert.Equal(t, int32(51821), node.ListenPort)
  98. assert.NotNil(t, node.Name)
  99. assert.Equal(t, "skynet", node.Network)
  100. assert.Equal(t, "nm-skynet", node.Interface)
  101. }
  102. func TestSetNetworkNodesLastModified(t *testing.T) {
  103. database.InitializeDatabase()
  104. deleteAllNetworks()
  105. createNet()
  106. t.Run("InvalidNetwork", func(t *testing.T) {
  107. err := SetNetworkNodesLastModified("badnet")
  108. assert.EqualError(t, err, "no result found")
  109. })
  110. t.Run("NetworkExists", func(t *testing.T) {
  111. err := SetNetworkNodesLastModified("skynet")
  112. assert.Nil(t, err)
  113. })
  114. }
  115. func createTestNode() models.Node {
  116. createnode := models.Node{PublicKey: "DM5qhLAE20PG9BbfBCger+Ac9D2NDOwCtY1rbYDLf34=", Endpoint: "10.0.0.1", MacAddress: "01:02:03:04:05:06", Password: "password", Network: "skynet"}
  117. node, _ := CreateNode(createnode, "skynet")
  118. return node
  119. }