refactor(main): Phase 6 - instantiate new handlers in main.go
- Create worker for background tasks (3 concurrent workers) - Create CollectionHandler for collection endpoints - Create MediaHandler with worker for media CRUD operations - Create SearchHandler for query operations - Create MatchingHandler for book matching/linking operations - Update routerConfig to include new handlers instead of EbookHandler All handlers properly initialized and passed to router package. System is fully operational with new handler architecture. This is Phase 6 of the ebook.go refactoring plan.
This commit is contained in:
@@ -94,6 +94,9 @@ func main() {
|
|||||||
queueProcessor := sync.NewSyncQueueProcessor(queries)
|
queueProcessor := sync.NewSyncQueueProcessor(queries)
|
||||||
go queueProcessor.Start(context.Background())
|
go queueProcessor.Start(context.Background())
|
||||||
|
|
||||||
|
// Create worker for background tasks
|
||||||
|
worker := services.NewWorker(3)
|
||||||
|
|
||||||
koreaderHandler := handlers.NewKOReaderHandler(queries, connManager, queueProcessor)
|
koreaderHandler := handlers.NewKOReaderHandler(queries, connManager, queueProcessor)
|
||||||
wsHandler := handlers.NewWSHandler(queries, connManager, cfg.JWTSecret, deviceAuthMiddleware)
|
wsHandler := handlers.NewWSHandler(queries, connManager, cfg.JWTSecret, deviceAuthMiddleware)
|
||||||
conflictHandler := handlers.NewConflictHandler(queries, connManager)
|
conflictHandler := handlers.NewConflictHandler(queries, connManager)
|
||||||
@@ -104,6 +107,12 @@ func main() {
|
|||||||
conversionService := services.NewConversionService(queries, "/var/bookhoard/cache/kepub")
|
conversionService := services.NewConversionService(queries, "/var/bookhoard/cache/kepub")
|
||||||
opdsHandler := handlers.NewOPDSHandler(queries, conversionService)
|
opdsHandler := handlers.NewOPDSHandler(queries, conversionService)
|
||||||
|
|
||||||
|
// NEW: Create refactored handlers
|
||||||
|
collectionHandler := handlers.NewCollectionHandler(queries, connManager)
|
||||||
|
mediaHandler := handlers.NewMediaHandler(queries, worker)
|
||||||
|
searchHandler := handlers.NewSearchHandler(queries)
|
||||||
|
matchingHandler := handlers.NewMatchingHandler(queries, connManager)
|
||||||
|
|
||||||
e := echo.New()
|
e := echo.New()
|
||||||
|
|
||||||
// Set up validator
|
// Set up validator
|
||||||
@@ -142,11 +151,15 @@ func main() {
|
|||||||
AuthHandler: authHandler,
|
AuthHandler: authHandler,
|
||||||
LibraryHandler: libraryHandler,
|
LibraryHandler: libraryHandler,
|
||||||
DeviceHandler: deviceHandler,
|
DeviceHandler: deviceHandler,
|
||||||
|
MediaHandler: mediaHandler,
|
||||||
|
SearchHandler: searchHandler,
|
||||||
|
MatchingHandler: matchingHandler,
|
||||||
KOReaderHandler: koreaderHandler,
|
KOReaderHandler: koreaderHandler,
|
||||||
WSHandler: wsHandler,
|
WSHandler: wsHandler,
|
||||||
ConflictHandler: conflictHandler,
|
ConflictHandler: conflictHandler,
|
||||||
AnalyticsHandler: analyticsHandler,
|
AnalyticsHandler: analyticsHandler,
|
||||||
QueueHandler: queueHandler,
|
QueueHandler: queueHandler,
|
||||||
|
CollectionHandler: collectionHandler,
|
||||||
OPDSHandler: opdsHandler,
|
OPDSHandler: opdsHandler,
|
||||||
ConnManager: connManager,
|
ConnManager: connManager,
|
||||||
QueueProcessor: queueProcessor,
|
QueueProcessor: queueProcessor,
|
||||||
|
|||||||
Reference in New Issue
Block a user