From c6989be4c74ad88da2ef18f2d23dd6c87b38ea9a Mon Sep 17 00:00:00 2001 From: swrup Date: Thu, 12 Mar 2026 14:03:27 +0100 Subject: [PATCH] --- src/mte.ml | 25 +++---------------------- 1 file changed, 3 insertions(+), 22 deletions(-) diff --git a/src/mte.ml b/src/mte.ml index 8319900a..4c3ca802 100644 --- a/src/mte.ml +++ b/src/mte.ml @@ -64,23 +64,6 @@ let routes = in tos @ status_info @ management -let caqti_get_ok = function - | Error e -> Fmt.failwith "%a" Caqti_error.pp e - | Ok v -> v - -let test (module Conn : Caqti_miou.CONNECTION) = - let minus_req = - let open Caqti_request.Infix in - let open Caqti_type in - (t2 int int ->! int) "SELECT ? - ?" - in - let a = 22 in - let b = 17 in - let c = Conn.find minus_req (22, 17) |> caqti_get_ok in - assert (a - b = c); - Logs.app (fun f -> f "%d - %d = %d" a b c); - () - module RNG = Mirage_crypto_rng.Fortuna let () = @@ -104,7 +87,7 @@ let () = let dns = Mnet_dns.create (udp, he) in let t = Mnet_dns.transport dns in let@ () = fun () -> Mnet_dns.Transport.kill t in - + (* -- *) Caqti_miou.Switch.run @@ fun sw -> let db_conn = let db_uri = Config.Exchangedb_postgres.config in @@ -115,13 +98,12 @@ let () = in let@ () = fun () -> - let (module Conn : Caqti_miou.CONNECTION) = db_conn in + let (module Conn : Pg.CONN) = db_conn in Conn.disconnect () in - let () = Pg.preflight db_conn in Logs.info (fun m -> m "database connection initialized"); - + (* -- *) let keys : (module Keys.S) = let (module Conn : Pg.CONN) = db_conn in let (module Fs : Fat.FS) = @@ -131,7 +113,6 @@ let () = in (module Keys.Make (Conn) (Fs)) in - (* -- *) let cfg = Vifu.Config.v Config.Exchange.port in Vifu.run ~cfg tcp routes (db_conn, keys)