62 lines
1.0 KiB
Go
62 lines
1.0 KiB
Go
package watchdog
|
|
|
|
import (
|
|
"log/slog"
|
|
"orbits-server/internal/server/bootstrap"
|
|
"orbits-server/internal/server/database"
|
|
"time"
|
|
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
type State struct {
|
|
FS map[string]struct{}
|
|
DB map[string]database.File
|
|
}
|
|
|
|
type Result struct {
|
|
FSOrphans []string
|
|
DBOrphans []database.File
|
|
}
|
|
|
|
func Kickoff(env bootstrap.Environment, db *gorm.DB) {
|
|
interval := time.Second * time.Duration(env.WatchdogInterval)
|
|
ticker := time.NewTicker(interval)
|
|
|
|
go func() {
|
|
defer ticker.Stop()
|
|
|
|
run(env, db)
|
|
|
|
for range ticker.C {
|
|
run(env, db)
|
|
}
|
|
}()
|
|
}
|
|
|
|
func run(env bootstrap.Environment, db *gorm.DB) {
|
|
slog.Debug("watchdog cycle start")
|
|
|
|
fsState, err := scanFS(env)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
dbState, err := scanDB(db)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
result := reconcile(fsState, dbState)
|
|
|
|
if len(result.FSOrphans) > 0 {
|
|
slog.Info("filesystem orphans detected")
|
|
applyFS(env, db, result.FSOrphans)
|
|
}
|
|
|
|
if len(result.DBOrphans) > 0 {
|
|
slog.Info("database orphans detected")
|
|
applyDB(db, result.DBOrphans)
|
|
}
|
|
}
|