mirror of
https://github.com/veops/oneterm.git
synced 2025-09-27 03:36:02 +08:00
fix(backend): db init
This commit is contained in:
@@ -13,6 +13,7 @@ import (
|
||||
"github.com/veops/oneterm/internal/model"
|
||||
"github.com/veops/oneterm/internal/service"
|
||||
fileservice "github.com/veops/oneterm/internal/service/file"
|
||||
gsession "github.com/veops/oneterm/internal/session"
|
||||
"github.com/veops/oneterm/pkg/config"
|
||||
"github.com/veops/oneterm/pkg/db"
|
||||
"github.com/veops/oneterm/pkg/logger"
|
||||
@@ -41,6 +42,8 @@ func initDB() {
|
||||
}
|
||||
|
||||
acl.MigrateNode()
|
||||
|
||||
gsession.InitSessionCleanup()
|
||||
}
|
||||
|
||||
func initServices() {
|
||||
|
@@ -26,7 +26,8 @@ var (
|
||||
onlineSession = &sync.Map{}
|
||||
)
|
||||
|
||||
func init() {
|
||||
// InitSessionCleanup initializes session cleanup after database is ready
|
||||
func InitSessionCleanup() {
|
||||
// After system restart, set all online sessions to offline
|
||||
sessions := make([]*Session, 0)
|
||||
if err := dbpkg.DB.
|
||||
@@ -34,7 +35,8 @@ func init() {
|
||||
Where("status = ?", model.SESSIONSTATUS_ONLINE).
|
||||
Find(&sessions).
|
||||
Error; err != nil {
|
||||
logger.L().Fatal("get sessions failed", zap.Error(err))
|
||||
logger.L().Error("get sessions failed", zap.Error(err))
|
||||
return
|
||||
}
|
||||
now := time.Now()
|
||||
for _, s := range sessions {
|
||||
|
@@ -1,6 +1,6 @@
|
||||
services:
|
||||
oneterm-api:
|
||||
image: registry.cn-hangzhou.aliyuncs.com/veops/oneterm-api:v25.6.2
|
||||
image: registry.cn-hangzhou.aliyuncs.com/veops/oneterm-api:v25.6.2.fix
|
||||
container_name: oneterm-api
|
||||
environment:
|
||||
ONETERM_RDP_DRIVE_PATH: /rdp
|
||||
|
Reference in New Issue
Block a user