[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_334":335,"_336":337},"routes/_app.x.$handle.$name",{"_101":100,"_32":46,"_109":91,"_27":103,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":60,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":25},"version",30,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","valtown/cron.ts","latestPath","fileId","7cd3ef8a-a795-11f1-a766-1607ee4eb77e","name","cron.ts","fileType","interval","content","// Val Town interval val. Cron: 0 3 * * * (03:00 UTC daily). Cron on Val Town is always UTC.\n//\n// A second lighter pass at 12:00 UTC can point at the same file; the pipeline is\n// idempotent because every capture is a new row and the policy compares to the last one.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initSchema } from \"../src/db.js\";\nimport { SCHEMA } from \"../src/schema.js\";\nimport { runCollection, releaseVetoes } from \"../src/ingest.js\";\nimport { falCollector } from \"../src/collectors/fal.js\";\nimport { replicateCollector } from \"../src/collectors/replicate.js\";\n\nexport default async function (interval: Interval) {\n await initSchema(sqlite, SCHEMA);\n const now = new Date().toISOString();\n\n const report = await runCollection(sqlite, [falCollector, replicateCollector], {\n now,\n fetchImpl: fetch,\n userAgent: \"InferenceIndexBot/1.0 (+https://inferenceticker.com/about)\",\n });\n report.vetoes_released = await releaseVetoes(sqlite, now);\n\n // Logged, not emailed. Only vetoes and parse failures deserve a human.\n console.log(JSON.stringify(report));\n\n if (report.errors.length || report.vetoed.length) {\n console.log(\"NEEDS ATTENTION\", JSON.stringify({ errors: report.errors, vetoed: report.vetoed }));\n }\n return report;\n}\n","// Val Town interval val. Cron: 0 3 * * * (03:00 UTC daily). Cron on Val Town is always UTC.\n//\n// A second lighter pass at 12:00 UTC can point at the same file; the pipeline is\n// idempotent because every capture is a new row and the policy compares to the last one.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initSchema } from \"../src/db.js\";\nimport { SCHEMA } from \"../src/schema.js\";\nimport { runCollection, releaseVetoes } from \"../src/ingest.js\";\nimport { replicateCollector } from \"../src/collectors/replicate.js\";\nimport { runwayCollector } from \"../src/collectors/runway.js\";\nimport { wavespeedCollector } from \"../src/collectors/wavespeed.js\";\n\n// fal is deliberately NOT in this list. On 3 Sep 2026 fal removed per-model pricing\n// from fal.ai/pricing; that page now carries GPU $/hr only. The collector still exists\n// at src/collectors/fal.js and still parses the old shape correctly, but there is\n// nothing left on that page for it to read. The replacement is fal.ai/api/models, whose\n// pricingInfoOverride field carries rates AND promo end dates as prose. That needs the\n// scheduled_events table from doc 12 section 5 and a confidence-scored prose parser,\n// so it is a build session, not a patch. See doc 17.\nconst COLLECTORS = [replicateCollector, runwayCollector, wavespeedCollector];\n\nexport default async function (interval: Interval) {\n await initSchema(sqlite, SCHEMA);\n const now = new Date().toISOString();\n\n const report = await runCollection(sqlite, COLLECTORS, {\n now,\n fetchImpl: fetch,\n userAgent: \"InferenceIndexBot/1.0 (+https://inferenceticker.com/about)\",\n });\n report.vetoes_released = await releaseVetoes(sqlite, now);\n\n // Logged, not emailed. Only vetoes and parse failures deserve a human.\n console.log(JSON.stringify(report));\n\n if (report.errors.length || report.vetoed.length) {\n console.log(\"NEEDS ATTENTION\", JSON.stringify({ errors: report.errors, vetoed: report.vetoed }));\n }\n return report;\n}\n","createdAt",["D",1788440852801],"branchVersion","branchId","c8dc6bc1-531b-4b2b-9d03-7e32281b6f29","id","5923a59d-1da5-40e1-bcc1-236c883917f3","inference-index",["D",1788438548015],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Price history and change alerts for image and video models","imageUrl","0b3f5114-fb40-4060-b6f7-df07b67b8e09","pinnedFileId","74df16ce-a795-11f1-b511-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a06731-c164-775f-a1ef-11bda3ba1211","tursoName","5923a59d1da540e1bcc1236c883917f3","tursoHostname","5923a59d1da540e1bcc1236c883917f3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789480235853],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_101":100,"_108":103},"org",{"_101":100,"_102":103,"_104":103,"_18":56,"_105":106,"_107":25},"branch",{"_13":90,"_32":91,"_44":43,"_92":45,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":46,"_99":100},"isOwned",207,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","protonmails","handle","displayName","","avatar","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_44":45,"_32":46,"_39":329,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":330,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":331,"_85":332,"_87":333,"_89":25},"tree",[177,192,195,196],"files",[177,178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196],"counts",{"_167":64,"_168":150,"_169":64,"_170":171,"_172":173},"contents",[131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{"_58":130},"modelpricehistory.com",{"_44":161,"_32":162,"_30":163,"_138":-5,"_42":43,"_41":164,"_140":60,"_39":165,"_13":64,"_34":159,"_36":-5,"_24":25,"_145":-5,"_27":166},{"_44":154,"_32":155,"_30":156,"_138":-5,"_42":43,"_41":157,"_140":60,"_39":158,"_13":64,"_34":159,"_36":-5,"_24":25,"_145":-5,"_27":160},{"_44":147,"_32":148,"_30":149,"_138":-5,"_42":43,"_41":150,"_140":60,"_39":151,"_13":64,"_34":20,"_36":152,"_24":25,"_145":-5,"_27":153},{"_44":135,"_32":136,"_30":137,"_138":-5,"_42":43,"_41":139,"_140":25,"_39":141,"_13":142,"_34":143,"_36":144,"_24":25,"_145":-5,"_27":146},"002b6473-da68-431b-a1db-dd10ef1da969","diag-sources.ts","d60fc838-a797-11f1-a2bd-1607ee4eb77e","parentId",28,"latest",["D",1788440810962],4,"script","// Dry run: what would the new collectors publish? Reads the live pages, parses,\n// prints. Touches no database. Delete once verified.\nimport { htmlToText } from \"./src/collectors/html.js\";\nimport { runwayCollector } from \"./src/collectors/runway.js\";\nimport { wavespeedCollector } from \"./src/collectors/wavespeed.js\";\nimport { normalise } from \"./src/normalise.js\";\n\nconst UA = \"InferenceIndexBot/1.0 (+https://inferenceticker.com/about)\";\n\nfor (const c of [runwayCollector, wavespeedCollector]) {\n const r = await fetch(c.source_url, { headers: { \"user-agent\": UA } });\n const rows = c.parse(htmlToText(await r.text()));\n console.log(`=== ${c.provider}: ${rows.length} rows`);\n const bad: string[] = [];\n for (const row of rows) {\n let usd: number | string;\n try { usd = normalise(row); } catch (e) { usd = \"NORMALISE FAIL: \" + (e as Error).message; bad.push(row.display_name); }\n console.log(\n \" \" + String(usd).padEnd(12) +\n (row.modality === \"video\" ? \"/s \" : \"/img\") +\n \" \" + row.display_name +\n \" [res \" + row.resolution + \"]\" +\n (row.tier !== \"standard\" ? \" [tier \" + row.tier + \"]\" : \"\")\n );\n }\n if (bad.length) console.log(\" !! normalise failures: \" + JSON.stringify(bad));\n await new Promise((s) => setTimeout(s, 150));\n}\n","label",[136],"f589f6a6-bec9-4de8-be0b-456beb905098","README.md","0f1bdda6-a793-11f1-a3ca-1607ee4eb77e",1,["D",1788438548051],"# Inference Index\n\nPrice history and change alerts for AI image and video generation models.\n",[148],"766735c2-a732-4d12-98d1-4705e55c21f9","valtown","d7a8ae44-8e7d-447d-8f70-30148c936f60",12,["D",1788439577767],"directory",[155],"56fa228f-a094-4629-9408-e1c00107aa0b","src","132301c4-95f4-4bca-ad65-84d68cb40af2",2,["D",1788438577468],[162],"pulls","branches","forks","envVars",{"_174":150,"_176":64},"connections",{"_174":64,"_175":64},"count","unfilledCount","emptyCount",{"_44":161,"_32":162,"_30":163,"_138":-5,"_42":43,"_41":164,"_140":60,"_39":326,"_13":64,"_34":159,"_36":-5,"_24":25,"_145":-5,"_198":327,"_27":328},{"_44":322,"_32":290,"_30":284,"_138":163,"_42":43,"_41":142,"_140":60,"_39":323,"_13":64,"_34":159,"_36":-5,"_24":25,"_145":-5,"_198":324,"_27":325},{"_44":314,"_32":315,"_30":316,"_138":284,"_42":43,"_41":317,"_140":60,"_39":318,"_13":64,"_34":143,"_36":319,"_24":25,"_145":-5,"_198":320,"_27":321},{"_44":307,"_32":308,"_30":309,"_138":284,"_42":43,"_41":142,"_140":60,"_39":310,"_13":64,"_34":143,"_36":311,"_24":25,"_145":-5,"_198":312,"_27":313},{"_44":299,"_32":300,"_30":301,"_138":284,"_42":43,"_41":302,"_140":60,"_39":303,"_13":64,"_34":143,"_36":304,"_24":25,"_145":-5,"_198":305,"_27":306},{"_44":291,"_32":292,"_30":293,"_138":284,"_42":43,"_41":294,"_140":60,"_39":295,"_13":252,"_34":143,"_36":296,"_24":25,"_145":-5,"_198":297,"_27":298},{"_44":281,"_32":282,"_30":283,"_138":284,"_42":43,"_41":285,"_140":60,"_39":286,"_13":64,"_34":143,"_36":287,"_24":25,"_145":-5,"_198":288,"_27":289},{"_44":273,"_32":274,"_30":275,"_138":163,"_42":43,"_41":276,"_140":25,"_39":277,"_13":64,"_34":143,"_36":278,"_24":25,"_145":-5,"_198":279,"_27":280},{"_44":265,"_32":266,"_30":267,"_138":163,"_42":43,"_41":268,"_140":25,"_39":269,"_13":64,"_34":143,"_36":270,"_24":25,"_145":-5,"_198":271,"_27":272},{"_44":257,"_32":258,"_30":259,"_138":163,"_42":43,"_41":260,"_140":60,"_39":261,"_13":64,"_34":143,"_36":262,"_24":25,"_145":-5,"_198":263,"_27":264},{"_44":249,"_32":250,"_30":251,"_138":163,"_42":43,"_41":252,"_140":60,"_39":253,"_13":64,"_34":143,"_36":254,"_24":25,"_145":-5,"_198":255,"_27":256},{"_44":241,"_32":242,"_30":243,"_138":163,"_42":43,"_41":244,"_140":25,"_39":245,"_13":64,"_34":143,"_36":246,"_24":25,"_145":-5,"_198":247,"_27":248},{"_44":233,"_32":234,"_30":235,"_138":163,"_42":43,"_41":236,"_140":25,"_39":237,"_13":64,"_34":143,"_36":238,"_24":25,"_145":-5,"_198":239,"_27":240},{"_44":226,"_32":227,"_30":228,"_138":163,"_42":43,"_41":164,"_140":25,"_39":229,"_13":64,"_34":143,"_36":230,"_24":25,"_145":-5,"_198":231,"_27":232},{"_44":218,"_32":219,"_30":220,"_138":163,"_42":43,"_41":221,"_140":60,"_39":222,"_13":64,"_34":143,"_36":223,"_24":25,"_145":-5,"_198":224,"_27":225},{"_44":154,"_32":155,"_30":156,"_138":-5,"_42":43,"_41":157,"_140":60,"_39":215,"_13":64,"_34":159,"_36":-5,"_24":25,"_145":-5,"_198":216,"_27":217},{"_44":211,"_32":33,"_30":31,"_138":156,"_42":43,"_41":14,"_140":25,"_39":212,"_13":150,"_34":35,"_36":38,"_24":25,"_145":-5,"_198":213,"_27":214},{"_44":204,"_32":205,"_30":58,"_138":156,"_42":43,"_41":157,"_140":25,"_39":206,"_13":64,"_34":207,"_36":208,"_24":25,"_145":-5,"_198":209,"_27":210},{"_44":147,"_32":148,"_30":149,"_138":-5,"_42":43,"_41":150,"_140":60,"_39":201,"_13":64,"_34":20,"_36":152,"_24":25,"_145":-5,"_198":202,"_27":203},{"_44":135,"_32":136,"_30":137,"_138":-5,"_42":43,"_41":139,"_140":25,"_39":197,"_13":142,"_34":143,"_36":144,"_24":25,"_145":-5,"_198":199,"_27":200},["D",1788440810962],"children",[],[136],["D",1788438548051],[],[148],"7c50483b-f2f5-420a-833b-328c7128bb71","http.ts",["D",1788439577767],"http","// Val Town HTTP val. It wires the shared router to Val Town's SQLite and nothing else.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { handle } from \"../src/router.js\";\nimport { initSchema } from \"../src/db.js\";\nimport { SCHEMA } from \"../src/schema.js\";\n\nlet ready: Promise | null = null;\nfunction ensureSchema() {\n if (!ready) ready = initSchema(sqlite, SCHEMA);\n return ready;\n}\n\nexport default async function (req: Request): Promise {\n await ensureSchema();\n return handle(req, {\n client: sqlite,\n now: new Date().toISOString(),\n adminKey: Deno.env.get(\"ADMIN_KEY\"),\n });\n}\n",[],[155,205],"2cbfba71-95da-473a-a430-aca8b641c375",["D",1788440852801],[],[155,33],["D",1788439577767],[193,194],[155],"345d5e0f-7363-4e86-9c62-5e461b57b55a","seed.js","468aac4a-a793-11f1-8dc9-1607ee4eb77e",8,["D",1788438641054],"// Seed rates, hand verified 2 September 2026.\n//\n// These come from a published secondary compilation, not from the vendor's own\n// page, so they carry parse_confidence 0.9 and say so on the model page. The\n// live collectors overwrite them with primary observations on the first run,\n// and every one of them keeps its source link and capture date.\n\nexport const SEED_SOURCE = 'https://invideo.io/blog/ai-video-model-pricing/';\n\nexport const seedCollector = {\n provider: 'vendor-direct',\n vendor_fallback: 'vendor',\n source_url: SEED_SOURCE,\n needs_live_verification: true,\n parse() {\n const v = (display_name, vendor, native_price, resolution, extra = {}) => ({\n display_name, vendor, modality: 'video', native_unit: 'per_second',\n native_price, native_currency: 'USD', fx_rate: 1, resolution,\n parse_confidence: 0.9, notes: 'secondary source, pending primary verification',\n ...extra,\n });\n return [\n v('P-Video', 'Pruna', 0.03, '720p'),\n v('LTX-2.3 Fast', 'Lightricks', 0.06, '1080p'),\n v('Grok Video 1.5', 'xAI', 0.08, '1080p'),\n v('Veo 3.1 Fast', 'Google', 0.10, '720p'),\n v('MiniMax H3', 'MiniMax', 0.13, '2K'),\n v('Sora 2 Pro', 'OpenAI', 0.70, '1080p', {\n status: 'sunset', sunset_date: '2026-09-24',\n notes: 'API sunset announced for 24 Sep 2026',\n }),\n // Quoted in CNY. Stored native with the FX rate applied at capture, so a\n // currency move is never mistaken for a price move.\n {\n display_name: 'Kling 3.0 Turbo', vendor: 'Kuaishou', modality: 'video',\n native_unit: 'per_second', native_price: 0.8, native_currency: 'CNY',\n fx_rate: 0.14, resolution: '1080p', parse_confidence: 0.9,\n notes: 'quoted in CNY, FX applied at capture',\n },\n ];\n },\n};\n",[],[162,219],"eaa9cfb9-9dda-42f5-baba-2d0e02e539cb","schema.js","20a5ff3e-a793-11f1-941d-1607ee4eb77e",["D",1788438577468],"// Schema as a module, so runtimes without filesystem access can apply it.\n// Keep this in sync with schema.sql. The test suite asserts they are identical.\nexport const SCHEMA = `-- Inference Index schema. Append only. Nothing is ever overwritten or deleted.\n\nCREATE TABLE IF NOT EXISTS models (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n slug TEXT NOT NULL UNIQUE,\n display_name TEXT NOT NULL,\n vendor TEXT NOT NULL,\n modality TEXT NOT NULL CHECK (modality IN ('video','image')),\n status TEXT NOT NULL DEFAULT 'active' CHECK (status IN ('active','deprecated','sunset')),\n first_seen_at TEXT NOT NULL,\n sunset_date TEXT,\n notes TEXT\n);\n\n-- Every capture is a new row. Never UPDATE, never DELETE.\nCREATE TABLE IF NOT EXISTS price_points (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n model_id INTEGER NOT NULL REFERENCES models(id),\n provider TEXT NOT NULL,\n endpoint_url TEXT,\n tier TEXT NOT NULL DEFAULT 'standard',\n resolution TEXT NOT NULL DEFAULT 'unspecified',\n native_unit TEXT NOT NULL,\n native_price REAL NOT NULL,\n native_currency TEXT NOT NULL DEFAULT 'USD',\n fx_rate REAL NOT NULL DEFAULT 1.0,\n normalised_price_usd REAL NOT NULL,\n clip_seconds REAL,\n outputs INTEGER NOT NULL DEFAULT 1,\n source_url TEXT NOT NULL,\n captured_at TEXT NOT NULL,\n parse_confidence REAL NOT NULL DEFAULT 1.0,\n is_promotional INTEGER NOT NULL DEFAULT 0,\n promo_ends_at TEXT\n);\nCREATE INDEX IF NOT EXISTS ix_pp_lookup ON price_points (model_id, provider, tier, resolution, captured_at DESC);\nCREATE INDEX IF NOT EXISTS ix_pp_captured ON price_points (captured_at DESC);\n\nCREATE TABLE IF NOT EXISTS changes (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n model_id INTEGER NOT NULL REFERENCES models(id),\n provider TEXT NOT NULL,\n tier TEXT NOT NULL DEFAULT 'standard',\n resolution TEXT NOT NULL DEFAULT 'unspecified',\n field_changed TEXT NOT NULL,\n old_value TEXT,\n new_value TEXT,\n pct_change REAL,\n detected_at TEXT NOT NULL,\n published_at TEXT,\n status TEXT NOT NULL CHECK (status IN ('auto_published','pending_veto','held','rejected')),\n source_url TEXT NOT NULL,\n note TEXT\n);\nCREATE INDEX IF NOT EXISTS ix_changes_detected ON changes (detected_at DESC);\n\n-- Parse failures and collector health. Feeds /admin and the daily note.\nCREATE TABLE IF NOT EXISTS collector_runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n provider TEXT NOT NULL,\n started_at TEXT NOT NULL,\n finished_at TEXT,\n ok INTEGER NOT NULL DEFAULT 0,\n found INTEGER NOT NULL DEFAULT 0,\n error TEXT\n);\n\nCREATE TABLE IF NOT EXISTS subscribers (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT NOT NULL UNIQUE,\n created_at TEXT NOT NULL,\n confirmed_at TEXT,\n confirm_token TEXT,\n plan TEXT NOT NULL DEFAULT 'free',\n stripe_customer_id TEXT,\n unsubscribed_at TEXT\n);\n\nCREATE TABLE IF NOT EXISTS watches (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n subscriber_id INTEGER NOT NULL REFERENCES subscribers(id),\n model_id INTEGER NOT NULL REFERENCES models(id),\n created_at TEXT NOT NULL,\n UNIQUE (subscriber_id, model_id)\n);\n\n-- Outbound clicks per provider. This is the sponsor pitch, so it is a first-class table.\nCREATE TABLE IF NOT EXISTS outbound_clicks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n provider TEXT NOT NULL,\n model_slug TEXT,\n clicked_at TEXT NOT NULL,\n referer TEXT\n);\nCREATE INDEX IF NOT EXISTS ix_clicks_provider ON outbound_clicks (provider, clicked_at DESC);\n\nCREATE TABLE IF NOT EXISTS sponsors (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n provider TEXT NOT NULL,\n label TEXT NOT NULL,\n url TEXT NOT NULL,\n starts_at TEXT NOT NULL,\n ends_at TEXT NOT NULL,\n active INTEGER NOT NULL DEFAULT 1\n);\n`;\n",[],[162,227],"4621feee-4b27-4b6f-a2fa-8a9e733a094d","router.js","82002fde-a793-11f1-a0ea-1607ee4eb77e",11,["D",1788438740790],"// Web layer. Standard Request in, Response out, so the same file serves\n// Val Town (Deno) and the local Node server with no adapter inside the app.\nimport * as db from './db.js';\nimport { isStale } from './policy.js';\nimport * as view from './render.js';\n\nconst PROVIDER_URL = {\n fal: 'https://fal.ai/pricing',\n replicate: 'https://replicate.com/pricing',\n 'vendor-direct': 'https://invideo.io/blog/ai-video-model-pricing/',\n runway: 'https://runwayml.com/pricing',\n google: 'https://cloud.google.com/vertex-ai/generative-ai/pricing',\n openai: 'https://openai.com/api/pricing/',\n minimax: 'https://www.minimax.io/price',\n};\n\nfunction html(body, status = 200) {\n return new Response(body, { status, headers: { 'content-type': 'text/html; charset=utf-8' } });\n}\nfunction json(obj, status = 200) {\n return new Response(JSON.stringify(obj, null, 2), {\n status,\n headers: { 'content-type': 'application/json; charset=utf-8' },\n });\n}\nfunction redirect(location) {\n return new Response(null, { status: 302, headers: { location } });\n}\n\nfunction daysOfHistory(firstCapture, now) {\n if (!firstCapture) return 0;\n return Math.max(0, Math.floor((Date.parse(now) - Date.parse(firstCapture)) / 86400000));\n}\n\n/** Decorate current prices with the 30 day delta, staleness and sponsorship. */\nexport async function buildHomeRows(client, now) {\n const rows = await db.currentPrices(client);\n const cutoff = new Date(Date.parse(now) - 30 * 86400000).toISOString();\n const sponsors = await db.all(client, 'SELECT * FROM sponsors WHERE active=1 AND starts_at<=? AND ends_at>=?', [now, now]);\n const sponsored = new Set(sponsors.map((s) => s.provider));\n const out = [];\n for (const r of rows) {\n const past = await db.priceAsOf(client, r.model_id, r.provider, r.tier, r.resolution, cutoff);\n const pct = past && past.normalised_price_usd !== 0 && past.id !== r.id\n ? (r.normalised_price_usd - past.normalised_price_usd) / past.normalised_price_usd\n : null;\n out.push({ ...r, pct_30d: pct, stale: isStale(r.captured_at, now), sponsored: sponsored.has(r.provider) });\n }\n // Ranking is by price. Sponsorship never reorders. This is enforced here on purpose.\n out.sort((a, b) => a.normalised_price_usd - b.normalised_price_usd);\n return out;\n}\n\nexport async function handle(request, ctx) {\n const client = ctx.client;\n const now = ctx.now || new Date().toISOString();\n const url = new URL(request.url);\n const path = url.pathname.replace(/\\/+$/, '') || '/';\n\n if (path === '/health') return json({ ok: true, now });\n\n if (path === '/') {\n const rows = await buildHomeRows(client, now);\n const stats = await db.stats(client);\n return html(view.homePage(rows, {\n modality: url.searchParams.get('m') || 'all',\n stats,\n days_of_history: daysOfHistory(stats.first_capture, now),\n }));\n }\n\n if (path.startsWith('/model/')) {\n const slug = decodeURIComponent(path.slice('/model/'.length));\n const model = await db.one(client, 'SELECT * FROM models WHERE slug=?', [slug]);\n if (!model) return html(view.layout('Not found', '

