[{"_1":2,"_185":-5,"_186":-5},"loaderData",{"_3":4,"_96":97},"root",{"_5":6,"_37":38,"_69":70},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":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","isHigherTownieTier","ENV",{"_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":68},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","efeea19332d9bfe7de1049656877be9cb817c45f","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",{"_71":72},"__internal_clerk_state",{"_73":74,"_75":48,"_76":77,"_78":77,"_79":20,"_80":77,"_81":77,"_82":77,"_83":77,"_84":85,"_94":20,"_95":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",{"_86":20,"_19":20,"_87":77,"_88":89,"_90":77,"_91":48,"_92":20,"_93":77},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_98":99,"_100":101,"_102":103,"_104":105,"_162":163,"_182":183,"_184":-5},"handle","dcm31","name","yesno","path","pipeline.ts","project",{"_106":107,"_100":101,"_108":109,"_110":-5,"_111":20,"_112":113,"_114":115,"_116":-5,"_12":117,"_118":-5,"_119":20,"_120":-5,"_121":-5,"_122":33,"_14":123,"_124":125,"_126":127,"_128":129,"_130":-5,"_131":132,"_133":132,"_134":135,"_136":135,"_137":135,"_138":132,"_139":132,"_23":140,"_143":144,"_148":149,"_161":20},"id","4cb49016-ffb1-11f0-91be-42dde27851f2","createdAt",["D",1769979740966],"deletedAt","legacyEnvVars","privacy","unlisted","description","Yes/No question prototype","imageUrl","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","d663a026-6449-42f6-9156-1d4a2d64d38c","tursoName","4cb49016ffb111f091be42dde27851f2","tursoHostname","4cb49016ffb111f091be42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1776208856590],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_141":142},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/3e904faa-3764-4629-c475-f561a49b0000/square512","org",{"_98":99,"_145":142,"_12":117,"_146":147},"avatar","tier","pro","branch",{"_150":151,"_100":46,"_106":152,"_153":107,"_154":-5,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":101,"_160":99},"version",30,"4cb4e21e-ffb1-11f0-91be-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_106":164,"_100":103,"_165":166,"_167":-5,"_168":152,"_169":170,"_171":172,"_108":173,"_150":174,"_175":176,"_177":178,"_179":20,"_180":-5,"_102":181},"133b6e84-1b10-11f1-909f-42dde27851f2","fileId","36b99a0a-1027-11f1-bb28-42dde27851f2","parentId","branchId","branchVersion",26,"latest",true,["D",1772989128110],2,"fileType","script","content","/**\n * Pipeline state machine for the daily habit tracker.\n *\n * Each habit produces two steps: PREDICT → CONFIRM.\n * If skipPredict is set, the predict step auto-advances.\n * Steps are indexed sequentially across all habits:\n * Step 0: habit[0] predict\n * Step 1: habit[0] confirm\n * Step 2: habit[1] predict\n * Step 3: habit[1] confirm\n * ...\n *\n * State auto-resets when the day rolls over (7am São Paulo = 2am PST cutoff).\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { HABITS, type Habit } from \"./habits.ts\";\nimport { createPrediction, resolvePrediction } from \"./fatebook.ts\";\n\n// ────────────────────────────────────────────\n// Types\n// ────────────────────────────────────────────\n\nexport type StepType = \"predict\" | \"confirm\";\n\nexport interface HabitState {\n fatebookQid: string | null;\n predictedYes: boolean | null; // null = not answered yet\n confirmedYes: boolean | null;\n context: Record; // habit-specific data (e.g. { goal: 18 })\n}\n\nexport interface PipelineState {\n date: string; // YYYY-MM-DD (routine day, with 2am PST cutoff)\n stepIndex: number;\n habits: Record;\n responses: ResponseEntry[];\n}\n\nexport interface ResponseEntry {\n timestamp: number;\n question: string;\n answer: \"yes\" | \"no\";\n habitId: string;\n stepType: StepType;\n}\n\n// ────────────────────────────────────────────\n// Date helpers\n// ────────────────────────────────────────────\n\n/** Get today's date string with 2am PST (7am São Paulo) cutoff */\nexport function getToday(): string {\n const now = new Date();\n const brazil = new Date(now.toLocaleString(\"en-US\", { timeZone: \"America/Sao_Paulo\" }));\n if (brazil.getHours() < 7) brazil.setDate(brazil.getDate() - 1);\n return formatDate(brazil);\n}\n\nfunction formatDate(d: Date): string {\n const y = d.getFullYear();\n const m = String(d.getMonth() + 1).padStart(2, \"0\");\n const dd = String(d.getDate()).padStart(2, \"0\");\n return `${y}-${m}-${dd}`;\n}\n\n// ────────────────────────────────────────────\n// State persistence\n// ────────────────────────────────────────────\n\nconst STATE_KEY = \"yesno_pipeline_v2\";\n\nfunction freshState(date: string): PipelineState {\n const habits: Record = {};\n for (const h of HABITS) {\n habits[h.id] = {\n fatebookQid: null,\n predictedYes: null,\n confirmedYes: null,\n context: {},\n };\n }\n return { date, stepIndex: 0, habits, responses: [] };\n}\n\n/** Get current state, auto-resetting if the day has changed */\nexport async function getState(): Promise {\n const today = getToday();\n try {\n const stored = await blob.getJSON(STATE_KEY) as PipelineState;\n if (stored?.date === today && stored.habits) return stored;\n } catch { /* first run or corrupted */ }\n const state = freshState(today);\n await saveState(state);\n return state;\n}\n\n/** Get raw state without auto-reset (for cron to inspect yesterday's state) */\nexport async function getRawState(): Promise {\n try {\n return await blob.getJSON(STATE_KEY) as PipelineState;\n } catch {\n return null;\n }\n}\n\nexport async function saveState(state: PipelineState): Promise {\n await blob.setJSON(STATE_KEY, state);\n}\n\n// ────────────────────────────────────────────\n// Step navigation\n// ────────────────────────────────────────────\n\nexport function totalSteps(): number {\n return HABITS.length * 2;\n}\n\nexport function isDone(state: PipelineState): boolean {\n return state.stepIndex >= totalSteps();\n}\n\nexport function currentHabit(state: PipelineState): Habit | null {\n const idx = Math.floor(state.stepIndex / 2);\n return idx < HABITS.length ? HABITS[idx] : null;\n}\n\nexport function currentHabitState(state: PipelineState): HabitState | null {\n const habit = currentHabit(state);\n return habit ? state.habits[habit.id] : null;\n}\n\nexport function currentStepType(state: PipelineState): StepType {\n return state.stepIndex % 2 === 0 ? \"predict\" : \"confirm\";\n}\n\n// ────────────────────────────────────────────\n// Auto-advance: skip predict steps and auto-complete confirm steps\n// ────────────────────────────────────────────\n\n/**\n * Check if any steps can be auto-advanced and advance past them.\n * Called on every /question poll and after every /yes or /no.\n * Returns the (possibly advanced) state.\n */\nexport async function runAutoAdvance(state: PipelineState): Promise {\n while (!isDone(state)) {\n const habit = currentHabit(state)!;\n const stepType = currentStepType(state);\n\n // Auto-skip predict steps for skipPredict habits\n if (stepType === \"predict\" && habit.skipPredict) {\n const hs = state.habits[habit.id];\n const { context } = await habit.getPredictText();\n if (context) Object.assign(hs.context, context);\n\n // Log the auto-skip\n state.responses.push({\n timestamp: Date.now(),\n question: `[auto-skip] ${habit.label} predict`,\n answer: \"yes\",\n habitId: habit.id,\n stepType: \"predict\",\n });\n\n state.stepIndex++;\n await saveState(state);\n console.log(`Auto-skipped: ${habit.id} predict (skipPredict)`);\n continue;\n }\n\n // Auto-complete confirm steps if checkAutoComplete returns true\n if (stepType === \"confirm\" && habit.checkAutoComplete) {\n const done = await habit.checkAutoComplete();\n if (done) {\n const hs = state.habits[habit.id];\n hs.confirmedYes = true;\n\n // Resolve Fatebook prediction if one was created (and not skipFatebook)\n if (!habit.skipFatebook && hs.fatebookQid) {\n await resolvePrediction(hs.fatebookQid, \"YES\");\n }\n\n // Call onConfirmYes if defined\n if (habit.onConfirmYes) {\n try {\n await habit.onConfirmYes(hs.context);\n } catch (e) {\n console.error(`onConfirmYes failed for ${habit.id}:`, e);\n }\n }\n\n // Log the auto-advance\n state.responses.push({\n timestamp: Date.now(),\n question: `[auto] ${habit.label} confirmed`,\n answer: \"yes\",\n habitId: habit.id,\n stepType: \"confirm\",\n });\n\n state.stepIndex++;\n await saveState(state);\n console.log(`Auto-advanced: ${habit.id} confirm → YES`);\n continue; // check next step\n }\n }\n break; // no auto-advance possible\n }\n return state;\n}\n\n// ────────────────────────────────────────────\n// Core actions (called by /yes and /no handlers)\n// ────────────────────────────────────────────\n\n/**\n * Get the text for the current step's question.\n * Returns null if the pipeline is done for today.\n */\nexport async function getQuestionText(state: PipelineState): Promise {\n if (isDone(state)) return null;\n\n const habit = currentHabit(state)!;\n const stepType = currentStepType(state);\n\n if (stepType === \"predict\") {\n const { text } = await habit.getPredictText();\n return text;\n } else {\n const hs = state.habits[habit.id];\n return await habit.getConfirmText(hs.context);\n }\n}\n\n/**\n * Handle a yes/no answer for the current step.\n * Creates or resolves Fatebook predictions as appropriate.\n * Advances the pipeline and runs auto-advance.\n * Returns the updated state.\n */\nexport async function handleAnswer(\n state: PipelineState,\n answer: \"yes\" | \"no\",\n): Promise {\n if (isDone(state)) return state;\n\n const habit = currentHabit(state)!;\n const stepType = currentStepType(state);\n const hs = state.habits[habit.id];\n\n // Get question text for logging\n const questionText = await getQuestionText(state) || \"?\";\n\n if (stepType === \"predict\") {\n // PREDICT step: create Fatebook prediction (unless skipFatebook)\n const { context } = await habit.getPredictText();\n if (context) Object.assign(hs.context, context);\n\n hs.predictedYes = answer === \"yes\";\n\n if (!habit.skipFatebook) {\n const forecast = answer === \"yes\" ? habit.forecast : (1 - habit.forecast);\n const qid = await createPrediction(\n habit.getFatebookTitle(hs.context),\n state.date,\n forecast,\n habit.tags,\n );\n hs.fatebookQid = qid;\n }\n } else {\n // CONFIRM step: resolve Fatebook prediction + call onConfirmYes\n hs.confirmedYes = answer === \"yes\";\n\n if (!habit.skipFatebook && hs.fatebookQid) {\n await resolvePrediction(hs.fatebookQid, answer === \"yes\" ? \"YES\" : \"NO\");\n }\n\n // Call onConfirmYes callback\n if (answer === \"yes\" && habit.onConfirmYes) {\n try {\n await habit.onConfirmYes(hs.context);\n } catch (e) {\n console.error(`onConfirmYes failed for ${habit.id}:`, e);\n }\n }\n }\n\n // Log response\n state.responses.push({\n timestamp: Date.now(),\n question: questionText,\n answer,\n habitId: habit.id,\n stepType,\n });\n\n // Advance\n state.stepIndex++;\n await saveState(state);\n\n // Run auto-advance for subsequent steps\n state = await runAutoAdvance(state);\n\n return state;\n}\n\n// ────────────────────────────────────────────\n// Cron: auto-resolve stale predictions\n// ────────────────────────────────────────────\n\n/**\n * Called by the cron job. Resolves any predictions that were created\n * but never confirmed as NO (the person didn't complete the habit).\n * Should run after the day boundary (2am PST / 7am São Paulo).\n */\nexport async function autoResolveStale(): Promise {\n const raw = await getRawState();\n if (!raw) return [];\n\n const today = getToday();\n if (raw.date === today) return []; // still today's state, nothing to resolve\n\n const resolved: string[] = [];\n\n for (const habit of HABITS) {\n // Skip habits that manage their own Fatebook predictions\n if (habit.skipFatebook) continue;\n\n const hs = raw.habits[habit.id];\n if (!hs) continue;\n\n // If a prediction was created but never confirmed, check actual completion\n if (hs.fatebookQid && hs.confirmedYes === null) {\n let actuallyDone = false;\n if (habit.checkAutoComplete) {\n try {\n actuallyDone = await habit.checkAutoComplete();\n } catch (e) {\n console.error(`Auto-resolve check failed for ${habit.id}:`, e);\n }\n }\n\n const resolution = actuallyDone ? \"YES\" : \"NO\";\n const ok = await resolvePrediction(hs.fatebookQid, resolution);\n if (ok) {\n resolved.push(`${habit.id}: resolved ${hs.fatebookQid} as ${resolution}`);\n }\n }\n }\n\n return resolved;\n}\n","deleted","label",[103],"permalink","https://www.val.town/x/dcm31/yesno/code/pipeline.ts","extension","actionData","errors"]