diff --git a/cmd/archivmail/cmd_import.go b/cmd/archivmail/cmd_import.go index 5aeb6a7..2b24137 100644 --- a/cmd/archivmail/cmd_import.go +++ b/cmd/archivmail/cmd_import.go @@ -288,6 +288,7 @@ Commands: rethread Thread-IDs rückwirkend aus In-Reply-To/References befüllen ocr-reprocess OCR für Anhänge nachholen (alle oder pro Mandant/Status) update Auf neueste Version aktualisieren (führt update.sh aus) + status Healthcheck für DB, Manticore und Storage version Version anzeigen help Diese Hilfe anzeigen @@ -334,5 +335,9 @@ archivmail recompress [flags] archivmail rethread [flags] --config Pfad zur Konfigurationsdatei (Standard: /etc/archivmail/config.yml) --dry-run Simulation: zeigt wie viele Mails gethreaded würden, ohne DB zu ändern + +archivmail status [flags] + --config Pfad zur Konfigurationsdatei (Standard: /etc/archivmail/config.yml) + --json Maschinenlesbare JSON-Ausgabe `, AppVersion) } diff --git a/cmd/archivmail/cmd_status.go b/cmd/archivmail/cmd_status.go new file mode 100644 index 0000000..79d30e2 --- /dev/null +++ b/cmd/archivmail/cmd_status.go @@ -0,0 +1,186 @@ +package main + +import ( + "context" + "database/sql" + "encoding/base64" + "encoding/json" + "flag" + "fmt" + "os" + "strings" + "syscall" + "time" + + _ "github.com/go-sql-driver/mysql" + "github.com/jackc/pgx/v5/pgxpool" + + "archivmail/config" +) + +// checkResult holds the outcome of a single health check. +type checkResult struct { + Name string `json:"name"` + OK bool `json:"ok"` + Detail string `json:"detail"` + Latency string `json:"latency,omitempty"` +} + +// runStatus performs health checks against PostgreSQL, Manticore Search, and +// the mail storage directory, and prints a summary. +// Usage: archivmail status [-config /path/to/config.yml] [-json] +func runStatus(args []string) { + fs := flag.NewFlagSet("status", flag.ExitOnError) + configPath := fs.String("config", "/etc/archivmail/config.yml", "path to config file") + jsonOut := fs.Bool("json", false, "machine-readable JSON output") + fs.Parse(args) + + cfg, err := config.Load(*configPath) + if err != nil { + fmt.Fprintf(os.Stderr, "archivmail status: config laden fehlgeschlagen: %v\n", err) + os.Exit(1) + } + + results := []checkResult{ + checkPostgres(cfg), + checkManticore(cfg), + checkStorage(cfg), + } + + allOK := true + for _, r := range results { + if !r.OK { + allOK = false + } + } + + if *jsonOut { + enc := json.NewEncoder(os.Stdout) + enc.SetIndent("", " ") + _ = enc.Encode(map[string]interface{}{"ok": allOK, "checks": results}) + } else { + for _, r := range results { + status := "OK" + if !r.OK { + status = "FEHLER" + } + if r.Latency != "" { + fmt.Printf("[%-6s] %-12s %s (%s)\n", status, r.Name, r.Detail, r.Latency) + } else { + fmt.Printf("[%-6s] %-12s %s\n", status, r.Name, r.Detail) + } + } + } + + if !allOK { + os.Exit(1) + } +} + +func checkPostgres(cfg *config.Config) checkResult { + ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) + defer cancel() + + start := time.Now() + pool, err := pgxpool.New(ctx, cfg.Database.DSN()) + if err != nil { + return checkResult{Name: "PostgreSQL", OK: false, Detail: fmt.Sprintf("Verbindung fehlgeschlagen: %v", err)} + } + defer pool.Close() + + if err := pool.Ping(ctx); err != nil { + return checkResult{Name: "PostgreSQL", OK: false, Detail: fmt.Sprintf("Ping fehlgeschlagen: %v", err)} + } + latency := time.Since(start) + + var totalMails int64 + var firstMail, lastMail *time.Time + _ = pool.QueryRow(ctx, `SELECT COUNT(*), MIN(received_at), MAX(received_at) FROM emails`). + Scan(&totalMails, &firstMail, &lastMail) + + detail := fmt.Sprintf("%d Mails", totalMails) + if firstMail != nil && lastMail != nil { + detail += fmt.Sprintf(", erste %s, letzte %s", firstMail.Format("2006-01-02"), lastMail.Format("2006-01-02 15:04")) + } + return checkResult{Name: "PostgreSQL", OK: true, Detail: detail, Latency: latency.Round(time.Millisecond).String()} +} + +func checkManticore(cfg *config.Config) checkResult { + dsn := cfg.Index.ManticoreDSN + if dsn == "" { + dsn = "manticore@tcp(127.0.0.1:9306)/" + } + + start := time.Now() + db, err := sql.Open("mysql", dsn) + if err != nil { + return checkResult{Name: "Manticore", OK: false, Detail: fmt.Sprintf("Verbindung fehlgeschlagen: %v", err)} + } + defer db.Close() + + if err := db.Ping(); err != nil { + return checkResult{Name: "Manticore", OK: false, Detail: fmt.Sprintf("Ping fehlgeschlagen: %v", err)} + } + latency := time.Since(start) + + var version string + _ = db.QueryRow(`SHOW STATUS LIKE 'version'`).Scan(new(string), &version) + + detail := "erreichbar" + if version != "" { + detail = "Version " + version + } + return checkResult{Name: "Manticore", OK: true, Detail: detail, Latency: latency.Round(time.Millisecond).String()} +} + +func checkStorage(cfg *config.Config) checkResult { + keyfile := cfg.Storage.Keyfile + data, err := os.ReadFile(keyfile) + if err != nil { + return checkResult{Name: "Storage", OK: false, Detail: fmt.Sprintf("Keyfile %s nicht lesbar: %v", keyfile, err)} + } + raw := strings.TrimSpace(string(data)) + decoded, err := base64.StdEncoding.DecodeString(raw) + if err != nil { + decoded = []byte(raw) + } + if len(decoded) != 32 { + return checkResult{Name: "Storage", OK: false, Detail: fmt.Sprintf("Keyfile %s ergibt %d Bytes, erwartet 32", keyfile, len(decoded))} + } + + storePath := cfg.Storage.StorePath + if _, err := os.Stat(storePath); err != nil { + return checkResult{Name: "Storage", OK: false, Detail: fmt.Sprintf("store_path %s nicht erreichbar: %v", storePath, err)} + } + + var stat syscall.Statfs_t + if err := syscall.Statfs(storePath, &stat); err != nil { + return checkResult{Name: "Storage", OK: false, Detail: fmt.Sprintf("Statfs %s fehlgeschlagen: %v", storePath, err)} + } + total := stat.Blocks * uint64(stat.Bsize) + free := stat.Bavail * uint64(stat.Bsize) + var usedPct float64 + if total > 0 { + usedPct = (1 - float64(free)/float64(total)) * 100 + } + + detail := fmt.Sprintf("%s, %.1f%% belegt, %s frei", storePath, usedPct, formatBytes(free)) + ok := usedPct < 95 + if !ok { + detail += " — Speicherplatz kritisch knapp" + } + return checkResult{Name: "Storage", OK: ok, Detail: detail} +} + +func formatBytes(b uint64) string { + const unit = 1024 + if b < unit { + return fmt.Sprintf("%d B", b) + } + div, exp := uint64(unit), 0 + for n := b / unit; n >= unit; n /= unit { + div *= unit + exp++ + } + return fmt.Sprintf("%.1f %ciB", float64(b)/float64(div), "KMGTPE"[exp]) +} diff --git a/cmd/archivmail/main.go b/cmd/archivmail/main.go index b1d7514..65f7a7c 100644 --- a/cmd/archivmail/main.go +++ b/cmd/archivmail/main.go @@ -70,6 +70,9 @@ func main() { case "update": runUpdate(os.Args[2:]) return + case "status": + runStatus(os.Args[2:]) + return case "version": fmt.Printf("archivmail %s\n", AppVersion) for mod, ver := range Modules {