helpers_test.go 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. package functions
  2. import (
  3. "context"
  4. "encoding/json"
  5. "os"
  6. "testing"
  7. "github.com/gravitl/netmaker/database"
  8. "github.com/gravitl/netmaker/logger"
  9. "github.com/gravitl/netmaker/logic"
  10. "github.com/gravitl/netmaker/models"
  11. "github.com/stretchr/testify/assert"
  12. )
  13. var (
  14. testNetwork = &models.Network{
  15. NetID: "not-a-network",
  16. }
  17. testExternalClient = &models.ExtClient{
  18. ClientID: "testExtClient",
  19. }
  20. )
  21. func TestMain(m *testing.M) {
  22. database.InitializeDatabase()
  23. defer database.CloseDB()
  24. logic.CreateSuperAdmin(&models.User{
  25. UserName: "superadmin",
  26. Password: "password",
  27. IsSuperAdmin: true,
  28. })
  29. peerUpdate := make(chan *models.Node)
  30. go logic.ManageZombies(context.Background(), peerUpdate)
  31. go func() {
  32. for update := range peerUpdate {
  33. //do nothing
  34. logger.Log(3, "received node update", update.Action)
  35. }
  36. }()
  37. os.Exit(m.Run())
  38. }
  39. func TestNetworkExists(t *testing.T) {
  40. database.DeleteRecord(database.NETWORKS_TABLE_NAME, testNetwork.NetID)
  41. exists, err := logic.NetworkExists(testNetwork.NetID)
  42. assert.NotNil(t, err)
  43. assert.False(t, exists)
  44. err = logic.SaveNetwork(testNetwork)
  45. assert.Nil(t, err)
  46. exists, err = logic.NetworkExists(testNetwork.NetID)
  47. assert.Nil(t, err)
  48. assert.True(t, exists)
  49. err = database.DeleteRecord(database.NETWORKS_TABLE_NAME, testNetwork.NetID)
  50. assert.Nil(t, err)
  51. }
  52. func TestGetAllExtClients(t *testing.T) {
  53. err := database.DeleteRecord(database.EXT_CLIENT_TABLE_NAME, testExternalClient.ClientID)
  54. assert.Nil(t, err)
  55. extClients, err := GetAllExtClients()
  56. if err == nil {
  57. t.Fatalf("expected error, received nil")
  58. }
  59. if len(extClients) >= 1 {
  60. t.Fatalf("expected no external clients, received %d", len(extClients))
  61. }
  62. extClient, err := json.Marshal(testExternalClient)
  63. if err != nil {
  64. t.Fatal(err)
  65. }
  66. err = database.Insert(testExternalClient.ClientID, string(extClient), database.EXT_CLIENT_TABLE_NAME)
  67. if err != nil {
  68. t.Fatal(err)
  69. }
  70. extClients, err = GetAllExtClients()
  71. if err != nil {
  72. t.Fatalf("expected nil, received: %s", err)
  73. }
  74. if len(extClients) < 1 {
  75. t.Fatalf("expected 1 external client, received %d", len(extClients))
  76. }
  77. err = database.DeleteRecord(database.EXT_CLIENT_TABLE_NAME, testExternalClient.ClientID)
  78. if err != nil {
  79. t.Fatalf("failed removing extclient: %s", err)
  80. }
  81. }