[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_246":247,"_248":249},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":53,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",35,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","spider.ts","latestPath","fileId","2ca8446c-59dd-11f1-87d5-ee650bb23af1","name","fileType","interval","content","// Cron val: crawl 好价, match the user's rules, push what is new.\n//\n// Set the schedule in the val.town editor. Because paging is now incremental,\n// a short interval (10 minutes) is both cheaper and fresher than the old\n// fixed-5-page run: quiet periods cost one request, busy periods dig deeper.\n\nimport {\n countSentDeals,\n findSentDeals,\n getCursor,\n getRules,\n getSettings,\n getStats,\n initDb,\n pruneSentDeals,\n recordSent,\n setCursor,\n setStats,\n} from \"./db.ts\";\nimport { compileRules, firstMatch } from \"./matcher.ts\";\nimport { sendCard, sendDigest, sendNotice } from \"./notify.ts\";\nimport { crawl, type Deal } from \"./smzdm.ts\";\nimport {\n escapeHtml,\n isQuietHour,\n MAX_CARDS_PER_RUN,\n MAX_PAGES,\n MAX_SENDS_PER_DEAL,\n nowSec,\n RETENTION_DAYS,\n type Settings,\n} from \"./shared.ts\";\n\nexport interface RunOptions {\n maxPages?: number;\n /** Manual runs ignore the paused flag. */\n manual?: boolean;\n}\n\nexport interface RunSummary {\n pages: number;\n scanned: number;\n matched: number;\n sent: number;\n failed: number;\n skipped: Record;\n errors: string[];\n note?: string;\n}\n\ninterface Candidate {\n deal: Deal;\n rule: string;\n priceDropFrom?: number;\n}\n\nfunction toRecord(deal: Deal) {\n return {\n articleId: deal.id,\n title: deal.title,\n url: deal.url,\n mall: deal.mall,\n priceText: deal.priceText,\n priceNum: deal.price,\n worthy: deal.worthy,\n publishedAt: deal.publishedAt,\n };\n}\n\nfunction passesFilters(\n deal: Deal,\n settings: Settings,\n skipped: Record,\n): boolean {\n const bump = (reason: string) => {\n skipped[reason] = (skipped[reason] ?? 0) + 1;\n return false;\n };\n\n // The feed keeps evergreen and pinned posts around: the very first row of\n // offset 0 has been observed as a 2021 deal flagged article_is_timeout.\n if (deal.expired) return bump(\"已过期\");\n if (deal.soldOut) return bump(\"已售罄\");\n\n if (\n deal.publishedAt > 0 &&\n nowSec() - deal.publishedAt > settings.maxAgeHours * 3_600\n ) {\n return bump(\"超过时效\");\n }\n if (settings.mallBlacklist.includes(deal.mall)) return bump(\"商城黑名单\");\n if (\n settings.mallWhitelist.length > 0 &&\n !settings.mallWhitelist.includes(deal.mall)\n ) {\n return bump(\"不在商城白名单\");\n }\n if (settings.minWorthy > 0 && deal.worthy < settings.minWorthy) {\n return bump(\"热度不足\");\n }\n return true;\n}\n\nexport async function runSpider(\n options: RunOptions = {},\n): Promise {\n await initDb();\n\n const settings = await getSettings();\n const skipped: Record = {};\n const summary: RunSummary = {\n pages: 0,\n scanned: 0,\n matched: 0,\n sent: 0,\n failed: 0,\n skipped,\n errors: [],\n };\n\n if (settings.paused && !options.manual) {\n summary.note = \"已暂停\";\n return summary;\n }\n\n const rules = compileRules(await getRules());\n if (rules.length === 0) {\n summary.note = \"未配置品牌规则\";\n return summary;\n }\n\n const cursor = await getCursor();\n const result = await crawl(cursor, options.maxPages ?? MAX_PAGES);\n summary.pages = result.pages;\n summary.scanned = result.deals.length;\n summary.errors = result.errors;\n\n const stats = await getStats();\n stats.lastRunAt = nowSec();\n stats.pages = result.pages;\n stats.scanned = result.deals.length;\n\n if (result.pages === 0) {\n stats.failStreak += 1;\n stats.lastError = result.errors[0] ?? \"未知抓取失败\";\n await setStats(stats);\n // Without this the bot dies quietly and the user assumes there are simply\n // no deals, which is the worst possible failure mode for a push bot.\n if (stats.failStreak === 3 || stats.failStreak % 12 === 0) {\n // The error text can contain a snippet of a WAF HTML page, so it has to\n // be escaped before going out as HTML.\n await sendNotice(\n `⚠️ 连续 ${stats.failStreak} 次抓取失败\\n` +\n `${escapeHtml(stats.lastError)}`,\n );\n }\n return summary;\n }\n\n const recovered = stats.failStreak >= 3;\n stats.failStreak = 0;\n stats.lastError = \"\";\n stats.lastOkAt = nowSec();\n\n const eligible = result.deals.filter((deal) =>\n passesFilters(deal, settings, skipped)\n );\n\n const matched: { deal: Deal; rule: string }[] = [];\n for (const deal of eligible) {\n const rule = firstMatch(rules, {\n title: deal.title,\n content: deal.content,\n mall: deal.mall,\n price: deal.price,\n }, settings.matchContent);\n if (rule) matched.push({ deal, rule });\n }\n summary.matched = matched.length;\n\n const known = await findSentDeals(matched.map(({ deal }) => deal.id));\n const candidates: Candidate[] = [];\n for (const { deal, rule } of matched) {\n const previous = known.get(deal.id);\n if (!previous) {\n candidates.push({ deal, rule });\n continue;\n }\n if (previous.sendCount >= MAX_SENDS_PER_DEAL) continue;\n\n const base = previous.bestPrice ?? previous.priceNum;\n if (\n deal.price !== null && base !== null &&\n deal.price < base * (1 - settings.dropThreshold)\n ) {\n candidates.push({ deal, rule, priceDropFrom: base });\n }\n }\n\n const silent = isQuietHour(settings, nowSec());\n const cards = candidates.slice(0, MAX_CARDS_PER_RUN);\n const overflow = candidates.slice(MAX_CARDS_PER_RUN);\n const failedPublishAt: number[] = [];\n\n for (const candidate of cards) {\n const ok = await sendCard(candidate.deal, {\n rule: candidate.rule,\n priceDropFrom: candidate.priceDropFrom,\n settings,\n silent,\n });\n if (ok) {\n await recordSent(toRecord(candidate.deal));\n summary.sent++;\n } else {\n summary.failed++;\n failedPublishAt.push(candidate.deal.publishedAt);\n }\n }\n\n if (overflow.length > 0) {\n const ok = await sendDigest(overflow, silent);\n for (const candidate of overflow) {\n if (ok) {\n await recordSent(toRecord(candidate.deal));\n summary.sent++;\n } else {\n summary.failed++;\n failedPublishAt.push(candidate.deal.publishedAt);\n }\n }\n }\n\n // Hold the cursor just behind the oldest failed push so the next run picks\n // it up again; the age floor keeps a permanently broken item from making the\n // crawl walk deeper and deeper forever.\n let nextCursor = result.newest;\n if (failedPublishAt.length > 0) {\n nextCursor = Math.min(nextCursor, Math.min(...failedPublishAt) - 1);\n }\n nextCursor = Math.max(nextCursor, nowSec() - settings.maxAgeHours * 3_600);\n await setCursor(nextCursor);\n\n await pruneSentDeals(RETENTION_DAYS);\n\n stats.matched = summary.matched;\n stats.sent = summary.sent;\n await setStats(stats);\n\n if (recovered) await sendNotice(\"✅ 抓取已恢复正常\");\n\n console.log(\n `[spider] pages=${summary.pages} scanned=${summary.scanned} ` +\n `matched=${summary.matched} sent=${summary.sent} ` +\n `failed=${summary.failed} history=${await countSentDeals()}`,\n );\n return summary;\n}\n\ninterface Interval {\n lastRunAt: Date | undefined;\n}\n\nexport default async function spider(_interval?: Interval): Promise {\n await runSpider();\n}","script","createdAt",["D",1785774784218],"branchVersion","branchId","8f6ec682-59da-11f1-9bcd-ee650bb23af1","id","8f6e1d7c-59da-11f1-9bcd-ee650bb23af1","smzdm",["D",1779893066929],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","96c2793d-57c8-41d2-a49a-d1ee82f9dd24","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","93515af8-c7b7-459c-9bf2-3bb3df310a75","tursoName","8f6e1d7c59da11f19bcdee650bb23af1","tursoHostname","8f6e1d7c59da11f19bcdee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494036282],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",51,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","yuxiaoy","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJObXd1QWdCZmVtaUh0bGU5TkswOG1sM0xheiIsImluaXRpYWxzIjoiRlkifQ","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":241,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":242,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":243,"_82":244,"_84":245,"_86":25},"tree",[208,209,210,211,212,213,214,215],"files",[208,209,210,211,212,213,214,215],"counts",{"_198":61,"_199":195,"_200":61,"_201":202,"_203":204},"contents",[128,129,130,131,132,133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":190,"_32":191,"_30":192,"_139":-5,"_41":42,"_40":193,"_141":25,"_38":194,"_13":195,"_33":20,"_35":196,"_24":25,"_146":-5,"_27":197},{"_43":182,"_32":183,"_30":184,"_139":-5,"_41":42,"_40":185,"_141":25,"_38":186,"_13":187,"_33":37,"_35":188,"_24":25,"_146":-5,"_27":189},{"_43":175,"_32":176,"_30":177,"_139":-5,"_41":42,"_40":178,"_141":25,"_38":179,"_13":157,"_33":37,"_35":180,"_24":25,"_146":-5,"_27":181},{"_43":168,"_32":169,"_30":170,"_139":-5,"_41":42,"_40":171,"_141":25,"_38":172,"_13":157,"_33":37,"_35":173,"_24":25,"_146":-5,"_27":174},{"_43":160,"_32":161,"_30":162,"_139":-5,"_41":42,"_40":163,"_141":25,"_38":164,"_13":165,"_33":37,"_35":166,"_24":25,"_146":-5,"_27":167},{"_43":152,"_32":153,"_30":154,"_139":-5,"_41":42,"_40":155,"_141":25,"_38":156,"_13":157,"_33":37,"_35":158,"_24":25,"_146":-5,"_27":159},{"_43":148,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":25,"_38":149,"_13":150,"_33":37,"_35":36,"_24":25,"_146":-5,"_27":151},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":25,"_38":142,"_13":143,"_33":144,"_35":145,"_24":25,"_146":-5,"_27":147},"a3a6ab64-4a7b-4fea-bc6f-ef78aa170f94","webhook.ts","8f710fe6-59da-11f1-9bcd-ee650bb23af1","parentId",33,"latest",["D",1785774681505],4,"http","// HTTP val: Telegram command interface for the SMZDM bot.\n//\n// Every handler sits behind an owner check. The previous version had none, so\n// anyone who found the bot could rewrite the brand list or wipe the data.\n\nimport {\n Bot,\n type Context,\n webhookCallback,\n} from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\nimport {\n clearSentDeals,\n countSentDeals,\n getRules,\n getSettings,\n getStats,\n initDb,\n listSentDeals,\n patchSettings,\n setRules,\n} from \"./db.ts\";\nimport {\n compileRules,\n evaluateRule,\n isUsableRule,\n parseRule,\n} from \"./matcher.ts\";\nimport { runSpider } from \"./spider.ts\";\nimport {\n BOT_TOKEN,\n chunkLines,\n dedupeOrdered,\n escapeHtml,\n formatLocal,\n OWNER_IDS,\n parsePrice,\n webhookSecret,\n} from \"./shared.ts\";\n\nconst bot = new Bot(BOT_TOKEN);\nconst SECRET_TOKEN = await webhookSecret();\n\nconst RESULTS_PAGE_SIZE = 15;\n\nconst HELP = `SMZDM Bot\n\n品牌规则\n/brands - 查看规则\n/add_brands 规则1 规则2 - 添加\n/delete_brands 规则1 - 删除\n/delete_all_brands - 清空\n/test 商品标题 - 测试标题会命中哪条规则\n\n规则语法（单条规则内不能有空格）\napple 标题含 apple\napple-watch 同时含两个词\nsony|索尼-耳机 括号或关系\napple-watch-!表带 排除配件\nnike-<300 价格不超过 300\n茅台->1000 价格不低于 1000\n/rtx\\\\s?40[6-9]0/ 正则\n\n过滤\n/malls - 查看商城名单\n/block_mall 商城 - 加入黑名单\n/unblock_mall 商城 - 移出黑名单\n/only_mall 京东天猫超市 - 只看这些商城（留空则取消）\n/min_worthy 数字 - 最低「值」票数（0 关闭，注意会过滤掉刚发布的好价）\n/max_age 小时 - 只推多久以内的好价\n/match_content on|off - 是否同时匹配爆料原文\n\n推送\n/photo preview|photo|off - 配图方式\n/quiet 23 7 - 该时段静音推送，off 关闭\n/drop 5 - 降价超过百分之几时复推\n/pause /resume - 暂停/恢复\n/run - 立刻抓取一次\n\n其他\n/status - 运行状态\n/settings - 当前配置\n/results [页码] - 已推送记录\n/delete_results - 清空推送记录`;\n\n// --- Guards -----------------------------------------------------------------\n\nbot.use(async (ctx, next) => {\n const userId = ctx.from?.id;\n if (OWNER_IDS.length === 0) {\n console.warn(\"[webhook] OWNER_IDS is empty; refusing all commands\");\n return;\n }\n if (!userId || !OWNER_IDS.includes(userId)) {\n console.warn(`[webhook] ignoring update from ${userId ?? \"unknown\"}`);\n return;\n }\n await initDb();\n await next();\n});\n\n// --- Helpers ----------------------------------------------------------------\n\nfunction args(match: unknown): string[] {\n return String(match ?? \"\").trim().split(/\\s+/).filter(Boolean);\n}\n\nasync function replyLong(ctx: Context, lines: string[]): Promise {\n for (const chunk of chunkLines(lines)) {\n await ctx.reply(chunk, {\n parse_mode: \"HTML\",\n link_preview_options: { is_disabled: true },\n });\n }\n}\n\nfunction onOff(value: string | undefined): boolean | undefined {\n if (value === \"on\" || value === \"true\" || value === \"1\") return true;\n if (value === \"off\" || value === \"false\" || value === \"0\") return false;\n return undefined;\n}\n\n// --- Brand rules ------------------------------------------------------------\n\nbot.command([\"start\", \"help\"], (ctx) =>\n ctx.reply(HELP, {\n parse_mode: \"HTML\",\n link_preview_options: { is_disabled: true },\n }));\n\nbot.command(\"brands\", async (ctx) => {\n const rules = await getRules();\n if (rules.length === 0) {\n return ctx.reply(\"还没有规则，用 /add_brands 添加。\");\n }\n await replyLong(ctx, [\n `当前 ${rules.length} 条规则`,\n ...rules.map((rule, index) =>\n `${index + 1}. ${escapeHtml(rule)}`\n ),\n ]);\n});\n\nbot.command(\"add_brands\", async (ctx) => {\n const incoming = args(ctx.match);\n if (incoming.length === 0) {\n return ctx.reply(\"用法：/add_brands 规则1 规则2 ...\");\n }\n\n const accepted: string[] = [];\n const rejected: string[] = [];\n for (const raw of incoming) {\n if (isUsableRule(parseRule(raw))) accepted.push(raw);\n else rejected.push(raw);\n }\n\n if (accepted.length > 0) {\n await setRules(dedupeOrdered([...(await getRules()), ...accepted]));\n }\n\n const parts: string[] = [];\n if (accepted.length > 0) parts.push(`已添加：${accepted.join(\", \")}`);\n if (rejected.length > 0) {\n // A rule made only of exclusions would match every deal in the feed.\n parts.push(`已忽略（缺少正向关键词）：${rejected.join(\", \")}`);\n }\n await ctx.reply(parts.join(\"\\n\"));\n});\n\nbot.command(\"delete_brands\", async (ctx) => {\n const targets = args(ctx.match);\n if (targets.length === 0) {\n return ctx.reply(\"用法：/delete_brands 规则1 规则2 ...\");\n }\n const before = await getRules();\n const remaining = before.filter((rule) => !targets.includes(rule));\n await setRules(remaining);\n await ctx.reply(\n `删除 ${\n before.length - remaining.length\n } 条，剩余 ${remaining.length} 条。`,\n );\n});\n\nbot.command(\"delete_all_brands\", async (ctx) => {\n await setRules([]);\n await ctx.reply(\"已清空所有规则，用 /add_brands 重新添加。\");\n});\n\nbot.command(\"test\", async (ctx) => {\n const title = String(ctx.match ?? \"\").trim();\n if (!title) return ctx.reply(\"用法：/test 商品标题（可带价格，如 199元）\");\n\n const settings = await getSettings();\n const raws = await getRules();\n if (raws.length === 0) return ctx.reply(\"还没有规则可测。\");\n\n const target = {\n title,\n content: \"\",\n mall: \"\",\n price: parsePrice(title),\n };\n const lines = raws.map((raw) => {\n const outcome = evaluateRule(parseRule(raw), target, settings.matchContent);\n const icon = outcome.ok ? \"✅\" : \"▫️\";\n return `${icon} ${escapeHtml(raw)} — ${\n escapeHtml(outcome.reason)\n }`;\n });\n await replyLong(ctx, [\n `识别价格：${target.price ?? \"无\"}`,\n ...lines,\n ]);\n});\n\n// --- Filters ----------------------------------------------------------------\n\nbot.command(\"malls\", async (ctx) => {\n const settings = await getSettings();\n const blacklist = settings.mallBlacklist.join(\", \") || \"（空）\";\n const whitelist = settings.mallWhitelist.join(\", \") || \"（空，表示不限）\";\n await ctx.reply(`黑名单：${blacklist}\\n白名单：${whitelist}`);\n});\n\nbot.command(\"block_mall\", async (ctx) => {\n const targets = args(ctx.match);\n if (targets.length === 0) return ctx.reply(\"用法：/block_mall 商城名\");\n const settings = await getSettings();\n const merged = dedupeOrdered([...settings.mallBlacklist, ...targets]);\n await patchSettings({ mallBlacklist: merged });\n await ctx.reply(`黑名单：${merged.join(\", \")}`);\n});\n\nbot.command(\"unblock_mall\", async (ctx) => {\n const targets = args(ctx.match);\n if (targets.length === 0) return ctx.reply(\"用法：/unblock_mall 商城名\");\n const settings = await getSettings();\n const remaining = settings.mallBlacklist.filter((m) => !targets.includes(m));\n await patchSettings({ mallBlacklist: remaining });\n await ctx.reply(`黑名单：${remaining.join(\", \") || \"（空）\"}`);\n});\n\nbot.command(\"only_mall\", async (ctx) => {\n const targets = args(ctx.match);\n await patchSettings({ mallWhitelist: targets });\n await ctx.reply(\n targets.length === 0\n ? \"已取消商城白名单。\"\n : `只推送这些商城：${targets.join(\", \")}`,\n );\n});\n\nbot.command(\"min_worthy\", async (ctx) => {\n const value = Number(args(ctx.match)[0]);\n if (!Number.isFinite(value) || value < 0) {\n return ctx.reply(\"用法：/min_worthy 数字（0 表示不过滤）\");\n }\n await patchSettings({ minWorthy: Math.floor(value) });\n await ctx.reply(\n value === 0\n ? \"已关闭热度过滤。\"\n : `只推送「值」票数 ≥ ${\n Math.floor(value)\n } 的好价。注意刚发布的好价票数为 0，会被挡下。`,\n );\n});\n\nbot.command(\"max_age\", async (ctx) => {\n const value = Number(args(ctx.match)[0]);\n if (!Number.isFinite(value) || value <= 0) {\n return ctx.reply(\"用法：/max_age 小时数\");\n }\n await patchSettings({ maxAgeHours: Math.floor(value) });\n await ctx.reply(`只推送 ${Math.floor(value)} 小时内发布的好价。`);\n});\n\nbot.command(\"match_content\", async (ctx) => {\n const value = onOff(args(ctx.match)[0]);\n if (value === undefined) return ctx.reply(\"用法：/match_content on|off\");\n await patchSettings({ matchContent: value });\n await ctx.reply(\n value\n ? \"已开启：规则同时匹配标题和爆料原文（覆盖更全，误报略多）。\"\n : \"已关闭：规则只匹配标题。\",\n );\n});\n\n// --- Delivery ---------------------------------------------------------------\n\nbot.command(\"photo\", async (ctx) => {\n const mode = args(ctx.match)[0];\n if (mode !== \"preview\" && mode !== \"photo\" && mode !== \"off\") {\n return ctx.reply(\"用法：/photo preview|photo|off\");\n }\n await patchSettings({ photoMode: mode });\n await ctx.reply(`配图方式：${mode}`);\n});\n\nbot.command(\"quiet\", async (ctx) => {\n const values = args(ctx.match);\n if (values[0] === \"off\") {\n await patchSettings({ quietStart: -1, quietEnd: -1 });\n return ctx.reply(\"已关闭静音时段。\");\n }\n const start = Number(values[0]);\n const end = Number(values[1]);\n const valid = (hour: number) =>\n Number.isInteger(hour) && hour >= 0 && hour <= 23;\n if (!valid(start) || !valid(end)) {\n return ctx.reply(\"用法：/quiet 23 7 或 /quiet off\");\n }\n await patchSettings({ quietStart: start, quietEnd: end });\n await ctx.reply(`${start}:00 - ${end}:00 期间静音推送（北京时间）。`);\n});\n\nbot.command(\"drop\", async (ctx) => {\n const percent = Number(args(ctx.match)[0]);\n if (!Number.isFinite(percent) || percent <= 0 || percent >= 100) {\n return ctx.reply(\"用法：/drop 5（降价超过 5% 时复推）\");\n }\n await patchSettings({ dropThreshold: percent / 100 });\n await ctx.reply(`降价超过 ${percent}% 时会再推一次。`);\n});\n\nbot.command(\"pause\", async (ctx) => {\n await patchSettings({ paused: true });\n await ctx.reply(\"已暂停推送，/resume 恢复。\");\n});\n\nbot.command(\"resume\", async (ctx) => {\n await patchSettings({ paused: false });\n await ctx.reply(\"已恢复推送。\");\n});\n\nbot.command(\"run\", async (ctx) => {\n await ctx.reply(\"开始抓取…\");\n const summary = await runSpider({ manual: true, maxPages: 5 });\n const skipped = Object.entries(summary.skipped)\n .map(([reason, count]) => `${reason} ${count}`)\n .join(\" · \") || \"无\";\n await ctx.reply(\n [\n summary.note ? `提示：${summary.note}` : \"\",\n `翻页 ${summary.pages} · 扫描 ${summary.scanned} · 命中 ${summary.matched}`,\n `已推送 ${summary.sent} · 失败 ${summary.failed}`,\n `过滤：${skipped}`,\n summary.errors.length > 0 ? `错误：${summary.errors[0]}` : \"\",\n ].filter(Boolean).join(\"\\n\"),\n );\n});\n\n// --- Introspection ----------------------------------------------------------\n\nbot.command(\"status\", async (ctx) => {\n const [stats, settings, total] = await Promise.all([\n getStats(),\n getSettings(),\n countSentDeals(),\n ]);\n await ctx.reply(\n [\n `状态：${settings.paused ? \"已暂停\" : \"运行中\"}`,\n `上次运行：${formatLocal(stats.lastRunAt)}`,\n `上次成功：${formatLocal(stats.lastOkAt)}`,\n `上轮：翻页 ${stats.pages} · 扫描 ${stats.scanned} · 命中 ${stats.matched} · 推送 ${stats.sent}`,\n `连续失败：${stats.failStreak}`,\n stats.lastError ? `最近错误：${stats.lastError}` : \"\",\n `历史记录：${total} 条`,\n ].filter(Boolean).join(\"\\n\"),\n );\n});\n\nbot.command(\"settings\", async (ctx) => {\n const settings = await getSettings();\n const quiet = settings.quietStart < 0\n ? \"关闭\"\n : `${settings.quietStart}:00-${settings.quietEnd}:00`;\n await ctx.reply(\n [\n `规则数：${compileRules(await getRules()).length}`,\n `商城黑名单：${settings.mallBlacklist.join(\", \") || \"（空）\"}`,\n `商城白名单：${settings.mallWhitelist.join(\", \") || \"（不限）\"}`,\n `最低值票：${settings.minWorthy}`,\n `时效：${settings.maxAgeHours} 小时`,\n `匹配爆料原文：${settings.matchContent ? \"开\" : \"关\"}`,\n `配图：${settings.photoMode}`,\n `静音时段：${quiet}`,\n `降价复推阈值：${Math.round(settings.dropThreshold * 100)}%`,\n ].join(\"\\n\"),\n );\n});\n\nbot.command(\"results\", async (ctx) => {\n const page = Math.max(1, Number(args(ctx.match)[0]) || 1);\n const total = await countSentDeals();\n if (total === 0) return ctx.reply(\"还没有推送记录。\");\n\n const pages = Math.ceil(total / RESULTS_PAGE_SIZE);\n const rows = await listSentDeals(\n RESULTS_PAGE_SIZE,\n (page - 1) * RESULTS_PAGE_SIZE,\n );\n await replyLong(\n ctx,\n [\n `推送记录 ${page}/${pages}（共 ${total} 条）`,\n ...rows.map((row, index) => {\n const order = (page - 1) * RESULTS_PAGE_SIZE + index + 1;\n const price = row.priceText ? ` — ${escapeHtml(row.priceText)}` : \"\";\n return `${order}. ${\n escapeHtml(row.title)\n }${price}`;\n }),\n pages > page ? `下一页：/results ${page + 1}` : \"\",\n ].filter(Boolean),\n );\n});\n\nbot.command(\"delete_results\", async (ctx) => {\n await clearSentDeals();\n await ctx.reply(\"已清空推送记录。注意：已推过的好价可能会再推一次。\");\n});\n\n// --- Inline buttons ---------------------------------------------------------\n\nbot.on(\"callback_query:data\", async (ctx) => {\n const data = ctx.callbackQuery.data;\n if (!data.startsWith(\"bm:\")) return ctx.answerCallbackQuery();\n\n const mall = data.slice(3);\n const settings = await getSettings();\n if (settings.mallBlacklist.includes(mall)) {\n return ctx.answerCallbackQuery(`${mall} 已在黑名单`);\n }\n await patchSettings({\n mallBlacklist: [...settings.mallBlacklist, mall],\n });\n await ctx.answerCallbackQuery(`已屏蔽 ${mall}`);\n});\n\n// Only in private chats: replying to everything in the push group would be\n// pure noise, which is what the old echo handler did.\nbot.on(\"message:text\", async (ctx) => {\n if (ctx.chat.type !== \"private\") return;\n await ctx.reply(\"没有这个命令，/help 查看用法。\");\n});\n\n// --- HTTP entry point -------------------------------------------------------\n\nconst handleUpdate = webhookCallback(bot, \"std/http\", {\n secretToken: SECRET_TOKEN,\n timeoutMilliseconds: 55_000,\n});\n\nconst COMMAND_MENU = [\n { command: \"help\", description: \"使用说明\" },\n { command: \"brands\", description: \"查看品牌规则\" },\n { command: \"add_brands\", description: \"添加规则，空格分隔\" },\n { command: \"delete_brands\", description: \"删除规则\" },\n { command: \"test\", description: \"测试标题是否命中规则\" },\n { command: \"malls\", description: \"查看商城名单\" },\n { command: \"status\", description: \"运行状态\" },\n { command: \"settings\", description: \"当前配置\" },\n { command: \"results\", description: \"已推送记录\" },\n { command: \"run\", description: \"立刻抓取一次\" },\n { command: \"pause\", description: \"暂停推送\" },\n { command: \"resume\", description: \"恢复推送\" },\n];\n\n/** Registration is idempotent and runs on GET, not on every cold start. */\nasync function setup(requestUrl: string): Promise {\n const url = new URL(requestUrl);\n url.search = \"\";\n url.hash = \"\";\n\n const notes: string[] = [];\n try {\n await bot.api.setWebhook(url.toString(), {\n secret_token: SECRET_TOKEN,\n allowed_updates: [\"message\", \"callback_query\"],\n });\n notes.push(`webhook -> ${url}`);\n } catch (error) {\n notes.push(`setWebhook failed: ${(error as Error).message}`);\n }\n try {\n await bot.api.setMyCommands(COMMAND_MENU);\n notes.push(\"command menu registered\");\n } catch (error) {\n notes.push(`setMyCommands failed: ${(error as Error).message}`);\n }\n return notes;\n}\n\nexport default async function handler(req: Request): Promise {\n if (req.method === \"POST\") return await handleUpdate(req);\n\n const notes = await setup(req.url);\n return new Response(\n `SMZDM bot is up.\\n${notes.join(\"\\n\")}\\n`,\n { headers: { \"content-type\": \"text/plain; charset=utf-8\" } },\n );\n}","label",[137],"a552bb13-439b-4969-b378-79e2b87d615f",["D",1785774784218],6,[28],"ceeab0cf-8262-4c2a-82cc-fe4bfd529734","smzdm.ts","073ebd78-8f57-11f1-9060-1607ee4eb77e",31,["D",1785774664221],2,"// SMZDM 好价 feed client: normalisation plus incremental cursor paging.\n//\n// The old version fetched a fixed 5 pages in parallel. Measurements on the\n// live feed showed 80 items spanning only ~35 minutes, with bursts as tight as\n// 7 seconds between items, so a fixed 100-item window silently drops deals\n// whenever the feed speeds up. Instead we page sequentially until a page holds\n// nothing newer than the stored cursor, which costs one request when the feed\n// is quiet and digs deeper automatically when it is busy.\n\nimport {\n FETCH_RETRIES,\n FETCH_TIMEOUT_MS,\n INITIAL_PAGES,\n MAX_PAGES,\n PAGE_SIZE,\n parsePrice,\n parseSmzdmDate,\n sleep,\n SMZDM_API_URL,\n SMZDM_HEADERS,\n} from \"./shared.ts\";\n\nexport interface Deal {\n id: string;\n title: string;\n url: string;\n /** go.smzdm.com redirect straight to the mall, when present. */\n buyUrl: string;\n pic: string;\n mall: string;\n priceText: string;\n price: number | null;\n worthy: number;\n unworthy: number;\n worthyPercent: string;\n comments: number;\n collections: number;\n referrals: string;\n /** 爆料原文: how to stack coupons, often the only place the model appears. */\n content: string;\n publishedAt: number;\n soldOut: boolean;\n expired: boolean;\n}\n\ninterface RawRow {\n article_id?: string;\n article_title?: string;\n article_url?: string;\n article_link?: string;\n article_pic?: string;\n article_price?: string;\n article_date?: string;\n article_mall?: string | null;\n mall_name?: string | null;\n article_worthy?: string;\n article_unworthy?: string;\n article_worthy_percent?: string;\n article_comment?: string;\n article_collection?: string;\n article_referrals?: string;\n article_filter_content?: string;\n article_is_sold_out?: string;\n article_is_timeout?: string;\n}\n\ninterface ListResponse {\n error_code?: string;\n error_msg?: string;\n data?: { rows?: RawRow[] };\n}\n\nfunction toInt(value?: string | null): number {\n const parsed = Number(value);\n return Number.isFinite(parsed) ? parsed : 0;\n}\n\nfunction normalise(row: RawRow): Deal | null {\n const id = row.article_id?.trim();\n const title = row.article_title?.trim();\n const rawUrl = row.article_url?.trim();\n // Banner and topic cards share the feed but carry none of these, so this\n // check doubles as a filter for non-deal rows.\n if (!id || !title || !rawUrl) return null;\n\n const url = rawUrl.replace(/^http:\\/\\//i, \"https://\");\n const priceText = row.article_price?.trim() ?? \"\";\n\n return {\n id,\n title,\n url,\n buyUrl: row.article_link?.trim() || url,\n pic: row.article_pic?.trim() ?? \"\",\n mall: (row.article_mall ?? row.mall_name ?? \"\").trim(),\n priceText,\n price: parsePrice(priceText),\n worthy: toInt(row.article_worthy),\n unworthy: toInt(row.article_unworthy),\n worthyPercent: row.article_worthy_percent?.trim() ?? \"\",\n comments: toInt(row.article_comment),\n collections: toInt(row.article_collection),\n referrals: row.article_referrals?.trim() ?? \"\",\n content: row.article_filter_content?.trim() ?? \"\",\n publishedAt: parseSmzdmDate(row.article_date),\n soldOut: row.article_is_sold_out === \"1\",\n expired: row.article_is_timeout === \"1\",\n };\n}\n\nclass PageError extends Error {}\n\nasync function fetchPage(offset: number): Promise {\n const url = `${SMZDM_API_URL}?limit=${PAGE_SIZE}&offset=${offset}`;\n let lastError = \"unknown error\";\n\n for (let attempt = 0; attempt <= FETCH_RETRIES; attempt++) {\n if (attempt > 0) await sleep(500 * attempt);\n\n let body: string;\n let status: number;\n try {\n const response = await fetch(url, {\n headers: SMZDM_HEADERS,\n signal: AbortSignal.timeout(FETCH_TIMEOUT_MS),\n });\n status = response.status;\n body = await response.text();\n } catch (error) {\n lastError = `network: ${(error as Error).message}`;\n continue;\n }\n\n // A HTML body means SMZDM rerouted us to its WAF or an error page.\n if (status !== 200 || /^\\s*<(!doctype|html|head|body)/i.test(body)) {\n lastError = `status=${status} bytes=${body.length} ` +\n `head=${JSON.stringify(body.slice(0, 60))}`;\n continue;\n }\n\n let payload: ListResponse;\n try {\n payload = JSON.parse(body) as ListResponse;\n } catch (error) {\n lastError = `invalid json: ${(error as Error).message}`;\n continue;\n }\n\n if (payload.error_code && payload.error_code !== \"0\") {\n lastError = `api ${payload.error_code}: ${payload.error_msg ?? \"\"}`;\n continue;\n }\n\n const rows = Array.isArray(payload.data?.rows) ? payload.data!.rows! : [];\n return rows\n .map(normalise)\n .filter((deal): deal is Deal => deal !== null);\n }\n\n throw new PageError(`offset=${offset} failed: ${lastError}`);\n}\n\nexport interface CrawlResult {\n deals: Deal[];\n pages: number;\n /** Newest publish time seen, for the next run's cursor. */\n newest: number;\n errors: string[];\n}\n\n/**\n * Walks the feed newest-first until it stops producing anything newer than\n * `cursor`. Returns deals deduped by article id, oldest first.\n */\nexport async function crawl(\n cursor: number,\n maxPages = MAX_PAGES,\n): Promise {\n const pageBudget = cursor > 0\n ? Math.min(maxPages, MAX_PAGES)\n : Math.min(maxPages, INITIAL_PAGES);\n\n const byId = new Map();\n const errors: string[] = [];\n let offset = 0;\n let pages = 0;\n let newest = cursor;\n\n for (let page = 0; page < pageBudget; page++) {\n let deals: Deal[];\n try {\n deals = await fetchPage(offset);\n } catch (error) {\n errors.push((error as Error).message);\n break;\n }\n\n pages++;\n if (deals.length === 0) break;\n\n let freshOnPage = 0;\n for (const deal of deals) {\n if (!byId.has(deal.id)) byId.set(deal.id, deal);\n if (deal.publishedAt > newest) newest = deal.publishedAt;\n if (deal.publishedAt > cursor) freshOnPage++;\n }\n\n // Counting fresh items rather than comparing the page's oldest timestamp\n // keeps pinned evergreen posts (we have seen a 2021 one at offset 0) from\n // aborting the walk on the first page.\n if (cursor > 0 && freshOnPage === 0) break;\n\n // Advancing by the smaller of the two guarantees overlap rather than a\n // gap: the API does not always honour `limit` exactly.\n offset += Math.min(PAGE_SIZE, deals.length);\n }\n\n const deals = [...byId.values()].sort(\n (a, b) => a.publishedAt - b.publishedAt,\n );\n return { deals, pages, newest, errors };\n}",[153],"5cd5865d-12f9-43c5-8c02-50dbd478cdf1","shared.ts","1b156086-59dd-11f1-9e63-ee650bb23af1",30,["D",1785774657452],7,"// Environment, tunables and small pure helpers shared by every file.\n//\n// Required environment variables:\n// BOT_TOKEN Telegram bot token from @BotFather\n// CHAT_ID Telegram chat that receives deal pushes\n// Optional:\n// OWNER_IDS Comma-separated Telegram user ids allowed to run commands.\n// Defaults to CHAT_ID. Anyone else is ignored.\n// WEBHOOK_SECRET Shared secret for Telegram webhook verification.\n// Defaults to a SHA-256 derived from BOT_TOKEN.\n\nfunction env(name: string): string | undefined {\n const value = Deno.env.get(name);\n return value && value.trim() ? value.trim() : undefined;\n}\n\nfunction requireEnv(name: string): string {\n const value = env(name);\n if (!value) throw new Error(`${name} env var is not set`);\n return value;\n}\n\nexport const BOT_TOKEN = requireEnv(\"BOT_TOKEN\");\nexport const CHAT_ID = requireEnv(\"CHAT_ID\");\n\nexport const OWNER_IDS: number[] = (env(\"OWNER_IDS\") ?? CHAT_ID)\n .split(/[,\\s]+/)\n .map((part) => Number(part))\n .filter((id) => Number.isFinite(id) && id !== 0);\n\n/**\n * Telegram only accepts `A-Z a-z 0-9 _ -` in secret_token. Deriving it by\n * hashing the bot token means a leaked secret does not leak half the token,\n * which is what using `BOT_TOKEN.split(\":\")[1]` directly would do.\n */\nexport async function webhookSecret(): Promise {\n const explicit = env(\"WEBHOOK_SECRET\");\n if (explicit) {\n return explicit.replace(/[^A-Za-z0-9_-]/g, \"\").slice(0, 256) || \"smzdm\";\n }\n const bytes = new TextEncoder().encode(`smzdm-webhook:${BOT_TOKEN}`);\n const digest = await crypto.subtle.digest(\"SHA-256\", bytes);\n return Array.from(new Uint8Array(digest))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\n// --- SMZDM source -----------------------------------------------------------\n//\n// api.smzdm.com is the mobile-app API. The www host sits behind Tencent Chaos\n// bot detection and returns a JS challenge stub to any non-browser caller,\n// so the app API is the only workable source. This endpoint needs no auth.\n\nexport const SMZDM_API_URL = \"https://api.smzdm.com/v1/youhui/list\";\n\nexport const SMZDM_HEADERS: Record = {\n \"user-agent\": \"smzdm_android_V11.4.6 rv:855 (Pixel 5;Android11;zh)smzdmapp\",\n \"accept\": \"application/json\",\n \"referer\": \"https://www.smzdm.com/\",\n};\n\nexport const PAGE_SIZE = 20;\n\n/** Hard ceiling on pages per run so a cursor glitch cannot loop forever. */\nexport const MAX_PAGES = 20;\n\n/** Pages to scan when no cursor exists yet (fresh install / after a reset). */\nexport const INITIAL_PAGES = 3;\n\nexport const FETCH_TIMEOUT_MS = 10_000;\nexport const FETCH_RETRIES = 2;\n\n// --- Telegram delivery ------------------------------------------------------\n\nexport const TELEGRAM_TIMEOUT_MS = 15_000;\n\n/** Telegram allows ~1 message/second per chat; stay under it. */\nexport const SEND_INTERVAL_MS = 1_200;\n\nexport const TELEGRAM_RETRIES = 3;\n\n/** Full cards per run. Anything beyond this is folded into a digest message. */\nexport const MAX_CARDS_PER_RUN = 8;\n\n/** Cap re-pushes of the same article so a flapping price cannot spam. */\nexport const MAX_SENDS_PER_DEAL = 3;\n\nexport const TEXT_LIMIT = 4096;\nexport const CAPTION_LIMIT = 1024;\n\n/** Days of push history to keep for dedupe and /results. */\nexport const RETENTION_DAYS = 30;\n\nexport const TIMEZONE = \"Asia/Shanghai\";\n\n// --- User-tunable settings (persisted, editable via bot commands) -----------\n\nexport interface Settings {\n paused: boolean;\n /** Minimum 值 votes required to push. 0 disables the filter. */\n minWorthy: number;\n /** Ignore deals published longer ago than this. */\n maxAgeHours: number;\n /** Also match rules against the deal's 爆料原文 body, not just the title. */\n matchContent: boolean;\n mallBlacklist: string[];\n /** When non-empty, only these malls are pushed. */\n mallWhitelist: string[];\n /** Local hours [start, end) delivered silently. -1 disables. */\n quietStart: number;\n quietEnd: number;\n /** Re-push when the price drops by at least this fraction. */\n dropThreshold: number;\n /** How the product image is attached. */\n photoMode: \"preview\" | \"photo\" | \"off\";\n}\n\nexport const DEFAULT_SETTINGS: Settings = {\n paused: false,\n minWorthy: 0,\n maxAgeHours: 24,\n matchContent: true,\n mallBlacklist: [\"唯品会\"],\n mallWhitelist: [],\n quietStart: -1,\n quietEnd: -1,\n dropThreshold: 0.05,\n photoMode: \"preview\",\n};\n\nexport interface Stats {\n lastRunAt: number;\n lastOkAt: number;\n lastError: string;\n failStreak: number;\n pages: number;\n scanned: number;\n matched: number;\n sent: number;\n}\n\nexport const EMPTY_STATS: Stats = {\n lastRunAt: 0,\n lastOkAt: 0,\n lastError: \"\",\n failStreak: 0,\n pages: 0,\n scanned: 0,\n matched: 0,\n sent: 0,\n};\n\n// --- Helpers ----------------------------------------------------------------\n\nexport function nowSec(): number {\n return Math.floor(Date.now() / 1000);\n}\n\nexport function sleep(ms: number): Promise {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nexport function escapeHtml(text: string): string {\n return text\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\");\n}\n\nexport function truncate(text: string, max: number): string {\n const trimmed = text.trim();\n return trimmed.length <= max ? trimmed : `${trimmed.slice(0, max - 1)}…`;\n}\n\n/**\n * SMZDM's `article_unix_date` does not agree with `article_date` (observed\n * skews of tens of minutes to half a day on the same row), so ordering and\n * the incremental cursor must come from `article_date`, which is Beijing time.\n */\nexport function parseSmzdmDate(value?: string | null): number {\n if (!value) return 0;\n const m = /^(\\d{4})-(\\d{2})-(\\d{2})[ T](\\d{2}):(\\d{2})(?::(\\d{2}))?/\n .exec(value.trim());\n if (!m) return 0;\n const iso = `${m[1]}-${m[2]}-${m[3]}T${m[4]}:${m[5]}:${m[6] ?? \"00\"}+08:00`;\n const parsed = Date.parse(iso);\n return Number.isFinite(parsed) ? Math.floor(parsed / 1000) : 0;\n}\n\n/** Pulls a comparable number out of strings like \"39.51元（需用券）\". */\nexport function parsePrice(text?: string | null): number | null {\n if (!text) return null;\n const cleaned = text.replaceAll(\",\", \"\");\n const yuan = /(\\d+(?:\\.\\d+)?)\\s*元/.exec(cleaned);\n if (yuan) return Number(yuan[1]);\n const symbol = /[$￥¥]\\s*(\\d+(?:\\.\\d+)?)/.exec(cleaned);\n if (symbol) return Number(symbol[1]);\n const bare = /(\\d+(?:\\.\\d+)?)/.exec(cleaned);\n return bare ? Number(bare[1]) : null;\n}\n\nconst dateFormatter = new Intl.DateTimeFormat(\"zh-CN\", {\n timeZone: TIMEZONE,\n month: \"2-digit\",\n day: \"2-digit\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n hour12: false,\n});\n\nexport function formatLocal(unixSec: number): string {\n if (!unixSec) return \"未知时间\";\n return dateFormatter.format(new Date(unixSec * 1000)).replace(/\\//g, \"-\");\n}\n\nexport function localHour(unixSec: number): number {\n const formatted = new Intl.DateTimeFormat(\"en-US\", {\n timeZone: TIMEZONE,\n hour: \"2-digit\",\n hour12: false,\n }).format(new Date(unixSec * 1000));\n return Number(formatted) % 24;\n}\n\nexport function isQuietHour(settings: Settings, unixSec: number): boolean {\n const { quietStart: start, quietEnd: end } = settings;\n if (start < 0 || end < 0 || start === end) return false;\n const hour = localHour(unixSec);\n return start < end\n ? hour >= start && hour < end\n : hour >= start || hour < end;\n}\n\n/** Groups lines into messages that each stay under Telegram's length limit. */\nexport function chunkLines(lines: string[], limit = TEXT_LIMIT): string[] {\n const chunks: string[] = [];\n let current = \"\";\n for (const line of lines) {\n const candidate = current ? `${current}\\n${line}` : line;\n if (candidate.length > limit && current) {\n chunks.push(current);\n current = line;\n } else {\n current = candidate;\n }\n }\n if (current) chunks.push(current);\n return chunks;\n}\n\n/** Dedupes while preserving insertion order. */\nexport function dedupeOrdered(items: T[]): T[] {\n return [...new Set(items)];\n}",[161],"4639252d-7735-4a8f-9be7-bc6a3a41dab9","notify.ts","13405d34-8f57-11f1-bd72-1607ee4eb77e",29,["D",1785774645387],"// Telegram delivery: rich HTML cards, digests, throttling and retries.\n//\n// Three problems with the previous implementation are fixed here. Sends are\n// serialised behind a shared interval so a burst of matches cannot trip\n// Telegram's per-chat rate limit; a 429 is honoured via `retry_after` instead\n// of being logged and dropped; and every send reports success so the caller\n// only records a deal as pushed once it actually arrived.\n\nimport type { Deal } from \"./smzdm.ts\";\nimport {\n BOT_TOKEN,\n CAPTION_LIMIT,\n CHAT_ID,\n chunkLines,\n escapeHtml,\n formatLocal,\n SEND_INTERVAL_MS,\n type Settings,\n sleep,\n TELEGRAM_RETRIES,\n TELEGRAM_TIMEOUT_MS,\n TEXT_LIMIT,\n truncate,\n} from \"./shared.ts\";\n\nconst API_BASE = `https://api.telegram.org/bot${BOT_TOKEN}`;\n\nlet nextSendAt = 0;\n\nasync function throttle(): Promise {\n const wait = nextSendAt - Date.now();\n if (wait > 0) await sleep(wait);\n nextSendAt = Date.now() + SEND_INTERVAL_MS;\n}\n\ninterface ApiResponse {\n ok: boolean;\n description?: string;\n parameters?: { retry_after?: number };\n}\n\n/** \"rejected\" means Telegram refused the payload itself, so retrying is futile. */\ntype Outcome = \"ok\" | \"failed\" | \"rejected\";\n\nasync function callApi(\n method: string,\n payload: Record,\n): Promise {\n for (let attempt = 0; attempt <= TELEGRAM_RETRIES; attempt++) {\n await throttle();\n\n let status: number;\n let body: ApiResponse;\n try {\n const response = await fetch(`${API_BASE}/${method}`, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify(payload),\n signal: AbortSignal.timeout(TELEGRAM_TIMEOUT_MS),\n });\n status = response.status;\n body = await response.json() as ApiResponse;\n } catch (error) {\n console.warn(`[notify] ${method} network error:`, error);\n await sleep(1_000 * (attempt + 1));\n continue;\n }\n\n if (body.ok) return \"ok\";\n\n if (status === 429) {\n const retryAfter = body.parameters?.retry_after ?? 3;\n console.warn(`[notify] rate limited, waiting ${retryAfter}s`);\n await sleep((retryAfter + 1) * 1_000);\n continue;\n }\n if (status >= 500) {\n await sleep(1_000 * (attempt + 1));\n continue;\n }\n\n // 4xx other than 429 will not fix itself; stop and surface it.\n console.error(`[notify] ${method} failed ${status}: ${body.description}`);\n return \"rejected\";\n }\n\n console.error(`[notify] ${method} gave up after ${TELEGRAM_RETRIES} retries`);\n return \"failed\";\n}\n\n/**\n * Last resort when Telegram rejects a formatted payload, e.g. a title that\n * breaks HTML parsing. Losing the formatting beats losing the deal.\n */\nasync function sendPlain(text: string, silent = false): Promise {\n const outcome = await callApi(\"sendMessage\", {\n chat_id: CHAT_ID,\n text: truncate(text, TEXT_LIMIT),\n disable_notification: silent,\n link_preview_options: { is_disabled: true },\n });\n return outcome === \"ok\";\n}\n\n// --- Message building -------------------------------------------------------\n\nfunction link(url: string, label: string): string {\n return `${escapeHtml(label)}`;\n}\n\nfunction votes(deal: Deal): string {\n if (deal.worthy === 0 && deal.unworthy === 0) return \"\";\n const percent = deal.worthyPercent\n ? ` ${escapeHtml(deal.worthyPercent)}`\n : \"\";\n return `👍 ${deal.worthy} 👎 ${deal.unworthy}${percent}`;\n}\n\n/**\n * Truncates already-escaped HTML without ever cutting an entity in half, which\n * would make Telegram reject the whole message.\n */\nfunction truncateEscaped(escaped: string, max: number): string {\n if (escaped.length <= max) return escaped;\n let cut = escaped.slice(0, max - 1);\n const lastAmp = cut.lastIndexOf(\"&\");\n if (lastAmp !== -1 && !cut.slice(lastAmp).includes(\";\")) {\n cut = cut.slice(0, lastAmp);\n }\n return `${cut}…`;\n}\n\nfunction keyboard(deal: Deal): Record {\n const row: Record[] = [\n { text: \"🛒 去购买\", url: deal.buyUrl },\n { text: \"📄 原文\", url: deal.url },\n ];\n const rows = [row];\n\n const muteData = `bm:${deal.mall}`;\n // callback_data is capped at 64 bytes; skip the button rather than 400.\n if (deal.mall && new TextEncoder().encode(muteData).length <= 64) {\n rows.push([{ text: `🚫 屏蔽 ${deal.mall}`, callback_data: muteData }]);\n }\n return { inline_keyboard: rows };\n}\n\nexport interface CardOptions {\n rule: string;\n priceDropFrom?: number;\n settings: Settings;\n silent: boolean;\n}\n\nfunction buildCard(deal: Deal, options: CardOptions, limit: number): string {\n const lines: string[] = [];\n\n if (options.priceDropFrom !== undefined) {\n lines.push(\n `📉 降价 ${options.priceDropFrom} 元 → ` +\n `${deal.price ?? \"?\"} 元`,\n );\n }\n\n lines.push(`🔥 ${link(deal.url, deal.title)}`);\n if (deal.priceText) lines.push(`💰 ${escapeHtml(deal.priceText)}`);\n\n const meta = [\n deal.mall ? `🏬 ${escapeHtml(deal.mall)}` : \"\",\n votes(deal),\n deal.comments > 0 ? `💬 ${deal.comments}` : \"\",\n `🕒 ${formatLocal(deal.publishedAt)}`,\n ].filter(Boolean);\n lines.push(meta.join(\" · \"));\n\n const tags = [\n `🏷 ${escapeHtml(options.rule)}`,\n deal.referrals ? `爆料 ${escapeHtml(deal.referrals)}` : \"\",\n ].filter(Boolean);\n lines.push(tags.join(\" · \"));\n\n const head = lines.join(\"\\n\");\n if (!deal.content) return head;\n\n // The 爆料原文 explains how to stack coupons and is often the whole point of\n // the deal, so it gets whatever room is left in the message.\n const budget = limit - head.length - 8;\n if (budget < 40) return head;\n return `${head}\\n📝 ${truncateEscaped(escapeHtml(deal.content), budget)}`;\n}\n\nexport async function sendCard(\n deal: Deal,\n options: CardOptions,\n): Promise {\n const usePhoto = options.settings.photoMode === \"photo\" && deal.pic !== \"\";\n const limit = usePhoto ? CAPTION_LIMIT : TEXT_LIMIT;\n const text = buildCard(deal, options, limit);\n\n const common = {\n chat_id: CHAT_ID,\n parse_mode: \"HTML\",\n disable_notification: options.silent,\n reply_markup: keyboard(deal),\n };\n\n const outcome = usePhoto\n ? await callApi(\"sendPhoto\", { ...common, photo: deal.pic, caption: text })\n : await callApi(\"sendMessage\", {\n ...common,\n text,\n link_preview_options: options.settings.photoMode === \"preview\" && deal.pic\n ? { url: deal.pic, prefer_large_media: true, show_above_text: true }\n : { is_disabled: true },\n });\n\n if (outcome === \"ok\") return true;\n if (outcome === \"failed\") return false;\n return await sendPlain(\n `${deal.title}\\n${deal.priceText}\\n${deal.url}`,\n options.silent,\n );\n}\n\n/**\n * Overflow beyond MAX_CARDS_PER_RUN is summarised instead of dropped, so a\n * busy feed neither floods the chat nor loses matches.\n */\nexport async function sendDigest(\n entries: { deal: Deal; rule: string }[],\n silent: boolean,\n): Promise {\n if (entries.length === 0) return true;\n\n const lines = [\n `📦 另有 ${entries.length} 条命中`,\n ...entries.map(({ deal, rule }, index) => {\n const price = deal.priceText ? ` — ${escapeHtml(deal.priceText)}` : \"\";\n const mall = deal.mall ? ` @${escapeHtml(deal.mall)}` : \"\";\n return `${index + 1}. ${link(deal.url, truncate(deal.title, 60))}` +\n `${price}${mall} [${escapeHtml(rule)}]`;\n }),\n ];\n\n let allOk = true;\n for (const chunk of chunkLines(lines)) {\n const outcome = await callApi(\"sendMessage\", {\n chat_id: CHAT_ID,\n parse_mode: \"HTML\",\n text: chunk,\n disable_notification: silent,\n link_preview_options: { is_disabled: true },\n });\n const ok = outcome === \"ok\" ||\n (outcome === \"rejected\" && await sendPlain(stripTags(chunk), silent));\n allOk = allOk && ok;\n }\n return allOk;\n}\n\nfunction stripTags(html: string): string {\n return html\n .replace(/([^<]*)<\\/a>/g, \"$2 $1\")\n .replace(/<[^>]+>/g, \"\")\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\");\n}\n\n/** Notice to the push chat, used for crawl-failure and recovery alerts. */\nexport async function sendNotice(text: string): Promise {\n const outcome = await callApi(\"sendMessage\", {\n chat_id: CHAT_ID,\n parse_mode: \"HTML\",\n text: truncate(text, TEXT_LIMIT),\n link_preview_options: { is_disabled: true },\n });\n if (outcome === \"ok\") return true;\n if (outcome === \"failed\") return false;\n return await sendPlain(stripTags(text));\n}",[169],"ef3267c9-fe03-47b9-a827-700853728ef3","matcher.ts","0d715e58-8f57-11f1-8377-1607ee4eb77e",28,["D",1785774638394],"// Rule parsing and matching.\n//\n// A rule is one whitespace-free token made of parts joined by \"-\". The old\n// version only supported plain AND-ed substrings, which made accessory noise\n// (\"apple watch 表带\") impossible to filter and gave no way to cap price.\n//\n// apple title contains \"apple\"\n// apple-watch contains both \"apple\" and \"watch\"\n// sony|索尼-耳机 (sony OR 索尼) AND 耳机\n// apple-watch-!表带-!钢化膜 excludes accessories\n// nike-<300 price at most 300\n// 茅台->1000 price at least 1000\n// /rtx\\s?40[6-9]0/ regex, case-insensitive\n// !/翻新|拆机/ negative regex\n//\n// Known limitation, inherited from the original syntax: \"-\" is the separator,\n// so a brand containing a hyphen must be written as a regex instead.\n\nexport interface Rule {\n raw: string;\n /** Each group is a set of alternatives; every group must match. */\n includes: string[][];\n excludes: string[][];\n patterns: RegExp[];\n negPatterns: RegExp[];\n minPrice?: number;\n maxPrice?: number;\n}\n\nexport interface MatchTarget {\n title: string;\n content: string;\n mall: string;\n price: number | null;\n}\n\nconst REGEX_TOKEN = /(!?)\\/((?:[^/\\\\]|\\\\.)+)\\//g;\n\nexport function parseRule(raw: string): Rule {\n const rule: Rule = {\n raw,\n includes: [],\n excludes: [],\n patterns: [],\n negPatterns: [],\n };\n\n // Regexes are pulled out before splitting so a \"-\" inside a pattern is not\n // mistaken for the part separator.\n const remainder = raw.replace(\n REGEX_TOKEN,\n (_match, negate: string, body: string) => {\n try {\n const pattern = new RegExp(body, \"i\");\n if (negate) rule.negPatterns.push(pattern);\n else rule.patterns.push(pattern);\n } catch {\n // An invalid pattern is kept as literal text instead of exploding.\n rule.includes.push([body.toLowerCase()]);\n }\n return \"-\";\n },\n );\n\n for (const part of remainder.split(\"-\")) {\n const token = part.trim();\n if (!token) continue;\n\n const upper = /^<=?\\s*(\\d+(?:\\.\\d+)?)$/.exec(token);\n if (upper) {\n rule.maxPrice = Number(upper[1]);\n continue;\n }\n const lower = /^>=?\\s*(\\d+(?:\\.\\d+)?)$/.exec(token);\n if (lower) {\n rule.minPrice = Number(lower[1]);\n continue;\n }\n\n const negated = token.startsWith(\"!\");\n const body = negated ? token.slice(1) : token;\n const alternatives = body\n .split(\"|\")\n .map((alt) => alt.trim().toLowerCase())\n .filter(Boolean);\n if (alternatives.length === 0) continue;\n\n if (negated) rule.excludes.push(alternatives);\n else rule.includes.push(alternatives);\n }\n\n return rule;\n}\n\n/** A rule with nothing positive would match every deal in the feed. */\nexport function isUsableRule(rule: Rule): boolean {\n return rule.includes.length > 0 || rule.patterns.length > 0;\n}\n\nexport interface MatchOutcome {\n ok: boolean;\n reason: string;\n}\n\nexport function evaluateRule(\n rule: Rule,\n target: MatchTarget,\n matchContent: boolean,\n): MatchOutcome {\n const haystack =\n (matchContent ? `${target.title}\\n${target.content}` : target.title)\n .toLowerCase();\n\n for (const group of rule.includes) {\n if (!group.some((alt) => haystack.includes(alt))) {\n return { ok: false, reason: `缺少关键词 ${group.join(\"|\")}` };\n }\n }\n for (const pattern of rule.patterns) {\n if (!pattern.test(haystack)) {\n return { ok: false, reason: `不匹配 ${pattern.source}` };\n }\n }\n for (const group of rule.excludes) {\n const hit = group.find((alt) => haystack.includes(alt));\n if (hit) return { ok: false, reason: `命中排除词 ${hit}` };\n }\n for (const pattern of rule.negPatterns) {\n if (pattern.test(haystack)) {\n return { ok: false, reason: `命中排除正则 ${pattern.source}` };\n }\n }\n\n // An unparseable price (\"包邮\", \"1元起\") passes the bounds rather than being\n // dropped, so a price constraint never hides a deal we cannot price.\n if (target.price !== null) {\n if (rule.maxPrice !== undefined && target.price > rule.maxPrice) {\n return { ok: false, reason: `价格 ${target.price} > ${rule.maxPrice}` };\n }\n if (rule.minPrice !== undefined && target.price < rule.minPrice) {\n return { ok: false, reason: `价格 ${target.price} < ${rule.minPrice}` };\n }\n }\n\n return { ok: true, reason: \"命中\" };\n}\n\n/** Returns the raw text of the first matching rule, or null. */\nexport function firstMatch(\n rules: Rule[],\n target: MatchTarget,\n matchContent: boolean,\n): string | null {\n for (const rule of rules) {\n if (evaluateRule(rule, target, matchContent).ok) return rule.raw;\n }\n return null;\n}\n\nexport function compileRules(raws: string[]): Rule[] {\n return raws.map(parseRule).filter(isUsableRule);\n}",[176],"e6857dfc-ff28-4f6a-af8f-f23f94b5e900","db.ts","1b89192c-8f57-11f1-a00b-1607ee4eb77e",27,["D",1785774632389],3,"// Persistence layer, backed by val.town's SQLite (std/sqlite).\n//\n// Replaces the previous single-blob-JSON storage. SQLite buys us three things\n// the blob could not give: a UNIQUE key on article_id so dedupe is exact and\n// O(1), per-row timestamps so history expires gradually instead of being\n// wiped wholesale, and no lost-update race between concurrent writers.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport {\n DEFAULT_SETTINGS,\n EMPTY_STATS,\n nowSec,\n type Settings,\n type Stats,\n} from \"./shared.ts\";\n\nconst DEALS_TABLE = \"smzdm_deals_v1\";\nconst KV_TABLE = \"smzdm_kv_v1\";\n\n// Legacy blob keys, read once during migration.\nconst LEGACY_BRANDS_KEY = \"smzdm_brands\";\nconst LEGACY_RESULT_KEY = \"smzdm_result\";\n\nexport interface SentDeal {\n articleId: string;\n title: string;\n url: string;\n mall: string;\n priceText: string;\n priceNum: number | null;\n bestPrice: number | null;\n worthy: number;\n publishedAt: number;\n firstSentAt: number;\n lastSentAt: number;\n sendCount: number;\n}\n\ninterface ExecuteResult {\n columns?: string[];\n rows?: unknown[];\n rowsAffected?: number;\n}\n\n/** Everything we bind is a scalar, which keeps us inside libSQL's InValue. */\ntype SqlArg = string | number | null;\n\n/**\n * std/sqlite returns rows as positional arrays; some versions also expose\n * named access. Normalise to plain objects so callers never depend on it.\n */\nfunction toObjects(result: ExecuteResult): Record[] {\n const columns = result.columns ?? [];\n const rows = result.rows ?? [];\n return rows.map((row) => {\n const record: Record = {};\n columns.forEach((column, index) => {\n record[column] = Array.isArray(row)\n ? row[index]\n : (row as Record)[column];\n });\n return record;\n });\n}\n\nasync function query(\n sql: string,\n args: SqlArg[] = [],\n): Promise[]> {\n const result = await sqlite.execute({ sql, args });\n return toObjects(result as unknown as ExecuteResult);\n}\n\nasync function run(sql: string, args: SqlArg[] = []): Promise {\n await sqlite.execute({ sql, args });\n}\n\nlet ready: Promise | undefined;\n\nexport function initDb(): Promise {\n // A failed init must not be cached, or one transient error would break the\n // isolate for its whole lifetime.\n ready ??= createSchema().catch((error) => {\n ready = undefined;\n throw error;\n });\n return ready;\n}\n\nasync function createSchema(): Promise {\n await run(`\n CREATE TABLE IF NOT EXISTS ${DEALS_TABLE} (\n article_id TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n url TEXT NOT NULL,\n mall TEXT NOT NULL DEFAULT '',\n price_text TEXT NOT NULL DEFAULT '',\n price_num REAL,\n best_price REAL,\n worthy INTEGER NOT NULL DEFAULT 0,\n published_at INTEGER NOT NULL DEFAULT 0,\n first_sent_at INTEGER NOT NULL,\n last_sent_at INTEGER NOT NULL,\n send_count INTEGER NOT NULL DEFAULT 1\n )\n `);\n await run(\n `CREATE INDEX IF NOT EXISTS idx_${DEALS_TABLE}_first_sent\n ON ${DEALS_TABLE}(first_sent_at)`,\n );\n await run(`\n CREATE TABLE IF NOT EXISTS ${KV_TABLE} (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n )\n `);\n await migrateFromBlob();\n}\n\n/** Carries the old blob-based brand list over on first run, once. */\nasync function migrateFromBlob(): Promise {\n const done = await readKv(\"migrated_from_blob\");\n if (done) return;\n\n try {\n const legacyBrands = await blob.getJSON(LEGACY_BRANDS_KEY);\n if (Array.isArray(legacyBrands) && legacyBrands.length > 0) {\n const existing = await readKv(\"rules\");\n if (!existing || existing.length === 0) {\n await writeKv(\"rules\", legacyBrands.map(String));\n console.log(\n `[db] migrated ${legacyBrands.length} brand rules from blob`,\n );\n }\n }\n\n // The old result list only held [title, url] pairs with no article id, so\n // it cannot seed the dedupe table. Seeding it with synthetic ids would\n // block nothing, so we intentionally drop it and let maxAgeHours keep the\n // first run from replaying stale deals.\n const legacyResults = await blob.getJSON(LEGACY_RESULT_KEY);\n if (Array.isArray(legacyResults)) {\n console.log(\n `[db] ignoring ${legacyResults.length} legacy results (no article_id)`,\n );\n }\n } catch (error) {\n console.warn(\"[db] blob migration skipped:\", error);\n }\n\n await writeKv(\"migrated_from_blob\", true);\n}\n\n// --- Key/value settings -----------------------------------------------------\n\nasync function readKv(key: string): Promise {\n const rows = await query(\n `SELECT value FROM ${KV_TABLE} WHERE key = ?`,\n [key],\n );\n if (rows.length === 0) return undefined;\n try {\n return JSON.parse(String(rows[0].value)) as T;\n } catch {\n return undefined;\n }\n}\n\nasync function writeKv(key: string, value: unknown): Promise {\n await run(\n `INSERT INTO ${KV_TABLE} (key, value) VALUES (?, ?)\n ON CONFLICT(key) DO UPDATE SET value = excluded.value`,\n [key, JSON.stringify(value)],\n );\n}\n\nexport async function getSettings(): Promise {\n const stored = await readKv>(\"settings\");\n return { ...DEFAULT_SETTINGS, ...(stored ?? {}) };\n}\n\nexport async function patchSettings(\n patch: Partial,\n): Promise {\n const merged = { ...(await getSettings()), ...patch };\n await writeKv(\"settings\", merged);\n return merged;\n}\n\nexport async function getRules(): Promise {\n return (await readKv(\"rules\")) ?? [];\n}\n\nexport async function setRules(rules: string[]): Promise {\n await writeKv(\"rules\", rules);\n}\n\nexport async function getCursor(): Promise {\n return (await readKv(\"cursor\")) ?? 0;\n}\n\nexport async function setCursor(publishedAt: number): Promise {\n await writeKv(\"cursor\", publishedAt);\n}\n\nexport async function getStats(): Promise {\n const stored = await readKv>(\"stats\");\n return { ...EMPTY_STATS, ...(stored ?? {}) };\n}\n\nexport async function setStats(stats: Stats): Promise {\n await writeKv(\"stats\", stats);\n}\n\n// --- Push history -----------------------------------------------------------\n\nfunction toSentDeal(row: Record): SentDeal {\n const number = (value: unknown): number | null =>\n value === null || value === undefined ? null : Number(value);\n return {\n articleId: String(row.article_id),\n title: String(row.title ?? \"\"),\n url: String(row.url ?? \"\"),\n mall: String(row.mall ?? \"\"),\n priceText: String(row.price_text ?? \"\"),\n priceNum: number(row.price_num),\n bestPrice: number(row.best_price),\n worthy: Number(row.worthy ?? 0),\n publishedAt: Number(row.published_at ?? 0),\n firstSentAt: Number(row.first_sent_at ?? 0),\n lastSentAt: Number(row.last_sent_at ?? 0),\n sendCount: Number(row.send_count ?? 0),\n };\n}\n\n/** One round-trip lookup for a whole batch of candidates. */\nexport async function findSentDeals(\n articleIds: string[],\n): Promise> {\n const found = new Map();\n if (articleIds.length === 0) return found;\n\n const batchSize = 200;\n for (let start = 0; start < articleIds.length; start += batchSize) {\n const batch = articleIds.slice(start, start + batchSize);\n const placeholders = batch.map(() => \"?\").join(\",\");\n const rows = await query(\n `SELECT * FROM ${DEALS_TABLE} WHERE article_id IN (${placeholders})`,\n batch,\n );\n for (const row of rows) {\n const deal = toSentDeal(row);\n found.set(deal.articleId, deal);\n }\n }\n return found;\n}\n\nexport interface RecordInput {\n articleId: string;\n title: string;\n url: string;\n mall: string;\n priceText: string;\n priceNum: number | null;\n worthy: number;\n publishedAt: number;\n}\n\n/**\n * Called only after Telegram confirms delivery, so a failed send is retried on\n * the next run instead of being silently marked as pushed.\n */\nexport async function recordSent(input: RecordInput): Promise {\n const timestamp = nowSec();\n await run(\n `INSERT INTO ${DEALS_TABLE} (\n article_id, title, url, mall, price_text, price_num, best_price,\n worthy, published_at, first_sent_at, last_sent_at, send_count\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 1)\n ON CONFLICT(article_id) DO UPDATE SET\n title = excluded.title,\n url = excluded.url,\n mall = excluded.mall,\n price_text = excluded.price_text,\n price_num = excluded.price_num,\n best_price = CASE\n WHEN excluded.price_num IS NOT NULL\n AND (best_price IS NULL OR excluded.price_num < best_price)\n THEN excluded.price_num ELSE best_price END,\n worthy = excluded.worthy,\n last_sent_at = excluded.last_sent_at,\n send_count = send_count + 1`,\n [\n input.articleId,\n input.title,\n input.url,\n input.mall,\n input.priceText,\n input.priceNum,\n input.priceNum,\n input.worthy,\n input.publishedAt,\n timestamp,\n timestamp,\n ],\n );\n}\n\nexport async function listSentDeals(\n limit: number,\n offset: number,\n): Promise {\n const rows = await query(\n `SELECT * FROM ${DEALS_TABLE}\n ORDER BY first_sent_at DESC LIMIT ? OFFSET ?`,\n [limit, offset],\n );\n return rows.map(toSentDeal);\n}\n\nexport async function countSentDeals(): Promise {\n const rows = await query(`SELECT COUNT(*) AS total FROM ${DEALS_TABLE}`);\n return Number(rows[0]?.total ?? 0);\n}\n\nexport async function clearSentDeals(): Promise {\n await run(`DELETE FROM ${DEALS_TABLE}`);\n}\n\n/** Ages out old rows so the table cannot grow without bound. */\nexport async function pruneSentDeals(retentionDays: number): Promise {\n await run(\n `DELETE FROM ${DEALS_TABLE} WHERE first_sent_at < ?`,\n [nowSec() - retentionDays * 86_400],\n );\n}",[183],"5a8094a5-314f-45a8-ab38-c6d596c4157c","README.md","ee89951e-8f56-11f1-83cc-1607ee4eb77e",34,["D",1785774693160],1,"# SMZDM Telegram Bot\n\n值得买（SMZDM）好价推送机器人，运行在 [Val Town](https://www.val.town) 的 Deno\n运行时上。按关键词规则监控「好价」列表，命中后以富文本卡片推送到 Telegram。\n\n这是对 `yuxiaoy/smzdm` 的重构版本：存储从单个 blob JSON 换成 SQLite，抓取从固定\n5 页换成增量游标翻页，推送从纯文本 `标题: 链接`\n换成带价格/商城/热度/爆料原文/按钮的卡片。\n\n## 文件结构\n\n| 文件 | 类型 | 作用 |\n| ------------ | ------------ | --------------------------------------------------- |\n| `shared.ts` | script | 环境变量、可调参数、时间与价格解析等纯函数 |\n| `db.ts` | script | SQLite 表结构、设置存取、推送历史、旧 blob 数据迁移 |\n| `smzdm.ts` | script | 好价接口客户端与增量游标翻页 |\n| `matcher.ts` | script | 规则解析与匹配 |\n| `notify.ts` | script | Telegram 卡片渲染、限流、重试 |\n| `spider.ts` | **interval** | 定时任务入口 |\n| `webhook.ts` | **http** | Telegram 命令入口 |\n\n## 部署\n\n1. 在 Val Town 新建一个 val，把上面 7 个文件贴进去，注意把 `spider.ts`\n 的类型设为 **Interval**、`webhook.ts` 设为 **HTTP**，其余保持 Script。\n2. 配置环境变量（Settings → Environment Variables）：\n\n | 变量 | 必填 | 说明 |\n | ---------------- | ---- | ----------------------------------------------------------------------- |\n | `BOT_TOKEN` | 是 | @BotFather 给的 bot token |\n | `CHAT_ID` | 是 | 接收推送的 chat id |\n | `OWNER_IDS` | 建议 | 允许发命令的 Telegram 用户 id，逗号分隔。**留空时机器人会拒绝所有命令** |\n | `WEBHOOK_SECRET` | 否 | webhook 校验密钥，不填则由 token 派生 SHA-256 |\n\n3. 用浏览器打开 `webhook.ts` 的 HTTP 地址一次。GET 请求会注册 webhook\n 和命令菜单，并返回注册结果。之后每次改动 URL 都要再访问一次。\n4. 把 `spider.ts` 的 interval 设为 **10 分钟**。增量翻页在闲时只发 1 个请求，\n 忙时自动加深，所以跑得勤反而更省也更及时。\n5. 在 Telegram 里 `/add_brands 你的关键词` 开始用。\n\n`OWNER_IDS` 如果不填，任何人找到这个 bot 都会被拒绝命令——这是故意的安全默认值。\n你的用户 id 可以问 [@userinfobot](https://t.me/userinfobot)。\n\n## 规则语法\n\n一条规则是不含空格的单个 token，内部用 `-` 分隔多个条件：\n\n| 写法 | 含义 |\n| --------------------------- | ----------------------------- |\n| `apple` | 含 `apple` |\n| `apple-watch` | 同时含 `apple` 和 `watch` |\n| `sony\\|索尼-耳机` | （`sony` 或 `索尼`）且 `耳机` |\n| `apple-watch-!表带-!钢化膜` | 排除配件噪音 |\n| `nike-<300` | 价格不超过 300 |\n| `茅台->1000` | 价格不低于 1000 |\n| `/rtx\\s?40[6-9]0/` | 正则，忽略大小写 |\n| `!/翻新\\|拆机/` | 负向正则 |\n\n约束：\n\n- `-` 是分隔符，所以品牌名里带连字符的要写成正则。\n- 只有排除条件、没有正向条件的规则会被 `/add_brands`\n 拒绝，否则它会命中全站好价。\n- 价格解析不出来的（`包邮`、`1元起`）**不会**被价格条件挡掉，宁可多推不漏推。\n- 中文没有词边界，`米` 这种短词误报率很高，建议配合排除词或正则。\n\n用 `/test 商品标题 199元` 可以看每条规则命中与否以及原因。\n\n## 命令\n\n```\n/help 使用说明\n/brands 查看规则\n/add_brands a b 添加规则\n/delete_brands a 删除规则\n/delete_all_brands 清空规则\n/test 标题测试规则命中情况\n\n/malls 查看商城名单\n/block_mall 唯品会加入黑名单\n/unblock_mall 唯品会移出黑名单\n/only_mall 京东天猫超市只看这些商城（留空取消）\n/min_worthy 0 最低「值」票数\n/max_age 24 只推多久以内发布的好价\n/match_content on|off 是否同时匹配爆料原文\n\n/photo preview|photo|off 配图方式\n/quiet 23 7 静音时段（北京时间），off 关闭\n/drop 5 降价超过 5% 时复推\n/pause /resume 暂停 / 恢复\n/run 立刻抓取一次\n\n/status 运行状态\n/settings 当前配置\n/results [页码] 推送记录\n/delete_results 清空推送记录\n```\n\n推送卡片下方还有三个按钮：去购买（`go.smzdm.com`\n直达商城）、原文、以及一键把该商城加入黑名单。\n\n## 关键实现说明\n\n**为什么用 app 接口。** `www.smzdm.com` 在腾讯 Chaos\n反爬后面，对非浏览器请求返回 JS 挑战页，Val Town 的出口 IP\n拿不到数据。`api.smzdm.com/v1/youhui/list` 是开放 JSON，这个端点不需要鉴权。\n\n**为什么用 `article_date` 而不是 `article_unix_date` 排序。**\n两个字段实测对不上：同一条 `article_date` 为 `00:06:41` 的商品，其\n`article_unix_date` 换算出来差了约 12 小时；两条相隔 7 秒的商品 unix 值差了 25\n分钟。所以时间排序和游标都基于 `article_date`（东八区）。\n\n**为什么改成增量翻页。** 实测好价流 80 条只跨约 35 分钟，且存在 7\n秒一条的爆发。固定抓 100 条约等于 44\n分钟的流量，白天高峰期会静默漏掉中间的商品。现在的做法是逐页往下翻，\n直到某一页不再包含比游标更新的条目为止，上限 20 页。\n\n判断「是否继续翻页」用的是「本页有几条比游标新」，而不是「本页最旧一条的时间」——因为\n`offset=0` 会出现运营置顶的老帖（实测见到 2021\n年的），用最旧时间判断会在第一页就误停。翻页步进取\n`min(PAGE_SIZE, 实际返回条数)`，保证宁可重叠也不跳过，因为接口并不严格遵守\n`limit`。\n\n**为什么过滤 `article_is_timeout` / `article_is_sold_out`。**\n列表里混有已失效和已售罄的条目，`offset=0`\n第一条就可能是几年前的置顶好价。不过滤就会推送早已过期的「好价」。\n\n**为什么先发送后入库。** 只有 Telegram 确认送达才写入\n`smzdm_deals_v1`；发送失败的条目\n会把游标回退到它之前，下一轮重试。旧版本是先入库再发送且忽略发送错误，一旦被限流，\n那条商品就永久丢失了。\n\n**为什么用 SQLite 而不是 blob。** `article_id` 做主键让去重精确且\nO(1)；每行带时间戳让历史按 30 天滚动过期，而不是像旧版那样攒到 150\n条就整表清空——清空后所有仍在列表里的旧商品会被当成新的重推一遍。SQLite\n也不存在两次 `setJSON` 互相覆盖的丢更新问题。\n\n## 从旧版本迁移\n\n首次运行时 `db.ts` 会自动把 blob 里的 `smzdm_brands` 读进\nSQLite，品牌列表不会丢。\n\n`smzdm_result` 里只有 `[标题, 链接]`，没有\n`article_id`，没法用来给去重表打底，所以会被\n忽略并打一条日志。为避免首轮重推，第一轮只抓 3 页，且默认只推 24\n小时内发布的好价。\n\n确认无误后可以自行删掉两个旧 blob key。\n\n## 已知取舍\n\n- `/min_worthy` 会挡掉刚发布的好价（票数为\n 0），而刚发布的往往是最值得抢的，所以默认 0。\n- `matchContent`\n 默认开启，覆盖更全（爆料原文常含具体型号），代价是误报略多，可关。\n- 单轮最多发 8 张卡片，多出来的合并成一条摘要，既不刷屏也不丢条目。\n- 同一商品最多推 3 次（首次 + 降价），防止价格反复波动时刷屏。",[191],"pulls","branches","forks","envVars",{"_205":187,"_207":61},"connections",{"_205":61,"_206":61},"count","unfilledCount","emptyCount",{"_43":190,"_32":191,"_30":192,"_139":-5,"_41":42,"_40":193,"_141":25,"_38":238,"_13":195,"_33":20,"_35":196,"_24":25,"_146":-5,"_217":239,"_27":240},{"_43":182,"_32":183,"_30":184,"_139":-5,"_41":42,"_40":185,"_141":25,"_38":235,"_13":187,"_33":37,"_35":188,"_24":25,"_146":-5,"_217":236,"_27":237},{"_43":175,"_32":176,"_30":177,"_139":-5,"_41":42,"_40":178,"_141":25,"_38":232,"_13":157,"_33":37,"_35":180,"_24":25,"_146":-5,"_217":233,"_27":234},{"_43":168,"_32":169,"_30":170,"_139":-5,"_41":42,"_40":171,"_141":25,"_38":229,"_13":157,"_33":37,"_35":173,"_24":25,"_146":-5,"_217":230,"_27":231},{"_43":160,"_32":161,"_30":162,"_139":-5,"_41":42,"_40":163,"_141":25,"_38":226,"_13":165,"_33":37,"_35":166,"_24":25,"_146":-5,"_217":227,"_27":228},{"_43":152,"_32":153,"_30":154,"_139":-5,"_41":42,"_40":155,"_141":25,"_38":223,"_13":157,"_33":37,"_35":158,"_24":25,"_146":-5,"_217":224,"_27":225},{"_43":148,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":25,"_38":220,"_13":150,"_33":37,"_35":36,"_24":25,"_146":-5,"_217":221,"_27":222},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":25,"_38":216,"_13":143,"_33":144,"_35":145,"_24":25,"_146":-5,"_217":218,"_27":219},["D",1785774681505],"children",[],[137],["D",1785774784218],[],[28],["D",1785774664221],[],[153],["D",1785774657452],[],[161],["D",1785774645387],[],[169],["D",1785774638394],[],[176],["D",1785774632389],[],[183],["D",1785774693160],[],[191],["D",1779893066929],["D",1789494036282],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_125":279,"_280":281,"_282":283,"_284":25,"_285":25,"_286":25,"_287":123,"_288":-5,"_289":-7,"_290":-7,"_291":61,"_292":25,"_293":25,"_294":-5,"_295":25,"_296":25,"_297":25,"_298":-5},"ENV",{"_250":251,"_252":253,"_254":88,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v35