[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_95":94,"_33":46,"_104":85,"_27":99,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":25,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",6,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":30},"file",{"_31":32,"_33":28,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_31":32,"_33":28,"_34":35,"_36":37},"deleted",false,"deletedHere","path","main.ts","latestPath","telegram_discount_filter.ts","fileId","21bb9fbe-a45f-11f1-908e-1607ee4eb77e","name","fileType","interval","content","import { kv } from \"https://esm.town\";\n\nexport default async function (interval: Interval) {\n const BOT_TOKEN = \"8802623572:AAGDcR7F00SjiOcpz9F0Kw0kaWGT5svYyAU\";\n const MY_CHAT_ID = \"5370819918\";\n const CHANNEL = \"onual_firsat\";\n const KEYWORDS = [\"iphone\", \"macbook\", \"dyson\", \"lego\", \"soda\"];\n\n // 1. Fetch the last processed message text from Val Town storage\n let lastSeenMessage = await kv.get(`last_seen_${CHANNEL}`) || \"\";\n\n for (let cycle = 0; cycle < 3; cycle++) {\n try {\n const response = await fetch(`https://t.me{CHANNEL}`);\n if (!response.ok) continue;\n\n const html = await response.text();\n const postBlocks = html.split(\n 'class=\"tgme_widget_message_text js-message_text\"',\n );\n\n // If no new posts are found, skip processing\n if (postBlocks.length <= 1) continue;\n\n let newMessagesFound = [];\n let latestMessageInThisRun = \"\";\n\n // 2. Loop through posts (Telegram organizes the html from oldest to newest down the page)\n for (let i = 1; i < postBlocks.length; i++) {\n const rawText = postBlocks[i].split(\"\")[0].replace(/<[^>]*>/g, \"\")\n .trim();\n\n // Track the final, most recent message at the bottom of the stream\n if (i === postBlocks.length - 1) {\n latestMessageInThisRun = rawText;\n }\n\n // If we hit a message we already processed in a past run, stop going down the list\n if (rawText === lastSeenMessage) {\n break;\n }\n\n const lowerText = rawText.toLowerCase();\n if (KEYWORDS.some((keyword) => lowerText.includes(keyword))) {\n newMessagesFound.push(rawText);\n }\n }\n\n // 3. Deliver only the brand new matches via your bot\n for (const msg of newMessagesFound) {\n await fetch(`https://telegram.org{BOT_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: MY_CHAT_ID,\n text: `🚨 **New Filtered Deal!** 🚨\\n\\n${msg}`,\n parse_mode: \"Markdown\",\n }),\n });\n }\n\n // 4. Update our checkpoint with the latest post text\n if (\n latestMessageInThisRun && latestMessageInThisRun !== lastSeenMessage\n ) {\n lastSeenMessage = latestMessageInThisRun;\n await kv.set(`last_seen_${CHANNEL}`, latestMessageInThisRun);\n }\n } catch (error) {\n console.error(\"Scraper Error:\", error);\n }\n\n // Interval sleep to maintain your strict 5-minute ticks\n if (cycle < 2) {\n await new Promise((resolve) => setTimeout(resolve, 900000));\n }\n }\n}","import { kv } from \"https://esm.town\";\n\nexport default async function (interval: Interval) {\n const BOT_TOKEN = \"8802623572:AAGDcR7F00SjiOcpz9F0Kw0kaWGT5svYyAU\";\n const MY_CHAT_ID = \"5370819918\";\n const CHANNEL = \"onual_firsat\";\n const KEYWORDS = [\"iphone\", \"macbook\", \"dyson\", \"lego\", \"soda\"];\n\n // 1. Fetch the last processed message text from Val Town storage\n let lastSeenMessage = await kv.get(`last_seen_${CHANNEL}`) || \"\";\n\n for (let cycle = 0; cycle < 3; cycle++) {\n try {\n const response = await fetch(`https://t.me{CHANNEL}`);\n if (!response.ok) continue;\n\n const html = await response.text();\n const postBlocks = html.split(\n 'class=\"tgme_widget_message_text js-message_text\"',\n );\n\n // If no new posts are found, skip processing\n if (postBlocks.length <= 1) continue;\n\n let newMessagesFound = [];\n let latestMessageInThisRun = \"\";\n\n // 2. Loop through posts (Telegram organizes the html from oldest to newest down the page)\n for (let i = 1; i < postBlocks.length; i++) {\n const rawText = postBlocks[i].split(\"\")[0].replace(/<[^>]*>/g, \"\")\n .trim();\n\n // Track the final, most recent message at the bottom of the stream\n if (i === postBlocks.length - 1) {\n latestMessageInThisRun = rawText;\n }\n\n // If we hit a message we already processed in a past run, stop going down the list\n if (rawText === lastSeenMessage) {\n break;\n }\n\n const lowerText = rawText.toLowerCase();\n if (KEYWORDS.some((keyword) => lowerText.includes(keyword))) {\n newMessagesFound.push(rawText);\n }\n }\n\n // 3. Deliver only the brand new matches via your bot\n for (const msg of newMessagesFound) {\n await fetch(`https://telegram.org{BOT_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: MY_CHAT_ID,\n text: `🚨 **New Filtered Deal!** 🚨\\n\\n${msg}`,\n parse_mode: \"Markdown\",\n }),\n });\n }\n\n // 4. Update our checkpoint with the latest post text\n if (\n latestMessageInThisRun && latestMessageInThisRun !== lastSeenMessage\n ) {\n lastSeenMessage = latestMessageInThisRun;\n await kv.set(`last_seen_${CHANNEL}`, latestMessageInThisRun);\n }\n } catch (error) {\n console.error(\"Scraper Error:\", error);\n }\n\n // Interval sleep to maintain your strict 5-minute ticks\n if (cycle < 2) {\n await new Promise((resolve) => setTimeout(resolve, 900000));\n }\n }\n}\n\nexport default async function (interval: Interval) {\n // 1. CONFIGURATION (Replace the XXXXXXXX placeholders)\n const BOT_TOKEN = \"8802623572:AAGDcR7F00SjiOcpz9F0Kw0kaWGT5svYyAU\";\n const MY_CHAT_ID = \"5370819918\";\n const CHANNEL = \"onual_firsat\";\n const KEYWORDS = [\"iphone\", \"macbook\", \"dyson\", \"lego\", \"soda\"];\n\n // 2. FETCH STORAGE (Using Val Town's native built-in global kv object)\n let lastSeenMessage = \"\";\n try {\n // Dynamic import handles native background initialization cleanly\n const { kv } = await import(\"https://esm.town\");\n lastSeenMessage = await kv.get(`last_seen_${CHANNEL}`) || \"\";\n } catch (e) {\n console.log(\"Starting fresh or KV initializing...\");\n }\n\n for (let cycle = 0; cycle < 3; cycle++) {\n try {\n const response = await fetch(`https://t.me{CHANNEL}`);\n if (!response.ok) continue;\n\n const html = await response.text();\n const postBlocks = html.split(\n 'class=\"tgme_widget_message_text js-message_text\"',\n );\n\n if (postBlocks.length <= 1) continue;\n\n let newMessagesFound = [];\n let latestMessageInThisRun = \"\";\n\n // Process posts\n for (let i = 1; i < postBlocks.length; i++) {\n const cleanChunk = postBlocks[i].split(\"\")[0]; // Grabs the first segment cleanly\n const rawText = cleanChunk.replace(/<[^>]*>/g, \"\").trim();\n\n if (i === postBlocks.length - 1) {\n latestMessageInThisRun = rawText;\n }\n\n if (rawText === lastSeenMessage) {\n break;\n }\n\n const lowerText = rawText.toLowerCase();\n if (KEYWORDS.some((keyword) => lowerText.includes(keyword))) {\n newMessagesFound.push(rawText);\n }\n }\n\n // Deliver matches to @mao_disc_bot\n for (const msg of newMessagesFound.reverse()) {\n await fetch(`https://telegram.org{BOT_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: MY_CHAT_ID,\n text: `🚨 **New Filtered Deal!** 🚨\\n\\n${msg}`,\n }),\n });\n }\n\n // Save latest post checkpoint\n if (\n latestMessageInThisRun && latestMessageInThisRun !== lastSeenMessage\n ) {\n lastSeenMessage = latestMessageInThisRun;\n try {\n const { kv } = await import(\"https://esm.town\");\n await kv.set(`last_seen_${CHANNEL}`, latestMessageInThisRun);\n } catch (e) {\n console.error(\"KV Save Error:\", e);\n }\n }\n } catch (error) {\n console.error(\"Scraper Processing Error:\", error);\n }\n\n // 5 minute loop buffer\n if (cycle < 2) {\n await new Promise((resolve) => setTimeout(resolve, 900000));\n }\n }\n}","createdAt",["D",1788087406084],"branchVersion","branchId","d4a5a4e1-4228-4143-9399-921278117158","id","bbb5ca77-1283-4175-b6a6-8de8f68c3b37","my-cron",["D",1788086383298],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","7afddf89-c65e-45ce-8651-b9132c058318","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0523c-e496-74e0-acfa-239746a5615d","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_33":85,"_44":43,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":46,"_93":94},"isOwned",28,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mao_py_val","handle","displayName","Aras Orhan","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_44":45,"_33":46,"_39":150,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":151,"_79":152,"_81":153,"_83":25},"tree",[145],"files",[145],"counts",{"_133":61,"_134":135,"_136":61,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":126,"_33":28,"_31":32,"_127":-5,"_42":43,"_41":14,"_128":25,"_39":129,"_13":130,"_34":35,"_36":38,"_24":25,"_131":-5,"_27":132},"3cf3723e-9934-46eb-9a5b-611a94180241","parentId","latest",["D",1788087406084],5,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":61},"connections",{"_141":61,"_142":61},"count","unfilledCount",2,"emptyCount",{"_44":126,"_33":28,"_31":32,"_127":-5,"_42":43,"_41":14,"_128":25,"_39":146,"_13":130,"_34":35,"_36":38,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1788087406084],"children",[],[28],["D",1788086383298],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_33":85,"_44":43,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":46,"_93":94},"ctx",{"_77":-5,"_122":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":196,"_197":-5,"_198":-7,"_199":-7,"_200":61,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_158":159,"_160":161,"_162":85,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v6