From 85ef0d05bf39ffa9c15afe37aec144673c5cd2aa Mon Sep 17 00:00:00 2001 From: swrup Date: Thu, 11 Dec 2025 09:54:40 +0100 Subject: [PATCH] --- src/pg.ml | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/src/pg.ml b/src/pg.ml index 7403b79e..acaba787 100644 --- a/src/pg.ml +++ b/src/pg.ml @@ -13,6 +13,7 @@ module type CONN = Caqti_miou.CONNECTION open Crypto open Bin_type +open Api module Caqti_type = struct include Caqti_type @@ -205,7 +206,7 @@ let insert_auditor = is_active, last_change) VALUES ($1, $2, $3, true, $4)" in fun (module Conn : CONN) - Api.AuditorSetupMessage. + AuditorSetupMessage. { auditor_url; auditor_name; auditor_pub; master_sig= _; validity_start } -> Conn.exec insert_auditor @@ -218,7 +219,7 @@ let update_auditor = last_change=$5 WHERE auditor_pub=$1" in fun (module Conn : CONN) - Api.AuditorSetupMessage. + AuditorSetupMessage. { auditor_url; auditor_name; auditor_pub; master_sig= _; validity_start } -> Conn.exec update_auditor @@ -285,7 +286,7 @@ let insert_global_fee = $12)" in fun (module Conn : CONN) - Api.GlobalFees. + GlobalFees. { start_date; end_date; @@ -330,7 +331,7 @@ let insert_wire = ($1,$2,$3::TEXT::JSONB,$4::TEXT::JSONB,$5,true,$6,$7,$8)" in fun (module Conn : CONN) - Api.WireSetupMessage. + WireSetupMessage. { payto_uri; master_sig_wire; @@ -368,7 +369,7 @@ let update_wire = bank_label=$8, priority=$9 WHERE payto_uri=$1" in fun (module Conn : CONN) - Api.WireSetupMessage. + WireSetupMessage. { payto_uri; master_sig_wire; @@ -417,7 +418,7 @@ let insert_drain_profit = trigger_date, amount, master_sig) VALUES ($1, $2, $3, $4, ($5,$6), $7)" in fun (module Conn : CONN) - Api.DrainProfitsMessage. + DrainProfitsMessage. { debit_account_section; credit_payto_uri; @@ -438,7 +439,7 @@ let insert_aml_officer = $4, $5, $6)" in fun (module Conn : CONN) - Api.AmlOfficerSetup. + AmlOfficerSetup. { officer_pub; officer_name; @@ -461,7 +462,7 @@ let insert_partner = $3, $4, ($5,$6), $7, $8) ON CONFLICT DO NOTHING" in fun (module Conn : CONN) - Api.ExchangePartnerSetupRequest. + ExchangePartnerSetupRequest. { partner_base_url; partner_pub;