feat(consumer): generate key pairs

deno.lock

···
     "jsr:@noble/hashes@2.0": "2.0.1",
     "jsr:@noble/hashes@^2.0.1": "2.0.1",
     "jsr:@noble/post-quantum@~0.5.2": "0.5.2",
+    "jsr:@puregarlic/randimal@^1.0.1": "1.0.1",
     "jsr:@std/assert@^1.0.14": "1.0.14",
     "jsr:@std/expect@^1.0.17": "1.0.17",
     "jsr:@std/internal@^1.0.10": "1.0.10",
···
         "jsr:@noble/curves",
         "jsr:@noble/hashes@2.0"
       ]
+    },
+    "@puregarlic/randimal@1.0.1": {
+      "integrity": "101da9e89561f4b8038426f47f6cb258484a11887e1f4d8a2b07cd5ebf487a5d"
     },
     "@std/assert@1.0.14": {
       "integrity": "68d0d4a43b365abc927f45a9b85c639ea18a9fab96ad92281e493e4ed84abaa4",
···
     "members": {
       "packages/consumer": {
         "dependencies": [
+          "jsr:@puregarlic/randimal@^1.0.1",
+          "npm:@atcute/atproto@^3.1.9",
           "npm:@atcute/client@^4.0.5",
           "npm:@atcute/lexicons@^1.2.2"
         ]

packages/consumer/deno.jsonc

···
     ".": "./mod.ts"
   },
   "imports": {
+    "@atcute/atproto": "npm:@atcute/atproto@^3.1.9",
     "@atcute/client": "npm:@atcute/client@^4.0.5",
-    "@atcute/lexicons": "npm:@atcute/lexicons@^1.2.2"
+    "@atcute/lexicons": "npm:@atcute/lexicons@^1.2.2",
+    "@puregarlic/randimal": "jsr:@puregarlic/randimal@^1.0.1"
   }
 }

packages/consumer/mod.ts

···
-import type { Client, CredentialManager } from "@atcute/client";
 import { produceRequirements } from "@cistern/shared";
+import { generateKeys } from "@cistern/crypto";
+import { generateRandomName } from "@puregarlic/randimal";
 import type { Did } from "@atcute/lexicons/syntax";
+import type { Client, CredentialManager } from "@atcute/client";
+import type { AppCisternLexiconPubkey } from "@cistern/lexicon";
 import type { ConsumerOptions, ConsumerParams, LocalKeyPair } from "./types.ts";
+
+import type {} from "@atcute/atproto";
 
 export async function createConsumer(
   options: ConsumerOptions,
···
 
   constructor(params: ConsumerParams) {
     this.did = params.miniDoc.did;
-    this.keypair = params.options.keypair;
+    this.keypair = params.options.keypair
+      ? {
+        privateKey: Uint8Array.fromBase64(params.options.keypair.privateKey),
+        publicKey: params.options.keypair.publicKey,
+      }
+      : undefined;
     this.rpc = params.rpc;
     this.manager = params.manager;
   }
 
   /**
    * Generates a key pair, uploading the public key to PDS and returning the pair.
-   * @todo Generate key pair
-   * @todo Store private key in local registry
-   * @todo Upload public key to PDS
    */
-  async generateKeyPair() {}
+  async generateKeyPair(): Promise<LocalKeyPair> {
+    if (this.keypair) {
+      throw new Error("client already has a key pair");
+    }
+
+    const keys = generateKeys();
+    const name = await generateRandomName();
+
+    const record: AppCisternLexiconPubkey.Main = {
+      $type: "app.cistern.lexicon.pubkey",
+      name,
+      algorithm: "x_wing",
+      content: keys.publicKey.toBase64(),
+      createdAt: new Date().toISOString(),
+    };
+    const res = await this.rpc.post("com.atproto.repo.createRecord", {
+      input: {
+        collection: "app.cistern.lexicon.pubkey",
+        repo: this.did,
+        record,
+      },
+    });
+
+    if (!res.ok) {
+      throw new Error(
+        `failed to save public key: ${res.status} ${res.data.error}`,
+      );
+    }
+
+    const keypair = {
+      privateKey: keys.secretKey,
+      publicKey: res.data.uri,
+    };
+
+    this.keypair = keypair;
+
+    return keypair;
+  }
 
   /**
    * Returns an async iterator that returns pages of the user's items from their PDS.

packages/consumer/types.ts

···
 import type { BaseClientOptions, ClientRequirements } from "@cistern/shared";
-import type { AppCisternLexiconPubkey } from "@cistern/lexicon";
+import type { ResourceUri } from "@atcute/lexicons";
+
+export interface InputLocalKeyPair {
+  privateKey: string;
+  publicKey: ResourceUri;
+}
 
 export interface LocalKeyPair {
-  privateKey: string;
-  publicKey: AppCisternLexiconPubkey.Main;
+  privateKey: Uint8Array;
+  publicKey: ResourceUri;
 }
 
 export interface ConsumerOptions extends BaseClientOptions {
-  keypair?: LocalKeyPair;
+  keypair?: InputLocalKeyPair;
 }
 
 export type ConsumerParams = ClientRequirements<ConsumerOptions>;