|
| 1 | +// melisai-share-api is the HTTP backend for short share links. |
| 2 | +// |
| 3 | +// It accepts gzip-compressed melisai report payloads on POST /api/r, |
| 4 | +// stores them in a local SQLite database, and serves them back by |
| 5 | +// 8-character short code on GET /api/r/{code}. The static viewer page |
| 6 | +// at https://melisai.dev/r/{code} fetches the payload and renders it |
| 7 | +// client-side. |
| 8 | +// |
| 9 | +// Designed to run as a sidecar next to the melisai-site nginx pod, |
| 10 | +// sharing a PVC for the database file. |
| 11 | +package main |
| 12 | + |
| 13 | +import ( |
| 14 | + "context" |
| 15 | + "errors" |
| 16 | + "flag" |
| 17 | + "fmt" |
| 18 | + "log/slog" |
| 19 | + "net/http" |
| 20 | + "os" |
| 21 | + "os/signal" |
| 22 | + "path/filepath" |
| 23 | + "syscall" |
| 24 | + "time" |
| 25 | + |
| 26 | + "github.com/dmitriimaksimovdevelop/melisai/internal/shareapi" |
| 27 | +) |
| 28 | + |
| 29 | +func main() { |
| 30 | + var ( |
| 31 | + addr = flag.String("addr", ":8080", "HTTP listen address") |
| 32 | + dbPath = flag.String("db", "/var/lib/melisai-share-api/store.db", "SQLite database path") |
| 33 | + publicBase = flag.String("public-base", "https://melisai.dev/r", "Viewer base URL embedded in POST responses") |
| 34 | + maxBodyBytes = flag.Int64("max-body-bytes", shareapi.DefaultMaxBodyBytes, "Max upload size in bytes") |
| 35 | + logLevel = flag.String("log-level", "info", "Log level: debug, info, warn, error") |
| 36 | + retention = flag.Duration("retention", 0, "Delete reports older than this; 0 disables retention (e.g. 2160h for 90 days)") |
| 37 | + cleanupInterval = flag.Duration("cleanup-interval", time.Hour, "How often the retention sweep runs (ignored when --retention=0)") |
| 38 | + ) |
| 39 | + flag.Parse() |
| 40 | + |
| 41 | + logger := newLogger(*logLevel) |
| 42 | + |
| 43 | + if err := shareapi.ValidatePublicBase(*publicBase); err != nil { |
| 44 | + logger.Error("invalid --public-base", "err", err) |
| 45 | + os.Exit(2) |
| 46 | + } |
| 47 | + |
| 48 | + if err := run(*addr, *dbPath, *publicBase, *maxBodyBytes, *retention, *cleanupInterval, logger); err != nil { |
| 49 | + logger.Error("server failed", "err", err) |
| 50 | + os.Exit(1) |
| 51 | + } |
| 52 | +} |
| 53 | + |
| 54 | +func run(addr, dbPath, publicBase string, maxBodyBytes int64, retention, cleanupInterval time.Duration, log *slog.Logger) error { |
| 55 | + if err := os.MkdirAll(filepath.Dir(dbPath), 0o755); err != nil { |
| 56 | + return fmt.Errorf("create db dir: %w", err) |
| 57 | + } |
| 58 | + |
| 59 | + store, err := shareapi.Open(dbPath) |
| 60 | + if err != nil { |
| 61 | + return fmt.Errorf("open store: %w", err) |
| 62 | + } |
| 63 | + defer func() { |
| 64 | + if cerr := store.Close(); cerr != nil { |
| 65 | + log.Error("store close", "err", cerr) |
| 66 | + } |
| 67 | + }() |
| 68 | + |
| 69 | + srv, err := shareapi.NewServer(store, publicBase, maxBodyBytes, log) |
| 70 | + if err != nil { |
| 71 | + return fmt.Errorf("init server: %w", err) |
| 72 | + } |
| 73 | + |
| 74 | + httpSrv := &http.Server{ |
| 75 | + Addr: addr, |
| 76 | + Handler: srv.Handler(), |
| 77 | + ReadHeaderTimeout: 5 * time.Second, |
| 78 | + ReadTimeout: 30 * time.Second, |
| 79 | + WriteTimeout: 30 * time.Second, |
| 80 | + IdleTimeout: 60 * time.Second, |
| 81 | + } |
| 82 | + |
| 83 | + ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM) |
| 84 | + defer stop() |
| 85 | + |
| 86 | + if retention > 0 { |
| 87 | + go runRetention(ctx, store, retention, cleanupInterval, log) |
| 88 | + } |
| 89 | + |
| 90 | + // Buffered so the listen goroutine never blocks on send; we drain |
| 91 | + // in the shutdown branch below to surface a late ListenAndServe |
| 92 | + // error that races with the signal. |
| 93 | + serveErr := make(chan error, 1) |
| 94 | + go func() { |
| 95 | + log.Info("listening", "addr", addr, "db", dbPath, "public_base", publicBase, "retention", retention) |
| 96 | + if err := httpSrv.ListenAndServe(); err != nil && !errors.Is(err, http.ErrServerClosed) { |
| 97 | + serveErr <- err |
| 98 | + } |
| 99 | + }() |
| 100 | + |
| 101 | + select { |
| 102 | + case <-ctx.Done(): |
| 103 | + log.Info("shutdown signal received") |
| 104 | + case err := <-serveErr: |
| 105 | + return fmt.Errorf("listen: %w", err) |
| 106 | + } |
| 107 | + |
| 108 | + shutdownCtx, cancel := context.WithTimeout(context.Background(), 10*time.Second) |
| 109 | + defer cancel() |
| 110 | + if err := httpSrv.Shutdown(shutdownCtx); err != nil { |
| 111 | + return fmt.Errorf("shutdown: %w", err) |
| 112 | + } |
| 113 | + |
| 114 | + // Drain any error that the listen goroutine produced after we |
| 115 | + // already lost the select race. |
| 116 | + select { |
| 117 | + case err := <-serveErr: |
| 118 | + log.Error("late listen error", "err", err) |
| 119 | + default: |
| 120 | + } |
| 121 | + |
| 122 | + log.Info("server stopped") |
| 123 | + return nil |
| 124 | +} |
| 125 | + |
| 126 | +// runRetention drops rows older than `age` on the given interval until |
| 127 | +// ctx is cancelled. The first sweep fires immediately on startup to |
| 128 | +// shrink any backlog from a previous run with longer retention. |
| 129 | +func runRetention(ctx context.Context, store *shareapi.Store, age, interval time.Duration, log *slog.Logger) { |
| 130 | + sweep := func() { |
| 131 | + cutoff := time.Now().Add(-age) |
| 132 | + deleted, err := store.DeleteOlderThan(ctx, cutoff) |
| 133 | + if err != nil { |
| 134 | + log.Error("retention sweep", "err", err) |
| 135 | + return |
| 136 | + } |
| 137 | + if deleted > 0 { |
| 138 | + log.Info("retention sweep", "deleted", deleted, "cutoff", cutoff) |
| 139 | + } |
| 140 | + } |
| 141 | + sweep() |
| 142 | + |
| 143 | + t := time.NewTicker(interval) |
| 144 | + defer t.Stop() |
| 145 | + for { |
| 146 | + select { |
| 147 | + case <-ctx.Done(): |
| 148 | + return |
| 149 | + case <-t.C: |
| 150 | + sweep() |
| 151 | + } |
| 152 | + } |
| 153 | +} |
| 154 | + |
| 155 | +func newLogger(level string) *slog.Logger { |
| 156 | + var lvl slog.Level |
| 157 | + switch level { |
| 158 | + case "debug": |
| 159 | + lvl = slog.LevelDebug |
| 160 | + case "warn": |
| 161 | + lvl = slog.LevelWarn |
| 162 | + case "error": |
| 163 | + lvl = slog.LevelError |
| 164 | + default: |
| 165 | + lvl = slog.LevelInfo |
| 166 | + } |
| 167 | + return slog.New(slog.NewJSONHandler(os.Stdout, &slog.HandlerOptions{Level: lvl})) |
| 168 | +} |
0 commit comments