wip debug
This commit is contained in:
parent
84a0543a50
commit
2f2befa1f6
6 changed files with 66 additions and 15 deletions
|
|
@ -13,15 +13,21 @@ let avail_languages_header_value =
|
||||||
s
|
s
|
||||||
|
|
||||||
let select_mimetype headers =
|
let select_mimetype headers =
|
||||||
let accept = Vif.Headers.get headers "accept" in
|
let opt = Vif.Headers.get headers "accept" in
|
||||||
Cohttp.Accept.media_ranges accept
|
Logs.err (fun m ->
|
||||||
|
let s = Option.value ~default:"none" opt in
|
||||||
|
m "Header accept: %s" s);
|
||||||
|
Cohttp.Accept.media_ranges opt
|
||||||
|> Cohttp.Accept.qsort
|
|> Cohttp.Accept.qsort
|
||||||
|> List.filter_map (fun (_q, (m, _p)) -> Assets.Mimetype.of_cohttp_media m)
|
|> List.filter_map (fun (_q, (m, _p)) -> Assets.Mimetype.of_cohttp_media m)
|
||||||
|> List.find_opt Assets.is_supported_mimetype
|
|> List.find_opt Assets.is_supported_mimetype
|
||||||
|
|
||||||
let select_language headers =
|
let select_language headers =
|
||||||
let accept_language = Vif.Headers.get headers "accept-language" in
|
let opt = Vif.Headers.get headers "accept-language" in
|
||||||
Cohttp.Accept.languages accept_language
|
Logs.err (fun m ->
|
||||||
|
let s = Option.value ~default:"none" opt in
|
||||||
|
m "Header accept-language: %s" s);
|
||||||
|
Cohttp.Accept.languages opt
|
||||||
|> Cohttp.Accept.qsort
|
|> Cohttp.Accept.qsort
|
||||||
|> List.map (fun (_q, lang) -> lang)
|
|> List.map (fun (_q, lang) -> lang)
|
||||||
|> List.map (function
|
|> List.map (function
|
||||||
|
|
@ -35,8 +41,11 @@ let select_language headers =
|
||||||
|> Option.value ~default:Assets.default_lang
|
|> Option.value ~default:Assets.default_lang
|
||||||
|
|
||||||
let select_encoding headers =
|
let select_encoding headers =
|
||||||
Vif.Headers.get headers "accept-encoding"
|
let opt = Vif.Headers.get headers "accept-encoding" in
|
||||||
|> Cohttp.Accept.encodings
|
Logs.err (fun m ->
|
||||||
|
let s = Option.value ~default:"none" opt in
|
||||||
|
m "Header accept-encoding: %s" s);
|
||||||
|
Cohttp.Accept.encodings opt
|
||||||
|> Cohttp.Accept.qsort
|
|> Cohttp.Accept.qsort
|
||||||
|> List.map snd
|
|> List.map snd
|
||||||
|> List.filter_map (function
|
|> List.filter_map (function
|
||||||
|
|
|
||||||
|
|
@ -190,7 +190,10 @@ let mk_keys ~db_conn (module Sm : Secmod.S) ~last_issue_date =
|
||||||
|
|
||||||
let recoup = (* TODO /recoup *) [] in
|
let recoup = (* TODO /recoup *) [] in
|
||||||
let* global_fees =
|
let* global_fees =
|
||||||
|
(* WIP DEBUG
|
||||||
Pg.get_global_fees db_conn ~start_date:Timestamp.zero |> unwrap_err_caqti
|
Pg.get_global_fees db_conn ~start_date:Timestamp.zero |> unwrap_err_caqti
|
||||||
|
*)
|
||||||
|
Ok []
|
||||||
in
|
in
|
||||||
let* auditors =
|
let* auditors =
|
||||||
(* TODO /auditors/$AUDITOR_PUB/$H_DENOM_PUB *)
|
(* TODO /auditors/$AUDITOR_PUB/$H_DENOM_PUB *)
|
||||||
|
|
@ -241,7 +244,7 @@ let jsont = ExchangeKeysResponse.jsont
|
||||||
|
|
||||||
(* TODO query param ?last_issue_date *)
|
(* TODO query param ?last_issue_date *)
|
||||||
let f req server _env =
|
let f 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 sm = Vif.Server.device Devices.secmod server in
|
let sm = Vif.Server.device Devices.secmod server in
|
||||||
let res =
|
let res =
|
||||||
|
|
|
||||||
|
|
@ -135,6 +135,7 @@ module Keys_post = struct
|
||||||
fee_withdraw= denom.fee_withdraw;
|
fee_withdraw= denom.fee_withdraw;
|
||||||
fee_deposit= denom.fee_deposit;
|
fee_deposit= denom.fee_deposit;
|
||||||
fee_refresh= denom.fee_refresh;
|
fee_refresh= denom.fee_refresh;
|
||||||
|
fee_refund= denom.fee_refund;
|
||||||
denom_hash= h_denom_pub;
|
denom_hash= h_denom_pub;
|
||||||
}
|
}
|
||||||
in
|
in
|
||||||
|
|
|
||||||
|
|
@ -248,6 +248,9 @@ module DenominationKeyValidity = struct
|
||||||
fee_withdraw: AmountNBO.t;
|
fee_withdraw: AmountNBO.t;
|
||||||
fee_deposit: AmountNBO.t;
|
fee_deposit: AmountNBO.t;
|
||||||
fee_refresh: AmountNBO.t;
|
fee_refresh: AmountNBO.t;
|
||||||
|
(* TODO debug sig
|
||||||
|
missing field from taler doc *)
|
||||||
|
fee_refund: AmountNBO.t;
|
||||||
denom_hash: DenominationHash.t;
|
denom_hash: DenominationHash.t;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -267,6 +270,7 @@ module DenominationKeyValidity = struct
|
||||||
fee_withdraw
|
fee_withdraw
|
||||||
fee_deposit
|
fee_deposit
|
||||||
fee_refresh
|
fee_refresh
|
||||||
|
fee_refund
|
||||||
denom_hash
|
denom_hash
|
||||||
->
|
->
|
||||||
{
|
{
|
||||||
|
|
@ -279,6 +283,7 @@ module DenominationKeyValidity = struct
|
||||||
fee_withdraw;
|
fee_withdraw;
|
||||||
fee_deposit;
|
fee_deposit;
|
||||||
fee_refresh;
|
fee_refresh;
|
||||||
|
fee_refund;
|
||||||
denom_hash;
|
denom_hash;
|
||||||
})
|
})
|
||||||
|+ Purpose.field purpose
|
|+ Purpose.field purpose
|
||||||
|
|
@ -291,6 +296,7 @@ module DenominationKeyValidity = struct
|
||||||
|+ field AmountNBO.bin (fun t -> t.fee_withdraw)
|
|+ field AmountNBO.bin (fun t -> t.fee_withdraw)
|
||||||
|+ field AmountNBO.bin (fun t -> t.fee_deposit)
|
|+ field AmountNBO.bin (fun t -> t.fee_deposit)
|
||||||
|+ field AmountNBO.bin (fun t -> t.fee_refresh)
|
|+ field AmountNBO.bin (fun t -> t.fee_refresh)
|
||||||
|
|+ field AmountNBO.bin (fun t -> t.fee_refund)
|
||||||
|+ field DenominationHash.bin (fun t -> t.denom_hash)
|
|+ field DenominationHash.bin (fun t -> t.denom_hash)
|
||||||
|> sealr
|
|> sealr
|
||||||
end
|
end
|
||||||
|
|
|
||||||
|
|
@ -19,11 +19,13 @@ module Respond_with = struct
|
||||||
let code = -1 in
|
let code = -1 in
|
||||||
let err = ErrorDetail.make ?hint code in
|
let err = ErrorDetail.make ?hint code in
|
||||||
let s = encode_exn ErrorDetail.jsont err in
|
let s = encode_exn ErrorDetail.jsont err in
|
||||||
|
Logs.err (fun m -> m "ErrorDetail: `%s`" s);
|
||||||
s
|
s
|
||||||
end
|
end
|
||||||
|
|
||||||
let bad_request ?hint req =
|
let bad_request ?hint req =
|
||||||
let body = error_detail ?hint `Bad_request in
|
let body = error_detail ?hint `Bad_request in
|
||||||
|
let* () = add ~field:"content-type" "application/json" in
|
||||||
let* () = with_string ?compression:None req body in
|
let* () = with_string ?compression:None req body in
|
||||||
respond `Bad_request
|
respond `Bad_request
|
||||||
|
|
||||||
|
|
@ -35,12 +37,13 @@ module Respond_with = struct
|
||||||
let body =
|
let body =
|
||||||
error_detail ~hint:"no acceptable mimetype" `Unsupported_media_type
|
error_detail ~hint:"no acceptable mimetype" `Unsupported_media_type
|
||||||
in
|
in
|
||||||
let* () = with_string ?compression:None req body in
|
let* () = add ~field:"content-type" "application/json" in
|
||||||
let* () = add ~field:"accept" Headers.accept_header_value in
|
let* () = add ~field:"accept" Headers.accept_header_value in
|
||||||
|
let* () = with_string ?compression:None req body in
|
||||||
respond `Unsupported_media_type
|
respond `Unsupported_media_type
|
||||||
end
|
end
|
||||||
|
|
||||||
let aux kind req _server _env =
|
let _aux kind req _server _env =
|
||||||
let etag = Assets.etag kind in
|
let etag = Assets.etag kind in
|
||||||
let headers = Vif.Request.headers req in
|
let headers = Vif.Request.headers req in
|
||||||
let has_matching_etag =
|
let has_matching_etag =
|
||||||
|
|
@ -50,11 +53,17 @@ let aux kind req _server _env =
|
||||||
Headers_lib.Etag.parse s |> Result.map (Headers_lib.Etag.evaluate etag)
|
Headers_lib.Etag.parse s |> Result.map (Headers_lib.Etag.evaluate etag)
|
||||||
in
|
in
|
||||||
match has_matching_etag with
|
match has_matching_etag with
|
||||||
| Error e -> Respond_with.bad_request ~hint:e req
|
| Error e ->
|
||||||
| Ok true -> Respond_with.not_modified ()
|
Logs.err (fun m -> m "bad request");
|
||||||
|
Respond_with.bad_request ~hint:e req
|
||||||
|
| Ok true ->
|
||||||
|
Logs.err (fun m -> m "not modified");
|
||||||
|
Respond_with.not_modified ()
|
||||||
| Ok false -> (
|
| Ok false -> (
|
||||||
match Headers.select_mimetype headers with
|
match Headers.select_mimetype headers with
|
||||||
| None -> Respond_with.unsupported_media_type req
|
| None ->
|
||||||
|
Logs.err (fun m -> m "unsupported_media_type");
|
||||||
|
Respond_with.unsupported_media_type req
|
||||||
| Some mime ->
|
| Some mime ->
|
||||||
let lang = Headers.select_language headers in
|
let lang = Headers.select_language headers in
|
||||||
let compression = Headers.select_encoding headers in
|
let compression = Headers.select_encoding headers in
|
||||||
|
|
@ -80,5 +89,27 @@ let aux kind req _server _env =
|
||||||
in
|
in
|
||||||
respond `OK)
|
respond `OK)
|
||||||
|
|
||||||
let terms req _server _env = aux Assets.Terms req _server _env
|
(* WIP DEBUG *)
|
||||||
let privacy req _server _env = aux Assets.Privacy req _server _env
|
let aux _kind req _server _env =
|
||||||
|
let open Vif.Response in
|
||||||
|
let open Syntax in
|
||||||
|
let data = "uhuh" in
|
||||||
|
let etag = "0" in
|
||||||
|
let content_type = "text/plain" in
|
||||||
|
let* () = with_string req data in
|
||||||
|
let* () = add ~field:"etag" etag in
|
||||||
|
let* () =
|
||||||
|
(* todo: is it "taler-privacy-version" for /policy ? *)
|
||||||
|
add ~field:"taler-terms-version" Assets.terms_legal_version
|
||||||
|
in
|
||||||
|
let* () = add ~field:"avail-languages" Headers.avail_languages_header_value in
|
||||||
|
let* () = add ~field:"content-type" content_type in
|
||||||
|
respond `OK
|
||||||
|
|
||||||
|
let terms req _server _env =
|
||||||
|
Logs.info (fun m -> m "GET /terms");
|
||||||
|
aux Assets.Terms req _server _env
|
||||||
|
|
||||||
|
let privacy req _server _env =
|
||||||
|
Logs.info (fun m -> m "GET /privacy");
|
||||||
|
aux Assets.Privacy req _server _env
|
||||||
|
|
|
||||||
|
|
@ -87,7 +87,7 @@ let mk_future_keys =
|
||||||
fee_withdraw;
|
fee_withdraw;
|
||||||
fee_deposit;
|
fee_deposit;
|
||||||
fee_refresh;
|
fee_refresh;
|
||||||
fee_refund= _;
|
fee_refund;
|
||||||
denom_secmod_sig= _;
|
denom_secmod_sig= _;
|
||||||
} =
|
} =
|
||||||
let octets = DenominationKey.to_octets denom_pub in
|
let octets = DenominationKey.to_octets denom_pub in
|
||||||
|
|
@ -107,6 +107,7 @@ let mk_future_keys =
|
||||||
fee_withdraw;
|
fee_withdraw;
|
||||||
fee_deposit;
|
fee_deposit;
|
||||||
fee_refresh;
|
fee_refresh;
|
||||||
|
fee_refund;
|
||||||
denom_hash= h_denom_pub;
|
denom_hash= h_denom_pub;
|
||||||
}
|
}
|
||||||
in
|
in
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue