hooray~~ls

This commit is contained in:
swrup 2026-03-12 19:24:59 +01:00
parent de9119d40b
commit e8f93eb30a

View file

@ -2,13 +2,14 @@
[connect_pool] with parameter [?post_connect] for preflight *)
let db_conn =
let f Env.{ sw; stack; tcp; dns; fs= _ } =
Logs.info (fun m -> m "Connecting to database ...");
let db_uri = Config.Exchangedb_postgres.config in
match Caqti_mnet.connect ~sw stack tcp dns db_uri with
| Error err ->
Fmt.failwith "Database connection failure: %a." Caqti_error.pp err
| Ok conn ->
let () = Pg.preflight conn in
Logs.info (fun m -> m "database connection initialized");
Logs.info (fun m -> m "... connection done.");
conn
in
let finally (module Conn : Pg.CONN) = Conn.disconnect () in