This commit is contained in:
swrup 2025-12-11 06:50:54 +01:00
parent aae3509581
commit 987c8936a9
4 changed files with 18 additions and 18 deletions

View file

@ -114,15 +114,15 @@ let management_auditors_disable req auditor_pub server _env =
in in
respond_with_res res req respond_with_res res req
let management_wirefee_jsont = WireFeeSetupMessage.jsont let management_wire_fee_jsont = WireFeeSetupMessage.jsont
let management_wirefee req server _env = let management_wire_fee req server _env =
let open Management in let open Management in
let db_conn = Vif.Server.device Devices.db_connection server in let db_conn = Vif.Server.device Devices.db_connection server in
let res = let res =
let* v = Vif.Request.of_json req |> unwrap_err_msg in let* v = Vif.Request.of_json req |> unwrap_err_msg in
let* () = verify_wirefee_setup_sig v in let* () = verify_wire_fee_setup_sig v in
let* () = update_wirefee_setup ~db_conn v in let* () = update_wire_fee_setup ~db_conn v in
Ok "" Ok ""
in in
respond_with_res res req respond_with_res res req

View file

@ -297,7 +297,7 @@ let auditor_disable ~db_conn auditor_pub
in in
() ()
let verify_wirefee_setup_sig let verify_wire_fee_setup_sig
WireFeeSetupMessage. WireFeeSetupMessage.
{ {
wire_method; wire_method;
@ -317,7 +317,7 @@ let verify_wirefee_setup_sig
closing_fee; closing_fee;
} }
let update_wirefee_setup ~db_conn let update_wire_fee_setup ~db_conn
WireFeeSetupMessage. WireFeeSetupMessage.
{ {
wire_method; wire_method;
@ -327,16 +327,16 @@ let update_wirefee_setup ~db_conn
closing_fee; closing_fee;
wire_fee; wire_fee;
} = } =
let* wirefee_opt = let* wire_fee_opt =
Pg.lookup_wirefee_by_time db_conn ~wire_method ~start_date:fee_start Pg.lookup_wire_fee_by_time db_conn ~wire_method ~start_date:fee_start
~end_date:fee_end ~end_date:fee_end
|> unwrap_err_caqti |> unwrap_err_caqti
in in
match wirefee_opt with match wire_fee_opt with
| Some (_wire_fee, _closing_fee) -> Error "wire-fee already setup" | Some (_wire_fee, _closing_fee) -> Error "wire-fee already setup"
| None -> | None ->
let+ () = let+ () =
Pg.insert_wirefee db_conn ~wire_method ~start_date:fee_start Pg.insert_wire_fee db_conn ~wire_method ~start_date:fee_start
~end_date:fee_end ~wire_fee ~closing_fee ~master_sig:master_sig_wire ~end_date:fee_end ~wire_fee ~closing_fee ~master_sig:master_sig_wire
|> unwrap_err_caqti |> unwrap_err_caqti
in in

View file

@ -49,8 +49,8 @@ let routes =
(v "management" / "auditors" /% string `Path / "disable") (v "management" / "auditors" /% string `Path / "disable")
management_auditors_disable_jsont management_auditors_disable_jsont
--> management_auditors_disable; --> management_auditors_disable;
post (v "management" / "wire-fee") management_wirefee_jsont post (v "management" / "wire-fee") management_wire_fee_jsont
--> management_wirefee; --> management_wire_fee;
post (v "management" / "global-fees") management_global_fees_jsont post (v "management" / "global-fees") management_global_fees_jsont
--> management_global_fees; --> management_global_fees;
] ]

View file

@ -221,17 +221,17 @@ let update_auditor =
Conn.exec update_auditor Conn.exec update_auditor
(auditor_pub, auditor_url, auditor_name, enabled, change_date) (auditor_pub, auditor_url, auditor_name, enabled, change_date)
let lookup_wirefee_by_time = let lookup_wire_fee_by_time =
let lookup_wirefee_by_time = let lookup_wire_fee_by_time =
Caqti_type.(t3 wire_method time time ->? t2 amount amount) Caqti_type.(t3 wire_method time time ->? t2 amount amount)
"SELECT (wire_fee).*, (closing_fee).* FROM wire_fee WHERE wire_method=$1 \ "SELECT (wire_fee).*, (closing_fee).* FROM wire_fee WHERE wire_method=$1 \
AND end_date > $2 AND start_date < $3" AND end_date > $2 AND start_date < $3"
in in
fun (module Conn : CONN) ~wire_method ~start_date ~end_date -> fun (module Conn : CONN) ~wire_method ~start_date ~end_date ->
Conn.find_opt lookup_wirefee_by_time (wire_method, start_date, end_date) Conn.find_opt lookup_wire_fee_by_time (wire_method, start_date, end_date)
let insert_wirefee = let insert_wire_fee =
let insert_wirefee = let insert_wire_fee =
let master_sig = Bin_sig.MasterWireFee.caqti in let master_sig = Bin_sig.MasterWireFee.caqti in
Caqti_type.(t6 wire_method time time amount amount master_sig ->. unit) Caqti_type.(t6 wire_method time time amount amount master_sig ->. unit)
"INSERT INTO wire_fee (wire_method, start_date, end_date, wire_fee, \ "INSERT INTO wire_fee (wire_method, start_date, end_date, wire_fee, \
@ -245,7 +245,7 @@ let insert_wirefee =
~closing_fee ~closing_fee
~master_sig ~master_sig
-> ->
Conn.exec insert_wirefee Conn.exec insert_wire_fee
(wire_method, start_date, end_date, wire_fee, closing_fee, master_sig) (wire_method, start_date, end_date, wire_fee, closing_fee, master_sig)
let lookup_global_fee_by_time = let lookup_global_fee_by_time =