This commit is contained in:
parent
8436d7eb5f
commit
64f2d2a10a
1 changed files with 2 additions and 2 deletions
|
|
@ -381,12 +381,12 @@ module Wire_fee = struct
|
||||||
}
|
}
|
||||||
|
|
||||||
let do_ ~db_conn (v : WireFeeSetupMessage.t) =
|
let do_ ~db_conn (v : WireFeeSetupMessage.t) =
|
||||||
let* wire_fee_opt =
|
let* wire_fees =
|
||||||
Pg.get_wire_fees_by_time db_conn ~wire_method:v.wire_method
|
Pg.get_wire_fees_by_time db_conn ~wire_method:v.wire_method
|
||||||
~start_date:v.fee_start ~end_date:v.fee_end
|
~start_date:v.fee_start ~end_date:v.fee_end
|
||||||
|> unwrap_err_caqti
|
|> unwrap_err_caqti
|
||||||
in
|
in
|
||||||
match wire_fee_opt with
|
match wire_fees with
|
||||||
| [] ->
|
| [] ->
|
||||||
let+ () = Pg.insert_wire_fee db_conn v |> unwrap_err_caqti in
|
let+ () = Pg.insert_wire_fee db_conn v |> unwrap_err_caqti in
|
||||||
()
|
()
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue