diff --git a/services/user_test.go b/services/user_test.go new file mode 100644 index 0000000..aa06685 --- /dev/null +++ b/services/user_test.go @@ -0,0 +1,134 @@ +package services + +import ( + "encoding/json" + "testing" + "time" + + "git.devices.local/mawas/golang-api-skeleton/lib/cache" + "git.devices.local/mawas/golang-api-skeleton/lib/common" + "git.devices.local/mawas/golang-api-skeleton/models" + "git.devices.local/mawas/golang-api-skeleton/repositories" + "gorm.io/driver/sqlite" + "gorm.io/gorm" +) + +const username = "unittest" + +func userServiceMock(t *testing.T) (models.User, *UserService) { + db, err := gorm.Open( + sqlite.Open(":memory:"), + &gorm.Config{DisableForeignKeyConstraintWhenMigrating: true}, + ) + if err != nil { + t.Error(err) + } + if err := db.AutoMigrate(&models.User{}); err != nil { + t.Error(err) + } + if err := db.AutoMigrate(&models.Token{}); err != nil { + t.Error(err) + } + appCache, err := cache.Bootstrap() + if err != nil { + t.Error(err) + } + userID, err := common.NewGUID() + if err != nil { + t.Error(err) + } + if err := appCache.Set("user:"+userID.String(), username); err != nil { + t.Error(err) + } + if err := appCache.Set("user:"+username, userID.String()); err != nil { + t.Error(err) + } + user := NewUser(username, "Unit", "Test", "unittest@unittest.test") + user.Active = true + user.ID = userID + userRepository := repositories.NewUserRepository(db, user.ID.String(), username, appCache) + return user, NewUserService(userRepository) +} + +func validateUserResponse(t *testing.T, response *models.User, user models.User) { + if response.Username != user.Username { + t.Errorf("User Username must be \"%s\" but is \"%s\"\n", user.Username, response.Username) + } + if response.Firstname != user.Firstname { + t.Errorf("User Firstname must be \"%s\" but is \"%s\"\n", user.Firstname, response.Firstname) + } + if response.Lastname != user.Lastname { + t.Errorf("User Lastname must be \"%s\" but is \"%s\"\n", user.Lastname, response.Lastname) + } + if response.Email != user.Email { + t.Errorf("User Email must be \"%s\" but is \"%s\"\n", user.Email, response.Email) + } + if !response.Active { + t.Error("User Active must be true") + } + if len(response.TokensRef) > 0 { + t.Error("User TokensRef must be empty") + } + if len(response.Tokens) > 0 { + t.Error("User Tokens must be empty") + } + jsonString, err := json.Marshal(response) + if err != nil { + t.Error(err) + } + var j map[string]interface{} + if err := json.Unmarshal([]byte(jsonString), &j); err != nil { + t.Error(err) + } + if _, exists := j["id"]; exists { + t.Error("User ID must be hidden in json") + } + if u, exists := j["created_by"]; !exists { + t.Error("User created_by not in json") + } else if u != username { + t.Errorf("User created_by must be \"%s\" but is \"%s\"\n", username, u) + } + if u, exists := j["updated_by"]; !exists { + t.Error("User updated_by not in json") + } else if u != username { + t.Errorf("User updated_by must be \"%s\" but is \"%s\"\n", username, u) + } + if datetime, exists := j["created_at"]; !exists { + t.Error("User created_at not in json") + } else if _, err := time.Parse(time.RFC3339, datetime.(string)); err != nil { + t.Errorf("User created_at must be a valid rfc 3339 date time in json, but is \"%s\"", datetime) + } + if datetime, exists := j["updated_at"]; !exists { + t.Error("User updated_at not in json") + } else if _, err := time.Parse(time.RFC3339, datetime.(string)); err != nil { + t.Errorf("User updated_at must be a valid rfc 3339 date time in json, but is \"%s\"", datetime) + } + if _, exists := j["deleted_by"]; exists { + t.Error("User deleted_by mustn't be set in json") + } + if _, exists := j["deleted_at"]; exists { + t.Error("User deleted_by mustn't be set in json") + } +} + +func TestUserRepository(t *testing.T) { + user, userService := userServiceMock(t) + response, err := userService.Create(&user) + if err != nil { + t.Errorf("userService Create failed with error: %v\n", err) + } + validateUserResponse(t, response, user) + response, err = userService.ReadByID(username) + if err != nil { + t.Errorf("userService ReadByID failed with error: %v\n", err) + } + validateUserResponse(t, response, user) + responses, err := userService.ReadAll() + if err != nil { + t.Errorf("userService ReadAll failed with error: %v\n", err) + } + if len(responses) != 1 { + t.Error("userService ReadAll failed with worng numer of responses") + } + validateUserResponse(t, responses[0], user) +}