[{"_1":2,"_294":-5,"_295":-5},"loaderData",{"_3":4,"_91":92,"_204":205},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","703ea01c1077155a6b2e005f3a31351a5b041073","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":22,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":22,"_90":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":22,"_21":22,"_82":72,"_83":84,"_85":72,"_86":45,"_87":22,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_93":94,"_95":96,"_97":43,"_98":99,"_100":-7,"_101":102,"_147":148,"_180":181,"_182":183,"_192":193,"_194":195,"_198":-5,"_199":-5,"_200":22,"_201":22,"_202":203},"handle","asurgift","name","asurareleasesbot","branchName","path","sender.ts","version","project",{"_103":104,"_95":96,"_105":106,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":128,"_131":132,"_134":135,"_146":22},"id","46967584-38a4-11f0-a69e-9e149126039e","createdAt",["D",1748093865852],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","904ee0b0-2f46-11f0-a8d0-c76c3b0567ad","pinnedFileId","pinPreview","screenshotVersion","likeCount","cbb98caa-f5b1-4c4e-8ed5-115be1412667","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_129":130},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ5MEFaTTA0b3JBMGRaTUZoQUxaYk9PNFBYUiJ9","org",{"_93":94,"_133":130},"avatar","branch",{"_100":136,"_95":43,"_103":137,"_138":104,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},72,"4696c098-38a4-11f0-a69e-9e149126039e","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[149,171],{"_103":150,"_95":151,"_152":153,"_154":-5,"_155":137,"_156":157,"_158":159,"_105":160,"_100":161,"_162":163,"_164":165,"_166":22,"_167":-5,"_168":169,"_98":170},"18aa21ec-422d-11f0-8bbf-76b3cceeab13","cronjob2.tsx","fileId","64a293b8-38a5-11f0-b94b-9e149126039e","parentId","branchId","branchVersion",56,"latest",true,["D",1749142190312],11,"fileType","interval","content","import sender from \"./sender.ts\";\n\nexport async function scheduledHandler() {\n console.log(\"✅ Esecuzione pianificata avviata\");\n await sender();\n}","deleted","label","children",[],[151],{"_103":172,"_95":99,"_152":173,"_154":-5,"_155":137,"_156":136,"_158":159,"_105":174,"_100":175,"_162":176,"_164":177,"_166":22,"_167":-5,"_168":178,"_98":179},"9356e62c-84c8-11f0-9ffa-0224a6c84d84","88742f04-38a5-11f0-8b51-9e149126039e",["D",1756465744862],42,"script","// sender.ts @ValTown\n// Announces New Series (Ch1), Season Starts, and Season Ends with corrected message formats.\n// Posts first to PRIMARY_CHAT_ID, then reposts to SECONDARY_CHAT_ID.\n// Uses Telegram channel messages from PRIMARY_CHAT_ID as sentinel.\n// ──────────────────────────────────────────────────────────────────────────\n\n/*──────────────────── 1 ▸ imports ───────────────────────────────────────*/\nimport axios from \"npm:axios@1.6.8\";\nimport cheerio from \"npm:cheerio@1.0.0-rc.12\";\nimport { Bot, GrammyError, HttpError } from \"npm:grammy@1.19.2\";\n\n/*──────────────────── 2 ▸ configuration (secrets & settings) ──────────*/\n\n// --- Telegram Configuration ---\nconst BOT_TOKEN = \"7765248227:AAHRtkaZ3ySSmH2mOK6jqBKbwP24ZEECT9s\";\nconst PRIMARY_CHAT_ID = \"@mandoqa2\";\nconst SECONDARY_CHAT_ID = \"@asurascansreleases\";\nconst BOT_OWNER_ID = 6129128211; // For sending error notifications\n\n// --- Scraping & Event Logic Configuration ---\nconst BASE_URL = \"https://asuracomic.net\";\nconst CHAPTER_NUMBER_FOR_NEW_SERIES = \"1\"; // The chapter number that signifies a new series\n\n/**\n * CRITICAL SETTING TO PREVENT DUPLICATES:\n * How many hours back to look for events. A shorter window (e.g., 2-3 hours)\n * is safer and significantly reduces the chance of re-posting old events if\n * the script fails and restarts. 24 hours was too long.\n */\nconst MAX_EVENT_AGE_HOURS = 2;\nconst MIN_EVENT_AGE_MINUTES = 0;\n\n// --- HTTP Client Configuration ---\nconst USER_AGENT =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 MultiEventBot/1.14-enhanced\";\nconst REQUEST_TIMEOUT_MS = 30_000;\nconst FETCH_SENTINEL_TIMEOUT_MS = 20_000;\n\n// --- Telegram Interaction Delays (to prevent rate limiting) ---\nconst TELEGRAM_INTER_MESSAGE_DELAY_MS = 3500; // Delay between sending different event messages\nconst TELEGRAM_REPOST_DELAY_MS = 1500; // Delay between primary and secondary channel posts\n\n// --- Debugging ---\nconst DEBUG_MODE = true;\n\n/*──────────────────── 3 ▸ Telegram Bot Initialization ───────────────────*/\nconst bot = new Bot(BOT_TOKEN);\n\n/*──────────────────── 4 ▸ Types & Interfaces ───────────────────────────*/\nenum EventType {\n NEW_SERIES = \"NEW_SERIES\",\n SEASON_START = \"SEASON_START\",\n SEASON_END = \"SEASON_END\",\n REGULAR_CHAPTER = \"REGULAR_CHAPTER\",\n}\n\ninterface ChapterEventInfo {\n eventType: EventType;\n seriesTitle: string;\n seriesImage?: string | null;\n seriesPageUrl: string;\n chapterNumberText: string;\n normalizedChapterNumber: string;\n seasonNumber?: string;\n chapterUrl: string;\n releaseTimeText: string;\n minutesAgo: number;\n definitiveSeriesTitle?: string;\n definitiveSeriesImage?: string;\n synopsis?: string | null;\n}\n\n/*──────────────────── 5 ▸ helper functions ──────────────────────────────*/\nconst getCurrentTimestamp = () => new Date().toISOString().slice(11, 19);\nconst log = (...args: any[]) => {\n if (DEBUG_MODE) console.log(`[${getCurrentTimestamp()}] INFO:`, ...args);\n};\nconst errorLog = (...args: any[]) => {\n console.error(`[${getCurrentTimestamp()}] ERROR:`, ...args);\n};\nconst htmlToText = (htmlString = \"\"): string =>\n htmlString.replace(/<[^>]*>/g, \"\").replace(/\\s+/g, \" \").trim();\nconst normalizeChapterNumOnly = (\n text: string,\n): string => (text.match(/(\\d+(\\.\\d+)?)/)?.[0] || \"\");\nconst normalizeString = (str = \"\"): string =>\n str.replace(/[‐–—−\\-]/g, \"-\").replace(/\\s+/g, \" \").trim().toLowerCase();\n\n/**\n * Cleans various suffixes and prefixes from a series title.\n * @param title The raw title string.\n * @returns A cleaned title or \"Unknown Title\".\n */\nfunction cleanTitle(title: string): string {\n if (!title) return \"Unknown Title\";\n let cleaned = title\n .replace(/\\| Manga TX$/i, \"\")\n .replace(/ - Asura Scans$/i, \"\")\n .replace(/ - MangaDex$/i, \"\")\n .replace(/Manhwa – .*$/i, \"\")\n .replace(/Read Manhwa Online For Free At .*$/i, \"\")\n .trim();\n if (cleaned.length < 2 && title.toLowerCase().includes(\"asura\")) {\n return \"Unknown Title\";\n }\n return cleaned || \"Unknown Title\";\n}\n\n/**\n * Parses a \"time ago\" phrase into minutes. Handles future posts (\"public in...\") as negative minutes.\n * @param phrase The time phrase (e.g., \"5 minutes ago\", \"public in 1 hour\").\n * @returns The number of minutes.\n */\nfunction parseMinutesFromPhrase(phrase = \"\"): number {\n const s = phrase.toLowerCase();\n const isolatedTimePhrase = s.match(\n /((?:(?:\\d+\\s+)?(?:second|minute|min|hour|day|week|month|year)s?\\s+ago)|(?:public\\s+in\\s+(?:\\d+\\s+)?(?:second|minute|min|hour)s?))/i,\n )?.[0] ||\n s;\n\n if (\n isolatedTimePhrase.includes(\"less than\") ||\n isolatedTimePhrase.includes(\"second\") || isolatedTimePhrase.includes(\"now\")\n ) {\n return 0;\n }\n if (\n isolatedTimePhrase.includes(\"week\") ||\n isolatedTimePhrase.includes(\"month\") || isolatedTimePhrase.includes(\"year\")\n ) {\n return 999_999;\n }\n\n const numMatch = isolatedTimePhrase.match(/-?\\d+(?:\\.\\d+)?/);\n const num = parseFloat(numMatch?.[0] || \"NaN\");\n if (Number.isNaN(num)) return 999_999;\n\n if (isolatedTimePhrase.includes(\"public in\")) {\n return isolatedTimePhrase.includes(\"hour\")\n ? -Math.round(num * 60)\n : -Math.round(num);\n }\n if (isolatedTimePhrase.includes(\"day\")) return Math.round(num * 24 * 60);\n if (isolatedTimePhrase.includes(\"hour\")) return Math.round(num * 60);\n if (\n isolatedTimePhrase.includes(\"minute\") || isolatedTimePhrase.includes(\"min\")\n ) return Math.round(num);\n\n return 999_999;\n}\n\n/**\n * Analyzes chapter text to determine if it's a special event.\n * @param chapterFullText The raw text from the chapter link (e.g., \"Chapter 1\", \"{S2 END}\").\n * @param normalizedChapterNumOnly The extracted chapter number.\n * @returns An object with the eventType and optional seasonNumber.\n */\nfunction analyzeChapterForEvents(\n chapterFullText: string,\n normalizedChapterNumOnly: string,\n): { eventType: EventType; seasonNumber?: string } {\n const lowerText = chapterFullText.toLowerCase();\n\n // Season End Detection\n const seasonEndMatch = chapterFullText.match(/\\{S(\\d+)\\s*END/i) ||\n chapterFullText.match(/\\[S(\\d+)\\s*[-]?\\s*EN(?:D)?/i) ||\n lowerText.match(\n /(?:season|s)\\s*(\\d+)\\s*(?:finale|conclusion|epilogue|afterword)/i,\n );\n if (seasonEndMatch?.[1]) {\n return { eventType: EventType.SEASON_END, seasonNumber: seasonEndMatch[1] };\n }\n if (\n chapterFullText.match(/\\{(?:Series|Serie)\\s*END/i) ||\n lowerText.includes(\"series finale\")\n ) {\n return { eventType: EventType.SEASON_END, seasonNumber: \"1\" }; // Assume S1 if not specified\n }\n\n // Season Start Detection\n const seasonStartMatch =\n chapterFullText.match(/\\{S(\\d+)\\s*(?:STA(?:RT)?|PREMIERE)/i) ||\n (lowerText.match(/(?:season|s)\\s*(\\d+)/i) &&\n (parseInt(normalizedChapterNumOnly, 10) <= 3 ||\n lowerText.includes(\"premiere\") ||\n lowerText.includes(\"return\")));\n if (seasonStartMatch?.[1]) {\n return {\n eventType: EventType.SEASON_START,\n seasonNumber: seasonStartMatch[1],\n };\n }\n if (\n lowerText.includes(\"new season\") &&\n parseInt(normalizedChapterNumOnly, 10) <= 3\n ) {\n const seasonNumFromText = lowerText.match(/(?:season|s)\\s*(\\d+)/i);\n return {\n eventType: EventType.SEASON_START,\n seasonNumber: seasonNumFromText?.[1],\n };\n }\n\n // New Series Detection (must be Ch 1 and have no season markers)\n if (normalizedChapterNumOnly === CHAPTER_NUMBER_FOR_NEW_SERIES) {\n if (\n !/\\{s\\d/i.test(lowerText) && !/(?:^|\\s|-)s\\d+/i.test(lowerText) &&\n !lowerText.includes(\"season \")\n ) {\n return { eventType: EventType.NEW_SERIES };\n } else {\n // It's Chapter 1 but seems to be a season start, not a new series.\n const seasonNumFromText = lowerText.match(/(?:season|s)\\s*(\\d+)/i) ||\n chapterFullText.match(/\\{S(\\d+)/i);\n if (seasonNumFromText?.[1]) {\n return {\n eventType: EventType.SEASON_START,\n seasonNumber: seasonNumFromText[1],\n };\n }\n }\n }\n\n return { eventType: EventType.REGULAR_CHAPTER };\n}\n\n/*──────────────────── 6 ▸ HTTP client (axios) ───────────────────────────*/\nconst httpClient = axios.create({\n headers: { \"User-Agent\": USER_AGENT },\n timeout: REQUEST_TIMEOUT_MS,\n maxRedirects: 5,\n});\n\n/*──────────────────── 7 ▸ Telegram Sentinel Logic ───────────────────────*/\nconst announcedEventsSentinel = new Set();\n\n/**\n * Populates the sentinel by scraping the primary Telegram channel's public web view.\n */\nasync function populateEventSentinelsFromChannel(): Promise {\n log(\n `Fetching event sentinel messages from Telegram channel: ${PRIMARY_CHAT_ID}`,\n );\n const sentinelUrl = `https://t.me/s/${PRIMARY_CHAT_ID.replace(/^@/, \"\")}`;\n try {\n const { data: html } = await httpClient.get(sentinelUrl, {\n timeout: FETCH_SENTINEL_TIMEOUT_MS,\n });\n const $ = cheerio.load(html);\n $(\".tgme_widget_message_text\").slice(-75).each((_i, el) => {\n const messageText = $(el).text();\n // New Series\n const newSeriesMatch = messageText.match(\n /New Series Announcement – ([^\\n]+)/i,\n );\n if (newSeriesMatch?.[1]) {\n announcedEventsSentinel.add(\n `${normalizeString(newSeriesMatch[1].trim())}#NEW_SERIES`,\n );\n }\n // Season Start\n const seasonStartMatch = messageText.match(\n /New Season Announcement – Season\\s*(\\d+)\\s*of\\s*([\\s\\S]+?)\\s*Has Started/i,\n );\n if (seasonStartMatch?.[1] && seasonStartMatch?.[2]) {\n announcedEventsSentinel.add(\n `${normalizeString(seasonStartMatch[2].trim())}#S${\n seasonStartMatch[1]\n }_START`,\n );\n }\n // Season End\n const seasonEndMatch = messageText.match(\n /Season Completion Announcement – Season\\s*(\\d+)\\s*of\\s*([\\s\\S]+?)\\s*Has Ended/i,\n );\n if (seasonEndMatch?.[1] && seasonEndMatch?.[2]) {\n announcedEventsSentinel.add(\n `${normalizeString(seasonEndMatch[2].trim())}#S${\n seasonEndMatch[1]\n }_END`,\n );\n }\n });\n log(\n `Populated ${announcedEventsSentinel.size} event sentinels from channel history.`,\n );\n } catch (error) {\n if (axios.isAxiosError(error)) {\n errorLog(\n `Failed to fetch sentinel (HTTP ${error.response?.status}):`,\n error.message,\n );\n } else {\n errorLog(\"Failed to fetch/parse event sentinel messages:\", error.message);\n }\n }\n}\n\n/**\n * Checks if a specific event has already been announced based on the sentinel.\n * @returns True if the event is found in the sentinel, false otherwise.\n */\nfunction hasEventBeenAnnounced(\n definitiveSeriesTitle: string,\n eventType: EventType,\n seasonNumber?: string,\n): boolean {\n let sentinelKey = normalizeString(definitiveSeriesTitle);\n if (eventType === EventType.NEW_SERIES) sentinelKey += \"#NEW_SERIES\";\n else if (eventType === EventType.SEASON_START && seasonNumber) {\n sentinelKey += `#S${seasonNumber}_START`;\n } else if (eventType === EventType.SEASON_END && seasonNumber) {\n sentinelKey += `#S${seasonNumber}_END`;\n } else return true; // Default to \"announced\" for REGULAR_CHAPTER to ignore them\n return announcedEventsSentinel.has(sentinelKey);\n}\n\n/*──────────────────── 8 ▸ Scraping Logic ────────────────────────────────*/\n\n/**\n * Scrapes the main page for recently released chapters and identifies potential events.\n * @returns A promise that resolves to an array of potential ChapterEventInfo objects.\n */\nasync function scrapeMainPageForChapterEvents(): Promise {\n log(\"Scraping main page for chapter events:\", BASE_URL);\n try {\n const { data } = await httpClient.get(BASE_URL, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const chapterEvents: ChapterEventInfo[] = [];\n\n const headingElement = $(\"h3, h2\").filter((_, h) =>\n $(h).text().trim().toLowerCase().includes(\"latest updates\")\n ).first();\n if (!headingElement.length) {\n errorLog(\n \"CRITICAL SCRAPE FAIL: Could not find 'Latest Updates' heading.\",\n );\n return [];\n }\n const updateBox = headingElement.parent().next(\"div.grid\");\n if (!updateBox.length) {\n errorLog(\"CRITICAL SCRAPE FAIL: Could not find 'div.grid' update box.\");\n return [];\n }\n\n const $seriesBlocks = updateBox.find(\"div.w-full.p-1.pt-1.pb-3\");\n log(`Found ${$seriesBlocks.length} potential series blocks.`);\n\n $seriesBlocks.each((_idx, itemBlock) => {\n const eventsFromBlock = processSeriesBlock($, itemBlock);\n chapterEvents.push(...eventsFromBlock);\n });\n\n log(\n `Found ${chapterEvents.length} potential special chapter events on main page.`,\n );\n return chapterEvents;\n } catch (e) {\n if (axios.isAxiosError(e)) {\n errorLog(\n `Scrape main page error (HTTP ${e.response?.status}):`,\n e.message,\n );\n } else errorLog(\"Exception in scrapeMainPageForChapterEvents:\", e.message);\n return [];\n }\n}\n\n/**\n * Processes a single series block from the main page to find chapter events.\n * @param $ The Cheerio instance.\n * @param itemBlock The Cheerio element for the series block.\n * @returns An array of ChapterEventInfo found in the block.\n */\nfunction processSeriesBlock(\n $: cheerio.CheerioAPI,\n itemBlock: cheerio.Element,\n): ChapterEventInfo[] {\n const $itemBlock = $(itemBlock);\n const events: ChapterEventInfo[] = [];\n\n const $seriesLinkElement = $itemBlock.find(\"span a[href*='/series/']\")\n .first();\n const seriesPagePath = $seriesLinkElement.attr(\"href\");\n const preliminarySeriesTitle = htmlToText($seriesLinkElement.text());\n\n if (!seriesPagePath || !preliminarySeriesTitle) return [];\n\n const seriesPageUrl = new URL(seriesPagePath, BASE_URL).href;\n const preliminarySeriesImage = $itemBlock.find(\"div a img\").attr(\"src\");\n const seriesImageFullUrl = preliminarySeriesImage\n ? new URL(preliminarySeriesImage, BASE_URL).href\n : null;\n\n $itemBlock.find(\"div.flex.justify-between\").each((_cIdx, chapDiv) => {\n const $chapDiv = $(chapDiv);\n const $chapterLinkAnchor = $chapDiv.find(\"a[href*='/chapter/']\").first();\n const href = $chapterLinkAnchor.attr(\"href\");\n if (!href) return;\n\n const releaseTimeText = htmlToText($chapDiv.find(\"p\").last().text());\n if (!releaseTimeText) return;\n\n const chapterNumberText = htmlToText(\n $chapterLinkAnchor.find(\"p\").first().text(),\n );\n const normalizedChapterNumber = normalizeChapterNumOnly(chapterNumberText);\n if (!normalizedChapterNumber) return;\n\n const eventAnalysis = analyzeChapterForEvents(\n chapterNumberText,\n normalizedChapterNumber,\n );\n if (eventAnalysis.eventType === EventType.REGULAR_CHAPTER) return;\n\n events.push({\n eventType: eventAnalysis.eventType,\n seasonNumber: eventAnalysis.seasonNumber,\n seriesTitle: preliminarySeriesTitle,\n seriesImage: seriesImageFullUrl,\n seriesPageUrl,\n chapterNumberText,\n normalizedChapterNumber,\n chapterUrl: new URL(href, BASE_URL).href,\n releaseTimeText,\n minutesAgo: parseMinutesFromPhrase(releaseTimeText),\n });\n });\n\n return events;\n}\n\n/**\n * Scrapes a specific series page for a more definitive title, image, and synopsis.\n * @param seriesPageUrl The URL of the series page to scrape.\n * @returns An object with definitive details.\n */\nasync function scrapeSeriesPageForDetails(\n seriesPageUrl: string,\n): Promise<\n Pick<\n ChapterEventInfo,\n \"definitiveSeriesTitle\" | \"definitiveSeriesImage\" | \"synopsis\"\n >\n> {\n log(\"Scraping series page for details:\", seriesPageUrl);\n try {\n const { data } = await httpClient.get(seriesPageUrl, {\n responseType: \"text\",\n });\n const $ = cheerio.load(data);\n\n let definitiveSeriesTitle = \"Unknown Title\";\n const titleSelectors = [\n \"h1.entry-title\",\n \"h1.post-title\",\n \"h2.text-\\\\[25px\\\\]\",\n \"meta[property='og:title']\",\n \"title\",\n ];\n for (const selector of titleSelectors) {\n const el = $(selector).first();\n const text = el.is(\"meta\") ? el.attr(\"content\") : el.text();\n if (text) {\n const cleaned = cleanTitle(htmlToText(text));\n if (cleaned !== \"Unknown Title\") {\n definitiveSeriesTitle = cleaned;\n break;\n }\n }\n }\n\n let definitiveSeriesImage = \"\";\n const imageSelectors = [\n \"div.flex img.aspect-\\\\[2\\\\/3\\\\]\",\n \".summary_image img\",\n \"meta[property='og:image']\",\n ];\n for (const selector of imageSelectors) {\n const el = $(selector).first();\n const src = el.attr(\"src\") || el.attr(\"content\");\n if (src) {\n definitiveSeriesImage = new URL(src, BASE_URL).href;\n break;\n }\n }\n\n let synopsis: string | null = null;\n const $synopsisHeading = $(\"h3, h2\").filter((_, el) =>\n $(el).text().toLowerCase().includes(\"synopsis\")\n ).first();\n if ($synopsisHeading.length) {\n const $content = $synopsisHeading.nextAll(\n \"p, div.summary__content, div.entry-content\",\n ).first();\n if ($content.length) {\n synopsis = htmlToText(\n $content.html()?.replace(//gi, \"\\n\") || \"\",\n );\n }\n }\n\n return { definitiveSeriesTitle, definitiveSeriesImage, synopsis };\n } catch (e) {\n if (axios.isAxiosError(e)) {\n errorLog(\n `Scrape series page error (HTTP ${e.response?.status}):`,\n e.message,\n );\n } else {errorLog(\n `Exception in scrapeSeriesPageForDetails for ${seriesPageUrl}:`,\n e.message,\n );}\n return {\n definitiveSeriesTitle: \"Error fetching title\",\n definitiveSeriesImage: \"\",\n synopsis: null,\n };\n }\n}\n\n/*──────────────────── 9 ▸ Telegram Messaging Logic ──────────────────────*/\n\n/**\n * Generates the Telegram message content and sentinel key for a given event.\n * @param event The ChapterEventInfo object.\n * @returns An object with the message content and sentinel key part, or null if not applicable.\n */\nfunction generateTelegramMessage(\n event: ChapterEventInfo,\n): { messageContent: string; sentinelKeyPart: string } | null {\n const nameOfManhwa = htmlToText(event.definitiveSeriesTitle!);\n const chapterNum = event.normalizedChapterNumber;\n const chapterUrl = event.chapterUrl;\n const seasonNum = event.seasonNumber;\n const synopsis = event.synopsis\n ? `\\n\\nSynopsis:\\n${htmlToText(event.synopsis)}`\n : \"\";\n\n switch (event.eventType) {\n case EventType.NEW_SERIES:\n return {\n messageContent:\n `📢 New Series Announcement – ${nameOfManhwa}\\n\\nWe are excited to announce a new series: ${nameOfManhwa}.${synopsis}\\n\\nChapter ${chapterNum} is now available:\\nStart Reading Chapter ${chapterNum}`,\n sentinelKeyPart: \"#NEW_SERIES\",\n };\n case EventType.SEASON_START:\n if (!seasonNum) return null;\n return {\n messageContent:\n `📢 New Season Announcement – Season ${seasonNum} of ${nameOfManhwa} Has Started\\n\\nSeason ${seasonNum} of ${nameOfManhwa} has officially begun.${synopsis}\\n\\nYou can read Chapter ${chapterNum} here:\\nRead Chapter ${chapterNum}`,\n sentinelKeyPart: `#S${seasonNum}_START`,\n };\n case EventType.SEASON_END:\n if (!seasonNum) return null;\n return {\n messageContent:\n `📢 Season Completion – Season ${seasonNum} of ${nameOfManhwa} Has Ended\\n\\nSeason ${seasonNum} of ${nameOfManhwa} has concluded with Chapter ${chapterNum}.\\n${synopsis}\\nWe thank all readers for their engagement. Please stay tuned for announcements about the next season.\\n\\nRead the final chapter of Season ${seasonNum}: Read Chapter ${chapterNum}`,\n sentinelKeyPart: `#S${seasonNum}_END`,\n };\n default:\n return null;\n }\n}\n\n/**\n * Announces a single event to the primary and secondary Telegram channels.\n * @param event The event to announce.\n */\nasync function announceEvent(event: ChapterEventInfo): Promise {\n const messageData = generateTelegramMessage(event);\n if (!messageData) {\n log(\n `Skipping event type ${event.eventType} for \"${event.definitiveSeriesTitle}\" as no message template is defined.`,\n );\n return;\n }\n const { messageContent, sentinelKeyPart } = messageData;\n const nameOfManhwa = event.definitiveSeriesTitle!;\n const imageUrl = event.definitiveSeriesImage;\n let successfullySentToPrimary = false;\n\n try {\n log(\n `Announcing to PRIMARY (${PRIMARY_CHAT_ID}): ${nameOfManhwa} - Event: ${event.eventType}`,\n );\n const usePhoto = imageUrl &&\n (event.eventType === EventType.NEW_SERIES ||\n event.eventType === EventType.SEASON_START);\n if (usePhoto) {\n await bot.api.sendPhoto(PRIMARY_CHAT_ID, imageUrl, {\n caption: messageContent,\n parse_mode: \"HTML\",\n });\n } else {\n await bot.api.sendMessage(PRIMARY_CHAT_ID, messageContent, {\n parse_mode: \"HTML\",\n disable_web_page_preview: false,\n });\n }\n successfullySentToPrimary = true;\n log(`Successfully announced to PRIMARY: ${nameOfManhwa}`);\n // Immediately add to sentinel to prevent re-posting in the same run or a quick follow-up run.\n announcedEventsSentinel.add(\n `${normalizeString(nameOfManhwa)}${sentinelKeyPart}`,\n );\n } catch (e) {\n errorLog(`TG send error to PRIMARY for ${nameOfManhwa}:`, e.message);\n if (e instanceof GrammyError) {\n errorLog(\"GrammyError Description:\", e.description);\n }\n if (BOT_OWNER_ID) {\n await bot.api.sendMessage(\n BOT_OWNER_ID,\n `PRIMARY SEND FAIL: ${event.eventType} for ${nameOfManhwa}.\\nError: ${\n e.message.substring(0, 300)\n }`,\n )\n .catch((err) =>\n errorLog(\"Failed to send error notification to owner:\", err.message)\n );\n }\n }\n\n if (successfullySentToPrimary && SECONDARY_CHAT_ID) {\n await new Promise((resolve) =>\n setTimeout(resolve, TELEGRAM_REPOST_DELAY_MS)\n );\n try {\n log(`Reposting to SECONDARY (${SECONDARY_CHAT_ID}): ${nameOfManhwa}`);\n const usePhoto = imageUrl &&\n (event.eventType === EventType.NEW_SERIES ||\n event.eventType === EventType.SEASON_START);\n if (usePhoto) {\n await bot.api.sendPhoto(SECONDARY_CHAT_ID, imageUrl, {\n caption: messageContent,\n parse_mode: \"HTML\",\n });\n } else {\n await bot.api.sendMessage(SECONDARY_CHAT_ID, messageContent, {\n parse_mode: \"HTML\",\n disable_web_page_preview: false,\n });\n }\n log(`Successfully reposted to SECONDARY: ${nameOfManhwa}`);\n } catch (e) {\n errorLog(`TG repost error to SECONDARY for ${nameOfManhwa}:`, e.message);\n if (BOT_OWNER_ID) {\n await bot.api.sendMessage(\n BOT_OWNER_ID,\n `SECONDARY REPOST FAIL: ${event.eventType} for ${nameOfManhwa}.\\nError: ${\n e.message.substring(0, 300)\n }`,\n )\n .catch((err) =>\n errorLog(\"Failed to send error notification to owner:\", err.message)\n );\n }\n }\n }\n}\n\n/*──────────────────── 10 ▸ Main Orchestration Logic ─────────────────────*/\nexport default async function sender() {\n log(`=== Multi-Event Announcer Run Start ===`);\n try {\n await bot.api.getMe();\n log(\"Bot token validated.\");\n } catch (e) {\n errorLog(\"Invalid Bot Token:\", e.message);\n return;\n }\n\n await populateEventSentinelsFromChannel();\n\n const potentialEvents = await scrapeMainPageForChapterEvents();\n if (!potentialEvents.length) {\n log(\"No potential special events found during scrape.\");\n log(\"=== Run End ===\");\n return;\n }\n\n const eventsToAnnounce: ChapterEventInfo[] = [];\n for (const event of potentialEvents) {\n if (\n event.minutesAgo < MIN_EVENT_AGE_MINUTES ||\n event.minutesAgo > (MAX_EVENT_AGE_HOURS * 60)\n ) {\n log(\n `Skipping \"${event.seriesTitle}\" (Ch ${event.normalizedChapterNumber}): outside time window (${event.minutesAgo}m ago).`,\n );\n continue;\n }\n\n const details = await scrapeSeriesPageForDetails(event.seriesPageUrl);\n if (\n !details.definitiveSeriesTitle ||\n details.definitiveSeriesTitle === \"Unknown Title\" ||\n details.definitiveSeriesTitle === \"Error fetching title\"\n ) {\n errorLog(\n `Could not get a definitive title for \"${event.seriesTitle}\". Skipping.`,\n );\n continue;\n }\n\n event.definitiveSeriesTitle = details.definitiveSeriesTitle;\n event.definitiveSeriesImage = details.definitiveSeriesImage ||\n event.seriesImage;\n event.synopsis = details.synopsis;\n\n if (\n hasEventBeenAnnounced(\n event.definitiveSeriesTitle,\n event.eventType,\n event.seasonNumber,\n )\n ) {\n log(\n `Skipping \"${event.definitiveSeriesTitle}\" (Type: ${event.eventType}, S:${\n event.seasonNumber || \"N/A\"\n }): already announced via sentinel.`,\n );\n continue;\n }\n\n log(\n `QUEUED for announcement: \"${event.definitiveSeriesTitle}\" (Type: ${event.eventType})`,\n );\n eventsToAnnounce.push(event);\n }\n\n if (!eventsToAnnounce.length) {\n log(\"No new, unannounced events to post.\");\n log(\"=== Run End ===\");\n return;\n }\n\n // Sort events to announce New Series first, then Season Starts, etc.\n eventsToAnnounce.sort((a, b) => {\n const order = [\n EventType.NEW_SERIES,\n EventType.SEASON_START,\n EventType.SEASON_END,\n ];\n return order.indexOf(a.eventType) - order.indexOf(b.eventType);\n });\n\n log(`Found ${eventsToAnnounce.length} event(s) to announce.`);\n for (const [index, event] of eventsToAnnounce.entries()) {\n await announceEvent(event);\n if (index < eventsToAnnounce.length - 1) {\n await new Promise((resolve) =>\n setTimeout(resolve, TELEGRAM_INTER_MESSAGE_DELAY_MS)\n );\n }\n }\n\n log(\"=== Multi-Event Announcer Run End ===\");\n}",[],[99],"files",[149,171],"counts",{"_184":32,"_185":186,"_187":32,"_188":189},"pulls","branches",1,"forks","envVars",{"_190":32,"_191":32},"count","emptyCount","contents",[],"file",{"_103":172,"_155":137,"_152":173,"_95":99,"_164":177,"_162":176,"_100":175,"_154":-5,"_105":196,"_156":136,"_167":-5,"_98":197},["D",1756465744862],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_93":94,"_95":96,"_97":43,"_98":99,"_101":206,"_194":211,"_214":215,"_277":278,"_291":-7,"_292":186,"_293":22},{"_103":104,"_95":96,"_105":207,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":208,"_131":209,"_134":210,"_146":22},["D",1748093865852],{"_93":94,"_129":130},{"_93":94,"_133":130},{"_100":136,"_95":43,"_103":137,"_138":104,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},{"_103":172,"_95":99,"_152":173,"_154":-5,"_155":137,"_156":136,"_158":159,"_105":212,"_100":175,"_162":176,"_164":177,"_166":22,"_167":-5,"_98":213},["D",1756465744862],[99],"history",[216,222,228,234,240,246,251,257,263,269,273],{"_103":217,"_155":137,"_152":173,"_95":99,"_164":218,"_162":176,"_100":219,"_154":-5,"_105":220,"_156":221,"_167":-5},"6fa2e804-4182-11f0-9ed0-76b3cceeab13","// newSeriesAnnouncer.ts @ValTown (or update your sender.ts)\n// Scans asuracomic.net for series releasing Chapter 1 and announces them.\n// No token privatization as per request.\n// Uses Deno.openKv() for ValTown KV store.\n// ──────────────────────────────────────────────────────────────────────────\n\n/*──────────────────── 1 ▸ imports ───────────────────────────────────────*/\nimport axios from \"npm:axios@1.6.8\";\nimport cheerio from \"npm:cheerio@1.0.0-rc.12\";\nimport { Bot } from \"npm:grammy@1.19.2\";\n\n/*──────────────────── 2 ▸ configuration (secrets & settings) ──────────*/\nconst BOT_TOKEN = \"6923200542:AAGdyYJydP1kcHjrO5aOr8Ams2GflTEki8c\";\nconst ANNOUNCEMENT_CHAT_ID = \"@mandoqa\";\nconst BOT_OWNER_ID = 6129128211;\n\nconst TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES = \"1\"; // <<< We are looking for Chapter 1\nconst MAX_NEW_SERIES_CHAPTER_1_AGE_HOURS = 24 * 2; // Announce if Chapter 1 is newer than this (e.g., 48 hours)\nconst MIN_NEW_SERIES_CHAPTER_1_AGE_MINUTES = 0;\n\nconst BASE_URL = \"https://asuracomic.net\";\nconst USER_AGENT =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 NewSeriesBot/1.4\";\n\nconst REQUEST_TIMEOUT_MS = 30_000;\n// Use a different KV key to avoid conflicts with the specific chapter announcer if you run both\nconst KV_ANNOUNCED_NEW_SERIES_KEY = \"announcedNewSeries_asura_v1\";\n\nconst DEBUG_MODE = true;\n\n/*──────────────────── 3 ▸ Telegram Bot Initialization ───────────────────*/\nconst bot = new Bot(BOT_TOKEN);\n\n/*──────────────────── 4 ▸ Types & Interfaces ───────────────────────────*/\ninterface ScrapedChapterInfo {\n seriesTitle: string;\n seriesImage?: string | null;\n seriesPageUrl: string;\n chapterNumberText: string;\n normalizedChapterNumber: string;\n chapterUrl: string;\n releaseTimeText: string;\n minutesAgo: number;\n}\n\ninterface NewSeriesDetails extends ScrapedChapterInfo {\n definitiveSeriesTitle: string;\n definitiveSeriesImage: string;\n synopsis: string | null;\n}\n\n/*──────────────────── 5 ▸ helper functions ──────────────────────────────*/\nconst getCurrentTimestamp = () => new Date().toISOString().slice(11, 19);\nconst log = (...args: any[]) => {\n if (DEBUG_MODE) console.log(`[${getCurrentTimestamp()}]`, ...args);\n};\nconst errorLog = (...args: any[]) => {\n console.error(`[${getCurrentTimestamp()}] ERROR:`, ...args);\n};\nconst htmlToText = (htmlString = \"\"): string => htmlString.replace(/<[^>]*>/g, \"\").replace(/\\s+/g, \" \").trim();\nconst normalizeChapterNumber = (text: string): string => (text.match(/(\\d+(\\.\\d+)?)/)?.[1] || \"\");\nconst normalizeString = (str = \"\"): string => str.replace(/[‐–—−\\-]/g, \"-\").replace(/\\s+/g, \" \").trim().toLowerCase();\n\nfunction parseMinutesFromPhrase(phrase = \"\"): number {\n const s = phrase.toLowerCase();\n let isolatedTimePhrase = s;\n const specificTimeMatch = s.match(\n /((?:(?:\\d+\\s+)?(?:second|minute|min|hour|day|week|month|year)s?\\s+ago)|(?:public\\s+in\\s+(?:\\d+\\s+)?(?:second|minute|min|hour)s?))/i,\n );\n if (specificTimeMatch && specificTimeMatch[0]) isolatedTimePhrase = specificTimeMatch[0];\n\n const numMatch = isolatedTimePhrase.match(/-?\\d+(?:\\.\\d+)?/);\n const num = parseFloat(numMatch?.[0] || \"NaN\");\n\n if (isolatedTimePhrase.includes(\"less than\") || isolatedTimePhrase.includes(\"second\")) return 0;\n if (isolatedTimePhrase.includes(\"now\")) return 0;\n if (\n isolatedTimePhrase.includes(\"week\") || isolatedTimePhrase.includes(\"month\") || isolatedTimePhrase.includes(\"year\")\n ) return 999_999;\n if (Number.isNaN(num)) return 999_999;\n\n if (isolatedTimePhrase.includes(\"public in\"))\n return isolatedTimePhrase.includes(\"hour\")\n ? -Math.round(num * 60)\n : -Math.round(num);\n if (isolatedTimePhrase.includes(\"day\")) return Math.round(num * 60 * 24);\n if (isolatedTimePhrase.includes(\"hour\")) return Math.round(num * 60);\n if (isolatedTimePhrase.includes(\"minute\") || isolatedTimePhrase.includes(\"min\")) return Math.round(num);\n return 999_999;\n}\n\n/*──────────────────── 6 ▸ HTTP client (axios) ───────────────────────────*/\nconst httpClient = axios.create({\n headers: { \"User-Agent\": USER_AGENT },\n timeout: REQUEST_TIMEOUT_MS,\n maxRedirects: 5,\n});\n\n/*──────────────────── 7 ▸ State Management (KV Store) ───────────────────*/\nasync function getKvStore(): Promise {\n return await Deno.openKv();\n}\n\n// For new series, we only need to store the seriesPageUrl once announced\nasync function hasNewSeriesBeenAnnounced(seriesPageUrl: string): Promise {\n const normalizedUrl = normalizeString(seriesPageUrl);\n let kvStore: Deno.Kv | undefined;\n try {\n kvStore = await getKvStore();\n const result = await kvStore.get([KV_ANNOUNCED_NEW_SERIES_KEY]);\n return result.value ? result.value.includes(normalizedUrl) : false;\n } catch (e) {\n errorLog(\"KV get error (hasNewSeriesBeenAnnounced):\", e.message);\n return true;\n }\n finally {\n try {\n kvStore?.close();\n } catch (e) { /*ignore*/ }\n }\n}\n\nasync function markNewSeriesAsAnnounced(seriesPageUrl: string): Promise {\n const normalizedUrl = normalizeString(seriesPageUrl);\n let kvStore: Deno.Kv | undefined;\n try {\n kvStore = await getKvStore();\n let success = false;\n let attempts = 0;\n const maxAttempts = 3;\n\n while (!success && attempts < maxAttempts) {\n attempts++;\n const currentEntry = await kvStore.get([KV_ANNOUNCED_NEW_SERIES_KEY]);\n let announced: string[] = currentEntry.value || [];\n if (announced.includes(normalizedUrl)) {\n log(\"New series already marked (concurrent or previous):\", normalizedUrl);\n return;\n }\n\n const newAnnounced = [...announced, normalizedUrl];\n const MAX_ANNOUNCED_ITEMS = 500; // Can store more new series titles over time\n const finalAnnounced = newAnnounced.length > MAX_ANNOUNCED_ITEMS\n ? newAnnounced.slice(newAnnounced.length - MAX_ANNOUNCED_ITEMS)\n : newAnnounced;\n\n const res = await kvStore.atomic().check(currentEntry).set([KV_ANNOUNCED_NEW_SERIES_KEY], finalAnnounced)\n .commit();\n success = res.ok;\n if (!success && attempts < maxAttempts) {\n log(`Atomic KV set failed for new series (attempt ${attempts}/${maxAttempts}), retrying:`, normalizedUrl);\n await new Promise(r => setTimeout(r, 100 * attempts));\n }\n }\n if (success) log(\"Marked new series as announced:\", normalizedUrl);\n else errorLog(\"Failed to mark new series as announced after multiple attempts:\", normalizedUrl);\n } catch (e) {\n errorLog(\"KV set error (markNewSeriesAsAnnounced):\", e.message);\n }\n finally {\n try {\n kvStore?.close();\n } catch (e) { /*ignore*/ }\n }\n}\n\n/*──────────────────── 8 ▸ Scraping Logic ────────────────────────────────*/\n// buildChapterObject, scrapeMainPageForPotentialTargetChapters, scrapeSeriesPageDetailsForTargetChapter\n// are the same as in the previous full sender.ts code.\n// I'll include them here for completeness.\n\nfunction buildChapterObject(\n $: cheerio.CheerioAPI,\n chapterLinkElement: cheerio.Element,\n seriesTitle: string,\n seriesImage: string | null | undefined,\n releaseTimeTextFromCaller: string,\n seriesPageUrl: string,\n): ScrapedChapterInfo | null {\n const $anchor = $(chapterLinkElement);\n const href = $anchor.attr(\"href\");\n\n if (!href) {\n log(`SCRAPE: Anchor element has no href for series \"${seriesTitle}\"`);\n return null;\n }\n\n const $chapterNumberP = $anchor.find(\"p[class*='w-[']\").first();\n const chapterNumberTextInHtml = htmlToText($chapterNumberP.text());\n const normalizedChapterNum = normalizeChapterNumber(chapterNumberTextInHtml);\n\n if (!normalizedChapterNum) {\n log(`SCRAPE: No valid chapter number in \"${chapterNumberTextInHtml}\" for: ${href}`);\n return null;\n }\n\n const minutesAgo = parseMinutesFromPhrase(releaseTimeTextFromCaller);\n\n return {\n seriesTitle: seriesTitle,\n seriesImage: seriesImage,\n seriesPageUrl: seriesPageUrl,\n chapterNumberText: chapterNumberTextInHtml,\n normalizedChapterNumber: normalizedChapterNum,\n chapterUrl: new URL(href, BASE_URL).href,\n releaseTimeText: releaseTimeTextFromCaller,\n minutesAgo: minutesAgo,\n };\n}\n\nasync function scrapeMainPageForPotentialChapters(): Promise { // Renamed for generic use\n log(\"Scraping main page for potential chapters:\", BASE_URL);\n const potentialChapters: ScrapedChapterInfo[] = [];\n try {\n const { data } = await httpClient.get(BASE_URL, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const headingElement = $(\"h3\").filter((_, h) => $(h).text().trim().toLowerCase() === \"latest updates\").first();\n if (!headingElement.length) {\n log(\"Could not find 'Latest Updates' heading.\");\n return [];\n }\n const updateBox = headingElement.parent().next(\"div.grid\");\n if (!updateBox.length) {\n log(\"Could not find 'div.grid' update box.\");\n return [];\n }\n\n updateBox.find(\"div.w-full.p-1.pt-1.pb-3\").each((_idx, itemBlock) => {\n const $itemBlock = $(itemBlock);\n const $seriesLinkElement = $itemBlock.find(\"span.text-\\\\[15px\\\\].font-medium a[href*='/series/']\").first();\n const preliminarySeriesTitle = htmlToText($seriesLinkElement.text());\n const seriesPagePath = $seriesLinkElement.attr(\"href\");\n\n if (!preliminarySeriesTitle || !seriesPagePath) {\n log(`SCRAPE: Skipping item block, missing series title or page URL.`);\n return;\n }\n const seriesPageUrl = new URL(seriesPagePath, BASE_URL).href;\n const preliminarySeriesImage = $itemBlock.find(\"div.col-span-3 a img\").attr(\"src\");\n const seriesImageFullUrl = preliminarySeriesImage ? new URL(preliminarySeriesImage, BASE_URL).href : null;\n\n $itemBlock.find(\"div.flex.flex-col > span.flex-1 > div.flex.flex-row.justify-between\").each((_cIdx, chapDiv) => {\n const $chapDiv = $(chapDiv);\n const $chapterLinkAnchor = $chapDiv.find(\"a[href*='/chapter/']\").first();\n\n if (!$chapterLinkAnchor.length || !$chapterLinkAnchor.attr(\"href\")) {\n log(`SCRAPE: No chapter link found in a chapDiv for \"${preliminarySeriesTitle}\"`);\n return;\n }\n\n let releaseTimeText = \"\";\n const $lastChildP = $chapDiv.children(\"p\").last();\n const $lastChildDivWithTime = $chapDiv.children(\"div.flex\").last();\n\n if (\n $lastChildP.length\n && ($lastChildP.text().toLowerCase().includes(\"ago\") || $lastChildP.text().toLowerCase().includes(\"now\"))\n ) {\n releaseTimeText = htmlToText($lastChildP.text());\n } else if ($lastChildDivWithTime.length && $lastChildDivWithTime.find(\"svg.lucide-timer\").length > 0) {\n const $publicInP = $lastChildDivWithTime.find(\"p\");\n if ($publicInP.length && $publicInP.text().toLowerCase().includes(\"public in\")) {\n releaseTimeText = htmlToText($publicInP.text());\n }\n }\n\n if (!releaseTimeText) {\n log(\n `SCRAPE: Could not find release time text for chapter under \"${preliminarySeriesTitle}\", link: ${\n $chapterLinkAnchor.attr(\"href\")\n }`,\n );\n return;\n }\n\n const chapterInfo = buildChapterObject(\n $,\n $chapterLinkAnchor.get(0) as cheerio.Element,\n preliminarySeriesTitle,\n seriesImageFullUrl,\n releaseTimeText,\n seriesPageUrl,\n );\n\n if (chapterInfo) {\n potentialChapters.push(chapterInfo);\n }\n });\n });\n log(`Found ${potentialChapters.length} potential chapter entries on main page.`);\n return potentialChapters;\n } catch (e) {\n errorLog(\"Failed to scrape main page:\", e.message);\n if (axios.isAxiosError(e) && e.response) errorLog(\"Scrape error status:\", e.response.status);\n return [];\n }\n}\n\nasync function scrapeSeriesPageForDetails(seriesPageUrl: string): Promise> { // Renamed for generic use\n log(\"Scraping series page for details:\", seriesPageUrl);\n try {\n const { data } = await httpClient.get(seriesPageUrl, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const definitiveSeriesTitle = htmlToText($(\"h2.text-\\\\[25px\\\\].font-semibold.text-white\").first().text())\n || htmlToText($(\"h1\").first().text());\n const $coverImageElement = $(\"div.flex.flex-col.items-center img.aspect-\\\\[2\\\\/3\\\\]\").first();\n let definitiveSeriesImage = $coverImageElement.attr(\"src\") || \"\";\n if (definitiveSeriesImage && !definitiveSeriesImage.startsWith(\"http\")) {\n definitiveSeriesImage = new URL(definitiveSeriesImage, BASE_URL).href;\n }\n\n let synopsis: string | null = null;\n const $synopsisHeading = $(\"h3.text-\\\\[\\\\#D9D9D9\\\\].font-medium.text-sm\").filter((_, el) =>\n $(el).text().toLowerCase().includes(\"synopsis\")\n ).first();\n if ($synopsisHeading.length) {\n const $synopsisContainer = $synopsisHeading.next(\"span.font-medium.text-sm.text-\\\\[\\\\#A2A2A2\\\\]\");\n if ($synopsisContainer.length) {\n const $synopsisParagraph = $synopsisContainer.find(\"p\");\n if ($synopsisParagraph.length)\n synopsis = htmlToText($synopsisParagraph.html()?.replace(//gi, \"\\n\") || \"\");\n else {\n const spanText = htmlToText($synopsisContainer.html()?.replace(//gi, \"\\n\") || \"\");\n if (spanText.length > 50) synopsis = spanText;\n }\n }\n }\n if (!synopsis && definitiveSeriesTitle && definitiveSeriesTitle !== \"Unknown Title\") {\n $(\"p\").each((_i, el) => {\n if (synopsis) return;\n const pText = $(el).text();\n if (\n pText.length > 150\n && (pText.toLowerCase().includes(\n definitiveSeriesTitle.toLowerCase().substring(0, Math.min(10, definitiveSeriesTitle.length)),\n ) || pText.toLowerCase().includes(\"story of\") || pText.toLowerCase().includes(\"follows the journey\"))\n ) {\n synopsis = htmlToText($(el).html()?.replace(//gi, \"\\n\") || \"\");\n }\n });\n }\n return { definitiveSeriesTitle: definitiveSeriesTitle || \"Unknown Title\", definitiveSeriesImage, synopsis };\n } catch (e) {\n errorLog(\"Failed to scrape series page:\", seriesPageUrl, e.message);\n if (axios.isAxiosError(e) && e.response) errorLog(\"Series page scrape error status:\", e.response.status);\n return {\n definitiveSeriesTitle: \"Error fetching title\",\n definitiveSeriesImage: \"\",\n synopsis: \"Error fetching synopsis.\",\n };\n }\n}\n\n/*──────────────────── 9 ▸ Main Orchestration Logic ──────────────────────*/\nexport default async function announceNewSeriesMain() { // Renamed main function for clarity\n log(`=== New Series Announcer (Target: Chapter ${TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES}) Run Start ===`);\n try {\n await bot.api.getMe();\n log(\"Bot token validated.\");\n }\n catch (e) {\n errorLog(\"Invalid Bot Token:\", e.message);\n return;\n }\n\n const potentialNewSeriesChapters = await scrapeMainPageForPotentialChapters();\n if (!potentialNewSeriesChapters.length) {\n log(\"No potential chapter entries found.\");\n log(\"=== New Series Announcer Run End ===\");\n return;\n }\n\n const seriesToAnnounce: NewSeriesDetails[] = [];\n for (const entry of potentialNewSeriesChapters) {\n log(\n `Checking: \"${entry.seriesTitle}\", Ch ${entry.normalizedChapterNumber} (Raw: \"${entry.chapterNumberText}\", Target ${TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES}), Time: ${entry.releaseTimeText} (${entry.minutesAgo}m ago)`,\n );\n\n if (\n entry.normalizedChapterNumber === TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES\n && entry.minutesAgo >= MIN_NEW_SERIES_CHAPTER_1_AGE_MINUTES\n && entry.minutesAgo <= (MAX_NEW_SERIES_CHAPTER_1_AGE_HOURS * 60)\n ) {\n log(`Found matching NEW SERIES (Chapter ${TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES}): \"${entry.seriesTitle}\"`);\n\n if (await hasNewSeriesBeenAnnounced(entry.seriesPageUrl)) { // Use the new KV check\n log(`Already announced as new series: \"${entry.seriesTitle}\"`);\n continue;\n }\n\n const details = await scrapeSeriesPageForDetails(entry.seriesPageUrl);\n if (\n !details.definitiveSeriesTitle || details.definitiveSeriesTitle === \"Unknown Title\"\n || details.definitiveSeriesTitle === \"Error fetching title\"\n ) {\n errorLog(`No valid definitive title for \"${entry.seriesTitle}\" from ${entry.seriesPageUrl}, skipping.`);\n continue;\n }\n\n const completeEntry: NewSeriesDetails = {\n seriesTitle: entry.seriesTitle,\n seriesImage: entry.seriesImage,\n seriesPageUrl: entry.seriesPageUrl,\n chapterNumberText: entry.chapterNumberText,\n normalizedChapterNumber: entry.normalizedChapterNumber,\n chapterUrl: entry.chapterUrl,\n releaseTimeText: entry.releaseTimeText,\n minutesAgo: entry.minutesAgo,\n definitiveSeriesTitle: details.definitiveSeriesTitle,\n definitiveSeriesImage: details.definitiveSeriesImage || entry.seriesImage || \"\",\n synopsis: details.synopsis || null,\n };\n seriesToAnnounce.push(completeEntry);\n }\n }\n\n if (!seriesToAnnounce.length) {\n log(`No unannounced new series (Chapter ${TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES}, recent) found.`);\n log(\"=== New Series Announcer Run End ===\");\n return;\n }\n log(`Found ${seriesToAnnounce.length} new series to announce.`);\n\n for (const series of seriesToAnnounce) {\n const nameOfManhwa = htmlToText(series.definitiveSeriesTitle);\n const synopsisText = series.synopsis ? `\\n\\nSynopsis:\\n${htmlToText(series.synopsis)}` : \"\";\n // Use definitiveSeriesImage first, then the one from the list, then provide a placeholder if none\n const imageUrl = series.definitiveSeriesImage || series.seriesImage;\n\n // Message template for NEW SERIES\n const message = `We've picked up a NEW SERIES!\n\n${nameOfManhwa}\n\nChapter ${TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES} is now available on the site\nand this is just the start.\nMore chapters are coming soon, so don’t miss out!\n${synopsisText}\n\nLink to chapter ${TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES}: Read Chapter ${TARGET_CHAPTER_NUMBER_FOR_NEW_SERIES}`;\n\n try {\n log(`Announcing NEW SERIES to ${ANNOUNCEMENT_CHAT_ID}: ${nameOfManhwa}`);\n if (imageUrl) {\n await bot.api.sendPhoto(ANNOUNCEMENT_CHAT_ID, imageUrl, { caption: message, parse_mode: \"HTML\" });\n } else {\n log(`No image for new series ${nameOfManhwa}, sending text only.`);\n await bot.api.sendMessage(ANNOUNCEMENT_CHAT_ID, message, {\n parse_mode: \"HTML\",\n disable_web_page_preview: false,\n });\n }\n log(`Successfully announced NEW SERIES: ${nameOfManhwa}`);\n await markNewSeriesAsAnnounced(series.seriesPageUrl); // Use the new KV mark\n } catch (e) {\n errorLog(`TG send error for NEW SERIES ${nameOfManhwa}:`, e.message);\n if (BOT_OWNER_ID) {\n try {\n await bot.api.sendMessage(\n BOT_OWNER_ID,\n `Failed to announce NEW SERIES ${nameOfManhwa}.\\nError: ${e.message.substring(0, 300)}`,\n ).catch(err => errorLog(\"Owner error send fail:\", err.message));\n }\n catch (ownerError) {\n errorLog(\"Owner error send outer fail:\", ownerError.message);\n }\n }\n }\n if (seriesToAnnounce.indexOf(series) < seriesToAnnounce.length - 1) {\n await new Promise(resolve => setTimeout(resolve, 4000)); // Slightly longer delay for new series posts\n }\n }\n log(\"=== New Series Announcer Run End ===\");\n}",10,["D",1749068892287],28,{"_103":223,"_155":137,"_152":173,"_95":99,"_164":224,"_162":176,"_100":225,"_154":-5,"_105":226,"_156":227,"_167":-5},"c4d30616-4181-11f0-8a82-76b3cceeab13","// sender.ts @ValTown\n// Scans asuracomic.net for a specific target chapter (e.g., 263) and announces it.\n// No token privatization as per request.\n// Uses Deno.openKv() for ValTown KV store.\n// Updated scraping logic based on new HTML snippet.\n// ──────────────────────────────────────────────────────────────────────────\n\n/*──────────────────── 1 ▸ imports ───────────────────────────────────────*/\nimport axios from \"npm:axios@1.6.8\";\nimport cheerio from \"npm:cheerio@1.0.0-rc.12\";\nimport { Bot } from \"npm:grammy@1.19.2\";\n\n/*──────────────────── 2 ▸ configuration (secrets & settings) ──────────*/\nconst BOT_TOKEN = \"6923200542:AAGdyYJydP1kcHjrO5aOr8Ams2GflTEki8c\";\nconst ANNOUNCEMENT_CHAT_ID = \"@mandoqa\";\nconst BOT_OWNER_ID = 6129128211;\n\nconst TARGET_CHAPTER_NUMBER_TO_ANNOUNCE = \"263\";\nconst MAX_TARGET_CHAPTER_AGE_HOURS = 24;\nconst MIN_TARGET_CHAPTER_AGE_MINUTES = 0;\n\nconst BASE_URL = \"https://asuracomic.net\";\nconst USER_AGENT =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 SpecificChapterBot/1.3.1-htmlfix\";\n\nconst REQUEST_TIMEOUT_MS = 30_000;\nconst KV_ANNOUNCED_TARGET_CHAPTERS_KEY = \"announcedTargetChapters_asura_v4\";\n\nconst DEBUG_MODE = true;\n\n/*──────────────────── 3 ▸ Telegram Bot Initialization ───────────────────*/\nconst bot = new Bot(BOT_TOKEN);\n\n/*──────────────────── 4 ▸ Types & Interfaces ───────────────────────────*/\ninterface ScrapedChapterInfo {\n seriesTitle: string;\n seriesImage?: string | null;\n seriesPageUrl: string;\n chapterNumberText: string;\n normalizedChapterNumber: string;\n chapterUrl: string;\n releaseTimeText: string;\n minutesAgo: number;\n}\n\ninterface SeriesDetailsForTargetChapter extends ScrapedChapterInfo {\n definitiveSeriesTitle: string;\n definitiveSeriesImage: string;\n synopsis: string | null;\n}\n\n/*──────────────────── 5 ▸ helper functions ──────────────────────────────*/\nconst getCurrentTimestamp = () => new Date().toISOString().slice(11, 19);\nconst log = (...args: any[]) => {\n if (DEBUG_MODE) console.log(`[${getCurrentTimestamp()}]`, ...args);\n};\nconst errorLog = (...args: any[]) => {\n console.error(`[${getCurrentTimestamp()}] ERROR:`, ...args);\n};\nconst htmlToText = (htmlString = \"\"): string => htmlString.replace(/<[^>]*>/g, \"\").replace(/\\s+/g, \" \").trim();\nconst normalizeChapterNumber = (text: string): string => (text.match(/(\\d+(\\.\\d+)?)/)?.[1] || \"\");\nconst normalizeString = (str = \"\"): string => str.replace(/[‐–—−\\-]/g, \"-\").replace(/\\s+/g, \" \").trim().toLowerCase();\n\nfunction parseMinutesFromPhrase(phrase = \"\"): number {\n const s = phrase.toLowerCase();\n let isolatedTimePhrase = s;\n const specificTimeMatch = s.match(\n /((?:(?:\\d+\\s+)?(?:second|minute|min|hour|day|week|month|year)s?\\s+ago)|(?:public\\s+in\\s+(?:\\d+\\s+)?(?:second|minute|min|hour)s?))/i,\n );\n if (specificTimeMatch && specificTimeMatch[0]) isolatedTimePhrase = specificTimeMatch[0];\n\n const numMatch = isolatedTimePhrase.match(/-?\\d+(?:\\.\\d+)?/);\n const num = parseFloat(numMatch?.[0] || \"NaN\");\n\n if (isolatedTimePhrase.includes(\"less than\") || isolatedTimePhrase.includes(\"second\")) return 0;\n if (isolatedTimePhrase.includes(\"now\")) return 0;\n if (\n isolatedTimePhrase.includes(\"week\") || isolatedTimePhrase.includes(\"month\") || isolatedTimePhrase.includes(\"year\")\n ) return 999_999;\n if (Number.isNaN(num)) return 999_999;\n\n if (isolatedTimePhrase.includes(\"public in\"))\n return isolatedTimePhrase.includes(\"hour\")\n ? -Math.round(num * 60)\n : -Math.round(num);\n if (isolatedTimePhrase.includes(\"day\")) return Math.round(num * 60 * 24);\n if (isolatedTimePhrase.includes(\"hour\")) return Math.round(num * 60);\n if (isolatedTimePhrase.includes(\"minute\") || isolatedTimePhrase.includes(\"min\")) return Math.round(num);\n return 999_999;\n}\n\n/*──────────────────── 6 ▸ HTTP client (axios) ───────────────────────────*/\nconst httpClient = axios.create({\n headers: { \"User-Agent\": USER_AGENT },\n timeout: REQUEST_TIMEOUT_MS,\n maxRedirects: 5,\n});\n\n/*──────────────────── 7 ▸ State Management (KV Store) ───────────────────*/\nasync function getKvStore(): Promise {\n return await Deno.openKv();\n}\n\nasync function hasTargetChapterBeenAnnounced(seriesPageUrl: string, chapterNumber: string): Promise {\n const uniqueId = `${normalizeString(seriesPageUrl)}#${chapterNumber}`;\n let kvStore: Deno.Kv | undefined;\n try {\n kvStore = await getKvStore();\n const result = await kvStore.get([KV_ANNOUNCED_TARGET_CHAPTERS_KEY]);\n return result.value ? result.value.includes(uniqueId) : false;\n } catch (e) {\n errorLog(\"KV get error:\", e.message);\n return true;\n }\n finally {\n try {\n kvStore?.close();\n } catch (e) { /*ignore close error in finally*/ }\n }\n}\n\nasync function markTargetChapterAsAnnounced(seriesPageUrl: string, chapterNumber: string): Promise {\n const uniqueId = `${normalizeString(seriesPageUrl)}#${chapterNumber}`;\n let kvStore: Deno.Kv | undefined;\n try {\n kvStore = await getKvStore();\n let success = false;\n let attempts = 0;\n const maxAttempts = 3;\n\n while (!success && attempts < maxAttempts) {\n attempts++;\n const currentEntry = await kvStore.get([KV_ANNOUNCED_TARGET_CHAPTERS_KEY]);\n let announced: string[] = currentEntry.value || [];\n if (announced.includes(uniqueId)) {\n log(\"Already marked (concurrent check or previous attempt):\", uniqueId);\n return;\n }\n\n const newAnnounced = [...announced, uniqueId];\n const MAX_ANNOUNCED_ITEMS = 300;\n const finalAnnounced = newAnnounced.length > MAX_ANNOUNCED_ITEMS\n ? newAnnounced.slice(newAnnounced.length - MAX_ANNOUNCED_ITEMS)\n : newAnnounced;\n\n const res = await kvStore.atomic().check(currentEntry).set([KV_ANNOUNCED_TARGET_CHAPTERS_KEY], finalAnnounced)\n .commit();\n success = res.ok;\n if (!success && attempts < maxAttempts) {\n log(`Atomic KV set failed (attempt ${attempts}/${maxAttempts}), retrying for:`, uniqueId);\n await new Promise(r => setTimeout(r, 100 * attempts));\n }\n }\n if (success) log(\"Marked target chapter as announced:\", uniqueId);\n else errorLog(\"Failed to mark target chapter as announced after multiple attempts:\", uniqueId);\n } catch (e) {\n errorLog(\"KV set error:\", e.message);\n }\n finally {\n try {\n kvStore?.close();\n } catch (e) { /*ignore close error in finally*/ }\n }\n}\n\n/*──────────────────── 8 ▸ Scraping Logic ────────────────────────────────*/\nfunction buildChapterObject(\n $: cheerio.CheerioAPI,\n chapterLinkElement: cheerio.Element,\n seriesTitle: string,\n seriesImage: string | null | undefined,\n releaseTimeTextFromCaller: string,\n seriesPageUrl: string,\n): ScrapedChapterInfo | null {\n const $anchor = $(chapterLinkElement);\n const href = $anchor.attr(\"href\");\n\n if (!href) {\n log(`SCRAPE: Anchor element has no href for series \"${seriesTitle}\"`);\n return null;\n }\n\n const $chapterNumberP = $anchor.find(\"p[class*='w-[']\").first();\n const chapterNumberTextInHtml = htmlToText($chapterNumberP.text());\n const normalizedChapterNum = normalizeChapterNumber(chapterNumberTextInHtml);\n\n if (!normalizedChapterNum) {\n log(`SCRAPE: No valid chapter number in \"${chapterNumberTextInHtml}\" for: ${href}`);\n return null;\n }\n\n const minutesAgo = parseMinutesFromPhrase(releaseTimeTextFromCaller);\n\n return {\n seriesTitle: seriesTitle,\n seriesImage: seriesImage,\n seriesPageUrl: seriesPageUrl,\n chapterNumberText: chapterNumberTextInHtml,\n normalizedChapterNumber: normalizedChapterNum,\n chapterUrl: new URL(href, BASE_URL).href,\n releaseTimeText: releaseTimeTextFromCaller,\n minutesAgo: minutesAgo,\n };\n}\n\nasync function scrapeMainPageForPotentialTargetChapters(): Promise {\n log(\"Scraping main page for target chapters:\", BASE_URL);\n const potentialChapters: ScrapedChapterInfo[] = [];\n try {\n const { data } = await httpClient.get(BASE_URL, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const headingElement = $(\"h3\").filter((_, h) => $(h).text().trim().toLowerCase() === \"latest updates\").first();\n if (!headingElement.length) {\n log(\"Could not find 'Latest Updates' heading.\");\n return [];\n }\n const updateBox = headingElement.parent().next(\"div.grid\");\n if (!updateBox.length) {\n log(\"Could not find 'div.grid' update box.\");\n return [];\n }\n\n updateBox.find(\"div.w-full.p-1.pt-1.pb-3\").each((_idx, itemBlock) => {\n const $itemBlock = $(itemBlock);\n const $seriesLinkElement = $itemBlock.find(\"span.text-\\\\[15px\\\\].font-medium a[href*='/series/']\").first();\n const preliminarySeriesTitle = htmlToText($seriesLinkElement.text());\n const seriesPagePath = $seriesLinkElement.attr(\"href\");\n\n if (!preliminarySeriesTitle || !seriesPagePath) {\n log(\n `SCRAPE: Skipping item block, missing series title or page URL. HTML: ${\n $itemBlock.html()?.substring(0, 100)\n }`,\n );\n return;\n }\n const seriesPageUrl = new URL(seriesPagePath, BASE_URL).href;\n const preliminarySeriesImage = $itemBlock.find(\"div.col-span-3 a img\").attr(\"src\");\n const seriesImageFullUrl = preliminarySeriesImage ? new URL(preliminarySeriesImage, BASE_URL).href : null;\n\n $itemBlock.find(\"div.flex.flex-col > span.flex-1 > div.flex.flex-row.justify-between\").each((_cIdx, chapDiv) => {\n const $chapDiv = $(chapDiv);\n const $chapterLinkAnchor = $chapDiv.find(\"a[href*='/chapter/']\").first();\n\n if (!$chapterLinkAnchor.length || !$chapterLinkAnchor.attr(\"href\")) {\n log(`SCRAPE: No chapter link found in a chapDiv for \"${preliminarySeriesTitle}\"`);\n return;\n }\n\n let releaseTimeText = \"\";\n const $lastChildP = $chapDiv.children(\"p\").last();\n const $lastChildDivWithTime = $chapDiv.children(\"div.flex\").last(); // Specifically for the \"Public in\" structure\n\n if (\n $lastChildP.length\n && ($lastChildP.text().toLowerCase().includes(\"ago\") || $lastChildP.text().toLowerCase().includes(\"now\"))\n ) {\n releaseTimeText = htmlToText($lastChildP.text());\n } else if ($lastChildDivWithTime.length && $lastChildDivWithTime.find(\"svg.lucide-timer\").length > 0) { // Check for timer icon\n const $publicInP = $lastChildDivWithTime.find(\"p\"); // Find p within this div\n if ($publicInP.length && $publicInP.text().toLowerCase().includes(\"public in\")) {\n releaseTimeText = htmlToText($publicInP.text());\n }\n }\n\n if (!releaseTimeText) {\n log(\n `SCRAPE: Could not find release time text for chapter under \"${preliminarySeriesTitle}\", link: ${\n $chapterLinkAnchor.attr(\"href\")\n }`,\n );\n return;\n }\n\n const chapterInfo = buildChapterObject(\n $,\n $chapterLinkAnchor.get(0) as cheerio.Element,\n preliminarySeriesTitle,\n seriesImageFullUrl,\n releaseTimeText,\n seriesPageUrl,\n );\n\n if (chapterInfo) {\n potentialChapters.push(chapterInfo);\n }\n });\n });\n log(`Found ${potentialChapters.length} potential chapter entries on main page.`);\n return potentialChapters;\n } catch (e) {\n errorLog(\"Failed to scrape main page:\", e.message);\n if (axios.isAxiosError(e) && e.response) errorLog(\"Scrape error status:\", e.response.status);\n return [];\n }\n}\n\nasync function scrapeSeriesPageDetailsForTargetChapter(\n seriesPageUrl: string,\n): Promise> {\n log(\"Scraping series page for details:\", seriesPageUrl);\n try {\n const { data } = await httpClient.get(seriesPageUrl, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const definitiveSeriesTitle = htmlToText($(\"h2.text-\\\\[25px\\\\].font-semibold.text-white\").first().text())\n || htmlToText($(\"h1\").first().text());\n const $coverImageElement = $(\"div.flex.flex-col.items-center img.aspect-\\\\[2\\\\/3\\\\]\").first();\n let definitiveSeriesImage = $coverImageElement.attr(\"src\") || \"\";\n if (definitiveSeriesImage && !definitiveSeriesImage.startsWith(\"http\")) { // Ensure it's a full URL\n definitiveSeriesImage = new URL(definitiveSeriesImage, BASE_URL).href;\n }\n\n let synopsis: string | null = null;\n const $synopsisHeading = $(\"h3.text-\\\\[\\\\#D9D9D9\\\\].font-medium.text-sm\").filter((_, el) =>\n $(el).text().toLowerCase().includes(\"synopsis\")\n ).first();\n if ($synopsisHeading.length) {\n const $synopsisContainer = $synopsisHeading.next(\"span.font-medium.text-sm.text-\\\\[\\\\#A2A2A2\\\\]\");\n if ($synopsisContainer.length) {\n const $synopsisParagraph = $synopsisContainer.find(\"p\");\n if ($synopsisParagraph.length)\n synopsis = htmlToText($synopsisParagraph.html()?.replace(//gi, \"\\n\") || \"\");\n else {\n const spanText = htmlToText($synopsisContainer.html()?.replace(//gi, \"\\n\") || \"\");\n if (spanText.length > 50) synopsis = spanText;\n }\n }\n }\n if (!synopsis && definitiveSeriesTitle && definitiveSeriesTitle !== \"Unknown Title\") {\n $(\"p\").each((_i, el) => {\n if (synopsis) return;\n const pText = $(el).text();\n if (\n pText.length > 150\n && (pText.toLowerCase().includes(\n definitiveSeriesTitle.toLowerCase().substring(0, Math.min(10, definitiveSeriesTitle.length)),\n ) || pText.toLowerCase().includes(\"story of\") || pText.toLowerCase().includes(\"follows the journey\"))\n ) {\n synopsis = htmlToText($(el).html()?.replace(//gi, \"\\n\") || \"\");\n }\n });\n }\n return { definitiveSeriesTitle: definitiveSeriesTitle || \"Unknown Title\", definitiveSeriesImage, synopsis };\n } catch (e) {\n errorLog(\"Failed to scrape series page:\", seriesPageUrl, e.message);\n if (axios.isAxiosError(e) && e.response) errorLog(\"Series page scrape error status:\", e.response.status);\n return {\n definitiveSeriesTitle: \"Error fetching title\",\n definitiveSeriesImage: \"\",\n synopsis: \"Error fetching synopsis.\",\n };\n }\n}\n\n/*──────────────────── 9 ▸ Main Orchestration Logic ──────────────────────*/\nexport default async function sender() {\n log(`=== Specific Chapter Announcer (Sender | Target: ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}) Run Start ===`);\n try {\n await bot.api.getMe();\n log(\"Bot token validated.\");\n }\n catch (e) {\n errorLog(\"Invalid Bot Token:\", e.message);\n return;\n }\n\n const potentialTargetChapters = await scrapeMainPageForPotentialTargetChapters();\n if (!potentialTargetChapters.length) {\n log(\"No potential chapter entries found.\");\n log(\"=== Sender Run End ===\");\n return;\n }\n\n const chaptersToAnnounce: SeriesDetailsForTargetChapter[] = [];\n for (const entry of potentialTargetChapters) {\n log(\n `Checking: \"${entry.seriesTitle}\", Ch ${entry.normalizedChapterNumber} (Raw: \"${entry.chapterNumberText}\", Target ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}), Time: ${entry.releaseTimeText} (${entry.minutesAgo}m ago)`,\n );\n\n if (\n entry.normalizedChapterNumber === TARGET_CHAPTER_NUMBER_TO_ANNOUNCE\n && entry.minutesAgo >= MIN_TARGET_CHAPTER_AGE_MINUTES\n && entry.minutesAgo <= (MAX_TARGET_CHAPTER_AGE_HOURS * 60)\n ) {\n log(`Found matching target: \"${entry.seriesTitle}\" - Ch ${entry.normalizedChapterNumber}`);\n\n if (await hasTargetChapterBeenAnnounced(entry.seriesPageUrl, TARGET_CHAPTER_NUMBER_TO_ANNOUNCE)) {\n log(`Already announced: \"${entry.seriesTitle}\" - Ch ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n continue;\n }\n\n const details = await scrapeSeriesPageDetailsForTargetChapter(entry.seriesPageUrl);\n if (\n !details.definitiveSeriesTitle || details.definitiveSeriesTitle === \"Unknown Title\"\n || details.definitiveSeriesTitle === \"Error fetching title\"\n ) {\n errorLog(`No valid definitive title for \"${entry.seriesTitle}\" from ${entry.seriesPageUrl}, skipping.`);\n continue;\n }\n\n // Merge details, ensuring all fields from ScrapedChapterInfo are present\n const completeEntry: SeriesDetailsForTargetChapter = {\n seriesTitle: entry.seriesTitle, // Keep preliminary from main page for reference if needed\n seriesImage: entry.seriesImage,\n seriesPageUrl: entry.seriesPageUrl,\n chapterNumberText: entry.chapterNumberText,\n normalizedChapterNumber: entry.normalizedChapterNumber,\n chapterUrl: entry.chapterUrl,\n releaseTimeText: entry.releaseTimeText,\n minutesAgo: entry.minutesAgo,\n definitiveSeriesTitle: details.definitiveSeriesTitle, // Override with definitive\n definitiveSeriesImage: details.definitiveSeriesImage || entry.seriesImage || \"\", // Prioritize definitive image\n synopsis: details.synopsis || null,\n };\n chaptersToAnnounce.push(completeEntry);\n }\n }\n\n if (!chaptersToAnnounce.length) {\n log(`No unannounced target chapters (${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}, recent) found.`);\n log(\"=== Sender Run End ===\");\n return;\n }\n log(`Found ${chaptersToAnnounce.length} target chapter(s) to announce.`);\n\n for (const series of chaptersToAnnounce) {\n const nameOfManhwa = htmlToText(series.definitiveSeriesTitle);\n const synopsisText = series.synopsis ? `\\n\\nSynopsis:\\n${htmlToText(series.synopsis)}` : \"\";\n const imageUrl = series.definitiveSeriesImage || series.seriesImage; // Use definitive image first, then list image\n\n const message =\n `📣 Heads up, readers! 📣\\n\\n${nameOfManhwa}\\nChapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE} is now available on the site!\\nRead Chapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE} Now\\n\\nDon't miss out on the latest developments!${synopsisText}`;\n try {\n log(`Announcing to ${ANNOUNCEMENT_CHAT_ID}: ${nameOfManhwa} - Ch ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n if (imageUrl) {\n await bot.api.sendPhoto(ANNOUNCEMENT_CHAT_ID, imageUrl, { caption: message, parse_mode: \"HTML\" });\n } else {\n log(`No image for ${nameOfManhwa}, sending text only.`);\n await bot.api.sendMessage(ANNOUNCEMENT_CHAT_ID, message, {\n parse_mode: \"HTML\",\n disable_web_page_preview: false,\n });\n }\n log(`Successfully announced: ${nameOfManhwa} - Ch ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n await markTargetChapterAsAnnounced(series.seriesPageUrl, TARGET_CHAPTER_NUMBER_TO_ANNOUNCE);\n } catch (e) {\n errorLog(`TG send error for ${nameOfManhwa} - Ch ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}:`, e.message);\n if (BOT_OWNER_ID) {\n try {\n await bot.api.sendMessage(\n BOT_OWNER_ID,\n `Failed to announce TARGET CH (${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}) for ${nameOfManhwa}.\\nError: ${\n e.message.substring(0, 300)\n }`,\n ).catch(err => errorLog(\"Owner error send fail:\", err.message));\n }\n catch (ownerError) {\n errorLog(\"Owner error send outer fail:\", ownerError.message);\n }\n }\n }\n if (chaptersToAnnounce.indexOf(series) < chaptersToAnnounce.length - 1) { // Add delay if not the last item\n await new Promise(resolve => setTimeout(resolve, 3000));\n }\n }\n log(\"=== Sender Run End ===\");\n}",9,["D",1749068605712],27,{"_103":229,"_155":137,"_152":173,"_95":99,"_164":230,"_162":176,"_100":231,"_154":-5,"_105":232,"_156":233,"_167":-5},"57a7f250-4180-11f0-9db1-76b3cceeab13","// sender.ts @ValTown\n// Scans asuracomic.net for a specific target chapter (e.g., 263) and announces it.\n// No token privatization as per request.\n// Uses Deno.openKv() for ValTown KV store.\n// ──────────────────────────────────────────────────────────────────────────\n\n/*──────────────────── 1 ▸ imports ───────────────────────────────────────*/\nimport axios from \"npm:axios@1.6.8\";\nimport cheerio from \"npm:cheerio@1.0.0-rc.12\";\nimport { Bot } from \"npm:grammy@1.19.2\";\n// KV store is accessed via Deno.openKv(), no specific import needed for 'kv' object\n\n/*──────────────────── 2 ▸ configuration (secrets & settings) ──────────*/\nconst BOT_TOKEN = \"6923200542:AAGdyYJydP1kcHjrO5aOr8Ams2GflTEki8c\"; // ⚠ Your Bot Token (not privatized)\nconst ANNOUNCEMENT_CHAT_ID = \"@mandoqa\"; // Chat ID for announcements\nconst BOT_OWNER_ID = 6129128211; // Optional: Numeric Telegram User ID for error notifications\n\nconst TARGET_CHAPTER_NUMBER_TO_ANNOUNCE = \"263\";\nconst MAX_TARGET_CHAPTER_AGE_HOURS = 24 * 3; // Announce if target chapter is newer than this (e.g., 72 hours)\n\nconst BASE_URL = \"https://asuracomic.net\";\nconst USER_AGENT =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 SpecificChapterBot/1.2-denokv\";\n\nconst REQUEST_TIMEOUT_MS = 30_000;\nconst KV_ANNOUNCED_TARGET_CHAPTERS_KEY = \"announcedTargetChapters_asura_v3\"; // KV key (incremented version)\n\nconst DEBUG_MODE = true;\n\n/*──────────────────── 3 ▸ Telegram Bot Initialization ───────────────────*/\nconst bot = new Bot(BOT_TOKEN);\n\n/*──────────────────── 4 ▸ Types & Interfaces ───────────────────────────*/\ninterface ScrapedChapterInfo {\n seriesTitle: string;\n seriesImage?: string | null;\n seriesPageUrl: string;\n chapterNumberText: string;\n normalizedChapterNumber: string;\n chapterUrl: string;\n releaseTimeText: string;\n minutesAgo: number;\n}\n\ninterface SeriesDetailsForTargetChapter extends ScrapedChapterInfo {\n definitiveSeriesTitle: string;\n definitiveSeriesImage: string; // Can be empty string if not found\n synopsis: string | null;\n}\n\n/*──────────────────── 5 ▸ helper functions ──────────────────────────────*/\nconst getCurrentTimestamp = () => new Date().toISOString().slice(11, 19);\n\nconst log = (...args: any[]) => {\n if (DEBUG_MODE) console.log(`[${getCurrentTimestamp()}]`, ...args);\n};\nconst errorLog = (...args: any[]) => {\n console.error(`[${getCurrentTimestamp()}] ERROR:`, ...args);\n};\n\nconst htmlToText = (htmlString = \"\"): string => htmlString.replace(/<[^>]*>/g, \"\").replace(/\\s+/g, \" \").trim();\n\nconst normalizeChapterNumber = (text: string): string => {\n const match = text.match(/(\\d+(\\.\\d+)?)/);\n return match ? parseFloat(match[1]).toString() : \"\";\n};\n\nconst normalizeString = (str = \"\"): string => str.replace(/[‐–—−\\-]/g, \"-\").replace(/\\s+/g, \" \").trim().toLowerCase();\n\nfunction parseMinutesFromPhrase(phrase = \"\"): number {\n const s = phrase.toLowerCase();\n let isolatedTimePhrase = s;\n const specificTimeMatch = s.match(\n /((?:(?:\\d+\\s+)?(?:second|minute|min|hour|day|week|month|year)s?\\s+ago)|(?:public\\s+in\\s+(?:\\d+\\s+)?(?:second|minute|min|hour)s?))/i,\n );\n if (specificTimeMatch && specificTimeMatch[0]) {\n isolatedTimePhrase = specificTimeMatch[0];\n }\n const numMatch = isolatedTimePhrase.match(/-?\\d+(?:\\.\\d+)?/);\n const num = parseFloat(numMatch?.[0] || \"NaN\");\n\n if (isolatedTimePhrase.includes(\"less than\") || isolatedTimePhrase.includes(\"second\")) return 0;\n if (\n isolatedTimePhrase.includes(\"week\") || isolatedTimePhrase.includes(\"month\") || isolatedTimePhrase.includes(\"year\")\n ) return 999_999;\n if (Number.isNaN(num)) return 999_999;\n\n if (isolatedTimePhrase.includes(\"public in\"))\n return isolatedTimePhrase.includes(\"hour\")\n ? -Math.round(num * 60)\n : -Math.round(num);\n if (isolatedTimePhrase.includes(\"day\")) return Math.round(num * 60 * 24);\n if (isolatedTimePhrase.includes(\"hour\")) return Math.round(num * 60);\n if (isolatedTimePhrase.includes(\"minute\") || isolatedTimePhrase.includes(\"min\")) return Math.round(num);\n return 999_999;\n}\n\n/*──────────────────── 6 ▸ HTTP client (axios) ───────────────────────────*/\nconst httpClient = axios.create({\n headers: { \"User-Agent\": USER_AGENT },\n timeout: REQUEST_TIMEOUT_MS,\n maxRedirects: 5,\n});\n\n/*──────────────────── 7 ▸ State Management (KV Store) ───────────────────*/\nasync function getKvStore(): Promise {\n return await Deno.openKv(); // Use the default KV store path for ValTown\n}\n\nasync function hasTargetChapterBeenAnnounced(seriesPageUrl: string, chapterNumber: string): Promise {\n const uniqueId = `${normalizeString(seriesPageUrl)}#${chapterNumber}`;\n let kvStore: Deno.Kv | undefined;\n try {\n kvStore = await getKvStore();\n const result = await kvStore.get([KV_ANNOUNCED_TARGET_CHAPTERS_KEY]);\n return result.value ? result.value.includes(uniqueId) : false;\n } catch (e) {\n errorLog(\"KV get error for hasTargetChapterBeenAnnounced:\", e.message);\n return true;\n } finally {\n try {\n kvStore?.close();\n } catch (e) { /*ignore close error*/ }\n }\n}\n\nasync function markTargetChapterAsAnnounced(seriesPageUrl: string, chapterNumber: string): Promise {\n const uniqueId = `${normalizeString(seriesPageUrl)}#${chapterNumber}`;\n let kvStore: Deno.Kv | undefined;\n try {\n kvStore = await getKvStore();\n // Use atomic check-and-set for better concurrency safety, though less critical for this app\n let success = false;\n while (!success) {\n const currentEntry = await kvStore.get([KV_ANNOUNCED_TARGET_CHAPTERS_KEY]);\n let announced: string[] = currentEntry.value || [];\n if (announced.includes(uniqueId)) {\n log(\"Already marked by another process/check:\", uniqueId);\n return; // Already marked, possibly by a concurrent run or previous step\n }\n\n const newAnnounced = [...announced, uniqueId];\n const MAX_ANNOUNCED_ITEMS = 300;\n const finalAnnounced = newAnnounced.length > MAX_ANNOUNCED_ITEMS\n ? newAnnounced.slice(newAnnounced.length - MAX_ANNOUNCED_ITEMS)\n : newAnnounced;\n\n const res = await kvStore.atomic()\n .check(currentEntry) // Ensure the value hasn't changed since we read it\n .set([KV_ANNOUNCED_TARGET_CHAPTERS_KEY], finalAnnounced)\n .commit();\n success = res.ok;\n if (!success) {\n log(\"Atomic operation for markTargetChapterAsAnnounced failed, retrying...\");\n await new Promise(r => setTimeout(r, 100)); // Small delay before retry\n }\n }\n log(\"Marked target chapter as announced:\", uniqueId);\n } catch (e) {\n errorLog(\"KV set error for markTargetChapterAsAnnounced:\", e.message);\n } finally {\n try {\n kvStore?.close();\n } catch (e) { /*ignore close error*/ }\n }\n}\n\n/*──────────────────── 8 ▸ Scraping Logic ────────────────────────────────*/\nasync function scrapeMainPageForPotentialTargetChapters(): Promise {\n log(\"Scraping main page for target chapters:\", BASE_URL);\n const potentialChapters: ScrapedChapterInfo[] = [];\n try {\n const { data } = await httpClient.get(BASE_URL, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const headingElement = $(\"h3\").filter((_, h) => $(h).text().trim().toLowerCase() === \"latest updates\").first();\n if (!headingElement.length) {\n log(\"Could not find 'Latest Updates' heading.\");\n return [];\n }\n const updateBox = headingElement.parent().next(\"div.grid\");\n if (!updateBox.length) {\n log(\"Could not find 'div.grid' update box.\");\n return [];\n }\n\n updateBox.find(\"div.w-full.p-1.pt-1.pb-3\").each((_idx, itemBlock) => {\n const $itemBlock = $(itemBlock);\n const $seriesLinkElement = $itemBlock.find(\"span.text-\\\\[15px\\\\].font-medium a[href*='/series/']\").first();\n const preliminarySeriesTitle = htmlToText($seriesLinkElement.text());\n const seriesPagePath = $seriesLinkElement.attr(\"href\");\n\n if (!preliminarySeriesTitle || !seriesPagePath) return;\n const seriesPageUrl = new URL(seriesPagePath, BASE_URL).href;\n const preliminarySeriesImage = $itemBlock.find(\"div.col-span-3 a img\").attr(\"src\");\n\n $itemBlock.find(\"div.flex.flex-col div.flex.flex-row.justify-between\").each((_cIdx, chapDiv) => {\n const $chapDiv = $(chapDiv);\n const $chapterLinkElement = $chapDiv.find(\"a[href*='/chapter/']\");\n const chapterUrlPath = $chapterLinkElement.attr(\"href\");\n if (!chapterUrlPath) return;\n\n const chapterNumberTextInHtml = htmlToText($chapterLinkElement.find(\"p.w-\\\\[80px\\\\]\").text());\n const normalizedChapterNum = normalizeChapterNumber(chapterNumberTextInHtml);\n const releaseTimeText = htmlToText($chapDiv.find(\"p.text-\\\\[\\\\#555555\\\\]\").text());\n\n if (normalizedChapterNum && releaseTimeText) {\n potentialChapters.push({\n seriesTitle: preliminarySeriesTitle,\n seriesImage: preliminarySeriesImage ? new URL(preliminarySeriesImage, BASE_URL).href : null,\n seriesPageUrl: seriesPageUrl,\n chapterNumberText: chapterNumberTextInHtml,\n normalizedChapterNumber: normalizedChapterNum,\n chapterUrl: new URL(chapterUrlPath, BASE_URL).href,\n releaseTimeText: releaseTimeText,\n minutesAgo: parseMinutesFromPhrase(releaseTimeText),\n });\n }\n });\n });\n log(`Found ${potentialChapters.length} potential chapter entries on main page.`);\n return potentialChapters;\n } catch (e) {\n errorLog(\"Failed to scrape main page:\", e.message);\n if (axios.isAxiosError(e) && e.response) {\n errorLog(\"Scrape error status:\", e.response.status);\n }\n return [];\n }\n}\n\nasync function scrapeSeriesPageDetailsForTargetChapter(\n seriesPageUrl: string,\n): Promise> {\n log(\"Scraping series page for details:\", seriesPageUrl);\n try {\n const { data } = await httpClient.get(seriesPageUrl, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const definitiveSeriesTitle = htmlToText($(\"h2.text-\\\\[25px\\\\].font-semibold.text-white\").first().text())\n || htmlToText($(\"h1\").first().text()); // Fallback\n const $coverImageElement = $(\"div.flex.flex-col.items-center img.aspect-\\\\[2\\\\/3\\\\]\").first();\n let definitiveSeriesImage = $coverImageElement.attr(\"src\") || \"\"; // Default to empty string\n if (definitiveSeriesImage) definitiveSeriesImage = new URL(definitiveSeriesImage, BASE_URL).href;\n\n let synopsis: string | null = null;\n const $synopsisHeading = $(\"h3.text-\\\\[\\\\#D9D9D9\\\\].font-medium.text-sm\").filter((_, el) =>\n $(el).text().toLowerCase().includes(\"synopsis\") // More robust check for \"Synopsis\"\n ).first();\n\n if ($synopsisHeading.length) {\n const $synopsisContainer = $synopsisHeading.next(\"span.font-medium.text-sm.text-\\\\[\\\\#A2A2A2\\\\]\");\n if ($synopsisContainer.length) {\n const $synopsisParagraph = $synopsisContainer.find(\"p\");\n if ($synopsisParagraph.length) {\n synopsis = htmlToText($synopsisParagraph.html()?.replace(//gi, \"\\n\") || \"\");\n } else {\n // If p is not found directly inside, try getting text of the span itself if it contains substantial text\n const spanText = htmlToText($synopsisContainer.html()?.replace(//gi, \"\\n\") || \"\");\n if (spanText.length > 50) synopsis = spanText; // Heuristic\n }\n }\n }\n // Fallback for synopsis if not found with specific structure and a title exists\n if (!synopsis && definitiveSeriesTitle) {\n $(\"p\").each((_i, el) => { // Iterate over all p tags on the page\n if (synopsis) return; // Stop if already found\n const pText = $(el).text();\n // Heuristic: a long paragraph that might contain the title or common synopsis keywords\n if (\n pText.length > 150\n && (pText.toLowerCase().includes(\n definitiveSeriesTitle.toLowerCase().substring(0, Math.min(10, definitiveSeriesTitle.length)),\n )\n || pText.toLowerCase().includes(\"story of\")\n || pText.toLowerCase().includes(\"follows the journey\"))\n ) {\n synopsis = htmlToText($(el).html()?.replace(//gi, \"\\n\") || \"\");\n }\n });\n }\n\n return {\n definitiveSeriesTitle: definitiveSeriesTitle || \"Unknown Title\", // Ensure title is never empty\n definitiveSeriesImage: definitiveSeriesImage,\n synopsis: synopsis,\n };\n } catch (e) {\n errorLog(\"Failed to scrape series page:\", seriesPageUrl, e.message);\n if (axios.isAxiosError(e) && e.response) {\n errorLog(\"Series page scrape error status:\", e.response.status);\n }\n return {\n definitiveSeriesTitle: \"Error fetching title\",\n definitiveSeriesImage: \"\",\n synopsis: \"Error fetching synopsis.\",\n };\n }\n}\n\n/*──────────────────── 9 ▸ Main Orchestration Logic ──────────────────────*/\nexport default async function sender() {\n log(`=== Specific Chapter Announcer (Sender | Target: ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}) Run Start ===`);\n try {\n await bot.api.getMe(); // Validate bot token\n log(\"Bot token validated.\");\n } catch (e) {\n errorLog(\"Invalid Bot Token or Telegram API issue:\", e.message);\n return; // Stop execution if bot token is invalid\n }\n\n const potentialTargetChapters = await scrapeMainPageForPotentialTargetChapters();\n if (!potentialTargetChapters.length) {\n log(\"No potential chapter entries found on main page.\");\n log(\"=== Sender Run End ===\");\n return;\n }\n\n const chaptersToAnnounce: SeriesDetailsForTargetChapter[] = [];\n\n for (const entry of potentialTargetChapters) {\n log(\n `Checking entry: ${entry.seriesTitle}, Ch: ${entry.normalizedChapterNumber}, Target: ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}, Time: ${entry.releaseTimeText} (${entry.minutesAgo} min ago)`,\n );\n\n if (\n entry.normalizedChapterNumber === TARGET_CHAPTER_NUMBER_TO_ANNOUNCE\n && entry.minutesAgo >= 0 && entry.minutesAgo <= (MAX_TARGET_CHAPTER_AGE_HOURS * 60)\n ) {\n log(`Found matching target chapter (${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}), recent: ${entry.seriesTitle}`);\n\n if (await hasTargetChapterBeenAnnounced(entry.seriesPageUrl, TARGET_CHAPTER_NUMBER_TO_ANNOUNCE)) {\n log(`Target chapter already announced for: ${entry.seriesTitle} - Ch ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n continue; // Skip if already announced\n }\n\n const details = await scrapeSeriesPageDetailsForTargetChapter(entry.seriesPageUrl);\n // Ensure we have a definitive title to proceed\n if (\n !details.definitiveSeriesTitle || details.definitiveSeriesTitle === \"Unknown Title\"\n || details.definitiveSeriesTitle === \"Error fetching title\"\n ) {\n errorLog(\n `Could not fetch valid definitive title for ${entry.seriesTitle} from ${entry.seriesPageUrl}, skipping.`,\n );\n continue;\n }\n\n chaptersToAnnounce.push({\n ...entry, // Spread initial info from main page scrape\n definitiveSeriesTitle: details.definitiveSeriesTitle,\n definitiveSeriesImage: details.definitiveSeriesImage || entry.seriesImage || \"\", // Prioritize series page image, fallback\n synopsis: details.synopsis || null, // Synopsis is optional\n });\n }\n }\n\n if (!chaptersToAnnounce.length) {\n log(`No unannounced target chapters (${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}, recent) found.`);\n log(\"=== Sender Run End ===\");\n return;\n }\n\n log(`Found ${chaptersToAnnounce.length} target chapter(s) to announce.`);\n\n for (const series of chaptersToAnnounce) {\n const nameOfManhwa = htmlToText(series.definitiveSeriesTitle);\n const synopsisText = series.synopsis ? `\\n\\nSynopsis:\\n${htmlToText(series.synopsis)}` : \"\";\n const imageUrl = series.definitiveSeriesImage || series.seriesImage; // Use definitive image first, then list image\n\n const message = `📣 Heads up, readers! 📣\n\n${nameOfManhwa}\nChapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE} is now available on the site!\nRead Chapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE} Now\n\nDon't miss out on the latest developments!${synopsisText}`;\n\n try {\n log(`Announcing to ${ANNOUNCEMENT_CHAT_ID}: ${nameOfManhwa} - Chapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n if (imageUrl) {\n await bot.api.sendPhoto(ANNOUNCEMENT_CHAT_ID, imageUrl, {\n caption: message,\n parse_mode: \"HTML\",\n });\n } else {\n log(`No image found for ${nameOfManhwa}, sending text only.`);\n await bot.api.sendMessage(ANNOUNCEMENT_CHAT_ID, message, {\n parse_mode: \"HTML\",\n disable_web_page_preview: false, // Allow link previews if no image\n });\n }\n log(`Successfully announced: ${nameOfManhwa} - Chapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n await markTargetChapterAsAnnounced(series.seriesPageUrl, TARGET_CHAPTER_NUMBER_TO_ANNOUNCE);\n } catch (e) {\n errorLog(\n `Failed to send Telegram announcement for ${nameOfManhwa} - Ch ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}:`,\n e.message,\n );\n if (BOT_OWNER_ID) {\n try {\n await bot.api.sendMessage(\n BOT_OWNER_ID,\n `Failed to announce TARGET CHAPTER (${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}) for ${nameOfManhwa} to ${ANNOUNCEMENT_CHAT_ID}.\\nError: ${\n e.message.substring(0, 300)\n }`,\n ).catch(err => errorLog(\"Failed to send owner error notification:\", err.message));\n } catch (ownerError) {\n errorLog(\"Further error sending notification to owner:\", ownerError.message);\n }\n }\n }\n // Delay between different series announcements to avoid hitting Telegram rate limits\n if (chaptersToAnnounce.length > 1) {\n await new Promise(resolve => setTimeout(resolve, 3000));\n }\n }\n\n log(\"=== Sender Run End ===\");\n}\n\n// This block is for local Deno execution (e.g., deno run --allow-net --allow-read --allow-write sender.ts)\n// ValTown will use the default export.\n// if (import.meta.main) {\n// log(\"Running sender.ts directly for testing...\");\n// sender().catch(e => errorLog(\"Top level crash in import.meta.main:\", e));\n// }",8,["D",1749067993046],24,{"_103":235,"_155":137,"_152":173,"_95":99,"_164":236,"_162":176,"_100":237,"_154":-5,"_105":238,"_156":239,"_167":-5},"d19ed4b2-417f-11f0-a2cc-76b3cceeab13","// specificChapterAnnouncer.ts @ValTown\n// Scans asuracomic.net for a specific target chapter (e.g., 263) and announces it.\n// No token privatization as per request.\n// ──────────────────────────────────────────────────────────────────────────\n\n/*──────────────────── 1 ▸ imports ───────────────────────────────────────*/\nimport axios from \"npm:axios@1.6.8\";\nimport cheerio from \"npm:cheerio@1.0.0-rc.12\";\nimport { Bot } from \"npm:grammy@1.19.2\";\nimport { kv } from \"https://esm.town/v/std/kv\"; // ValTown Deno KV store\n\n/*──────────────────── 2 ▸ configuration (secrets & settings) ──────────*/\nconst BOT_TOKEN = \"6923200542:AAGdyYJydP1kcHjrO5aOr8Ams2GflTEki8c\"; // ⚠ Your Bot Token (not privatized)\nconst ANNOUNCEMENT_CHAT_ID = \"@mandoqa\"; // Chat ID for announcements\nconst BOT_OWNER_ID = 6129128211; // Optional: Numeric Telegram User ID for error notifications\n\nconst TARGET_CHAPTER_NUMBER_TO_ANNOUNCE = \"263\"; // <<< MODIFIED: The chapter number to look for\nconst MAX_TARGET_CHAPTER_AGE_HOURS = 24 * 3; // Announce if target chapter is newer than this (e.g., 72 hours)\n\nconst BASE_URL = \"https://asuracomic.net\";\nconst USER_AGENT =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 SpecificChapterBot/1.0\";\n\nconst REQUEST_TIMEOUT_MS = 30_000;\nconst KV_ANNOUNCED_TARGET_CHAPTERS_KEY = \"announcedTargetChapters_asura\"; // KV key\n\nconst DEBUG_MODE = true; // Toggle detailed operational logs\n\n/*──────────────────── 3 ▸ Telegram Bot Initialization ───────────────────*/\nconst bot = new Bot(BOT_TOKEN);\n\n/*──────────────────── 4 ▸ Types & Interfaces ───────────────────────────*/\ninterface ScrapedChapterInfo {\n seriesTitle: string;\n seriesImage?: string | null;\n seriesPageUrl: string;\n chapterNumberText: string; \n normalizedChapterNumber: string;\n chapterUrl: string;\n releaseTimeText: string; \n minutesAgo: number;\n}\n\ninterface SeriesDetailsForTargetChapter extends ScrapedChapterInfo {\n definitiveSeriesTitle: string;\n definitiveSeriesImage: string;\n synopsis: string | null;\n}\n\n/*──────────────────── 5 ▸ helper functions ──────────────────────────────*/\nconst getCurrentTimestamp = () => new Date().toISOString().slice(11, 19);\n\nconst log = (...args: any[]) => {\n if (DEBUG_MODE) console.log(`[${getCurrentTimestamp()}]`, ...args);\n};\nconst errorLog = (...args: any[]) => {\n console.error(`[${getCurrentTimestamp()}] ERROR:`, ...args);\n};\n\nconst htmlToText = (htmlString = \"\"): string =>\n htmlString.replace(/<[^>]*>/g, \"\").replace(/\\s+/g, \" \").trim();\n\nconst normalizeChapterNumber = (text: string): string => {\n const match = text.match(/(\\d+(\\.\\d+)?)/); // Extracts first number sequence\n return match ? parseFloat(match[1]).toString() : \"\"; // \"Chapter 263\" -> \"263\", \"263.5\" -> \"263.5\"\n};\n\nconst normalizeString = (str = \"\"): string =>\n str.replace(/[‐–—−\\-]/g, \"-\").replace(/\\s+/g, \" \").trim().toLowerCase();\n\nfunction parseMinutesFromPhrase(phrase = \"\"): number {\n const s = phrase.toLowerCase();\n let isolatedTimePhrase = s;\n const specificTimeMatch = s.match(\n /((?:(?:\\d+\\s+)?(?:second|minute|min|hour|day|week|month|year)s?\\s+ago)|(?:public\\s+in\\s+(?:\\d+\\s+)?(?:second|minute|min|hour)s?))/i,\n );\n if (specificTimeMatch && specificTimeMatch[0]) {\n isolatedTimePhrase = specificTimeMatch[0];\n }\n const numMatch = isolatedTimePhrase.match(/-?\\d+(?:\\.\\d+)?/);\n const num = parseFloat(numMatch?.[0] || \"NaN\");\n\n if (isolatedTimePhrase.includes(\"less than\") || isolatedTimePhrase.includes(\"second\")) return 0;\n // For target chapter, be more lenient with \"days ago\" than for a \"new series\"\n if (isolatedTimePhrase.includes(\"week\") || isolatedTimePhrase.includes(\"month\") || isolatedTimePhrase.includes(\"year\")) return 999_999;\n if (Number.isNaN(num)) return 999_999;\n\n if (isolatedTimePhrase.includes(\"public in\")) return isolatedTimePhrase.includes(\"hour\") ? -Math.round(num * 60) : -Math.round(num);\n if (isolatedTimePhrase.includes(\"day\")) return Math.round(num * 60 * 24);\n if (isolatedTimePhrase.includes(\"hour\")) return Math.round(num * 60);\n if (isolatedTimePhrase.includes(\"minute\") || isolatedTimePhrase.includes(\"min\")) return Math.round(num);\n return 999_999;\n}\n\n/*──────────────────── 6 ▸ HTTP client (axios) ───────────────────────────*/\nconst httpClient = axios.create({\n headers: { \"User-Agent\": USER_AGENT },\n timeout: REQUEST_TIMEOUT_MS,\n maxRedirects: 5,\n});\n\n/*──────────────────── 7 ▸ State Management (KV Store) ───────────────────*/\n// Key for KV store will be seriesPageUrl + # + chapterNumber to make it unique per chapter\nasync function hasTargetChapterBeenAnnounced(seriesPageUrl: string, chapterNumber: string): Promise {\n const uniqueId = `${normalizeString(seriesPageUrl)}#${chapterNumber}`;\n try {\n const announced: string[] | null = await kv.get(KV_ANNOUNCED_TARGET_CHAPTERS_KEY);\n return announced ? announced.includes(uniqueId) : false;\n } catch (e) {\n errorLog(\"KV get error:\", e.message);\n return true; // Fail safe\n }\n}\n\nasync function markTargetChapterAsAnnounced(seriesPageUrl: string, chapterNumber: string): Promise {\n const uniqueId = `${normalizeString(seriesPageUrl)}#${chapterNumber}`;\n try {\n let announced: string[] | null = await kv.get(KV_ANNOUNCED_TARGET_CHAPTERS_KEY);\n if (!announced) announced = [];\n if (!announced.includes(uniqueId)) {\n announced.push(uniqueId);\n }\n const MAX_ANNOUNCED_ITEMS = 300; // Store more items if checking for specific chaps\n if (announced.length > MAX_ANNOUNCED_ITEMS) {\n announced = announced.slice(announced.length - MAX_ANNOUNCED_ITEMS);\n }\n await kv.set(KV_ANNOUNCED_TARGET_CHAPTERS_KEY, announced);\n log(\"Marked target chapter as announced:\", uniqueId);\n } catch (e) {\n errorLog(\"KV set error:\", e.message);\n }\n}\n\n/*──────────────────── 8 ▸ Scraping Logic ────────────────────────────────*/\nasync function scrapeMainPageForPotentialTargetChapters(): Promise {\n log(\"Scraping main page for target chapters:\", BASE_URL);\n const potentialChapters: ScrapedChapterInfo[] = [];\n try {\n const { data } = await httpClient.get(BASE_URL, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const headingElement = $(\"h3\").filter((_, h) => $(h).text().trim().toLowerCase() === \"latest updates\").first();\n if (!headingElement.length) {\n log(\"Could not find 'Latest Updates' heading.\");\n return [];\n }\n const updateBox = headingElement.parent().next(\"div.grid\");\n if (!updateBox.length) {\n log(\"Could not find 'div.grid' update box.\");\n return [];\n }\n\n updateBox.find(\"div.w-full.p-1.pt-1.pb-3\").each((_idx, itemBlock) => {\n const $itemBlock = $(itemBlock);\n const $seriesLinkElement = $itemBlock.find(\"span.text-\\\\[15px\\\\].font-medium a[href*='/series/']\").first();\n const preliminarySeriesTitle = htmlToText($seriesLinkElement.text());\n const seriesPagePath = $seriesLinkElement.attr(\"href\");\n\n if (!preliminarySeriesTitle || !seriesPagePath) return;\n const seriesPageUrl = new URL(seriesPagePath, BASE_URL).href;\n const preliminarySeriesImage = $itemBlock.find(\"div.col-span-3 a img\").attr(\"src\");\n\n $itemBlock.find(\"div.flex.flex-col div.flex.flex-row.justify-between\").each((_cIdx, chapDiv) => {\n const $chapDiv = $(chapDiv);\n const $chapterLinkElement = $chapDiv.find(\"a[href*='/chapter/']\");\n const chapterUrlPath = $chapterLinkElement.attr(\"href\");\n if (!chapterUrlPath) return;\n\n const chapterNumberTextInHtml = htmlToText($chapterLinkElement.find(\"p.w-\\\\[80px\\\\]\").text()); // e.g., \"Chapter 263\"\n const normalizedChapterNum = normalizeChapterNumber(chapterNumberTextInHtml);\n const releaseTimeText = htmlToText($chapDiv.find(\"p.text-\\\\[\\\\#555555\\\\]\").text());\n\n if (normalizedChapterNum && releaseTimeText) {\n potentialChapters.push({\n seriesTitle: preliminarySeriesTitle,\n seriesImage: preliminarySeriesImage ? new URL(preliminarySeriesImage, BASE_URL).href : null,\n seriesPageUrl: seriesPageUrl,\n chapterNumberText: chapterNumberTextInHtml, \n normalizedChapterNumber: normalizedChapterNum,\n chapterUrl: new URL(chapterUrlPath, BASE_URL).href,\n releaseTimeText: releaseTimeText,\n minutesAgo: parseMinutesFromPhrase(releaseTimeText),\n });\n }\n });\n });\n log(`Found ${potentialChapters.length} potential chapter entries on main page.`);\n return potentialChapters;\n } catch (e) {\n errorLog(\"Failed to scrape main page:\", e.message);\n return [];\n }\n}\n\nasync function scrapeSeriesPageDetailsForTargetChapter(seriesPageUrl: string): Promise> {\n log(\"Scraping series page for details:\", seriesPageUrl);\n try {\n const { data } = await httpClient.get(seriesPageUrl, { responseType: \"text\" });\n const $ = cheerio.load(data);\n const definitiveSeriesTitle = htmlToText($(\"h2.text-\\\\[25px\\\\].font-semibold.text-white\").first().text()) ||\n htmlToText($(\"h1\").first().text());\n const $coverImageElement = $(\"div.flex.flex-col.items-center img.aspect-\\\\[2\\\\/3\\\\]\").first();\n let definitiveSeriesImage = $coverImageElement.attr(\"src\");\n if (definitiveSeriesImage) definitiveSeriesImage = new URL(definitiveSeriesImage, BASE_URL).href;\n\n let synopsis: string | null = null;\n const $synopsisHeading = $(\"h3.text-\\\\[\\\\#D9D9D9\\\\].font-medium.text-sm\").filter((_, el) =>\n $(el).text().toLowerCase().includes(\"synopsis\")\n ).first();\n if ($synopsisHeading.length) {\n const $synopsisParagraph = $synopsisHeading.next(\"span.font-medium.text-sm.text-\\\\[\\\\#A2A2A2\\\\]\").find(\"p\");\n if ($synopsisParagraph.length) {\n synopsis = htmlToText($synopsisParagraph.html()?.replace(//gi, \"\\n\") || \"\");\n }\n }\n // Fallback for synopsis if needed (can be expanded)\n if (!synopsis && definitiveSeriesTitle) {\n $(\"p\").each((i, el) => {\n if (synopsis) return;\n const pText = $(el).text();\n if (pText.length > 100 && pText.toLowerCase().includes(definitiveSeriesTitle.toLowerCase().substring(0, Math.min(10, definitiveSeriesTitle.length)))) {\n synopsis = htmlToText($(el).html()?.replace(//gi, \"\\n\") || \"\");\n }\n });\n }\n\n return {\n definitiveSeriesTitle: definitiveSeriesTitle || \"Unknown Title\",\n definitiveSeriesImage: definitiveSeriesImage || undefined, // Use undefined if not found\n synopsis: synopsis,\n };\n } catch (e) {\n errorLog(\"Failed to scrape series page:\", seriesPageUrl, e.message);\n return {};\n }\n}\n\n/*──────────────────── 9 ▸ Main Orchestration Logic ──────────────────────*/\nexport default async function announceSpecificChapter() {\n log(`=== Specific Chapter Announcer (Target: ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}) Run Start ===`);\n try {\n await bot.api.getMe();\n } catch (e) {\n errorLog(\"Invalid Bot Token or Telegram API issue:\", e.message);\n return;\n }\n\n const potentialTargetChapters = await scrapeMainPageForPotentialTargetChapters();\n if (!potentialTargetChapters.length) {\n log(\"No potential chapter entries found on main page.\");\n log(\"=== Specific Chapter Announcer Run End ===\");\n return;\n }\n\n const chaptersToAnnounce: SeriesDetailsForTargetChapter[] = [];\n\n for (const entry of potentialTargetChapters) {\n log(`Checking entry: ${entry.seriesTitle}, Ch: ${entry.normalizedChapterNumber}, Target: ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}, Time: ${entry.releaseTimeText} (${entry.minutesAgo} min ago)`);\n\n if (entry.normalizedChapterNumber === TARGET_CHAPTER_NUMBER_TO_ANNOUNCE &&\n entry.minutesAgo >= 0 && entry.minutesAgo <= (MAX_TARGET_CHAPTER_AGE_HOURS * 60)) {\n log(`Found matching target chapter (${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}), recent: ${entry.seriesTitle}`);\n\n if (await hasTargetChapterBeenAnnounced(entry.seriesPageUrl, TARGET_CHAPTER_NUMBER_TO_ANNOUNCE)) {\n log(`Target chapter already announced for: ${entry.seriesTitle} - Ch ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n continue;\n }\n\n const details = await scrapeSeriesPageDetailsForTargetChapter(entry.seriesPageUrl);\n if (!details.definitiveSeriesTitle) { // Synopsis is optional for this version\n log(`Could not fetch definitive title for ${entry.seriesTitle}, skipping.`);\n continue;\n }\n\n chaptersToAnnounce.push({\n ...entry,\n definitiveSeriesTitle: details.definitiveSeriesTitle,\n definitiveSeriesImage: details.definitiveSeriesImage || entry.seriesImage || \"\", // Prioritize detailed image\n synopsis: details.synopsis || null, // Synopsis is optional but nice to have\n });\n }\n }\n\n if (!chaptersToAnnounce.length) {\n log(`No unannounced target chapters (${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}, recent) found.`);\n log(\"=== Specific Chapter Announcer Run End ===\");\n return;\n }\n\n log(`Found ${chaptersToAnnounce.length} target chapter(s) to announce.`);\n\n for (const series of chaptersToAnnounce) {\n const nameOfManhwa = htmlToText(series.definitiveSeriesTitle);\n const synopsisText = series.synopsis ? `\\n\\nSynopsis:\\n${htmlToText(series.synopsis)}` : \"\";\n const imageUrl = series.definitiveSeriesImage || series.seriesImage; // Use definitive image first\n\n // Modified announcement message\n const message = `📣 Heads up, readers! 📣\n\n${nameOfManhwa}\nChapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE} is now available on the site!\nRead Chapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE} Now\n\nDon't miss out on the latest developments!${synopsisText}`;\n\n try {\n log(`Announcing to ${ANNOUNCEMENT_CHAT_ID}: ${nameOfManhwa} - Chapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n if (imageUrl) {\n await bot.api.sendPhoto(ANNOUNCEMENT_CHAT_ID, imageUrl, {\n caption: message,\n parse_mode: \"HTML\",\n });\n } else {\n await bot.api.sendMessage(ANNOUNCEMENT_CHAT_ID, message, {\n parse_mode: \"HTML\",\n disable_web_page_preview: false,\n });\n }\n log(`Successfully announced: ${nameOfManhwa} - Chapter ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}`);\n await markTargetChapterAsAnnounced(series.seriesPageUrl, TARGET_CHAPTER_NUMBER_TO_ANNOUNCE);\n } catch (e) {\n errorLog(`Failed to send Telegram announcement for ${nameOfManhwa} - Ch ${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}:`, e.message);\n if (BOT_OWNER_ID) {\n await bot.api.sendMessage(BOT_OWNER_ID, `Failed to announce TARGET CHAPTER (${TARGET_CHAPTER_NUMBER_TO_ANNOUNCE}) for ${nameOfManhwa} to ${ANNOUNCEMENT_CHAT_ID}.\\nError: ${e.message}`).catch(err => errorLog(\"Failed to send owner error\", err));\n }\n }\n await new Promise(resolve => setTimeout(resolve, 2000)); // Delay\n }\n\n log(\"=== Specific Chapter Announcer Run End ===\");\n}\n\n// To run locally with Deno: deno run --allow-net --allow-env specificChapterAnnouncer.ts\n// if (import.meta.main) {\n// announceSpecificChapter().catch(e => errorLog(\"Top level crash:\", e));\n// }",7,["D",1749067768186],21,{"_103":241,"_155":137,"_152":173,"_95":242,"_164":236,"_162":176,"_100":243,"_154":-5,"_105":244,"_156":245,"_167":-5},"65760e86-417f-11f0-a685-76b3cceeab13","announceSpecificChapter.ts",6,["D",1749067586728],19,{"_103":247,"_155":137,"_152":173,"_95":242,"_164":72,"_162":176,"_100":248,"_154":-5,"_105":249,"_156":250,"_167":-5},"311bcd24-417f-11f0-8fc4-76b3cceeab13",5,["D",1749067498896],17,{"_103":252,"_155":137,"_152":173,"_95":253,"_164":72,"_162":176,"_100":254,"_154":-5,"_105":255,"_156":256,"_167":-5},"2c7366c4-417f-11f0-bbb1-76b3cceeab13","announceSpecificChapter",4,["D",1749067491081],16,{"_103":258,"_155":137,"_152":173,"_95":259,"_164":72,"_162":176,"_100":260,"_154":-5,"_105":261,"_156":262,"_167":-5},"d72b3372-38a5-11f0-9cc2-9e149126039e","main.ts",3,["D",1748094537912],14,{"_103":264,"_155":137,"_152":173,"_95":259,"_164":265,"_162":176,"_100":266,"_154":-5,"_105":267,"_156":268,"_167":-5},"9efadf84-38a5-11f0-9be1-9e149126039e","// @schedule { \"cron\": \"0 10 * * *\" }\n// Example cron job: Runs daily at 10:00 AM UTC.\n// You can change \"0 10 * * *\" to your desired schedule.\n// For example:\n// \"0 * * * *\" -> Every hour\n// \"*/30 * * * *\" -> Every 30 minutes\n// \"0 0 * * 1\" -> Every Monday at midnight UTC\n\n// This script runs as a Val Town Val\n// It sends a random, previously unsent quiz generated by an LLM\n// about a specific manhwa/manhua subject from a predefined list.\n\n// --- Configuration ---\n// !! WARNING: Placing API keys directly in the code is NOT SECURE.\n// !! It's highly recommended to use Val Town Secrets instead.\n// !! This is done only because explicitly requested.\n// Your Telegram Bot Token (provided by you)\nconst BOT_TOKEN = \"8016525726:AAHkYt9R87OTWDcELwjCrOCmjNBTJZCEk4M\";\n// Your OpenAI API Key (You MUST replace 'sk-proj-...' with your actual key)\nconst OPENAI_API_KEY =\n \"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\"; // !! REPLACE THIS PLACEHOLDER !!\n\nconst CHANNEL_USERNAME = \"@mandoqa\"; // The target channel username\n\n// Base URLs for APIs\nconst TELEGRAM_API_BASE = `https://api.telegram.org/bot${BOT_TOKEN}`;\nconst OPENAI_API_BASE = \"https://api.openai.com/v1\";\n\n// Key prefix for storing sent subjects in KV\nconst SENT_SUBJECTS_KV_KEY_PREFIX = `sent_subjects:${CHANNEL_USERNAME}`;\n\n// --- Manhwa/Manhua Subjects and Corresponding Images ---\n// Define the type for the subject-to-image mapping\ntype ManhwaSubjects = { [key: string]: string };\n\n// Add your subjects and their image URLs here.\n// The LLM will be prompted to create a quiz about one of these subjects.\nconst MANHWA_SUBJECTS: ManhwaSubjects = {\n \"Sung Jin-Woo\": \"https://i.imgur.com/example_sungjinwoo.jpg\", // Replace with actual image URL of Sung Jin-Woo\n \"Cha Hae-In\": \"https://i.imgur.com/example_chaaein.jpg\", // Replace with actual image URL of Cha Hae-In\n \"Seo Moon-Yeop\": \"https://i.imgur.com/example_seomoonyeop.jpg\", // Replace with actual image URL of Seo Moon-Yeop\n \"Yuder\": \"https://i.imgur.com/example_yuder.jpg\", // Replace with actual image URL of Yuder\n \"Grid (Park Hyun-woo)\": \"https://i.imgur.com/example_grid.jpg\", // Replace with actual image URL of Grid\n // Add more subjects and image URLs as needed\n // Ensure image URLs are publicly accessible links.\n // Make sure each key (subject name) is unique.\n};\n\nconst ALL_SUBJECTS: string[] = Object.keys(MANHWA_SUBJECTS);\n\n// --- Type Definitions for LLM Interaction ---\ntype LLMMessage = {\n role: \"system\" | \"user\" | \"assistant\";\n content: string;\n};\n\n// Expected structure of the JSON response from the LLM\ninterface QuizGenerationResponse {\n question: string;\n options: string[]; // Array of exactly 4 strings\n correctAnswer: string; // Exact text of the correct option\n}\n\n// Structure of the quiz data after processing for Telegram\ninterface ProcessedQuizData extends QuizGenerationResponse {\n correctOptionId: number; // 0-based index for Telegram Poll API\n type: \"regular\" | \"quiz\";\n}\n\n// --- LLM Prompt Function ---\n// This function constructs the prompt to send to the LLM.\nconst buildQuizPrompt = (subject: string): LLMMessage[] => {\n return [\n {\n role: \"system\",\n content:\n `You are a helpful assistant that creates multiple-choice quiz questions about Manhwa and Manhua characters and series.\n Generate a quiz question about the Manhwa/Manhua subject \"${subject}\".\n Provide exactly 4 distinct answer options.\n Ensure one option is the correct answer related to the subject (e.g., their full name, title, series they are from, key ability, or a significant fact).\n The other three options should be plausible but incorrect distractors, possibly from other manhwa/manhua or related concepts.\n Format the output strictly as a JSON object with the following keys:\n \"question\": The quiz question string.\n \"options\": An array of exactly four strings for the answer options.\n \"correctAnswer\": The *exact text* of the correct option from the \"options\" array.\n Do not include any introductory or concluding text outside the JSON object.`,\n },\n {\n role: \"user\",\n content: `Create a quiz about \"${subject}\".`,\n },\n ];\n};\n\n// --- Main Val Function ---\nexport default async function(): Promise {\n let kv: Deno.Kv | undefined;\n try {\n // Open Val Town's built-in KV store\n kv = await Deno.openKv();\n\n // --- Get list of sent subjects for this channel ---\n const sentSubjectsResult: Deno.KvEntry = await kv.get([SENT_SUBJECTS_KV_KEY_PREFIX]);\n // Initialize Set with existing data or an empty array\n let sentSubjects: Set = new Set(sentSubjectsResult.value || []);\n\n // --- Find unsent subjects ---\n const unsentSubjects: string[] = ALL_SUBJECTS.filter(subject => !sentSubjects.has(subject));\n\n // --- Handle case where all subjects have been sent ---\n if (unsentSubjects.length === 0) {\n console.log(\n `All ${ALL_SUBJECTS.length} subjects have been used for quizzes in ${CHANNEL_USERNAME}. Resetting sent list.`,\n );\n // Reset the sent list and use all subjects again\n sentSubjects = new Set(); // Clear the set\n await kv.set([SENT_SUBJECTS_KV_KEY_PREFIX], Array.from(sentSubjects)); // Save empty list immediately\n console.log(\"Sent subjects list reset.\");\n // Now unsentSubjects will be ALL_SUBJECTS again\n unsentSubjects.push(...ALL_SUBJECTS); // Add all subjects back\n }\n\n // --- Select a random unsent subject ---\n const randomIndex = Math.floor(Math.random() * unsentSubjects.length);\n const randomSubject: string = unsentSubjects[randomIndex];\n console.log(`Selected subject for new quiz: ${randomSubject}`);\n\n // --- Get Image URL ---\n const imageUrl: string | undefined = MANHWA_SUBJECTS[randomSubject];\n if (!imageUrl) {\n console.error(`No image URL found for subject: ${randomSubject}`);\n return `Error: No image URL found for subject \"${randomSubject}\".`;\n }\n\n // --- Generate Quiz Text using LLM ---\n let quizData: ProcessedQuizData;\n try {\n const prompt = buildQuizPrompt(randomSubject);\n const openaiResponse: Response = await fetch(`${OPENAI_API_BASE}/chat/completions`, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${OPENAI_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"gpt-3.5-turbo\", // Or other suitable model like \"gpt-4o\"\n messages: prompt,\n response_format: { type: \"json_object\" }, // Ask for JSON output\n temperature: 0.7, // Controls creativity\n max_tokens: 200, // Limit response size\n }),\n });\n\n const openaiResult: any = await openaiResponse.json(); // Use 'any' initially as response structure varies\n\n if (!openaiResponse.ok) {\n console.error(\"OpenAI API Error:\", openaiResult);\n return `Error calling OpenAI API: ${openaiResult.error?.message || \"Unknown error\"}`;\n }\n\n // Parse the LLM's JSON response\n const llmResponseContent: string | null | undefined = openaiResult.choices?.[0]?.message?.content;\n if (!llmResponseContent) {\n console.error(\"OpenAI response content missing:\", openaiResult);\n return \"Error: OpenAI response content missing or unexpected structure.\";\n }\n\n try {\n // Attempt to parse the JSON from the LLM and cast to expected type\n const parsedQuizResponse: QuizGenerationResponse = JSON.parse(llmResponseContent);\n\n // Basic validation of LLM output structure\n if (\n !parsedQuizResponse.question || !Array.isArray(parsedQuizResponse.options)\n || parsedQuizResponse.options.length !== 4 || !parsedQuizResponse.correctAnswer\n ) {\n console.error(\"LLM generated invalid quiz structure:\", parsedQuizResponse);\n return \"Error: LLM generated invalid quiz structure.\";\n }\n // Find the 0-based index of the correct answer\n const correctOptionId: number = parsedQuizResponse.options.indexOf(parsedQuizResponse.correctAnswer);\n if (correctOptionId === -1) {\n console.error(\"LLM generated correct answer text not found in options:\", parsedQuizResponse);\n return \"Error: LLM correct answer not found in options.\";\n }\n // Structure the final quiz data for Telegram\n quizData = {\n ...parsedQuizResponse,\n correctOptionId: correctOptionId,\n type: \"regular\", // Or 'quiz' if you want Telegram to show the correct answer after voting\n };\n } catch (parseError) {\n console.error(\"Failed to parse LLM response JSON:\", llmResponseContent, parseError);\n return `Error: Failed to parse LLM response JSON: ${llmResponseContent}`;\n }\n } catch (error: any) { // Catching any potential errors during fetch or parsing\n console.error(\"Error communicating with OpenAI API:\", error);\n return `Error communicating with OpenAI API: ${error.message || error}`;\n }\n\n // --- Send Photo to Telegram ---\n // The poll will be sent in a separate message, but Telegram often groups them visually.\n try {\n const photoApiUrl = `${TELEGRAM_API_BASE}/sendPhoto`;\n const photoPayload = new URLSearchParams({\n chat_id: CHANNEL_USERNAME,\n photo: imageUrl,\n caption: `Quiz about ${randomSubject}! Guess who?`, // Optional caption\n });\n\n const photoResponse: Response = await fetch(photoApiUrl, {\n method: \"POST\",\n body: photoPayload,\n });\n\n const photoResult: any = await photoResponse.json(); // Use 'any' for simple validation\n if (!photoResult.ok) {\n console.error(\"Telegram sendPhoto API Error:\", photoResult.description);\n // Log error but proceed to try sending the poll\n } else {\n console.log(\"Photo sent successfully.\");\n }\n } catch (error: any) {\n console.error(\"Fetch error while sending photo:\", error);\n // Log error but proceed to try sending the poll\n }\n\n // --- Send Poll to Telegram ---\n try {\n const pollApiUrl = `${TELEGRAM_API_BASE}/sendPoll`;\n const pollPayload = new URLSearchParams({\n chat_id: CHANNEL_USERNAME,\n question: quizData.question,\n options: JSON.stringify(quizData.options), // Options must be a JSON string\n type: quizData.type,\n is_anonymous: true,\n allows_multiple_answers: false,\n // Conditionally include correct_option_id only if type is 'quiz'\n ...(quizData.type === \"quiz\" && { correct_option_id: quizData.correctOptionId.toString() }), // Needs to be string for URLSearchParams\n });\n\n const pollResponse: Response = await fetch(pollApiUrl, {\n method: \"POST\",\n body: pollPayload,\n });\n\n const pollResult: any = await pollResponse.json(); // Use 'any' for simple validation\n\n if (!pollResult.ok) {\n console.error(\"Telegram sendPoll API Error:\", pollResult.description);\n // Don't mark as sent if poll failed, but log the error\n return `Failed to send quiz about \"${randomSubject}\": ${pollResult.description || \"Unknown API error\"}`;\n }\n\n console.log(\"Poll sent successfully.\");\n\n // --- Mark subject as sent ---\n sentSubjects.add(randomSubject);\n // Store back as array for KV\n await kv.set([SENT_SUBJECTS_KV_KEY_PREFIX], Array.from(sentSubjects));\n\n console.log(`Marked subject \"${randomSubject}\" as sent.`);\n\n // Provide feedback including remaining unsent count before potential reset\n const finalUnsentCount = ALL_SUBJECTS.length - sentSubjects.size;\n return `Successfully sent quiz about \"${randomSubject}\" to ${CHANNEL_USERNAME}. ${finalUnsentCount} unique subjects remaining before list resets.`;\n } catch (error: any) {\n console.error(\"Error sending poll to Telegram:\", error);\n // Don't mark as sent if Telegram API call failed\n return `Error sending poll to Telegram: ${error.message || error}`;\n }\n } catch (error: any) { // Catching any unexpected errors in the main flow\n console.error(\"An unexpected error occurred:\", error);\n return `An unexpected error occurred: ${error.message || error}`;\n } finally {\n // Ensure the KV connection is closed\n if (kv) {\n try {\n await kv.close();\n } catch (e) {\n console.error(\"Error closing KV:\", e);\n }\n }\n }\n}",2,["D",1748094443640],13,{"_103":270,"_155":137,"_152":173,"_95":259,"_164":72,"_162":176,"_100":186,"_154":-5,"_105":271,"_156":272,"_167":-5},"8df8f1c6-38a5-11f0-bd97-9e149126039e",["D",1748094415105],12,{"_103":274,"_155":137,"_152":173,"_95":275,"_164":72,"_162":176,"_100":32,"_154":-5,"_105":276,"_156":161,"_167":-5},"88742e50-38a5-11f0-8b51-9e149126039e","new-file-4837.tsx",["D",1748094405849],"versions",[279,281,282,283,284,285,286,287,288,289,290],{"_194":216,"_280":222},"previous",{"_194":222,"_280":228},{"_194":228,"_280":234},{"_194":234,"_280":240},{"_194":240,"_280":246},{"_194":246,"_280":251},{"_194":251,"_280":257},{"_194":257,"_280":263},{"_194":263,"_280":269},{"_194":269,"_280":273},{"_194":273,"_280":-5},"versionNumber","page","hasNext","actionData","errors"]

asurgift

asurareleasesbot

History for sender.ts