Bookhoard/bookhoard
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 12 Wiki Activity

refactor: inject ConnectionManager into Worker

Browse Source 
Pass ConnectionManager to Worker constructor to enable WebSocket
broadcasting capabilities. Updated:
- main.go: server initialization
- test_helpers.go: test setup
- commonhandlers.go: handler initialization

This change enables Worker to broadcast job updates to connected clients.
This commit is contained in:
john-okeefe
2026-03-05 17:13:26 -05:00
parent 39a87ddabc
commit ab11eade68
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/server/main.go
+1 -1
View File
@@ -105,7 +105,7 @@ func main() {
libraryService := services.NewLibraryService(queries) libraryService := services.NewLibraryService(queries)
// Create worker for background tasks // Create worker for background tasks
worker := services.NewWorker(3) worker := services.NewWorker(3, connManager)
services.WorkerInstance = worker services.WorkerInstance = worker
koreaderHandler := handlers.NewKOReaderHandler(queries, connManager, queueProcessor) koreaderHandler := handlers.NewKOReaderHandler(queries, connManager, queueProcessor)
cmd/server/tests/test_helpers.go
+1 -1
View File
@@ -458,7 +458,7 @@ func setupTestServer(t *testing.T) *TestServerSetup {
// Create refactored handlers (matching main.go) // Create refactored handlers (matching main.go)
libraryService := services.NewLibraryService(queries) libraryService := services.NewLibraryService(queries)
worker := services.NewWorker(3) worker := services.NewWorker(3, connManager)
collectionHandler := handlers.NewCollectionHandler(queries, libraryService, connManager) collectionHandler := handlers.NewCollectionHandler(queries, libraryService, connManager)
dashboardService := services.NewDashboardService(queries) dashboardService := services.NewDashboardService(queries)
dashboardHandler := handlers.NewDashboardHandler(queries) dashboardHandler := handlers.NewDashboardHandler(queries)
internal/handlers/commonhandlers.go
+1 -1
View File
@@ -32,7 +32,7 @@ type Handler struct {
func NewHandler(db *database.Queries, connManager *wsync.ConnectionManager, queueProcessor *wsync.SyncQueueProcessor, cfg *config.Config) *Handler { func NewHandler(db *database.Queries, connManager *wsync.ConnectionManager, queueProcessor *wsync.SyncQueueProcessor, cfg *config.Config) *Handler {
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
worker := services.NewWorker(3) worker := services.NewWorker(3, connManager)
queueCtx, queueCancel := context.WithCancel(context.Background()) queueCtx, queueCancel := context.WithCancel(context.Background())