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

add caqti device

Browse source
This commit is contained in:
swrup 2025-11-11 03:12:12 +01:00
parent 606d2a6045
commit 4749bb7c62
7 changed files with 83 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

20
src/devices.ml
View file

@ -1,5 +1,10 @@
(* TODO KV store *)
type env = {
caqti_switch: Caqti_miou.Switch.t;
db_uri: Uri.t;
}
module Secmod_signkey = struct
type t = {
sm_key: Signkey.t;
@ -8,7 +13,7 @@ module Secmod_signkey = struct
let v =
let finally _key = () in
Vif.Device.v ~name:"secmod_signkey" ~finally [] @@ fun () ->
Vif.Device.v ~name:"secmod_signkey" ~finally [] @@ fun (_env : env) ->
let sm_key = Signkey.generate () in
let keys = [ Signkey.generate () ] in
{ sm_key; keys }
@ -22,7 +27,7 @@ module Secmod_denom = struct
let v =
let finally _key = () in
Vif.Device.v ~name:"secmod_denom" ~finally [] @@ fun () ->
Vif.Device.v ~name:"secmod_denom" ~finally [] @@ fun (_env : env) ->
let sm_key = Signkey.generate () in
let keys = List.map Denomination.make Config.coins in
{ sm_key; keys }
@ -30,3 +35,14 @@ end
let secmod_signkey = Secmod_signkey.v
let secmod_denom = Secmod_denom.v
let caqti :
( env,
(Caqti_miou.connection, Caqti_error.t) Caqti_miou_unix.Pool.t )
Vif.Device.device =
let finally pool = Caqti_miou_unix.Pool.drain pool in
Vif.Device.v ~name:"caqti" ~finally [] @@ fun { caqti_switch; db_uri } ->
match Caqti_miou_unix.connect_pool ~sw:caqti_switch db_uri with
| Error err ->
Fmt.failwith "Database connection failure: %a." Caqti_error.pp err
| Ok pool -> pool