3x-ui/database/db.go

89 lines
2.1 KiB
Go
Raw Normal View History

2023-02-09 19:18:06 +00:00
package database
import (
2025-10-07 20:44:05 +00:00
"errors"
2025-10-07 22:29:05 +00:00
"fmt"
2025-09-19 08:05:43 +00:00
"github.com/mhsanaei/3x-ui/v2/database/model"
"golang.org/x/crypto/bcrypt"
2025-10-07 22:51:21 +00:00
// "gorm.io/driver/sqlite"
"github.com/glebarez/sqlite"
2023-02-16 15:58:20 +00:00
"gorm.io/gorm"
2023-02-09 19:18:06 +00:00
)
var db *gorm.DB
2025-10-07 22:29:05 +00:00
// InitDB открывает sqlite и выполняет миграции / начальное заполнение.
2023-02-09 19:18:06 +00:00
func InitDB(dbPath string) error {
database, err := gorm.Open(sqlite.Open(dbPath), &gorm.Config{})
2023-02-09 19:18:06 +00:00
if err != nil {
return err
}
db = database
2023-02-09 19:18:06 +00:00
2025-10-07 22:29:05 +00:00
// миграции
if err := AutoMigrate(); err != nil {
2024-07-13 23:22:02 +00:00
return err
}
2025-10-07 22:29:05 +00:00
// seed admin (один раз создаём дефолтного админа при отсутствии)
if err := SeedAdmin(); err != nil {
2025-09-18 20:06:01 +00:00
return err
}
2023-02-09 19:18:06 +00:00
return nil
}
2025-10-07 22:29:05 +00:00
// GetDB возвращает активное соединение GORM.
func GetDB() *gorm.DB {
return db
}
// IsNotFound — хелпер для проверки "запись не найдена".
func IsNotFound(err error) bool {
return errors.Is(err, gorm.ErrRecordNotFound)
}
// Checkpoint — безопасный чекпоинт WAL для sqlite.
// Для других СУБД — no-op.
func Checkpoint() error {
if db == nil {
return fmt.Errorf("database is not initialized")
}
if db.Dialector.Name() != "sqlite" {
return nil
}
// TRUNCATE обычно полезнее, чтобы подрезать WAL-файл.
return db.Exec("PRAGMA wal_checkpoint(TRUNCATE);").Error
}
// AutoMigrate применяет миграции схемы.
func AutoMigrate() error {
return db.AutoMigrate(
2025-10-07 22:29:05 +00:00
&model.User{},
&model.Setting{}, // таблица настроек
)
2023-02-09 19:18:06 +00:00
}
2023-05-05 18:21:39 +00:00
2025-10-07 22:29:05 +00:00
// SeedAdmin создаёт дефолтного админа, если его нет.
func SeedAdmin() error {
var count int64
if err := db.Model(&model.User{}).
Where("username = ?", "admin@local.test").
Count(&count).Error; err != nil {
return err
}
if count > 0 {
return nil
2023-05-05 18:21:39 +00:00
}
2023-12-08 19:35:10 +00:00
hash, _ := bcrypt.GenerateFromPassword([]byte("Admin12345!"), 12)
admin := model.User{
Username: "admin@local.test",
PasswordHash: string(hash),
Role: "admin",
2023-12-08 19:35:10 +00:00
}
return db.Create(&admin).Error
2023-12-08 19:35:10 +00:00
}