diff options
| author | nsfisis <nsfisis@gmail.com> | 2024-08-05 05:35:45 +0900 |
|---|---|---|
| committer | nsfisis <nsfisis@gmail.com> | 2024-08-05 05:35:45 +0900 |
| commit | b0ff29a3c88bd3014cc966c619683c8d7e33d703 (patch) | |
| tree | 529f1debc2972ac1486e8c0ca4b25827ccd069a6 /backend/main.go | |
| parent | 9ff9c151e5defd9eed5cba3c88bc341b4360d09c (diff) | |
| parent | dc16e903999af89d87364ad6619e7c8b41301da4 (diff) | |
| download | phperkaigi-2025-albatross-b0ff29a3c88bd3014cc966c619683c8d7e33d703.tar.gz phperkaigi-2025-albatross-b0ff29a3c88bd3014cc966c619683c8d7e33d703.tar.zst phperkaigi-2025-albatross-b0ff29a3c88bd3014cc966c619683c8d7e33d703.zip | |
Merge branch 'feat/task-queue'
Diffstat (limited to 'backend/main.go')
| -rw-r--r-- | backend/main.go | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/backend/main.go b/backend/main.go index e2e4bbd..e3d0052 100644 --- a/backend/main.go +++ b/backend/main.go @@ -15,6 +15,7 @@ import ( "github.com/nsfisis/iosdc-japan-2024-albatross/backend/api" "github.com/nsfisis/iosdc-japan-2024-albatross/backend/db" "github.com/nsfisis/iosdc-japan-2024-albatross/backend/game" + "github.com/nsfisis/iosdc-japan-2024-albatross/backend/taskqueue" ) func connectDB(ctx context.Context, dsn string) (*pgxpool.Pool, error) { @@ -59,7 +60,9 @@ func main() { e.Use(middleware.Logger()) e.Use(middleware.Recover()) - gameHubs := game.NewGameHubs(queries) + taskQueue := taskqueue.NewQueue("task-db:6379") + + gameHubs := game.NewGameHubs(queries, taskQueue) err = gameHubs.RestoreFromDB(ctx) if err != nil { log.Fatalf("Error restoring game hubs from db %v", err) @@ -94,6 +97,11 @@ func main() { gameHubs.Run() + workerServer := taskqueue.NewWorkerServer("task-db:6379", queries, gameHubs.C()) + go func() { + workerServer.Run() + }() + if err := e.Start(":80"); err != http.ErrServerClosed { log.Fatal(err) } |