[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_1099":-5,"_1102":1103,"_1104":1105},"routes/shell",{"_874":875,"_1098":-5,"_1099":-5,"_1100":1101},"routes/repo",{"_867":-7,"_868":869,"_870":871,"_872":873,"_874":875,"_876":26,"_877":26,"_878":26,"_879":26,"_880":26,"_881":26,"_882":44,"_883":44,"_884":26,"_885":-7,"_886":-7,"_887":888,"_889":890,"_891":892,"_893":-5,"_894":895,"_896":897,"_898":899,"_900":901},"routes/repo.commit",{"_13":14,"_15":16,"_17":18},"commit",{"_85":22,"_845":846,"_847":848,"_849":850,"_851":852,"_853":-5,"_854":852,"_855":856},"diff",{"_19":20,"_21":22,"_23":24,"_25":26},"checks",[],"old","6dc0f1c881983718d00b042f4018f3ad6e535bdd","new","aff8d54e95c93c117efe1d3682d8d89c4a208bcc","files",[27,28,29,30,31,32,33,34],"truncated",false,{"_35":821,"_19":822,"_21":823,"_39":40,"_41":94,"_43":94,"_45":824},{"_35":656,"_19":657,"_21":658,"_39":40,"_41":659,"_43":236,"_45":660},{"_35":614,"_19":615,"_21":616,"_39":40,"_41":51,"_43":617,"_45":618},{"_35":487,"_19":488,"_21":489,"_39":40,"_41":131,"_43":51,"_45":490},{"_35":286,"_19":287,"_21":288,"_39":40,"_41":289,"_43":290,"_45":291},{"_35":119,"_19":120,"_21":121,"_39":40,"_41":122,"_43":123,"_45":124},{"_35":90,"_19":91,"_21":92,"_39":40,"_41":93,"_43":94,"_45":95},{"_35":36,"_19":37,"_21":38,"_39":40,"_41":42,"_43":44,"_45":46},"path","docs/architecture.md",{"_85":89,"_87":88},{"_85":86,"_87":88},"kind","text","add",7,"del",0,"hunks",[47],{"_48":49,"_50":51,"_52":49,"_53":54,"_55":56},"aStart",106,"aLen",6,"bStart","bLen",13,"ops",[57,58,59,60,61,62,63,64,65,66,67,68,69],{"_70":71,"_72":84},{"_70":71,"_72":83},{"_70":71,"_72":76},{"_70":41,"_72":82},{"_70":41,"_72":81},{"_70":41,"_72":80},{"_70":41,"_72":79},{"_70":41,"_72":78},{"_70":41,"_72":77},{"_70":41,"_72":76},{"_70":71,"_72":75},{"_70":71,"_72":74},{"_70":71,"_72":73},"tag","eq","line","liveness sweep broadcasts when a crashed worker's busy projection becomes stale, without writing","or dormant channels, and check the worker PID as well as the socket path. A five-second host","Workers clear the busy projection on startup and normal exit. Listings suppress it for archived","","A rejected watch retries only when asked, or once when an offline channel's host becomes reachable.","killed channel's worker as reopening it would, and stops after three quick ends with an error.","end of a watch it released, restarts others with a fresh replay and channel info, which wakes a","or peer gateway closed; relays then drop it and never re-watch on their own. The app ignores the","failure frame after the accepted reply, whether it was released or its worker, hosted connection,","The app owns its transcript watches. A gateway or peer host relaying a watch reports its end with a","retires when it has no clients and no live work.","channel's worker on demand and talk to it over `channel.sock` with newline-delimited JSON. A worker","oid","40d34f5","mode","100644","2ba7068","apps/host/src/protocol.ts",{"_85":118,"_87":88},{"_85":117,"_87":88},2,1,[96],{"_48":97,"_50":42,"_52":97,"_53":98,"_55":99},161,8,[100,101,102,103,104,105,106,107,108],{"_70":71,"_72":109},{"_70":71,"_72":116},{"_70":71,"_72":115},{"_70":43,"_72":114},{"_70":41,"_72":113},{"_70":41,"_72":112},{"_70":71,"_72":111},{"_70":71,"_72":110},{"_70":71,"_72":109},"\t/**","\t| { op: \"channel\"; channel: string; request: Request }","\t */","\t * the channel's worker or a relaying host closes. Clients that predate this frame drop it.","\t * events until a failure frame for its id follows the accepted reply: after `release`, or when","\t * events until `release`.","\t * channel's host sets every author field to the participant it verified. A `watch` streams","\t * Forward a request to a channel on this host or a peer, starting its worker if dormant. The","6f015ed","b2c19b5","apps/host/src/gateway.ts",{"_85":285,"_87":88},{"_85":284,"_87":88},26,12,[125,126,127,128,129],{"_48":266,"_50":42,"_52":266,"_53":42,"_55":267},{"_48":235,"_50":236,"_52":235,"_53":133,"_55":237},{"_48":185,"_50":51,"_52":186,"_53":187,"_55":188},{"_48":171,"_50":42,"_52":172,"_53":42,"_55":173},{"_48":130,"_50":131,"_52":132,"_53":133,"_55":134},389,16,408,11,[135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152],{"_70":71,"_72":170},{"_70":71,"_72":169},{"_70":71,"_72":168},{"_70":43,"_72":167},{"_70":41,"_72":166},{"_70":71,"_72":165},{"_70":71,"_72":164},{"_70":71,"_72":163},{"_70":43,"_72":162},{"_70":43,"_72":161},{"_70":43,"_72":160},{"_70":43,"_72":159},{"_70":43,"_72":158},{"_70":43,"_72":157},{"_70":41,"_72":156},{"_70":71,"_72":155},{"_70":71,"_72":154},{"_70":71,"_72":153},"\t\t\tconst open = client.channels.get(request.channel);","\t\tcase \"release\": {","\t\t}","\t\t\treturn target.channel(request.channel, request.request, watch, trace);","\t\t\t);","\t\t\t\ttrace,","\t\t\t\t(event) => send({ id, event }),","\t\t\t\trequest.request,","\t\t\t\trequest.channel,","\t\t\treturn target.channel(","\t\t\tconst target = await remote(client, machine.name);","\t\t\tif (!machine) throw new Error(\"No reachable host runs that channel\");","\t\t\t}","\t\t\t\treturn target.request(forwarded, watch, trace);","\t\t\t\treturn target.request(forwarded, (event) => send({ id, event }), trace);","\t\t\t\tconst target = await connection(client, request.channel, hosted.hosted);","\t\t\t\t\t: request.request;","\t\t\t\t\t? { ...request.request, author: client.user }",376,395,[174,175,176,177,178,179,180,181],{"_70":71,"_72":170},{"_70":71,"_72":169},{"_70":71,"_72":184},{"_70":43,"_72":167},{"_70":41,"_72":166},{"_70":71,"_72":165},{"_70":71,"_72":183},{"_70":71,"_72":182},"\t\t\tconst hosted = !client.peer && !machine","\t\t\tconst machine = !client.peer && peers.find(request.channel);","\t\t\t\tconst target = await connection(client, request.channel);",367,369,23,[189,190,191,192,193,194,195,196,197,198,199,200,201,202,203,204,205,206,207,208,209,210,211],{"_70":71,"_72":234},{"_70":71,"_72":233},{"_70":71,"_72":232},{"_70":41,"_72":231},{"_70":41,"_72":230},{"_70":41,"_72":229},{"_70":41,"_72":228},{"_70":41,"_72":227},{"_70":41,"_72":226},{"_70":41,"_72":225},{"_70":41,"_72":224},{"_70":41,"_72":223},{"_70":41,"_72":222},{"_70":41,"_72":221},{"_70":41,"_72":220},{"_70":41,"_72":219},{"_70":41,"_72":218},{"_70":41,"_72":217},{"_70":41,"_72":216},{"_70":41,"_72":215},{"_70":71,"_72":214},{"_70":71,"_72":213},{"_70":71,"_72":212},"\t\t\t\t\tif (client.user !== catalog.user) throw new Error(\"Only the channel's owner can kill it\");","\t\t\t\tif (request.request.op === \"kill\") {","\t\t\tif (catalog.owns(request.channel)) {","\t\t\t\t: undefined;","\t\t\t\t}","\t\t\t\t\t},","\t\t\t\t\t\tsend({ id, ok: false, error });","\t\t\t\t\t\t});","\t\t\t\t\t\t\terror,","\t\t\t\t\t\t\tchannel: request.channel,","\t\t\t\t\t\t\tpeer: client.peer,","\t\t\t\t\t\t\tuser: client.user,","\t\t\t\t\t\t\ttrace,","\t\t\t\t\t\tlog(\"debug\", \"gateway.watch.closed\", {","\t\t\t\t\tclosed: (error) => {","\t\t\t\t\t// After the accepted reply, a failure for the same id tells the client its watch ended.","\t\t\t\t\tevent: (event) => send({ id, event }),","\t\t\t\t? {","\t\t\tconst watch: Watch | undefined = request.request.op === \"watch\"","\t\t\t// Only a watch streams; other requests must not leave watchers behind in relays.","\t\tcase \"channel\": {","\t\t\treturn terminals.close(request.terminal);","\t\t\tclient.terminals.delete(request.terminal);",151,9,[238,239,240,241,242,243,244,245,246,247,248,249,250,251],{"_70":71,"_72":265},{"_70":71,"_72":264},{"_70":71,"_72":263},{"_70":43,"_72":262},{"_70":43,"_72":261},{"_70":43,"_72":260},{"_70":41,"_72":259},{"_70":41,"_72":258},{"_70":41,"_72":257},{"_70":41,"_72":256},{"_70":41,"_72":255},{"_70":71,"_72":254},{"_70":71,"_72":253},{"_70":71,"_72":252},"}","\treturn open;","\t}","\t\topen.then((connection) => connection.closed.then(drop), drop);","\t\t};","\t\t\tif (client.channels.get(channel) === open) client.channels.delete(channel);","\t\tconst drop = () => {","\t\t// A released connection can close after its replacement opened; never drop the replacement.","\t\t});","\t\t\tclient.channels.delete(channel);","\t\topen.then((connection) => connection.closed.then(() => client.channels.delete(channel)), () => {","\t\tclient.channels.set(channel, open);","\t\topen = hosted ? Connection.hosted(hosted, channel) : Connection.open(channel);","\tif (!open) {",10,[268,269,270,271,272,273,274,275],{"_70":71,"_72":283},{"_70":71,"_72":282},{"_70":71,"_72":281},{"_70":43,"_72":280},{"_70":41,"_72":279},{"_70":71,"_72":278},{"_70":71,"_72":277},{"_70":71,"_72":276},"import { failure, log, open as openLog } from \"./log\";","import { seal } from \"./keys\";","import * as github from \"./github\";","import { GatewayClient, type Watch } from \"./gateway-client\";","import { GatewayClient } from \"./gateway-client\";","import * as directory from \"./directory\";","import { diagnostics } from \"./diagnostics\";","import { config } from \"./config\";","a8371f7","155d855","apps/host/src/gateway-client.ts",{"_85":486,"_87":88},{"_85":485,"_87":88},38,18,[292,293,294,295,296],{"_48":448,"_50":266,"_52":448,"_53":290,"_55":449},{"_48":409,"_50":54,"_52":410,"_53":131,"_55":411},{"_48":365,"_50":133,"_52":366,"_53":367,"_55":368},{"_48":351,"_50":42,"_52":352,"_53":42,"_55":353},{"_48":297,"_50":131,"_52":298,"_53":299,"_55":300},191,208,19,[301,302,303,304,305,306,307,308,309,310,311,312,313,314,315,316,317,318,319,320,321,322,323,324,325,326,327],{"_70":71,"_72":350},{"_70":71,"_72":349},{"_70":71,"_72":348},{"_70":43,"_72":347},{"_70":41,"_72":346},{"_70":71,"_72":345},{"_70":71,"_72":344},{"_70":43,"_72":343},{"_70":43,"_72":342},{"_70":43,"_72":341},{"_70":43,"_72":340},{"_70":43,"_72":165},{"_70":43,"_72":339},{"_70":43,"_72":260},{"_70":41,"_72":338},{"_70":41,"_72":337},{"_70":41,"_72":336},{"_70":41,"_72":335},{"_70":41,"_72":334},{"_70":41,"_72":333},{"_70":41,"_72":216},{"_70":41,"_72":332},{"_70":41,"_72":331},{"_70":41,"_72":256},{"_70":71,"_72":330},{"_70":71,"_72":329},{"_70":71,"_72":328},"\t\t\treturn value;","\t\t\tif (request.op === \"rename\") this.#update(channel, value as Metadata);","\t\treturn this.request({ op: \"channel\", channel, request }, observe, trace).then((value) => {","\t\t\t},","\t\t\t\twatch.event(event);","\t\t\t\t\tthis.#update(channel, { name, summary, revision });","\t\t\t\t\tconst { name, summary, revision } = event;","\t\t\t\tif (event.kind === \"metadata\") {","\t\t\tevent: (event: Event) => {","\t\t\tclosed: (error: string) => watch.closed?.(error),","\t\tconst observe = watch && {","\t\t\twatch(event);","\t\t\t\tthis.#update(channel, { name, summary, revision });","\t\t\t\tconst { name, summary, revision } = event;","\t\t\tif (event.kind === \"metadata\") {","\t\tconst observe = watch && ((event: Event) => {","\t): Promise {","\t\ttrace?: string,","\t\twatch?: Watch,","\t\twatch?: (event: Event) => void,","\t\trequest: Request,","\t\tchannel: string,","\tchannel(",172,189,[354,355,356,357,358,359,360,361],{"_70":71,"_72":76},{"_70":71,"_72":364},{"_70":71,"_72":363},{"_70":43,"_72":347},{"_70":41,"_72":346},{"_70":71,"_72":345},{"_70":71,"_72":344},{"_70":71,"_72":362},"\t\tif (this.status !== \"open\") return Promise.reject(new Error(\"Not connected to the host\"));","\t\trequest: HostRequest,","\trequest(",109,120,17,[369,370,371,372,373,374,375,376,377,378,379,380,381,382,383,384,385,386,387,388,389,390],{"_70":71,"_72":155},{"_70":71,"_72":408},{"_70":71,"_72":407},{"_70":43,"_72":406},{"_70":43,"_72":405},{"_70":43,"_72":404},{"_70":43,"_72":403},{"_70":43,"_72":402},{"_70":41,"_72":401},{"_70":41,"_72":400},{"_70":41,"_72":399},{"_70":41,"_72":398},{"_70":41,"_72":397},{"_70":41,"_72":396},{"_70":41,"_72":155},{"_70":41,"_72":395},{"_70":41,"_72":394},{"_70":41,"_72":393},{"_70":41,"_72":392},{"_70":71,"_72":254},{"_70":71,"_72":76},{"_70":71,"_72":391},"\tasync #rename(request: TabRename, socket: WebSocket) {","\t\tpending.reject(new Error(frame.error));","\t\tif (pending.accepted) return pending.watch?.closed?.(frame.error);","\t\tif (frame.ok) return pending.resolve(frame.value);","\t\tthis.#pending.delete(frame.id);","\t\t\treturn pending.resolve(frame.value);","\t\t\tpending.accepted = true;","\t\tif (pending.watch && frame.ok) {","\t\t// A watch keeps its entry so later events still reach it, until a failure ends it.","\t\tif (\"event\" in frame) return pending.watch?.event(frame.event);","\t\tif (!pending) return;","\t\tpending?.reject(new Error(frame.error));","\t\tif (frame.ok) return pending?.resolve(frame.value);","\t\tif (!pending?.watch || !frame.ok) this.#pending.delete(frame.id);","\t\t// A watch keeps its entry so later events still reach it.","\t\tif (\"event\" in frame) return pending?.watch?.(frame.event);","\t\tconst pending = this.#pending.get(frame.id);","\t\tif (\"terminal\" in frame) return this.#terminals.get(frame.terminal)?.(frame);",76,84,[412,413,414,415,416,417,418,419,420,421,422,423,424,425,426,427,428,429,430],{"_70":71,"_72":447},{"_70":71,"_72":446},{"_70":71,"_72":445},{"_70":43,"_72":444},{"_70":43,"_72":443},{"_70":43,"_72":165},{"_70":41,"_72":442},{"_70":71,"_72":441},{"_70":71,"_72":440},{"_70":71,"_72":439},{"_70":71,"_72":438},{"_70":41,"_72":437},{"_70":41,"_72":436},{"_70":41,"_72":435},{"_70":41,"_72":434},{"_70":41,"_72":165},{"_70":71,"_72":433},{"_70":71,"_72":432},{"_70":71,"_72":431},"\t\t\tthis.#retry = Math.min(this.#retry * 2, 5000);","\t\t\tthis.#timer = setTimeout(() => this.#connect(), this.#retry);","\t\t\tif (this.#closed) return;","\t\t\t\telse pending.reject(new Error(error));","\t\t\t\tif (pending.accepted) pending.watch?.closed?.(error);","\t\t\tfor (const pending of ended) {","\t\t\tconst error = \"Disconnected from the host\";","\t\t\tthis.#set(\"closed\");","\t\t\tthis.channels = [];","\t\t\tthis.#metadata.clear();","\t\t\tthis.#pending.clear();","\t\t\tconst ended = [...this.#pending.values()];","\t\t\t\tpending.reject(new Error(\"Disconnected from the host\"));","\t\t\tfor (const pending of this.#pending.values()) {","\t\tsocket.addEventListener(\"close\", () => {","\t\t);","\t\t\t(message) => this.#receive(JSON.parse(String(message.data)) as HostFrame, socket),",14,[450,451,452,453,454,455,456,457,458,459,460,461,462,463,464,465,466,467,468],{"_70":71,"_72":484},{"_70":71,"_72":483},{"_70":71,"_72":76},{"_70":41,"_72":482},{"_70":41,"_72":481},{"_70":41,"_72":480},{"_70":41,"_72":479},{"_70":41,"_72":478},{"_70":41,"_72":76},{"_70":71,"_72":477},{"_70":71,"_72":476},{"_70":71,"_72":475},{"_70":43,"_72":474},{"_70":41,"_72":473},{"_70":41,"_72":472},{"_70":41,"_72":471},{"_70":71,"_72":470},{"_70":71,"_72":469},{"_70":71,"_72":76},"export type Status = \"connecting\" | \"open\" | \"closed\";","};","\taccepted?: boolean;","\t/** The watch was accepted, so a later failure ends it instead of rejecting the request. */","\twatch?: Watch;","\twatch?: (event: Event) => void;","\treject(error: Error): void;","\tresolve(value: unknown): void;","type Pending = {","export type Watch = { event(event: Event): void; closed?(error: string): void };"," */"," * or a relaying host closed. The owner decides whether to watch again."," * A watch's events, then `closed` once an accepted watch ends: released, or its channel connection","/**","} from \"./protocol\";","\tWindowState,","2f9e724","8c862ef","apps/host/src/client.ts",{"_85":613,"_87":88},{"_85":612,"_87":88},[491,492,493,494,495],{"_48":93,"_50":266,"_52":93,"_53":133,"_55":590},{"_48":570,"_50":42,"_52":571,"_53":98,"_55":572},{"_48":535,"_50":236,"_52":536,"_53":537,"_55":538},{"_48":522,"_50":42,"_52":523,"_53":42,"_55":524},{"_48":97,"_50":448,"_52":496,"_53":131,"_55":497},169,[498,499,500,501,502,503,504,505,506,507,508,509,510,511,512,513,514],{"_70":71,"_72":254},{"_70":71,"_72":76},{"_70":71,"_72":521},{"_70":41,"_72":520},{"_70":71,"_72":519},{"_70":71,"_72":254},{"_70":71,"_72":76},{"_70":71,"_72":518},{"_70":43,"_72":517},{"_70":41,"_72":516},{"_70":71,"_72":407},{"_70":71,"_72":395},{"_70":71,"_72":403},{"_70":41,"_72":515},{"_70":71,"_72":402},{"_70":71,"_72":254},{"_70":71,"_72":252},"\t\tthis.#watchers.delete(frame.id);","\t\tif (\"event\" in frame) return this.#watchers.get(frame.id)?.event(frame.event);","\t\tif (\"event\" in frame) return this.#watchers.get(frame.id)?.(frame.event);","\t#receive(frame: Frame) {","\t\tthis.#transport.end();","\t\tthis.#released = true;","\tclose(): void {",149,157,[525,526,527,528,529,530,531,532],{"_70":71,"_72":76},{"_70":71,"_72":364},{"_70":71,"_72":534},{"_70":43,"_72":347},{"_70":41,"_72":346},{"_70":71,"_72":345},{"_70":71,"_72":344},{"_70":71,"_72":533},"\t\tconst id = this.#next++;","\t\trequest: Request | WorkerRequest,",105,107,15,[539,540,541,542,543,544,545,546,547,548,549,550,551,552,553,554,555],{"_70":71,"_72":569},{"_70":71,"_72":568},{"_70":71,"_72":567},{"_70":43,"_72":566},{"_70":43,"_72":565},{"_70":41,"_72":564},{"_70":41,"_72":563},{"_70":41,"_72":562},{"_70":41,"_72":561},{"_70":41,"_72":560},{"_70":71,"_72":165},{"_70":41,"_72":559},{"_70":41,"_72":558},{"_70":41,"_72":557},{"_70":71,"_72":260},{"_70":71,"_72":556},{"_70":71,"_72":254},"\t\treturn connection;","\t\t\tconnection.#pending.clear();","\t\t\tfor (const { reject } of connection.#pending.values()) reject(new Error(error));","\t\t\tconnection.#watchers.clear();","\t\t\t\twatch.closed?.(connection.#released ? \"The watch was released\" : error);","\t\t\t\tif (connection.#pending.has(id)) continue;","\t\t\tfor (const [id, watch] of connection.#watchers) {","\t\t\t// Every accepted watch ends here, so relays can drop it; its owner decides whether to watch again.","\t\t\tconst error = \"The channel closed the connection\";","\t\t\t\treject(new Error(\"The channel closed the connection\"));","\t\t\tfor (const { reject } of connection.#pending.values()) {","\t\tconnection.closed.then(() => {","\t\tconnection.closed = connection.#transport.closed;","\t\tconnection.#transport = await open((text) => connection.#receive(JSON.parse(text)));",95,96,[573,574,575,576,577,578,579,580,581],{"_70":71,"_72":589},{"_70":71,"_72":588},{"_70":71,"_72":587},{"_70":43,"_72":586},{"_70":41,"_72":585},{"_70":41,"_72":584},{"_70":71,"_72":583},{"_70":71,"_72":76},{"_70":71,"_72":582},"\tprivate constructor() {}","\tclosed!: Promise;","\t#released = false;","\t#watchers = new Map();","\t#watchers = new Map void>();","\t#pending = new Map();","\t#next = 1;","\t#transport!: Transport;",[591,592,593,594,595,596,597,598,599,600,601,602],{"_70":71,"_72":611},{"_70":71,"_72":610},{"_70":71,"_72":76},{"_70":43,"_72":609},{"_70":41,"_72":608},{"_70":71,"_72":76},{"_70":71,"_72":607},{"_70":71,"_72":283},{"_70":41,"_72":606},{"_70":71,"_72":605},{"_70":71,"_72":604},{"_70":71,"_72":603},"import { failure, log } from \"./log\";","import { lines } from \"./lines\";","import { key, workerEnv } from \"./keys\";","import type { Watch } from \"./gateway-client\";","import * as catalog from \"./catalog\";","import type { Frame, Request } from \"@ace/channel/protocol\";","import type { Event, Frame, Request } from \"@ace/channel/protocol\";","import { connect as dial, type Socket } from \"node:net\";","import { closeSync, openSync } from \"node:fs\";","05191fb","5c1d755","apps/host/src/cli.ts",{"_85":655,"_87":654},{"_85":653,"_87":654},4,[619],{"_48":620,"_50":266,"_52":620,"_53":123,"_55":621},119,[622,623,624,625,626,627,628,629,630,631,632,633,634,635,636,637],{"_70":71,"_72":652},{"_70":71,"_72":651},{"_70":71,"_72":650},{"_70":43,"_72":649},{"_70":43,"_72":648},{"_70":43,"_72":647},{"_70":43,"_72":646},{"_70":41,"_72":645},{"_70":41,"_72":644},{"_70":41,"_72":643},{"_70":41,"_72":642},{"_70":41,"_72":641},{"_70":41,"_72":640},{"_70":71,"_72":639},{"_70":71,"_72":638},{"_70":71,"_72":252},"\treturn { connection, done: done.promise };","\t});","\t\t},","\t\t\tif (live && until?.(event)) done.resolve();","\t\t\tif (live || replay) render(event, info);","\t\t\tif (event.kind === \"live\") return void (live = true);","\t\tevent(event) {","\tawait connection.request({ op: \"watch\", chat: chat() }, {","\t\tif (live && until?.(event)) done.resolve();","\t\tif (live || replay) render(event, info);","\t\tif (event.kind === \"live\") return void (live = true);","\tawait connection.request({ op: \"watch\", chat: chat() }, (event) => {","\tconst done = Promise.withResolvers();","\tlet live = false;","\tconst info = await connection.request({ op: \"info\" });","4266cd8","100755","6c8767a","apps/app/src/transcript.ts",{"_85":820,"_87":88},{"_85":819,"_87":88},45,[661],{"_48":662,"_50":663,"_52":662,"_53":664,"_55":665},129,36,72,[666,667,668,669,670,671,672,673,674,675,676,677,678,679,680,681,682,683,684,685,686,687,688,689,690,691,692,693,694,695,696,697,698,699,700,701,702,703,704,705,706,707,708,709,710,711,712,713,714,715,716,717,718,719,720,721,722,723,724,725,726,727,728,729,730,731,732,733,734,735,736,737,738,739,740,741,742,743,744,745,746],{"_70":71,"_72":818},{"_70":71,"_72":252},{"_70":71,"_72":76},{"_70":43,"_72":817},{"_70":43,"_72":816},{"_70":41,"_72":815},{"_70":41,"_72":814},{"_70":41,"_72":813},{"_70":41,"_72":76},{"_70":41,"_72":482},{"_70":41,"_72":812},{"_70":41,"_72":811},{"_70":41,"_72":810},{"_70":41,"_72":479},{"_70":41,"_72":809},{"_70":41,"_72":808},{"_70":41,"_72":807},{"_70":41,"_72":806},{"_70":41,"_72":805},{"_70":71,"_72":804},{"_70":71,"_72":803},{"_70":71,"_72":802},{"_70":71,"_72":801},{"_70":41,"_72":800},{"_70":41,"_72":799},{"_70":41,"_72":798},{"_70":41,"_72":797},{"_70":41,"_72":254},{"_70":71,"_72":796},{"_70":71,"_72":795},{"_70":71,"_72":794},{"_70":71,"_72":793},{"_70":41,"_72":792},{"_70":41,"_72":791},{"_70":71,"_72":790},{"_70":71,"_72":789},{"_70":41,"_72":788},{"_70":71,"_72":787},{"_70":71,"_72":786},{"_70":71,"_72":785},{"_70":41,"_72":784},{"_70":71,"_72":783},{"_70":71,"_72":782},{"_70":43,"_72":781},{"_70":41,"_72":780},{"_70":71,"_72":779},{"_70":71,"_72":778},{"_70":43,"_72":777},{"_70":43,"_72":776},{"_70":43,"_72":775},{"_70":43,"_72":774},{"_70":41,"_72":773},{"_70":41,"_72":772},{"_70":41,"_72":771},{"_70":41,"_72":770},{"_70":41,"_72":769},{"_70":41,"_72":759},{"_70":41,"_72":768},{"_70":41,"_72":767},{"_70":41,"_72":766},{"_70":41,"_72":765},{"_70":41,"_72":764},{"_70":41,"_72":763},{"_70":41,"_72":762},{"_70":41,"_72":761},{"_70":41,"_72":760},{"_70":41,"_72":759},{"_70":71,"_72":758},{"_70":43,"_72":757},{"_70":41,"_72":756},{"_70":71,"_72":755},{"_70":71,"_72":256},{"_70":71,"_72":754},{"_70":43,"_72":753},{"_70":41,"_72":752},{"_70":41,"_72":751},{"_70":41,"_72":750},{"_70":41,"_72":260},{"_70":71,"_72":749},{"_70":71,"_72":748},{"_70":71,"_72":747},"\t\t\toff();","\t\t\tactive = false;","\t\treturn () => {","\t\t\tstart();","\t\t\trecoveries = 0;","\t\tconst off = onOpen(() => {","\t\tconst off = onOpen(start);","\t\tstart();","\t\t\t});","\t\t\t\tif (current()) setError(error.message);","\t\t\t\tif (active && version === generation) setError(error.message);","\t\t\t}).catch((error: Error) => {","\t\t\t\t},","\t\t\t\t\tsetError(reason);","\t\t\t\t\tsetInfo(undefined);","\t\t\t\t\tsetState(EMPTY);","\t\t\t\t\tgeneration++;","\t\t\t\t\tif (recoveries++ < RECOVERIES) return start();","\t\t\t\t\tif (Date.now() - started > STABLE) recoveries = 0;","\t\t\t\t\tif (!current() || host.status !== \"open\") return;","\t\t\t\tclosed(reason) {","\t\t\t\t// A released watch belongs to an old generation; a reconnecting host restarts every watch.","\t\t\t\t\tif (event.kind === \"run\") void refresh();","\t\t\t\t\tsetState((state) => apply(state, event));","\t\t\t\t\tif (!current()) return;","\t\t\t\tevent(event) {","\t\t\thost.channel(channel, { op: \"watch\", ...(chat === undefined ? {} : { chat }) }, {","\t\t\t\tif (event.kind === \"run\") void refresh();","\t\t\t\tsetState((current) => apply(current, event));","\t\t\t\tif (!active || version !== generation) return;","\t\t\thost.channel(channel, { op: \"watch\", ...(chat === undefined ? {} : { chat }) }, (event) => {","\t\t\tvoid refresh();","\t\t\t\t}, () => {});","\t\t\t\t\tif (current()) setInfo(value);","\t\t\t\t\tif (active && version === generation) setInfo(value);","\t\t\t\thost.channel(channel, { op: \"info\" }).then((value) => {","\t\t\tconst refresh = () =>","\t\t\tconst current = () => active && version === generation;","\t\t\tsetError(undefined);","\t\t\tsetInfo(undefined);","\t\t\tsetState(EMPTY);","\t\t\tstarted = Date.now();","\t\t\tconst version = ++generation;","\t\tconst start = () => {","\t\tlet started = 0;","\t\tlet recoveries = 0;","\t\tlet generation = 0;","\t\tlet active = true;","\t\tif (!channel) return;","\tuseEffect(() => {","\t\tif (!offline && error) setAttempt((value) => value + 1);","\t\tsetWasOffline(offline);","\tif (offline !== wasOffline) {","\tconst [wasOffline, setWasOffline] = useState(offline);","\tconst [attempt, setAttempt] = useState(0);","\tconst [error, setError] = useState();","\tconst [info, setInfo] = useState();","\tconst [state, setState] = useState(EMPTY);",") {","\toffline: boolean,","\tchat: number | undefined,","\tchannel: string | undefined,","export function useTranscript("," * watch retries once when its channel's host comes back from `offline`."," * watch ends, such as when the channel's worker restarts, and releases it on unmount. A failed"," * Watches one chat of a channel. Owns the watch: re-watches after the host reconnects or the","const STABLE = 60_000;","const RECOVERIES = 3;","/** Automatic re-watches allowed before a watch stays open for `STABLE` ms. */","export function useTranscript(channel: string | undefined, chat?: number) {","/** Watches one chat of a channel, re-watching after the host reconnects. */","\treturn { at, author, text, ...(images ? { images } : {}), invoked };","9aad760","96613ff","apps/app/src/conversation.tsx",{"_85":844,"_87":88},{"_85":843,"_87":88},[825],{"_48":826,"_50":42,"_52":826,"_53":42,"_55":827},25,[828,829,830,831,832,833,834,835],{"_70":71,"_72":842},{"_70":71,"_72":841},{"_70":71,"_72":805},{"_70":43,"_72":840},{"_70":41,"_72":839},{"_70":71,"_72":838},{"_70":71,"_72":837},{"_70":71,"_72":836},"\tconst people = useSyncExternalStore(host.subscribe, () => host.people);","\tconst model = chat?.model || channel.model;","\tconst chat = transcript.info?.chats.find((value) => value.id === id);","\tconst transcript = useTranscript(channel.id, id, channel.state === \"offline\");","\tconst transcript = useTranscript(channel.id, id);","\t{ channel, chat: id, user, draft, onDraftLoaded, onSettings, onWork }: Props,","export function Conversation(","90e7978","91226d5","parents",[20],"author",{"_858":859,"_860":861,"_865":866},"committer",{"_858":859,"_860":861,"_865":866},"message","fix(host): recover open transcript watches after channel workers restart","signature","subject","authors",[857],{"_858":859,"_860":861,"_862":859,"_863":864},"name","iamnbutler","email","iamnbutler@github.com","login","avatarUrl","https://avatars.githubusercontent.com/u/1714999?v=4","time",1791322025,"documentNavigation","repo","githubnext/ace2","repoId","938fe4cd-5320-4e4f-ac7c-87d4dad8490c","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars","watchers","watching","pinned","notify","views",[1054,1055,1056,1057,1058,1059,1060,1061,1062,1063,1064,1065,1066],"navigation",{"_887":888,"_1014":1015,"_1016":1017,"_1018":1019,"_1020":1021,"_1022":1023,"_70":1024},"sources",[],"viewer","meta",{"_1007":1008,"_1009":1010,"_1011":76,"_876":26,"_1012":999,"_1013":26,"_882":44,"_883":44},"branches",[914,915,916,917,918,919,920,921,922,923,924,925,926,927,928,929,930,931,932,933,934,935,936,937,938,939,940,941,942,943,944,945,946,947,948,949,950,951,952,953,954,955,956,957,958,959,960,961,962,963,964,965,966,967,968,969,970,971,972,973,974,975,976,977,978,979,980,981,982,983,984,985,986,987,988,989,990,991,992,993,994,995,996,997,998,999,1000,1001,1002,1003,1004,1005,1006],"tags",[902,903,904,905,906,907,908,909,910,911,912,913],"cloneUrl","https://git.nexthub.sh/githubnext/ace2.git","desktop-canary-v0.0.10","desktop-canary-v0.0.11","desktop-canary-v0.0.12","desktop-canary-v0.0.13","desktop-canary-v0.0.14","desktop-canary-v0.0.15","desktop-canary-v0.0.16","desktop-canary-v0.0.18","desktop-canary-v0.0.21","desktop-canary-v0.0.7","desktop-canary-v0.0.8","desktop-canary-v0.0.9","amber-beacon/composer-effort","brisk-ember/github-avatars","brisk-grove/image-paste-91","calm-anchor/fix-streaming-draft-overlap","calm-grove/composer-agent-mode","cloud-pilot-ops/canary-0-0-17","cloud-pilot-ops/cloud-move","cloud-pilot-ops/cloud-pilot","codex/agentation-shortcut","codex/annotation-polish","codex/browser-pages","codex/canary-0-0-21","codex/canary-0.0.11","codex/channel-delete-close","codex/channel-watch-recovery","codex/clipboard-files-write","codex/composer-coordinate-check","codex/computer-use-validation","codex/desktop-actions","codex/desktop-app-search","codex/desktop-app-state","codex/desktop-availability","codex/desktop-click-variants","codex/desktop-clipboard","codex/desktop-clipboard-files","codex/desktop-clipboard-image","codex/desktop-clipboard-image-write","codex/desktop-clipboard-text","codex/desktop-drag","codex/desktop-keyboard","codex/desktop-launch","codex/desktop-locked-feedback","codex/desktop-menu-command","codex/desktop-menu-inventory","codex/desktop-minimize","codex/desktop-open","codex/desktop-pointer","codex/desktop-quit","codex/desktop-selection-keys","codex/desktop-tool-guidance","codex/desktop-tools-extraction","codex/desktop-window-close","codex/desktop-window-geometry","codex/desktop-windows","codex/dev-permission-identity","codex/durable-composer-drafts","codex/fix-message-clipping","codex/lane-base-96","codex/native-patch-prefix","codex/peekaboo","codex/peer-channel-messaging","codex/pixel-snapshot-authority","codex/publish-canary-0-0-21","codex/readme-security","codex/settings-refresh","codex/stale-click-refusal","codex/tab-renaming-api","codex/team-agent-access","codex/team-channel-sections","codex/team-dogfood-integration","codex/webkit-coordinate-window","codex/webkit-desktop-focus","deft-beacon/helper-isolation","deft-grove/align-avatar-byline","deft-grove/build-canary-0-0-18","deft-grove/canary-github-releases","deft-grove/ship-canary-0-0-18","deft-meadow/details-sidebar","fair-ember/canary-0-0-13","fair-ember/canary-0-0-14","fair-fjord/all-projects","feat/github-cache","feat/rebuild","fix/channel-credentials","glad-anchor/restore-message-queue","glad-ember/archive-inactive-channels","glad-fjord/project-identity","glad-orbit/channel-progress","glad-ridge/terminal-replay-input","hazy-anchor/github-row-actions","hazy-ember/channel-access-toggles","hazy-grove/all-projects-add-channel","local-project-setup/build-canary-0-0-20","local-project-setup/canary-0-0-20","local-project-setup/local-project-setup","main","mellow-ridge/canary-0-0-16","mellow-ridge/top-bar-drag-area","nimble-cedar/modal-top-offset","nimble-meadow/canary-0-0-15","remote-channel-load/build-canary-0-0-19","remote-channel-load/canary-0-0-19","remote-channel-load/fix-remote-channel-load","description","Ace: a collaborative coding environment on the team's own machines","owner","githubnext","section","head","empty","pins",[1037,1038,1039],"documents",{"_1032":1033,"_1034":1035},"code",{"_1029":1030,"_1031":94},"automations",{"_1027":93,"_1028":-5},"delivery",{"_1025":44,"_1026":-5},"9Rn62lcgXCFfpmCuooTjLxGyUf8","releases","applications","workflows","deployments","commits",215,"changes","counts",{"_1036":1035},"total",86,"issue",{"_1040":1031,"_858":1052,"_35":1031,"_1043":1053,"_885":1045,"_1046":26,"_1047":1045,"_1048":94},{"_1040":1049,"_858":1050,"_35":1049,"_1043":1051,"_885":1045,"_1046":26,"_1047":1045,"_1048":44},{"_1040":1041,"_858":1042,"_35":1041,"_1043":1044,"_885":1045,"_1046":26,"_1047":1045,"_1048":1035},"id","issues","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_1040":1031,"_858":1052,"_35":1031,"_1043":1097,"_885":1045,"_1046":26,"_1047":1045},{"_1040":1049,"_858":1050,"_35":1049,"_1043":1096,"_885":1045,"_1046":26,"_1047":1045},{"_1040":1041,"_858":1042,"_35":1041,"_1043":1095,"_885":1045,"_1046":26,"_1047":1045},{"_1040":1092,"_858":1093,"_35":1092,"_1043":1094,"_885":26,"_1046":26,"_1047":1045},{"_1040":1089,"_858":1090,"_35":1089,"_1043":1091,"_885":26,"_1046":26,"_1047":1045},{"_1040":1027,"_858":1087,"_35":1020,"_1043":1088,"_885":26,"_1046":26,"_1047":1045},{"_1040":1028,"_858":1084,"_35":1085,"_1043":1086,"_885":26,"_1046":26,"_1047":1045},{"_1040":1025,"_858":1082,"_35":1025,"_1043":1083,"_885":26,"_1046":26,"_1047":1045},{"_1040":1078,"_858":1079,"_35":1080,"_1043":1081,"_885":26,"_1046":26,"_1047":1045},{"_1040":1016,"_858":1076,"_35":1016,"_1043":1077,"_885":26,"_1046":26,"_1047":26},{"_1040":1073,"_858":1074,"_35":1073,"_1043":1075,"_885":26,"_1046":26,"_1047":26},{"_1040":1070,"_858":1071,"_35":1070,"_1043":1072,"_885":26,"_1046":26,"_1047":26},{"_1040":1067,"_858":1068,"_35":1067,"_1043":1069,"_885":26,"_1046":26,"_1047":26},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794434911852,"sidebar","expanded"]