| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257 | package controllerimport (	"context"	"os"	"testing"	"time"	"github.com/gravitl/netmaker/models"	"github.com/gravitl/netmaker/mongoconn"	"github.com/stretchr/testify/assert")func TestMain(m *testing.M) {	mongoconn.ConnectDatabase()	var gconf models.GlobalConfig	gconf.ServerGRPC = "localhost:8081"	gconf.PortGRPC = "50051"	//err := SetGlobalConfig(gconf)	collection := mongoconn.Client.Database("netmaker").Collection("config")	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)	defer cancel()	//create, _, err := functions.GetGlobalConfig()	_, err := collection.InsertOne(ctx, gconf)	if err != nil {		panic("could not create config store")	}	//drop network, nodes, and user collections	var collections = []string{"networks", "nodes", "users", "dns"}	for _, table := range collections {		collection := mongoconn.Client.Database("netmaker").Collection(table)		ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)		defer cancel()		err := collection.Drop(ctx)		if err != nil {			panic("could not drop collection")		}	}	os.Exit(m.Run())}func TestHasAdmin(t *testing.T) {	_, err := DeleteUser("admin")	assert.Nil(t, err)	user := models.User{"admin", "password", true}	_, err = CreateUser(user)	assert.Nil(t, err)	t.Run("AdminExists", func(t *testing.T) {		found, err := HasAdmin()		assert.Nil(t, err)		assert.True(t, found)	})	t.Run("NoUser", func(t *testing.T) {		_, err := DeleteUser("admin")		assert.Nil(t, err)		found, err := HasAdmin()		assert.Nil(t, err)		assert.False(t, found)	})}func TestCreateUser(t *testing.T) {	user := models.User{"admin", "password", true}	t.Run("NoUser", func(t *testing.T) {		_, err := DeleteUser("admin")		assert.Nil(t, err)		admin, err := CreateUser(user)		assert.Nil(t, err)		assert.Equal(t, user.UserName, admin.UserName)	})	t.Run("AdminExists", func(t *testing.T) {		_, err := CreateUser(user)		assert.NotNil(t, err)		assert.Equal(t, "Admin already Exists", err.Error())	})}func TestDeleteUser(t *testing.T) {	hasadmin, err := HasAdmin()	assert.Nil(t, err)	if !hasadmin {		user := models.User{"admin", "pasword", true}		_, err := CreateUser(user)		assert.Nil(t, err)	}	t.Run("ExistingUser", func(t *testing.T) {		deleted, err := DeleteUser("admin")		assert.Nil(t, err)		assert.True(t, deleted)		t.Log(deleted, err)	})	t.Run("NonExistantUser", func(t *testing.T) {		deleted, err := DeleteUser("admin")		assert.Nil(t, err)		assert.False(t, deleted)	})}func TestValidateUser(t *testing.T) {	var user models.User	t.Run("ValidCreate", func(t *testing.T) {		user.UserName = "admin"		user.Password = "validpass"		err := ValidateUser("create", user)		assert.Nil(t, err)	})	t.Run("ValidUpdate", func(t *testing.T) {		user.UserName = "admin"		user.Password = "password"		err := ValidateUser("update", user)		assert.Nil(t, err)	})	t.Run("InvalidUserName", func(t *testing.T) {		user.UserName = "invalid*"		err := ValidateUser("update", user)		assert.NotNil(t, err)		assert.Contains(t, err.Error(), "Field validation for 'UserName' failed")	})	t.Run("ShortUserName", func(t *testing.T) {		user.UserName = "12"		err := ValidateUser("create", user)		assert.NotNil(t, err)		assert.Contains(t, err.Error(), "Field validation for 'UserName' failed")	})	t.Run("EmptyPassword", func(t *testing.T) {		user.Password = ""		err := ValidateUser("create", user)		assert.NotNil(t, err)		assert.Contains(t, err.Error(), "Field validation for 'Password' failed")	})	t.Run("ShortPassword", func(t *testing.T) {		user.Password = "123"		err := ValidateUser("create", user)		assert.NotNil(t, err)		assert.Contains(t, err.Error(), "Field validation for 'Password' failed")	})}func TestGetUser(t *testing.T) {	t.Run("UserExisits", func(t *testing.T) {		user := models.User{"admin", "password", true}		hasadmin, err := HasAdmin()		assert.Nil(t, err)		if !hasadmin {			_, err := CreateUser(user)			assert.Nil(t, err)		}		admin, err := GetUser("admin")		assert.Nil(t, err)		assert.Equal(t, user.UserName, admin.UserName)	})	t.Run("NonExistantUser", func(t *testing.T) {		_, err := DeleteUser("admin")		assert.Nil(t, err)		admin, err := GetUser("admin")		assert.Equal(t, "mongo: no documents in result", err.Error())		assert.Equal(t, "", admin.UserName)	})}func TestUpdateUser(t *testing.T) {	user := models.User{"admin", "password", true}	newuser := models.User{"hello", "world", true}	t.Run("UserExisits", func(t *testing.T) {		_, err := DeleteUser("admin")		_, err = CreateUser(user)		assert.Nil(t, err)		admin, err := UpdateUser(newuser, user)		assert.Nil(t, err)		assert.Equal(t, newuser.UserName, admin.UserName)	})	t.Run("NonExistantUser", func(t *testing.T) {		_, err := DeleteUser("hello")		assert.Nil(t, err)		_, err = UpdateUser(newuser, user)		assert.Equal(t, "mongo: no documents in result", err.Error())	})}func TestValidateToken(t *testing.T) {	t.Run("EmptyToken", func(t *testing.T) {		err := ValidateToken("")		assert.NotNil(t, err)		assert.Equal(t, "Missing Auth Token.", err.Error())	})	t.Run("InvalidToken", func(t *testing.T) {		err := ValidateToken("Bearer: badtoken")		assert.NotNil(t, err)		assert.Equal(t, "Error Verifying Auth Token", err.Error())	})	t.Run("InvalidUser", func(t *testing.T) {		t.Skip()		//need authorization	})	t.Run("ValidToken", func(t *testing.T) {		err := ValidateToken("Bearer: secretkey")		assert.Nil(t, err)	})}func TestVerifyAuthRequest(t *testing.T) {	var authRequest models.UserAuthParams	t.Run("EmptyUserName", func(t *testing.T) {		authRequest.UserName = ""		authRequest.Password = "Password"		jwt, err := VerifyAuthRequest(authRequest)		assert.NotNil(t, err)		assert.Equal(t, "", jwt)		assert.Equal(t, "Username can't be empty", err.Error())	})	t.Run("EmptyPassword", func(t *testing.T) {		authRequest.UserName = "admin"		authRequest.Password = ""		jwt, err := VerifyAuthRequest(authRequest)		assert.NotNil(t, err)		assert.Equal(t, "", jwt)		assert.Equal(t, "Password can't be empty", err.Error())	})	t.Run("NonExistantUser", func(t *testing.T) {		_, err := DeleteUser("admin")		authRequest.UserName = "admin"		authRequest.Password = "password"		jwt, err := VerifyAuthRequest(authRequest)		assert.NotNil(t, err)		assert.Equal(t, "", jwt)		assert.Equal(t, "User admin not found", err.Error())	})	t.Run("Non-Admin", func(t *testing.T) {		//can't create a user that is not a an admin		t.Skip()		user := models.User{"admin", "admin", false}		_, err := CreateUser(user)		assert.Nil(t, err)		authRequest := models.UserAuthParams{"admin", "admin"}		jwt, err := VerifyAuthRequest(authRequest)		assert.NotNil(t, err)		assert.Equal(t, "", jwt)		assert.Equal(t, "User is not an admin", err.Error())	})	t.Run("WrongPassword", func(t *testing.T) {		_, err := DeleteUser("admin")		user := models.User{"admin", "password", true}		_, err = CreateUser(user)		assert.Nil(t, err)		authRequest := models.UserAuthParams{"admin", "badpass"}		jwt, err := VerifyAuthRequest(authRequest)		assert.NotNil(t, err)		assert.Equal(t, "", jwt)		assert.Equal(t, "Wrong Password", err.Error())	})	t.Run("Success", func(t *testing.T) {		authRequest := models.UserAuthParams{"admin", "password"}		jwt, err := VerifyAuthRequest(authRequest)		assert.Nil(t, err)		assert.NotNil(t, jwt)	})}
 |