fix sk init, use future_sk

This commit is contained in:
swrup 2026-02-17 09:30:20 +01:00
parent 77d5327745
commit 43fd85b827
13 changed files with 466 additions and 537 deletions

View file

View file

@ -922,6 +922,19 @@ module SignKey = struct
master_sig: ExchangeSigningKeyValidity.t; master_sig: ExchangeSigningKeyValidity.t;
} }
(* TODO rm one of them *)
let of_signkey
Signkey.
{
pub;
stamp_start;
stamp_expire;
stamp_end;
master_sig;
revoked_sig= _;
} =
{ key= pub; stamp_start; stamp_expire; stamp_end; master_sig }
let jsont = let jsont =
let make key stamp_start stamp_expire stamp_end master_sig = let make key stamp_start stamp_expire stamp_end master_sig =
{ key; stamp_start; stamp_expire; stamp_end; master_sig } { key; stamp_start; stamp_expire; stamp_end; master_sig }

View file

@ -2,6 +2,7 @@ open Parse_config
let config_filename = "mte.conf" let config_filename = "mte.conf"
let secrets_dir = Fpath.v "secrets" let secrets_dir = Fpath.v "secrets"
let secmod_dir = Fpath.(secrets_dir / "secmod")
let config_data = let config_data =
match Assets_crunch.read config_filename with match Assets_crunch.read config_filename with

View file

@ -269,7 +269,7 @@ type eddsa_sig = EddsaSignature.t
type rsa_priv = RsaPrivateKey.t type rsa_priv = RsaPrivateKey.t
type rsa_pub = RsaPublicKey.t type rsa_pub = RsaPublicKey.t
type rsa_sig = RsaSignature.t type rsa_sig = RsaSignature.t
type denomination_hash = Hash.DenominationHash.t type denom_hash = Hash.DenominationHash.t
(* WIP *) (* WIP *)
module FDH_RSA = struct module FDH_RSA = struct

View file

@ -2,34 +2,20 @@ open Bos.OS
open Syntax open Syntax
open Crypto open Crypto
let read fname = let read fname = File.read fname |> unwrap_err_msg
let* b = File.exists fname |> Syntax.unwrap_err_msg in
match b with
| false -> Ok None
| true ->
let+ content = File.read fname |> Syntax.unwrap_err_msg in
Some content
let write_eddsa fname priv = let write_eddsa fname priv =
EddsaPrivateKey.to_octets priv |> File.write fname |> Syntax.unwrap_err_msg EddsaPrivateKey.to_octets priv |> File.write fname |> unwrap_err_msg
let write_rsa fname priv = let write_rsa fname priv =
RsaPrivateKey.to_octets priv |> File.write fname |> Syntax.unwrap_err_msg RsaPrivateKey.to_octets priv |> File.write fname |> unwrap_err_msg
let read_eddsa fname = let read_eddsa fname =
let* opt = read fname in let* data = read fname in
match opt with let+ v = EddsaPrivateKey.of_octets data in
| None -> Ok None v
| Some data -> (
EddsaPrivateKey.of_octets data |> function
| Error e -> Error e
| Ok v -> Ok (Some v))
let read_rsa fname = let read_rsa fname =
let* opt = read fname in let* data = read fname in
match opt with let+ v = RsaPrivateKey.of_octets data in
| None -> Ok None v
| Some data -> (
RsaPrivateKey.of_octets data |> function
| Error e -> Error e
| Ok v -> Ok (Some v))

View file

@ -12,7 +12,7 @@ type t = {
fee_refresh: Amount.t; fee_refresh: Amount.t;
fee_refund: Amount.t; fee_refund: Amount.t;
age_mask: int; age_mask: int;
h_pub: denomination_hash; h_pub: denom_hash;
master_sig: Signatures.DenominationKeyValidity.t option; master_sig: Signatures.DenominationKeyValidity.t;
revoked_sig: Signatures.MasterDenominationKeyRevocation.t option; revoked_sig: Signatures.MasterDenominationKeyRevocation.t option;
} }

View file

