fix: reuse PGO connection across the codebase

Signed-off-by: Guillaume Hivert <[email protected]>

apps/backend/src/backend.gleam

@@ -1,4 +1,4 @@
-import backend/config.{type Config}
+import backend/config.{type Context}
 import backend/postgres/postgres
 import backend/router
 import dot_env
@@ -30,7 +30,7 @@ pub fn main() {
 
   let assert Ok(_) =
     supervisor.start(fn(children) {
-      let assert Ok(_) = start_hex_sync(cnf, children)
+      let assert Ok(_) = start_hex_sync(ctx, children)
       children
     })
 
@@ -45,14 +45,11 @@ fn supervise(start: fn() -> _) {
   })
 }
 
-fn sync_hex(cnf: Config, children: supervisor.Children(Nil)) {
-  hex.sync_new_gleam_releases(cnf, children)
+fn sync_hex(ctx: Context, children: supervisor.Children(Nil)) {
+  hex.sync_new_gleam_releases(ctx, children)
 }
 
-fn start_hex_sync(cnf: Config, children: supervisor.Children(Nil)) {
+fn start_hex_sync(ctx: Context, children: supervisor.Children(Nil)) {
   use <- supervise()
-  periodic.periodically(
-    do: fn() { sync_hex(cnf, children) },
-    waiting: 60 * 1000,
-  )
+  periodic.periodically(do: fn() { sync_hex(ctx, children) }, waiting: 6 * 1000)
 }

apps/backend/src/tasks/hex.gleam

@@ -1,11 +1,10 @@
 import api/hex as api
 import api/hex_repo
 import api/signatures
-import backend/config.{type Config, type Context}
+import backend/config.{type Context}
 import backend/data/hex_read.{type HexRead}
 import backend/error.{type Error}
 import backend/gleam/context
-import backend/postgres/postgres
 import backend/postgres/queries
 import birl.{type Time}
 import birl/duration
@@ -34,18 +33,17 @@ type State {
 }
 
 pub fn sync_new_gleam_releases(
-  cnf: Config,
+  ctx: Context,
   children: supervisor.Children(Nil),
 ) -> Result(HexRead, Error) {
-  let ctx = postgres.connect(cnf)
   wisp.log_info("Syncing new releases from Hex")
   use limit <- result.try(queries.get_last_hex_date(ctx.db))
   use latest <- result.try(sync_packages(
     State(
       page: 1,
       limit: limit,
       newest: limit,
-      hex_api_key: cnf.hex_api_key,
+      hex_api_key: ctx.hex_api_key,
       last_logged: birl.now(),
       db: ctx.db,
     ),
@@ -54,7 +52,6 @@ pub fn sync_new_gleam_releases(
   let latest = queries.upsert_most_recent_hex_timestamp(ctx.db, latest)
   wisp.log_info("")
   wisp.log_info("Up to date!")
-  pgo.disconnect(ctx.db)
   latest
 }