107 lines
2.2 KiB
Go
Executable File
107 lines
2.2 KiB
Go
Executable File
package fake
|
|
|
|
import (
|
|
"encoding/json"
|
|
"errors"
|
|
"hamster-tycoon/storage/dao"
|
|
"hamster-tycoon/storage/model"
|
|
"hamster-tycoon/utils"
|
|
"time"
|
|
|
|
"github.com/satori/go.uuid"
|
|
)
|
|
|
|
const (
|
|
cacheKeyUsers = "users"
|
|
)
|
|
|
|
func (db *DatabaseFake) saveUsers(users []*model.User) {
|
|
data := make([]interface{}, 0)
|
|
for _, v := range users {
|
|
data = append(data, v)
|
|
}
|
|
db.save(cacheKeyUsers, data)
|
|
}
|
|
|
|
func (db *DatabaseFake) loadUsers() []*model.User {
|
|
users := make([]*model.User, 0)
|
|
b, err := db.Cache.Get(cacheKeyUsers)
|
|
if err != nil {
|
|
return users
|
|
}
|
|
err = json.Unmarshal(b, &users)
|
|
if err != nil {
|
|
utils.GetLogger().WithError(err).Error("Error while unmarshal fake users")
|
|
}
|
|
return users
|
|
}
|
|
|
|
func (db *DatabaseFake) GetAllUsers() ([]*model.User, error) {
|
|
return db.loadUsers(), nil
|
|
}
|
|
|
|
func (db *DatabaseFake) GetUsersByID(userID string) (*model.User, error) {
|
|
users := db.loadUsers()
|
|
for _, u := range users {
|
|
if u.ID == userID {
|
|
return u, nil
|
|
}
|
|
}
|
|
return nil, dao.NewDAOError(dao.ErrTypeNotFound, errors.New("user not found"))
|
|
}
|
|
|
|
func (db *DatabaseFake) CreateUser(user *model.User) error {
|
|
user.ID = uuid.NewV4().String()
|
|
user.CreatedAt = time.Now()
|
|
|
|
users := db.loadUsers()
|
|
users = append(users, user)
|
|
db.saveUsers(users)
|
|
return nil
|
|
}
|
|
|
|
func (db *DatabaseFake) DeleteUser(userID string) error {
|
|
users := db.loadUsers()
|
|
newUsers := make([]*model.User, 0)
|
|
for _, u := range users {
|
|
if u.ID != userID {
|
|
newUsers = append(newUsers, u)
|
|
}
|
|
}
|
|
db.saveUsers(newUsers)
|
|
return nil
|
|
}
|
|
|
|
func (db *DatabaseFake) UpdateUser(user *model.User) error {
|
|
users := db.loadUsers()
|
|
var foundUser *model.User
|
|
for _, u := range users {
|
|
if u.ID == user.ID {
|
|
foundUser = u
|
|
break
|
|
}
|
|
}
|
|
|
|
if foundUser == nil {
|
|
return dao.NewDAOError(dao.ErrTypeNotFound, errors.New("user not found"))
|
|
}
|
|
|
|
foundUser.UserEditable = user.UserEditable
|
|
now := time.Now()
|
|
foundUser.UpdatedAt = &now
|
|
db.saveUsers(users)
|
|
|
|
*user = *foundUser
|
|
return nil
|
|
}
|
|
|
|
func (db *DatabaseFake) GetUsersByGoogleID(userID string) (*model.User, error) {
|
|
users := db.loadUsers()
|
|
for _, u := range users {
|
|
if u.GoogleId == userID {
|
|
return u, nil
|
|
}
|
|
}
|
|
return nil, dao.NewDAOError(dao.ErrTypeNotFound, errors.New("user not found"))
|
|
}
|