[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_298":299,"_300":301},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_38":-7,"_123":-5,"_19":124,"_125":126,"_127":128,"_129":130,"_131":132,"_21":133,"_134":-5,"_135":-5,"_136":24,"_137":138,"_139":85,"_140":-5,"_141":-5,"_142":143},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","SpeedEX","name","speedex-diesel-agent","branchName","main","path","lib/news.ts","project",{"_32":72,"_13":14,"_36":73,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":83,"_84":85,"_86":-5,"_87":-5,"_88":26,"_40":41,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":94,"_95":94,"_96":97,"_98":97,"_99":97,"_100":94,"_101":94,"_52":102,"_103":104,"_105":106,"_107":24},"file",{"_62":63,"_13":64,"_65":66,"_67":24,"_71":-5},"isDirectory",false,"page",0,"history",[31],"hasNext","userId",{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53,"_21":54,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":60},"id","16d5dead-3cf3-4f6f-991a-063423205586","branchId","184b5693-e711-4133-9930-b43a3d355298","createdAt",["D",1787745689609],"version",28,"orgId","01a03acd-fe07-7408-83aa-f3189a61eb2d","parentId","eed027e3-f3cc-4da5-82e3-ea9573ff7adf","incomingCommitId","aiChatMessageId","85ca90e7-6db2-494e-a8de-1798c406bdd9","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_32":68,"_40":41,"_11":12,"_69":70},{"_62":63,"_13":64,"_65":66,"_67":24},"pull","merge","revert","multiple","commits",[61],{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53,"_21":54,"_55":-5,"_56":-5,"_57":-5},"fileId","df4a4444-a145-11f1-b96e-1607ee4eb77e","news.ts","fileType","script","deleted","eca68b7c-1554-4461-8c04-19038b4f4bb0","avatar","https://lh3.googleusercontent.com/a/ACg8ocLo8ToSnnLb-WXLcA1AUVX__xz1uozWdwd6GlO6BsEGT8GL1A=s96-c","deletedAtVersion","c5cc85c9-bd9f-48d2-add8-c13a76d9b9c6",["D",1787693858683],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Daily diesel (ДП) price digest for @speedex_transportation","imageUrl","pinnedFileId","83522c2c-a0d4-11f1-a917-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_122":70},"org",{"_11":12,"_117":118,"_69":70,"_30":68,"_119":120,"_121":24},"branch",{"_38":108,"_13":16,"_32":35,"_109":72,"_110":-5,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":14,"_116":12},"isOwned",31,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Work Hadar","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":72,"_13":14,"_36":294,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":83,"_84":85,"_86":-5,"_87":-5,"_88":26,"_40":41,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":94,"_95":94,"_96":97,"_98":97,"_99":97,"_100":94,"_101":94,"_52":295,"_103":296,"_105":297,"_107":24},"tree",[166,174,178,179,180],"files",[166,167,168,169,170,171,172,173,174,175,176,177,178,179,180],"counts",{"_154":26,"_155":156,"_157":26,"_158":159,"_160":161},"contents",[],{"_32":144,"_13":64,"_62":63,"_42":145,"_34":35,"_146":39,"_147":85,"_36":148,"_38":26,"_65":66,"_149":150,"_67":24,"_151":-5,"_17":152},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"ec64495a-d2d7-4158-8af7-8f840e16643f","7544c295-a56d-407d-9502-fe0fe0634085","branchVersion","latest",["D",1787745689609],"content","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\n// A fast Gemini model with Google Search grounding. (gemini-2.0-flash is known\n// to misbehave with google_search grounding, so we use a newer Flash model.)\nconst GEMINI_MODEL = \"gemini-3.5-flash\";\nconst GEMINI_URL =\n `https://generativelanguage.googleapis.com/v1beta/models/${GEMINI_MODEL}:generateContent`;\n\n// Counter of successfully published news posts, stored in the same blob storage\n// used for the diesel prices (project-scoped blobs).\nconst NEWS_COUNTER_KEY = \"news:counter\";\n\nconst NEWS_PROMPT = `Search the web with Google Search for the single most important, very recent news item (published within the last 24 to 48 hours) relevant to the freight trucking and logistics industry in Ukraine and the EU, including new rules, laws, or regulations. Prioritize relevance in this order: (1) hired truck drivers, (2) carriers, (3) cargo owners, (4) related businesses.\n\nUse ONLY facts you actually find via your search. Never invent or guess any number, quote, or source. If no sufficiently important and verifiable news item exists for the current day, respond with exactly the text NO_NEWS_TODAY and nothing else.\n\nOtherwise respond with a message formatted exactly as follows, using literal newlines:\nFirst a bold line: 📢Новина дня | #{POST_NUMBER}\nthen a blank line,\nthen three paragraphs, each 50 to 75 words, separated by blank lines:\n- the first paragraph contains only the plain facts of the news itself, no filler;\n- the second paragraph explains the causes and consequences;\n- the third paragraph explains specifically who is affected and why, and who is not affected and why not;\nthen a blank line,\nthen the plain text @speedex_transportation.`;\n\n/** Call the Gemini generateContent API, optionally with Google Search grounding. */\nasync function geminiGenerate(prompt: string, useGoogleSearch: boolean): Promise {\n const apiKey = Deno.env.get(\"GEMINI_API_KEY\");\n if (!apiKey) throw new Error(\"GEMINI_API_KEY env var is not set\");\n\n const body: Record = {\n contents: [{ role: \"user\", parts: [{ text: prompt }] }],\n generationConfig: { temperature: 0.4 },\n };\n if (useGoogleSearch) body.tools = [{ googleSearch: {} }];\n\n const res = await fetch(GEMINI_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"x-goog-api-key\": apiKey },\n body: JSON.stringify(body),\n });\n const data = await res.json().catch(() => null);\n if (!res.ok || !data) {\n throw new Error(`Gemini generateContent failed (${res.status}): ${JSON.stringify(data)}`);\n }\n const parts: { text?: string }[] = data?.candidates?.[0]?.content?.parts ?? [];\n const text = parts.map((p) => p.text ?? \"\").join(\"\").trim();\n if (!text) throw new Error(\"Gemini returned empty content\");\n return text;\n}\n\n/**\n * Build the daily news post for a given post number.\n * Returns the fully formatted Telegram caption, or exactly \"NO_NEWS_TODAY\"\n * (trimmed) when there is no important verifiable news for that day.\n */\nexport async function getNewsPost(postNumber: number): Promise {\n const prompt = NEWS_PROMPT.replaceAll(\"{POST_NUMBER}\", String(postNumber));\n const text = await geminiGenerate(prompt, true);\n return text.trim();\n}\n\n/** Remove the bold header line and the trailing channel handle from the raw text. */\nfunction stripFormatting(newsText: string): string {\n return newsText\n .replace(/.*?<\\/b>\\s?/i, \"\")\n .split(\"\\n\")\n .filter((l) => !l.startsWith(\"@speedex_transportation\"))\n .join(\"\\n\")\n .trim();\n}\n\n/** Extract a short (3-6 word) English topic description from the news text. */\nexport async function extractTopic(newsText: string): Promise {\n const body = stripFormatting(newsText);\n const prompt =\n \"Return a short English description of the topic of this Ukrainian news item, \" +\n \"3 to 6 words, no punctuation, no quotes, nothing else.\\n\\nNews:\\n\" +\n body;\n const t = await geminiGenerate(prompt, false);\n const clean = t.replace(/[^\\w\\s-]/g, \"\").trim().split(/\\s+/).slice(0, 6).join(\" \");\n return clean || \"Ukraine freight trucking and logistics news\";\n}\n\n/**\n * Generate an editorial illustration for the news topic via Pollinations and\n * return the raw image bytes.\n */\nexport async function generateImage(newsText: string): Promise {\n const topic = await extractTopic(newsText);\n const prompt =\n `Editorial illustration in the style of The Economist magazine about ${topic}, ` +\n `minimalist, dramatic lighting, 8k, square 1:1 aspect ratio`;\n const url = new URL(\"https://image.pollinations.ai/prompt/\" + encodeURIComponent(prompt));\n url.searchParams.set(\"width\", \"1024\");\n url.searchParams.set(\"height\", \"1024\");\n url.searchParams.set(\"nologo\", \"true\");\n const res = await fetch(url.toString());\n if (!res.ok) throw new Error(`Pollinations image generation failed (${res.status})`);\n return new Uint8Array(await res.arrayBuffer());\n}\n\n/** The next post number = current count + 1 (does not mutate). */\nexport async function nextPostNumber(): Promise {\n return ((await blob.getJSON(NEWS_COUNTER_KEY)) ?? 0) + 1;\n}\n\n/** Increment the published-post counter and return the new value. */\nexport async function incrementPostCounter(): Promise {\n const n = (await blob.getJSON(NEWS_COUNTER_KEY)) ?? 0;\n await blob.setJSON(NEWS_COUNTER_KEY, n + 1);\n return n + 1;\n}\n","label",[153,64],"lib","pulls","branches",1,"forks","envVars",{"_162":164,"_165":26},"connections",{"_162":26,"_163":26},"count","unfilledCount",2,"emptyCount",{"_32":290,"_13":153,"_62":145,"_42":-5,"_34":35,"_146":285,"_147":85,"_36":291,"_38":26,"_65":234,"_149":-5,"_67":24,"_151":-5,"_187":292,"_17":293},{"_32":282,"_13":283,"_62":284,"_42":145,"_34":35,"_146":285,"_147":85,"_36":286,"_38":26,"_65":66,"_149":287,"_67":24,"_151":-5,"_187":288,"_17":289},{"_32":274,"_13":275,"_62":276,"_42":145,"_34":35,"_146":277,"_147":85,"_36":278,"_38":156,"_65":66,"_149":279,"_67":24,"_151":-5,"_187":280,"_17":281},{"_32":265,"_13":266,"_62":267,"_42":145,"_34":35,"_146":268,"_147":85,"_36":269,"_38":270,"_65":66,"_149":271,"_67":24,"_151":-5,"_187":272,"_17":273},{"_32":144,"_13":64,"_62":63,"_42":145,"_34":35,"_146":39,"_147":85,"_36":262,"_38":26,"_65":66,"_149":150,"_67":24,"_151":-5,"_187":263,"_17":264},{"_32":254,"_13":255,"_62":256,"_42":145,"_34":35,"_146":257,"_147":85,"_36":258,"_38":156,"_65":66,"_149":259,"_67":24,"_151":-5,"_187":260,"_17":261},{"_32":246,"_13":247,"_62":248,"_42":145,"_34":35,"_146":249,"_147":85,"_36":250,"_38":164,"_65":66,"_149":251,"_67":24,"_151":-5,"_187":252,"_17":253},{"_32":237,"_13":238,"_62":239,"_42":145,"_34":35,"_146":240,"_147":85,"_36":241,"_38":242,"_65":66,"_149":243,"_67":24,"_151":-5,"_187":244,"_17":245},{"_32":232,"_13":216,"_62":210,"_42":-5,"_34":35,"_146":211,"_147":85,"_36":233,"_38":26,"_65":234,"_149":-5,"_67":24,"_151":-5,"_187":235,"_17":236},{"_32":225,"_13":226,"_62":227,"_42":210,"_34":35,"_146":108,"_147":85,"_36":228,"_38":26,"_65":66,"_149":229,"_67":24,"_151":-5,"_187":230,"_17":231},{"_32":217,"_13":218,"_62":219,"_42":210,"_34":35,"_146":220,"_147":85,"_36":221,"_38":26,"_65":66,"_149":222,"_67":24,"_151":-5,"_187":223,"_17":224},{"_32":207,"_13":208,"_62":209,"_42":210,"_34":35,"_146":211,"_147":85,"_36":212,"_38":26,"_65":66,"_149":213,"_67":24,"_151":-5,"_187":214,"_17":215},{"_32":198,"_13":199,"_62":83,"_42":-5,"_34":35,"_146":200,"_147":85,"_36":201,"_38":164,"_65":202,"_149":203,"_67":24,"_151":204,"_187":205,"_17":206},{"_32":190,"_13":191,"_62":192,"_42":-5,"_34":35,"_146":193,"_147":85,"_36":194,"_38":156,"_65":185,"_149":195,"_67":24,"_151":-5,"_187":196,"_17":197},{"_32":181,"_13":64,"_62":182,"_42":-5,"_34":35,"_146":183,"_147":85,"_36":184,"_38":26,"_65":185,"_149":186,"_67":24,"_151":-5,"_187":188,"_17":189},"3707d891-3f07-4b14-a8a6-2123de57ec2c","df526f48-a145-11f1-b96e-1607ee4eb77e",29,["D",1787745689660],"interval","import {\n generateImage,\n getNewsPost,\n incrementPostCounter,\n nextPostNumber,\n} from \"./lib/news.ts\";\nimport { sendTelegramPhoto } from \"./lib/telegram.ts\";\n\n// Scheduled Mon-Sat at 16:00 Europe/Kyiv by this file's cron trigger.\nexport default async function (_interval: Interval) {\n const postNumber = await nextPostNumber();\n const newsText = await getNewsPost(postNumber);\n\n // No sufficiently important, verifiable news for today: stop without posting.\n if (newsText === \"NO_NEWS_TODAY\") {\n console.log(\"NO_NEWS_TODAY - no important news, skipping without posting.\");\n return;\n }\n\n console.log(\"News text:\\n\" + newsText);\n\n // DRY_RUN preview mode: log the formatted news and exit without generating an\n // image, posting to Telegram, or incrementing the counter — mirrors the diesel\n // flow guard so we can preview the format before going live.\n if (Deno.env.get(\"DRY_RUN\")) {\n console.log(\n \"DRY_RUN is set - skipping image generation and send. Counter not incremented, nothing posted.\",\n );\n return;\n }\n\n const imageBytes = await generateImage(newsText);\n await sendTelegramPhoto(newsText, imageBytes);\n await incrementPostCounter();\n console.log(`News post #${postNumber} sent to @speedex_transportation`);\n}\n","children",[],[64],"1df7e357-d7a5-4d65-b6df-f884693fa486","main.ts","31b17a96-a0cd-11f1-bfba-1607ee4eb77e",9,["D",1787693904184],"import { runDaily } from \"./lib/run.ts\";\n\n// Scheduled daily (Mon-Sat) at 08:00 Europe/Kyiv by this val's cron trigger.\nexport default async function (_interval: Interval) {\n await runDaily();\n}\n",[],[191],"0641176f-a962-462d-bbdb-bb5db794f594","cover.ts",22,["D",1787697839381],"http","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\n/** Serves the digest cover image from this val's scoped blob storage. */\nexport default async function (_req: Request): Promise {\n try {\n const res = await blob.get(\"v0003.png\");\n // Buffer the full bytes and set an explicit Content-Length. Telegram's\n // photo downloader rejects streamed/chunked (no Content-Length) responses\n // with \"failed to get HTTP URL content\".\n const bytes = new Uint8Array(await res.arrayBuffer());\n return new Response(bytes.buffer, {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Content-Length\": String(bytes.byteLength),\n },\n });\n } catch {\n return new Response(\"v0003.png not found in blob storage\", { status: 404 });\n }\n}\n","speedex-cover",[],[199],"ac41d073-d0e5-4f49-aba3-3e6c43f2c96c","simulate-prev.ts","584c1454-a0d2-11f1-b24a-1607ee4eb77e","467deab0-6038-48c6-a7af-62df006141e9",16,["D",1787696070999],"import { composeMessage } from \"../lib/message.ts\";\n\n// Today's prices (same as the live scrape).\nconst current: Record = {\n \"Parallel\": 89.9,\n \"UKRNAFTA\": 89.9,\n \"VST\": 89.9,\n \"AMIC\": 89.99,\n \"БРСМ-Нафта\": 89.99,\n \"Marshal\": 89.99,\n \"Маркет\": 90.59,\n \"UPG\": 90.9,\n \"Авантаж 7\": 90.95,\n \"Chipo\": 92.1,\n \"WOG\": 93.9,\n \"ОККО\": 93.9,\n \"KLO\": 93.9,\n \"SOCAR\": 94.9,\n};\n\n// Simulated \"yesterday\" prices — a mix of increases, decreases, and no-change\n// so we exercise all three arrows and the up/down/flat sentence.\nconst prev: Record = {\n \"Parallel\": 89.5, // up ▲\n \"UKRNAFTA\": 89.95, // down ▼\n \"VST\": 89.9, // flat →\n \"AMIC\": 89.99, // flat →\n \"БРСМ-Нафта\": 90.05, // down ▼\n \"Marshal\": 90.0, // down ▼\n \"Маркет\": 90.0, // up ▲\n \"UPG\": 91.1, // down ▼\n \"Авантаж 7\": 90.95, // flat →\n \"Chipo\": 91.5, // up ▲\n \"WOG\": 94.1, // down ▼\n \"ОККО\": 93.9, // flat →\n \"KLO\": 94.4, // down ▼\n \"SOCAR\": 94.9, // flat →\n};\n\nconst now = new Date();\nconst text = composeMessage(now, current, prev);\nconsole.log(text);\n",[],[216,208],"scripts","5609eedc-9c82-4e63-af15-704f4d291fa5","preview-today.ts","8870695a-a0d7-11f1-9c3c-1607ee4eb77e",26,["D",1787698299257],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { composeMessage } from \"../lib/message.ts\";\nimport { dateKey } from \"../lib/date.ts\";\n\n// Load today's already-saved prices (no prior day yet -> prev is empty).\nconst today = new Date();\nconst current =\n (await blob.getJSON>(\"prices:\" + dateKey(today))) ?? {};\n\nconsole.log(\"Loaded keys: \" + Object.keys(current).length + \"\\n\");\nconsole.log(composeMessage(today, current, {}));\n",[],[216,218],"0d7d1cb4-f2e5-4e4e-bbc5-beb0550a7eb4","preview-news.ts","e80c4118-a145-11f1-858a-1607ee4eb77e",["D",1787745704303],"import { getNewsPost, nextPostNumber } from \"../lib/news.ts\";\n\n// Mirrors the DRY_RUN branch of news.ts: compose the news from Gemini and print\n// it, but generate no image, post nothing to Telegram, and touch no counter.\n// Safe to run — read-only against the news pipeline.\nconst postNumber = await nextPostNumber();\nconst text = await getNewsPost(postNumber);\n\nif (text === \"NO_NEWS_TODAY\") {\n console.log(\"[DRY RUN] NO_NEWS_TODAY - nothing would be posted today.\");\n} else {\n console.log(`[DRY RUN] Post #${postNumber} (not sent):\\n\\n${text}`);\n}\n",[],[216,226],"8f20ea1a-9463-4cfd-9043-61e73d725677",["D",1787696070999],"directory",[175,176,177],[216],"56e2f7f1-2c8e-42d3-9d7b-8000b6a06e71","telegram.ts","49e619aa-a0cd-11f1-8c59-1607ee4eb77e",30,["D",1787745689720],4,"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst CHAT_ID = \"@speedex_transportation\";\n\n/**\n * Cover image stored in this val's blob storage. We read it here and upload\n * it to Telegram as multipart form-data, rather than handing Telegram a URL\n * to fetch — remote-URL photo sends are unreliable from Telegram's servers.\n */\nconst COVER_BLOB_KEY = \"v0003.png\";\n\n/**\n * Generalised photo sender. Pass `caption` and optional arbitrary `photoBytes`.\n *\n * - Diesel flow (unchanged): call with just a caption (no bytes) and it reads\n * the fixed cover blob and uploads that, exactly as before.\n * - News flow: pass the generated image bytes explicitly.\n */\nexport async function sendTelegramPhoto(\n caption: string,\n photoBytes?: ArrayBuffer | Uint8Array | Blob,\n) {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n if (!token) throw new Error(\"TELEGRAM_BOT_TOKEN env var is not set\");\n\n // When no explicit bytes are given, read the cover from blob storage.\n let photoBlob: Blob;\n if (photoBytes === undefined) {\n const res = await blob.get(COVER_BLOB_KEY);\n photoBlob = await res.blob();\n } else {\n photoBlob = photoBytes instanceof Blob\n ? photoBytes\n : new Blob([photoBytes], { type: \"image/png\" });\n }\n\n // Multipart upload to sendPhoto: photo is a file attachment, not a URL.\n const form = new FormData();\n form.append(\"chat_id\", CHAT_ID);\n form.append(\"photo\", photoBlob, photoBytes === undefined ? \"cover.png\" : \"news.png\");\n form.append(\"caption\", caption);\n form.append(\"parse_mode\", \"HTML\");\n\n const tgRes = await fetch(`https://api.telegram.org/bot${token}/sendPhoto`, {\n method: \"POST\",\n body: form,\n });\n const body = await tgRes.json();\n if (!tgRes.ok || !body?.ok) {\n throw new Error(`Telegram sendPhoto failed: ${JSON.stringify(body)}`);\n }\n return body;\n}\n",[],[153,238],"545cc53b-b03c-4267-a5ab-2ffd189ef51b","scrape.ts","49cfd37a-a0cd-11f1-8c59-1607ee4eb77e",18,["D",1787696390784],"import * as cheerio from \"https://esm.sh/cheerio@1.0.0\";\n\nconst REGIONAL_URL = \"https://index.minfin.com.ua/ua/markets/fuel/reg/zakarpatskaya/\";\nconst DETAIL_URL = \"https://index.minfin.com.ua/ua/markets/fuel/detail/\";\n\n/** Networks whose price is read from the Zakarpatska regional page. */\nconst REGIONAL_NETWORKS = [\n \"UKRNAFTA\",\n \"WOG\",\n \"ОККО\",\n \"Маркет\",\n \"БРСМ-Нафта\",\n \"Parallel\",\n \"Chipo\",\n \"VST\",\n \"AMIC\",\n \"UPG\",\n];\n\n/** Networks whose price is uniform nationally, read from the detail page. */\nconst NATIONAL_NETWORKS = [\"Marshal\", \"Авантаж 7\", \"KLO\", \"SOCAR\"];\n\nfunction parsePrice(s: string): number | null {\n const m = s.replace(/[^0-9.,]/g, \"\").match(/(\\d+)[.,](\\d+)/);\n if (!m) return null;\n return parseFloat(`${m[1]}.${m[2]}`);\n}\n\n/**\n * minfin operator rows have 7 cells:\n * [0] name | [1] spacer | [2] А95+ | [3] А95 | [4] А92 | [5] ДП | [6] ГАЗ\n * Empty cells are present as `
`, so the ДП column is always index 5.\n */\nfunction parseDiesel(html: string, names: string[]): Record {\n const $ = cheerio.load(html);\n const out: Record = {};\n $(\"tr\").each((_, tr) => {\n const tds = $(tr).find(\"td\");\n if (tds.length < 6) return;\n const name = $(tds.eq(0)).text().trim();\n if (!names.includes(name)) return;\n const price = parsePrice($(tds.eq(5)).text());\n // Keep the FIRST region row matched per network so the value is anchored\n // to one consistent region instead of whichever row happens to come last.\n if (price != null && !(name in out)) out[name] = price;\n });\n return out;\n}\n\nasync function fetchText(url: string): Promise {\n const res = await fetch(url, {\n headers: { \"User-Agent\": \"Mozilla/5.0 (speedex-diesel-agent)\" },\n });\n if (!res.ok) throw new Error(`Fetch failed ${res.status} for ${url}`);\n return await res.text();\n}\n\n/** Returns a map of network -> ДП price (₴/L) for all 14 tracked networks. */\nexport async function fetchDieselPrices(): Promise> {\n const [regionalHtml, detailHtml] = await Promise.all([\n fetchText(REGIONAL_URL),\n fetchText(DETAIL_URL),\n ]);\n const prices: Record = {\n ...parseDiesel(regionalHtml, REGIONAL_NETWORKS),\n ...parseDiesel(detailHtml, NATIONAL_NETWORKS),\n };\n if (Object.keys(prices).length < 14) {\n console.warn(`Parsed ${Object.keys(prices).length}/14 networks`, prices);\n }\n return prices;\n}\n",[],[153,247],"5b04d368-a47e-469e-a9ee-49637c35582b","run.ts","49ee3d6a-a0cd-11f1-8c59-1607ee4eb77e",13,["D",1787695489502],"import { fetchDieselPrices } from \"./scrape.ts\";\nimport { composeMessage } from \"./message.ts\";\nimport { loadPrevPrices, saveTodayPrices } from \"./db.ts\";\nimport { sendTelegramPhoto } from \"./telegram.ts\";\n\nexport async function runDaily() {\n const now = new Date();\n\n const current = await fetchDieselPrices();\n const prev = await loadPrevPrices(now);\n const message = composeMessage(now, current, prev);\n\n console.log(\"Composed message:\\n\" + message);\n\n // DRY_RUN preview mode: log the message and exit without persisting\n // anything or sending the live Telegram post.\n if (Deno.env.get(\"DRY_RUN\")) {\n console.log(\"DRY_RUN is set - skipping send. No prices saved, nothing sent.\");\n return;\n }\n\n await saveTodayPrices(now, current);\n await sendTelegramPhoto(message);\n console.log(\"Digest sent to @speedex_transportation\");\n}\n",[],[153,255],["D",1787745689609],[],[153,64],"9cae46c0-931d-4a49-bd48-2f20533c7fd0","message.ts","49de75c4-a0cd-11f1-8c59-1607ee4eb77e",27,["D",1787698639735],5,"import { displayDate } from \"./date.ts\";\n\nconst EPS = 0.005; // treat sub-cent differences as \"no change\"\n\nfunction fmtComma(n: number): string {\n return n.toFixed(2).replace(\".\", \",\");\n}\nfunction fmtDot(n: number): string {\n return n.toFixed(2);\n}\nfunction signed(n: number): string {\n return (n >= 0 ? \"+\" : \"\") + n.toFixed(2);\n}\n\nexport interface Entry {\n name: string;\n price: number;\n}\n\n/**\n * Compose the Telegram caption.\n * Prices in the per-network bullet lines use a comma decimal (XX,XX₴);\n * other figures use a dot decimal. Section headers are wrapped in HTML \n * tags so they render bold when the caption is sent with parse_mode=HTML.\n */\nexport function composeMessage(\n now: Date,\n current: Record,\n prev: Record,\n): string {\n const entries: Entry[] = Object.entries(current).map(([name, price]) => ({ name, price }));\n entries.sort((a, b) => a.price - b.price);\n const total = entries.length;\n const hasPrev = Object.keys(prev).length > 0;\n\n const lines: string[] = [];\n lines.push(`⛽Дизель сьогодні | ${displayDate(now)}`);\n lines.push(\"\");\n\n // Per-network lines, ascending by price. Trend arrow only when there is\n // prior data; otherwise the line is just bullet, name, colon, price.\n for (const e of entries) {\n let line = `•${e.name}: ${fmtComma(e.price)}₴`;\n if (hasPrev) {\n const prior = prev[e.name];\n if (prior !== undefined) {\n line += e.price > prior + EPS\n ? \" ▲\"\n : e.price < prior - EPS\n ? \" ▼\"\n : \" →\";\n }\n }\n lines.push(line);\n }\n\n lines.push(\"\");\n\n // Daily change summary.\n if (!hasPrev) {\n lines.push(\"Це перший зафіксований день — порівнювати поки немає з чим.\");\n } else {\n let up = 0;\n let down = 0;\n for (const e of entries) {\n const prior = prev[e.name];\n if (prior === undefined) continue;\n const diff = e.price - prior;\n if (diff > EPS) up++;\n else if (diff < -EPS) down++;\n }\n // flat is derived so up + down + flat always equals total (no double count).\n const flat = total - up - down;\n lines.push(\n `Зміна за добу: ${up} мереж подорожчали, ${down} подешевшали, ${flat} без змін.`,\n );\n }\n\n lines.push(\"\");\n\n // Spread between priciest and cheapest.\n const priciest = entries[entries.length - 1];\n const cheapest = entries[0];\n const diff = priciest.price - cheapest.price;\n const pctSpread = (diff / cheapest.price) * 100;\n const tank = Math.round(diff * 600);\n const monthly = Math.round(diff * 1424);\n const pctSave = (diff / priciest.price) * 100;\n lines.push(\n `Розрив між мережами: ${priciest.name} (${fmtDot(priciest.price)}₴) проти ${cheapest.name} (${fmtDot(cheapest.price)}₴) - різниця ${fmtDot(diff)}₴ (+${fmtDot(pctSpread)}%). На баку тягача (600л) це ${tank}₴. При 8 рейсах/міс Київ-Львів (1424л) на ${cheapest.name} економите ${monthly}₴/міс (-${fmtDot(pctSave)}%), обираючи найдешевшу мережу.`,\n );\n\n lines.push(\"\");\n\n // Market average vs yesterday's average.\n const avg = entries.reduce((s, e) => s + e.price, 0) / total;\n let avgLine = `Середня по ринку: ${fmtDot(avg)}₴ (${total} мереж)`;\n const prevEntries = Object.entries(prev);\n if (prevEntries.length > 0) {\n const avgPrev = prevEntries.reduce((s, [, p]) => s + p, 0) / prevEntries.length;\n const d = avg - avgPrev;\n const pct = (d / avgPrev) * 100;\n avgLine += `, ${signed(d)}₴ (${signed(pct)}%) до вчорашньої`;\n }\n lines.push(avgLine + \".\");\n\n // Trailing channel-handle tag (plain text, not bold).\n lines.push(\"\");\n lines.push(\"@speedex_transportation\");\n\n return lines.join(\"\\n\");\n}\n",[],[153,266],"7e2c83f9-2632-4449-adce-e24cb405fe2c","db.ts","49d6cebe-a0cd-11f1-8c59-1607ee4eb77e",11,["D",1787695151981],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { dateKey } from \"./date.ts\";\n\nconst PREFIX = \"prices:\";\n\n/** Load the most recent stored day's prices strictly before `today`. */\nexport async function loadPrevPrices(today: Date): Promise> {\n const dk = dateKey(today);\n const entries = await blob.list(PREFIX);\n const prior = entries\n .map((e) => e.key.slice(PREFIX.length))\n .filter((k) => k < dk)\n .sort()\n .pop();\n if (!prior) return {};\n const prices = await blob.getJSON>(PREFIX + prior);\n return prices ?? {};\n}\n\n/** Persist today's prices so the next run can compute daily changes. */\nexport async function saveTodayPrices(today: Date, prices: Record) {\n await blob.setJSON(PREFIX + dateKey(today), prices);\n}\n",[],[153,275],"b31eef4a-5dbf-4b35-9adb-235d477bab6f","date.ts","49b74e7c-a0cd-11f1-8c59-1607ee4eb77e",3,["D",1787693899039],"/** Kyiv-timezone date helpers (cron runs in UTC, so we derive the Kyiv date explicitly). */\n\nexport function kyivParts(d: Date = new Date()) {\n const fmt = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"Europe/Kyiv\",\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n });\n const parts = fmt.formatToParts(d);\n const get = (t: string) => parts.find((p) => p.type === t)!.value;\n return { yyyy: get(\"year\"), mm: get(\"month\"), dd: get(\"day\") };\n}\n\n/** ISO-ish key used to store/compare days in SQLite, e.g. \"2026-08-25\". */\nexport function dateKey(d: Date = new Date()): string {\n const p = kyivParts(d);\n return `${p.yyyy}-${p.mm}-${p.dd}`;\n}\n\n/** Display form DD.MM.YYYY used in the message header. */\nexport function displayDate(d: Date = new Date()): string {\n const p = kyivParts(d);\n return `${p.dd}.${p.mm}.${p.yyyy}`;\n}\n",[],[153,283],"9852dbcb-4959-4cb5-97cb-dfd7838d7d1a",["D",1787693899039],[167,168,169,170,171,172,173],[153],["D",1787693858683],{"_11":12,"_122":70},{"_11":12,"_117":118,"_69":70,"_30":68,"_119":120,"_121":24},{"_38":108,"_13":16,"_32":35,"_109":72,"_110":-5,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":14,"_116":12},"ctx",{"_52":-5,"_141":331,"_332":333,"_334":335,"_336":24,"_337":24,"_338":24,"_339":85,"_340":-5,"_341":-7,"_342":-7,"_343":26,"_344":24,"_345":24,"_346":-5,"_347":24,"_348":24,"_349":24,"_350":-5},"ENV",{"_302":303,"_304":305,"_306":16,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330},"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"]

History · news.ts