This commit is contained in:
parent
d69b49a335
commit
0f6131c920
2 changed files with 74 additions and 134 deletions
|
|
@ -9,16 +9,18 @@ module Keys_get = struct
|
||||||
Logs.info (fun m -> m "GET /management/keys/");
|
Logs.info (fun m -> m "GET /management/keys/");
|
||||||
let (module Keys : Keys.S) = Vif.Server.device Devices.keys server in
|
let (module Keys : Keys.S) = Vif.Server.device Devices.keys server in
|
||||||
let res =
|
let res =
|
||||||
let* v = Keys.make_future_keys_response () in
|
let v = Keys.make_future_keys_response () in
|
||||||
Api.encode jsont v
|
Api.encode jsont v
|
||||||
in
|
in
|
||||||
Respond.result res req
|
Respond.result res req
|
||||||
end
|
end
|
||||||
|
|
||||||
module Keys_post = struct
|
module Keys_post = struct
|
||||||
let verify_dn (module Keys : Keys.S) fdn denom_hash master_sig =
|
let verify_fdn (module Keys : Keys.S)
|
||||||
|
DenomSignature.{ h_denom_pub; master_sig } =
|
||||||
let open FutureDenom in
|
let open FutureDenom in
|
||||||
let open Signatures.DenominationKeyValidity in
|
let open Signatures.DenominationKeyValidity in
|
||||||
|
let* fdn = Keys.find_future_denomination h_denom_pub in
|
||||||
verify Config.master_public_key master_sig
|
verify Config.master_public_key master_sig
|
||||||
{
|
{
|
||||||
R.master= Config.master_public_key;
|
R.master= Config.master_public_key;
|
||||||
|
|
@ -31,54 +33,23 @@ module Keys_post = struct
|
||||||
fee_deposit= fdn.fee_deposit;
|
fee_deposit= fdn.fee_deposit;
|
||||||
fee_refresh= fdn.fee_refresh;
|
fee_refresh= fdn.fee_refresh;
|
||||||
fee_refund= fdn.fee_refund;
|
fee_refund= fdn.fee_refund;
|
||||||
denom_hash;
|
denom_hash= h_denom_pub;
|
||||||
}
|
}
|
||||||
|
|
||||||
let verify_denom_sigs (module Keys : Keys.S) denom_sigs =
|
let verify_fsk (module Keys : Keys.S) SignKeySignature.{ key; master_sig } =
|
||||||
let* fdn_l = Keys.future_denominations () in
|
|
||||||
let fdn_l =
|
|
||||||
List.map
|
|
||||||
(fun fdn ->
|
|
||||||
let h_pub =
|
|
||||||
(* TODO DenominationHash.of_denom_pub *)
|
|
||||||
DenominationHash.hash
|
|
||||||
(DenominationKey.to_octets fdn.FutureDenom.denom_pub)
|
|
||||||
in
|
|
||||||
(h_pub, fdn))
|
|
||||||
fdn_l
|
|
||||||
in
|
|
||||||
list_iter
|
|
||||||
(fun DenomSignature.{ h_denom_pub; master_sig } ->
|
|
||||||
match List.assoc_opt h_denom_pub fdn_l with
|
|
||||||
| None -> Error "future denomination not found"
|
|
||||||
| Some fdn -> verify_dn (module Keys) fdn h_denom_pub master_sig)
|
|
||||||
denom_sigs
|
|
||||||
|
|
||||||
let verify_sk (module Keys : Keys.S)
|
|
||||||
FutureSignKey.
|
|
||||||
{ key; stamp_start; stamp_expire; stamp_end; signkey_secmod_sig= _ }
|
|
||||||
master_sig =
|
|
||||||
let open Signatures.ExchangeSigningKeyValidity in
|
let open Signatures.ExchangeSigningKeyValidity in
|
||||||
|
let* fsk = Keys.find_future_signkey key in
|
||||||
verify Config.master_public_key master_sig
|
verify Config.master_public_key master_sig
|
||||||
{
|
{
|
||||||
R.start= stamp_start;
|
R.start= fsk.stamp_start;
|
||||||
expire= stamp_expire;
|
expire= fsk.stamp_expire;
|
||||||
end_= stamp_end;
|
end_= fsk.stamp_end;
|
||||||
signkey_pub= key;
|
signkey_pub= key;
|
||||||
}
|
}
|
||||||
|
|
||||||
let verify_signkey_sigs (module Keys : Keys.S) signkey_sigs =
|
|
||||||
let* fsk_l = Keys.future_signkeys () in
|
|
||||||
list_iter
|
|
||||||
(fun SignKeySignature.{ key; master_sig } ->
|
|
||||||
match List.find_opt (fun sk -> sk.FutureSignKey.key = key) fsk_l with
|
|
||||||
| None -> Error "future signkey not found"
|
|
||||||
| Some fsk -> verify_sk (module Keys) fsk master_sig)
|
|
||||||
signkey_sigs
|
|
||||||
|
|
||||||
let verify keys MasterSignatures.{ denom_sigs; signkey_sigs } =
|
let verify keys MasterSignatures.{ denom_sigs; signkey_sigs } =
|
||||||
let* () = verify_signkey_sigs keys signkey_sigs in
|
let* () = list_iter (verify_fsk keys) signkey_sigs in
|
||||||
let* () = verify_denom_sigs keys denom_sigs in
|
let* () = list_iter (verify_fdn keys) denom_sigs in
|
||||||
Ok ()
|
Ok ()
|
||||||
|
|
||||||
let do_ ~db_conn:_ (module Keys : Keys.S)
|
let do_ ~db_conn:_ (module Keys : Keys.S)
|
||||||
|
|
|
||||||
155
src/keys.ml
155
src/keys.ml
|
|
@ -11,9 +11,9 @@ module type S = sig
|
||||||
val find_denomination : denom_hash -> Denomination.t option result
|
val find_denomination : denom_hash -> Denomination.t option result
|
||||||
val signkeys : unit -> Signkey.t list result
|
val signkeys : unit -> Signkey.t list result
|
||||||
val denominations : unit -> Denomination.t list result
|
val denominations : unit -> Denomination.t list result
|
||||||
val future_signkeys : unit -> Api.FutureSignKey.t list result
|
val find_future_signkey : eddsa_pub -> Api.FutureSignKey.t result
|
||||||
val future_denominations : unit -> Api.FutureDenom.t list result
|
val find_future_denomination : denom_hash -> Api.FutureDenom.t result
|
||||||
val make_future_keys_response : unit -> Api.FutureKeysResponse.t result
|
val make_future_keys_response : unit -> Api.FutureKeysResponse.t
|
||||||
|
|
||||||
val certify_future_signkey :
|
val certify_future_signkey :
|
||||||
eddsa_pub -> Signatures.ExchangeSigningKeyValidity.t -> unit result
|
eddsa_pub -> Signatures.ExchangeSigningKeyValidity.t -> unit result
|
||||||
|
|
@ -66,8 +66,8 @@ module Make (Conn : Pg.CONN) : S = struct
|
||||||
| _ ->
|
| _ ->
|
||||||
Logs.warn (fun m ->
|
Logs.warn (fun m ->
|
||||||
m
|
m
|
||||||
"signkeys found in database are missing from secmod, (unclean \
|
"some signkeys found in database are missing from secmod, \
|
||||||
database/secmod state?)");
|
(unclean database/secmod state?)");
|
||||||
l
|
l
|
||||||
|
|
||||||
let denominations () =
|
let denominations () =
|
||||||
|
|
@ -82,11 +82,11 @@ module Make (Conn : Pg.CONN) : S = struct
|
||||||
| _ ->
|
| _ ->
|
||||||
Logs.warn (fun m ->
|
Logs.warn (fun m ->
|
||||||
m
|
m
|
||||||
"denominations found in database are missing from secmod, \
|
"some denominations found in database are missing from secmod, \
|
||||||
(unclean database/secmod state?)");
|
(unclean database/secmod state?)");
|
||||||
l
|
l
|
||||||
|
|
||||||
let make_future_sk ~pub ~start ~expire =
|
let make_future_sk (pub, (start, expire)) =
|
||||||
let open Time in
|
let open Time in
|
||||||
let stamp_start = Timestamp.of_absolute start in
|
let stamp_start = Timestamp.of_absolute start in
|
||||||
let stamp_expire = Timestamp.of_absolute expire in
|
let stamp_expire = Timestamp.of_absolute expire in
|
||||||
|
|
@ -104,7 +104,15 @@ module Make (Conn : Pg.CONN) : S = struct
|
||||||
Api.FutureSignKey.
|
Api.FutureSignKey.
|
||||||
{ key= pub; stamp_start; stamp_expire; stamp_end; signkey_secmod_sig }
|
{ key= pub; stamp_start; stamp_expire; stamp_end; signkey_secmod_sig }
|
||||||
|
|
||||||
let make_future_dn ~coin ~pub ~start =
|
let coin_of_section_name section_name =
|
||||||
|
Config.Coin.all_coins
|
||||||
|
|> List.find_opt (fun coin -> coin.Config.Coin.section_name = section_name)
|
||||||
|
|> function
|
||||||
|
| None ->
|
||||||
|
Fmt.failwith "coin section `%s` not found in configuration" section_name
|
||||||
|
| Some v -> v
|
||||||
|
|
||||||
|
let make_future_dn (h_pub, (section_name, pub, start)) =
|
||||||
let open Time in
|
let open Time in
|
||||||
let Config.Coin.
|
let Config.Coin.
|
||||||
{
|
{
|
||||||
|
|
@ -121,7 +129,7 @@ module Make (Conn : Pg.CONN) : S = struct
|
||||||
rsa_keysize= _;
|
rsa_keysize= _;
|
||||||
age_restricted= _;
|
age_restricted= _;
|
||||||
} =
|
} =
|
||||||
coin
|
coin_of_section_name section_name
|
||||||
in
|
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 =
|
||||||
|
|
@ -138,7 +146,6 @@ module Make (Conn : Pg.CONN) : S = struct
|
||||||
RsaDenominationKey.{ age_mask= 0; rsa_pub= pub }
|
RsaDenominationKey.{ age_mask= 0; rsa_pub= pub }
|
||||||
in
|
in
|
||||||
let denom_pub = DenominationKey.Rsa rsa_denomination_key in
|
let denom_pub = DenominationKey.Rsa rsa_denomination_key in
|
||||||
let h_pub = DenominationHash.hash (RsaPublicKey.to_octets pub) in
|
|
||||||
let denom_secmod_sig =
|
let denom_secmod_sig =
|
||||||
let open Signatures.DenominationKeyAnnouncement in
|
let open Signatures.DenominationKeyAnnouncement in
|
||||||
signf Sm_rsa.sign_secmod
|
signf Sm_rsa.sign_secmod
|
||||||
|
|
@ -165,59 +172,31 @@ module Make (Conn : Pg.CONN) : S = struct
|
||||||
denom_secmod_sig;
|
denom_secmod_sig;
|
||||||
}
|
}
|
||||||
|
|
||||||
let future_signkeys () =
|
let find_future_signkey pub =
|
||||||
Sm_eddsa.keys ()
|
match Sm_eddsa.find_key pub with
|
||||||
|> list_filter_map (fun (pub, (t1, t2)) ->
|
| None -> Error "future signkey not found"
|
||||||
let* opt = find_signkey pub in
|
| Some (pub, (t1, t2)) ->
|
||||||
match opt with
|
let fsk = make_future_sk (pub, (t1, t2)) in
|
||||||
| None ->
|
Ok fsk
|
||||||
let future_sk = make_future_sk ~pub ~start:t1 ~expire:t2 in
|
|
||||||
Ok (Some future_sk)
|
|
||||||
| Some sk -> (
|
|
||||||
match Timestamp.of_absolute t1 = sk.stamp_start with
|
|
||||||
| false ->
|
|
||||||
Fmt.error
|
|
||||||
"secmod/database stamp_start mismatch for signkey `%s`"
|
|
||||||
(EddsaPublicKey.to_b32 pub)
|
|
||||||
| true -> Ok None))
|
|
||||||
|
|
||||||
let future_denominations () =
|
let find_future_denomination h_pub =
|
||||||
Sm_rsa.keys ()
|
match Sm_rsa.find_key h_pub with
|
||||||
|> list_filter_map (fun (h_pub, (section_name, pub, t1)) ->
|
| None -> Error "future denomination not found"
|
||||||
let* opt = find_denomination h_pub in
|
| Some (h_pub, (section_name, pub, t1)) ->
|
||||||
match opt with
|
let future_dn = make_future_dn (h_pub, (section_name, pub, t1)) in
|
||||||
| None ->
|
Ok future_dn
|
||||||
let* coin =
|
|
||||||
Config.Coin.all_coins
|
|
||||||
|> List.find_opt (fun coin ->
|
|
||||||
coin.Config.Coin.section_name = section_name)
|
|
||||||
|> function
|
|
||||||
| Some v -> Ok v
|
|
||||||
| None ->
|
|
||||||
Fmt.error "coin `%s` not found in configuration" section_name
|
|
||||||
in
|
|
||||||
let future_dn = make_future_dn ~coin ~pub ~start:t1 in
|
|
||||||
Ok (Some future_dn)
|
|
||||||
| Some sk -> (
|
|
||||||
match Timestamp.of_absolute t1 = sk.stamp_start with
|
|
||||||
| false ->
|
|
||||||
Fmt.error
|
|
||||||
"secmod/database stamp_start mismatch for denomination `%s`"
|
|
||||||
section_name
|
|
||||||
| true -> Ok None))
|
|
||||||
|
|
||||||
let make_future_keys_response () =
|
let make_future_keys_response () =
|
||||||
let* future_signkeys = future_signkeys () in
|
let future_signkeys = Sm_eddsa.keys () |> List.map make_future_sk in
|
||||||
let* future_denoms = future_denominations () in
|
let future_denoms = Sm_rsa.keys () |> List.map make_future_dn in
|
||||||
Ok
|
Api.FutureKeysResponse.
|
||||||
Api.FutureKeysResponse.
|
{
|
||||||
{
|
future_denoms;
|
||||||
future_denoms;
|
future_signkeys;
|
||||||
future_signkeys;
|
master_pub= Config.Exchange.master_public_key;
|
||||||
master_pub= Config.Exchange.master_public_key;
|
denom_secmod_public_key= Sm_rsa.sm_pub;
|
||||||
denom_secmod_public_key= Sm_rsa.sm_pub;
|
signkey_secmod_public_key= Sm_eddsa.sm_pub;
|
||||||
signkey_secmod_public_key= Sm_eddsa.sm_pub;
|
}
|
||||||
}
|
|
||||||
|
|
||||||
let sk_of_future_sk future_sk master_sig =
|
let sk_of_future_sk future_sk master_sig =
|
||||||
let Api.FutureSignKey.
|
let Api.FutureSignKey.
|
||||||
|
|
@ -268,43 +247,33 @@ module Make (Conn : Pg.CONN) : S = struct
|
||||||
let certify_future_signkey pub master_sig =
|
let certify_future_signkey pub master_sig =
|
||||||
match Sm_eddsa.find_key pub with
|
match Sm_eddsa.find_key pub with
|
||||||
| None -> Error "future signkey not found"
|
| None -> Error "future signkey not found"
|
||||||
| Some (pub, (t1, t2)) ->
|
| Some (pub, (t1, t2)) -> (
|
||||||
let* () =
|
let* opt = find_signkey pub in
|
||||||
let* opt = find_signkey pub in
|
match opt with
|
||||||
match opt with
|
| Some _sk ->
|
||||||
| None -> Ok ()
|
Logs.info (fun m -> m "signkey already certified");
|
||||||
| Some _sk -> Error "signkey already certified"
|
Ok ()
|
||||||
in
|
| None ->
|
||||||
(* rebuild it *)
|
(* rebuild it *)
|
||||||
let future_sk = make_future_sk ~pub ~start:t1 ~expire:t2 in
|
let future_sk = make_future_sk (pub, (t1, t2)) in
|
||||||
let sk = sk_of_future_sk future_sk master_sig in
|
let sk = sk_of_future_sk future_sk master_sig in
|
||||||
let* () = Pg.insert_signkey conn sk |> unwrap_err_caqti in
|
let* () = Pg.insert_signkey conn sk |> unwrap_err_caqti in
|
||||||
Ok ()
|
Ok ())
|
||||||
|
|
||||||
let certify_future_denomination h_pub master_sig =
|
let certify_future_denomination h_pub master_sig =
|
||||||
match Sm_rsa.find_key h_pub with
|
match Sm_rsa.find_key h_pub with
|
||||||
| None -> Error "future denomination not found"
|
| None -> Error "future denomination not found"
|
||||||
| Some (h_pub, (section_name, pub, t1)) ->
|
| Some (h_pub, (section_name, pub, t1)) -> (
|
||||||
let* () =
|
let* opt = find_denomination h_pub in
|
||||||
let* opt = find_denomination h_pub in
|
match opt with
|
||||||
match opt with
|
| Some _dn ->
|
||||||
| None -> Ok ()
|
Logs.info (fun m -> m "denomination already certified");
|
||||||
| Some _sk -> Error "denomination already certified"
|
Ok ()
|
||||||
in
|
| None ->
|
||||||
(* rebuild it *)
|
let future_dn = make_future_dn (h_pub, (section_name, pub, t1)) in
|
||||||
let* coin =
|
let dn = dn_of_future_dn future_dn h_pub master_sig in
|
||||||
Config.Coin.all_coins
|
let* () = Pg.insert_denom conn dn |> unwrap_err_caqti in
|
||||||
|> List.find_opt (fun coin ->
|
Ok ())
|
||||||
coin.Config.Coin.section_name = section_name)
|
|
||||||
|> function
|
|
||||||
| Some v -> Ok v
|
|
||||||
| None ->
|
|
||||||
Fmt.error "coin `%s` not found in configuration" section_name
|
|
||||||
in
|
|
||||||
let future_dn = make_future_dn ~coin ~pub ~start:t1 in
|
|
||||||
let dn = dn_of_future_dn future_dn h_pub master_sig in
|
|
||||||
let* () = Pg.insert_denom conn dn |> unwrap_err_caqti in
|
|
||||||
Ok ()
|
|
||||||
|
|
||||||
let revoke_signkey pub revoked_sig =
|
let revoke_signkey pub revoked_sig =
|
||||||
let* opt = find_signkey pub in
|
let* opt = find_signkey pub in
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue