mirror of
https://github.com/gotify/server.git
synced 2026-05-07 05:48:41 +08:00
* chore: Migrate github.com/jinzhu/gorm to gorm.io/gorm
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* chore: drop singleton connection limit on sqlite3 backend
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* enhance: database logging
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* Revert "chore: drop singleton connection limit on sqlite3 backend"
This reverts commit b494a3bd1f.
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* typo
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* rename unique_index -> uniqueIndex
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* drop uniqueIndex on primary key
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* migrate fully to new gorm tag format
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* specify unique index name
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* remove pluginConf duplicate index
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
* disable auto migrate FK
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
---------
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
66 lines
1.9 KiB
Go
66 lines
1.9 KiB
Go
package database
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/gotify/server/v2/model"
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
// GetApplicationByToken returns the application for the given token or nil.
|
|
func (d *GormDatabase) GetApplicationByToken(token string) (*model.Application, error) {
|
|
app := new(model.Application)
|
|
err := d.DB.Where("token = ?", token).Find(app).Error
|
|
if err == gorm.ErrRecordNotFound {
|
|
err = nil
|
|
}
|
|
if app.Token == token {
|
|
return app, err
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
// GetApplicationByID returns the application for the given id or nil.
|
|
func (d *GormDatabase) GetApplicationByID(id uint) (*model.Application, error) {
|
|
app := new(model.Application)
|
|
err := d.DB.Where("id = ?", id).Find(app).Error
|
|
if err == gorm.ErrRecordNotFound {
|
|
err = nil
|
|
}
|
|
if app.ID == id {
|
|
return app, err
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
// CreateApplication creates an application.
|
|
func (d *GormDatabase) CreateApplication(application *model.Application) error {
|
|
return d.DB.Create(application).Error
|
|
}
|
|
|
|
// DeleteApplicationByID deletes an application by its id.
|
|
func (d *GormDatabase) DeleteApplicationByID(id uint) error {
|
|
d.DeleteMessagesByApplication(id)
|
|
return d.DB.Where("id = ?", id).Delete(&model.Application{}).Error
|
|
}
|
|
|
|
// GetApplicationsByUser returns all applications from a user.
|
|
func (d *GormDatabase) GetApplicationsByUser(userID uint) ([]*model.Application, error) {
|
|
var apps []*model.Application
|
|
err := d.DB.Where("user_id = ?", userID).Order("id ASC").Find(&apps).Error
|
|
if err == gorm.ErrRecordNotFound {
|
|
err = nil
|
|
}
|
|
return apps, err
|
|
}
|
|
|
|
// UpdateApplication updates an application.
|
|
func (d *GormDatabase) UpdateApplication(app *model.Application) error {
|
|
return d.DB.Save(app).Error
|
|
}
|
|
|
|
// UpdateApplicationTokenLastUsed updates the last used time of the application token.
|
|
func (d *GormDatabase) UpdateApplicationTokenLastUsed(token string, t *time.Time) error {
|
|
return d.DB.Model(&model.Application{}).Where("token = ?", token).Update("last_used", t).Error
|
|
}
|