Mikkel Elvers
a25e8f1655
* feat: add ffmpeg for hls streaming * feat: torrent streaming with hls transcoding - add nyaa.si torrent search client - add streaming service using anacrolix/torrent - add hls transcoding via ffmpeg for browser playback - add watch page with episode selection - add socks5 proxy support via TORRENT_PROXY env - switch to modernc.org/sqlite (pure go, no cgo conflicts) - update dockerfile with ffmpeg
79 lines
2.7 KiB
Go
79 lines
2.7 KiB
Go
package server
|
|
|
|
import (
|
|
"log/slog"
|
|
"net/http"
|
|
"os"
|
|
|
|
"mal/internal/database"
|
|
"mal/internal/features/anime"
|
|
"mal/internal/features/auth"
|
|
"mal/internal/features/watchlist"
|
|
"mal/internal/jikan"
|
|
"mal/internal/shared/middleware"
|
|
"mal/internal/streaming"
|
|
)
|
|
|
|
type Config struct {
|
|
DB *database.Queries
|
|
JikanClient *jikan.Client
|
|
AuthService *auth.Service
|
|
}
|
|
|
|
func NewRouter(cfg Config) http.Handler {
|
|
mux := http.NewServeMux()
|
|
|
|
authHandler := auth.NewHandler(cfg.AuthService)
|
|
|
|
watchlistSvc := watchlist.NewService(cfg.DB)
|
|
watchlistHandler := watchlist.NewHandler(watchlistSvc)
|
|
|
|
animeSvc := anime.NewService(cfg.JikanClient, cfg.DB)
|
|
animeHandler := anime.NewHandler(animeSvc)
|
|
|
|
logger := slog.New(slog.NewTextHandler(os.Stderr, nil))
|
|
streamSvc, err := streaming.NewService(logger)
|
|
if err != nil {
|
|
panic("failed to initialize streaming service: " + err.Error())
|
|
}
|
|
streamHandler := streaming.NewHandler(streamSvc, cfg.JikanClient)
|
|
|
|
// Serve static files
|
|
fs := http.FileServer(http.Dir("./static"))
|
|
mux.Handle("/static/", http.StripPrefix("/static/", fs))
|
|
|
|
// Anime / Search / Catalog
|
|
mux.HandleFunc("/", animeHandler.HandleCatalog)
|
|
mux.HandleFunc("/search", animeHandler.HandleSearch)
|
|
mux.HandleFunc("/api/search", animeHandler.HandleAPISearch)
|
|
mux.HandleFunc("/api/search-quick", animeHandler.HandleQuickSearch)
|
|
mux.HandleFunc("/api/catalog", animeHandler.HandleAPICatalog)
|
|
mux.HandleFunc("/anime/", animeHandler.HandleAnimeDetails)
|
|
mux.HandleFunc("/api/anime/{id}/relations", animeHandler.HandleAPIAnimeRelations)
|
|
mux.HandleFunc("/api/anime/{id}/episodes", animeHandler.HandleAPIAnimeEpisodes)
|
|
|
|
// Auth Endpoints
|
|
mux.HandleFunc("/login", func(w http.ResponseWriter, r *http.Request) {
|
|
if r.Method == http.MethodGet {
|
|
authHandler.HandleLoginPage(w, r)
|
|
} else {
|
|
authHandler.HandleLogin(w, r)
|
|
}
|
|
})
|
|
mux.HandleFunc("/logout", authHandler.HandleLogout)
|
|
|
|
// Streaming endpoints
|
|
streamHandler.RegisterRoutes(mux)
|
|
|
|
// Watchlist POST endpoint (Protected)
|
|
mux.Handle("/api/watchlist/export", middleware.RequireAuth(http.HandlerFunc(watchlistHandler.HandleExportWatchlist)))
|
|
mux.Handle("/api/watchlist/import", middleware.RequireAuth(http.HandlerFunc(watchlistHandler.HandleImportWatchlist)))
|
|
mux.Handle("/api/watchlist", middleware.RequireAuth(http.HandlerFunc(watchlistHandler.HandleUpdateWatchlist)))
|
|
mux.Handle("/api/watchlist/", middleware.RequireAuth(http.HandlerFunc(watchlistHandler.HandleDeleteWatchlist)))
|
|
mux.Handle("/watchlist", middleware.RequireAuth(http.HandlerFunc(watchlistHandler.HandleGetWatchlist)))
|
|
|
|
// Wrap mux with global auth checking, THEN auth context parsing
|
|
protectedHandler := middleware.RequireGlobalAuth(mux)
|
|
return middleware.Auth(cfg.AuthService)(protectedHandler)
|
|
}
|