package cmd import ( "context" "database/sql" "embed" "log" "net/http" "os" "os/signal" "syscall" "time" "github.com/hashicorp/go-multierror" "github.com/labstack/echo-contrib/session" "github.com/labstack/echo/v4" "github.com/labstack/echo/v4/middleware" "undef.ninja/x/feedaka/api" "undef.ninja/x/feedaka/auth" "undef.ninja/x/feedaka/config" "undef.ninja/x/feedaka/db" "undef.ninja/x/feedaka/feed" ) func fetchOneFeed(feedID int64, url string, ctx context.Context, queries *db.Queries) error { log.Printf("Fetching %s...\n", url) result, err := feed.Fetch(ctx, url) if err != nil { return err } return feed.Sync(ctx, queries, feedID, result.Feed) } func listFeedsToBeFetched(ctx context.Context, queries *db.Queries) (map[int64]string, error) { feeds, err := queries.GetFeedsToFetch(ctx) if err != nil { return nil, err } result := make(map[int64]string) for _, feed := range feeds { fetchedAtTime, err := time.Parse(time.RFC3339, feed.FetchedAt) if err != nil { log.Fatal(err) } now := time.Now().UTC() if now.Sub(fetchedAtTime).Minutes() <= 10 { continue } result[feed.ID] = feed.Url } return result, nil } func fetchAllFeeds(ctx context.Context, queries *db.Queries) error { feeds, err := listFeedsToBeFetched(ctx, queries) if err != nil { return err } var result *multierror.Error for feedID, url := range feeds { err := fetchOneFeed(feedID, url, ctx, queries) if err != nil { result = multierror.Append(result, err) } time.Sleep(5 * time.Second) } return result.ErrorOrNil() } func scheduled(ctx context.Context, d time.Duration, fn func()) { ticker := time.NewTicker(d) go func() { for { select { case <-ticker.C: fn() case <-ctx.Done(): return } } }() } func RunServe(database *sql.DB, cfg *config.Config, publicFS embed.FS) { err := db.ValidateSchemaVersion(database) if err != nil { log.Fatal(err) } queries := db.New(database) sessionConfig := auth.NewSessionConfig(cfg.SessionSecret, cfg.DevNonSecureCookie) e := echo.New() e.Use(middleware.Logger()) e.Use(middleware.Recover()) e.Use(middleware.CORS()) e.Use(session.Middleware(sessionConfig.GetStore())) e.Use(middleware.StaticWithConfig(middleware.StaticConfig{ HTML5: true, Root: "public", Filesystem: http.FS(publicFS), })) handler := &api.Handler{ DB: database, Queries: queries, SessionConfig: sessionConfig, } strictHandler := api.NewStrictHandler(handler, nil) // Register REST API routes with auth middleware apiGroup := e.Group("", auth.SessionAuthMiddleware(sessionConfig), echoContextMiddleware()) api.RegisterHandlers(apiGroup, strictHandler) ctx, cancel := context.WithCancel(context.Background()) defer cancel() scheduled(ctx, 1*time.Hour, func() { err := fetchAllFeeds(ctx, queries) if err != nil { log.Printf("Failed to fetch feeds: %v\n", err) } }) // Setup graceful shutdown go func() { sigChan := make(chan os.Signal, 1) signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM) <-sigChan log.Println("Shutting down server...") cancel() // Give time for graceful shutdown shutdownCtx, shutdownCancel := context.WithTimeout(context.Background(), 10*time.Second) defer shutdownCancel() if err := e.Shutdown(shutdownCtx); err != nil { log.Printf("Error during shutdown: %v\n", err) } }() log.Printf("Server starting on port %s...\n", cfg.Port) err = e.Start(":" + cfg.Port) if err != nil && err != http.ErrServerClosed { log.Printf("Server error: %v\n", err) } log.Println("Server stopped") } // echoContextMiddleware injects echo.Context into request context // so strict server handlers can access it (needed for session operations) func echoContextMiddleware() echo.MiddlewareFunc { return func(next echo.HandlerFunc) echo.HandlerFunc { return func(c echo.Context) error { ctx := api.WithEchoContext(c.Request().Context(), c) c.SetRequest(c.Request().WithContext(ctx)) return next(c) } } }