mirror of
https://github.com/gotify/server.git
synced 2024-01-28 15:20:56 +03:00
80 lines
2.0 KiB
Go
80 lines
2.0 KiB
Go
package database
|
|
|
|
import (
|
|
"github.com/gotify/server/v2/model"
|
|
"github.com/jinzhu/gorm"
|
|
)
|
|
|
|
// GetUserByName returns the user by the given name or nil.
|
|
func (d *GormDatabase) GetUserByName(name string) (*model.User, error) {
|
|
user := new(model.User)
|
|
err := d.DB.Where("name = ?", name).Find(user).Error
|
|
if err == gorm.ErrRecordNotFound {
|
|
err = nil
|
|
}
|
|
if user.Name == name {
|
|
return user, err
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
// GetUserByID returns the user by the given id or nil.
|
|
func (d *GormDatabase) GetUserByID(id uint) (*model.User, error) {
|
|
user := new(model.User)
|
|
err := d.DB.Find(user, id).Error
|
|
if err == gorm.ErrRecordNotFound {
|
|
err = nil
|
|
}
|
|
if user.ID == id {
|
|
return user, err
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
// CountUser returns the user count which satisfies the given condition.
|
|
func (d *GormDatabase) CountUser(condition ...interface{}) (int, error) {
|
|
c := -1
|
|
handle := d.DB.Model(new(model.User))
|
|
if len(condition) == 1 {
|
|
handle = handle.Where(condition[0])
|
|
} else if len(condition) > 1 {
|
|
handle = handle.Where(condition[0], condition[1:]...)
|
|
}
|
|
err := handle.Count(&c).Error
|
|
return c, err
|
|
}
|
|
|
|
// GetUsers returns all users.
|
|
func (d *GormDatabase) GetUsers() ([]*model.User, error) {
|
|
var users []*model.User
|
|
err := d.DB.Find(&users).Error
|
|
return users, err
|
|
}
|
|
|
|
// DeleteUserByID deletes a user by its id.
|
|
func (d *GormDatabase) DeleteUserByID(id uint) error {
|
|
apps, _ := d.GetApplicationsByUser(id)
|
|
for _, app := range apps {
|
|
d.DeleteApplicationByID(app.ID)
|
|
}
|
|
clients, _ := d.GetClientsByUser(id)
|
|
for _, client := range clients {
|
|
d.DeleteClientByID(client.ID)
|
|
}
|
|
pluginConfs, _ := d.GetPluginConfByUser(id)
|
|
for _, conf := range pluginConfs {
|
|
d.DeletePluginConfByID(conf.ID)
|
|
}
|
|
return d.DB.Where("id = ?", id).Delete(&model.User{}).Error
|
|
}
|
|
|
|
// UpdateUser updates a user.
|
|
func (d *GormDatabase) UpdateUser(user *model.User) error {
|
|
return d.DB.Save(user).Error
|
|
}
|
|
|
|
// CreateUser creates a user.
|
|
func (d *GormDatabase) CreateUser(user *model.User) error {
|
|
return d.DB.Create(user).Error
|
|
}
|