Not found

No model with that slug.

'), 404);\n const points = await db.history(client, model.id);\n const changes = await db.all(\n client,\n \"SELECT * FROM changes WHERE model_id=? AND status='auto_published' ORDER BY detected_at DESC LIMIT 50\",\n [model.id]\n );\n return html(view.modelPage(model, points, changes, { now }));\n }\n\n if (path === '/changes') return html(view.changesPage(await db.recentChanges(client, 100)));\n\n if (path === '/changes.rss') {\n const changes = await db.recentChanges(client, 50);\n return new Response(view.rss(changes, url.origin), {\n headers: { 'content-type': 'application/rss+xml; charset=utf-8' },\n });\n }\n\n if (path === '/calculator') return html(view.calculatorPage(await db.currentPrices(client)));\n\n if (path === '/subscribe') {\n if (request.method === 'POST') {\n const form = await request.formData();\n const email = String(form.get('email') || '').trim().toLowerCase();\n if (!/^[^@\\s]+@[^@\\s.]+\\.[^@\\s]+$/.test(email)) {\n return html(view.subscribePage('That does not look like an email address.', null), 400);\n }\n const token = Math.random().toString(36).slice(2) + Date.now().toString(36);\n const { created, subscriber } = await db.addSubscriber(client, email, now, token);\n const watch = String(form.get('watch') || '');\n if (watch) {\n const m = await db.one(client, 'SELECT * FROM models WHERE slug=?', [watch]);\n if (m) {\n await db.run(client, 'INSERT OR IGNORE INTO watches (subscriber_id, model_id, created_at) VALUES (?,?,?)', [subscriber.id, m.id, now]);\n }\n }\n if (ctx.sendEmail && created) {\n await ctx.sendEmail({ to: email, subject: 'Confirm your Inference Index alerts', token });\n }\n return html(view.subscribePage(created ? 'Check your inbox and confirm. Nothing is sent until you do.' : 'You are already on the list.', null));\n }\n return html(view.subscribePage(null, url.searchParams.get('watch')));\n }\n\n if (path === '/sponsor') {\n const since = new Date(Date.parse(now) - 30 * 86400000).toISOString();\n const clicks = await db.clickCounts(client, since);\n const stats = await db.stats(client);\n return html(view.sponsorPage(clicks, stats, daysOfHistory(stats.first_capture, now)));\n }\n\n if (path === '/api') return html(view.apiPage());\n\n if (path === '/api/prices.json') {\n const rows = await db.currentPrices(client);\n return json({\n generated_at: now,\n unit: { video: 'USD per finished second', image: 'USD per finished image' },\n count: rows.length,\n prices: rows.map((r) => ({\n model: r.slug, display_name: r.display_name, vendor: r.vendor, modality: r.modality,\n provider: r.provider, tier: r.tier, resolution: r.resolution,\n native: { price: r.native_price, currency: r.native_currency, unit: r.native_unit, fx_rate: r.fx_rate },\n usd: r.normalised_price_usd, captured_at: r.captured_at,\n parse_confidence: r.parse_confidence, source_url: r.source_url,\n stale: isStale(r.captured_at, now),\n })),\n });\n }\n\n if (path === '/api/changes.json') {\n const changes = await db.recentChanges(client, 200);\n return json({ generated_at: now, count: changes.length, changes });\n }\n\n if (path === '/api/history.json') {\n const slug = url.searchParams.get('model');\n if (!slug) return json({ error: 'model parameter required' }, 400);\n const model = await db.one(client, 'SELECT * FROM models WHERE slug=?', [slug]);\n if (!model) return json({ error: 'unknown model' }, 404);\n return json({ model: model.slug, history: await db.history(client, model.id) });\n }\n\n if (path.startsWith('/go/')) {\n const provider = decodeURIComponent(path.slice('/go/'.length));\n const target = PROVIDER_URL[provider];\n if (!target) return json({ error: 'unknown provider' }, 404);\n await db.recordClick(client, provider, url.searchParams.get('m'), now, request.headers.get('referer'));\n return redirect(target);\n }\n\n if (path === '/admin') {\n const token = url.searchParams.get('key') || request.headers.get('x-admin-key');\n if (!ctx.adminKey || token !== ctx.adminKey) {\n return new Response('Unauthorized', { status: 401 });\n }\n const pending = await db.pendingChanges(client);\n const runs = await db.all(client, 'SELECT * FROM collector_runs ORDER BY started_at DESC, id DESC LIMIT 20');\n return html(view.adminPage(pending, runs, await db.stats(client)));\n }\n\n return html(view.layout('Not found', '

