aboutsummaryrefslogtreecommitdiff
path: root/cmd
diff options
context:
space:
mode:
authorFuwn <[email protected]>2026-01-23 20:54:50 -0800
committerFuwn <[email protected]>2026-01-23 20:54:50 -0800
commit4f8955fb5b9e05a5d0e2f4811c13926a6cbbe4b3 (patch)
tree4d1bcd871bb90e55f1aa11b16bc8763ac692af73 /cmd
parentfeat: Add database maintenance with backup/reset modes and triggers (diff)
downloadkaze-4f8955fb5b9e05a5d0e2f4811c13926a6cbbe4b3.tar.xz
kaze-4f8955fb5b9e05a5d0e2f4811c13926a6cbbe4b3.zip
feat: Switch to libsql driver for Turso compatibility
Diffstat (limited to 'cmd')
-rw-r--r--cmd/kaze/main.go18
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())