objective categorical abstract machine language personal data server
Ensure repo is active at all unauthed endpoints
+2
-2
+1
-1
pegasus/lib/api/repo/getRecord.ml
+1
-1
pegasus/lib/api/repo/getRecord.ml
···
8
8
Xrpc.handler (fun ctx ->
9
9
let input = Xrpc.parse_query ctx.req query_of_yojson in
10
10
let%lwt input_did = Xrpc.resolve_repo_did ctx input.repo in
11
-
let%lwt repo = Repository.load input_did in
11
+
let%lwt repo = Repository.load ~ensure_active:true input_did in
12
12
let path = input.collection ^ "/" ^ input.rkey in
13
13
let uri = "at://" ^ input_did ^ "/" ^ path in
14
14
match%lwt Repository.get_record repo path with
+1
-1
pegasus/lib/api/repo/listRecords.ml
+1
-1
pegasus/lib/api/repo/listRecords.ml
···
23
23
100
24
24
in
25
25
let%lwt input_did = Xrpc.resolve_repo_did ctx input.repo in
26
-
let%lwt db = User_store.connect input_did in
26
+
let%lwt {db; _} = Repository.load ~ensure_active:true input_did in
27
27
let%lwt results =
28
28
User_store.list_records db ~limit ?cursor:input.cursor
29
29
?reverse:input.reverse input.collection