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-18 18:18:04 +01:00
parent e9372b8867
commit 855bf6a6e7
4 changed files with 17 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/devices.ml
View file

@ -18,9 +18,9 @@ let db_connection : (env, Caqti_miou.connection) Vif.Device.device =
Logs.info (fun m -> m "database connection initialized"); Logs.info (fun m -> m "database connection initialized");
conn) conn)
let secmod = let keys =
let finally _key = () in let finally _key = () in
Vif.Device.v ~name:"secmod" ~finally [ Vif.Device.value db_connection ] Vif.Device.v ~name:"keys" ~finally [ Vif.Device.value db_connection ]
@@ fun (module Conn : Pg.CONN) (_env : env) -> @@ fun (module Conn : Pg.CONN) (_env : env) ->
let sm : (module Keys.S) = (module Keys.Make (Conn)) in let sm : (module Keys.S) = (module Keys.Make (Conn)) in
sm sm

2
src/http_information.ml
View file

@ -235,7 +235,7 @@ let jsont = ExchangeKeysResponse.jsont
let keys req server _env = let keys req server _env =
Logs.info (fun m -> m "GET /keys"); Logs.info (fun m -> m "GET /keys");
let db_conn = Vif.Server.device Devices.db_connection server in let db_conn = Vif.Server.device Devices.db_connection server in
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server in
let res = let res =
let* last_issue_date = let* last_issue_date =
match Vif.Queries.get req "last_issue_date" with match Vif.Queries.get req "last_issue_date" with

26
src/http_management.ml
View file

@ -22,7 +22,7 @@ module Keys_get = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "GET /management/keys/"); Logs.info (fun m -> m "GET /management/keys/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server in
let res = let res =
let v = mk_future_keys_response keys in let v = mk_future_keys_response keys in
let s = Api.encode_exn jsont v in let s = Api.encode_exn jsont v in
@ -103,7 +103,7 @@ module Keys_post = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/keys/"); Logs.info (fun m -> m "POST /management/keys/");
let db_conn = Vif.Server.device Devices.db_connection server in let db_conn = Vif.Server.device Devices.db_connection server in
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys 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 keys v in let* () = verify keys v in
@ -128,7 +128,7 @@ module Denom_revoke = struct
let f req h_denom_pub server _env = let f req h_denom_pub server _env =
Logs.info (fun m -> m "POST /management/denominations/$H_DENOM_PUB/revoke/"); Logs.info (fun m -> m "POST /management/denominations/$H_DENOM_PUB/revoke/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server in
let res = let res =
let* h_denom_pub = DenominationHash.of_b32 h_denom_pub in let* h_denom_pub = DenominationHash.of_b32 h_denom_pub in
let* v = Vif.Request.of_json req |> unwrap_err_msg in let* v = Vif.Request.of_json req |> unwrap_err_msg in
@ -154,7 +154,7 @@ module Signkey_revoke = struct
let f req exchange_pub server _env = let f req exchange_pub server _env =
Logs.info (fun m -> m "POST /management/signkeys/$EXCHANGE_PUB/revoke/"); Logs.info (fun m -> m "POST /management/signkeys/$EXCHANGE_PUB/revoke/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server in
let res = let res =
let* exchange_pub = Crypto.EddsaPublicKey.of_b32 exchange_pub in let* exchange_pub = Crypto.EddsaPublicKey.of_b32 exchange_pub in
let* v = Vif.Request.of_json req |> unwrap_err_msg in let* v = Vif.Request.of_json req |> unwrap_err_msg in
@ -208,7 +208,7 @@ module Auditors = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/auditors/"); Logs.info (fun m -> m "POST /management/auditors/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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
@ -248,7 +248,7 @@ module Auditors_disable = struct
let f req auditor_pub server _env = let f req auditor_pub server _env =
Logs.info (fun m -> m "POST /management/auditors/$AUDITOR_PUB/revoke/"); Logs.info (fun m -> m "POST /management/auditors/$AUDITOR_PUB/revoke/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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* auditor_pub = Crypto.EddsaPublicKey.of_b32 auditor_pub in let* auditor_pub = Crypto.EddsaPublicKey.of_b32 auditor_pub in
@ -308,7 +308,7 @@ module Wire_fee = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/wire-fee/"); Logs.info (fun m -> m "POST /management/wire-fee/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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
@ -379,7 +379,7 @@ module Global_fees = struct
and once set for a timeframe, it should not change. *) and once set for a timeframe, it should not change. *)
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/global-fees/"); Logs.info (fun m -> m "POST /management/global-fees/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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
@ -458,7 +458,7 @@ module Wire = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/wire/"); Logs.info (fun m -> m "POST /management/wire/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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
@ -493,7 +493,7 @@ module Wire_disable = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/wire/disable/"); Logs.info (fun m -> m "POST /management/wire/disable/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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
@ -533,7 +533,7 @@ module Drain = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/drain/"); Logs.info (fun m -> m "POST /management/drain/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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
@ -573,7 +573,7 @@ module AmlOfficer = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/aml-officers/"); Logs.info (fun m -> m "POST /management/aml-officers/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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
@ -615,7 +615,7 @@ module Partners = struct
let f req server _env = let f req server _env =
Logs.info (fun m -> m "POST /management/partners/"); Logs.info (fun m -> m "POST /management/partners/");
let keys = Vif.Server.device Devices.secmod server in let keys = Vif.Server.device Devices.keys server 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

2
src/mte.ml
View file

@ -76,7 +76,7 @@ let () =
let env : Devices.env = let env : Devices.env =
{ caqti_switch; db_uri= Config.Exchangedb_postgres.config } { caqti_switch; db_uri= Config.Exchangedb_postgres.config }
in in
let devices = Vif.Devices.[ Devices.db_connection; Devices.secmod ] in let devices = Vif.Devices.[ Devices.db_connection; Devices.keys ] in
let middlewares = Vif.Middlewares.[] in let middlewares = Vif.Middlewares.[] in
Logs.info (fun m -> Logs.info (fun m ->
m ~tags:(Util.Log_reporter.detail "...") "Starting MTE server"); m ~tags:(Util.Log_reporter.detail "...") "Starting MTE server");