fd5e62e23b
* experimental livestrea support * test livestream * update wait time detection * update livestream functions * persist and restore livestreams monitor session * fan-in logging * deps update * added live time display * livestream monitor prototype * changed to default logger instead of passing *slog.Logger everywhere * code refactoring, comments
34 lines
877 B
Go
34 lines
877 B
Go
package rpc
|
|
|
|
import (
|
|
"github.com/go-chi/chi/v5"
|
|
"github.com/marcopeocchi/yt-dlp-web-ui/server/config"
|
|
"github.com/marcopeocchi/yt-dlp-web-ui/server/internal"
|
|
"github.com/marcopeocchi/yt-dlp-web-ui/server/internal/livestream"
|
|
middlewares "github.com/marcopeocchi/yt-dlp-web-ui/server/middleware"
|
|
"github.com/marcopeocchi/yt-dlp-web-ui/server/openid"
|
|
)
|
|
|
|
// Dependency injection container.
|
|
func Container(db *internal.MemoryDB, mq *internal.MessageQueue, lm *livestream.Monitor) *Service {
|
|
return &Service{
|
|
db: db,
|
|
mq: mq,
|
|
lm: lm,
|
|
}
|
|
}
|
|
|
|
// RPC service must be registered before applying this router!
|
|
func ApplyRouter() func(chi.Router) {
|
|
return func(r chi.Router) {
|
|
if config.Instance().RequireAuth {
|
|
r.Use(middlewares.Authenticated)
|
|
}
|
|
if config.Instance().UseOpenId {
|
|
r.Use(openid.Middleware)
|
|
}
|
|
r.Get("/ws", WebSocket)
|
|
r.Post("/http", Post)
|
|
}
|
|
}
|