~
This commit is contained in:
parent
2ceecb5aba
commit
9cfdd00922
6 changed files with 51 additions and 30 deletions
|
|
@ -2,7 +2,7 @@ version=0.28.1
|
||||||
exp-grouping=preserve
|
exp-grouping=preserve
|
||||||
type-decl=sparse
|
type-decl=sparse
|
||||||
break-infix=fit-or-vertical
|
break-infix=fit-or-vertical
|
||||||
break-collection-expressions=wrap
|
break-collection-expressions=fit-or-vertical
|
||||||
break-sequences=false
|
break-sequences=false
|
||||||
break-infix-before-func=false
|
break-infix-before-func=false
|
||||||
dock-collection-brackets=true
|
dock-collection-brackets=true
|
||||||
|
|
|
||||||
|
|
@ -56,7 +56,8 @@ let of_string =
|
||||||
choice
|
choice
|
||||||
[
|
[
|
||||||
char '+' *> return (Some Sign_plus);
|
char '+' *> return (Some Sign_plus);
|
||||||
char '-' *> return (Some Sign_minus); return None;
|
char '-' *> return (Some Sign_minus);
|
||||||
|
return None;
|
||||||
]
|
]
|
||||||
in
|
in
|
||||||
let parse_currency =
|
let parse_currency =
|
||||||
|
|
|
||||||
|
|
@ -17,10 +17,14 @@ let privacy_legal_version = "1"
|
||||||
module Mimetype = struct
|
module Mimetype = struct
|
||||||
let mimetype_extension_assoc =
|
let mimetype_extension_assoc =
|
||||||
[
|
[
|
||||||
(("text", "plain"), ".txt"); (("text", "markdown"), ".md");
|
(("text", "plain"), ".txt");
|
||||||
(("text", "html"), ".html"); (("text", "html"), ".htm");
|
(("text", "markdown"), ".md");
|
||||||
(("application", "pdf"), ".pdf"); (("image", "jpeg"), ".jpg");
|
(("text", "html"), ".html");
|
||||||
(("image", "jpeg"), ".jpeg"); (("image", "png"), ".png");
|
(("text", "html"), ".htm");
|
||||||
|
(("application", "pdf"), ".pdf");
|
||||||
|
(("image", "jpeg"), ".jpg");
|
||||||
|
(("image", "jpeg"), ".jpeg");
|
||||||
|
(("image", "png"), ".png");
|
||||||
(("image", "gif"), ".gif");
|
(("image", "gif"), ".gif");
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -2,12 +2,7 @@
|
||||||
- GNU Taler db-events?
|
- GNU Taler db-events?
|
||||||
it seems caqti/pgx does not support it *)
|
it seems caqti/pgx does not support it *)
|
||||||
|
|
||||||
let test_activate req server _ =
|
let on_ok req () =
|
||||||
let db_conn = Vif.Server.device Devices.db_connection server in
|
|
||||||
let secmod_signkey = Vif.Server.device Devices.secmod_signkey server in
|
|
||||||
let exchange_public_key = secmod_signkey.sm_key in
|
|
||||||
match Pg.activate_signing_key db_conn exchange_public_key with
|
|
||||||
| Ok () ->
|
|
||||||
let open Vif.Response.Syntax in
|
let open Vif.Response.Syntax in
|
||||||
let* () =
|
let* () =
|
||||||
Vif.Response.add ~field:"content-type" "text/plain; charset= utf-8"
|
Vif.Response.add ~field:"content-type" "text/plain; charset= utf-8"
|
||||||
|
|
@ -16,10 +11,23 @@ let test_activate req server _ =
|
||||||
Vif.Response.with_string req (Fmt.str "activate_signing_key done~~@.")
|
Vif.Response.with_string req (Fmt.str "activate_signing_key done~~@.")
|
||||||
in
|
in
|
||||||
Vif.Response.respond `OK
|
Vif.Response.respond `OK
|
||||||
| Error err ->
|
|
||||||
(* TODO don't leak private data in error messages *)
|
let on_error req err =
|
||||||
|
(* TODO be sure to not leak private data in error messages *)
|
||||||
let open Vif.Response.Syntax in
|
let open Vif.Response.Syntax in
|
||||||
let str = Fmt.str "Database error: %a." Caqti_error.pp err in
|
let str = Fmt.str "Database error: %a." Caqti_error.pp err in
|
||||||
Logs.err (fun m -> m "%s" str);
|
Logs.err (fun m -> m "%s" str);
|
||||||
let* () = Vif.Response.with_string req str in
|
let* () = Vif.Response.with_string req str in
|
||||||
Vif.Response.respond `Internal_server_error
|
Vif.Response.respond `Internal_server_error
|
||||||
|
|
||||||
|
(* TODO master_sig *)
|
||||||
|
let dummy_master_sig =
|
||||||
|
Option.some @@ Crypto.EddsaSignature.of_octets (String.make 64 '\x00')
|
||||||
|
|
||||||
|
let test_activate req server _ =
|
||||||
|
let db_conn = Vif.Server.device Devices.db_connection server in
|
||||||
|
let secmod_signkey = Vif.Server.device Devices.secmod_signkey server in
|
||||||
|
let sm_key = secmod_signkey.sm_key in
|
||||||
|
let sm_key = { sm_key with master_sig= dummy_master_sig } in
|
||||||
|
let res = Pg.activate_signing_key db_conn sm_key in
|
||||||
|
Result.fold ~ok:(on_ok req) ~error:(on_error req) res
|
||||||
|
|
|
||||||
13
src/mte.ml
13
src/mte.ml
|
|
@ -24,11 +24,16 @@ let routes =
|
||||||
let open Vif.Uri in
|
let open Vif.Uri in
|
||||||
let open Vif.Route in
|
let open Vif.Route in
|
||||||
let open Vif.Type in
|
let open Vif.Type in
|
||||||
|
(* just for alignement *)
|
||||||
|
let get_ = get in
|
||||||
|
let post = Fun.flip post in
|
||||||
[
|
[
|
||||||
get (rel /?? nil) --> hello; get (rel / "terms" /?? nil) --> Static.terms;
|
get_ (rel /?? nil) --> hello;
|
||||||
get (rel / "privacy" /?? nil) --> Static.privacy;
|
get_ (rel / "terms" /?? nil) --> Static.terms;
|
||||||
get (rel / "management" / "keys" /?? nil) --> Management.keys_get;
|
get_ (rel / "privacy" /?? nil) --> Static.privacy;
|
||||||
post any (rel / "management" / "keys" /?? nil) --> Management.keys_post;
|
get_ (rel / "test" /?? nil) --> Database.test_activate;
|
||||||
|
get_ (rel / "management" / "keys" /?? nil) --> Management.keys_get;
|
||||||
|
post (rel / "management" / "keys" /?? nil) any --> Management.keys_post;
|
||||||
]
|
]
|
||||||
|
|
||||||
let () =
|
let () =
|
||||||
|
|
|
||||||
|
|
@ -71,8 +71,11 @@ let preflight =
|
||||||
Caqti_type.(unit ->. unit)
|
Caqti_type.(unit ->. unit)
|
||||||
[
|
[
|
||||||
"SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL \
|
"SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL \
|
||||||
SERIALIZABLE;"; "SET enable_sort=OFF;"; "SET enable_seqscan=OFF;";
|
SERIALIZABLE;";
|
||||||
"SET enable_mergejoin=OFF;"; "SET search_path TO exchange;";
|
"SET enable_sort=OFF;";
|
||||||
|
"SET enable_seqscan=OFF;";
|
||||||
|
"SET enable_mergejoin=OFF;";
|
||||||
|
"SET search_path TO exchange;";
|
||||||
]
|
]
|
||||||
in
|
in
|
||||||
fun (module Conn : Caqti_miou.CONNECTION) ->
|
fun (module Conn : Caqti_miou.CONNECTION) ->
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue