[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_228":-5,"_231":232,"_233":234},"routes/shell",{"_40":41,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":31,"_43":31,"_44":31,"_45":31,"_46":31,"_47":31,"_48":49,"_50":49,"_51":31,"_52":-7,"_53":-7,"_54":55,"_56":57,"_58":59,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":14,"_22":23,"_24":-5,"_25":26,"_27":28,"_28":29,"_30":31,"_32":14},"ref","beb8a54dca3abf74ad8c9e2f0eecf8ef1e3e720e","path","apps/server/src/storage/memory/adapter.ts","oid","eefd08b00f5bdb8b796eb6a8d8f7f6c8d4e125a7","size",23435,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { conflict, missing } from \"../errors\";\nimport { documentSlug, documentSlugCandidate } from \"../../channels/slug\";\nimport { MemoryBackgroundJobStore } from \"./jobs\";\n\nimport type {\n\tAddUserProject,\n\tAddUserProjectResult,\n\tAgentState,\n\tChannelCursor,\n\tChannelPage,\n\tChannelRecord,\n\tChannelScanCursor,\n\tChannelScanPage,\n\tChannelSnapshot,\n\tChannelUpdate,\n\tCommitChannel,\n\tCommitResult,\n\tCreateChannel,\n\tJsonValue,\n\tLease,\n\tRecordNavigationVisit,\n\tRenameChannel,\n\tRenameResult,\n\tReplaceChannel,\n\tSaveCheckpoint,\n\tStoredChannel,\n\tStoredEvent,\n\tUpdateAgentContext,\n\tUserNavigation,\n\tUserProject,\n\tUserRecord,\n\tWebSession,\n} from \"../model\";\nimport type {\n\tBackgroundJobStore,\n\tChannelStore,\n\tCollaborationStore,\n\tLeaseStore,\n\tNavigationStore,\n\tSessionStore,\n\tStorageAdapter,\n\tUserStore,\n} from \"../port\";\n\nfunction bytes(value: Uint8Array): Uint8Array {\n\treturn new Uint8Array(value);\n}\n\nfunction json(value: JsonValue): JsonValue {\n\treturn structuredClone(value);\n}\n\nfunction user(value: UserRecord): UserRecord {\n\treturn { ...value, createdAt: new Date(value.createdAt), updatedAt: new Date(value.updatedAt) };\n}\n\nfunction session(value: WebSession): WebSession {\n\treturn {\n\t\t...value,\n\t\texpiresAt: new Date(value.expiresAt),\n\t\tcreatedAt: new Date(value.createdAt),\n\t};\n}\n\nfunction project(value: UserProject): UserProject {\n\treturn { ...value, addedAt: new Date(value.addedAt) };\n}\n\nfunction navigation(value: UserNavigation): UserNavigation {\n\treturn { ...value, updatedAt: new Date(value.updatedAt) };\n}\n\nfunction channel(value: ChannelRecord): ChannelRecord {\n\treturn { ...value, createdAt: new Date(value.createdAt), updatedAt: new Date(value.updatedAt) };\n}\n\nfunction snapshot(value: ChannelSnapshot): ChannelSnapshot {\n\treturn {\n\t\t...value,\n\t\tdocument: bytes(value.document),\n\t\tsidecar: json(value.sidecar),\n\t\tcreatedAt: new Date(value.createdAt),\n\t};\n}\n\nfunction agent(value: AgentState): AgentState {\n\treturn { ...value, updatedAt: new Date(value.updatedAt) };\n}\n\nfunction lease(value: Lease): Lease {\n\treturn { ...value, expiresAt: new Date(value.expiresAt) };\n}\n\ntype Operation = CommitResult;\n\n/** A strict in-memory adapter used by domain tests, not a production fallback. */\nexport class MemoryStorage implements StorageAdapter {\n\treadonly driver = \"memory\";\n\n\t#users = new Map();\n\t#sessions = new Map();\n\t#projects = new Map();\n\t#navigation = new Map();\n\t#channels = new Map();\n\t#channelSlugs = new Map>();\n\t#snapshots = new Map();\n\t#sequences = new Map();\n\t#updates = new Map();\n\t#events = new Map();\n\t#sidecars = new Map();\n\t#operations = new Map>();\n\t#agents = new Map();\n\t#leases = new Map();\n\n\treadonly users: UserStore = {\n\t\tput: input => {\n\t\t\tlet previous = this.#users.get(input.id);\n\t\t\tlet saved: UserRecord = {\n\t\t\t\tid: input.id,\n\t\t\t\tlogin: input.login,\n\t\t\t\tavatarUrl: input.avatarUrl,\n\t\t\t\tcreatedAt: previous?.createdAt ?? input.now,\n\t\t\t\tupdatedAt: input.now,\n\t\t\t};\n\t\t\tthis.#users.set(saved.id, saved);\n\t\t\treturn Promise.resolve(user(saved));\n\t\t},\n\t\tget: id => Promise.resolve(this.#users.get(id)).then(value => value && user(value)),\n\t};\n\n\treadonly sessions: SessionStore = {\n\t\tcreate: input => {\n\t\t\tif (!this.#users.has(input.userId)) throw missing(`user ${input.userId} does not exist`);\n\t\t\tif (this.#sessions.has(input.id)) throw conflict(`session ${input.id} already exists`);\n\t\t\tthis.#sessions.set(input.id, session(input));\n\t\t\treturn Promise.resolve();\n\t\t},\n\t\tget: (id, now) => {\n\t\t\tlet found = this.#sessions.get(id);\n\t\t\treturn Promise.resolve(found && found.expiresAt > now ? session(found) : undefined);\n\t\t},\n\t\tdelete: id => {\n\t\t\tlet deleted = this.#sessions.delete(id);\n\t\t\tif (deleted) this.#expireOwners(new Set([id]), new Date());\n\t\t\treturn Promise.resolve(deleted);\n\t\t},\n\t\tdeleteExpired: now => {\n\t\t\tlet expired = new Set();\n\t\t\tfor (let [id, value] of this.#sessions) {\n\t\t\t\tif (value.expiresAt <= now) {\n\t\t\t\t\tthis.#sessions.delete(id);\n\t\t\t\t\texpired.add(id);\n\t\t\t\t}\n\t\t\t}\n\t\t\tthis.#expireOwners(expired, now);\n\t\t\treturn Promise.resolve(expired.size);\n\t\t},\n\t\tdeleteAll: async (now, held, ttlMs) => {\n\t\t\tthis.#assertLease(held);\n\t\t\tlet deleted = new Set(this.#sessions.keys());\n\t\t\tthis.#sessions.clear();\n\t\t\tthis.#expireOwners(deleted, now);\n\t\t\tlet renewed = await this.#renew(held, ttlMs);\n\t\t\tif (!renewed) throw conflict(`storage lease ${held.name} is no longer held`);\n\t\t\treturn { deleted: deleted.size, lease: renewed };\n\t\t},\n\t};\n\n\treadonly navigation: NavigationStore = {\n\t\tprojects: userId => {\n\t\t\tthis.#requireUser(userId);\n\t\t\treturn Promise.resolve((this.#projects.get(userId) ?? []).map(project));\n\t\t},\n\t\taddProject: input => this.#addProject(input),\n\t\tget: userId => {\n\t\t\tthis.#requireUser(userId);\n\t\t\tlet found = this.#navigation.get(userId);\n\t\t\treturn Promise.resolve(found && navigation(found));\n\t\t},\n\t\tsetLastDocument: (userId, documentId, now) => this.#setLastDocument(userId, documentId, now),\n\t\trecordVisit: input => this.#recordVisit(input),\n\t};\n\n\treadonly channels: ChannelStore = {\n\t\tcreate: input => this.#createChannel(input),\n\t\tget: id => Promise.resolve(this.#channels.get(id)).then(value => value && channel(value)),\n\t\tresolve: (repositoryId, slug) => {\n\t\t\tlet id = this.#channelSlugs.get(repositoryId)?.get(slug);\n\t\t\tlet found = id ? this.#channels.get(id) : undefined;\n\t\t\treturn Promise.resolve(found && channel(found));\n\t\t},\n\t\trename: input => this.#renameChannel(input),\n\t\tlist: (repositoryId, limit, after, query) =>\n\t\t\tthis.#listChannels(repositoryId, limit, after, query),\n\t\tscan: (repositoryId, limit, after) => this.#scanChannels(repositoryId, limit, after),\n\t\tclaimAgentOwner: (channelId, sessionId, now) =>\n\t\t\tthis.#claimAgentOwner(channelId, sessionId, now),\n\t\tclearAgentOwner: (channelId, expectedSessionId, expectedGeneration, now) =>\n\t\t\tthis.#clearAgentOwner(channelId, expectedSessionId, expectedGeneration, now),\n\t\tupdateAgentContext: context => this.#updateAgentContext(context),\n\t\treadAgent: (channelId, now) => this.#readAgent(channelId, now),\n\t};\n\n\treadonly collaboration: CollaborationStore = {\n\t\tload: (channelId, now) => this.#load(channelId, now),\n\t\tcommit: input => this.#commit(input),\n\t\treplace: input => this.#replace(input),\n\t\tcheckpoint: input => this.#checkpoint(input),\n\t};\n\n\treadonly jobs: BackgroundJobStore = new MemoryBackgroundJobStore({\n\t\tchannelExists: channelId => this.#channels.has(channelId),\n\t\tassertLease: held => this.#assertLease(held),\n\t});\n\n\treadonly leases: LeaseStore = {\n\t\tacquire: (name, owner, ttlMs) => this.#acquire(name, owner, ttlMs),\n\t\trenew: (held, ttlMs) => this.#renew(held, ttlMs),\n\t\trelease: held => this.#release(held),\n\t};\n\n\tasync migrate(): Promise {}\n\n\tasync health(): Promise {}\n\n\tasync close(): Promise {}\n\n\t#expireOwners(expired: Set, now: Date): void {\n\t\tif (expired.size === 0) return;\n\t\tfor (let [id, state] of this.#agents) {\n\t\t\tif (state.ownerSessionId && expired.has(state.ownerSessionId)) {\n\t\t\t\tthis.#agents.set(id, {\n\t\t\t\t\t...state,\n\t\t\t\t\townerSessionId: undefined,\n\t\t\t\t\tstatus: \"unavailable\",\n\t\t\t\t\tupdatedAt: now,\n\t\t\t\t});\n\t\t\t}\n\t\t}\n\t}\n\n\t#requireUser(userId: string): void {\n\t\tif (!this.#users.has(userId)) throw missing(`user ${userId} does not exist`);\n\t}\n\n\t#addProject(input: AddUserProject): Promise {\n\t\tthis.#requireUser(input.userId);\n\t\tlet projects = this.#projects.get(input.userId) ?? [];\n\t\tlet existing = projects.find(project => project.repositoryId === input.repositoryId);\n\t\tif (existing) return Promise.resolve({ project: project(existing), added: false });\n\t\tlet saved: UserProject = {\n\t\t\tuserId: input.userId,\n\t\t\trepositoryId: input.repositoryId,\n\t\t\trepositoryOwner: input.repositoryOwner,\n\t\t\trepositoryName: input.repositoryName,\n\t\t\tposition: Math.max(-1, ...projects.map(project => project.position)) + 1,\n\t\t\taddedAt: input.now,\n\t\t};\n\t\tthis.#projects.set(input.userId, [...projects, saved]);\n\t\treturn Promise.resolve({ project: project(saved), added: true });\n\t}\n\n\tasync #setLastDocument(\n\t\tuserId: string,\n\t\tdocumentId: string | undefined,\n\t\tnow: Date,\n\t): Promise {\n\t\tthis.#requireUser(userId);\n\t\tif (documentId && !this.#channels.has(documentId)) {\n\t\t\tthrow missing(`channel ${documentId} does not exist`);\n\t\t}\n\t\tlet saved: UserNavigation = { userId, lastDocumentId: documentId, updatedAt: now };\n\t\tthis.#navigation.set(userId, saved);\n\t\treturn navigation(saved);\n\t}\n\n\tasync #recordVisit(input: RecordNavigationVisit): Promise {\n\t\tthis.#requireUser(input.userId);\n\t\tlet document = this.#channels.get(input.documentId);\n\t\tif (!document || document.repositoryId !== input.repositoryId) {\n\t\t\tthrow missing(\n\t\t\t\t`channel ${input.documentId} does not exist in repository ${input.repositoryId}`,\n\t\t\t);\n\t\t}\n\t\tawait this.#addProject(input);\n\t\treturn this.#setLastDocument(input.userId, input.documentId, input.now);\n\t}\n\n\tasync #createChannel(input: CreateChannel): Promise {\n\t\tif (!this.#users.has(input.createdBy)) throw missing(`user ${input.createdBy} does not exist`);\n\t\tif (this.#channels.has(input.id)) throw conflict(`channel ${input.id} already exists`);\n\t\tif (\n\t\t\t[...this.#channels.values()].some(channel =>\n\t\t\t\tchannel.repositoryId === input.repositoryId\n\t\t\t\t&& channel.title.toLowerCase() === input.title.toLowerCase()\n\t\t\t)\n\t\t) throw conflict(`channel title ${input.title} already exists in this repository`);\n\t\tlet { initial, now, ...record } = input;\n\t\tlet slug = this.#reserveSlug(input.repositoryId, input.id, input.title);\n\t\tlet saved: ChannelRecord = {\n\t\t\t...record,\n\t\t\tslug,\n\t\t\trevision: 0,\n\t\t\tcreatedAt: now,\n\t\t\tupdatedAt: now,\n\t\t};\n\t\tthis.#channels.set(saved.id, saved);\n\t\tthis.#sequences.set(saved.id, 1);\n\t\tthis.#sidecars.set(saved.id, initial ? json(initial.sidecar) : null);\n\t\tif (initial) {\n\t\t\tthis.#snapshots.set(saved.id, {\n\t\t\t\tchannelId: saved.id,\n\t\t\t\t...initial,\n\t\t\t\trevision: 0,\n\t\t\t\tthroughSequence: 0,\n\t\t\t\tdocument: bytes(initial.document),\n\t\t\t\tsidecar: json(initial.sidecar),\n\t\t\t\tcreatedAt: now,\n\t\t\t});\n\t\t}\n\t\treturn channel(saved);\n\t}\n\n\tasync #renameChannel(input: RenameChannel): Promise {\n\t\tlet found = this.#channels.get(input.id);\n\t\tif (!found) throw missing(`channel ${input.id} does not exist`);\n\t\tif (found.title === input.title) return { channel: channel(found), changed: false };\n\t\tif (\n\t\t\t[...this.#channels.values()].some(value =>\n\t\t\t\tvalue.id !== found.id\n\t\t\t\t&& value.repositoryId === found.repositoryId\n\t\t\t\t&& value.title.toLowerCase() === input.title.toLowerCase()\n\t\t\t)\n\t\t) throw conflict(`channel title ${input.title} already exists in this repository`);\n\t\tlet updatedAt = input.now > found.updatedAt\n\t\t\t? input.now\n\t\t\t: new Date(found.updatedAt.getTime() + 1);\n\t\tlet slug = this.#reserveSlug(found.repositoryId, found.id, input.title);\n\t\tlet saved = { ...found, title: input.title, slug, updatedAt };\n\t\tthis.#channels.set(saved.id, saved);\n\t\treturn { channel: channel(saved), changed: true };\n\t}\n\n\t#reserveSlug(repositoryId: string, channelId: string, title: string): string {\n\t\tlet aliases = this.#channelSlugs.get(repositoryId);\n\t\tif (!aliases) {\n\t\t\taliases = new Map();\n\t\t\tthis.#channelSlugs.set(repositoryId, aliases);\n\t\t}\n\t\tlet base = documentSlug(title);\n\t\tfor (let index = 1;; index++) {\n\t\t\tlet candidate = documentSlugCandidate(base, index);\n\t\t\tlet owner = aliases.get(candidate);\n\t\t\tif (owner && owner !== channelId) continue;\n\t\t\taliases.set(candidate, channelId);\n\t\t\treturn candidate;\n\t\t}\n\t}\n\n\t#listChannels(\n\t\trepositoryId: string,\n\t\tlimit: number,\n\t\tafter?: ChannelCursor,\n\t\tquery?: string,\n\t): Promise {\n\t\tlet count = Math.min(100, Math.max(1, limit));\n\t\tlet ordered = [...this.#channels.values()]\n\t\t\t.filter(value => value.repositoryId === repositoryId)\n\t\t\t.filter(value => !query || value.title.toLowerCase().includes(query.toLowerCase()))\n\t\t\t.sort((left, right) =>\n\t\t\t\tright.updatedAt.getTime() - left.updatedAt.getTime() || left.id.localeCompare(right.id)\n\t\t\t);\n\t\tif (after) {\n\t\t\tordered = ordered.filter(value =>\n\t\t\t\tvalue.updatedAt < after.updatedAt\n\t\t\t\t|| (value.updatedAt.getTime() === after.updatedAt.getTime() && value.id > after.id)\n\t\t\t);\n\t\t}\n\t\tlet page = ordered.slice(0, count);\n\t\tlet last = page.at(-1);\n\t\treturn Promise.resolve({\n\t\t\tchannels: page.map(channel),\n\t\t\tnext: ordered.length > page.length && last\n\t\t\t\t? { updatedAt: new Date(last.updatedAt), id: last.id }\n\t\t\t\t: undefined,\n\t\t});\n\t}\n\n\t#scanChannels(\n\t\trepositoryId: string,\n\t\tlimit: number,\n\t\tafter?: ChannelScanCursor,\n\t): Promise {\n\t\tlet count = Math.min(100, Math.max(1, limit));\n\t\tlet ordered = [...this.#channels.values()]\n\t\t\t.filter(value => value.repositoryId === repositoryId)\n\t\t\t.sort((left, right) =>\n\t\t\t\tright.createdAt.getTime() - left.createdAt.getTime() || left.id.localeCompare(right.id)\n\t\t\t);\n\t\tif (after) {\n\t\t\tordered = ordered.filter(value =>\n\t\t\t\tvalue.createdAt < after.createdAt\n\t\t\t\t|| (value.createdAt.getTime() === after.createdAt.getTime() && value.id > after.id)\n\t\t\t);\n\t\t}\n\t\tlet page = ordered.slice(0, count);\n\t\tlet last = page.at(-1);\n\t\treturn Promise.resolve({\n\t\t\tchannels: page.map(channel),\n\t\t\tnext: ordered.length > page.length && last\n\t\t\t\t? { createdAt: new Date(last.createdAt), id: last.id }\n\t\t\t\t: undefined,\n\t\t});\n\t}\n\n\t#claimAgentOwner(channelId: string, sessionId: string, now: Date): Promise {\n\t\tif (!this.#channels.has(channelId)) throw missing(`channel ${channelId} does not exist`);\n\t\tlet owner = this.#sessions.get(sessionId);\n\t\tif (!owner || owner.expiresAt <= now) throw missing(`session ${sessionId} is not active`);\n\t\tlet existing = this.#agents.get(channelId);\n\t\tif (existing?.ownerSessionId) return Promise.resolve(agent(existing));\n\t\tlet saved: AgentState = {\n\t\t\tchannelId,\n\t\t\townerSessionId: sessionId,\n\t\t\tgeneration: (existing?.generation ?? 0) + 1,\n\t\t\tsummary: existing?.summary ?? \"\",\n\t\t\ttranscriptCursor: existing?.transcriptCursor ?? 0,\n\t\t\tstatus: \"ready\",\n\t\t\tupdatedAt: now,\n\t\t};\n\t\tthis.#agents.set(channelId, saved);\n\t\treturn Promise.resolve(agent(saved));\n\t}\n\n\t#clearAgentOwner(\n\t\tchannelId: string,\n\t\texpectedSessionId: string,\n\t\texpectedGeneration: number,\n\t\tnow: Date,\n\t): Promise {\n\t\tlet existing = this.#agents.get(channelId);\n\t\tif (\n\t\t\t!existing\n\t\t\t|| existing.ownerSessionId !== expectedSessionId\n\t\t\t|| existing.generation !== expectedGeneration\n\t\t) return Promise.resolve(false);\n\t\tthis.#agents.set(channelId, {\n\t\t\t...existing,\n\t\t\townerSessionId: undefined,\n\t\t\tstatus: \"unavailable\",\n\t\t\tupdatedAt: now,\n\t\t});\n\t\treturn Promise.resolve(true);\n\t}\n\n\t#updateAgentContext(input: UpdateAgentContext): Promise {\n\t\tlet existing = this.#agents.get(input.channelId);\n\t\tlet owner = this.#sessions.get(input.ownerSessionId);\n\t\tif (\n\t\t\t!existing\n\t\t\t|| existing.ownerSessionId !== input.ownerSessionId\n\t\t\t|| existing.generation !== input.generation\n\t\t\t|| !owner\n\t\t\t|| owner.expiresAt <= input.now\n\t\t) {\n\t\t\tthrow conflict(`agent owner changed for channel ${input.channelId}`);\n\t\t}\n\t\tlet saved: AgentState = {\n\t\t\tchannelId: input.channelId,\n\t\t\townerSessionId: input.ownerSessionId,\n\t\t\tgeneration: input.generation,\n\t\t\tsummary: input.summary,\n\t\t\ttranscriptCursor: input.transcriptCursor,\n\t\t\tstatus: input.status,\n\t\t\tupdatedAt: input.now,\n\t\t};\n\t\tthis.#agents.set(input.channelId, saved);\n\t\treturn Promise.resolve(agent(saved));\n\t}\n\n\t#readAgent(channelId: string, now: Date) {\n\t\tlet found = this.#channels.get(channelId);\n\t\tif (!found) return Promise.resolve(undefined);\n\t\tlet state = this.#agents.get(channelId);\n\t\tlet saved = state && agent(state);\n\t\tif (saved?.ownerSessionId) {\n\t\t\tlet owner = this.#sessions.get(saved.ownerSessionId);\n\t\t\tif (!owner || owner.expiresAt <= now) {\n\t\t\t\tsaved = { ...saved, ownerSessionId: undefined, status: \"unavailable\" };\n\t\t\t}\n\t\t}\n\t\treturn Promise.resolve({ channel: channel(found), agent: saved });\n\t}\n\n\t#load(channelId: string, now: Date): Promise {\n\t\tlet found = this.#channels.get(channelId);\n\t\tif (!found) return Promise.resolve(undefined);\n\t\tlet storedAgent = this.#agents.get(channelId) ? agent(this.#agents.get(channelId)!) : undefined;\n\t\tif (storedAgent?.ownerSessionId) {\n\t\t\tlet owner = this.#sessions.get(storedAgent.ownerSessionId);\n\t\t\tif (!owner || owner.expiresAt <= now) {\n\t\t\t\tstoredAgent = { ...storedAgent, ownerSessionId: undefined, status: \"unavailable\" };\n\t\t\t}\n\t\t}\n\t\treturn Promise.resolve({\n\t\t\tchannel: channel(found),\n\t\t\tlatestSequence: (this.#sequences.get(channelId) ?? 1) - 1,\n\t\t\tsnapshot: this.#snapshots.get(channelId)\n\t\t\t\t? snapshot(this.#snapshots.get(channelId)!)\n\t\t\t\t: undefined,\n\t\t\tupdates: (this.#updates.get(channelId) ?? []).map(value => ({\n\t\t\t\t...value,\n\t\t\t\tupdate: bytes(value.update),\n\t\t\t})),\n\t\t\tevents: (this.#events.get(channelId) ?? []).map(value => ({\n\t\t\t\t...value,\n\t\t\t\tpayload: json(value.payload),\n\t\t\t\tcreatedAt: new Date(value.createdAt),\n\t\t\t})),\n\t\t\tsidecar: json(this.#sidecars.get(channelId) ?? null),\n\t\t\tagent: storedAgent,\n\t\t});\n\t}\n\n\t#commit(input: CommitChannel): Promise {\n\t\tthis.#assertLease(input.lease);\n\t\tlet found = this.#channels.get(input.channelId);\n\t\tif (!found) throw missing(`channel ${input.channelId} does not exist`);\n\t\tlet operations = this.#operations.get(input.channelId) ?? new Map();\n\t\tthis.#operations.set(input.channelId, operations);\n\t\tlet repeated = operations.get(input.operationId);\n\t\tif (repeated) return Promise.resolve({ ...repeated, repeated: true });\n\t\tif (found.revision !== input.expectedRevision) {\n\t\t\tthrow conflict(\n\t\t\t\t`channel ${input.channelId} is at revision ${found.revision}, expected ${input.expectedRevision}`,\n\t\t\t);\n\t\t}\n\t\tlet existingEvents = this.#events.get(input.channelId) ?? [];\n\t\tlet eventIds = new Set(existingEvents.map(value => value.id));\n\t\tfor (let item of input.events) {\n\t\t\tif (eventIds.has(item.id)) {\n\t\t\t\tthrow conflict(`channel ${input.channelId} already has event ${item.id}`);\n\t\t\t}\n\t\t\teventIds.add(item.id);\n\t\t}\n\n\t\tlet sequence = this.#sequences.get(input.channelId) ?? 1;\n\t\tlet revision = found.revision + 1;\n\t\tif (input.update) {\n\t\t\tlet updates = this.#updates.get(input.channelId) ?? [];\n\t\t\tupdates.push({\n\t\t\t\tchannelId: input.channelId,\n\t\t\t\tsequence,\n\t\t\t\trevision,\n\t\t\t\tepoch: input.epoch,\n\t\t\t\tupdate: bytes(input.update),\n\t\t\t});\n\t\t\tthis.#updates.set(input.channelId, updates);\n\t\t}\n\t\tif (input.sidecar !== undefined) this.#sidecars.set(input.channelId, json(input.sidecar));\n\t\tif (input.events.length > 0) {\n\t\t\texistingEvents.push(...input.events.map((event, ordinal) => ({\n\t\t\t\t...event,\n\t\t\t\tchannelId: input.channelId,\n\t\t\t\tsequence,\n\t\t\t\tordinal,\n\t\t\t\tpayload: json(event.payload),\n\t\t\t\tcreatedAt: new Date(event.createdAt),\n\t\t\t})));\n\t\t\tthis.#events.set(input.channelId, existingEvents);\n\t\t}\n\t\tthis.#channels.set(input.channelId, {\n\t\t\t...found,\n\t\t\trevision,\n\t\t\tupdatedAt: new Date(Math.max(found.updatedAt.getTime(), input.now.getTime())),\n\t\t});\n\t\tthis.#sequences.set(input.channelId, sequence + 1);\n\t\tlet result = { revision, sequence, repeated: false };\n\t\toperations.set(input.operationId, result);\n\t\treturn Promise.resolve(result);\n\t}\n\n\t#checkpoint(input: SaveCheckpoint): Promise {\n\t\tthis.#assertLease(input.lease);\n\t\tlet found = this.#channels.get(input.channelId);\n\t\tif (!found) throw missing(`channel ${input.channelId} does not exist`);\n\t\tif (found.revision !== input.expectedRevision || input.revision !== input.expectedRevision) {\n\t\t\tthrow conflict(`channel ${input.channelId} changed before its checkpoint`);\n\t\t}\n\t\tlet previous = this.#snapshots.get(input.channelId);\n\t\tif (previous && previous.throughSequence > input.throughSequence) {\n\t\t\tthrow conflict(`channel ${input.channelId} already has a newer checkpoint`);\n\t\t}\n\t\tlet lastSequence = (this.#sequences.get(input.channelId) ?? 1) - 1;\n\t\tif (input.throughSequence > lastSequence) {\n\t\t\tthrow conflict(`checkpoint for channel ${input.channelId} is ahead of its journal`);\n\t\t}\n\t\tthis.#snapshots.set(input.channelId, snapshot(input));\n\t\tthis.#updates.set(\n\t\t\tinput.channelId,\n\t\t\t(this.#updates.get(input.channelId) ?? []).filter(\n\t\t\t\tvalue => value.sequence > input.throughSequence,\n\t\t\t),\n\t\t);\n\t\treturn Promise.resolve();\n\t}\n\n\t#replace(input: ReplaceChannel): Promise {\n\t\tthis.#assertLease(input.lease);\n\t\tlet found = this.#channels.get(input.channelId);\n\t\tif (!found) throw missing(`channel ${input.channelId} does not exist`);\n\t\tlet operations = this.#operations.get(input.channelId) ?? new Map();\n\t\tthis.#operations.set(input.channelId, operations);\n\t\tlet repeated = operations.get(input.operationId);\n\t\tif (repeated) return Promise.resolve({ ...repeated, repeated: true });\n\t\tif (found.revision !== input.expectedRevision) {\n\t\t\tthrow conflict(\n\t\t\t\t`channel ${input.channelId} is at revision ${found.revision}, expected ${input.expectedRevision}`,\n\t\t\t);\n\t\t}\n\t\tlet sequence = this.#sequences.get(input.channelId) ?? 1;\n\t\tlet revision = found.revision + 1;\n\t\tthis.#sidecars.set(input.channelId, json(input.sidecar));\n\t\tthis.#snapshots.set(input.channelId, {\n\t\t\tchannelId: input.channelId,\n\t\t\tgeneration: input.generation,\n\t\t\trevision,\n\t\t\tthroughSequence: sequence,\n\t\t\tepoch: input.epoch,\n\t\t\tsource: input.source,\n\t\t\tsourceHash: input.sourceHash,\n\t\t\tdocument: bytes(input.document),\n\t\t\tsidecar: json(input.sidecar),\n\t\t\tcreatedAt: input.now,\n\t\t});\n\t\tthis.#updates.set(input.channelId, []);\n\t\tthis.#channels.set(input.channelId, {\n\t\t\t...found,\n\t\t\trevision,\n\t\t\tupdatedAt: new Date(Math.max(found.updatedAt.getTime(), input.now.getTime())),\n\t\t});\n\t\tthis.#sequences.set(input.channelId, sequence + 1);\n\t\tlet result = { revision, sequence, repeated: false };\n\t\toperations.set(input.operationId, result);\n\t\treturn Promise.resolve(result);\n\t}\n\n\t#acquire(name: string, owner: string, ttlMs: number): Promise {\n\t\tlet now = new Date();\n\t\tlet existing = this.#leases.get(name);\n\t\tif (existing && existing.expiresAt > now && existing.owner !== owner) {\n\t\t\treturn Promise.resolve(undefined);\n\t\t}\n\t\tlet saved: Lease = {\n\t\t\tname,\n\t\t\towner,\n\t\t\tfencing: existing && existing.owner === owner && existing.expiresAt > now\n\t\t\t\t? existing.fencing\n\t\t\t\t: (existing?.fencing ?? 0) + 1,\n\t\t\texpiresAt: new Date(now.getTime() + ttlMs),\n\t\t};\n\t\tthis.#leases.set(name, saved);\n\t\treturn Promise.resolve(lease(saved));\n\t}\n\n\t#renew(held: Lease, ttlMs: number): Promise {\n\t\tlet now = new Date();\n\t\tlet existing = this.#leases.get(held.name);\n\t\tif (\n\t\t\t!existing\n\t\t\t|| existing.owner !== held.owner\n\t\t\t|| existing.fencing !== held.fencing\n\t\t\t|| existing.expiresAt <= now\n\t\t) return Promise.resolve(undefined);\n\t\tlet saved = { ...existing, expiresAt: new Date(now.getTime() + ttlMs) };\n\t\tthis.#leases.set(held.name, saved);\n\t\treturn Promise.resolve(lease(saved));\n\t}\n\n\t#release(held: Lease): Promise {\n\t\tlet existing = this.#leases.get(held.name);\n\t\tif (!existing || existing.owner !== held.owner || existing.fencing !== held.fencing) {\n\t\t\treturn Promise.resolve(false);\n\t\t}\n\t\tthis.#leases.set(held.name, { ...existing, expiresAt: new Date(0) });\n\t\treturn Promise.resolve(true);\n\t}\n\n\t#assertLease(held: Lease): void {\n\t\tlet now = new Date();\n\t\tlet existing = this.#leases.get(held.name);\n\t\tif (\n\t\t\t!existing\n\t\t\t|| existing.owner !== held.owner\n\t\t\t|| existing.fencing !== held.fencing\n\t\t\t|| existing.expiresAt <= now\n\t\t) throw conflict(`storage lease ${held.name} is no longer held`);\n\t}\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[183,184,185,186,187,188,189,190,191,192,193,194,195],"navigation",{"_54":55,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_42":31,"_137":126,"_138":31,"_48":49,"_50":49},"branches",[73,74,75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130],"tags",[69,70,71,72],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[165,166,167],"documents",{"_160":161,"_162":163},"code",{"_156":157,"_158":159},"automations",{"_153":154,"_155":-5},"delivery",{"_151":49,"_152":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_164":163},"total",11,"issue",{"_168":158,"_170":181,"_15":158,"_172":182,"_52":174,"_175":31,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_52":174,"_175":31,"_176":174,"_177":49},{"_168":169,"_170":171,"_15":169,"_172":173,"_52":174,"_175":31,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_52":174,"_175":31,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_52":174,"_175":31,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_52":174,"_175":31,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_52":31,"_175":31,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_52":31,"_175":31,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_52":31,"_175":31,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_52":31,"_175":31,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_52":31,"_175":31,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_52":31,"_175":31,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_52":31,"_175":31,"_176":31},{"_168":202,"_170":203,"_15":202,"_172":204,"_52":31,"_175":31,"_176":31},{"_168":199,"_170":200,"_15":199,"_172":201,"_52":31,"_175":31,"_176":31},{"_168":196,"_170":197,"_15":196,"_172":198,"_52":31,"_175":31,"_176":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794486030491,"sidebar","expanded"]