miniflux_v2/internal/cli/daemon.go

// SPDX-FileCopyrightText: Copyright The Miniflux Authors. All rights reserved.
// SPDX-License-Identifier: Apache-2.0

package cli // import "miniflux.app/v2/internal/cli"

import (
	"context"
	"log/slog"
	"net/http"
	"os"
	"os/signal"
	"syscall"
	"time"

	"miniflux.app/v2/internal/config"
	"miniflux.app/v2/internal/http/server"
	"miniflux.app/v2/internal/metric"
	"miniflux.app/v2/internal/storage"
	"miniflux.app/v2/internal/systemd"
	"miniflux.app/v2/internal/worker"
)

func startDaemon(store *storage.Storage) {
	slog.Debug("Starting daemon...")

	stop := make(chan os.Signal, 1)
	signal.Notify(stop, os.Interrupt)
	signal.Notify(stop, syscall.SIGTERM)

	reload := make(chan os.Signal, 1)
	signal.Notify(reload, syscall.SIGHUP)

	pool := worker.NewPool(store, config.Opts.WorkerPoolSize())

	if config.Opts.HasSchedulerService() && !config.Opts.HasMaintenanceMode() {
		runScheduler(store, pool)
	}

	var httpServers []*http.Server
	var certReloadFn func()
	if config.Opts.HasHTTPService() {
		httpServers, certReloadFn = server.StartWebServer(store, pool)
	}

	metricsCtx, cancelMetrics := context.WithCancel(context.Background())
	if config.Opts.HasMetricsCollector() {
		collector := metric.NewCollector(store, config.Opts.MetricsRefreshInterval())
		go collector.GatherStorageMetrics(metricsCtx)
	}

	if systemd.HasNotifySocket() {
		slog.Debug("Sending readiness notification to Systemd")

		if err := systemd.SdNotify(systemd.SdNotifyReady); err != nil {
			slog.Error("Unable to send readiness notification to systemd", slog.Any("error", err))
		}

		if config.Opts.HasWatchdog() && systemd.HasSystemdWatchdog() {
			slog.Debug("Activating Systemd watchdog")

			go func() {
				interval, err := systemd.WatchdogInterval()
				if err != nil {
					slog.Error("Unable to get watchdog interval from systemd", slog.Any("error", err))
					return
				}

				for {
					if err := store.Ping(); err != nil {
						slog.Error("Unable to ping database", slog.Any("error", err))
					} else {
						systemd.SdNotify(systemd.SdNotifyWatchdog)
					}

					time.Sleep(interval / 3)
				}
			}()
		}
	}

	for {
		select {
		case <-stop:
			slog.Debug("Shutting down the process")
			cancelMetrics()
			ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
			defer cancel()

			if len(httpServers) > 0 {
				slog.Debug("Shutting down HTTP servers...")
				for _, srv := range httpServers {
					if srv != nil {
						if err := srv.Shutdown(ctx); err != nil {
							slog.Error("HTTP server shutdown error", slog.Any("error", err), slog.String("addr", srv.Addr))
						}
					}
				}
				slog.Debug("All HTTP servers shut down.")
			} else {
				slog.Debug("No HTTP servers to shut down.")
			}

			slog.Debug("Shutting down worker pool...")
			pool.Shutdown()
			slog.Debug("Worker pool shut down.")

			slog.Debug("Process gracefully stopped")
			return

		case <-reload:
			slog.Info("Received SIGHUP, reloading TLS certificates")
			if certReloadFn != nil {
				certReloadFn()
			}
		}
	}
}