This commit is contained in:
parent
a8541919a8
commit
a978f199ee
2 changed files with 10 additions and 35 deletions
|
|
@ -33,7 +33,7 @@ let mk_keys ~db_conn ~sm ~last_issue_date =
|
||||||
(* todo asset_type
|
(* todo asset_type
|
||||||
Type of the asset. "fiat", "crypto", "regional" or "stock". *)
|
Type of the asset. "fiat", "crypto", "regional" or "stock". *)
|
||||||
let asset_type = "xxx" in
|
let asset_type = "xxx" in
|
||||||
let* accounts = Pg.get_wire_accouts db_conn |> unwrap_err_caqti in
|
let* accounts = Pg.get_wire_accounts db_conn |> unwrap_err_caqti in
|
||||||
let* wire_fees =
|
let* wire_fees =
|
||||||
(* todo
|
(* todo
|
||||||
where does wire_methods comes from? *)
|
where does wire_methods comes from? *)
|
||||||
|
|
|
||||||
43
src/pg.ml
43
src/pg.ml
|
|
@ -624,6 +624,15 @@ let disable_wire =
|
||||||
fun (module Conn : CONN) ~payto_uri ~validity_end ->
|
fun (module Conn : CONN) ~payto_uri ~validity_end ->
|
||||||
Conn.exec disable_wire (payto_uri, validity_end)
|
Conn.exec disable_wire (payto_uri, validity_end)
|
||||||
|
|
||||||
|
let get_wire_accounts =
|
||||||
|
let get_wire_accounts =
|
||||||
|
Caqti_type.(unit ->* exchange_wire_account)
|
||||||
|
"SELECT payto_uri, conversion_url, debit_restrictions::TEXT, \
|
||||||
|
credit_restrictions::TEXT, master_sig, bank_label, priority FROM \
|
||||||
|
wire_accounts WHERE is_active"
|
||||||
|
in
|
||||||
|
fun (module Conn : CONN) -> Conn.collect_list get_wire_accounts ()
|
||||||
|
|
||||||
let insert_drain_profit =
|
let insert_drain_profit =
|
||||||
let insert_drain_profit =
|
let insert_drain_profit =
|
||||||
Caqti_type.(drain_profit_message ->. unit)
|
Caqti_type.(drain_profit_message ->. unit)
|
||||||
|
|
@ -649,40 +658,6 @@ let insert_partner =
|
||||||
in
|
in
|
||||||
fun (module Conn : CONN) v -> Conn.exec insert_partner v
|
fun (module Conn : CONN) v -> Conn.exec insert_partner v
|
||||||
|
|
||||||
let get_wire_accouts =
|
|
||||||
let get_wire_accounts =
|
|
||||||
let master_sig = Bin_sig.MasterWireDetails.caqti in
|
|
||||||
Caqti_type.(
|
|
||||||
unit
|
|
||||||
->* t7 string (option string) account_restrictions account_restrictions
|
|
||||||
master_sig (option string) (option int))
|
|
||||||
"SELECT payto_uri, conversion_url, debit_restrictions::TEXT, \
|
|
||||||
credit_restrictions::TEXT, master_sig, bank_label, priority FROM \
|
|
||||||
wire_accounts WHERE is_active"
|
|
||||||
in
|
|
||||||
fun (module Conn : CONN) ->
|
|
||||||
let open Syntax in
|
|
||||||
let+ l = Conn.collect_list get_wire_accounts () in
|
|
||||||
List.map
|
|
||||||
(fun ( payto_uri,
|
|
||||||
conversion_url,
|
|
||||||
debit_restrictions,
|
|
||||||
credit_restrictions,
|
|
||||||
master_sig,
|
|
||||||
bank_label,
|
|
||||||
priority ) ->
|
|
||||||
ExchangeWireAccount.
|
|
||||||
{
|
|
||||||
payto_uri;
|
|
||||||
conversion_url;
|
|
||||||
debit_restrictions;
|
|
||||||
credit_restrictions;
|
|
||||||
master_sig;
|
|
||||||
bank_label;
|
|
||||||
priority;
|
|
||||||
})
|
|
||||||
l
|
|
||||||
|
|
||||||
(* TODO
|
(* TODO
|
||||||
iterate_denominations
|
iterate_denominations
|
||||||
iterate_active_signkeys
|
iterate_active_signkeys
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue