objective categorical abstract machine language personal data server
Get account creation working 🎉
+9
-9
+3
-3
pegasus/lib/api/repo/createAccount.ml
+3
-3
pegasus/lib/api/repo/createAccount.ml
···
53
53
| _ ->
54
54
Lwt.return ()
55
55
in
56
-
let signing_key, signing_pubkey = Kleidos.P256.generate_keypair () in
56
+
let signing_key, signing_pubkey = Kleidos.K256.generate_keypair () in
57
57
let%lwt did =
58
58
match input.did with
59
59
| Some did -> (
···
63
63
| None ->
64
64
Lwt.return did )
65
65
| None -> (
66
-
let sk_did = Kleidos.P256.pubkey_to_did_key signing_pubkey in
66
+
let sk_did = Kleidos.K256.pubkey_to_did_key signing_pubkey in
67
67
let rotation_did_keys =
68
68
match input.recovery_key with Some rk -> [rk] | None -> []
69
69
in
···
87
87
| None ->
88
88
Lwt.return ()
89
89
in
90
-
let sk_priv_mk = Kleidos.P256.privkey_to_multikey signing_key in
90
+
let sk_priv_mk = Kleidos.K256.privkey_to_multikey signing_key in
91
91
let%lwt () =
92
92
Data_store.create_actor ~did ~handle:input.handle ~email:input.email
93
93
~password:input.password ~signing_key:sk_priv_mk ctx.db
+2
-1
pegasus/lib/repository.ml
+2
-1
pegasus/lib/repository.ml
···
419
419
let%lwt blocks =
420
420
Car.blocks_to_stream commit_cid block_stream |> Car.collect_stream
421
421
in
422
+
let%lwt ds = Data_store.connect () in
422
423
let%lwt _ =
423
-
Sequencer.sequence_commit t.db.db ~did:t.did ~commit:commit_cid
424
+
Sequencer.sequence_commit ds ~did:t.did ~commit:commit_cid
424
425
~rev:commit_signed.rev ~blocks ~ops:!commit_ops ~since:commit.rev
425
426
~prev_data:commit.data ()
426
427
in
+3
-3
pegasus/lib/user_store.ml
+3
-3
pegasus/lib/user_store.ml
···
77
77
in
78
78
[%rapper
79
79
execute
80
-
{sql| CREATE TABLE IF NOT EXISTS commit (
80
+
{sql| CREATE TABLE IF NOT EXISTS repo_commit (
81
81
id INTEGER PRIMARY KEY CHECK (id = 0),
82
82
cid TEXT NOT NULL,
83
83
data BLOB NOT NULL
···
126
126
[%rapper
127
127
get_opt
128
128
{sql| SELECT @CID{cid}, @Blob{data}
129
-
FROM commit WHERE id = 0
129
+
FROM repo_commit WHERE id = 0
130
130
|sql}]
131
131
()
132
132
133
133
let put_commit cid data =
134
134
[%rapper
135
135
execute
136
-
{sql| INSERT INTO commit (id, cid, data)
136
+
{sql| INSERT INTO repo_commit (id, cid, data)
137
137
VALUES (0, %CID{cid}, %Blob{data})
138
138
ON CONFLICT(id) DO UPDATE SET
139
139
cid = excluded.cid,
+1
-2
pegasus/lib/util.ml
+1
-2
pegasus/lib/util.ml
···
198
198
Uri.add_query_params' db_uri
199
199
[("create", string_of_bool create); ("write", string_of_bool write)]
200
200
in
201
-
Dream.log "%s" (Uri.to_string uri) ;
202
201
match
203
202
Caqti_lwt_unix.connect_pool
204
203
~post_connect:(fun conn -> Lwt_result.ok @@ _init_connection conn)
···
309
308
Ok ()
310
309
311
310
let mkfile_p path ~perm =
312
-
Core_unix.mkdir_p (Filename.dirname path) ~perm:0o644 ;
311
+
Core_unix.mkdir_p (Filename.dirname path) ~perm:0o755 ;
313
312
Core_unix.openfile ~mode:[O_CREAT; O_WRONLY] ~perm path |> Core_unix.close