+6 -1

packages/consumer/client.ts

··· 134 }); 135 136 yield { 0 137 tid: memo.tid, 138 text: decrypted, 139 }; ··· 182 length: record.contentLength, 183 }); 184 185 - const command = yield { tid: record.tid, text: decrypted }; 0 0 0 0 186 187 if (command === "stop") return; 188 }

··· 134 }); 135 136 yield { 137 + key: record.uri.split("/").pop() as RecordKey, 138 tid: memo.tid, 139 text: decrypted, 140 }; ··· 183 length: record.contentLength, 184 }); 185 186 + const command = yield { 187 + key: event.commit.rkey, 188 + tid: record.tid, 189 + text: decrypted, 190 + }; 191 192 if (command === "stop") return; 193 }

+1 -1

packages/consumer/deno.jsonc

··· 1 { 2 "name": "@cistern/consumer", 3 - "version": "1.0.2", 4 "license": "MIT", 5 "exports": { 6 ".": "./mod.ts"

··· 1 { 2 "name": "@cistern/consumer", 3 + "version": "1.0.3", 4 "license": "MIT", 5 "exports": { 6 ".": "./mod.ts"

+4 -1

packages/consumer/types.ts

··· 1 import type { BaseClientOptions, ClientRequirements } from "@cistern/shared"; 2 - import type { ResourceUri, Tid } from "@atcute/lexicons"; 3 4 /** 5 * A locally-stored key pair suitable for storage ··· 34 35 /** A simplified, encrypted memo */ 36 export interface DecryptedMemo { 0 0 0 37 /** TID for when the memo was created */ 38 tid: Tid; 39

··· 1 import type { BaseClientOptions, ClientRequirements } from "@cistern/shared"; 2 + import type { RecordKey, ResourceUri, Tid } from "@atcute/lexicons"; 3 4 /** 5 * A locally-stored key pair suitable for storage ··· 34 35 /** A simplified, encrypted memo */ 36 export interface DecryptedMemo { 37 + /** Record key of this memo */ 38 + key: RecordKey; 39 + 40 /** TID for when the memo was created */ 41 tid: Tid; 42