[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","dinavinter","name","gallary","path","xstate-viewer/index.tsx","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/dinavinter/gallary/code/xstate-viewer/index.tsx","extension","id","f926d46a-6c5a-462e-8469-399de6561477","index.tsx","fileId","a179c950-7e1d-11f1-affc-1607ee4eb77e","parentId","a15fb290-7e1d-11f1-9a99-1607ee4eb77e","branchId","89dd9e90-891f-45a2-aa18-f3512f064f79","branchVersion",23,"latest",true,"createdAt",["D",1783883806610],"version",2,"fileType","http","content","/** @jsxImportSource npm:hono/jsx */\nimport { streamSSE } from \"npm:hono/streaming\";\nimport { createActor, type AnyStateMachine } from \"npm:xstate\";\nimport * as Y from \"https://esm.sh/yjs@13.6.31?target=esnext\";\nimport { changes, sharedDoc, yjs } from \"../hono.yjs.tsx\";\n\ntype StateDefinition = {\n id: string;\n events: string[];\n};\n\ntype StoredInstance = {\n id: string;\n element: Y.XmlElement;\n snapshot?: Record;\n state?: string;\n context?: Record;\n error?: string;\n};\n\nconst MachineBoard = ({ states, instances, base }: { states: StateDefinition[]; instances: StoredInstance[]; base: string }) => (\n

\n {states.map((state) => (\n

State

{state.id}

\n \n {instances.filter((instance) => instance.state === state.id).length} pins\n \n

\n {state.events.map((event) => {event})}\n {!state.events.length && Final state}\n

\n {instances.filter((instance) => instance.state === state.id).map((instance) => (\n \n {instance.id}\n \n ))}\n

\n ))}\n {instances.filter((instance) => instance.error).map((instance) => (\n

Migration required

{instance.id}

{instance.error}

\n ))}\n

\n);\n\nconst Cursor = ({ instance, state, context, events, base }: { instance: string; state: unknown; context: Record; events: string[]; base: string }) => (\n \n);\n\nconst handler = yjs.createApp();\n\nhandler.use(\"/:definition/*\", async (c, next) => {\n const definition = c.req.param(\"definition\");\n if (!/^[a-z0-9-]+$/i.test(definition)) return c.text(\"Invalid machine definition.\", 400);\n try {\n const module = await import(`./machines/${definition}.ts`);\n const machine = module.default as AnyStateMachine | undefined;\n if (!machine || typeof machine.getInitialSnapshot !== \"function\") return c.text(\"Machine module must default-export an XState machine.\", 422);\n const fragment = sharedDoc().getXmlFragment(`xstate-machine:${definition}`);\n const definitionElement = new Y.XmlElement(\"machine\");\n definitionElement.setAttribute(\"id\", machine.id);\n definitionElement.setAttribute(\"initial\", String(machine.config.initial ?? \"\"));\n for (const [stateId, stateConfig] of Object.entries(machine.config.states ?? {})) {\n const stateElement = new Y.XmlElement(\"state\");\n stateElement.setAttribute(\"id\", stateId);\n for (const event of Object.keys((stateConfig as { on?: Record }).on ?? {})) {\n const eventElement = new Y.XmlElement(\"event\");\n eventElement.setAttribute(\"type\", event);\n stateElement.push([eventElement]);\n }\n definitionElement.push([stateElement]);\n }\n const currentDefinition = fragment.toArray().find((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"machine\");\n if (!currentDefinition || currentDefinition.toString() !== definitionElement.toString()) {\n fragment.doc?.transact(() => {\n if (currentDefinition) fragment.delete(fragment.toArray().indexOf(currentDefinition), 1);\n fragment.insert(0, [definitionElement]);\n }, \"xstate-definition-sync\");\n }\n c.set(\"machine\" as never, machine as never);\n c.set(\"fragment\" as never, fragment as never);\n await next();\n } catch {\n return c.text(`Machine definition ${definition} was not found.`, 404);\n }\n});\n\nhandler.get(\"/:definition\", (c) => {\n const definition = c.req.param(\"definition\");\n const machine = c.get(\"machine\" as never) as AnyStateMachine;\n const fragment = c.get(\"fragment\" as never) as Y.XmlFragment;\n const states: StateDefinition[] = fragment.toArray().find((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"machine\")?.toArray().filter((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"state\").map((state) => ({ id: state.getAttribute(\"id\") ?? \"\", events: state.toArray().filter((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"event\").map((event) => event.getAttribute(\"type\") ?? \"\") })) ?? [];\n const instances: StoredInstance[] = fragment.toArray().filter((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"instance\").map((element) => {\n const id = element.getAttribute(\"id\") ?? \"\";\n try {\n const snapshot = JSON.parse(element.getAttribute(\"snapshot\") ?? \"{}\") as Record;\n createActor(machine, { snapshot: snapshot as never }).start().stop();\n return { id, element, snapshot, state: typeof snapshot.value === \"string\" ? snapshot.value : JSON.stringify(snapshot.value), context: (snapshot.context ?? {}) as Record };\n } catch { return { id, element, error: \"The saved snapshot cannot be restored by the current TypeScript machine.\" }; }\n });\n const base = `/xstate-viewer/${encodeURIComponent(definition)}`;\n return c.render(\n

TypeScript XState machine

{machine.id}

Definition mirrored to Y.XmlFragment · snapshots persisted generically

\n \n

,\n );\n});\n\nhandler.get(\"/:definition/view\", (c) => {\n const fragment = c.get(\"fragment\" as never) as Y.XmlFragment;\n const definition = c.req.param(\"definition\");\n const machineElement = fragment.toArray().find((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"machine\");\n const states: StateDefinition[] = machineElement?.toArray().filter((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"state\").map((state) => ({ id: state.getAttribute(\"id\") ?? \"\", events: state.toArray().filter((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"event\").map((event) => event.getAttribute(\"type\") ?? \"\") })) ?? [];\n const instances: StoredInstance[] = fragment.toArray().filter((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"instance\").map((element) => { try { const snapshot = JSON.parse(element.getAttribute(\"snapshot\") ?? \"{}\"); return { id: element.getAttribute(\"id\") ?? \"\", element, snapshot, state: typeof snapshot.value === \"string\" ? snapshot.value : JSON.stringify(snapshot.value), context: snapshot.context ?? {} }; } catch { return { id: element.getAttribute(\"id\") ?? \"\", element, error: \"Invalid persisted snapshot.\" }; } });\n return c.render();\n});\n\nhandler.post(\"/:definition/instances\", async (c) => {\n const machine = c.get(\"machine\" as never) as AnyStateMachine;\n const fragment = c.get(\"fragment\" as never) as Y.XmlFragment;\n const body = await c.req.parseBody();\n const id = String(body.instance ?? \"\").trim();\n if (!id) return c.text(\"Instance ID is required.\", 400);\n if (fragment.toArray().some((node) => node instanceof Y.XmlElement && node.nodeName === \"instance\" && node.getAttribute(\"id\") === id)) return c.text(`Instance ${id} already exists.`, 409);\n const input = Object.fromEntries(Object.entries(body).filter(([key, value]) => key !== \"instance\" && String(value).length));\n const actor = createActor(machine, { input });\n actor.start();\n const persisted = actor.getPersistedSnapshot();\n actor.stop();\n const element = new Y.XmlElement(\"instance\");\n element.setAttribute(\"id\", id);\n element.setAttribute(\"snapshot\", JSON.stringify(persisted));\n fragment.doc?.transact(() => fragment.push([element]), \"xstate-create-instance\");\n c.header(\"HX-Trigger\", JSON.stringify({ \"xstate-instance-changed\": { instance: id } }));\n return c.redirect(`/xstate-viewer/${encodeURIComponent(c.req.param(\"definition\"))}/view`, 303);\n});\n\nhandler.get(\"/:definition/:instance/cursor\", (c) => {\n const machine = c.get(\"machine\" as never) as AnyStateMachine;\n const fragment = c.get(\"fragment\" as never) as Y.XmlFragment;\n const id = c.req.param(\"instance\");\n const element = fragment.toArray().find((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"instance\" && node.getAttribute(\"id\") === id);\n if (!element) return c.text(\"Instance not found.\", 404);\n try {\n const actor = createActor(machine, { snapshot: JSON.parse(element.getAttribute(\"snapshot\") ?? \"{}\") as never });\n actor.start();\n const snapshot = actor.getSnapshot();\n const events = [...new Set(snapshot._nodes.flatMap((node) => node.ownEvents.map(String)))];\n actor.stop();\n return c.render(} events={events} base={`/xstate-viewer/${encodeURIComponent(c.req.param(\"definition\"))}`} />);\n } catch { return c.text(\"This snapshot requires migration before it can be restored.\", 409); }\n});\n\nhandler.post(\"/:definition/:instance\", async (c) => {\n const machine = c.get(\"machine\" as never) as AnyStateMachine;\n const fragment = c.get(\"fragment\" as never) as Y.XmlFragment;\n const id = c.req.param(\"instance\");\n const element = fragment.toArray().find((node): node is Y.XmlElement => node instanceof Y.XmlElement && node.nodeName === \"instance\" && node.getAttribute(\"id\") === id);\n if (!element) return c.text(\"Instance not found.\", 404);\n try {\n const body = await c.req.parseBody();\n const type = String(body.event ?? \"\");\n const actor = createActor(machine, { snapshot: JSON.parse(element.getAttribute(\"snapshot\") ?? \"{}\") as never });\n actor.start();\n actor.send({ type, ...Object.fromEntries(Object.entries(body).filter(([key]) => key !== \"event\")) });\n const persisted = actor.getPersistedSnapshot();\n actor.stop();\n fragment.doc?.transact(() => element.setAttribute(\"snapshot\", JSON.stringify(persisted)), \"xstate-send-event\");\n c.header(\"HX-Trigger\", JSON.stringify({ \"xstate-instance-changed\": { instance: id } }));\n return c.redirect(`/xstate-viewer/${encodeURIComponent(c.req.param(\"definition\"))}/${encodeURIComponent(id)}/cursor`, 303);\n } catch { return c.text(\"The event could not be applied to this actor snapshot.\", 409); }\n});\n\nhandler.get(\"/:definition/stream\", (c) => {\n const fragment = c.get(\"fragment\" as never) as Y.XmlFragment;\n return streamSSE(c, async (stream) => {\n for await (const _ of changes(fragment, c.req.raw.signal)) await stream.writeSSE({ event: \"xstate-machine-changed\", data: \"{}\" });\n });\n});\n\nexport { handler };\n\nexport default yjs.createApp().get(\"/\", (c) => c.redirect(\"/demo\")).route(\"/\", handler).fetch;\n","deleted",false,"label",[47,24],"xstate-viewer","50c582a3-a1a6-4c6c-8677-8613bbc316ef",["D",1783599528265],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Component gallery: headless Hono SSR + htmx + Yjs","imageUrl","userId","6d45e71e-9df4-45e8-82ab-e09c45bfc5a1","pinnedFileId","b1d7da38-7b90-11f1-af08-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","b636164b-34c9-4e0c-9d39-dd3dc6f25436","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_99":-5,"_100":101,"_58":59,"_102":103,"_104":44},"branch",{"_37":89,"_11":90,"_22":30,"_91":48,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",45,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycVgxSUNRd1V1VDlqTnNmYUh6MDA0VW1ldlMifQ","tier","pro","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":44,"_146":44,"_147":44,"_148":34,"_149":-5,"_150":-7,"_151":-7,"_152":66,"_153":44,"_154":44,"_155":-5,"_156":44,"_157":44,"_158":44,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]