Not found

Nothing at that address.

'), 404);\n}\n",[],[162,234],"00290575-8481-4d47-a96c-45913707b521","render.js","aaa4ee6e-a795-11f1-b0b9-1607ee4eb77e",14,["D",1788439667966],"// Server-rendered HTML. No framework, no external assets, no build step.\nimport { formatUsd } from './normalise.js';\nimport { isStale } from './policy.js';\n\nexport function esc(s) {\n return String(s === null || s === undefined ? '' : s)\n .replace(/&/g, '&').replace(//g, '>')\n .replace(/\"/g, '"').replace(/'/g, ''');\n}\n\nconst CSS = `\n:root{--bg:#fbfaf8;--fg:#1a1a19;--muted:#6b6a66;--line:#e3e0d9;--card:#fff;--up:#a8321e;--down:#1d6b45;--accent:#2a4d8f;--chip:#f0ede7}\n:root[data-theme=dark],@media(prefers-color-scheme:dark){}\n@media(prefers-color-scheme:dark){:root:not([data-theme=light]){--bg:#131312;--fg:#eceae5;--muted:#9c9a93;--line:#2c2b28;--card:#1b1b19;--up:#e8785f;--down:#5fbf8f;--accent:#8fb3f0;--chip:#232320}}\n:root[data-theme=dark]{--bg:#131312;--fg:#eceae5;--muted:#9c9a93;--line:#2c2b28;--card:#1b1b19;--up:#e8785f;--down:#5fbf8f;--accent:#8fb3f0;--chip:#232320}\n*{box-sizing:border-box}\nbody{margin:0;background:var(--bg);color:var(--fg);font:15px/1.55 ui-sans-serif,system-ui,-apple-system,\"Segoe UI\",Roboto,sans-serif}\n.wrap{max-width:1040px;margin:0 auto;padding:24px 18px 72px}\nheader.site{display:flex;flex-wrap:wrap;gap:14px;align-items:baseline;justify-content:space-between;border-bottom:1px solid var(--line);padding-bottom:14px;margin-bottom:22px}\n.brand{font-weight:650;font-size:17px;letter-spacing:-.01em;text-decoration:none;color:var(--fg)}\nnav a{color:var(--muted);text-decoration:none;margin-left:14px;font-size:14px}\nnav a:hover,a:hover{color:var(--accent)}\nh1{font-size:26px;line-height:1.2;letter-spacing:-.02em;margin:0 0 6px}\nh2{font-size:18px;margin:32px 0 10px}\n.sub{color:var(--muted);margin:0 0 22px;max-width:62ch}\n.tablewrap{overflow-x:auto;border:1px solid var(--line);border-radius:10px;background:var(--card)}\ntable{border-collapse:collapse;width:100%;font-size:14px;min-width:640px}\nth,td{text-align:left;padding:9px 12px;border-bottom:1px solid var(--line);white-space:nowrap}\nth{font-weight:600;font-size:12px;text-transform:uppercase;letter-spacing:.04em;color:var(--muted)}\ntr:last-child td{border-bottom:0}\ntd.num,th.num{text-align:right;font-variant-numeric:tabular-nums}\n.up{color:var(--up)}.down{color:var(--down)}\n.chip{display:inline-block;background:var(--chip);border-radius:999px;padding:1px 8px;font-size:11px;color:var(--muted)}\n.stale{color:var(--up);font-size:11px}\n.spon{background:var(--chip)}\n.meta{color:var(--muted);font-size:12.5px}\n.card{border:1px solid var(--line);border-radius:10px;background:var(--card);padding:16px;margin:14px 0}\ninput[type=email],input[type=number],select{background:var(--bg);color:var(--fg);border:1px solid var(--line);border-radius:7px;padding:8px 10px;font:inherit;font-size:14px}\nbutton{background:var(--fg);color:var(--bg);border:0;border-radius:7px;padding:9px 14px;font:inherit;font-weight:550;cursor:pointer}\nfooter{margin-top:44px;padding-top:16px;border-top:1px solid var(--line);color:var(--muted);font-size:12.5px}\n.kpi{display:flex;gap:22px;flex-wrap:wrap;margin:0 0 20px}\n.kpi div{font-size:13px;color:var(--muted)}\n.kpi b{display:block;font-size:21px;color:var(--fg);font-variant-numeric:tabular-nums}\n.filters{margin:16px 0 10px;display:flex;gap:8px;flex-wrap:wrap}\n.filters a{font-size:13px;padding:4px 11px;border:1px solid var(--line);border-radius:999px;text-decoration:none;color:var(--muted)}\n.filters a[aria-current=true]{background:var(--fg);color:var(--bg);border-color:var(--fg)}\n.spark{display:block}\n`;\n\nexport function layout(title, body, opts = {}) {\n return `\n\n${esc(title)}\n\n\n

Inference Index\n

\n${body}\n\n

`;\n}\n\nfunction delta(pct) {\n if (pct === null || pct === undefined) return 'new';\n if (pct === 0) return '0%';\n const cls = pct > 0 ? 'up' : 'down';\n const sign = pct > 0 ? '+' : '';\n return `${sign}${(pct * 100).toFixed(1)}%`;\n}\n\nexport function homePage(rows, ctx) {\n const modality = ctx.modality || 'all';\n const filtered = rows.filter((r) => modality === 'all' || r.modality === modality);\n const body = `\n

What AI generation actually costs, and what it cost before

Every other price page shows you today. This one keeps the history, records every change, and tells you before your bill changes. ${esc(ctx.stats.models)} models tracked, ${esc(ctx.stats.price_points)} observations, ${esc(ctx.days_of_history)} days of history.

${esc(ctx.stats.models)}models tracked

${esc(ctx.stats.changes)}price changes recorded

${esc(ctx.days_of_history)}days of history

\n All\n Video\n Image\n

\n\n\n${filtered.map((r) => `\n\n\n\n\n\n\n\n`).join('\\n')}\n

Model	Vendor	Provider	Res	Price	30 days	Verified
${esc(r.display_name)}${r.status !== 'active' ? ` ${esc(r.status)}` : ''}${r.sponsored ? ' sponsor' : ''}	${esc(r.vendor)}	${esc(r.provider)}	${esc(r.resolution)}	${esc(formatUsd(r.normalised_price_usd, r.modality))}	${delta(r.pct_30d)}	${esc(r.captured_at.slice(0, 10))}${r.stale ? ' stale' : ''}

Video prices are USD per finished second at the resolution quoted by the provider. Image prices are USD per finished image. We never rescale one resolution into another, because no provider publishes a conversion factor and the result would be invented.

`;\n return layout('Inference Index, AI image and video model prices', body);\n}\n\nexport function sparkline(points, w = 560, h = 90) {\n if (points.length < 2) return '

Not enough history yet. The chart appears after the second observation.

';\n const xs = points.map((p) => Date.parse(p.captured_at));\n const ys = points.map((p) => p.normalised_price_usd);\n const x0 = Math.min(...xs), x1 = Math.max(...xs);\n const y0 = Math.min(...ys), y1 = Math.max(...ys);\n const px = (x) => (x1 === x0 ? 4 : 4 + ((x - x0) / (x1 - x0)) * (w - 8));\n const py = (y) => (y1 === y0 ? h / 2 : h - 8 - ((y - y0) / (y1 - y0)) * (h - 20));\n const d = points.map((p, i) => `${i ? 'L' : 'M'}${px(Date.parse(p.captured_at)).toFixed(1)},${py(p.normalised_price_usd).toFixed(1)}`).join(' ');\n const dots = points.map((p) => ``).join('');\n return ``;\n}\n\nexport function modelPage(model, points, changes, ctx) {\n const latest = points.length ? points[points.length - 1] : null;\n const body = `\n

${esc(model.display_name)} pricing

${esc(model.vendor)} ${esc(model.modality)} model.${model.status !== 'active' ? ` Status: ${esc(model.status)}${model.sunset_date ? `, ${esc(model.sunset_date)}` : ''}.` : ''} ${latest ? `Currently ${esc(formatUsd(latest.normalised_price_usd, model.modality))} at ${esc(latest.resolution)} on ${esc(latest.provider)}, last verified ${esc(latest.captured_at.slice(0, 10))}.` : ''}

${sparkline(points)}

Every observation

\n\n${points.slice().reverse().map((p) => `\n\n\n\n\n\n\n`).join('')}

Captured	Provider	Res	Quoted	Normalised	Source
${esc(p.captured_at.slice(0, 10))}	${esc(p.provider)}	${esc(p.resolution)}	${esc(p.native_price)} ${esc(p.native_currency)} ${esc(p.native_unit.replace('per_', 'per '))}${p.native_currency !== 'USD' ? ` fx ${esc(p.fx_rate)}` : ''}	${esc(formatUsd(p.normalised_price_usd, model.modality))}	source${p.parse_confidence < 1 ? ` confidence ${esc(p.parse_confidence)}` : ''}

\n${changes.length ? `

Change log

${esc(c.detected_at.slice(0, 10))}: ${c.old_value === null ? 'first recorded at' : `${esc(Number(c.old_value).toFixed(4))} to`} ${esc(Number(c.new_value).toFixed(4))} USD${c.pct_change !== null ? ` (${(c.pct_change * 100).toFixed(1)}%)` : ''} source

` : ''}\n${model.notes ? `

Note: ${esc(model.notes)}

` : ''}\n

Get an alert when this price changes

`;\n return layout(`${model.display_name} pricing and price history`, body, {\n description: `Current and historical API pricing for ${model.display_name}, with every recorded change and its source.`,\n });\n}\n\nexport function changesPage(changes) {\n const body = `\n

Price changes

Every recorded change across image and video generation models, newest first. RSS.

