[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_271":-5,"_274":275,"_276":277},"routes/shell",{"_40":41,"_270":-5,"_271":-5,"_272":273},"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","f6ace1266109c8bcc91bfdbda1eead693579efcd","path","apps/app/src/github-cache.ts","oid","440c40752034901981032be6858805429bf37c46","size",6273,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { useEffect, useSyncExternalStore } from \"react\";\n\nimport type { HostRequest } from \"@ace/host/protocol\";\n\nimport { host, onOpen } from \"./host\";\nimport type { AppProject } from \"./projects\";\n\ntype Request = Extract<\n\tHostRequest,\n\t{ op: \"project-repo\" | \"github-list\" | \"github-detail\" | \"github-files\" }\n>;\ntype Snapshot = { value?: unknown; error?: string; loading: boolean };\ntype Saved = { key: string; request: Request; value: unknown };\ntype Entry = {\n\tkey: string;\n\trequest: Request;\n\tsnapshot: Snapshot;\n\tchecked: number;\n\trunning?: Promise;\n\tlisteners: Set<() => void>;\n\tsubscribe: (listener: () => void) => () => void;\n\tread: () => Snapshot;\n};\n\nexport type Query = { value?: T; error?: string; loading: boolean; refresh: () => void };\n\nconst INTERVAL = 3 * 60 * 60 * 1000;\nconst EMPTY: Snapshot = { loading: true };\nconst cache = new Map();\nconst database = new Promise((resolve, reject) => {\n\tconst request = indexedDB.open(`ace:github:${host.url}`, 1);\n\trequest.addEventListener(\n\t\t\"upgradeneeded\",\n\t\t() => request.result.createObjectStore(\"queries\", { keyPath: \"key\" }),\n\t);\n\trequest.addEventListener(\"success\", () => {\n\t\trequest.result.addEventListener(\"versionchange\", () => request.result.close());\n\t\tresolve(request.result);\n\t});\n\trequest.addEventListener(\"error\", () => reject(request.error));\n}).catch(() => undefined);\n\n/** Storage failure leaves the shared memory cache usable. */\nasync function stored(\n\tmode: IDBTransactionMode,\n\toperation: (store: IDBObjectStore) => IDBRequest,\n): Promise {\n\ttry {\n\t\tconst db = await database;\n\t\tif (!db) return;\n\t\treturn await new Promise((resolve, reject) => {\n\t\t\tconst transaction = db.transaction(\"queries\", mode);\n\t\t\tconst request = operation(transaction.objectStore(\"queries\"));\n\t\t\ttransaction.addEventListener(\"complete\", () => resolve(request.result));\n\t\t\ttransaction.addEventListener(\"abort\", () => reject(transaction.error));\n\t\t\ttransaction.addEventListener(\"error\", () => reject(transaction.error));\n\t\t});\n\t} catch {\n\t\treturn undefined;\n\t}\n}\n\nfunction entry(request: Request): Entry {\n\tif (\"repo\" in request) request = { ...request, repo: request.repo.toLowerCase() };\n\tconst key = JSON.stringify(request, Object.keys(request).sort());\n\tconst existing = cache.get(key);\n\tif (existing) return existing;\n\tconst value: Entry = {\n\t\tkey,\n\t\trequest,\n\t\tsnapshot: EMPTY,\n\t\tchecked: 0,\n\t\tlisteners: new Set(),\n\t\tsubscribe(listener) {\n\t\t\tvalue.listeners.add(listener);\n\t\t\treturn () => void value.listeners.delete(listener);\n\t\t},\n\t\tread: () => value.snapshot,\n\t};\n\tcache.set(key, value);\n\treturn value;\n}\n\nfunction publish(value: Entry, snapshot: Snapshot) {\n\tvalue.snapshot = snapshot;\n\tfor (const listener of value.listeners) listener();\n}\n\nconst ready = stored(\"readonly\", (store) => store.getAll()).then((saved) => {\n\tfor (const value of saved || []) {\n\t\tpublish(entry(value.request), { value: value.value, loading: false });\n\t}\n});\n\nasync function load(value: Entry, force = false): Promise {\n\tawait ready;\n\tif (value.running) return value.running;\n\tif (host.status !== \"open\") return;\n\tif (!force && Date.now() - value.checked < INTERVAL) return;\n\tvalue.checked = Date.now();\n\tvalue.running = host.request(value.request).then(\n\t\t(result) => {\n\t\t\tpublish(value, { value: result, loading: false });\n\t\t\tvoid stored(\n\t\t\t\t\"readwrite\",\n\t\t\t\t(store) =>\n\t\t\t\t\tstore.put({ key: value.key, request: value.request, value: result } satisfies Saved),\n\t\t\t);\n\t\t},\n\t\t(error: Error) => {\n\t\t\tpublish(value, { ...value.snapshot, error: error.message, loading: false });\n\t\t},\n\t).finally(() => {\n\t\tvalue.running = undefined;\n\t});\n\tpublish(value, { ...value.snapshot, error: undefined, loading: true });\n\treturn value.running;\n}\n\nlet refreshing: Promise | undefined;\n\n/** Warm both pages without mounting them, and serialize background GitHub requests. */\nfunction refresh(force = false): Promise {\n\tif (refreshing) return refreshing;\n\trefreshing = (async () => {\n\t\tawait ready;\n\t\tfor (const value of cache.values()) {\n\t\t\tif (host.status !== \"open\") break;\n\t\t\tawait load(value, force);\n\t\t\tif (value.request.op !== \"project-repo\") continue;\n\t\t\tconst repo = value.snapshot.value as string | null | undefined;\n\t\t\tif (!repo) continue;\n\t\t\tfor (const kind of [\"issues\", \"prs\"] as const) {\n\t\t\t\tfor (const state of [\"open\", \"closed\", \"all\"] as const) {\n\t\t\t\t\tentry({ op: \"github-list\", repo, kind, state, search: \"\", limit: 50 });\n\t\t\t\t}\n\t\t\t}\n\t\t}\n\t})().finally(() => {\n\t\trefreshing = undefined;\n\t});\n\treturn refreshing;\n}\n\nexport function useGithubRefresh(projects: AppProject[]) {\n\tconst source = JSON.stringify(projects.map(({ host, path }) => ({\n\t\top: \"project-repo\",\n\t\thost,\n\t\tproject: path,\n\t})));\n\tuseEffect(() => {\n\t\tfor (const request of JSON.parse(source) as Request[]) entry(request);\n\t\tvoid refresh();\n\t}, [source]);\n\tuseEffect(() => {\n\t\tconst connected = () => {\n\t\t\tfor (const value of cache.values()) {\n\t\t\t\tif (value.snapshot.error) value.checked = 0;\n\t\t\t}\n\t\t\tvoid refresh();\n\t\t};\n\t\tconst wake = () => {\n\t\t\tif (document.visibilityState === \"visible\") void refresh();\n\t\t};\n\t\tconst stop = onOpen(connected);\n\t\tconst timer = setInterval(() => void refresh(true), INTERVAL);\n\t\twindow.addEventListener(\"focus\", wake);\n\t\tdocument.addEventListener(\"visibilitychange\", wake);\n\t\tif (host.status === \"open\") connected();\n\t\treturn () => {\n\t\t\tstop();\n\t\t\tclearInterval(timer);\n\t\t\twindow.removeEventListener(\"focus\", wake);\n\t\t\tdocument.removeEventListener(\"visibilitychange\", wake);\n\t\t};\n\t}, []);\n}\n\nconst inactive = { subscribe: () => () => {}, read: () => EMPTY };\n\nexport function useGithub(request?: Request): Query {\n\tconst value = request ? entry(request) : undefined;\n\tconst store = value || inactive;\n\tconst snapshot = useSyncExternalStore(store.subscribe, store.read);\n\tconst status = useSyncExternalStore(host.subscribe, () => host.status);\n\tuseEffect(() => {\n\t\tif (value && status === \"open\") void load(value);\n\t}, [value, status]);\n\treturn {\n\t\tvalue: snapshot.value as T | undefined,\n\t\terror: !value ? undefined : status !== \"open\"\n\t\t\t? \"Connect to your host to refresh GitHub.\"\n\t\t\t: snapshot.error,\n\t\tloading: !!value && status === \"open\" && snapshot.loading,\n\t\trefresh: () => {\n\t\t\tif (value) void load(value, true);\n\t\t},\n\t};\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/ace2","repoId","938fe4cd-5320-4e4f-ac7c-87d4dad8490c","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[226,227,228,229,230,231,232,233,234,235,236,237,238],"navigation",{"_54":55,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193},"sources",[],"viewer","meta",{"_174":175,"_176":177,"_178":179,"_42":31,"_180":166,"_181":31,"_48":49,"_50":49},"branches",[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,131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159,160,161,162,163,164,165,166,167,168,169,170,171,172,173],"tags",[69,70,71,72,73,74,75,76,77,78,79,80],"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",[208,209,210],"documents",{"_203":204,"_205":206},"code",{"_199":200,"_201":202},"automations",{"_196":197,"_198":-5},"delivery",{"_194":49,"_195":-5},"tag","9Rn62lcgXCFfpmCuooTjLxGyUf8","releases","applications","workflows",2,"deployments","commits",215,"changes",1,"counts",{"_207":206},"total",86,"issue",{"_211":201,"_213":224,"_15":201,"_215":225,"_52":217,"_218":31,"_219":217,"_220":202},{"_211":221,"_213":222,"_15":221,"_215":223,"_52":217,"_218":31,"_219":217,"_220":49},{"_211":212,"_213":214,"_15":212,"_215":216,"_52":217,"_218":31,"_219":217,"_220":206},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_211":201,"_213":224,"_15":201,"_215":269,"_52":217,"_218":31,"_219":217},{"_211":221,"_213":222,"_15":221,"_215":268,"_52":217,"_218":31,"_219":217},{"_211":212,"_213":214,"_15":212,"_215":267,"_52":217,"_218":31,"_219":217},{"_211":264,"_213":265,"_15":264,"_215":266,"_52":31,"_218":31,"_219":217},{"_211":261,"_213":262,"_15":261,"_215":263,"_52":31,"_218":31,"_219":217},{"_211":196,"_213":259,"_15":188,"_215":260,"_52":31,"_218":31,"_219":217},{"_211":198,"_213":256,"_15":257,"_215":258,"_52":31,"_218":31,"_219":217},{"_211":194,"_213":254,"_15":194,"_215":255,"_52":31,"_218":31,"_219":217},{"_211":250,"_213":251,"_15":252,"_215":253,"_52":31,"_218":31,"_219":217},{"_211":184,"_213":248,"_15":184,"_215":249,"_52":31,"_218":31,"_219":31},{"_211":245,"_213":246,"_15":245,"_215":247,"_52":31,"_218":31,"_219":31},{"_211":242,"_213":243,"_15":242,"_215":244,"_52":31,"_218":31,"_219":31},{"_211":239,"_213":240,"_15":239,"_215":241,"_52":31,"_218":31,"_219":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794438429404,"sidebar","expanded"]