From 6bb6071ec1dce0cce59df0cb1c38168918061041 Mon Sep 17 00:00:00 2001 From: nsfisis Date: Wed, 7 Aug 2024 22:14:51 +0900 Subject: refactor(backend): move ownership of channel to send task results --- backend/main.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'backend/main.go') diff --git a/backend/main.go b/backend/main.go index e3d0052..62499d6 100644 --- a/backend/main.go +++ b/backend/main.go @@ -61,8 +61,9 @@ func main() { e.Use(middleware.Recover()) taskQueue := taskqueue.NewQueue("task-db:6379") + workerServer := taskqueue.NewWorkerServer("task-db:6379", queries) - gameHubs := game.NewGameHubs(queries, taskQueue) + gameHubs := game.NewGameHubs(queries, taskQueue, workerServer.Results()) err = gameHubs.RestoreFromDB(ctx) if err != nil { log.Fatalf("Error restoring game hubs from db %v", err) @@ -95,9 +96,8 @@ func main() { return c.Redirect(http.StatusPermanentRedirect, "http://localhost:5173/logout") }) - gameHubs.Run() + go gameHubs.Run() - workerServer := taskqueue.NewWorkerServer("task-db:6379", queries, gameHubs.C()) go func() { workerServer.Run() }() -- cgit v1.2.3-70-g09d2