[{"_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","1906e8f485d00a4e2d8fcbd68cb63b2c85c483b6","path","apps/server/src/tasks/lifecycle.ts","oid","d191c5ad7a218a55dc11b2d91565800bbc4b7ea1","size",26370,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { matches, restoreRunVersion } from \"./graphs\";\n\nimport type { Plan as WirePlan } from \"@chopin/protocol\";\nimport type { Graph, Run, Task, Version } from \"./graphs\";\n\nexport type PullRequest = {\n\turl: string;\n\tstate: \"open\" | \"merged\" | \"closed\";\n};\n\ntype Working = {\n\tid: string;\n\tpullRequest?: PullRequest;\n};\n\nexport type TaskProgress =\n\t| { id: string; state: \"queued\" }\n\t| (Working & { state: \"in_progress\" })\n\t| (Working & { state: \"blocked\"; blocker: string })\n\t| { id: string; state: \"completed\"; summary: string; pullRequest: PullRequest };\n\nexport type VerificationEvidence = { taskId: string; evidence: string[] };\nexport type VerificationReport = {\n\tpassed: boolean;\n\tsummary: string;\n\treviewerMethod: string;\n\tevidence: VerificationEvidence[];\n\ttasksNeedingWork: string[];\n};\n\ntype Command =\n\t| { kind: \"start\"; taskId: string; idempotencyKey: string }\n\t| { kind: \"block\"; taskId: string; reason: string; idempotencyKey: string }\n\t| {\n\t\tkind: \"report_pr\";\n\t\ttaskId: string;\n\t\turl: string;\n\t\tstate: PullRequest[\"state\"];\n\t\tidempotencyKey: string;\n\t}\n\t| { kind: \"complete\"; taskId: string; summary: string; idempotencyKey: string }\n\t| ({ kind: \"report_verification\"; idempotencyKey: string } & VerificationReport)\n\t| { kind: \"request_revision\"; reason: string; idempotencyKey: string };\n\nexport type ProgressEvent = Command;\n\nexport type Progress = {\n\ttasks: TaskProgress[];\n\tevents: ProgressEvent[];\n\tverification?: VerificationReport;\n};\n\nexport type ArchivedRun = { run: Run; events: ProgressEvent[] };\nexport type HistoricalRun = {\n\trun: Run;\n\tprogress: Progress;\n\toutcome:\n\t\t| { kind: \"revision_requested\"; reason: string }\n\t\t| { kind: \"implemented\" }\n\t\t| { kind: \"delivered\" };\n};\n\nexport type Lifecycle = {\n\tevents?: ProgressEvent[];\n\thistory: ArchivedRun[];\n};\n\nexport type LifecycleState = {\n\tgraph: Graph;\n\texecution?: Run;\n\tlifecycle: Lifecycle;\n};\n\nexport type ImplementationLifecycle = Pick<\n\tWirePlan.Lifecycle,\n\t\"execution\" | \"activity\" | \"history\"\n>;\n\nexport type LifecycleInput = Command & { runId: string };\n\nexport type LifecycleResult =\n\t| { kind: \"accepted\" | \"replayed\"; state: LifecycleState }\n\t| { kind: \"refused\"; reason: string };\n\nexport type ClaimEligibility =\n\t| { ok: true }\n\t| { ok: false; reason: \"already-verified\" | \"run\" };\n\ntype DerivedRun =\n\t| { phase: \"active\"; progress: Progress }\n\t| { phase: \"revision_requested\"; progress: Progress; reason: string }\n\t| { phase: \"implemented\" | \"delivered\"; progress: Progress };\n\ntype ReducerContext = { tasks: Task[]; run: Run };\ntype ReducerProgress = { tasks: TaskProgress[]; verification?: VerificationReport };\ntype ReducerState =\n\t| { phase: \"active\"; context: ReducerContext; progress: ReducerProgress }\n\t| {\n\t\tphase: \"revision_requested\";\n\t\tcontext: ReducerContext;\n\t\tprogress: ReducerProgress;\n\t\treason: string;\n\t}\n\t| {\n\t\tphase: \"implemented\" | \"delivered\";\n\t\tcontext: ReducerContext;\n\t\tprogress: ReducerProgress;\n\t};\ntype Reduction =\n\t| { kind: \"accepted\"; state: ReducerState }\n\t| { kind: \"refused\"; reason: string };\n\nfunction copy(value: T): T {\n\treturn structuredClone(value);\n}\n\nfunction exact(value: Record, keys: string[]): boolean {\n\tlet actual = Object.keys(value).sort();\n\tlet expected = [...keys].sort();\n\treturn actual.length === expected.length\n\t\t&& actual.every((key, index) => key === expected[index]);\n}\n\nfunction text(value: unknown): value is string {\n\treturn typeof value === \"string\" && Boolean(value.trim());\n}\n\nfunction pullRequestState(value: unknown): value is PullRequest[\"state\"] {\n\treturn value === \"open\" || value === \"merged\" || value === \"closed\";\n}\n\nfunction ownPullRequest(repository: string, url: string): boolean {\n\tlet match = /^https:\\/\\/github\\.com\\/([^/]+\\/[^/]+)\\/pull\\/([1-9]\\d*)\\/?$/.exec(url);\n\treturn match?.[1] === repository;\n}\n\nfunction versionFor(graph: Graph, run: Run): Version | undefined {\n\treturn graph.versions.find(version => matches(run, version));\n}\n\nfunction activeVersion(graph: Graph, run: Run): Version | undefined {\n\tlet version = graph.versions.at(-1);\n\treturn version?.state === \"locked\" && matches(run, version) ? version : undefined;\n}\n\nfunction initial(tasks: Task[], run: Run): ReducerState {\n\treturn {\n\t\tphase: \"active\",\n\t\tcontext: { tasks, run },\n\t\tprogress: { tasks: tasks.map(task => ({ id: task.id, state: \"queued\" })) },\n\t};\n}\n\nfunction reportFrom(value: VerificationReport): VerificationReport {\n\treturn {\n\t\tpassed: value.passed,\n\t\tsummary: value.summary,\n\t\treviewerMethod: value.reviewerMethod,\n\t\tevidence: copy(value.evidence),\n\t\ttasksNeedingWork: copy(value.tasksNeedingWork),\n\t};\n}\n\nfunction validReport(report: VerificationReport, tasks: Task[]): boolean {\n\tif (\n\t\ttypeof report.passed !== \"boolean\"\n\t\t|| !text(report.summary)\n\t\t|| !text(report.reviewerMethod)\n\t\t|| !Array.isArray(report.evidence)\n\t\t|| !Array.isArray(report.tasksNeedingWork)\n\t) return false;\n\tlet taskIds = new Set(tasks.map(task => task.id));\n\tlet evidenceIds = new Set();\n\tfor (let entry of report.evidence) {\n\t\tif (\n\t\t\t!entry || typeof entry !== \"object\" || Array.isArray(entry)\n\t\t\t|| !exact(entry as unknown as Record, [\"evidence\", \"taskId\"])\n\t\t\t|| !text(entry.taskId)\n\t\t\t|| !taskIds.has(entry.taskId)\n\t\t\t|| evidenceIds.has(entry.taskId)\n\t\t\t|| !Array.isArray(entry.evidence)\n\t\t\t|| entry.evidence.length === 0\n\t\t\t|| entry.evidence.some(item => !text(item))\n\t\t) return false;\n\t\tevidenceIds.add(entry.taskId);\n\t}\n\tif (evidenceIds.size !== taskIds.size) return false;\n\tif (report.tasksNeedingWork.some(id => !text(id) || !taskIds.has(id))) return false;\n\tlet work = new Set(report.tasksNeedingWork);\n\tif (work.size !== report.tasksNeedingWork.length) return false;\n\treturn report.passed ? work.size === 0 : work.size > 0;\n}\n\nfunction deliveryPhase(tasks: TaskProgress[]): \"implemented\" | \"delivered\" {\n\tlet requests = new Map();\n\tfor (let task of tasks) {\n\t\tif (task.state !== \"completed\") return \"implemented\";\n\t\trequests.set(task.pullRequest.url, task.pullRequest.state);\n\t}\n\treturn [...requests.values()].every(state => state === \"merged\")\n\t\t? \"delivered\"\n\t\t: \"implemented\";\n}\n\nfunction accepted(state: ReducerState): Reduction {\n\treturn { kind: \"accepted\", state };\n}\n\nfunction refused(reason: string): Reduction {\n\treturn { kind: \"refused\", reason };\n}\n\nfunction reduceEvent(state: ReducerState, stored: ProgressEvent): Reduction {\n\tlet { run, tasks } = state.context;\n\tlet progress = state.progress;\n\tif (state.phase === \"revision_requested\") return refused(\"terminal\");\n\tif (state.phase === \"implemented\" || state.phase === \"delivered\") {\n\t\tif (stored.kind !== \"report_pr\") return refused(\"terminal\");\n\t\tlet addressed = progress.tasks.find(task => task.id === stored.taskId);\n\t\tif (\n\t\t\t!addressed || addressed.state !== \"completed\"\n\t\t\t|| addressed.pullRequest.url !== stored.url\n\t\t) return refused(\"pull-request\");\n\t\tif (!ownPullRequest(run.repository, stored.url)) return refused(\"repository\");\n\t\tif (\n\t\t\tprogress.tasks.some(task =>\n\t\t\t\ttask.state === \"completed\"\n\t\t\t\t&& task.pullRequest.url === stored.url\n\t\t\t\t&& task.pullRequest.state === \"merged\"\n\t\t\t)\n\t\t\t&& stored.state !== \"merged\"\n\t\t) return refused(\"pull-request-state\");\n\t\tlet nextTasks = progress.tasks.map(task =>\n\t\t\ttask.state === \"completed\" && task.pullRequest.url === stored.url\n\t\t\t\t? { ...task, pullRequest: { url: stored.url, state: stored.state } }\n\t\t\t\t: task\n\t\t);\n\t\treturn accepted({\n\t\t\tphase: deliveryPhase(nextTasks),\n\t\t\tcontext: state.context,\n\t\t\tprogress: { ...progress, tasks: nextTasks },\n\t\t});\n\t}\n\n\tif (stored.kind === \"request_revision\") {\n\t\tif (!text(stored.reason)) return refused(\"reason\");\n\t\treturn accepted({\n\t\t\tphase: \"revision_requested\",\n\t\t\tcontext: state.context,\n\t\t\tprogress,\n\t\t\treason: stored.reason,\n\t\t});\n\t}\n\n\tif (stored.kind === \"report_verification\") {\n\t\tif (!validReport(stored, tasks)) return refused(\"verification\");\n\t\tfor (let item of progress.tasks) {\n\t\t\tif (item.state !== \"completed\") return refused(\"task-state\");\n\t\t\tif (item.pullRequest.state !== \"open\" && item.pullRequest.state !== \"merged\") {\n\t\t\t\treturn refused(\"pull-request\");\n\t\t\t}\n\t\t\tif (!ownPullRequest(run.repository, item.pullRequest.url)) {\n\t\t\t\treturn refused(\"repository\");\n\t\t\t}\n\t\t}\n\t\tlet verification = reportFrom(stored);\n\t\tif (stored.passed) {\n\t\t\treturn accepted({\n\t\t\t\tphase: deliveryPhase(progress.tasks),\n\t\t\t\tcontext: state.context,\n\t\t\t\tprogress: { ...progress, verification },\n\t\t\t});\n\t\t}\n\t\tlet work = new Set(stored.tasksNeedingWork);\n\t\tlet nextTasks = progress.tasks.map(item =>\n\t\t\twork.has(item.id) && item.state === \"completed\"\n\t\t\t\t? {\n\t\t\t\t\tid: item.id,\n\t\t\t\t\tstate: \"in_progress\" as const,\n\t\t\t\t\tpullRequest: copy(item.pullRequest),\n\t\t\t\t}\n\t\t\t\t: item\n\t\t);\n\t\treturn accepted({\n\t\t\tphase: \"active\",\n\t\t\tcontext: state.context,\n\t\t\tprogress: { ...progress, tasks: nextTasks, verification },\n\t\t});\n\t}\n\n\tlet index = progress.tasks.findIndex(item => item.id === stored.taskId);\n\tlet task = tasks[index];\n\tlet item = progress.tasks[index];\n\tif (!task || !item) return refused(\"task\");\n\tlet next: TaskProgress;\n\tswitch (stored.kind) {\n\t\tcase \"start\":\n\t\t\tif (item.state !== \"queued\" && item.state !== \"blocked\") {\n\t\t\t\treturn refused(\"task-state\");\n\t\t\t}\n\t\t\tif (\n\t\t\t\ttask.dependsOn.some(id =>\n\t\t\t\t\tprogress.tasks.find(item => item.id === id)?.state !== \"completed\"\n\t\t\t\t)\n\t\t\t) return refused(\"dependency\");\n\t\t\tnext = {\n\t\t\t\tid: item.id,\n\t\t\t\tstate: \"in_progress\",\n\t\t\t\t...(item.state === \"blocked\" && item.pullRequest\n\t\t\t\t\t? { pullRequest: item.pullRequest }\n\t\t\t\t\t: {}),\n\t\t\t};\n\t\t\tbreak;\n\t\tcase \"block\":\n\t\t\tif (item.state !== \"in_progress\") return refused(\"task-state\");\n\t\t\tif (!text(stored.reason)) return refused(\"reason\");\n\t\t\tnext = {\n\t\t\t\tid: item.id,\n\t\t\t\tstate: \"blocked\",\n\t\t\t\tblocker: stored.reason,\n\t\t\t\t...(item.pullRequest ? { pullRequest: item.pullRequest } : {}),\n\t\t\t};\n\t\t\tbreak;\n\t\tcase \"report_pr\": {\n\t\t\tif (item.state === \"queued\") return refused(\"task-state\");\n\t\t\tif (!text(stored.url) || !pullRequestState(stored.state)) {\n\t\t\t\treturn refused(\"pull-request\");\n\t\t\t}\n\t\t\tif (!ownPullRequest(run.repository, stored.url)) return refused(\"repository\");\n\t\t\tlet shared = progress.tasks.filter(task =>\n\t\t\t\t\"pullRequest\" in task && task.pullRequest?.url === stored.url\n\t\t\t);\n\t\t\tif (\n\t\t\t\tshared.some(task => \"pullRequest\" in task && task.pullRequest?.state === \"merged\")\n\t\t\t\t&& stored.state !== \"merged\"\n\t\t\t) return refused(\"pull-request-state\");\n\t\t\tlet pullRequest = { url: stored.url, state: stored.state };\n\t\t\tnext = { ...item, pullRequest };\n\t\t\tbreak;\n\t\t}\n\t\tcase \"complete\":\n\t\t\tif (item.state !== \"in_progress\") return refused(\"task-state\");\n\t\t\tif (!item.pullRequest) return refused(\"pull-request\");\n\t\t\tif (!text(stored.summary)) return refused(\"summary\");\n\t\t\tnext = {\n\t\t\t\tid: item.id,\n\t\t\t\tstate: \"completed\",\n\t\t\t\tsummary: stored.summary,\n\t\t\t\tpullRequest: item.pullRequest,\n\t\t\t};\n\t\t\tbreak;\n\t}\n\tlet nextTasks = progress.tasks.map((task, taskIndex) => {\n\t\tif (taskIndex === index) return next;\n\t\treturn stored.kind === \"report_pr\" && stored.state === \"merged\"\n\t\t\t\t&& \"pullRequest\" in task && task.pullRequest?.url === stored.url\n\t\t\t? { ...task, pullRequest: { url: stored.url, state: stored.state } }\n\t\t\t: task;\n\t});\n\treturn accepted({\n\t\tphase: \"active\",\n\t\tcontext: state.context,\n\t\tprogress: { ...progress, tasks: nextTasks },\n\t});\n}\n\nfunction foldRun(tasks: Task[], run: Run, events: ProgressEvent[]): Reduction {\n\tlet state = initial(tasks, run);\n\tfor (let stored of events) {\n\t\tlet result = reduceEvent(state, stored);\n\t\tif (result.kind === \"refused\") return result;\n\t\tstate = result.state;\n\t}\n\treturn accepted(state);\n}\n\nfunction projectRun(state: ReducerState, events: ProgressEvent[]): DerivedRun {\n\tlet progress: Progress = {\n\t\t...copy(state.progress),\n\t\tevents: copy(events),\n\t};\n\treturn state.phase === \"revision_requested\"\n\t\t? { phase: state.phase, progress, reason: state.reason }\n\t\t: { phase: state.phase, progress };\n}\n\nfunction evidence(value: unknown): VerificationEvidence[] | undefined {\n\tif (!Array.isArray(value)) return undefined;\n\tlet restored: VerificationEvidence[] = [];\n\tfor (let entry of value) {\n\t\tif (!entry || typeof entry !== \"object\" || Array.isArray(entry)) return undefined;\n\t\tlet item = entry as Record;\n\t\tif (\n\t\t\t!exact(item, [\"evidence\", \"taskId\"])\n\t\t\t|| typeof item.taskId !== \"string\"\n\t\t\t|| !Array.isArray(item.evidence)\n\t\t\t|| item.evidence.some(value => typeof value !== \"string\")\n\t\t) return undefined;\n\t\trestored.push({ taskId: item.taskId, evidence: item.evidence as string[] });\n\t}\n\treturn restored;\n}\n\nfunction progressEvent(value: unknown): ProgressEvent | undefined {\n\tif (!value || typeof value !== \"object\" || Array.isArray(value)) return undefined;\n\tlet item = value as Record;\n\tif (!text(item.idempotencyKey)) return undefined;\n\tlet idempotencyKey = item.idempotencyKey;\n\tif (\n\t\titem.kind === \"request_revision\"\n\t\t&& exact(item, [\"idempotencyKey\", \"kind\", \"reason\"])\n\t\t&& text(item.reason)\n\t) return { kind: item.kind, reason: item.reason, idempotencyKey };\n\tif (\n\t\titem.kind === \"report_verification\"\n\t\t&& exact(item, [\n\t\t\t\"evidence\",\n\t\t\t\"idempotencyKey\",\n\t\t\t\"kind\",\n\t\t\t\"passed\",\n\t\t\t\"reviewerMethod\",\n\t\t\t\"summary\",\n\t\t\t\"tasksNeedingWork\",\n\t\t])\n\t\t&& typeof item.passed === \"boolean\"\n\t\t&& typeof item.summary === \"string\"\n\t\t&& typeof item.reviewerMethod === \"string\"\n\t\t&& Array.isArray(item.tasksNeedingWork)\n\t\t&& item.tasksNeedingWork.every(value => typeof value === \"string\")\n\t) {\n\t\tlet restored = evidence(item.evidence);\n\t\treturn restored\n\t\t\t? {\n\t\t\t\tkind: item.kind,\n\t\t\t\tpassed: item.passed,\n\t\t\t\tsummary: item.summary,\n\t\t\t\treviewerMethod: item.reviewerMethod,\n\t\t\t\tevidence: restored,\n\t\t\t\ttasksNeedingWork: item.tasksNeedingWork as string[],\n\t\t\t\tidempotencyKey,\n\t\t\t}\n\t\t\t: undefined;\n\t}\n\tif (!text(item.taskId)) return undefined;\n\tlet taskId = item.taskId;\n\tif (item.kind === \"start\" && exact(item, [\"idempotencyKey\", \"kind\", \"taskId\"])) {\n\t\treturn { kind: item.kind, taskId, idempotencyKey };\n\t}\n\tif (\n\t\titem.kind === \"block\"\n\t\t&& exact(item, [\"idempotencyKey\", \"kind\", \"reason\", \"taskId\"])\n\t\t&& text(item.reason)\n\t) return { kind: item.kind, taskId, reason: item.reason, idempotencyKey };\n\tif (\n\t\titem.kind === \"report_pr\"\n\t\t&& exact(item, [\"idempotencyKey\", \"kind\", \"state\", \"taskId\", \"url\"])\n\t\t&& text(item.url)\n\t\t&& pullRequestState(item.state)\n\t) {\n\t\treturn {\n\t\t\tkind: item.kind,\n\t\t\ttaskId,\n\t\t\turl: item.url,\n\t\t\tstate: item.state,\n\t\t\tidempotencyKey,\n\t\t};\n\t}\n\tif (\n\t\titem.kind === \"complete\"\n\t\t&& exact(item, [\"idempotencyKey\", \"kind\", \"summary\", \"taskId\"])\n\t\t&& text(item.summary)\n\t) return { kind: item.kind, taskId, summary: item.summary, idempotencyKey };\n\treturn undefined;\n}\n\nfunction restoreEvents(value: unknown): ProgressEvent[] | undefined {\n\tif (!Array.isArray(value) || value.length === 0) return undefined;\n\tlet restored = value.map(progressEvent);\n\treturn restored.some(event => !event) ? undefined : restored as ProgressEvent[];\n}\n\nfunction restoreHistory(stored: unknown, graph: Graph): ArchivedRun[] | undefined {\n\tif (!Array.isArray(stored)) return undefined;\n\tlet history: ArchivedRun[] = [];\n\tfor (let value of stored) {\n\t\tif (!value || typeof value !== \"object\" || Array.isArray(value)) return undefined;\n\t\tlet item = value as Record;\n\t\tif (!exact(item, [\"events\", \"run\"])) return undefined;\n\t\tlet run = restoreRunVersion(item.run, graph);\n\t\tlet events = restoreEvents(item.events);\n\t\tif (!run || !events) return undefined;\n\t\thistory.push({ run, events });\n\t}\n\treturn history;\n}\n\nfunction projectHistory(graph: Graph, history: ArchivedRun[]): HistoricalRun[] | undefined {\n\tlet projected: HistoricalRun[] = [];\n\tfor (let archived of history) {\n\t\tlet version = versionFor(graph, archived.run);\n\t\tif (!version) return undefined;\n\t\tlet folded = foldRun(version.definition.tasks, archived.run, archived.events);\n\t\tif (folded.kind === \"refused\") return undefined;\n\t\tlet derived = projectRun(folded.state, archived.events);\n\t\tif (derived.phase === \"active\") return undefined;\n\t\tlet outcome: HistoricalRun[\"outcome\"] = derived.phase === \"revision_requested\"\n\t\t\t? { kind: derived.phase, reason: derived.reason }\n\t\t\t: { kind: derived.phase };\n\t\tprojected.push({\n\t\t\trun: copy(archived.run),\n\t\t\tprogress: copy(derived.progress),\n\t\t\toutcome,\n\t\t});\n\t}\n\treturn projected;\n}\n\nfunction eligibility(\n\thistory: Array<{ run: Run; successful: boolean }>,\n\tversion: Version,\n\trunId: string,\n): ClaimEligibility {\n\tif (history.some(item => item.successful && matches(item.run, version))) {\n\t\treturn { ok: false, reason: \"already-verified\" };\n\t}\n\tif (history.some(item => item.run.id === runId)) return { ok: false, reason: \"run\" };\n\treturn { ok: true };\n}\n\n/** Decide whether a run may own this exact graph without reusing lifecycle identity. */\nexport function claimEligibility(\n\tlifecycle: Lifecycle,\n\tversion: Version,\n\trunId: string,\n): ClaimEligibility {\n\tlet history = lifecycle.history.map(archived => {\n\t\tif (!matches(archived.run, version)) return { run: archived.run, successful: false };\n\t\tlet folded = foldRun(version.definition.tasks, archived.run, archived.events);\n\t\treturn {\n\t\t\trun: archived.run,\n\t\t\tsuccessful: folded.kind === \"accepted\"\n\t\t\t\t&& (folded.state.phase === \"implemented\" || folded.state.phase === \"delivered\"),\n\t\t};\n\t});\n\treturn eligibility(history, version, runId);\n}\n\n/** Restore lifecycle data only when it describes this graph and claim exactly. */\nexport function restoreLifecycle(\n\tvalue: unknown,\n\tgraph: Graph,\n\texecution: Run | undefined,\n): Lifecycle | undefined {\n\tif (!value || typeof value !== \"object\" || Array.isArray(value)) return undefined;\n\tlet stored = value as Record;\n\tlet keys = stored.events === undefined ? [\"history\"] : [\"events\", \"history\"];\n\tif (!exact(stored, keys)) return undefined;\n\tlet history = restoreHistory(stored.history, graph);\n\tif (!history) return undefined;\n\tlet projected = projectHistory(graph, history);\n\tif (!projected) return undefined;\n\tlet events = stored.events === undefined ? undefined : restoreEvents(stored.events);\n\tif (stored.events !== undefined && !events) return undefined;\n\tlet current = graph.versions.at(-1);\n\tif (!current || (current.state === \"locked\") !== Boolean(execution)) return undefined;\n\tif (events && !execution) return undefined;\n\tif (execution) {\n\t\tlet version = activeVersion(graph, execution);\n\t\tif (!version) return undefined;\n\t\tlet folded = foldRun(version.definition.tasks, execution, events ?? []);\n\t\tif (folded.kind === \"refused\" || folded.state.phase !== \"active\") return undefined;\n\t\tlet eligible = eligibility(\n\t\t\tprojected.map(item => ({\n\t\t\t\trun: item.run,\n\t\t\t\tsuccessful: item.outcome.kind !== \"revision_requested\",\n\t\t\t})),\n\t\t\tversion,\n\t\t\texecution.id,\n\t\t);\n\t\tif (!eligible.ok) {\n\t\t\treturn undefined;\n\t\t}\n\t}\n\n\tlet runIds = history.map(item => item.run.id);\n\tif (new Set(runIds).size !== runIds.length) return undefined;\n\tlet allEvents = [...(events ?? []), ...history.flatMap(item => item.events)];\n\tif (new Set(allEvents.map(event => event.idempotencyKey)).size !== allEvents.length) {\n\t\treturn undefined;\n\t}\n\tlet successful = new Set();\n\tfor (let [index, archived] of history.entries()) {\n\t\tif (projected[index]?.outcome.kind === \"revision_requested\") continue;\n\t\tlet reference = [\n\t\t\tarchived.run.graphVersion,\n\t\t\tarchived.run.graphRevision,\n\t\t\tarchived.run.planRevision,\n\t\t].join(\":\");\n\t\tif (successful.has(reference)) return undefined;\n\t\tsuccessful.add(reference);\n\t}\n\treturn { ...(events ? { events } : {}), history };\n}\n\nfunction event(input: LifecycleInput): ProgressEvent {\n\tswitch (input.kind) {\n\t\tcase \"start\":\n\t\t\treturn {\n\t\t\t\tkind: input.kind,\n\t\t\t\ttaskId: input.taskId,\n\t\t\t\tidempotencyKey: input.idempotencyKey,\n\t\t\t};\n\t\tcase \"block\":\n\t\t\treturn {\n\t\t\t\tkind: input.kind,\n\t\t\t\ttaskId: input.taskId,\n\t\t\t\treason: input.reason,\n\t\t\t\tidempotencyKey: input.idempotencyKey,\n\t\t\t};\n\t\tcase \"report_pr\":\n\t\t\treturn {\n\t\t\t\tkind: input.kind,\n\t\t\t\ttaskId: input.taskId,\n\t\t\t\turl: input.url,\n\t\t\t\tstate: input.state,\n\t\t\t\tidempotencyKey: input.idempotencyKey,\n\t\t\t};\n\t\tcase \"complete\":\n\t\t\treturn {\n\t\t\t\tkind: input.kind,\n\t\t\t\ttaskId: input.taskId,\n\t\t\t\tsummary: input.summary,\n\t\t\t\tidempotencyKey: input.idempotencyKey,\n\t\t\t};\n\t\tcase \"report_verification\":\n\t\t\treturn {\n\t\t\t\tkind: input.kind,\n\t\t\t\t...reportFrom(input),\n\t\t\t\tidempotencyKey: input.idempotencyKey,\n\t\t\t};\n\t\tcase \"request_revision\":\n\t\t\treturn {\n\t\t\t\tkind: input.kind,\n\t\t\t\treason: input.reason,\n\t\t\t\tidempotencyKey: input.idempotencyKey,\n\t\t\t};\n\t}\n}\n\nfunction sameEvidence(left: VerificationEvidence[], right: VerificationEvidence[]): boolean {\n\treturn left.length === right.length && left.every((entry, index) => {\n\t\tlet other = right[index];\n\t\treturn entry.taskId === other?.taskId\n\t\t\t&& entry.evidence.length === other.evidence.length\n\t\t\t&& entry.evidence.every((value, evidenceIndex) => value === other.evidence[evidenceIndex]);\n\t});\n}\n\nfunction same(stored: ProgressEvent, input: LifecycleInput): boolean {\n\tif (stored.kind !== input.kind || stored.idempotencyKey !== input.idempotencyKey) return false;\n\tswitch (stored.kind) {\n\t\tcase \"start\":\n\t\t\treturn input.kind === \"start\" && stored.taskId === input.taskId;\n\t\tcase \"block\":\n\t\t\treturn input.kind === \"block\" && stored.taskId === input.taskId\n\t\t\t\t&& stored.reason === input.reason;\n\t\tcase \"report_pr\":\n\t\t\treturn input.kind === \"report_pr\" && stored.taskId === input.taskId\n\t\t\t\t&& stored.url === input.url && stored.state === input.state;\n\t\tcase \"complete\":\n\t\t\treturn input.kind === \"complete\" && stored.taskId === input.taskId\n\t\t\t\t&& stored.summary === input.summary;\n\t\tcase \"report_verification\":\n\t\t\treturn input.kind === \"report_verification\"\n\t\t\t\t&& stored.passed === input.passed\n\t\t\t\t&& stored.summary === input.summary\n\t\t\t\t&& stored.reviewerMethod === input.reviewerMethod\n\t\t\t\t&& sameEvidence(stored.evidence, input.evidence)\n\t\t\t\t&& stored.tasksNeedingWork.length === input.tasksNeedingWork.length\n\t\t\t\t&& stored.tasksNeedingWork.every((value, index) => value === input.tasksNeedingWork[index]);\n\t\tcase \"request_revision\":\n\t\t\treturn input.kind === \"request_revision\" && stored.reason === input.reason;\n\t}\n}\n\nfunction replay(state: LifecycleState, input: LifecycleInput): LifecycleResult | undefined {\n\tlet owned = [\n\t\t...(state.execution\n\t\t\t? (state.lifecycle.events ?? []).map(event => ({ runId: state.execution!.id, event }))\n\t\t\t: []),\n\t\t...state.lifecycle.history.flatMap(item =>\n\t\t\titem.events.map(event => ({ runId: item.run.id, event }))\n\t\t),\n\t];\n\tlet prior = owned.find(item => item.event.idempotencyKey === input.idempotencyKey);\n\treturn prior\n\t\t? prior.runId === input.runId && same(prior.event, input)\n\t\t\t? { kind: \"replayed\", state: copy(state) }\n\t\t\t: { kind: \"refused\", reason: \"idempotency-conflict\" }\n\t\t: undefined;\n}\n\nfunction released(\n\tstate: LifecycleState,\n\trun: Run,\n\tevents: ProgressEvent[],\n): LifecycleState {\n\tlet next = copy(state);\n\tlet version = next.graph.versions.at(-1)!;\n\tnext.graph.versions[next.graph.versions.length - 1] = { ...version, state: \"approved\" };\n\tnext.execution = undefined;\n\tnext.lifecycle = {\n\t\thistory: [...next.lifecycle.history, { run: copy(run), events: copy(events) }],\n\t};\n\treturn next;\n}\n\n/** Apply one lifecycle event without mutating the graph or claim identity. */\nexport function transition(state: LifecycleState, input: LifecycleInput): LifecycleResult {\n\tif (!text(input.runId)) return { kind: \"refused\", reason: \"run\" };\n\tif (!text(input.idempotencyKey)) {\n\t\treturn { kind: \"refused\", reason: \"idempotency-key\" };\n\t}\n\tlet prior = replay(state, input);\n\tif (prior) return prior;\n\n\tlet archivedIndex = state.lifecycle.history.findIndex(item => item.run.id === input.runId);\n\tif (archivedIndex >= 0) {\n\t\tif (input.kind !== \"report_pr\") return { kind: \"refused\", reason: \"inactive\" };\n\t\tlet archived = state.lifecycle.history[archivedIndex]!;\n\t\tlet version = versionFor(state.graph, archived.run);\n\t\tif (!version) return { kind: \"refused\", reason: \"inactive\" };\n\t\tlet folded = foldRun(version.definition.tasks, archived.run, archived.events);\n\t\tif (folded.kind === \"refused\") return folded;\n\t\tlet stored = event(input);\n\t\tlet reduced = reduceEvent(folded.state, stored);\n\t\tif (reduced.kind === \"refused\") return reduced;\n\t\tif (reduced.state.phase === \"active\" || reduced.state.phase === \"revision_requested\") {\n\t\t\treturn { kind: \"refused\", reason: \"inactive\" };\n\t\t}\n\t\tlet events = [...archived.events, stored];\n\t\tlet next = copy(state);\n\t\tnext.lifecycle.history[archivedIndex] = {\n\t\t\trun: copy(archived.run),\n\t\t\tevents: copy(events),\n\t\t};\n\t\treturn { kind: \"accepted\", state: next };\n\t}\n\n\tlet run = state.execution;\n\tlet version = run && activeVersion(state.graph, run);\n\tif (!run || input.runId !== run.id || !version) {\n\t\treturn { kind: \"refused\", reason: \"run\" };\n\t}\n\tlet existingEvents = state.lifecycle.events ?? [];\n\tlet folded = foldRun(version.definition.tasks, run, existingEvents);\n\tif (folded.kind === \"refused\" || folded.state.phase !== \"active\") {\n\t\treturn { kind: \"refused\", reason: \"invalid-lifecycle\" };\n\t}\n\tlet stored = event(input);\n\tlet reduced = reduceEvent(folded.state, stored);\n\tif (reduced.kind === \"refused\") return reduced;\n\tlet events = [...existingEvents, stored];\n\tif (reduced.state.phase !== \"active\") {\n\t\treturn {\n\t\t\tkind: \"accepted\",\n\t\t\tstate: released(state, run, events),\n\t\t};\n\t}\n\treturn {\n\t\tkind: \"accepted\",\n\t\tstate: {\n\t\t\t...state,\n\t\t\tlifecycle: { ...state.lifecycle, events: copy(events) },\n\t\t},\n\t};\n}\n\n/** Project queued work before the first lifecycle event. */\nexport function progressFor(\n\tgraph: Graph,\n\tlifecycle: Lifecycle,\n\texecution?: Run,\n): Progress | undefined {\n\tif (!execution) return undefined;\n\tlet version = activeVersion(graph, execution);\n\tif (!version) return undefined;\n\tlet events = lifecycle.events ?? [];\n\tlet folded = foldRun(version.definition.tasks, execution, events);\n\tif (folded.kind === \"refused\" || folded.state.phase !== \"active\") return undefined;\n\treturn projectRun(folded.state, events).progress;\n}\n\n/** Project archived event logs against the graph versions they implemented. */\nexport function historyFor(graph: Graph, lifecycle: Lifecycle): HistoricalRun[] {\n\treturn copy(projectHistory(graph, lifecycle.history) ?? []);\n}\n\n/** Project durable lifecycle state into the shape shared by MCP and the wire. */\nexport function implementationLifecycle(state: LifecycleState): ImplementationLifecycle {\n\treturn {\n\t\texecution: state.execution ? { state: \"active\" } : { state: \"idle\" },\n\t\tactivity: progressFor(state.graph, state.lifecycle, state.execution),\n\t\thistory: historyFor(state.graph, state.lifecycle),\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",1794440659834,"sidebar","expanded"]