[{"_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","kfieseler","name","ndx-parts-dev","path","_ctr_backfill.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/kfieseler/ndx-parts-dev/code/_ctr_backfill.ts","extension","id","1db93014-5175-4184-9953-e0ab544fa78c","fileId","285bb052-9e6f-11f1-ad46-1607ee4eb77e","parentId","branchId","1ba53fed-b2e4-413d-8a29-62afbe01b059","branchVersion",2464,"latest",true,"createdAt",["D",1787686191252],"version",6,"fileType","interval","content","// TEMP INTERVAL — backfill idle/fuel/hours counter history into fl_asset_snap\n// from Tenna /v1/trips cumulative counters (Kaden 8/22: \"can we use past data\n// to feed it\"). Trips carry total_duration_cum (engine-hours meter),\n// total_idle_duration_cum (idle-hours meter) and total_fuel_usage_cum (liters)\n// at every trip. For each date D the \"5 AM value\" = counters of the last trip\n// ending before D 05:00 LA (12:00Z in PDT) — same convention the real 5 AM\n// snapshots use. Existing snapshot rows only get NULL columns filled\n// (COALESCE); missing (date, unit) rows are INSERT OR IGNOREd with no site\n// fields, so nothing about today's flow changes. idle_fuel_l is NOT backfilled\n// (trips carry no counter for it; a synthetic one would break deltas across\n// the 8/22 boundary).\n// DONE 8/25/2026 — fl_ctr_bf is 52 of 52. The schedule was still firing every\n// 15 minutes (~96 times a day) long after the work finished. Each firing was\n// cheap — seed() returns early and todo comes back empty, so it made no Tenna\n// calls — but it was 96 pointless invocations a day and 96 lines of log noise\n// hiding anything real. Parked on a yearly cron rather than deleted, because\n// the trip-counter -> 5 AM-snapshot mapping in backfillUnit() is the only\n// worked example we have of reading cumulative counters out of /v1/trips, and\n// that is worth keeping. Safe to delete once that lives somewhere else.\n//\n// To run it again: set the interval back to */15 * * * * and it picks up any\n// fl_ctr_bf row with done = 0.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { rows } from \"./core.ts\";\n\nconst KEY = Deno.env.get(\"TENNA_KEY\") ?? \"\";\nconst FROM = \"2026-06-01\"; // backfill floor\nconst UNITS_PER_RUN = 6;\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\nasync function seed() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS fl_ctr_bf (unit TEXT PRIMARY KEY, uuid TEXT, done INTEGER DEFAULT 0, days INTEGER, at TEXT)`);\n const n = rows(await sqlite.execute(\"SELECT COUNT(*) c FROM fl_ctr_bf\"))[0];\n if (Number(n.c) > 0) return;\n // which fleet units report counters at all (live pull is already normalized)\n const { pullAssetsFull } = await import(\"./fuel_api.ts\");\n const pull = await pullAssetsFull();\n const fleet = new Set(rows(await sqlite.execute(\"SELECT unit FROM fl_fleet_def\")).map((r: any) => String(r.unit)));\n const want = new Set();\n for (const a of (pull.assets || [])) {\n const u = String(a.unit ?? \"\");\n if (fleet.has(u) && ((a as any).idle != null || (a as any).fuel_l != null)) want.add(u);\n }\n console.log(\"want:\", want.size, \"units with counters\");\n // UUIDs from the read API\n const ids: Record = {};\n for (let off = 0; off < 600; off += 100) {\n const r = await fetch(\"https://api.tenna.com/v1/assets?limit=100&offset=\" + off, { headers: { Authorization: \"Bearer \" + KEY } });\n if (!r.ok) { console.log(\"assets page @\" + off + \" -> \" + r.status); await sleep(1500); continue; }\n const j = await r.json();\n const res = j.results ?? [];\n if (off === 0 && res.length) console.log(\"asset row keys sample:\", JSON.stringify(Object.keys(res[0]).slice(0, 12)));\n for (const a of res) {\n const u = String(a.fleet ?? a.asset_fleet ?? \"\");\n if (want.has(u)) ids[u] = String(a.asset_id ?? \"\");\n }\n if (res.length < 100) break;\n await sleep(300);\n }\n for (const u of want) {\n if (ids[u]) {\n await sqlite.execute({ sql: \"INSERT OR IGNORE INTO fl_ctr_bf (unit, uuid, done) VALUES (?, ?, 0)\", args: [u, ids[u]] });\n }\n }\n console.log(\"seeded\", Object.keys(ids).length, \"counter units for backfill\");\n}\n\nasync function backfillUnit(u: string, uuid: string): Promise {\n // pull trips desc until we pass the floor\n const trips: { end: number; h: number | null; i: number | null; f: number | null }[] = [];\n const floorMs = Date.parse(FROM + \"T00:00:00Z\") - 86400000;\n for (let page = 0; page < 20; page++) {\n let r: Response | null = null;\n for (let tryN = 0; tryN < 3; tryN++) {\n r = await fetch(\n \"https://api.tenna.com/v1/trips?asset_id=\" + uuid + \"&sort=-start_date&limit=100&offset=\" + page * 100,\n { headers: { Authorization: \"Bearer \" + KEY } },\n );\n if (r.status !== 429) break;\n await sleep(2500 + tryN * 2500); // back off through the 5 req/s wall\n }\n if (!r || !r.ok) {\n console.log(u, \"trips page\", page, \"->\", r ? r.status : \"no response\");\n // a failed FIRST page means we know nothing — signal retry-next-firing\n if (page === 0) return -1;\n break;\n }\n const j = await r.json();\n const res = j.results ?? [];\n let past = false;\n for (const t of res) {\n const end = Date.parse(String(t.end_date ?? t.start_date));\n if (isNaN(end)) continue;\n trips.push({\n end,\n h: t.total_duration_cum != null ? Number(t.total_duration_cum) : null,\n i: t.total_idle_duration_cum != null ? Number(t.total_idle_duration_cum) : null,\n f: t.total_fuel_usage_cum != null ? Number(t.total_fuel_usage_cum) : null,\n });\n if (end < floorMs) past = true;\n }\n if (past || res.length < 100) break;\n await sleep(320);\n }\n if (!trips.length) return 0;\n trips.sort((a, b) => a.end - b.end); // asc\n // for each date, the last trip before D 05:00 LA (12:00Z in PDT)\n let wrote = 0;\n const start = new Date(Date.parse(FROM + \"T12:00:00Z\"));\n const stop = Date.parse(\"2026-08-22T12:00:00Z\");\n let ti = 0;\n let last: { h: number | null; i: number | null; f: number | null } | null = null;\n for (let ms = start.getTime(); ms <= stop; ms += 86400000) {\n while (ti < trips.length && trips[ti].end < ms) { last = trips[ti]; ti++; }\n if (!last || (last.i == null && last.f == null)) continue;\n const d = new Date(ms - 86400000 * 0).toISOString().slice(0, 10); // ms IS D 12:00Z → date D\n const args = [last.i, last.f, last.h, d, u];\n const upd = await sqlite.execute({\n sql: \"UPDATE fl_asset_snap SET idle = COALESCE(idle, ?), fuel_l = COALESCE(fuel_l, ?), hours = COALESCE(hours, ?) WHERE date = ? AND unit = ?\",\n args,\n });\n if ((upd as any).rowsAffected === 0) {\n await sqlite.execute({\n sql: \"INSERT OR IGNORE INTO fl_asset_snap (date, unit, name, hours, idle, fuel_l) VALUES (?, ?, '', ?, ?, ?)\",\n args: [d, u, last.h, last.i, last.f],\n });\n }\n wrote++;\n }\n return wrote;\n}\n\nasync function main() {\n await seed();\n const todo = rows(await sqlite.execute(\"SELECT unit, uuid FROM fl_ctr_bf WHERE done = 0 LIMIT \" + UNITS_PER_RUN));\n if (!todo.length) {\n console.log(\"ctr backfill complete — delete this val\");\n return;\n }\n for (const t of todo) {\n try {\n const n = await backfillUnit(String(t.unit), String(t.uuid));\n if (n < 0) {\n console.log(String(t.unit), \"rate-limited on first page — will retry next firing\");\n } else {\n await sqlite.execute({ sql: \"UPDATE fl_ctr_bf SET done = 1, days = ?, at = ? WHERE unit = ?\", args: [n, new Date().toISOString(), String(t.unit)] });\n console.log(String(t.unit), \"backfilled\", n, \"days\");\n }\n } catch (e) {\n console.log(String(t.unit), \"FAILED:\", String(e).slice(0, 120));\n }\n await sleep(700);\n }\n const left = rows(await sqlite.execute(\"SELECT COUNT(*) c FROM fl_ctr_bf WHERE done = 0\"))[0];\n console.log(Number(left.c), \"units left\");\n}\nexport default async function () {\n await main();\n}\n","deleted",false,"label",[14],"1730b37d-28eb-4a6b-8ba7-7294e47bbdb7",["D",1785517935233],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","DEV copy of NDX Parts — staging. Writes to TEST board.","imageUrl","userId","ab88c973-4988-481a-90fe-82231ca2dbda","pinnedFileId","ffd44ea0-8d02-11f1-95b0-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fb4e5-7efe-7110-bc8f-c886bb63dd3f","tursoName","1730b37d28eb4a6b8ba77294e47bbdb7","tursoHostname","1730b37d28eb4a6b8ba77294e47bbdb7-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789452068287],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":100},"org",{"_9":10,"_99":100,"_101":100,"_55":56,"_102":103,"_104":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",2869,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","pro","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_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"]