[{"_1":2,"_184":-5,"_185":-5},"loaderData",{"_3":4,"_95":96},"root",{"_5":6,"_36":37,"_68":69},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","3dfcd76250bcea90f57c8069f4d023cda8cd3097","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_70":71},"__internal_clerk_state",{"_72":73,"_74":47,"_75":76,"_77":76,"_78":20,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":20,"_94":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_85":20,"_19":20,"_86":76,"_87":88,"_89":76,"_90":47,"_91":20,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_97":98,"_99":100,"_101":102,"_103":104,"_158":159,"_181":182,"_183":-5},"handle","greenpt","name","office-window","path","flows/energy-question/graph.ts","project",{"_105":106,"_99":100,"_107":108,"_109":-5,"_110":20,"_111":112,"_113":114,"_115":-5,"_12":116,"_117":118,"_119":20,"_120":-5,"_121":-5,"_122":33,"_14":123,"_124":-5,"_125":-5,"_126":-5,"_127":-5,"_128":129,"_130":129,"_131":132,"_133":132,"_134":132,"_135":129,"_136":129,"_23":137,"_139":140,"_144":145,"_157":20},"id","aa4ea4f2-0cb6-11f1-8b14-42dde27851f2","createdAt",["D",1771411410564],"deletedAt","legacyEnvVars","privacy","public","description","Starter template with client-side React & Hono server","imageUrl","019bfe98-75fd-713b-83d5-edcffcda6af5","pinnedFileId","019c7059-0ed3-724f-869d-77bad99efb88","pinPreview","pinMigrated","screenshotVersion","likeCount","019bfe9a-421b-7083-aaed-77cdd02b9cc1","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_97":98,"_138":76},"profileImageUrl","org",{"_97":98,"_141":76,"_12":-5,"_142":143},"avatar","tier","free","branch",{"_146":147,"_99":45,"_105":148,"_149":106,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":100,"_156":98},"version",178,"aa53671c-0cb6-11f1-8b14-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_105":160,"_99":161,"_162":163,"_164":165,"_166":148,"_167":147,"_168":169,"_107":170,"_146":171,"_172":173,"_174":175,"_176":20,"_177":-5,"_101":178},"048be838-1713-11f1-90bd-42dde27851f2","graph.ts","fileId","e17068d8-1712-11f1-9378-42dde27851f2","parentId","b01d20be-1712-11f1-84b7-42dde27851f2","branchId","branchVersion","latest",true,["D",1772550587319],1,"fileType","script","content","import { Annotation, StateGraph, START, END } from \"npm:@langchain/langgraph\";\nimport { Langfuse } from \"npm:langfuse\";\nimport { getLangfuseCredentials } from \"../../backend/langfuse.ts\";\n\nimport { presentQuestionNode } from \"./nodes/present-question.ts\";\nimport { collectAnswerNode } from \"./nodes/collect-answer.ts\";\nimport { collectEmailNode } from \"./nodes/collect-email.ts\";\nimport { checkExistingSubmissionNode } from \"./nodes/check-existing.ts\";\nimport { storeSubmissionNode } from \"./nodes/store-submission.ts\";\nimport { sendConfirmationNode } from \"./nodes/send-confirmation.ts\";\n\n// ── Re-export types for nodes ──────────────────────────────────────────\n\nexport type LangfuseTrace = ReturnType;\n\n// ── Chat message (plain, serializable) ─────────────────────────────────\n\ninterface ChatMessage {\n role: \"user\" | \"assistant\";\n content: string;\n}\n\n// ── Graph state ────────────────────────────────────────────────────────\n\nconst EQGraphState = Annotation.Root({\n // Routing — which step this invocation enters on\n step: Annotation({\n reducer: (_: string, update: string) => update,\n default: () => \"present\",\n }),\n userInput: Annotation({\n reducer: (_: string, update: string) => update,\n default: () => \"\",\n }),\n\n // Question data\n week: Annotation({\n reducer: (_: number, update: number) => update,\n default: () => 0,\n }),\n questionText: Annotation({\n reducer: (_: string, update: string) => update,\n default: () => \"\",\n }),\n\n // Answer & email\n rawAnswer: Annotation({\n reducer: (_: string, update: string) => update,\n default: () => \"\",\n }),\n email: Annotation({\n reducer: (_: string, update: string) => update,\n default: () => \"\",\n }),\n emailRetryCount: Annotation({\n reducer: (_: number, update: number) => update,\n default: () => 0,\n }),\n\n // Router outcomes\n emailOutcome: Annotation({\n reducer: (_: string, update: string) => update,\n default: () => \"\",\n }),\n existingOutcome: Annotation({\n reducer: (_: string, update: string) => update,\n default: () => \"\",\n }),\n isUpdate: Annotation({\n reducer: (_: boolean, update: boolean) => update,\n default: () => false,\n }),\n\n // What the caller should advance to next (collect_answer | collect_email | done)\n nextStep: Annotation({\n reducer: (_: string, update: string) => update,\n default: () => \"\",\n }),\n\n // Messages produced by this invocation (returned to the frontend)\n responseMessages: Annotation({\n reducer: (curr: ChatMessage[], update: ChatMessage[]) => [...curr, ...update],\n default: () => [],\n }),\n});\n\nexport type EQGraphStateType = typeof EQGraphState.State;\n\n// ── Routers ────────────────────────────────────────────────────────────\n\nfunction stepRouter(state: EQGraphStateType): string {\n switch (state.step) {\n case \"present\":\n return \"present\";\n case \"collect_answer\":\n return \"collect_answer\";\n case \"collect_email\":\n return \"collect_email\";\n default:\n return \"present\";\n }\n}\n\nfunction emailRouter(state: EQGraphStateType): string {\n return state.emailOutcome; // \"valid\" | \"invalid\" | \"max_retries\" | \"refused\"\n}\n\nfunction existingRouter(state: EQGraphStateType): string {\n return state.existingOutcome; // \"new\" | \"duplicate\"\n}\n\n// ── Graph definition ───────────────────────────────────────────────────\n\nfunction buildEQGraph() {\n const workflow = new StateGraph(EQGraphState)\n .addNode(\"present_question\", presentQuestionNode)\n .addNode(\"collect_answer\", collectAnswerNode)\n .addNode(\"collect_email\", collectEmailNode)\n .addNode(\"check_existing\", checkExistingSubmissionNode)\n .addNode(\"store_submission\", storeSubmissionNode)\n .addNode(\"send_confirmation\", sendConfirmationNode)\n\n .addConditionalEdges(START, stepRouter, {\n present: \"present_question\",\n collect_answer: \"collect_answer\",\n collect_email: \"collect_email\",\n })\n\n .addEdge(\"present_question\", END)\n .addEdge(\"collect_answer\", END)\n\n .addConditionalEdges(\"collect_email\", emailRouter, {\n valid: \"check_existing\",\n invalid: END,\n max_retries: END,\n refused: END,\n })\n\n .addConditionalEdges(\"check_existing\", existingRouter, {\n new: \"store_submission\",\n duplicate: \"store_submission\",\n })\n\n .addEdge(\"store_submission\", \"send_confirmation\")\n .addEdge(\"send_confirmation\", END);\n\n return workflow.compile();\n}\n\n// ── Public API (serializable flow state for the frontend) ──────────────\n\nexport type EQFlowStep = \"collect_answer\" | \"collect_email\" | \"done\";\n\nexport interface EQFlowState {\n step: EQFlowStep;\n week: number;\n questionText: string;\n rawAnswer?: string;\n email?: string;\n emailRetryCount?: number;\n}\n\ninterface EQStartResult {\n active: true;\n state: EQFlowState;\n messages: ChatMessage[];\n}\n\ninterface EQInactiveResult {\n active: false;\n}\n\nexport interface EQStepResult {\n state: EQFlowState;\n messages: ChatMessage[];\n}\n\n// ── Entry points ───────────────────────────────────────────────────────\n\nexport async function runEQStart(): Promise {\n const langfuse = new Langfuse(getLangfuseCredentials());\n const trace = langfuse.trace({\n name: \"eq:start\",\n metadata: { runtime: \"val-town\", flow: \"energy-question\" },\n });\n\n const graph = buildEQGraph();\n\n try {\n const result = await graph.invoke(\n { step: \"present\" },\n { configurable: { langfuseTrace: trace } },\n );\n\n if (result.responseMessages.length === 0) {\n trace.update({ output: { active: false } });\n return { active: false };\n }\n\n const flowState: EQFlowState = {\n step: result.nextStep as EQFlowStep,\n week: result.week,\n questionText: result.questionText,\n };\n\n trace.update({ output: { active: true, week: result.week } });\n\n return {\n active: true,\n state: flowState,\n messages: result.responseMessages,\n };\n } finally {\n await langfuse.flushAsync();\n }\n}\n\nexport async function runEQRespond(\n flowState: EQFlowState,\n userInput: string,\n): Promise {\n const langfuse = new Langfuse(getLangfuseCredentials());\n const trace = langfuse.trace({\n name: `eq:${flowState.step}`,\n input: { userInput, flowState },\n metadata: {\n runtime: \"val-town\",\n flow: \"energy-question\",\n week: flowState.week,\n step: flowState.step,\n },\n });\n\n const graph = buildEQGraph();\n\n try {\n const result = await graph.invoke(\n {\n step: flowState.step === \"collect_answer\" ? \"collect_answer\" : \"collect_email\",\n userInput,\n week: flowState.week,\n questionText: flowState.questionText,\n rawAnswer: flowState.rawAnswer ?? \"\",\n email: flowState.email ?? \"\",\n emailRetryCount: flowState.emailRetryCount ?? 0,\n },\n { configurable: { langfuseTrace: trace } },\n );\n\n const nextStep = (result.nextStep || \"done\") as EQFlowStep;\n\n const nextFlowState: EQFlowState = {\n step: nextStep,\n week: result.week,\n questionText: result.questionText,\n rawAnswer: result.rawAnswer || flowState.rawAnswer,\n email: result.email || flowState.email,\n emailRetryCount: result.emailRetryCount,\n };\n\n trace.update({ output: { nextStep, messages: result.responseMessages } });\n\n return {\n state: nextFlowState,\n messages: result.responseMessages,\n };\n } finally {\n await langfuse.flushAsync();\n }\n}\n","deleted","label",[179,180,161],"flows","energy-question","permalink","https://www.val.town/x/greenpt/office-window/code/flows/energy-question/graph.ts","extension","actionData","errors"]