diff options
| author | Fuwn <[email protected]> | 2026-01-23 20:54:50 -0800 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2026-01-23 20:54:50 -0800 |
| commit | 4f8955fb5b9e05a5d0e2f4811c13926a6cbbe4b3 (patch) | |
| tree | 4d1bcd871bb90e55f1aa11b16bc8763ac692af73 /cmd | |
| parent | feat: Add database maintenance with backup/reset modes and triggers (diff) | |
| download | kaze-4f8955fb5b9e05a5d0e2f4811c13926a6cbbe4b3.tar.xz kaze-4f8955fb5b9e05a5d0e2f4811c13926a6cbbe4b3.zip | |
feat: Switch to libsql driver for Turso compatibility
Diffstat (limited to 'cmd')
| -rw-r--r-- | cmd/kaze/main.go | 18 |
1 files changed, 16 insertions, 2 deletions
diff --git a/cmd/kaze/main.go b/cmd/kaze/main.go index ee12ae8..aaed1fa 100644 --- a/cmd/kaze/main.go +++ b/cmd/kaze/main.go @@ -8,6 +8,7 @@ import ( "os" "os/signal" "path/filepath" + "strings" "syscall" "time" @@ -24,6 +25,18 @@ var ( date = "unknown" ) +func maskDatabaseURL(url string) string { + if strings.Contains(url, "authToken=") { + idx := strings.Index(url, "authToken=") + end := strings.Index(url[idx:], "&") + if end == -1 { + return url[:idx] + "authToken=***" + } + return url[:idx] + "authToken=***" + url[idx+end:] + } + return url +} + func main() { // Parse flags configPath := flag.String("config", "config.yaml", "Path to configuration file") @@ -68,14 +81,15 @@ func main() { "groups", len(cfg.Groups), "incidents", len(cfg.Incidents)) - store, err := storage.NewWithMaintenance(cfg.Storage.Path, cfg.Storage.HistoryDays, cfg.Storage.Maintenance) + dbURL := cfg.Storage.GetDatabaseURL() + store, err := storage.NewWithMaintenance(dbURL, cfg.Storage.HistoryDays, cfg.Storage.Maintenance) if err != nil { logger.Error("failed to initialize storage", "error", err) os.Exit(1) } defer store.Close() logger.Info("initialized storage", - "path", cfg.Storage.Path, + "url", maskDatabaseURL(dbURL), "history_days", cfg.Storage.HistoryDays, "maintenance_mode", store.GetMaintenanceMode()) |