]*data-post=\")/;\n\nfunction parsePage(html: string): Post[] {\n const out: Post[] = [];\n for (const block of html.split(POST_SPLIT)) {\n const idm = block.match(/data-post=\"[^/\"]+\\/(\\d+)\"/);\n if (!idm) continue;\n const tm = block.match(\n /

]*>([\\s\\S]*?)<\\/div>/,\n );\n const lm = block.match(/]*url_button[^>]*href=\"([^\"]+)\"/);\n out.push({\n id: Number(idm[1]),\n text: tm ? htmlToText(tm[1]) : \"\",\n link: lm?.[1],\n });\n }\n return out;\n}\n\nasync function fetchPage(before?: number): Promise {\n const url = `https://t.me/s/${CHANNEL}${before ? `?before=${before}` : \"\"}`;\n const res = await fetch(url, {\n headers: { \"user-agent\": UA, \"accept-language\": \"tr,en;q=0.9\" },\n });\n if (!res.ok) throw new Error(`t.me returned ${res.status} for ${url}`);\n const posts = parsePage(await res.text());\n if (!posts.length) {\n throw new Error(\n `No posts parsed from ${url} — channel preview may be disabled or the markup changed`,\n );\n }\n return posts;\n}\n\n/** Walk ?before= backwards until the checkpoint is covered. Returns ascending by id. */\nasync function collectSince(lastId: number): Promise {\n const seen = new Map();\n let before: number | undefined;\n for (let page = 0; page < MAX_PAGES; page++) {\n const posts = await fetchPage(before);\n for (const p of posts) if (p.id > lastId) seen.set(p.id, p);\n const oldest = Math.min(...posts.map((p) => p.id));\n if (oldest <= lastId + 1) break;\n before = oldest;\n }\n return [...seen.values()].sort((a, b) => a.id - b.id);\n}\n\n/* -------------------------------- deliver ------------------------------ */\n\nfunction format(p: Post): string {\n const body = escapeHtml(p.text).slice(0, 3500);\n const links = [`post`];\n if (p.link) links.unshift(`link`);\n return `🚨 New filtered deal\\n\\n${body}\\n\\n${links.join(\" · \")}`;\n}\n\nasync function send(text: string, attempt = 0): Promise {\n const res = await fetch(\n `https://api.telegram.org/bot${BOT_TOKEN}/sendMessage`,\n {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: CHAT_ID,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n },\n );\n const body = await res.json().catch(() => ({}));\n if (res.status === 429 && attempt < 3) {\n await sleep(((body?.parameters?.retry_after ?? 5) + 1) * 1000);\n return send(text, attempt + 1);\n }\n if (!body?.ok) {\n throw new Error(redact(`sendMessage failed: ${JSON.stringify(body)}`));\n }\n}\n\n/* --------------------------------- main -------------------------------- */\n\nexport default async function () {\n if (!BOT_TOKEN) {\n throw new Error(\n \"Missing TELEGRAM_API_TOKEN — set it in the val's Environment Variables, then edit the val once to force a redeploy\",\n );\n }\n\n try {\n const state = (await blob.getJSON(STATE_KEY)) as\n | { lastId: number }\n | undefined;\n\n // First run: seed the checkpoint instead of blasting the 20 posts on the page.\n if (!state || typeof state.lastId !== \"number\") {\n const posts = await fetchPage();\n const lastId = Math.max(...posts.map((p) => p.id));\n await blob.setJSON(STATE_KEY, { lastId });\n console.log(`Seeded checkpoint at ${CHANNEL}/${lastId}`);\n return;\n }\n\n const posts = await collectSince(state.lastId);\n const hits = posts.filter((p) => matches(p.text));\n console.log(`${posts.length} new posts, ${hits.length} matched`);\n\n let committed = state.lastId;\n try {\n for (const p of posts) {\n if (matches(p.text)) {\n await send(format(p));\n await sleep(SEND_DELAY_MS);\n }\n committed = p.id; // only advances behind successful sends\n }\n } finally {\n if (committed > state.lastId) {\n await blob.setJSON(STATE_KEY, { lastId: committed });\n }\n }\n } catch (e) {\n console.error(redact(e));\n throw e;\n }\n}","deleted","label","children",[],"path",[42],"12307d4c-b566-4f80-b3ce-9dfacb63dcaf","README.md","72da2c44-a49b-11f1-9b0d-1607ee4eb77e",20,["D",1788112357694],1,"file","# my-cron\n\nthis scheduled cron runs on onu_al public telegram channel every 15 minutes and\nsends posts of interest to me via my bot in telegram",[],[66],["D",1788112357694],[66],{"_40":65,"_13":66,"_43":67,"_45":-5,"_46":47,"_48":68,"_50":51,"_52":81,"_16":70,"_55":71,"_57":72,"_59":35,"_60":-5,"_63":82},{"_40":41,"_13":42,"_43":44,"_45":-5,"_46":47,"_48":49,"_50":51,"_52":79,"_16":54,"_55":56,"_57":58,"_59":35,"_60":-5,"_63":80},["D",1789396610482],[42],["D",1788112357694],[66],"pulls",0,"branches","forks","envVars",{"_91":93,"_94":84},"connections",{"_91":84,"_92":84},"count","unfilledCount",2,"emptyCount","bbb5ca77-1283-4175-b6a6-8de8f68c3b37",["D",1788086383298],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","7afddf89-c65e-45ce-8651-b9132c058318","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0523c-e496-74e0-acfa-239746a5615d","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_149":145},"org",{"_11":12,"_142":143,"_144":145,"_104":105,"_146":147,"_148":35},"branch",{"_16":49,"_13":133,"_40":47,"_134":95,"_135":-5,"_136":-5,"_137":-5,"_138":-5,"_139":-5,"_140":14,"_141":12},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Aras Orhan","avatar","","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_40":95,"_13":14,"_52":179,"_97":-5,"_98":35,"_99":100,"_101":100,"_102":-5,"_103":-5,"_104":105,"_106":-5,"_107":35,"_108":-5,"_109":-5,"_110":84,"_111":112,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_126":180,"_128":181,"_130":182,"_132":35},"tree",[173,174],[173,174],{"_83":84,"_85":70,"_86":84,"_87":171,"_89":172},[167,168],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_40":65,"_13":66,"_43":67,"_45":-5,"_46":47,"_48":68,"_50":51,"_52":81,"_16":70,"_55":71,"_57":72,"_59":35,"_60":-5,"_63":170},{"_40":41,"_13":42,"_43":44,"_45":-5,"_46":47,"_48":49,"_50":51,"_52":79,"_16":54,"_55":56,"_57":58,"_59":35,"_60":-5,"_63":169},[42],[66],{"_91":93,"_94":84},{"_91":84,"_92":84},{"_40":65,"_13":66,"_43":67,"_45":-5,"_46":47,"_48":68,"_50":51,"_52":69,"_16":70,"_55":71,"_57":72,"_59":35,"_60":-5,"_61":177,"_63":178},{"_40":41,"_13":42,"_43":44,"_45":-5,"_46":47,"_48":49,"_50":51,"_52":53,"_16":54,"_55":56,"_57":58,"_59":35,"_60":-5,"_61":175,"_63":176},[],[42],[],[66],["D",1788086383298],{"_11":12,"_149":145},{"_11":12,"_142":143,"_144":145,"_104":105,"_146":147,"_148":35},{"_16":49,"_13":133,"_40":47,"_134":95,"_135":-5,"_136":-5,"_137":-5,"_138":-5,"_139":-5,"_140":14,"_141":12},"ctx",{"_126":-5,"_164":216,"_217":218,"_219":220,"_221":35,"_222":35,"_223":35,"_224":51,"_225":-5,"_226":-7,"_227":-7,"_228":84,"_229":35,"_230":35,"_231":-5,"_232":35,"_233":35,"_234":35,"_235":-5},"ENV",{"_187":188,"_189":190,"_191":133,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215},"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"]

mao_py_val

my-cron

my-cron