[{"_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","fuel_burn.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/fuel_burn.ts","extension","id","ece42d8c-2b4a-480e-8ffd-5574f410a012","fileId","abaad222-9b4e-11f1-8b84-1607ee4eb77e","parentId","branchId","1ba53fed-b2e4-413d-8a29-62afbe01b059","branchVersion",2477,"latest",true,"createdAt",["D",1787694611865],"version",36,"fileType","script","content","// THE BURN MODEL — how fast each machine drinks, and how full it is now.\n//\n// This is what turns \"last fueled 3 days ago\" into \"~41 gal to fill it, about\n// 38% left\". It is READ-ONLY over Tenna and writes only our own fl_burn table.\n//\n// ---------------------------------------------------------------------------\n// WHERE THE DATA COMES FROM\n//\n// Tenna's /v1/fuel-entries carries the meter reading AT the fill\n// (fuel_entry_asset_hours, ~97% populated). That makes the model\n// self-contained: two consecutive fills give both the gallons pumped and the\n// engine hours between them, with no meter-snapshot join and no guessing.\n//\n// burn rate (gal/hr) = gallons on fill N / (meter at N − meter at N−1)\n//\n// The per-machine rate is the MEDIAN of those intervals, not the mean — one\n// bad interval shouldn't move it.\n//\n// ---------------------------------------------------------------------------\n// WHY THE FILTERS EXIST (each one is a real failure we have seen)\n//\n// · BATCH KEYING. A fueler closes out a whole stop at once — measured 8/18,\n// seven entries landed between 17:50:37 and 17:52:45. If one machine gets\n// two entries in that burst, the meter barely moved and the implied rate is\n// nonsense. Any interval under DH_MIN engine-hours is a keying artifact,\n// not a run gap, and is dropped.\n// · FLEET NUMBER TYPED INTO GALLONS. #512 once shows a \"512 gallon\" fill.\n// That is why capacity is the 95th percentile of fills, never the max.\n// · MISSED ENTRIES. If a fill never got keyed, the next interval spans double\n// the hours and halves the apparent rate. RATE_MIN/RATE_MAX bracket it out.\n// · BURNED > TANK is impossible on a running machine — it means a fill was not\n// keyed. The model must SAY SO rather than quietly claim the tank is full.\n//\n// ---------------------------------------------------------------------------\n// THE CAPACITY STACK, highest wins\n// 1. fl_tank, confirmed — Kaden's spec sheet. Trusted.\n// 2. fl_tank, unconfirmed — spec sheet, number still being verified.\n// 3. inferred — 95th percentile of this machine's own clean fills.\n// Tenna's fuel_tank_size is never used: 12/97 populated and several wrong.\n//\n// ---------------------------------------------------------------------------\n// THE RATE STACK, same shape, added 8/24\n// 1. fl_rate, confirmed — the machine's OWN telematics. My Komatsu, VisionLink,\n// Product Link. Measured by the engine, not inferred\n// from paperwork. Trusted absolutely.\n// 2. fl_rate, unconfirmed — a number in hand that is not verified yet.\n// 3. inferred — median of this machine's clean fill intervals.\n//\n// Kaden 8/24, on where this is going: \"I want this and tenna/machine hours from\n// the log to become the new source of truth when we get everything working\n// properly.\" Available machine by machine — some have it, some don't — so this\n// is a shelf that fills up over time, not a switch.\n//\n// WHY IT MATTERS, measured the day it was built: 411 is a WA320-8. My Komatsu\n// says 1,664.57 gal over 834.7 engine hours = 1.99 gal/h. The inferred rate said\n// 3.99 — exactly double — and that one number invented the biggest fuel gap in\n// the fleet. The audit had 411 burning 432 gal against 217 recorded, a 215-gallon\n// hole. At 1.99 the same hours burn 215.5 against 217 recorded. Nothing was ever\n// missing. The rate was wrong, because 411's fills carry a STALE METER — three\n// fills across six days all reading 2666.0 — so there were no real intervals to\n// learn from and the model learned noise instead.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { rows } from \"./core.ts\";\n\nexport const CFG = {\n RATE_MIN: 0.2, // gal/hr — below this the interval is a missed fill\n RATE_MAX: 40, // gal/hr — above this it is a keying error\n DH_MIN: 0.5, // engine-hours between fills; under this = batch keying\n DH_MAX: 600, // over this the machine sat, or a fill went unkeyed\n CAP_PCTILE: 0.95, // capacity percentile when inferring from fills\n CONF_MIN_N: 5, // fewer clean intervals than this = low confidence\n STALE_DAYS: 90, // no fill in this long = do not rank it as empty\n // WHEN THE LEVEL WALK HAS LOST TRACK (Kaden 8/24: \"why would this show red\n // when it was filled today\"). 407/2 read 3% on a loader that had just worked\n // a full shift — arithmetically correct off a 4-gallon fill, and wrong about\n // the machine, which plainly did not run all day on two gallons.\n // The walk only climbs back to full when one fill SATURATES the tank. Every\n // under-recorded fill ratchets it down, permanently. Audited 8/24 over 30\n // days: fleet-wide the books balance (6,386 gal burned modeled vs 6,804\n // recorded) but per machine the gap runs ±50%, and 53 of 78 machines have run\n // more than a tankful since the model last saw them full.\n // So the number is only refused where it is BOTH alarming AND undefendable.\n LOST_PCT: 30, // only second-guess a reading this low\n LOST_TANKFULS: 3, // tanks' worth of running since we last saw it full\n\n KEEP_RATES: 60,\n PAGE_SLEEP: 250, // Tenna allows 5 req/s PER ACCOUNT — stay under it\n};\n\nasync function ensure() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS fl_burn (\n unit TEXT PRIMARY KEY,\n name TEXT DEFAULT '',\n rate_gph REAL,\n n_rates INTEGER DEFAULT 0,\n cap REAL,\n cap_src TEXT DEFAULT '',\n last_fill_ts TEXT,\n last_fill_meter REAL,\n last_fill_gal REAL,\n last_fill_site TEXT DEFAULT '',\n -- gallons actually IN the tank right after the last recorded fill. NOT the\n -- capacity: fuelers top off as well as fill up. See the level walk below.\n last_level REAL,\n n_fills INTEGER DEFAULT 0,\n at TEXT\n )`);\n // added after the first hold-out test — older DBs won't have it\n try { await sqlite.execute(\"ALTER TABLE fl_burn ADD COLUMN last_level REAL\"); } catch { /* already there */ }\n // the meter at the last fill that actually FILLED it — the anchor the level\n // walk is estimating from. Added 8/24 with the lost-track check.\n try { await sqlite.execute(\"ALTER TABLE fl_burn ADD COLUMN last_full_meter REAL\"); } catch { /* already there */ }\n // where the burn rate came from — \"telematics-confirmed\", \"telematics\", or\n // \"inferred\". A number off the machine's own ECU is not the same kind of\n // thing as one reverse-engineered from fill paperwork, and the app should\n // never present them as though they were.\n try { await sqlite.execute(\"ALTER TABLE fl_burn ADD COLUMN rate_src TEXT DEFAULT ''\"); } catch { /* already there */ }\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS fl_rate (\n unit TEXT PRIMARY KEY, gph REAL NOT NULL, src TEXT DEFAULT '',\n confirmed INTEGER DEFAULT 0, note TEXT DEFAULT '', at TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS fl_burn_meta (\n k TEXT PRIMARY KEY, v TEXT\n )`);\n}\n\nconst median = (xs: number[]): number | null => {\n if (!xs.length) return null;\n const s = [...xs].sort((a, b) => a - b);\n const m = s.length >> 1;\n return s.length % 2 ? s[m] : (s[m - 1] + s[m]) / 2;\n};\n\nconst pctile = (xs: number[], p: number): number | null => {\n if (!xs.length) return null;\n const s = [...xs].sort((a, b) => a - b);\n const i = Math.min(s.length - 1, Math.max(0, Math.ceil(p * s.length) - 1));\n return s[i];\n};\n\n// '605/2' and '605' are the same machine. Fuel entries carry the /division\n// suffix, the asset feed mostly does not.\nexport const baseUnit = (f: unknown) => String(f ?? \"\").split(\"/\")[0].trim();\n\n/** Page Tenna's fuel entries. Pass `since` to fold in only what is new. */\nexport async function pullFuelEntries(since?: string, maxPages = 90): Promise {\n const key = Deno.env.get(\"TENNA_KEY\") ?? \"\";\n if (!key) return [];\n const out: any[] = [];\n const sinceMs = since ? Date.parse(since) : 0;\n for (let off = 0; off < maxPages * 100; off += 100) {\n let r: Response | null = null;\n for (let attempt = 0; attempt < 3; attempt++) {\n if (attempt) await new Promise((s) => setTimeout(s, 1200 * attempt));\n r = await fetch(\n \"https://api.tenna.com/v1/fuel-entries?limit=100&sort=-pumped_at_time&offset=\" + off,\n { headers: { Authorization: \"Bearer \" + key } },\n );\n if (r.ok) break;\n if (r.status !== 429 && r.status < 500) break;\n }\n if (!r || !r.ok) {\n console.log(\"fuel-entries stopped at offset \" + off + \": \" + (r?.status ?? \"no response\"));\n break;\n }\n // Envelope is {metadata, results} — NOT data/items. Reading the wrong key\n // returns zero rows and looks exactly like \"no data\".\n const got: any[] = (await r.json()).results ?? [];\n if (!got.length) break;\n out.push(...got);\n // sorted newest-first, so once we are behind the cursor we can stop\n if (sinceMs && Date.parse(got[got.length - 1]?.pumped_at_time ?? \"\") <= sinceMs) break;\n if (got.length < 100) break;\n await new Promise((s) => setTimeout(s, CFG.PAGE_SLEEP));\n }\n return sinceMs ? out.filter((e) => Date.parse(e.pumped_at_time ?? \"\") > sinceMs) : out;\n}\n\n/**\n * Units the model must NOT treat as machines, from fl_asset.\n *\n * Two kinds, and the difference matters:\n * · BULK TANKS. 1111 \"Bulk Fuel Tank (RED)\" 12,000 gal, 1112 \"Bulk Fuel\n * (GREEN)\" 1,200 gal, 1113 \"Fuel Tanks/Cans\". Diesel going INTO these is\n * not diesel being burned; it is stock moving from the vendor to our yard.\n * Modelling them as machines invented a burn rate and a tank size for a\n * tank, and double-counted every gallon that later went into real iron.\n * 1113 was already special-cased twice by hand; this generalises it.\n * · DISPOSED. Tenna's asset export of 8/25 marks 9 units designation=disposed\n * — sold or gone. Six of them still had rows here, still carrying a burn\n * rate and a level, still landing in fleet tallies and the audit.\n *\n * Nothing is deleted from Tenna and nothing is deleted from the fill history.\n * Set fl_asset.active = 1 and the next rebuild brings the machine back.\n */\nasync function skipSet(): Promise> {\n const out = new Set();\n try {\n for (const r of rows(await sqlite.execute(\n \"SELECT unit FROM fl_asset WHERE active = 0 OR kind <> 'machine'\",\n ))) out.add(baseUnit(r.unit));\n } catch { /* table not loaded yet — model everything, as before */ }\n // belt and braces: the fuel cans predate fl_asset and must never come back\n out.add(\"1113\");\n return out;\n}\n\n/** Rebuild the model. First run pages the full history; later runs fold in new fills. */\nexport async function buildBurnModel(opts: { full?: boolean } = {}) {\n await ensure();\n const SKIP = await skipSet();\n const cur = rows(await sqlite.execute(\"SELECT v FROM fl_burn_meta WHERE k = 'cursor'\"))[0];\n const since = opts.full ? undefined : (cur ? String(cur.v) : undefined);\n const fresh = await pullFuelEntries(since);\n console.log(\"pulled \" + fresh.length + \" fuel entries\" + (since ? \" since \" + since : \" (full history)\"));\n // No early return on a quiet Tenna day: our OWN log can gain fills Tenna\n // never saw (paper keyed in via fix-the-log), and those must reach the model.\n\n // Replay from scratch when seeding; otherwise merge new fills into what we\n // already know. Simplest correct thing: on any run, rebuild from the full\n // set of fills we can see. Tenna holds ~2 years, which is a single pass.\n const all = since ? await pullFuelEntries(undefined) : fresh;\n\n // ---- FILLS TENNA NEVER SAW (the paper log / fix-the-log) -----------------\n // 8/19 proved a whole stop can get fueled and never keyed into Tenna: five\n // fills at 7-Eleven existed only on paper. Once they are keyed into OUR log\n // they must feed the model, or every machine fueled off-paper reads emptier\n // and thirstier than it is — 310 sat with an 8/13 \"last fill\" while it was\n // actually filled 8/19, and the route kept flagging it (Kaden, 8/20).\n // Rule: any fill in fl_mach that has no matching Tenna entry (same machine,\n // same day, within a gallon) joins the replay as if Tenna had carried it.\n const appFills = rows(await sqlite.execute(\n `SELECT j.date d, m.unit u, m.gal g, m.hours h, m.tenna_hours th, m.name nm\n FROM fl_mach m JOIN fl_job j ON j.id = m.job_id\n WHERE m.gal > 0 AND COALESCE(j.kind,'') <> 'refuel'`,\n ));\n const seenT = new Set();\n for (const e of all) {\n const ts = Date.parse(String(e.pumped_at_time ?? \"\"));\n if (!isFinite(ts)) continue; // no timestamp, nothing to match a day against\n const d = new Date(ts - 7 * 3600 * 1000).toISOString().slice(0, 10);\n seenT.add(baseUnit(e.asset_fleet) + \"|\" + d + \"|\" + Math.round(Number(e.gallons)));\n }\n let mergedApp = 0;\n for (const f of appFills) {\n const u = baseUnit(f.u);\n if (!u || SKIP.has(u)) continue; // bulk tank or retired — see skipSet()\n // meter at the fill: Tenna-basis reading first, the keyed dash second\n const meter = f.th != null ? Number(f.th) : (f.h != null ? Number(f.h) : null);\n if (meter == null || !isFinite(meter)) continue; // no meter, no interval math\n const g = Math.round(Number(f.g));\n const day = String(f.d);\n if (seenT.has(u + \"|\" + day + \"|\" + g) || seenT.has(u + \"|\" + day + \"|\" + (g + 1)) || seenT.has(u + \"|\" + day + \"|\" + (g - 1))) {\n continue; // Tenna already carries this fill\n }\n all.push({\n asset_fleet: String(f.u),\n gallons: Number(f.g),\n fuel_entry_asset_hours: meter,\n pumped_at_time: day + \"T19:00:00.000Z\", // ~noon Pacific — right day, close enough hour\n asset_name: String(f.nm ?? \"\"),\n site_name: \"(our log)\",\n });\n // AND REMEMBER IT. Found 8/25: seenT was built from Tenna alone and never\n // updated here, so the reconciled-fills pass below could not see what this\n // pass had just merged. A fill sitting in BOTH fl_mach and fl_fill_extra\n // was counted TWICE — double gallons, and a zero-hour interval between the\n // two copies. Nothing had hit it yet only because the two tables had never\n // held the same day.\n seenT.add(u + \"|\" + day + \"|\" + g);\n mergedApp++;\n }\n if (mergedApp) console.log(\"merged \" + mergedApp + \" fills from our log that Tenna never saw\");\n\n // ---- RECONCILED FILLS (8/24) --------------------------------------------\n // Fills that exist on the fuelers' own daily sheets and nowhere else. Kaden's\n // workbook carried 43 of them, 831 gallons, over eight weeks — against only\n // two rows going the other way, both of which turned out to be \"006\" vs \"6\"\n // formatting. They live in their own table on purpose: they are history, not\n // route work, and putting them in fl_mach would invent jobs that never\n // happened. Deleting this table puts the model back exactly as it was.\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS fl_fill_extra (\n unit TEXT NOT NULL, date TEXT NOT NULL, gal REAL NOT NULL, meter REAL,\n src TEXT DEFAULT '', at TEXT, PRIMARY KEY (unit, date, gal))`);\n let mergedX = 0;\n for (const f of rows(await sqlite.execute(\"SELECT unit, date, gal, meter FROM fl_fill_extra WHERE meter IS NOT NULL\"))) {\n const u = baseUnit(f.unit);\n if (!u || SKIP.has(u)) continue; // bulk tank or retired — see skipSet()\n const g = Math.round(Number(f.gal));\n const day = String(f.date);\n if (seenT.has(u + \"|\" + day + \"|\" + g) || seenT.has(u + \"|\" + day + \"|\" + (g + 1)) || seenT.has(u + \"|\" + day + \"|\" + (g - 1))) continue;\n all.push({\n asset_fleet: String(f.unit),\n gallons: Number(f.gal),\n fuel_entry_asset_hours: Number(f.meter),\n pumped_at_time: day + \"T19:00:00.000Z\",\n asset_name: \"\",\n site_name: \"(fuelers' sheet)\",\n });\n mergedX++;\n }\n if (mergedX) console.log(\"merged \" + mergedX + \" reconciled fills from the fuelers' sheets\");\n } catch (e) {\n console.log(\"reconciled fills skipped: \" + String(e).slice(0, 120));\n }\n\n // group by machine, oldest first\n const byUnit: Record = {};\n let skipped = 0;\n const skipGal: Record = {};\n for (const e of all) {\n const u = baseUnit(e.asset_fleet);\n if (!u) continue;\n // The Tenna fill exists and stays in Tenna. It just is not a machine\n // burning fuel, so it does not get a burn rate, a tank, or a level.\n if (SKIP.has(u)) {\n skipped++;\n (skipGal[u] ??= [0, 0])[0]++;\n skipGal[u][1] += Number(e.gallons) || 0;\n continue;\n }\n (byUnit[u] ??= []).push(e);\n }\n if (skipped) {\n console.log(\"skipped \" + skipped + \" fills on bulk tanks / retired units: \" +\n Object.entries(skipGal).map(([u, [n, g]]) => u + \" \" + n + \" fills/\" + Math.round(g) + \" gal\").join(\", \"));\n }\n for (const u of Object.keys(byUnit)) {\n byUnit[u].sort((a, b) => Date.parse(a.pumped_at_time ?? \"\") - Date.parse(b.pumped_at_time ?? \"\"));\n }\n\n const spec: Record = {};\n for (const t of rows(await sqlite.execute(\"SELECT unit, gal, confirmed FROM fl_tank\"))) {\n spec[String(t.unit)] = { gal: Number(t.gal), confirmed: Number(t.confirmed) };\n }\n // rates the machine itself reported, machine by machine as they become available\n const rateSpec: Record = {};\n for (const t of rows(await sqlite.execute(\"SELECT unit, gph, confirmed, src FROM fl_rate\"))) {\n rateSpec[baseUnit(t.unit)] = { gph: Number(t.gph), confirmed: Number(t.confirmed), src: String(t.src ?? \"\") };\n }\n\n const now = new Date().toISOString();\n let wrote = 0;\n for (const [unit, fills] of Object.entries(byUnit)) {\n const rates: number[] = [];\n const clean: number[] = [];\n for (let i = 1; i < fills.length; i++) {\n const g = Number(fills[i].gallons);\n const h0 = Number(fills[i - 1].fuel_entry_asset_hours);\n const h1 = Number(fills[i].fuel_entry_asset_hours);\n if (!(g > 0) || !isFinite(h0) || !isFinite(h1)) continue;\n const dh = h1 - h0;\n if (!(dh >= CFG.DH_MIN && dh <= CFG.DH_MAX)) continue; // batch-key / sat / missed\n const rate = g / dh;\n if (!(rate >= CFG.RATE_MIN && rate <= CFG.RATE_MAX)) continue;\n rates.push(Math.round(rate * 1000) / 1000);\n clean.push(g);\n }\n const inferredRate = median(rates.slice(-CFG.KEEP_RATES));\n // THE MACHINE'S OWN NUMBER WINS. Nothing inferred from paperwork beats the\n // engine's own count of what it drank.\n const rs = rateSpec[unit];\n const rate = rs ? rs.gph : inferredRate;\n const rateSrc = rs\n ? (rs.confirmed ? \"telematics-confirmed\" : \"telematics\")\n : (inferredRate == null ? \"\" : \"inferred\");\n\n // capacity: spec sheet first, inference only as a fallback\n let cap: number | null = null;\n let capSrc = \"\";\n const sp = spec[unit];\n if (sp) {\n cap = sp.gal;\n capSrc = sp.confirmed ? \"spec-confirmed\" : \"spec-unverified\";\n } else {\n const inferred = pctile(clean.length ? clean : fills.map((f) => Number(f.gallons)).filter((g) => g > 0), CFG.CAP_PCTILE);\n if (inferred) { cap = Math.round(inferred * 10) / 10; capSrc = \"inferred-p95\"; }\n }\n\n // ---- THE LEVEL WALK ----------------------------------------------------\n // Found by the first hold-out test: 905 was predicted to take 155 gal and\n // took 17. That is not a bad burn rate, it is a TOP-OFF. Assuming every\n // fill leaves the tank full is wrong, and it would have shipped a fuel\n // gauge that reads high on every machine the fuelers splash a few gallons\n // into.\n //\n // So walk the whole fill history and carry the tank level forward:\n // level after a fill = min(cap, level before + gallons pumped)\n // level before = level after previous − rate x hours between\n // Seeded at full (the least-wrong first guess) and it self-corrects the\n // moment any fill saturates the tank.\n let level: number | null = null;\n // the meter the last time this walk could actually SEE a full tank — the\n // anchor everything after it is estimated from. Null means never.\n let lastFullMeter: number | null = null;\n if (rate != null && cap != null) {\n level = cap;\n for (let i = 0; i < fills.length; i++) {\n const g = Number(fills[i].gallons);\n const hi = Number(fills[i].fuel_entry_asset_hours);\n if (i > 0) {\n const h0 = Number(fills[i - 1].fuel_entry_asset_hours);\n const dh = hi - h0;\n if (isFinite(dh) && dh > 0 && dh <= CFG.DH_MAX) {\n const after = level - rate * dh;\n // A MACHINE THAT KEPT RUNNING HAD FUEL IN IT (Kaden 8/24: \"if we\n // knew the burn rate we would know how many hours that machine\n // could run until empty\"). If the walk goes past empty and the\n // machine went on working to its next fill, the walk is provably\n // wrong — fuel went in that nobody wrote down. Carrying \"empty\"\n // forward is the one thing we know to be false, so re-anchor at\n // full, exactly as this already does after a long gap.\n // Back-tested 8/24 over 815 fills: median fill-up prediction error\n // 4.9 gal -> 3.9 gal, and provably-impossible states 51 -> 28.\n if (after < 0) { level = cap; if (isFinite(h0)) lastFullMeter = h0; }\n else level = after;\n } else if (isFinite(dh) && dh > CFG.DH_MAX) {\n // a gap this long means we lost track — re-seed at full rather\n // than carry a level we cannot defend\n level = cap;\n if (isFinite(h0)) lastFullMeter = h0;\n }\n }\n if (g > 0) {\n level = Math.min(cap, level + g);\n // a fill that fills it is the only thing that re-anchors the walk\n if (level >= cap - 0.01 && isFinite(hi)) lastFullMeter = hi;\n }\n }\n level = Math.round(level * 10) / 10;\n }\n\n const last = fills[fills.length - 1];\n await sqlite.execute({\n sql: `INSERT INTO fl_burn (unit, name, rate_gph, n_rates, cap, cap_src,\n last_fill_ts, last_fill_meter, last_fill_gal, last_fill_site, last_level, last_full_meter,\n rate_src, n_fills, at)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)\n ON CONFLICT (unit) DO UPDATE SET\n name = excluded.name, rate_gph = excluded.rate_gph, n_rates = excluded.n_rates,\n cap = excluded.cap, cap_src = excluded.cap_src,\n last_fill_ts = excluded.last_fill_ts, last_fill_meter = excluded.last_fill_meter,\n last_fill_gal = excluded.last_fill_gal, last_fill_site = excluded.last_fill_site,\n last_level = excluded.last_level, last_full_meter = excluded.last_full_meter,\n rate_src = excluded.rate_src, n_fills = excluded.n_fills, at = excluded.at`,\n args: [\n unit,\n String(last.asset_name ?? \"\").slice(0, 80),\n rate == null ? null : Math.round(rate * 1000) / 1000,\n rates.length,\n cap,\n capSrc,\n String(last.pumped_at_time ?? \"\"),\n Number.isFinite(Number(last.fuel_entry_asset_hours)) ? Number(last.fuel_entry_asset_hours) : null,\n Number(last.gallons) || null,\n String(last.site_name ?? \"\").slice(0, 60),\n level,\n lastFullMeter != null && isFinite(lastFullMeter) ? lastFullMeter : null,\n rateSrc,\n fills.length,\n now,\n ],\n });\n wrote++;\n }\n\n // Rows written before a unit was retired or reclassified stay behind on\n // their own — nothing above ever touches them again. Clear them, so the\n // model holds exactly what it currently believes.\n let cleared = 0;\n for (const u of SKIP) {\n const r = await sqlite.execute({ sql: \"DELETE FROM fl_burn WHERE unit = ?\", args: [u] });\n cleared += Number(r.rowsAffected ?? 0);\n }\n if (cleared) console.log(\"cleared \" + cleared + \" stale fl_burn rows\");\n\n const newestTs = all.reduce((a: string, e: any) => {\n const t = String(e.pumped_at_time ?? \"\");\n return t > a ? t : a;\n }, \"\");\n if (newestTs) {\n await sqlite.execute({\n sql: `INSERT INTO fl_burn_meta (k, v) VALUES ('cursor', ?)\n ON CONFLICT (k) DO UPDATE SET v = excluded.v`,\n args: [newestTs],\n });\n }\n console.log(\"burn model: \" + wrote + \" machines from \" + all.length + \" fills, cursor \" + newestTs);\n return { units: wrote, entries: all.length };\n}\n\nexport type Estimate = {\n unit: string;\n gallonsLeft: number | null;\n pct: number | null;\n toFill: number | null;\n cap: number | null;\n capSrc: string;\n rate: number | null;\n hoursSinceFill: number | null;\n confidence: \"good\" | \"low\" | \"none\";\n flag: \"\" | \"fill-record-missing\" | \"lost-track\" | \"stale\" | \"no-model\";\n note: string;\n};\n\n/**\n * How full is this machine, given a current meter reading?\n * Returns nulls rather than guesses — every caller must be able to say\n * \"we don't know\" out loud. This never claims a gauge reading.\n */\nexport function estimate(\n m: { unit: string; rate_gph: number | null; cap: number | null; cap_src: string;\n last_fill_ts: string | null; last_fill_meter: number | null; n_rates: number;\n last_level?: number | null; last_full_meter?: number | null },\n currentMeter: number | null,\n): Estimate {\n const base: Estimate = {\n unit: m.unit, gallonsLeft: null, pct: null, toFill: null,\n cap: m.cap ?? null, capSrc: m.cap_src ?? \"\", rate: m.rate_gph ?? null,\n hoursSinceFill: null, confidence: \"none\", flag: \"no-model\", note: \"\",\n };\n if (m.rate_gph == null || m.cap == null) {\n return { ...base, note: \"no burn rate yet — needs a few more fills\" };\n }\n const daysSince = m.last_fill_ts\n ? (Date.now() - Date.parse(m.last_fill_ts)) / 86400000\n : null;\n if (daysSince != null && daysSince > CFG.STALE_DAYS) {\n return { ...base, flag: \"stale\", note: \"no fill in \" + Math.round(daysSince) + \" days — check it by eye\" };\n }\n if (currentMeter == null || m.last_fill_meter == null) {\n return { ...base, note: \"no current meter reading\" };\n }\n const dh = Math.round((currentMeter - m.last_fill_meter) * 10) / 10;\n if (dh < 0) return { ...base, hoursSinceFill: null, note: \"meter reads lower than at the last fill\" };\n\n const burned = m.rate_gph * dh;\n const conf: Estimate[\"confidence\"] = m.n_rates >= CFG.CONF_MIN_N ? \"good\" : \"low\";\n\n // Start from what was actually IN the tank after the last fill, not from a\n // full tank. Fuelers top off; assuming every fill fills it would read high\n // on exactly the machines that get splashed a few gallons.\n const startedAt = m.last_level != null ? Math.min(m.last_level, m.cap) : m.cap;\n\n // Burning more than was in there is impossible on a running machine.\n // It means a fill was never keyed. Say that; do not invent a number.\n if (burned > startedAt) {\n return {\n ...base, hoursSinceFill: dh, confidence: conf, flag: \"fill-record-missing\",\n note: \"ran \" + dh.toFixed(1) + \"h since the last recorded fill, which left about \" +\n Math.round(startedAt) + \" gal in a \" + m.cap + \" gal tank — a fill was not keyed\",\n };\n }\n const left = Math.max(0, Math.round((startedAt - burned) * 10) / 10);\n const pct = Math.round((left / m.cap) * 100);\n\n // ---- HAVE WE LOST TRACK? ------------------------------------------------\n // The level above is a running total, and it only gets corrected when a fill\n // actually fills the tank. If this machine has run several tanks' worth of\n // hours since the last time we SAW it full, that total is an accumulation of\n // estimates, not a measurement — and saying \"3%\" out loud about a machine\n // that has been working all day is worse than saying nothing.\n // Only where it is BOTH alarming and undefendable; a low reading anchored to\n // a recent full tank is real and still shows.\n if (pct < CFG.LOST_PCT && m.last_full_meter != null && isFinite(m.last_full_meter)) {\n const sinceFull = currentMeter - m.last_full_meter;\n const tankfuls = (sinceFull * m.rate_gph) / m.cap;\n if (tankfuls > CFG.LOST_TANKFULS) {\n return {\n ...base, hoursSinceFill: dh, confidence: conf, flag: \"lost-track\",\n note: \"the fills on record do not add up for this machine — it has run about \" +\n Math.round(tankfuls) + \" tanks' worth of hours since one of them last filled it. \" +\n \"Check the gauge; the last recorded fill was \" + Math.round(startedAt) +\n \" gal in a \" + m.cap + \" gal tank.\",\n };\n }\n }\n\n return {\n ...base,\n gallonsLeft: left,\n pct: pct,\n toFill: Math.round((m.cap - left) * 10) / 10,\n hoursSinceFill: dh,\n confidence: conf,\n flag: \"\",\n note: conf === \"low\" ? \"rough — only \" + m.n_rates + \" clean fills to learn from\" : \"\",\n };\n}\n\n/** Load the whole model keyed by base unit number. */\nexport async function loadBurn(): Promise> {\n await ensure();\n const out: Record = {};\n for (const r of rows(await sqlite.execute(\"SELECT * FROM fl_burn\"))) {\n out[String(r.unit)] = {\n unit: String(r.unit),\n name: String(r.name ?? \"\"),\n rate_gph: r.rate_gph == null ? null : Number(r.rate_gph),\n n_rates: Number(r.n_rates ?? 0),\n cap: r.cap == null ? null : Number(r.cap),\n cap_src: String(r.cap_src ?? \"\"),\n last_fill_ts: r.last_fill_ts ? String(r.last_fill_ts) : null,\n last_fill_meter: r.last_fill_meter == null ? null : Number(r.last_fill_meter),\n last_fill_gal: r.last_fill_gal == null ? null : Number(r.last_fill_gal),\n last_fill_site: String(r.last_fill_site ?? \"\"),\n last_level: r.last_level == null ? null : Number(r.last_level),\n last_full_meter: r.last_full_meter == null ? null : Number(r.last_full_meter),\n rate_src: String(r.rate_src ?? \"\"),\n n_fills: Number(r.n_fills ?? 0),\n };\n }\n return out;\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"]