@ -24,7 +24,7 @@ let config req _server _env =
for now we only have one item in each "denom group" for now we only have one item in each "denom group"
change this once we have denom/signkey rotation *) change this once we have denom/signkey rotation *)
let denomgroup_of_denomdata let denomgroup_of_denomdata
Denom_data. Denomination.
{ {
pub; pub;
value; value;
@ -41,7 +41,6 @@ let denomgroup_of_denomdata
master_sig; master_sig;
revoked_sig= _; revoked_sig= _;
} = } =
let master_sig = match master_sig with None -> assert false | Some v -> v in
let denoms = let denoms =
[ [
RsaDenom. RsaDenom.
@ -112,92 +111,66 @@ let mk_keys ~db_conn (module Sm : Secmod.S) ~last_issue_date =
let wallet_balance_limit_without_kyc = None in let wallet_balance_limit_without_kyc = None in
let hard_limits = [] in let hard_limits = [] in
let zero_limits = [] in let zero_limits = [] in
let denom_data_l = let dn_l =
(* TODO sm-db *)
(*Pg.get_denominations db_conn |> unwrap_err_caqti *) (*Pg.get_denominations db_conn |> unwrap_err_caqti *)
Sm.get_denoms_data () Sm.get_denominations ()
in |>
let denom_data_l =
(* reverse chronological order *) (* reverse chronological order *)
List.sort List.sort (fun a b ->
(fun a b -> Stdlib.compare b.Denom_data.stamp_start a.stamp_start) Stdlib.compare b.Denomination.stamp_start a.stamp_start)
denom_data_l
in in
let list_issue_date = let list_issue_date =
match denom_data_l with match dn_l with
| [] -> Time.Timestamp.never | [] -> Timestamp.never
| v :: _ -> v.Denom_data.stamp_start | dn :: _ -> dn.Denomination.stamp_start
in in
let denominations = let denominations =
let open Denom_data in
(* if `?last_issue_date` query param does not exactly match the `stamp_start` (* if `?last_issue_date` query param does not exactly match the `stamp_start`
of one of the denomination keys, all keys are returned *) of one of the denomination keys, all keys are returned *)
let open Denomination in
let l = let l =
match last_issue_date with match last_issue_date with
| None -> denom_data_l | None -> dn_l
| Some last_issue_date -> ( | Some last_issue_date -> (
match match
List.find_opt List.find_opt
(fun v -> (fun v -> Timestamp.compare v.stamp_start last_issue_date = 0)
Time.Timestamp.compare v.stamp_start last_issue_date = 0) dn_l
denom_data_l
with with
| None -> denom_data_l | None -> dn_l
| Some _ -> | Some _ ->
List.filter List.filter
(fun v -> (fun v ->
Time.Timestamp.compare v.stamp_start last_issue_date >= 0) Time.Timestamp.compare v.stamp_start last_issue_date >= 0)
denom_data_l) dn_l)
in in
List.map denomgroup_of_denomdata l List.map denomgroup_of_denomdata l
in in
let signkeys = let signkeys =
(* TODO sm-db
use database signkey data / verify secmod and database are in sync *)
(* (*
let now = Ptime_clock.now () |> Option.some in let now = Ptime_clock.now () |> Option.some in
let+ signkey_data_l = Pg.get_active_signkeys db_conn ~now |> unwrap_err_caqti in*) let+ signkey_data_l = Pg.get_active_signkeys db_conn ~now |> unwrap_err_caqti in*)
let signkey_data_l = Sm.get_signkeys_data () in Sm.get_signkeys ()
let signkey_data_l = |> List.sort (fun a b ->
List.sort let open Signkey in
(fun a b -> Stdlib.compare b.stamp_start a.stamp_start)
let open Signkey_data in |> List.map Api.SignKey.of_signkey
Stdlib.compare b.stamp_start a.stamp_start)
signkey_data_l
in
List.filter_map
(fun Signkey_data.
{
pub;
stamp_start;
stamp_expire;
stamp_end;
master_sig;
revoked_sig= _;
} ->
match master_sig with
| None -> None
| Some master_sig ->
Some
SignKey.
{ key= pub; stamp_start; stamp_expire; stamp_end; master_sig })
signkey_data_l
in in
let exchange_pub = let exchange_pub =
(* the eddsa pub key used to sign exchange_sig *) (* the eddsa pub key used to sign exchange_sig *)
match signkeys with match signkeys with
| [] -> Fmt.failwith "exchange has no active signkey" | [] -> Fmt.failwith "exchange has no active signkey"
| v :: _ -> v.SignKey.key | sk :: _ -> sk.SignKey.key
in in
let exchange_sig = let exchange_sig =
(* Compact EdDSA signature (binary-only) over the (* Compact EdDSA signature (binary-only) over the
contatentation of all of the master_sigs (in reverse contatentation of all of the master_sigs (in reverse
chronological order by group) in the arrays under "denominations". *) chronological order by group) in the arrays under "denominations". *)
let hc = let hc =
denom_data_l dn_l
|> List.filter_map (fun v -> v.Denom_data.master_sig) |> List.map (fun dn -> dn.Denomination.master_sig)
|> List.map Signatures.DenominationKeyValidity.to_octets |> List.map Signatures.DenominationKeyValidity.to_octets
|> String.concat "" |> String.concat ""
|> Hash.H64.hash |> Hash.H64.hash

View file

@ -3,93 +3,12 @@ open Api
open Hash open Hash
module Keys_get = struct module Keys_get = struct
let mk_future_denom (module Sm : Secmod.S) ~section_name
({
pub;
value;
stamp_start;
stamp_expire_withdraw;
stamp_expire_deposit;
stamp_expire_legal;
fee_withdraw;
fee_deposit;
fee_refresh;
fee_refund;
age_mask;
h_pub;
master_sig= _;
revoked_sig= _;
} :
Denom_data.t) =
let denom_pub =
DenominationKey.of_rsa RsaDenominationKey.{ age_mask; rsa_pub= pub }
in
let denom_secmod_sig =
let open Signatures.DenominationKeyAnnouncement in
let h_denom_pub = h_pub in
let h_section_name = Hash.Cstring.H64.hash section_name in
let anchor_time = stamp_start in
let duration_withdraw =
Timestamp.diff stamp_start stamp_expire_withdraw
in
sign_f ~f:Sm.sign_with_sm_key
{ h_denom_pub; h_section_name; anchor_time; duration_withdraw }
in
FutureDenom.
{
section_name;
value;
stamp_start;
stamp_expire_withdraw;
stamp_expire_deposit;
stamp_expire_legal;
denom_pub;
fee_withdraw;
fee_deposit;
fee_refresh;
fee_refund;
denom_secmod_sig;
}
let mk_future_signkey (module Sm : Secmod.S)
({
pub;
stamp_start;
stamp_expire;
stamp_end;
master_sig= _;
revoked_sig= _;
} :
Signkey_data.t) =
let signkey_secmod_sig =
let open Signatures.SigningKeyAnnouncement in
let exchange_pub = pub in
let anchor_time = stamp_start in
let duration = Timestamp.diff stamp_start stamp_expire in
sign_f ~f:Sm.sign_with_sm_key { exchange_pub; anchor_time; duration }
in
FutureSignKey.
{ key= pub; stamp_start; stamp_expire; stamp_end; signkey_secmod_sig }
let mk_future_keys_response (module Sm : Secmod.S) = let mk_future_keys_response (module Sm : Secmod.S) =
let future_signkeys = let future_signkeys = Sm.get_future_signkeys () in
Sm.get_signkeys_data () let future_denoms = Sm.get_future_denominations () in
|> List.filter (fun k -> Option.is_none k.Signkey_data.master_sig)
|> List.map (fun signkey -> mk_future_signkey (module Sm) signkey)
in
let future_denoms =
Sm.get_denoms_data ()
|> List.filter (fun k -> Option.is_none k.Denom_data.master_sig)
|> List.map (fun dn_data ->
let opt = Sm.find_denom_section_name dn_data.Denom_data.h_pub in
match opt with
| None -> Fmt.failwith "section_name not found."
| Some section_name ->
mk_future_denom (module Sm) ~section_name dn_data)
in
let master_pub = Config.Exchange.master_public_key in let master_pub = Config.Exchange.master_public_key in
let denom_secmod_public_key = Sm.get_sm_key_pub () in let denom_secmod_public_key = Sm.sm_pubkey in
let signkey_secmod_public_key = Sm.get_sm_key_pub () in let signkey_secmod_public_key = Sm.sm_pubkey in
FutureKeysResponse. FutureKeysResponse.
{ {
future_denoms; future_denoms;
@ -113,15 +32,15 @@ module Keys_get = struct
end end
module Keys_post = struct module Keys_post = struct
let error_key_unknown =
"404 not found, One of the keys for which a signature was provided is \
unknown to the exchange."
let verify_denom_signature (module Sm : Secmod.S) let verify_denom_signature (module Sm : Secmod.S)
DenomSignature.{ h_denom_pub; master_sig } = DenomSignature.{ h_denom_pub; master_sig } =
let* denom = let* denom =
match Sm.find_denom_data h_denom_pub with Sm.find_future_denomination h_denom_pub
| None -> |> Option.to_result ~none:error_key_unknown
Fmt.error
"404 not found, One of the keys for which a signature was provided \
is unknown to the exchange."
| Some denom -> Ok denom
in in
let open Signatures.DenominationKeyValidity in let open Signatures.DenominationKeyValidity in
let r : r = let r : r =
@ -144,12 +63,7 @@ module Keys_post = struct
let verify_signkey_signature (module Sm : Secmod.S) let verify_signkey_signature (module Sm : Secmod.S)
SignKeySignature.{ key; master_sig } = SignKeySignature.{ key; master_sig } =
let* signkey = let* signkey =
match Sm.find_signkey_data key with Sm.find_future_signkey key |> Option.to_result ~none:error_key_unknown
| None ->
Fmt.error
"404 not found, One of the keys for which a signature was provided \
is unknown to the exchange."
| Some signkey -> Ok signkey
in in
let open Signatures.ExchangeSigningKeyValidity in let open Signatures.ExchangeSigningKeyValidity in
let r : r = let r : r =
@ -157,7 +71,7 @@ module Keys_post = struct
start= signkey.stamp_start; start= signkey.stamp_start;
expire= signkey.stamp_expire; expire= signkey.stamp_expire;
end_= signkey.stamp_end; end_= signkey.stamp_end;
signkey_pub= signkey.pub; signkey_pub= signkey.key;
} }
in in
verify_f ~f:Sm.verify_with_master_key master_sig r verify_f ~f:Sm.verify_with_master_key master_sig r
@ -170,18 +84,18 @@ module Keys_post = struct
let do_ ~db_conn:_ (module Sm : Secmod.S) let do_ ~db_conn:_ (module Sm : Secmod.S)
MasterSignatures.{ denom_sigs; signkey_sigs } = MasterSignatures.{ denom_sigs; signkey_sigs } =
let* () = let* () =
signkey_sigs list_iter
|> List.map (fun SignKeySignature.{ key; master_sig } -> (fun SignKeySignature.{ key; master_sig } ->
(key, master_sig)) Sm.certify_future_signkey key master_sig)
|> Sm.add_signkey_master_signatures signkey_sigs
in in
let* () = let* () =
denom_sigs list_iter
|> List.map (fun DenomSignature.{ h_denom_pub; master_sig } -> (fun DenomSignature.{ h_denom_pub; master_sig } ->
(h_denom_pub, master_sig)) Sm.certify_future_denomination h_denom_pub master_sig)
|> Sm.add_denom_master_signatures denom_sigs
in in
let* () = Sm.store () in let* () = Sm.save () in
Ok () Ok ()
let jsont = MasterSignatures.jsont let jsont = MasterSignatures.jsont

View file

@ -67,7 +67,7 @@ let insert_signkey =
let find_denom = let find_denom =
let find_denom = let find_denom =
Caqti_type.(denomination_hash ->? denom_data) Caqti_type.(denom_hash ->? denom_data)
"SELECT dn.denom_pub, (dn.coin).*, dn.valid_from, dn.expire_withdraw, \ "SELECT dn.denom_pub, (dn.coin).*, dn.valid_from, dn.expire_withdraw, \
dn.expire_deposit, dn.expire_legal, (dn.fee_withdraw).*, \ dn.expire_deposit, dn.expire_legal, (dn.fee_withdraw).*, \
(dn.fee_deposit).*, (dn.fee_refresh).*, (dn.fee_refund).*, dn.age_mask, \ (dn.fee_deposit).*, (dn.fee_refresh).*, (dn.fee_refund).*, dn.age_mask, \
@ -104,7 +104,7 @@ let insert_denom =
let insert_denomination_revocation = let insert_denomination_revocation =
let denomination_revocation_insert = let denomination_revocation_insert =
let master_sig = Signatures.MasterDenominationKeyRevocation.caqti in let master_sig = Signatures.MasterDenominationKeyRevocation.caqti in
Caqti_type.(t2 denomination_hash master_sig ->. unit) Caqti_type.(t2 denom_hash master_sig ->. unit)
"INSERT INTO denomination_revocations (denominations_serial, master_sig) \ "INSERT INTO denomination_revocations (denominations_serial, master_sig) \
SELECT denominations_serial, $2 FROM denominations WHERE \ SELECT denominations_serial, $2 FROM denominations WHERE \
denom_pub_hash=$1" denom_pub_hash=$1"
@ -168,7 +168,7 @@ let disable_auditor =
let insert_auditor_denom_sig = let insert_auditor_denom_sig =
let insert_auditor_denom_sig = let insert_auditor_denom_sig =
let auditor_sig = Signatures.ExchangeKeyValidity.caqti in let auditor_sig = Signatures.ExchangeKeyValidity.caqti in
Caqti_type.(t3 eddsa_pub denomination_hash auditor_sig ->. unit) Caqti_type.(t3 eddsa_pub denom_hash auditor_sig ->. unit)
"WITH ax AS (SELECT auditor_uuid FROM auditors WHERE auditor_pub=$1) \ "WITH ax AS (SELECT auditor_uuid FROM auditors WHERE auditor_pub=$1) \
INSERT INTO auditor_denom_sigs (auditor_uuid, denominations_serial, \ INSERT INTO auditor_denom_sigs (auditor_uuid, denominations_serial, \
auditor_sig) SELECT ax.auditor_uuid, denominations_serial, $3 FROM \ auditor_sig) SELECT ax.auditor_uuid, denominations_serial, $3 FROM \
@ -185,8 +185,7 @@ let insert_auditor_denom_sig =
let get_auditor_keys = let get_auditor_keys =
let get_auditor_keys = let get_auditor_keys =
let auditor_sig = Signatures.ExchangeKeyValidity.caqti in let auditor_sig = Signatures.ExchangeKeyValidity.caqti in
Caqti_type.( Caqti_type.(unit ->* t5 eddsa_pub string string denom_hash auditor_sig)
unit ->* t5 eddsa_pub string string denomination_hash auditor_sig)
"SELECT a.auditor_pub, a.auditor_url, a.auditor_name, dn.denom_pub_hash, \ "SELECT a.auditor_pub, a.auditor_url, a.auditor_name, dn.denom_pub_hash, \
ads.auditor_sig FROM auditor_denom_sigs AS ads JOIN auditors AS a USING \ ads.auditor_sig FROM auditor_denom_sigs AS ads JOIN auditors AS a USING \
(auditor_uuid) JOIN denominations AS dn USING (denominations_serial) \ (auditor_uuid) JOIN denominations AS dn USING (denominations_serial) \

View file

@ -32,7 +32,7 @@ include struct
let fullpayto_hash = FullPaytoHash.caqti let fullpayto_hash = FullPaytoHash.caqti
let nomalizaedpayto_hash = NormalizedPaytoHash.caqti let nomalizaedpayto_hash = NormalizedPaytoHash.caqti
let denomination_hash = DenominationHash.caqti let denom_hash = DenominationHash.caqti
let privatecontract_hash = PrivateContractHash.caqti let privatecontract_hash = PrivateContractHash.caqti
let extensionspolicy_hash = ExtensionsPolicyHash.caqti let extensionspolicy_hash = ExtensionsPolicyHash.caqti
let merchantwire_hash = MerchantWireHash.caqti let merchantwire_hash = MerchantWireHash.caqti
@ -48,24 +48,13 @@ let signkey_data =
let revoked_sig = option Signatures.MasterSigningKeyRevocation.caqti in let revoked_sig = option Signatures.MasterSigningKeyRevocation.caqti in
custom custom
~encode:(fun ~encode:(fun
Signkey_data. Signkey.
{ pub; stamp_start; stamp_expire; stamp_end; master_sig; revoked_sig } { pub; stamp_start; stamp_expire; stamp_end; master_sig; revoked_sig }
-> ->
match master_sig with Ok (pub, stamp_start, stamp_expire, stamp_end, master_sig, revoked_sig))
| None -> Error "signkey_data master_sig is none"
| Some master_sig ->
Ok (pub, stamp_start, stamp_expire, stamp_end, master_sig, revoked_sig))
~decode:(fun ~decode:(fun
(pub, stamp_start, stamp_expire, stamp_end, master_sig, revoked_sig) -> (pub, stamp_start, stamp_expire, stamp_end, master_sig, revoked_sig) ->
Ok Ok { pub; stamp_start; stamp_expire; stamp_end; master_sig; revoked_sig })
{
pub;
stamp_start;
stamp_expire;
stamp_end;
master_sig= Some master_sig;
revoked_sig;
})
(t6 eddsa_pub time time time master_sig revoked_sig) (t6 eddsa_pub time time time master_sig revoked_sig)
let denom_data = let denom_data =
@ -73,7 +62,7 @@ let denom_data =
let revoked_sig = option Signatures.MasterDenominationKeyRevocation.caqti in let revoked_sig = option Signatures.MasterDenominationKeyRevocation.caqti in
custom custom
~encode:(fun ~encode:(fun
Denom_data. Denomination.
{ {
pub; pub;
value; value;
@ -91,22 +80,19 @@ let denom_data =
revoked_sig; revoked_sig;
} }
-> ->
match master_sig with Ok
| None -> Error "denom_data master_sig is none" ( pub,
| Some master_sig -> value,
Ok stamp_start,
( pub, stamp_expire_withdraw,
value, stamp_expire_deposit,
stamp_start, stamp_expire_legal,
stamp_expire_withdraw, fee_withdraw,
stamp_expire_deposit, fee_deposit,
stamp_expire_legal, fee_refresh,
fee_withdraw, fee_refund,
fee_deposit, age_mask,
fee_refresh, (h_pub, master_sig, revoked_sig) ))
fee_refund,
age_mask,
(h_pub, master_sig, revoked_sig) ))
~decode:(fun ~decode:(fun
( pub, ( pub,
value, value,
@ -135,11 +121,11 @@ let denom_data =
fee_refund; fee_refund;
age_mask; age_mask;
h_pub; h_pub;
master_sig= Some master_sig; master_sig;
revoked_sig; revoked_sig;
}) })
(t12 rsa_pub amount time time time time amount amount amount amount int (t12 rsa_pub amount time time time time amount amount amount amount int
(t3 denomination_hash master_sig revoked_sig)) (t3 denom_hash master_sig revoked_sig))
let account_restrictions = let account_restrictions =
custom custom

View file

@ -1,6 +1,7 @@
module type S = sig module type S = sig
open Crypto open Crypto
val sm_pubkey : eddsa_pub
val sign_with_sm_key : string -> eddsa_sig val sign_with_sm_key : string -> eddsa_sig
val sign_with_signkey : pub:eddsa_pub -> string -> eddsa_sig val sign_with_signkey : pub:eddsa_pub -> string -> eddsa_sig
val verify_with_master_key : eddsa_sig -> msg:string -> (unit, string) result val verify_with_master_key : eddsa_sig -> msg:string -> (unit, string) result
@ -9,26 +10,22 @@ module type S = sig
val verify_with_signkey : val verify_with_signkey :
pub:eddsa_pub -> eddsa_sig -> msg:string -> (unit, string) result pub:eddsa_pub -> eddsa_sig -> msg:string -> (unit, string) result
(* TODO query database instead? *) val get_signkeys : unit -> Signkey.t list
val get_sm_key_pub : unit -> eddsa_pub val get_denominations : unit -> Denomination.t list
val get_signkeys_data : unit -> Signkey_data.t list val get_future_signkeys : unit -> Api.FutureSignKey.t list
val get_denoms_data : unit -> Denom_data.t list val get_future_denominations : unit -> Api.FutureDenom.t list
val find_signkey_data : eddsa_pub -> Signkey_data.t option val find_signkey : eddsa_pub -> Signkey.t option
val find_denom_data : denomination_hash -> Denom_data.t option val find_denomination : denom_hash -> Denomination.t option
val find_denom_section_name : denomination_hash -> string option val find_future_signkey : eddsa_pub -> Api.FutureSignKey.t option
val find_future_denomination : denom_hash -> Api.FutureDenom.t option
(* - management operations - *) val certify_future_signkey :
(* TODO eddsa_pub ->
problem of keeping db and secmod state syncronized Signatures.ExchangeSigningKeyValidity.t ->
do db interaction from secmod? *)
val add_signkey_master_signatures :
(eddsa_pub * Signatures.ExchangeSigningKeyValidity.t) list ->
(unit, string) result (unit, string) result
val add_denom_master_signatures : val certify_future_denomination :
(denomination_hash * Signatures.DenominationKeyValidity.t) list -> denom_hash -> Signatures.DenominationKeyValidity.t -> (unit, string) result
(unit, string) result
val revoke_signkey : val revoke_signkey :
eddsa_pub -> eddsa_pub ->
@ -36,156 +33,76 @@ module type S = sig
(unit, string) result (unit, string) result
val revoke_denomination : val revoke_denomination :
denomination_hash -> denom_hash ->
Signatures.MasterDenominationKeyRevocation.t -> Signatures.MasterDenominationKeyRevocation.t ->
(unit, string) result (unit, string) result
val store : unit -> (unit, string) result val save : unit -> (unit, string) result
end end
module Make (Conn : Pg.CONN) = struct module Make (Conn : Pg.CONN) = struct
(* TODO
- key rotation
- how many signkey to use?
we just use 1 for now
- does the secmod's own key as metadata/expiration date?
- something to refer to valid sk/dn
- eddsa.ml with phantom type for key-kind + signed-data-kind *)
open Syntax open Syntax
open Crypto open Crypto
module DenominationHash = Hash.DenominationHash
type signkey = { type sk = Signkey.t
priv: eddsa_priv; type future_sk = Api.FutureSignKey.t
sk_data: Signkey_data.t; type dn = Denomination.t
} type future_dn = Api.FutureDenom.t
type denom = {
priv: rsa_priv;
dn_data: Denom_data.t;
}
(* TODO ! use lock *)
(* not sure what to do with coin section_name, rm if possible *)
type t = { type t = {
lock: Miou.Mutex.t; sm_key: eddsa_priv;
sm_key_priv: eddsa_priv; sm_pubkey: eddsa_pub;
sm_key_pub: eddsa_pub; sk_ht: (eddsa_pub, sk) Hashtbl.t;
sk_ht: (eddsa_pub, signkey) Hashtbl.t; dn_ht: (denom_hash, dn) Hashtbl.t;
dn_ht: (denomination_hash, denom) Hashtbl.t; sk_key_ht: (eddsa_pub, eddsa_priv) Hashtbl.t;
dn_section_name_ht: (denomination_hash, string) Hashtbl.t; dn_key_ht: (denom_hash, rsa_priv) Hashtbl.t;
future_sk_ht: (eddsa_pub, future_sk) Hashtbl.t;
future_dn_ht: (denom_hash, future_dn) Hashtbl.t;
future_sk_key_ht: (eddsa_pub, eddsa_priv) Hashtbl.t;
future_dn_key_ht: (denom_hash, rsa_priv) Hashtbl.t;
dn_section_name_ht: (denom_hash, string) Hashtbl.t;
} }
let db_lookup_signkey_data conn fname pub = let conn = (module Conn : Pg.CONN)
let* opt = Pg.find_signkey conn pub |> unwrap_err_caqti in let sm_key_fname = Fpath.(Config.secmod_dir / "sm_key")
match opt with let sk_fname i = Fpath.(Config.secmod_dir / Fmt.str "sk_%d" i)
| None ->
Fmt.error
"load_signkey error, no associated data found in database for \
signkey `%s`."
(Fpath.to_string fname)
| Some sk_data -> Ok sk_data
let db_lookup_denom_data conn ~section_name priv = let dn_fname section_name =
let pub = RsaPrivateKey.pub_of_priv priv in Fpath.(Config.secmod_dir / Fmt.str "dn_%s" section_name)
let h_pub = Hash.DenominationHash.hash (RsaPublicKey.to_octets pub) in
let* opt = Pg.find_denom conn h_pub |> unwrap_err_caqti in
match opt with
| None ->
Fmt.error
"load_denom error no associated metadata found in database for \
denomination `%s`."
section_name
| Some dn_data -> Ok dn_data
let load_signkey conn fname = let sign_with_sm_key t s = EddsaSignature.sign ~key:t.sm_key s
let* opt = Data_file.read_eddsa fname in
match opt with
| None -> Ok None
| Some priv ->
let pub = EddsaPrivateKey.pub_of_priv priv in
let* sk_data = db_lookup_signkey_data conn fname pub in
let signkey = { priv; sk_data } in
Ok (Some signkey)
let load conn = let make_future_sk t =
let error_invalid_state =
Fmt.error "secmod load error: invalid store state."
in
let* sm_key_priv =
Data_file.read_eddsa Fpath.(Config.secrets_dir / "sk_sm")
in
let* signkeys =
let l =
List.init 1 (fun i -> Fpath.(Config.secrets_dir / Fmt.str "sk_%d" i))
in
let* l = list_map (fun fname -> load_signkey conn fname) l in
match opt_list l with Error () -> error_invalid_state | Ok opt -> Ok opt
in
let dn_section_name_ht = Hashtbl.create 0xff in
let* denoms =
let* l =
let open Config.Coin in
list_map
(fun coin ->
let section_name = coin.section_name in
let fname = Fpath.(Config.secrets_dir / section_name) in
let* opt = Data_file.read_rsa fname in
match opt with
| None -> Ok None
| Some priv ->
(* todo: could check that coin config match db values *)
let* dn_data = db_lookup_denom_data conn ~section_name priv in
Hashtbl.replace dn_section_name_ht dn_data.h_pub section_name;
let denom = { priv; dn_data } in
Ok (Some denom))
all_coins
in
match Syntax.opt_list l with
| Error () -> error_invalid_state
| Ok opt -> Ok opt
in
match (sm_key_priv, signkeys, denoms) with
| None, None, None -> Ok None
| Some sm_key_priv, Some signkeys, Some denoms ->
let sm_key_pub = EddsaPrivateKey.pub_of_priv sm_key_priv in
let lock = Miou.Mutex.create () in
let sk_ht =
signkeys
|> List.map (fun v -> (v.sk_data.pub, v))
|> List.to_seq
|> Hashtbl.of_seq
in
let dn_ht =
denoms
|> List.map (fun v -> (v.dn_data.h_pub, v))
|> List.to_seq
|> Hashtbl.of_seq
in
Ok
(Some
{ lock; sm_key_priv; sm_key_pub; sk_ht; dn_ht; dn_section_name_ht })
| _, _, _ -> error_invalid_state
let make_new_signkey () =
let start = Time.Absolute.of_ptime (Ptime_clock.now ()) in let start = Time.Absolute.of_ptime (Ptime_clock.now ()) in
let expire = let expire =
Time.Absolute.add start Config.Exchange.signkey_legal_duration Time.Absolute.add start Config.Exchange.signkey_legal_duration
in in
let stamp_start = Time.Timestamp.of_absolute start in let stamp_start = Timestamp.of_absolute start in
let stamp_expire = Time.Timestamp.of_absolute expire in let stamp_expire = Timestamp.of_absolute expire in
let stamp_end = stamp_expire in let stamp_end = stamp_expire in
let priv, pub = Mirage_crypto_ec.Ed25519.generate () in let priv, pub = Mirage_crypto_ec.Ed25519.generate () in
let master_sig = None in let signkey_secmod_sig =
let revoked_sig = None in let open Signatures.SigningKeyAnnouncement in
let sk_data = let exchange_pub = pub in
Signkey_data. let anchor_time = stamp_start in
{ pub; stamp_start; stamp_expire; stamp_end; master_sig; revoked_sig } let duration = Timestamp.diff stamp_start stamp_expire in
sign_f ~f:(sign_with_sm_key t) { exchange_pub; anchor_time; duration }
in in
{ priv; sk_data } let future_sk =
Api.FutureSignKey.
{ key= pub; stamp_start; stamp_expire; stamp_end; signkey_secmod_sig }
in
Hashtbl.replace t.future_sk_ht pub future_sk;
Hashtbl.replace t.future_sk_key_ht pub priv;
()
let make_new_denom let make_future_dn t
Config.Coin. Config.Coin.
{ {
section_name= _; section_name;
value; value;
duration_withdraw; duration_withdraw;
duration_spend; duration_spend;
@ -199,213 +116,355 @@ module Make (Conn : Pg.CONN) = struct
age_restricted= _; age_restricted= _;
} = } =
assert (cipher = `RSA); assert (cipher = `RSA);
let open Time in let start = Time.Absolute.of_ptime (Ptime_clock.now ()) in
let start = Absolute.of_ptime (Ptime_clock.now ()) in
let stamp_start = Timestamp.of_absolute start in let stamp_start = Timestamp.of_absolute start in
let stamp_expire_withdraw = let stamp_expire_withdraw =
Timestamp.of_absolute @@ Absolute.add start duration_withdraw Timestamp.of_absolute @@ Time.Absolute.add start duration_withdraw
in in
let stamp_expire_deposit = let stamp_expire_deposit =
Timestamp.of_absolute @@ Absolute.add start duration_spend Timestamp.of_absolute @@ Time.Absolute.add start duration_spend
in in
let stamp_expire_legal = let stamp_expire_legal =
Timestamp.of_absolute @@ Absolute.add start duration_legal Timestamp.of_absolute @@ Time.Absolute.add start duration_legal
in in
let priv, pub = RsaPrivateKey.generate ~bits:rsa_keysize () in let priv, pub = RsaPrivateKey.generate ~bits:rsa_keysize () in
let h_pub = Hash.DenominationHash.hash (RsaPublicKey.to_octets pub) in let open Api in
let master_sig = None in let rsa_denomination_key =
let revoked_sig = None in RsaDenominationKey.{ age_mask= 0; rsa_pub= pub }
let dn_data = in
Denom_data. let denom_pub = DenominationKey.Rsa rsa_denomination_key in
let h_pub = DenominationHash.hash (RsaPublicKey.to_octets pub) in
let denom_secmod_sig =
let open Signatures.DenominationKeyAnnouncement in
let h_denom_pub = h_pub in
let h_section_name = Hash.Cstring.H64.hash section_name in
let anchor_time = stamp_start in
let duration_withdraw =
Timestamp.diff stamp_start stamp_expire_withdraw
in
sign_f ~f:(sign_with_sm_key t)
{ h_denom_pub; h_section_name; anchor_time; duration_withdraw }
in
let future_dn =
FutureDenom.
{ {
pub; section_name;
value; value;
stamp_start; stamp_start;
stamp_expire_withdraw; stamp_expire_withdraw;
stamp_expire_deposit; stamp_expire_deposit;
stamp_expire_legal; stamp_expire_legal;
denom_pub;
fee_withdraw; fee_withdraw;
fee_deposit; fee_deposit;
fee_refresh; fee_refresh;
fee_refund; fee_refund;
age_mask= 0; denom_secmod_sig;
h_pub;
master_sig;
revoked_sig;
} }
in in
{ priv; dn_data } Hashtbl.replace t.future_dn_ht h_pub future_dn;
Hashtbl.replace t.future_dn_key_ht h_pub priv;
()
let make_new () = let make_new () =
let lock = Miou.Mutex.create () in let sm_key, sm_pubkey = Mirage_crypto_ec.Ed25519.generate () in
let sm_key_priv, sm_key_pub = Mirage_crypto_ec.Ed25519.generate () in let t =
let sk_ht = {
[ make_new_signkey () ] sm_key;
|> List.map (fun v -> (v.sk_data.pub, v)) sm_pubkey;
|> List.to_seq sk_ht= Hashtbl.create 0xff;
|> Hashtbl.of_seq dn_ht= Hashtbl.create 0xff;
sk_key_ht= Hashtbl.create 0xff;
dn_key_ht= Hashtbl.create 0xff;
future_sk_ht= Hashtbl.create 0xff;
future_dn_ht= Hashtbl.create 0xff;
future_sk_key_ht= Hashtbl.create 0xff;
future_dn_key_ht= Hashtbl.create 0xff;
dn_section_name_ht= Hashtbl.create 0xff;
}
in in
make_future_sk t;
List.iter (make_future_dn t) Config.Coin.all_coins;
t
let database_find_sk conn pub =
let* opt = Pg.find_signkey conn pub |> unwrap_err_caqti in
match opt with
| None ->
Fmt.error "secmod failure: a signkey could not be found in database"
| Some sk_data -> Ok sk_data
let database_find_dn conn h_pub =
let* opt = Pg.find_denom conn h_pub |> unwrap_err_caqti in
match opt with
| None ->
Fmt.error
"secmod failure: a denomination could not be found in database"
| Some dn_data -> Ok dn_data
let list_to_ht l = Hashtbl.of_seq (List.to_seq l)
let load () =
let* sm_key = Data_file.read_eddsa sm_key_fname in
let sm_pubkey = EddsaPrivateKey.pub_of_priv sm_key in
let* sk_keys = list_map Data_file.read_eddsa (List.init 1 sk_fname) in
let* sk_l =
list_map
(fun priv ->
let pub = EddsaPrivateKey.pub_of_priv priv in
let+ sk = database_find_sk conn pub in
((pub, sk), (pub, priv)))
sk_keys
in
let sk_ht, sk_key_ht =
match List.split sk_l with l1, l2 -> (list_to_ht l1, list_to_ht l2)
in
let dn_section_name_ht = Hashtbl.create 0xff in let dn_section_name_ht = Hashtbl.create 0xff in
let dn_ht = let* dn_keys =
Config.Coin.all_coins list_map
|> List.map (fun coin -> (fun coin ->
let denom = make_new_denom coin in let section_name = coin.Config.Coin.section_name in
Hashtbl.replace dn_section_name_ht denom.dn_data.h_pub let+ priv = Data_file.read_rsa (dn_fname section_name) in
coin.section_name; (section_name, priv))
(denom.dn_data.h_pub, denom)) Config.Coin.all_coins
|> List.to_seq
|> Hashtbl.of_seq
in in
{ lock; sm_key_priv; sm_key_pub; sk_ht; dn_ht; dn_section_name_ht } let* dn_l =
list_map
(fun (section_name, priv) ->
let h_pub =
priv
|> RsaPrivateKey.pub_of_priv
|> RsaPublicKey.to_octets
|> DenominationHash.hash
in
(* fill dn_section_name_ht *)
Hashtbl.replace dn_section_name_ht h_pub section_name;
let+ dn = database_find_dn conn h_pub in
((h_pub, dn), (h_pub, priv)))
dn_keys
in
let dn_ht, dn_key_ht =
match List.split dn_l with l1, l2 -> (list_to_ht l1, list_to_ht l2)
in
(* future keys are not stored anywhere until they are certified with a master_sig
so we don't have any future key to load *)
let t =
{
sm_key;
sm_pubkey;
sk_ht;
dn_ht;
sk_key_ht;
dn_key_ht;
future_sk_ht= Hashtbl.create 0xff;
future_dn_ht= Hashtbl.create 0xff;
future_sk_key_ht= Hashtbl.create 0xff;
future_dn_key_ht= Hashtbl.create 0xff;
dn_section_name_ht;
}
in
Ok t
let init () =
let dir = Config.secmod_dir in
let* b = Bos.OS.Dir.create ~mode:0o700 dir |> unwrap_err_msg in
if b then
Logs.info (fun m -> m "secmod: created directory `%a`" Fpath.pp dir);
let* l =
Bos.OS.Dir.contents ~dotfiles:false ~rel:false dir |> unwrap_err_msg
in
match List.is_empty l with
| true ->
Logs.info (fun m -> m "secmod: empty storage, generating fresh keys");
let t = make_new () in
Ok t
| false ->
Logs.info (fun m -> m "secmod: loading keys from storage");
load ()
let t = let t =
match load (module Conn) with match init () with
| Ok None -> | Error e -> Fmt.failwith "secmod initialization failure: `%s`." e
let t = make_new () in | Ok t ->
Logs.info (fun m -> m "secmod initialized with fresh keys"); Logs.info (fun m -> m "secmod initialized");
t t
| Ok (Some t) ->
Logs.info (fun m -> m "secmod initialized from storage");
t
| Error e -> Fmt.failwith "secmod init failure: %s." e
(* note: don't expose a signing function if we want a real "security module" one day *) let sm_pubkey = t.sm_pubkey
let sign_with_sm_key s = EddsaSignature.sign ~key:t.sm_key_priv s let sign_with_sm_key s = sign_with_sm_key t s
let verify_with_sm_key s ~msg = EddsaSignature.verify ~key:t.sm_key_pub s ~msg
let verify_with_master_key s ~msg =
EddsaSignature.verify ~key:Config.master_public_key s ~msg
(* TODO
- do something to force `pub` to be one of the valid signkey
how to handle revocation?
raise exn for now *)
let sign_with_signkey ~pub s = let sign_with_signkey ~pub s =
Miou.Mutex.protect t.lock @@ fun () -> match Hashtbl.find_opt t.sk_key_ht pub with
match Hashtbl.find_opt t.sk_ht pub with | None -> Fmt.failwith "secmod failure: signkey not found."
| None -> Fmt.failwith "secmod failure: public key not found." | Some priv -> EddsaSignature.sign ~key:priv s
| Some signkey ->
let v = EddsaSignature.sign ~key:signkey.priv s in let verify_with_sm_key s ~msg = EddsaSignature.verify ~key:t.sm_pubkey s ~msg
v
let verify_with_master_key =
EddsaSignature.verify ~key:Config.master_public_key
let verify_with_signkey ~pub s ~msg = let verify_with_signkey ~pub s ~msg =
Miou.Mutex.protect t.lock @@ fun () -> (* check that [pub] is one of our own keys *)
match Hashtbl.find_opt t.sk_ht pub with match Hashtbl.find_opt t.sk_ht pub with
| None -> Error "secmod failure: public key not found." | None -> Fmt.failwith "secmod failure: signkey not found."
| Some signkey -> EddsaSignature.verify ~key:signkey.sk_data.pub s ~msg | Some _priv -> EddsaSignature.verify ~key:pub s ~msg
let get_sm_key_pub () = t.sm_key_pub let get_signkeys () = t.sk_ht |> Hashtbl.to_seq_values |> List.of_seq
let get_denominations () = t.dn_ht |> Hashtbl.to_seq_values |> List.of_seq
let get_signkeys () = let get_future_signkeys () =
Miou.Mutex.protect t.lock @@ fun () -> t.future_sk_ht |> Hashtbl.to_seq_values |> List.of_seq
Hashtbl.to_seq_values t.sk_ht |> List.of_seq
let get_denoms () = let get_future_denominations () =
Miou.Mutex.protect t.lock @@ fun () -> t.future_dn_ht |> Hashtbl.to_seq_values |> List.of_seq
Hashtbl.to_seq_values t.dn_ht |> List.of_seq
let find_signkey pub = let find_signkey pub = Hashtbl.find_opt t.sk_ht pub
Miou.Mutex.protect t.lock @@ fun () -> Hashtbl.find_opt t.sk_ht pub let find_denomination h_pub = Hashtbl.find_opt t.dn_ht h_pub
let find_future_signkey pub = Hashtbl.find_opt t.future_sk_ht pub
let find_future_denomination h_pub = Hashtbl.find_opt t.future_dn_ht h_pub
let find_denom h_denom = let certify_future_signkey pub master_sig =
Miou.Mutex.protect t.lock @@ fun () -> Hashtbl.find_opt t.dn_ht h_denom match
( Hashtbl.find_opt t.future_sk_ht pub,
let get_signkeys_data () = get_signkeys () |> List.map (fun v -> v.sk_data) Hashtbl.find_opt t.future_sk_key_ht pub )
let get_denoms_data () = get_denoms () |> List.map (fun v -> v.dn_data) with
| None, _ | _, None -> Error "secmod failure: future signkey not found."
let find_signkey_data pub = | Some future_sk, Some priv -> (
find_signkey pub |> Option.map (fun v -> v.sk_data)
let find_denom_data h_denom =
find_denom h_denom |> Option.map (fun v -> v.dn_data)
let find_denom_section_name h_denom =
Miou.Mutex.protect t.lock @@ fun () ->
Hashtbl.find_opt t.dn_section_name_ht h_denom
let add_signkey_master_signatures l =
Miou.Mutex.protect t.lock @@ fun () ->
list_iter
(fun (pub, master_sig) ->
match Hashtbl.find_opt t.sk_ht pub with match Hashtbl.find_opt t.sk_ht pub with
| None -> Error "secmod failure: public key not found." | Some _sk ->
| Some signkey -> Error "secmod failure: this signkey already has a master signature"
let sk_data = | None ->
{ signkey.sk_data with master_sig= Some master_sig } let Api.FutureSignKey.
{
key;
stamp_start;
stamp_expire;
stamp_end;
signkey_secmod_sig= _;
} =
future_sk
in in
let signkey = { signkey with sk_data } in let sk =
let* () = Signkey.
Pg.insert_signkey (module Conn) sk_data |> unwrap_err_caqti {
pub= key;
stamp_start;
stamp_expire;
stamp_end;
master_sig;
revoked_sig= None;
}
in in
Hashtbl.replace t.sk_ht pub signkey; Hashtbl.replace t.sk_ht pub sk;
Ok ()) Hashtbl.replace t.sk_key_ht pub priv;
l Hashtbl.remove t.future_sk_ht pub;
Hashtbl.remove t.future_sk_key_ht pub;
let add_denom_master_signatures l = let* () = Pg.insert_signkey (module Conn) sk |> unwrap_err_caqti in
Miou.Mutex.protect t.lock @@ fun () ->
list_iter
(fun (h_denom_pub, master_sig) ->
match Hashtbl.find_opt t.dn_ht h_denom_pub with
| None -> Error "secmod failure: denomination hash not found."
| Some denom ->
let dn_data = { denom.dn_data with master_sig= Some master_sig } in
let denom = { denom with dn_data } in
let* () =
Pg.insert_denom (module Conn) dn_data |> unwrap_err_caqti
in
Hashtbl.replace t.dn_ht h_denom_pub denom;
Ok ()) Ok ())
l
let revoke_signkey exchange_pub revoked_sig = let certify_future_denomination h_pub master_sig =
Miou.Mutex.protect t.lock @@ fun () -> match
match Hashtbl.find_opt t.sk_ht exchange_pub with ( Hashtbl.find_opt t.future_dn_ht h_pub,
| None -> Error "secmod failure: denomination hash not found." Hashtbl.find_opt t.future_dn_key_ht h_pub )
| Some signkey -> with
let sk_data = { signkey.sk_data with revoked_sig= Some revoked_sig } in | None, _ | _, None ->
let signkey = { signkey with sk_data } in Error "secmod failure: future denomination not found."
Hashtbl.replace t.sk_ht exchange_pub signkey; | Some future_dn, Some priv -> (
match Hashtbl.find_opt t.dn_ht h_pub with
| Some _dn ->
Error
"secmod failure: this denomination already has a master signature"
| None ->
let Api.FutureDenom.
{
section_name;
value;
stamp_start;
stamp_expire_withdraw;
stamp_expire_deposit;
stamp_expire_legal;
denom_pub;
fee_withdraw;
fee_deposit;
fee_refresh;
fee_refund;
denom_secmod_sig= _;
} =
future_dn
in
let rsa_pub =
match denom_pub with
| Rsa Api.RsaDenominationKey.{ age_mask= _; rsa_pub } -> rsa_pub
in
let dn =
Denomination.
{
pub= rsa_pub;
value;
stamp_start;
stamp_expire_withdraw;
stamp_expire_deposit;
stamp_expire_legal;
fee_withdraw;
fee_deposit;
fee_refresh;
fee_refund;
age_mask= 0;
h_pub;
master_sig;
revoked_sig= None;
}
in
Hashtbl.replace t.dn_ht h_pub dn;
Hashtbl.replace t.dn_key_ht h_pub priv;
Hashtbl.replace t.dn_section_name_ht h_pub section_name;
Hashtbl.remove t.future_dn_ht h_pub;
Hashtbl.remove t.future_dn_key_ht h_pub;
let* () = Pg.insert_denom (module Conn) dn |> unwrap_err_caqti in
Ok ())
let revoke_signkey pub revoked_sig =
match Hashtbl.find_opt t.sk_ht pub with
| None -> Error "secmod failure: signkey not found."
| Some sk ->
let sk = { sk with revoked_sig= Some revoked_sig } in
Hashtbl.replace t.sk_ht pub sk;
(* TODO revoke, apply to database *)
Ok () Ok ()
let revoke_denomination h_denom_pub revoked_sig = let revoke_denomination pub revoked_sig =
Miou.Mutex.protect t.lock @@ fun () -> match Hashtbl.find_opt t.dn_ht pub with
match Hashtbl.find_opt t.dn_ht h_denom_pub with | None -> Error "secmod failure: denomination not found."
| None -> Error "secmod failure: denomination hash not found." | Some dn ->
| Some denom -> let dn = { dn with revoked_sig= Some revoked_sig } in
let dn_data = { denom.dn_data with revoked_sig= Some revoked_sig } in Hashtbl.replace t.dn_ht pub dn;
let denom = { denom with dn_data } in
Hashtbl.replace t.dn_ht h_denom_pub denom; (* TODO revoke, apply to database *)
Ok () Ok ()
let store () = let save () =
Miou.Mutex.protect t.lock @@ fun () -> let* () = Data_file.write_eddsa sm_key_fname t.sm_key in
let* () = let* () =
Data_file.write_eddsa Fpath.(Config.secrets_dir / "sk_sm") t.sm_key_priv Hashtbl.to_seq_values t.sk_key_ht
in
let* () =
Hashtbl.to_seq_values t.sk_ht
|> List.of_seq |> List.of_seq
|> List.mapi (fun i (key : signkey) -> |> List.mapi (fun i priv -> Data_file.write_eddsa (sk_fname i) priv)
let fname = Fpath.(Config.secrets_dir / Fmt.str "sk_%d" i) in |> list_iter Fun.id
(fname, key.priv))
|> list_iter (fun (fname, key) -> Data_file.write_eddsa fname key)
in in
let* () = let* () =
let* l = Hashtbl.to_seq t.dn_key_ht
Hashtbl.to_seq_values t.dn_ht |> List.of_seq
|> List.of_seq |> list_iter (fun (pub, priv) ->
|> Syntax.list_map (fun (key : denom) -> let* section_name =
let+ section_name = match Hashtbl.find_opt t.dn_section_name_ht pub with
match Hashtbl.find_opt t.dn_section_name_ht key.dn_data.h_pub with | None -> Error "invalid state, section_name not found"
| None -> Error "invalid state, section_name not found" | Some s -> Ok s
| Some s -> Ok s in
in Data_file.write_rsa (dn_fname section_name) priv)
let fname = Fpath.(Config.secrets_dir / section_name) in
(fname, key.priv))
in
list_iter (fun (fname, key) -> Data_file.write_rsa fname key) l
in in
Logs.info (fun m -> m "stored secmod data to file"); Logs.info (fun m -> m "saved secmod private keys data");
Ok () Ok ()
end end

View file

@ -1,6 +1,7 @@
module type S = sig module type S = sig
open Crypto open Crypto
val sm_pubkey : eddsa_pub
val sign_with_sm_key : string -> eddsa_sig val sign_with_sm_key : string -> eddsa_sig
val sign_with_signkey : pub:eddsa_pub -> string -> eddsa_sig val sign_with_signkey : pub:eddsa_pub -> string -> eddsa_sig
val verify_with_master_key : eddsa_sig -> msg:string -> (unit, string) result val verify_with_master_key : eddsa_sig -> msg:string -> (unit, string) result
@ -9,26 +10,22 @@ module type S = sig
val verify_with_signkey : val verify_with_signkey :
pub:eddsa_pub -> eddsa_sig -> msg:string -> (unit, string) result pub:eddsa_pub -> eddsa_sig -> msg:string -> (unit, string) result
(* TODO query database instead? *) val get_signkeys : unit -> Signkey.t list
val get_sm_key_pub : unit -> eddsa_pub val get_denominations : unit -> Denomination.t list
val get_signkeys_data : unit -> Signkey_data.t list val get_future_signkeys : unit -> Api.FutureSignKey.t list
val get_denoms_data : unit -> Denom_data.t list val get_future_denominations : unit -> Api.FutureDenom.t list
val find_signkey_data : eddsa_pub -> Signkey_data.t option val find_signkey : eddsa_pub -> Signkey.t option
val find_denom_data : denomination_hash -> Denom_data.t option val find_denomination : denom_hash -> Denomination.t option
val find_denom_section_name : denomination_hash -> string option val find_future_signkey : eddsa_pub -> Api.FutureSignKey.t option
val find_future_denomination : denom_hash -> Api.FutureDenom.t option
(* - management operations - *) val certify_future_signkey :
(* TODO eddsa_pub ->
problem of keeping db and secmod state syncronized Signatures.ExchangeSigningKeyValidity.t ->
do db interaction from secmod? *)
val add_signkey_master_signatures :
(eddsa_pub * Signatures.ExchangeSigningKeyValidity.t) list ->
(unit, string) result (unit, string) result
val add_denom_master_signatures : val certify_future_denomination :
(denomination_hash * Signatures.DenominationKeyValidity.t) list -> denom_hash -> Signatures.DenominationKeyValidity.t -> (unit, string) result
(unit, string) result
val revoke_signkey : val revoke_signkey :
eddsa_pub -> eddsa_pub ->
@ -36,11 +33,11 @@ module type S = sig
(unit, string) result (unit, string) result
val revoke_denomination : val revoke_denomination :
denomination_hash -> denom_hash ->
Signatures.MasterDenominationKeyRevocation.t -> Signatures.MasterDenominationKeyRevocation.t ->
(unit, string) result (unit, string) result
val store : unit -> (unit, string) result val save : unit -> (unit, string) result
end end
module Make (_ : Pg.CONN) : S module Make (_ : Pg.CONN) : S

View file

@ -1,10 +1,11 @@
open Crypto open Crypto
(* TODO replace by Api.SignKey.t instead? (no revoked_sig) *)
type t = { type t = {
pub: eddsa_pub; pub: eddsa_pub;
stamp_start: Timestamp.t; stamp_start: Timestamp.t;
stamp_expire: Timestamp.t; stamp_expire: Timestamp.t;
stamp_end: Timestamp.t; stamp_end: Timestamp.t;
master_sig: Signatures.ExchangeSigningKeyValidity.t option; master_sig: Signatures.ExchangeSigningKeyValidity.t;
revoked_sig: Signatures.MasterSigningKeyRevocation.t option; revoked_sig: Signatures.MasterSigningKeyRevocation.t option;
} }