[{"_1":2,"_168":-5,"_169":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","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","73d011c55f6ff6e543547a2f801bf2081197a5a4","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":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_165":166,"_167":-5},"handle","asurgift","name","asurareleasesbot","path","sender.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"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,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ5MEFaTTA0b3JBMGRaTUZoQUxaYk9PNFBYUiJ9","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",72,"4696c098-38a4-11f0-a69e-9e149126039e","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":98,"_149":150,"_151":-5,"_152":136,"_153":135,"_154":155,"_103":156,"_134":157,"_158":159,"_160":161,"_162":20,"_163":-5,"_97":164},"9356e62c-84c8-11f0-9ffa-0224a6c84d84","fileId","88742f04-38a5-11f0-8b51-9e149126039e","parentId","branchId","branchVersion","latest",true,["D",1756465744862],42,"fileType","script","content","// 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}","deleted","label",[98],"permalink","https://www.val.town/x/asurgift/asurareleasesbot/code/sender.ts","extension","actionData","errors"]