\n${changes.length === 0 ? '

No changes recorded yet. The feed fills as the collector runs.

' : ''}\n

\n\n${changes.map((c) => `\n\n\n\n\n\n\n\n`).join('')}

Date	Model	Provider	From	To	Change	Source
${esc(c.detected_at.slice(0, 10))}	${esc(c.display_name)}	${esc(c.provider)}	${c.old_value === null ? 'new' : esc(Number(c.old_value).toFixed(4))}	${esc(Number(c.new_value).toFixed(4))}	${delta(c.pct_change)}	source

`;\n return layout('AI model price changes', body);\n}\n\nexport function rss(changes, origin) {\n const items = changes.map((c) => `\n${esc(c.display_name)}: ${c.old_value === null ? 'now tracked at' : `${Number(c.old_value).toFixed(4)} to`} ${Number(c.new_value).toFixed(4)} USD${c.pct_change !== null && c.pct_change !== 0 ? ` (${(c.pct_change * 100).toFixed(1)}%)` : ''}\n${esc(origin)}/model/${esc(c.slug)}\nchange-${esc(c.id)}\n${new Date(c.detected_at).toUTCString()}\n${esc(c.provider)} ${esc(c.resolution)}. Source: ${esc(c.source_url)}\n`).join('\\n');\n return `\nInference Index price changes\n${esc(origin)}/changes\nEvery recorded price change for AI image and video generation models.\n${items}\n`;\n}\n\nexport function calculatorPage(rows) {\n const data = rows.map((r) => ({ n: r.display_name, p: r.provider, m: r.modality, v: r.normalised_price_usd, r: r.resolution }));\n const body = `\n

What it will actually cost you

Sticker price assumes every generation is usable. It never is. Set a realistic failure rate and see the number you will really pay.

\nVolume per month \nof \nretry and failure rate %\n

Model	Provider	Res	Sticker	Real cost

\n`;\n return layout('AI generation cost calculator', body);\n}\n\nexport function subscribePage(msg, watch) {\n const body = `\n

Price change alerts

Email when a model you watch changes price, a promotional rate expires, or a model is deprecated. Free tier watches three models and sends a weekly digest. Pro is unlimited models, instant alerts and webhooks at EUR 19 per month.

\n${msg ? `

${esc(msg)}

` : ''}\n`;\n return layout('AI model price change alerts', body);\n}\n\nexport function sponsorPage(clicks, stats, days) {\n const total = clicks.reduce((a, c) => a + c.clicks, 0);\n const body = `\n

Sponsor a row

The numbers below are live from the database, not a media kit. Buy a slot without talking to anyone.

${esc(total)}outbound clicks, last 30 days

${esc(stats.models)}models listed

${esc(days)}days of price history

Clicks we sent, by provider

\n${clicks.length ? clicks.map((c) => ``).join('') : ''}

Provider	Clicks, 30 days
${esc(c.provider)}	${esc(c.clicks)}
No clicks recorded yet.

What a sponsored row is

Your row carries your logo and a \"sponsor\" label. It does not move up the table. Ranking is by price, always, and that is the only reason anyone trusts this page. EUR 300 per month for the modality section, EUR 800 for the whole site. Cancel any time.

Self serve checkout goes here once Stripe is connected. Until then, email the address in the footer.

`;\n return layout('Sponsor the Inference Index', body);\n}\n\nexport function apiPage() {\n const body = `\n

Data API

Everything on this site as JSON. Current prices are free and unauthenticated. History and change feeds are EUR 29 per month, and the full historical export is EUR 149 one off.

GET /api/prices.json

Current normalised price for every model and provider. Free.

GET /api/changes.json

Recorded changes, newest first. Free for the last 30 days.

GET /api/history.json?model=SLUG

Every observation for one model. Requires a key.

No rate limits worth mentioning. Attribution appreciated, not required.

`;\n return layout('Inference Index API', body);\n}\n\nexport function adminPage(pending, runs, stats) {\n const body = `\n

Admin

${esc(pending.length)}awaiting your call

${esc(stats.price_points)}observations

${esc(stats.subscribers)}subscribers

Pending vetoes and holds

\n${pending.length === 0 ? '

Nothing waiting. This is the normal state.

' : `

\n\n${pending.map((p) => ``).join('')}

Detected	Model	Provider	From	To	Status	Why
${esc(p.detected_at.slice(0, 16).replace('T', ' '))}	${esc(p.display_name)}	${esc(p.provider)}	${p.old_value === null ? 'new' : esc(p.old_value)}	${esc(p.new_value)}	${esc(p.status)}	${esc(p.note)}

`}\n

Collector health

\n${runs.map((r) => ``).join('')}

Provider	Last run	OK	Rows	Error
${esc(r.provider)}	${esc(r.started_at.slice(0, 16).replace('T', ' '))}	${r.ok ? 'yes' : 'no'}	${esc(r.found)}	${esc(r.error \|\| '')}

`;\n return layout('Admin', body);\n}\n",[],[162,242],"bf3e7d29-bf21-4bc2-ba30-f0eda6203750","policy.js","27590b00-a793-11f1-8b39-1607ee4eb77e",3,["D",1788438588727],"// Confidence-tiered publishing policy.\n//\n// The rule that outranks every other rule: a wrong number published silently is\n// worse than a missed update. When the parse is not clean, we hold and keep the\n// last known good value marked stale.\n\nexport const AUTO_LIMIT = 0.10; // under 10 percent: publish, log only\nexport const FLAG_LIMIT = 0.50; // 10 to 50 percent: publish, flag in the daily note\nexport const VETO_HOURS = 6; // over 50 percent: hold for a veto window\nexport const MIN_CONFIDENCE = 0.8;\nexport const STALE_HOURS = 72;\n\n/**\n * Decide what to do with a freshly collected candidate.\n * @param {{normalised_price_usd:number, parse_confidence:number}|null} previous last stored point, null if new\n * @param {{normalised_price_usd:number, parse_confidence:number, missing?:boolean}} candidate\n * @returns {{action:'insert_new'|'publish'|'flag'|'veto'|'hold', status:string, pct:number|null, reason:string}}\n */\nexport function decide(previous, candidate) {\n if (candidate.missing) {\n return { action: 'veto', status: 'pending_veto', pct: null, reason: 'model disappeared from source' };\n }\n if (!Number.isFinite(candidate.normalised_price_usd)) {\n return { action: 'hold', status: 'held', pct: null, reason: 'unparseable price' };\n }\n if (candidate.parse_confidence < MIN_CONFIDENCE) {\n return { action: 'hold', status: 'held', pct: null, reason: `parse confidence ${candidate.parse_confidence} below ${MIN_CONFIDENCE}` };\n }\n if (!previous) {\n return { action: 'insert_new', status: 'auto_published', pct: null, reason: 'first observation' };\n }\n\n const oldP = previous.normalised_price_usd;\n const newP = candidate.normalised_price_usd;\n\n if (newP === 0 && oldP !== 0) {\n return { action: 'veto', status: 'pending_veto', pct: -1, reason: 'price dropped to zero' };\n }\n if (oldP === 0) {\n return { action: 'veto', status: 'pending_veto', pct: null, reason: 'price rose from zero' };\n }\n\n const pct = (newP - oldP) / oldP;\n const mag = Math.abs(pct);\n\n if (mag === 0) return { action: 'publish', status: 'auto_published', pct: 0, reason: 'unchanged' };\n if (mag < AUTO_LIMIT) return { action: 'publish', status: 'auto_published', pct, reason: 'small change' };\n if (mag <= FLAG_LIMIT) return { action: 'flag', status: 'auto_published', pct, reason: 'material change, flagged' };\n return { action: 'veto', status: 'pending_veto', pct, reason: 'change over 50 percent' };\n}\n\n/** Has a veto window expired? Silence means publish. */\nexport function vetoExpired(detectedAtIso, nowIso) {\n const detected = Date.parse(detectedAtIso);\n const now = Date.parse(nowIso);\n return now - detected >= VETO_HOURS * 3600 * 1000;\n}\n\n/** Is a stored value old enough that the site must show it as stale? */\nexport function isStale(capturedAtIso, nowIso) {\n return Date.parse(nowIso) - Date.parse(capturedAtIso) > STALE_HOURS * 3600 * 1000;\n}\n",[],[162,250],"57a98c99-4416-4ca2-a7ba-b5c3c160f0d2","normalise.js","390bdf12-a793-11f1-883f-1607ee4eb77e",5,["D",1788438618382],"// Unit and currency normalisation.\n//\n// This is the most important file in the project. If it is wrong, every number\n// on the site is wrong. It is pure: no database, no network, no clock.\n//\n// Canonical figures:\n// video -> USD per finished second, at the quoted resolution\n// image -> USD per finished image, at the quoted resolution\n//\n// Deliberate decision: we do NOT rescale a 1080p price into a 720p price.\n// No provider publishes a conversion factor, so any such number would be invented.\n// We store the resolution alongside the price and only ever compare like with like.\n\nexport const VIDEO_UNITS = ['per_second', 'per_minute', 'per_generation', 'per_clip'];\nexport const IMAGE_UNITS = ['per_image', 'per_generation', 'per_megapixel'];\n\nexport class NormaliseError extends Error {}\n\n/** Megapixels implied by a resolution label such as \"1024x1024\" or \"720p\". */\nexport function megapixels(resolution) {\n if (!resolution) throw new NormaliseError('resolution required for per_megapixel pricing');\n const wh = String(resolution).toLowerCase().match(/^(\\d+)\\s*[x×]\\s*(\\d+)$/);\n if (wh) return (Number(wh[1]) * Number(wh[2])) / 1000000;\n const p = String(resolution).toLowerCase().match(/^(\\d+)p$/);\n if (p) {\n const h = Number(p[1]);\n const w = Math.round((h * 16) / 9);\n return (w * h) / 1000000;\n }\n throw new NormaliseError('cannot derive megapixels from resolution \"' + resolution + '\"');\n}\n\n/**\n * @param {object} q quoted price\n * @param {'video'|'image'} q.modality\n * @param {string} q.native_unit\n * @param {number} q.native_price\n * @param {string} [q.native_currency] ISO code, default USD\n * @param {number} [q.fx_rate] USD per 1 unit of native_currency, default 1\n * @param {number} [q.clip_seconds] required for video priced per_generation / per_clip\n * @param {number} [q.outputs] images produced per generation, default 1\n * @param {string} [q.resolution] required for per_megapixel\n * @returns {number} USD per finished second (video) or per finished image (image)\n */\nexport function normalise(q) {\n const modality = q.modality;\n const unit = q.native_unit;\n const price = q.native_price;\n const currency = q.native_currency || 'USD';\n const fx = q.fx_rate === undefined ? 1 : q.fx_rate;\n const clip = q.clip_seconds;\n const outputs = q.outputs === undefined ? 1 : q.outputs;\n const resolution = q.resolution;\n\n if (modality !== 'video' && modality !== 'image') throw new NormaliseError('unknown modality \"' + modality + '\"');\n if (typeof price !== 'number' || !Number.isFinite(price) || price < 0) {\n throw new NormaliseError('native_price must be a non-negative number, got ' + price);\n }\n if (typeof fx !== 'number' || !Number.isFinite(fx) || fx <= 0) {\n throw new NormaliseError('fx_rate must be positive, got ' + fx);\n }\n if (currency === 'USD' && fx !== 1) {\n throw new NormaliseError('fx_rate must be 1 when native_currency is USD');\n }\n\n const usd = price * fx;\n let out;\n\n if (modality === 'video') {\n if (unit === 'per_second') {\n out = usd;\n } else if (unit === 'per_minute') {\n out = usd / 60;\n } else if (unit === 'per_generation' || unit === 'per_clip') {\n if (!clip || clip <= 0) throw new NormaliseError(unit + ' video pricing needs clip_seconds');\n out = usd / clip;\n } else {\n throw new NormaliseError('unit \"' + unit + '\" is not valid for video');\n }\n } else {\n if (unit === 'per_image') {\n out = usd;\n } else if (unit === 'per_generation') {\n if (!outputs || outputs <= 0) throw new NormaliseError('per_generation image pricing needs outputs');\n out = usd / outputs;\n } else if (unit === 'per_megapixel') {\n out = usd * megapixels(resolution);\n } else {\n throw new NormaliseError('unit \"' + unit + '\" is not valid for image');\n }\n }\n\n // Round to 8 decimals. Cheap image models are priced at 2e-4, so 2 decimals would flatten them to zero.\n return Math.round(out * 1e8) / 1e8;\n}\n\n/** Human display of a normalised figure, with the unit spelled out. */\nexport function formatUsd(value, modality) {\n const unit = modality === 'video' ? '/s' : '/img';\n if (!Number.isFinite(value)) return 'n/a';\n if (value === 0) return '$0' + unit;\n const dp = value < 0.001 ? 6 : value < 0.1 ? 4 : 3;\n let s = value.toFixed(dp);\n // Trim trailing zeros but always keep money-shaped, at least two decimals.\n while (s.endsWith('0') && s.split('.')[1].length > 2) s = s.slice(0, -1);\n return '$' + s + unit;\n}\n",[],[162,258],"03ae7e06-f706-4330-9bb4-31ac5f4015b3","ingest.js","6d918a5c-a793-11f1-9f21-1607ee4eb77e",10,["D",1788438706509],"// The collection pipeline: fetch -> parse -> normalise -> policy -> store.\n// Nothing here decides what is true. It records what a source said, when, and\n// how confident the parse was, and defers every risky call to policy.js.\n\nimport { normalise } from './normalise.js';\nimport { decide } from './policy.js';\nimport { htmlToText } from './collectors/html.js';\nimport * as db from './db.js';\n\nexport function slugify(name) {\n return String(name)\n .toLowerCase()\n .replace(/[^a-z0-9]+/g, '-')\n .replace(/^-+|-+$/g, '')\n .slice(0, 64);\n}\n\n/**\n * @param {object} client sqlite client\n * @param {Array} collectors\n * @param {object} ctx {now: ISO string, fetchImpl, fixtures?: {provider: text}}\n */\nexport async function runCollection(client, collectors, ctx) {\n const now = ctx.now || new Date().toISOString();\n const report = { started_at: now, providers: [], published: 0, flagged: [], vetoed: [], held: [], errors: [] };\n\n for (const c of collectors) {\n const started = now;\n let text = null;\n let error = null;\n\n try {\n if (ctx.fixtures && ctx.fixtures[c.provider] !== undefined) {\n text = ctx.fixtures[c.provider];\n } else {\n const res = await ctx.fetchImpl(c.source_url, {\n headers: { 'User-Agent': ctx.userAgent || 'InferenceIndexBot/1.0 (+https://example.com/about)' },\n });\n if (!res.ok) throw new Error('HTTP ' + res.status);\n const body = await res.text();\n text = /<[a-z][\\s\\S]*>/i.test(body) ? htmlToText(body) : body;\n }\n } catch (e) {\n error = String(e && e.message ? e.message : e);\n }\n\n let candidates = [];\n if (!error) {\n try {\n candidates = c.parse(text) || [];\n if (candidates.length === 0) error = 'parsed zero rows, treating as a parse failure';\n } catch (e) {\n error = 'parse threw: ' + String(e && e.message ? e.message : e);\n }\n }\n\n await db.run(\n client,\n `INSERT INTO collector_runs (provider, started_at, finished_at, ok, found, error) VALUES (?,?,?,?,?,?)`,\n [c.provider, started, now, error ? 0 : 1, candidates.length, error]\n );\n\n if (error) {\n report.providers.push({ provider: c.provider, ok: false, found: 0, error });\n report.errors.push({ provider: c.provider, error });\n continue;\n }\n\n for (const cand of candidates) {\n const outcome = await ingestCandidate(client, c, cand, now);\n if (outcome.action === 'flag') report.flagged.push(outcome);\n else if (outcome.action === 'veto') report.vetoed.push(outcome);\n else if (outcome.action === 'hold') report.held.push(outcome);\n if (outcome.stored) report.published++;\n }\n\n report.providers.push({ provider: c.provider, ok: true, found: candidates.length, error: null });\n }\n\n report.finished_at = now;\n return report;\n}\n\nexport async function ingestCandidate(client, collector, cand, now) {\n const slug = cand.slug || slugify(cand.display_name);\n const model = await db.upsertModel(\n client,\n {\n slug,\n display_name: cand.display_name,\n vendor: cand.vendor || collector.vendor_fallback || collector.provider,\n modality: cand.modality,\n status: cand.status || 'active',\n sunset_date: cand.sunset_date,\n notes: cand.notes,\n },\n now\n );\n\n let normalised;\n try {\n normalised = normalise({\n modality: cand.modality,\n native_unit: cand.native_unit,\n native_price: cand.native_price,\n native_currency: cand.native_currency,\n fx_rate: cand.fx_rate,\n clip_seconds: cand.clip_seconds,\n outputs: cand.outputs,\n resolution: cand.resolution,\n });\n } catch (e) {\n normalised = NaN;\n }\n\n const tier = cand.tier || 'standard';\n const resolution = cand.resolution || 'unspecified';\n const previous = await db.latestFor(client, model.id, collector.provider, tier, resolution);\n const verdict = decide(previous, {\n normalised_price_usd: normalised,\n parse_confidence: cand.parse_confidence === undefined ? 1 : cand.parse_confidence,\n });\n\n const sourceUrl = cand.source_url || collector.source_url;\n const base = {\n model_id: model.id,\n provider: collector.provider,\n endpoint_url: cand.endpoint_url,\n tier,\n resolution,\n native_unit: cand.native_unit,\n native_price: cand.native_price,\n native_currency: cand.native_currency || 'USD',\n fx_rate: cand.fx_rate === undefined ? 1 : cand.fx_rate,\n normalised_price_usd: normalised,\n clip_seconds: cand.clip_seconds,\n outputs: cand.outputs,\n source_url: sourceUrl,\n captured_at: now,\n parse_confidence: cand.parse_confidence === undefined ? 1 : cand.parse_confidence,\n is_promotional: cand.is_promotional,\n promo_ends_at: cand.promo_ends_at,\n };\n\n const result = { model: model.slug, provider: collector.provider, action: verdict.action, reason: verdict.reason, pct: verdict.pct, stored: false };\n\n if (verdict.action === 'hold') {\n await db.insertChange(client, {\n model_id: model.id, provider: collector.provider, tier, resolution,\n field_changed: 'normalised_price_usd',\n old_value: previous ? previous.normalised_price_usd : null,\n new_value: Number.isFinite(normalised) ? normalised : null,\n pct_change: verdict.pct, detected_at: now, status: 'held',\n source_url: sourceUrl, note: verdict.reason,\n });\n return result; // last known good value stays current, and the UI marks it stale\n }\n\n if (verdict.action === 'veto') {\n await db.insertChange(client, {\n model_id: model.id, provider: collector.provider, tier, resolution,\n field_changed: 'normalised_price_usd',\n old_value: previous ? previous.normalised_price_usd : null,\n new_value: Number.isFinite(normalised) ? normalised : null,\n pct_change: verdict.pct, detected_at: now, status: 'pending_veto',\n source_url: sourceUrl, note: verdict.reason,\n });\n return result;\n }\n\n // insert_new, publish, flag all store the point\n await db.insertPricePoint(client, base);\n result.stored = true;\n\n const changed = !previous || previous.normalised_price_usd !== normalised;\n if (changed) {\n await db.insertChange(client, {\n model_id: model.id, provider: collector.provider, tier, resolution,\n field_changed: previous ? 'normalised_price_usd' : 'first_seen',\n old_value: previous ? previous.normalised_price_usd : null,\n new_value: normalised, pct_change: verdict.pct,\n detected_at: now, published_at: now, status: 'auto_published',\n source_url: sourceUrl, note: verdict.reason,\n });\n }\n return result;\n}\n\n/** Release veto windows whose 6 hours have elapsed. Silence means publish. */\nexport async function releaseVetoes(client, now) {\n const { vetoExpired } = await import('./policy.js');\n const pending = await db.all(client, \"SELECT * FROM changes WHERE status='pending_veto'\");\n let released = 0;\n for (const ch of pending) {\n if (!vetoExpired(ch.detected_at, now)) continue;\n if (ch.new_value === null) continue;\n const model = await db.one(client, 'SELECT * FROM models WHERE id=?', [ch.model_id]);\n const prev = await db.latestFor(client, ch.model_id, ch.provider, ch.tier, ch.resolution);\n await db.insertPricePoint(client, {\n model_id: ch.model_id, provider: ch.provider, tier: ch.tier, resolution: ch.resolution,\n native_unit: prev ? prev.native_unit : 'per_second',\n native_price: Number(ch.new_value),\n native_currency: 'USD', fx_rate: 1,\n normalised_price_usd: Number(ch.new_value),\n source_url: ch.source_url, captured_at: now, parse_confidence: 1,\n });\n await db.run(client, \"UPDATE changes SET status='auto_published', published_at=? WHERE id=?\", [now, ch.id]);\n released++;\n }\n return released;\n}\n",[],[162,266],"c4925a8f-3173-41c2-abb7-169dd1b5332b","db.js","59c2bfe6-a793-11f1-8dc9-1607ee4eb77e",9,["D",1788438673298],"// Thin data layer over a libsql-style client: client.execute({sql, args}) -> {rows}\n// Works unchanged against Val Town std/sqlite and the local node:sqlite shim.\n\nexport async function initSchema(db, schemaSql) {\n for (const stmt of schemaSql.split(';')) {\n const s = stmt.trim();\n if (s) await db.execute(s);\n }\n}\n\nexport async function all(db, sql, args = []) {\n const r = await db.execute({ sql, args });\n return r.rows || [];\n}\n\nexport async function one(db, sql, args = []) {\n const rows = await all(db, sql, args);\n return rows.length ? rows[0] : null;\n}\n\nexport async function run(db, sql, args = []) {\n return db.execute({ sql, args });\n}\n\nexport async function upsertModel(db, m, nowIso) {\n const existing = await one(db, 'SELECT * FROM models WHERE slug = ?', [m.slug]);\n if (existing) return existing;\n await run(\n db,\n `INSERT INTO models (slug, display_name, vendor, modality, status, first_seen_at, sunset_date, notes)\n VALUES (?,?,?,?,?,?,?,?)`,\n [m.slug, m.display_name, m.vendor, m.modality, m.status || 'active', nowIso, m.sunset_date || null, m.notes || null]\n );\n return one(db, 'SELECT * FROM models WHERE slug = ?', [m.slug]);\n}\n\n/** Most recent price point for every (model, provider, tier, resolution) combination. */\nexport async function currentPrices(db) {\n return all(\n db,\n `SELECT p.*, m.slug, m.display_name, m.vendor, m.modality, m.status, m.sunset_date\n FROM price_points p\n JOIN models m ON m.id = p.model_id\n WHERE p.id IN (\n SELECT id FROM (\n SELECT id, ROW_NUMBER() OVER (\n PARTITION BY model_id, provider, tier, resolution\n ORDER BY captured_at DESC, id DESC\n ) AS rn\n FROM price_points\n ) WHERE rn = 1\n )\n ORDER BY m.modality, p.normalised_price_usd ASC`\n );\n}\n\nexport async function latestFor(db, modelId, provider, tier, resolution) {\n return one(\n db,\n `SELECT * FROM price_points\n WHERE model_id=? AND provider=? AND tier=? AND resolution=?\n ORDER BY captured_at DESC, id DESC LIMIT 1`,\n [modelId, provider, tier, resolution]\n );\n}\n\n/** Price as it stood on or before a given date, used for the delta column. */\nexport async function priceAsOf(db, modelId, provider, tier, resolution, isoDate) {\n return one(\n db,\n `SELECT * FROM price_points\n WHERE model_id=? AND provider=? AND tier=? AND resolution=? AND captured_at <= ?\n ORDER BY captured_at DESC, id DESC LIMIT 1`,\n [modelId, provider, tier, resolution, isoDate]\n );\n}\n\nexport async function history(db, modelId) {\n return all(\n db,\n `SELECT * FROM price_points WHERE model_id=? ORDER BY captured_at ASC, id ASC`,\n [modelId]\n );\n}\n\nexport async function insertPricePoint(db, p) {\n await run(\n db,\n `INSERT INTO price_points\n (model_id, provider, endpoint_url, tier, resolution, native_unit, native_price,\n native_currency, fx_rate, normalised_price_usd, clip_seconds, outputs,\n source_url, captured_at, parse_confidence, is_promotional, promo_ends_at)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n [\n p.model_id, p.provider, p.endpoint_url || null, p.tier || 'standard',\n p.resolution || 'unspecified', p.native_unit, p.native_price,\n p.native_currency || 'USD', p.fx_rate === undefined ? 1 : p.fx_rate,\n p.normalised_price_usd, p.clip_seconds || null, p.outputs || 1,\n p.source_url, p.captured_at, p.parse_confidence === undefined ? 1 : p.parse_confidence,\n p.is_promotional ? 1 : 0, p.promo_ends_at || null,\n ]\n );\n}\n\nexport async function insertChange(db, c) {\n await run(\n db,\n `INSERT INTO changes\n (model_id, provider, tier, resolution, field_changed, old_value, new_value,\n pct_change, detected_at, published_at, status, source_url, note)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n [\n c.model_id, c.provider, c.tier || 'standard', c.resolution || 'unspecified',\n c.field_changed,\n c.old_value === undefined || c.old_value === null ? null : String(c.old_value),\n c.new_value === undefined || c.new_value === null ? null : String(c.new_value),\n c.pct_change === undefined ? null : c.pct_change,\n c.detected_at, c.published_at || null, c.status, c.source_url, c.note || null,\n ]\n );\n}\n\nexport async function recentChanges(db, limit = 50) {\n return all(\n db,\n `SELECT c.*, m.slug, m.display_name, m.modality\n FROM changes c JOIN models m ON m.id = c.model_id\n WHERE c.status = 'auto_published'\n ORDER BY c.detected_at DESC, c.id DESC LIMIT ?`,\n [limit]\n );\n}\n\nexport async function pendingChanges(db) {\n return all(\n db,\n `SELECT c.*, m.slug, m.display_name FROM changes c JOIN models m ON m.id = c.model_id\n WHERE c.status IN ('pending_veto','held') ORDER BY c.detected_at DESC`\n );\n}\n\nexport async function recordClick(db, provider, modelSlug, nowIso, referer) {\n await run(\n db,\n `INSERT INTO outbound_clicks (provider, model_slug, clicked_at, referer) VALUES (?,?,?,?)`,\n [provider, modelSlug || null, nowIso, referer || null]\n );\n}\n\nexport async function clickCounts(db, sinceIso) {\n return all(\n db,\n `SELECT provider, COUNT(*) AS clicks FROM outbound_clicks\n WHERE clicked_at >= ? GROUP BY provider ORDER BY clicks DESC`,\n [sinceIso]\n );\n}\n\nexport async function addSubscriber(db, email, nowIso, token) {\n const existing = await one(db, 'SELECT * FROM subscribers WHERE email = ?', [email]);\n if (existing) return { created: false, subscriber: existing };\n await run(\n db,\n `INSERT INTO subscribers (email, created_at, confirm_token) VALUES (?,?,?)`,\n [email, nowIso, token]\n );\n const subscriber = await one(db, 'SELECT * FROM subscribers WHERE email = ?', [email]);\n return { created: true, subscriber };\n}\n\nexport async function stats(db) {\n const models = await one(db, 'SELECT COUNT(*) AS n FROM models');\n const points = await one(db, 'SELECT COUNT(*) AS n FROM price_points');\n const first = await one(db, 'SELECT MIN(captured_at) AS d FROM price_points');\n const subs = await one(db, 'SELECT COUNT(*) AS n FROM subscribers');\n const chg = await one(db, \"SELECT COUNT(*) AS n FROM changes WHERE status='auto_published'\");\n return {\n models: models ? models.n : 0,\n price_points: points ? points.n : 0,\n first_capture: first ? first.d : null,\n subscribers: subs ? subs.n : 0,\n changes: chg ? chg.n : 0,\n };\n}\n",[],[162,274],"18ae63c7-3b0f-4b66-9da5-b4be9c1515c0","wavespeed.js","41f15b98-a798-11f1-8422-1607ee4eb77e","04134d4d-98b2-4f95-a0a7-743e287193a2",25,["D",1788440780777],"// WaveSpeed pricing collector.\n// Source shape (verified 3 Sep 2026): a \"Model / Unit / Price / Output per $1\" table\n// rendered server side, one row per line:\n// \"Nano Banana 2 image $0.07/image 14 images\"\n// \"Kling 3.0 Std second $0.084/second 11.9 seconds\"\n//\n// The same table also lists text models priced per million tokens (\"$5/M\"). Those do\n// not match the pattern and are dropped, which is deliberate: doc 03 section 7 excludes\n// text token pricing.\nimport { lines } from './html.js';\n\n// name, unit column, price, price unit. Non-greedy name so multi-word names survive.\nconst ROW = /^(.+?)\\s+(image|second)\\s+\\$\\s?([0-9]+(?:\\.[0-9]+)?)\\s*\\/\\s*(image|second)\\b/i;\n\nexport function parseWavespeedPricing(text) {\n const out = [];\n for (const l of lines(text)) {\n if (!l || /^Model\\s+Unit\\s+Price/i.test(l)) continue;\n const m = l.match(ROW);\n if (!m) continue;\n\n // The unit column and the price unit must agree. If they ever disagree the row is\n // ambiguous, so it is dropped rather than guessed at.\n if (m[2].toLowerCase() !== m[4].toLowerCase()) continue;\n\n const isImage = m[4].toLowerCase() === 'image';\n out.push({\n display_name: m[1].trim(),\n vendor: 'wavespeed',\n modality: isImage ? 'image' : 'video',\n native_unit: isImage ? 'per_image' : 'per_second',\n native_price: Number(m[3]),\n native_currency: 'USD',\n fx_rate: 1,\n // WaveSpeed does not print a resolution on this table. Saying \"unspecified\" is\n // honest; inventing 720p would not be.\n resolution: 'unspecified',\n tier: 'standard',\n outputs: 1,\n parse_confidence: 1,\n });\n }\n return out;\n}\n\nexport const wavespeedCollector = {\n provider: 'wavespeed',\n vendor_fallback: 'wavespeed',\n source_url: 'https://wavespeed.ai/pricing',\n parse: parseWavespeedPricing,\n needs_live_verification: false,\n};\n",[],[162,290,282],"collectors","bc5065b2-e41a-4b9c-8b86-9793a5dd4041","runway.js","39428846-a798-11f1-bc07-1607ee4eb77e",29,["D",1788440833323],"// Runway Dev pricing collector.\n// Source shape (verified 3 Sep 2026): docs.dev.runwayml.com/guides/pricing/ prices\n// everything in CREDITS, and states the credit value in prose: \"$0.01 per credit\".\n//\n// The credit value is READ FROM THE PAGE, never hardcoded. If Runway changes it and\n// the sentence moves, this throws, the run is recorded as a parse failure, and the\n// site keeps its last verified numbers. That is the correct outcome: a stale price\n// with a visible date beats a silently wrong one.\n//\n// Deliberately skipped, because the page states a RANGE rather than a rate:\n// grok_imagine_image_2 (\"4-8 credits per image, by quality and resolution\")\n// gpt_image_2 (\"1-41 credits per image, by quality and resolution\")\n// Their quality x resolution matrices are further down the page and need the request\n// parameters to resolve. Publishing the midpoint of a range would be inventing a number.\n//\n// Also skipped: upscale, SDR-to-HDR, audio, real-time and recipe sections, the\n// professional/HDR per-second surcharges, and anything billed per second of INPUT.\nimport { lines } from './html.js';\n\n/** \"$0.01 per credit\" -> 0.01 */\nexport function parseCreditValue(ls) {\n for (const l of ls) {\n const m = l.match(/\\$\\s?([0-9]+(?:\\.[0-9]+)?)\\s+per\\s+credit/i);\n if (m) return Number(m[1]);\n }\n throw new Error('credit value sentence not found on the page');\n}\n\n/** A parenthesised qualifier is a resolution if it looks like one, otherwise a tier. */\nfunction classifyQualifier(q) {\n if (!q) return { resolution: 'unspecified', tier: 'standard' };\n const t = q.trim();\n if (/^\\d+\\s*[pPkK](\\s*\\/\\s*\\d+\\s*[pPkK])?$/.test(t.replace(/\\s+/g, ''))) {\n return { resolution: t, tier: 'standard' };\n }\n return { resolution: 'unspecified', tier: t };\n}\n\n/**\n * Lines between a heading and the next heading.\n *\n * The page prints its own table of contents first, so every heading string appears\n * twice. The real heading is the one immediately followed by a \"Section titled ...\"\n * line, which is how the doc generator marks it. Matching the first occurrence would\n * silently return an empty table-of-contents slice and publish nothing, which is how\n * the image section was lost on the first attempt.\n */\nfunction section(ls, startRe, endRes) {\n let start = ls.findIndex((l, i) => startRe.test(l) && /^Section titled/.test(ls[i + 1] || ''));\n if (start < 0) start = ls.findIndex((l) => startRe.test(l));\n if (start < 0) return [];\n const rest = ls.slice(start + 1);\n let end = rest.length;\n for (const re of endRes) {\n const i = rest.findIndex((l) => re.test(l));\n if (i >= 0 && i < end) end = i;\n }\n return rest.slice(0, end);\n}\n\nconst VIDEO_LINE = /^([A-Za-z0-9_.\\-]+)\\s*(?:\$([^)]+)\$)?\\s+([0-9]+(?:\\.[0-9]+)?)\\s+credits?\\s+per\\s+second\\b(.*)$/;\nconst IMAGE_RATE = /([0-9]+(?:\\.[0-9]+)?)\\s+credits?\\s+per\\s+((?:[\\w.]+(?:\\s+or\\s+[\\w.]+)?)\\s+)?image/gi;\nconst RANGE = /[0-9]\\s*[–—-]\\s*[0-9]+\\s+credits?/;\n\nexport function parseRunwayPricing(text) {\n const ls = lines(text).filter((l) => l !== '');\n const creditUsd = parseCreditValue(ls);\n const out = [];\n\n // ---- Video generation\n const video = section(\n ls,\n /^Video Generation Pricing$/i,\n [/^Professional and HDR output formats$/i, /^Image Generation Pricing$/i]\n );\n for (const l of video) {\n const m = l.match(VIDEO_LINE);\n if (!m) continue;\n const trailing = m[4] || '';\n // \"11 credits per second of input video\" is a charge on the input, not the output.\n if (/^\\s*of\\s+input/i.test(trailing)) continue;\n const { resolution, tier } = classifyQualifier(m[2]);\n out.push({\n display_name: m[1],\n vendor: 'runway',\n modality: 'video',\n native_unit: 'per_second',\n native_price: Number((Number(m[3]) * creditUsd).toFixed(8)),\n native_currency: 'USD',\n fx_rate: 1,\n resolution,\n tier,\n outputs: 1,\n parse_confidence: 1,\n });\n }\n\n // ---- Image generation\n const image = section(ls, /^Image Generation Pricing$/i, [/^Image Upscale Pricing$/i]);\n for (const l of image) {\n if (RANGE.test(l)) continue; // a range is not a rate\n const nameMatch = l.match(/^([A-Za-z0-9_.\\-]+)\\s/);\n if (!nameMatch) continue;\n IMAGE_RATE.lastIndex = 0;\n let m;\n while ((m = IMAGE_RATE.exec(l)) !== null) {\n const res = (m[2] || '').trim();\n out.push({\n display_name: nameMatch[1],\n vendor: 'runway',\n modality: 'image',\n native_unit: 'per_image',\n native_price: Number((Number(m[1]) * creditUsd).toFixed(8)),\n native_currency: 'USD',\n fx_rate: 1,\n resolution: res || 'any',\n tier: 'standard',\n outputs: 1,\n parse_confidence: 1,\n });\n }\n }\n\n return out;\n}\n\nexport const runwayCollector = {\n provider: 'runway',\n vendor_fallback: 'runway',\n source_url: 'https://docs.dev.runwayml.com/guides/pricing/',\n parse: parseRunwayPricing,\n needs_live_verification: false,\n};\n",[],[162,290,292],"26c53f44-416a-4278-b219-ca6e36f8e332","replicate.js","422e4bca-a793-11f1-8b80-1607ee4eb77e",7,["D",1788438633740],"// Replicate pricing page collector.\n// Source shape (verified 2 Sep 2026): \"owner/model-name\" on its own line, a\n// description, then one or more \"$X / unit\" lines.\nimport { lines } from './html.js';\n\nconst MODEL_LINE = /^[a-z0-9][a-z0-9-]*\\/[a-z0-9][a-z0-9._-]*$/i;\nconst PRICE_LINE = /^\\$([0-9]+(?:\\.[0-9]+)?)\\s*\\/\\s*(.+)$/;\n\nfunction interpretUnit(priceText, amount) {\n const t = priceText.toLowerCase().trim();\n if (/second of output video/.test(t)) {\n return { modality: 'video', native_unit: 'per_second', native_price: amount, resolution: 'unspecified' };\n }\n if (/thousand output images?/.test(t)) {\n return { modality: 'image', native_unit: 'per_image', native_price: amount / 1000, resolution: 'unspecified' };\n }\n if (/output images?/.test(t)) {\n return { modality: 'image', native_unit: 'per_image', native_price: amount, resolution: 'unspecified' };\n }\n return null; // tokens and anything else: out of scope by design\n}\n\nexport function parseReplicatePricing(text) {\n const ls = lines(text);\n const out = [];\n for (let i = 0; i < ls.length; i++) {\n if (!MODEL_LINE.test(ls[i])) continue;\n const slugPath = ls[i];\n for (let j = i + 1; j < Math.min(i + 12, ls.length); j++) {\n if (MODEL_LINE.test(ls[j])) break;\n const m = ls[j].match(PRICE_LINE);\n if (!m) continue;\n const spec = interpretUnit(m[2], Number(m[1]));\n if (!spec) continue;\n out.push({\n display_name: slugPath,\n vendor: slugPath.split('/')[0],\n modality: spec.modality,\n native_unit: spec.native_unit,\n native_price: spec.native_price,\n native_currency: 'USD',\n fx_rate: 1,\n resolution: /720p/.test(slugPath) ? '720p' : /480p/.test(slugPath) ? '480p' : spec.resolution,\n outputs: 1,\n parse_confidence: 1,\n });\n }\n }\n return out;\n}\n\nexport const replicateCollector = {\n provider: 'replicate',\n vendor_fallback: 'replicate',\n source_url: 'https://replicate.com/pricing',\n parse: parseReplicatePricing,\n needs_live_verification: false,\n};\n",[],[162,290,300],"516f2ceb-86df-4a1e-8eee-9a0e5090441f","html.js","2b15ca08-a793-11f1-84bf-1607ee4eb77e",["D",1788438594966],"// Minimal HTML to text. The collectors parse visible text, not markup, because\n// pricing tables are re-styled far more often than they are reworded.\nconst ENTITIES = { amp: '&', lt: '<', gt: '>', quot: '\"', apos: \"'\", nbsp: ' ', '#39': \"'\", '#x27': \"'\" };\n\nexport function decodeEntities(s) {\n return s.replace(/&(#x?[0-9a-fA-F]+|[a-zA-Z]+);/g, (m, code) => {\n if (ENTITIES[code] !== undefined) return ENTITIES[code];\n if (code[0] === '#') {\n const n = code[1] === 'x' || code[1] === 'X' ? parseInt(code.slice(2), 16) : parseInt(code.slice(1), 10);\n return Number.isFinite(n) ? String.fromCodePoint(n) : m;\n }\n return m;\n });\n}\n\nexport function htmlToText(html) {\n let s = String(html);\n s = s.replace(//gi, ' ');\n s = s.replace(//gi, ' ');\n s = s.replace(//gi, ' ');\n s = s.replace(/<\\/(td|th)>/gi, '\\t');\n s = s.replace(/<\\/(tr|p|div|li|h[1-6]|section)>/gi, '\\n');\n s = s.replace(//gi, '\\n');\n s = s.replace(/<[^>]+>/g, '');\n s = decodeEntities(s);\n s = s.replace(/\\r/g, '');\n s = s.replace(/[ ]+/g, ' ');\n s = s.replace(/\\n{3,}/g, '\\n\\n');\n return s.trim();\n}\n\n/** Split text into logical lines with tabs and padding removed. */\nexport function lines(text) {\n return String(text).split('\\n').map((l) => l.replace(/\\t/g, ' ').trim());\n}\n",[],[162,290,308],"48318e0c-8f9f-4f96-a2ac-141b6fe4b3f6","fal.js","3d8044f2-a793-11f1-af1c-1607ee4eb77e",6,["D",1788438625882],"// fal.ai pricing page collector.\n// Source shape (verified 2 Sep 2026): a \"Model / Unit / Price\" table, split into\n// a Video Models section and an Image Models section.\nimport { lines } from './html.js';\n\nconst UNITS = {\n second: { unit: 'per_second', modality: 'video' },\n video: { unit: 'per_generation', modality: 'video', clip_seconds: 5 },\n image: { unit: 'per_image', modality: 'image' },\n megapixel: { unit: 'per_megapixel', modality: 'image', resolution: '1000x1000' },\n};\n\nconst NOISE = /^(model|unit|price|output per|start building|gpu|vram|list price|as low as|\\*|resources|products)/i;\n\nexport function parseFalPricing(text) {\n const ls = lines(text);\n const out = [];\n for (let i = 0; i < ls.length; i++) {\n const name = ls[i];\n if (!name || NOISE.test(name) || name.includes('$')) continue;\n\n // next two non-empty lines must be a unit keyword then a price\n let j = i + 1;\n while (j < ls.length && ls[j] === '') j++;\n const unitLine = (ls[j] || '').toLowerCase();\n const spec = UNITS[unitLine];\n if (!spec) continue;\n\n let k = j + 1;\n while (k < ls.length && ls[k] === '') k++;\n const m = (ls[k] || '').match(/\\$([0-9]+(?:\\.[0-9]+)?)/);\n if (!m) continue;\n\n out.push({\n display_name: name,\n modality: spec.modality,\n native_unit: spec.unit,\n native_price: Number(m[1]),\n native_currency: 'USD',\n fx_rate: 1,\n clip_seconds: spec.clip_seconds,\n resolution: spec.resolution || (spec.modality === 'video' ? '720p' : '1000x1000'),\n outputs: 1,\n parse_confidence: 1,\n });\n i = k;\n }\n return out;\n}\n\nexport const falCollector = {\n provider: 'fal',\n vendor_fallback: 'fal',\n source_url: 'https://fal.ai/pricing',\n parse: parseFalPricing,\n // fal renders this page client side. If a plain fetch returns a shell, the run\n // is recorded as a parse failure and nothing is published. See README section 6.\n needs_live_verification: true,\n};\n",[],[162,290,315],"775900cc-68d5-41a1-803f-766a6e5bd0d1",["D",1788438594966],[179,180,181,182,183],[162,290],["D",1788438577468],[178,184,185,186,187,188,189,190,191],[162],["D",1788438548015],["D",1789480235853],{"_101":100,"_108":103},{"_101":100,"_102":103,"_104":103,"_18":56,"_105":106,"_107":25},{"_13":90,"_32":91,"_44":43,"_92":45,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":46,"_99":100},"ctx",{"_83":-5,"_127":367,"_368":369,"_370":371,"_372":25,"_373":25,"_374":25,"_375":60,"_376":-5,"_377":-7,"_378":-7,"_379":64,"_380":25,"_381":25,"_382":-5,"_383":25,"_384":25,"_385":25,"_386":-5},"ENV",{"_338":339,"_340":341,"_342":91,"_343":344,"_345":346,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v30