futur.blue
+10
-4
pegasus/lib/repository.ml
+10
-4
pegasus/lib/repository.ml
···
274
274
let path = Format.sprintf "%s/%s" collection rkey in
275
275
let uri = Format.sprintf "at://%s/%s" t.did path in
276
276
let%lwt existing_record = User_store.get_record t.db path in
277
-
let old_cid = Option.map (fun (r : record) -> r.cid) existing_record in
277
+
let old_cid =
278
+
Option.map (fun (r : record) -> r.cid) existing_record
279
+
in
278
280
( if
279
281
(swap_record <> None && swap_record <> old_cid)
280
282
|| (swap_record = None && old_cid = None)
···
389
391
let commit_block =
390
392
new_commit_signed |> signed_commit_to_yojson |> Dag_cbor.encode_yojson
391
393
in
392
-
let proof_keys = List.map (fun ({path; _} : commit_evt_op) -> path) commit_ops in
393
-
let%lwt proof_blocks = Cached_mst.proof_for_keys new_mst new_mst.root proof_keys in
394
+
let proof_keys =
395
+
List.map (fun ({path; _} : commit_evt_op) -> path) commit_ops
396
+
in
397
+
let%lwt proof_blocks =
398
+
Cached_mst.proof_for_keys new_mst new_mst.root proof_keys
399
+
in
394
400
let proof_blocks = Block_map.merge proof_blocks !added_leaves in
395
401
let block_stream =
396
402
proof_blocks |> Block_map.entries |> Lwt_seq.of_list
···
567
573
in
568
574
let record_data = List.rev record_data in
569
575
let%lwt _ =
570
-
Util.use_pool t.db.db (fun conn ->
576
+
Util.use_pool ~timeout:600. t.db.db (fun conn ->
571
577
Util.transact conn (fun () ->
572
578
let$! _ = User_store.Queries.put_commit root commit_bytes conn in
573
579
let$! () = User_store.Queries.clear_mst conn in