swrup/mte
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

~

Browse source
This commit is contained in:
swrup 2026-02-03 14:04:05 +01:00
parent 67bd144bb0
commit 28872cb239
3 changed files with 17 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

26
src/pg.ml
View file

@ -128,13 +128,13 @@ let insert_signkey_revocation =
fun (module Conn : CONN) exchange_pub master_sig ->
Conn.exec signkey_revocation_insert (exchange_pub, master_sig)
let lookup_auditor_timestamp =
let lookup_auditor_timestamp =
let get_auditor_timestamp =
let get_auditor_timestamp =
Caqti_type.(eddsa_pub ->? time)
"SELECT last_change FROM auditors WHERE auditor_pub=$1"
in
fun (module Conn : CONN) auditor_pub ->
Conn.find_opt lookup_auditor_timestamp auditor_pub
Conn.find_opt get_auditor_timestamp auditor_pub
let insert_auditor =
let insert_auditor =
@ -265,14 +265,14 @@ let insert_wire_fee =
(wire_method, fee_start, fee_end, wire_fee, closing_fee, master_sig_wire)
let get_wire_fees_by_time =
let lookup_wire_fee_by_time =
let get_wire_fee_by_time =
Caqti_type.(t3 wire_method time time ->* aggregate_transfer_fee)
"SELECT (wire_fee).*, (closing_fee).*, start_date, end_date, master_sig \
FROM wire_fee WHERE wire_method=$1 AND end_date > $2 AND start_date < \
$3"
in
fun (module Conn : CONN) ~wire_method ~start_date ~end_date ->
Conn.collect_list lookup_wire_fee_by_time (wire_method, start_date, end_date)
Conn.collect_list get_wire_fee_by_time (wire_method, start_date, end_date)
let get_wire_fees =
let get_wire_fees =
@ -293,15 +293,15 @@ let get_global_fees =
fun (module Conn : CONN) ~start_date ->
Conn.collect_list get_global_fees start_date
let lookup_global_fees_by_time =
let lookup_global_fees_by_time =
let get_global_fees_by_time =
let get_global_fees_by_time =
Caqti_type.(t2 time time ->* global_fee)
"SELECT start_date, end_date, (history_fee).*, (account_fee).*, \
(purse_fee).*, history_expiration, purse_account_limit, purse_timeout, \
master_sig FROM global_fee WHERE end_date > $1 AND start_date < $2"
in
fun (module Conn : CONN) ~start_date ~end_date ->
Conn.collect_list lookup_global_fees_by_time (start_date, end_date)
Conn.collect_list get_global_fees_by_time (start_date, end_date)
let insert_global_fee =
let insert_global_fee =
@ -313,13 +313,13 @@ let insert_global_fee =
in
fun (module Conn : CONN) v -> Conn.exec insert_global_fee v
let lookup_wire_timestamp =
let lookup_wire_timestamp =
let get_wire_timestamp =
let get_wire_timestamp =
Caqti_type.(payto_uri ->? time)
"SELECT last_change FROM wire_accounts WHERE payto_uri=$1"
in
fun (module Conn : CONN) ~payto_uri ->
Conn.find_opt lookup_wire_timestamp payto_uri
Conn.find_opt get_wire_timestamp payto_uri
let insert_wire =
let insert_wire =
@ -388,7 +388,3 @@ let insert_partner =
$3, $4, ($5,$6), $7, $8) ON CONFLICT DO NOTHING"
in
fun (module Conn : CONN) v -> Conn.exec insert_partner v
(* TODO
get_recoup_denoms
*)