[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_152":153,"_154":155},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":53,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":25,"_120":-5,"_121":-5,"_122":123},"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":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","1b4351b4-86a9-11f1-8629-1607ee4eb77e","name","fileType","interval","content","// ============================================================================\n// 车身开发前沿情报机器人 (Car Body Material & Process Radar)\n// ----------------------------------------------------------------------------\n// 面向车身开发工程师，自动抓取国内外关于新材料 / 新工艺 / 新技术的实时资讯，\n// 去重、按主题归类后，通过邮件定时推送。\n//\n// 部署平台：Val Town (https://val.town) —— 这是一个 Cron 触发的 Val。\n// 运行时：Deno。除 Val Town 标准库外无第三方依赖，冷启动最快。\n//\n// 触发方式：把本文件设为 Cron 触发，建议每周一、周四各一次（见 README）。\n// ============================================================================\n\nimport { email } from \"https://esm.town/v/std/email\";\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ----------------------------------------------------------------------------\n// 1) 关注的主题与检索关键词\n// 每个主题包含中文与英文关键词，分别去抓国内源和国外源。\n// 需要增删方向时，直接改这里即可。\n// ----------------------------------------------------------------------------\ninterface Topic {\n id: string;\n label: string; // 邮件里显示的中文分组名\n zh: string[]; // 中文检索词（Google News 中文）\n en: string[]; // 英文检索词（Google News 英文）\n}\n\nconst TOPICS: Topic[] = [\n {\n id: \"steel\",\n label: \"新型高强钢\",\n zh: [\"汽车第三代高强钢\", \"车身热成形钢\", \"汽车超高强钢应用\"],\n en: [\"automotive third generation AHSS\", \"car body press hardened steel\", \"gigapascal steel automotive\"],\n },\n {\n id: \"aldiecast\",\n label: \"压铸铝合金 / 一体化压铸\",\n zh: [\"一体化压铸车身\", \"免热处理压铸铝合金\", \"超大型压铸汽车\"],\n en: [\"gigacasting car body\", \"heat-free die casting aluminum alloy automotive\", \"megacasting vehicle structure\"],\n },\n {\n id: \"mg\",\n label: \"镁合金\",\n zh: [\"镁合金汽车车身\", \"镁合金压铸汽车轻量化\"],\n en: [\"magnesium alloy automotive body\", \"magnesium die casting vehicle lightweight\"],\n },\n {\n id: \"composite\",\n label: \"低成本复合材料\",\n zh: [\"汽车碳纤维复合材料低成本\", \"车身玻纤复合材料轻量化\", \"热塑性复合材料汽车\"],\n en: [\"low cost carbon fiber automotive\", \"thermoplastic composite car body\", \"glass fiber composite vehicle lightweight\"],\n },\n {\n id: \"energy\",\n label: \"高吸能材料 / 碰撞结构\",\n zh: [\"汽车吸能盒材料\", \"车身碰撞吸能结构新材料\", \"泡沫铝汽车吸能\"],\n en: [\"automotive crash energy absorption material\", \"crashworthiness structure new material vehicle\", \"aluminum foam energy absorbing car\"],\n },\n {\n id: \"joining\",\n label: \"连接工艺\",\n zh: [\"车身自冲铆接 SPR\", \"汽车激光焊接铝\", \"车身异种材料连接胶接\"],\n en: [\"self piercing rivet car body\", \"laser welding aluminum automotive\", \"dissimilar material joining car body adhesive\"],\n },\n];\n\n// ----------------------------------------------------------------------------\n// 2) 运行参数（可按需调整）\n// ----------------------------------------------------------------------------\nconst CONFIG = {\n // 只保留最近多少天内发布的内容（作为兜底窗口；配合去重使用）\n lookbackDays: 4,\n // 每个主题最多展示多少条，避免邮件过长\n maxItemsPerTopic: 6,\n // 去重库里最多保留多少条历史链接，超出后自动清理最旧的\n maxSeenLinks: 4000,\n // 存储去重数据用的 blob key\n blobKey: \"car_body_radar_seen_links\",\n // 抓取语言：由用户选择“中英文都要”\n fetchZh: true,\n fetchEn: true,\n // 单个 RSS 请求超时（毫秒）\n fetchTimeoutMs: 10000,\n // 并发上限。Google News 会对共享出口 IP 的突发请求返回 503，\n // 全并发（12）必被限流，3 是实测下速度与成功率的平衡点。\n concurrency: 3,\n // 遇到 503 / 429 / 网络错误时的重试次数与退避基数\n maxRetries: 2,\n retryBaseMs: 1000,\n // 把同一主题的多个关键词合并成一条 OR 检索，请求数从 34 降到 12。\n // 若发现某方向结果变少，可改为 false 退回“一个关键词一个请求”。\n combineQueries: true,\n};\n\n// ----------------------------------------------------------------------------\n// 3) 工具函数\n// ----------------------------------------------------------------------------\ninterface Article {\n title: string;\n link: string;\n source: string;\n pubMs: number; // 发布时间戳，解析一次后复用，避免反复 new Date()\n lang: \"zh\" | \"en\";\n}\n\n// 预编译正则，避免每条 item 重新构造\nconst ITEM_RE = /]*>([\\s\\S]*?)<\\/item>/gi;\nconst TITLE_RE = /]*>([\\s\\S]*?)<\\/title>/i;\nconst LINK_RE = /]*>([\\s\\S]*?)<\\/link>/i;\nconst PUBDATE_RE = /]*>([\\s\\S]*?)<\\/pubDate>/i;\nconst SOURCE_RE = /]*>([\\s\\S]*?)<\\/source>/i;\n\n// & 必须最后解，否则会把 < 这类二次转义错误展开\nfunction decodeXml(raw: string): string {\n return raw\n .replace(//g, \"$1\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'|�*39;/g, \"'\")\n .replace(/&#(\\d+);/g, (_, d) => String.fromCodePoint(Number(d)))\n .replace(/&/g, \"&\")\n .trim();\n}\n\nfunction pick(block: string, re: RegExp): string {\n const m = block.match(re);\n return m ? decodeXml(m[1]) : \"\";\n}\n\n// when:Nd 让 Google 只返回时间窗内的结果：响应体积大幅变小，\n// 且避免高相关度的旧闻挤占前 100 条名额、把新内容挤掉。\nfunction googleNewsUrl(query: string, lang: \"zh\" | \"en\", windowDays: number): string {\n const q = encodeURIComponent(`${query} when:${windowDays}d`);\n return lang === \"zh\"\n ? `https://news.google.com/rss/search?q=${q}&hl=zh-CN&gl=CN&ceid=CN:zh-Hans`\n : `https://news.google.com/rss/search?q=${q}&hl=en-US&gl=US&ceid=US:en`;\n}\n\n// 规范化链接，去掉跳转参数带来的重复。无 ?/# 的链接走快速路径\nfunction normalizeLink(link: string): string {\n if (!link.includes(\"?\") && !link.includes(\"#\")) return link;\n try {\n const u = new URL(link);\n u.hash = \"\";\n [\"utm_source\", \"utm_medium\", \"utm_campaign\", \"utm_term\", \"utm_content\", \"oc\"].forEach((p) =>\n u.searchParams.delete(p),\n );\n return u.toString();\n } catch {\n return link;\n }\n}\n\nfunction parseFeed(xml: string, lang: \"zh\" | \"en\"): Article[] {\n const out: Article[] = [];\n ITEM_RE.lastIndex = 0;\n let m: RegExpExecArray | null;\n while ((m = ITEM_RE.exec(xml)) !== null) {\n const block = m[1];\n const pubMs = new Date(pick(block, PUBDATE_RE)).getTime();\n if (isNaN(pubMs)) continue;\n\n // Google News 标题格式常为 \"标题 - 来源\"，标签里有更干净的来源名\n const rawTitle = pick(block, TITLE_RE);\n const source = pick(block, SOURCE_RE);\n const suffix = source ? ` - ${source}` : \"\";\n const title = suffix && rawTitle.endsWith(suffix) ? rawTitle.slice(0, -suffix.length).trim() : rawTitle;\n\n const link = normalizeLink(pick(block, LINK_RE));\n if (!title || !link) continue;\n out.push({ title, link, source, pubMs, lang });\n }\n return out;\n}\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\n// 真实浏览器 UA，自定义 UA 更容易被 Google 拦截\nconst UA =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36\";\n\nasync function fetchFeed(url: string, lang: \"zh\" | \"en\"): Promise {\n let lastErr = \"\";\n\n for (let attempt = 0; attempt <= CONFIG.maxRetries; attempt++) {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), CONFIG.fetchTimeoutMs);\n try {\n const res = await fetch(url, {\n signal: controller.signal,\n headers: {\n \"User-Agent\": UA,\n Accept: \"application/rss+xml, application/xml;q=0.9, */*;q=0.8\",\n \"Accept-Language\": lang === \"zh\" ? \"zh-CN,zh;q=0.9\" : \"en-US,en;q=0.9\",\n },\n });\n if (res.ok) return parseFeed(await res.text(), lang);\n\n lastErr = `HTTP ${res.status}`;\n await res.body?.cancel(); // 不读走响应体会让连接一直挂着\n // 4xx（除 429）是稳定错误，重试没有意义\n if (res.status < 500 && res.status !== 429) break;\n } catch (err) {\n lastErr = (err as Error).message;\n } finally {\n clearTimeout(timer);\n }\n\n // 指数退避 + 随机抖动，避免多个请求同时重试再次撞上限流\n if (attempt < CONFIG.maxRetries) {\n await sleep(CONFIG.retryBaseMs * 2 ** attempt + Math.random() * 500);\n }\n }\n\n console.warn(`抓取失败 [${lang}] ${lastErr}: ${url}`);\n return [];\n}\n\n// 限制同时在飞的请求数\nasync function mapLimit(items: T[], limit: number, fn: (item: T) => Promise): Promise {\n const results = new Array(items.length);\n let next = 0;\n const workers = Array.from({ length: Math.min(limit, items.length) }, async () => {\n while (true) {\n const i = next++;\n if (i >= items.length) break;\n results[i] = await fn(items[i]);\n }\n });\n await Promise.all(workers);\n return results;\n}\n\nfunction escapeHtml(s: string): string {\n return s\n .replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\");\n}\n\nfunction fmtDate(ms: number): string {\n return new Date(ms).toISOString().slice(0, 10);\n}\n\n// ----------------------------------------------------------------------------\n// 4) 邮件发送：使用 Val Town 内置 std/email，发到你的 Val Town 账号邮箱。\n// 不传 to，免费版即可正常发送（to 留空时默认发给账号所有者）。\n// 如需转投到其他邮箱，在账号邮箱里设一条自动转发规则即可。\n// ----------------------------------------------------------------------------\nasync function sendEmail(subject: string, html: string) {\n await email({ subject, html });\n console.log(\"已通过 std/email 发送到 Val Town 账号邮箱\");\n}\n\n// ----------------------------------------------------------------------------\n// 5) 主流程（Cron 入口）\n// ----------------------------------------------------------------------------\ninterface FetchTask {\n topicIndex: number;\n lang: \"zh\" | \"en\";\n query: string;\n}\n\nfunction buildTasks(): FetchTask[] {\n const tasks: FetchTask[] = [];\n TOPICS.forEach((topic, topicIndex) => {\n for (const lang of [\"zh\", \"en\"] as const) {\n if (lang === \"zh\" && !CONFIG.fetchZh) continue;\n if (lang === \"en\" && !CONFIG.fetchEn) continue;\n const keywords = lang === \"zh\" ? topic.zh : topic.en;\n if (CONFIG.combineQueries) {\n tasks.push({ topicIndex, lang, query: keywords.map((k) => `(${k})`).join(\" OR \") });\n } else {\n keywords.forEach((query) => tasks.push({ topicIndex, lang, query }));\n }\n }\n });\n return tasks;\n}\n\nasync function loadSeen(): Promise> {\n try {\n return (await blob.getJSON(CONFIG.blobKey)) || {};\n } catch {\n return {};\n }\n}\n\nexport default async function (interval: { lastRunAt?: Date } = {}) {\n const startedAt = Date.now();\n const now = startedAt;\n // 兜底时间窗：取“上次运行时间”与“lookbackDays”里更早的那个，避免漏内容\n const lookbackMs = now - CONFIG.lookbackDays * 24 * 3600 * 1000;\n const lastRunMs = interval?.lastRunAt ? new Date(interval.lastRunAt).getTime() : lookbackMs;\n const sinceMs = Math.min(lookbackMs, isNaN(lastRunMs) ? lookbackMs : lastRunMs);\n\n const tasks = buildTasks();\n // 多留 1 天余量，避开 Google 与本地时间窗的边界差\n const windowDays = Math.min(30, Math.ceil((now - sinceMs) / 86400000) + 1);\n\n // 抓取与 blob 读取并发；抓取内部按 concurrency 限流，避免触发 Google 503\n const [seen, feeds] = await Promise.all([\n loadSeen(),\n mapLimit(tasks, CONFIG.concurrency, (t) => fetchFeed(googleNewsUrl(t.query, t.lang, windowDays), t.lang)),\n ]);\n const okCount = feeds.filter((f) => f.length > 0).length;\n console.log(\n `抓取完成：${tasks.length} 个请求，${okCount} 个有结果，耗时 ${Date.now() - startedAt}ms`,\n );\n\n // 按主题归拢抓取结果\n const byTopic: Article[][] = TOPICS.map(() => []);\n feeds.forEach((articles, i) => byTopic[tasks[i].topicIndex].push(...articles));\n\n const grouped: { topic: Topic; items: Article[] }[] = [];\n let totalNew = 0;\n\n TOPICS.forEach((topic, i) => {\n // 主题内去重（按链接），并过滤时间窗 + 全局已推送\n const dedup = new Map();\n for (const a of byTopic[i]) {\n if (a.pubMs < sinceMs) continue;\n if (seen[a.link]) continue;\n if (!dedup.has(a.link)) dedup.set(a.link, a);\n }\n\n // 按发布时间倒序，取前 N 条\n const items = [...dedup.values()].sort((x, y) => y.pubMs - x.pubMs).slice(0, CONFIG.maxItemsPerTopic);\n\n items.forEach((a) => (seen[a.link] = now));\n totalNew += items.length;\n grouped.push({ topic, items });\n });\n\n // 清理去重库，避免无限膨胀\n let toStore = seen;\n const seenEntries = Object.entries(seen);\n if (seenEntries.length > CONFIG.maxSeenLinks) {\n seenEntries.sort((a, b) => b[1] - a[1]);\n toStore = Object.fromEntries(seenEntries.slice(0, CONFIG.maxSeenLinks));\n }\n\n if (totalNew === 0) {\n await blob.setJSON(CONFIG.blobKey, toStore);\n console.log(`本次没有新内容，跳过发送。总耗时 ${Date.now() - startedAt}ms`);\n return { totalNew: 0 };\n }\n\n // 写去重库与发信互不依赖，并发执行\n const html = renderEmail(grouped, totalNew, sinceMs, now);\n const dateStr = new Date(now).toISOString().slice(0, 10);\n await Promise.all([\n blob.setJSON(CONFIG.blobKey, toStore),\n sendEmail(`【车身前沿情报】${dateStr} · 新增 ${totalNew} 条`, html),\n ]);\n\n console.log(`完成：共推送 ${totalNew} 条，总耗时 ${Date.now() - startedAt}ms`);\n return { totalNew };\n}\n\n// ----------------------------------------------------------------------------\n// 6) 邮件模板\n// ----------------------------------------------------------------------------\nfunction renderEmail(\n grouped: { topic: Topic; items: Article[] }[],\n totalNew: number,\n sinceMs: number,\n now: number,\n): string {\n const sinceStr = new Date(sinceMs).toISOString().slice(0, 10);\n const nowStr = new Date(now).toISOString().slice(0, 10);\n\n const sections = grouped\n .filter((g) => g.items.length > 0)\n .map((g) => {\n const rows = g.items\n .map((a) => {\n const flag = a.lang === \"zh\" ? \"国内\" : \"国外\";\n const meta = [a.source, fmtDate(a.pubMs)].filter(Boolean).join(\" · \");\n return `\n

\n \n ${escapeHtml(a.title)}\n \n

\n ${flag}\n ${escapeHtml(meta)}\n

`;\n })\n .join(\"\");\n return `\n

\n ${escapeHtml(g.topic.label)}\n （${g.items.length}）\n

${rows}\n

`;\n })\n .join(\"\");\n\n return `\n

车身开发前沿情报

新材料 · 新工艺 · 新技术｜${sinceStr} ~ ${nowStr}｜共 ${totalNew} 条

\n ${sections}\n

\n 本邮件由部署在 Val Town 的自动化程序生成，数据来源：Google News（中/英）。\n 如需调整关注方向或推送频率，请修改 Val 中的 TOPICS / Cron 配置。\n

`;\n}","// ============================================================================\n// 车身开发前沿情报机器人 (Car Body Material & Process Radar)\n// ----------------------------------------------------------------------------\n// 面向车身开发工程师，自动抓取国内外关于新材料 / 新工艺 / 新技术的实时资讯，\n// 去重、按主题归类后，通过邮件定时推送。\n//\n// 部署平台：Val Town (https://val.town) —— 这是一个 Cron 触发的 Val。\n// 运行时：Deno。除 Val Town 标准库外无第三方依赖，冷启动最快。\n//\n// 触发方式：把本文件设为 Cron 触发，每天一次，北京时间 9:00 → UTC `0 1 * * *`。\n// ============================================================================\n\nimport { email } from \"https://esm.town/v/std/email\";\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ----------------------------------------------------------------------------\n// 1) 关注的主题与检索关键词\n// 每个主题包含中文与英文关键词，分别去抓国内源和国外源。\n// 需要增删方向时，直接改这里即可。\n// ----------------------------------------------------------------------------\ninterface Topic {\n id: string;\n label: string; // 邮件里显示的中文分组名\n zh: string[]; // 中文检索词（Google News 中文）\n en: string[]; // 英文检索词（Google News 英文）\n}\n\nconst TOPICS: Topic[] = [\n {\n id: \"steel\",\n label: \"新型高强钢\",\n zh: [\"汽车第三代高强钢\", \"车身热成形钢\", \"汽车超高强钢应用\"],\n en: [\"automotive third generation AHSS\", \"car body press hardened steel\", \"gigapascal steel automotive\"],\n },\n {\n id: \"aldiecast\",\n label: \"压铸铝合金 / 一体化压铸\",\n zh: [\"一体化压铸车身\", \"免热处理压铸铝合金\", \"超大型压铸汽车\"],\n en: [\"gigacasting car body\", \"heat-free die casting aluminum alloy automotive\", \"megacasting vehicle structure\"],\n },\n {\n id: \"mg\",\n label: \"镁合金\",\n zh: [\"镁合金汽车车身\", \"镁合金压铸汽车轻量化\"],\n en: [\"magnesium alloy automotive body\", \"magnesium die casting vehicle lightweight\"],\n },\n {\n id: \"composite\",\n label: \"低成本复合材料\",\n zh: [\"汽车碳纤维复合材料低成本\", \"车身玻纤复合材料轻量化\", \"热塑性复合材料汽车\"],\n en: [\"low cost carbon fiber automotive\", \"thermoplastic composite car body\", \"glass fiber composite vehicle lightweight\"],\n },\n {\n id: \"energy\",\n label: \"高吸能材料 / 碰撞结构\",\n zh: [\"汽车吸能盒材料\", \"车身碰撞吸能结构新材料\", \"泡沫铝汽车吸能\"],\n en: [\"automotive crash energy absorption material\", \"crashworthiness structure new material vehicle\", \"aluminum foam energy absorbing car\"],\n },\n {\n id: \"joining\",\n label: \"连接工艺\",\n zh: [\"车身自冲铆接 SPR\", \"汽车激光焊接铝\", \"车身异种材料连接胶接\"],\n en: [\"self piercing rivet car body\", \"laser welding aluminum automotive\", \"dissimilar material joining car body adhesive\"],\n },\n];\n\n// ----------------------------------------------------------------------------\n// 2) 运行参数（可按需调整）\n// ----------------------------------------------------------------------------\nconst CONFIG = {\n // 只保留最近多少天内发布的内容（兜底窗口；配合去重使用）。\n // 每天推送时 2 天足够，留一天余量以防某次运行失败漏内容。\n lookbackDays: 2,\n // 每个主题最多展示多少条，避免邮件过长\n maxItemsPerTopic: 6,\n // 去重库里最多保留多少条历史链接，超出后自动清理最旧的\n maxSeenLinks: 4000,\n // 存储去重数据用的 blob key\n blobKey: \"car_body_radar_seen_links\",\n // 抓取语言：由用户选择“中英文都要”\n fetchZh: true,\n fetchEn: true,\n // 单个 RSS 请求超时（毫秒）\n fetchTimeoutMs: 10000,\n // 并发上限。Google News 会对共享出口 IP 的突发请求返回 503，\n // 全并发（12）必被限流，3 是实测下速度与成功率的平衡点。\n concurrency: 3,\n // 遇到 503 / 429 / 网络错误时的重试次数与退避基数\n maxRetries: 2,\n retryBaseMs: 1000,\n // 把同一主题的多个关键词合并成一条 OR 检索，请求数从 34 降到 12。\n // 若发现某方向结果变少，可改为 false 退回“一个关键词一个请求”。\n combineQueries: true,\n};\n\n// ----------------------------------------------------------------------------\n// 3) 工具函数\n// ----------------------------------------------------------------------------\ninterface Article {\n title: string;\n link: string;\n source: string;\n pubMs: number; // 发布时间戳，解析一次后复用，避免反复 new Date()\n lang: \"zh\" | \"en\";\n}\n\n// 预编译正则，避免每条 item 重新构造\nconst ITEM_RE = /]*>([\\s\\S]*?)<\\/item>/gi;\nconst TITLE_RE = /]*>([\\s\\S]*?)<\\/title>/i;\nconst LINK_RE = /]*>([\\s\\S]*?)<\\/link>/i;\nconst PUBDATE_RE = /]*>([\\s\\S]*?)<\\/pubDate>/i;\nconst SOURCE_RE = /]*>([\\s\\S]*?)<\\/source>/i;\n\n// & 必须最后解，否则会把 < 这类二次转义错误展开\nfunction decodeXml(raw: string): string {\n return raw\n .replace(//g, \"$1\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'|�*39;/g, \"'\")\n .replace(/&#(\\d+);/g, (_, d) => String.fromCodePoint(Number(d)))\n .replace(/&/g, \"&\")\n .trim();\n}\n\nfunction pick(block: string, re: RegExp): string {\n const m = block.match(re);\n return m ? decodeXml(m[1]) : \"\";\n}\n\n// when:Nd 让 Google 只返回时间窗内的结果：响应体积大幅变小，\n// 且避免高相关度的旧闻挤占前 100 条名额、把新内容挤掉。\nfunction googleNewsUrl(query: string, lang: \"zh\" | \"en\", windowDays: number): string {\n const q = encodeURIComponent(`${query} when:${windowDays}d`);\n return lang === \"zh\"\n ? `https://news.google.com/rss/search?q=${q}&hl=zh-CN&gl=CN&ceid=CN:zh-Hans`\n : `https://news.google.com/rss/search?q=${q}&hl=en-US&gl=US&ceid=US:en`;\n}\n\n// 规范化链接，去掉跳转参数带来的重复。无 ?/# 的链接走快速路径\nfunction normalizeLink(link: string): string {\n if (!link.includes(\"?\") && !link.includes(\"#\")) return link;\n try {\n const u = new URL(link);\n u.hash = \"\";\n [\"utm_source\", \"utm_medium\", \"utm_campaign\", \"utm_term\", \"utm_content\", \"oc\"].forEach((p) =>\n u.searchParams.delete(p),\n );\n return u.toString();\n } catch {\n return link;\n }\n}\n\nfunction parseFeed(xml: string, lang: \"zh\" | \"en\"): Article[] {\n const out: Article[] = [];\n ITEM_RE.lastIndex = 0;\n let m: RegExpExecArray | null;\n while ((m = ITEM_RE.exec(xml)) !== null) {\n const block = m[1];\n const pubMs = new Date(pick(block, PUBDATE_RE)).getTime();\n if (isNaN(pubMs)) continue;\n\n // Google News 标题格式常为 \"标题 - 来源\"，标签里有更干净的来源名\n const rawTitle = pick(block, TITLE_RE);\n const source = pick(block, SOURCE_RE);\n const suffix = source ? ` - ${source}` : \"\";\n const title = suffix && rawTitle.endsWith(suffix) ? rawTitle.slice(0, -suffix.length).trim() : rawTitle;\n\n const link = normalizeLink(pick(block, LINK_RE));\n if (!title || !link) continue;\n out.push({ title, link, source, pubMs, lang });\n }\n return out;\n}\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\n// 真实浏览器 UA，自定义 UA 更容易被 Google 拦截\nconst UA =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36\";\n\nasync function fetchFeed(url: string, lang: \"zh\" | \"en\"): Promise {\n let lastErr = \"\";\n\n for (let attempt = 0; attempt <= CONFIG.maxRetries; attempt++) {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), CONFIG.fetchTimeoutMs);\n try {\n const res = await fetch(url, {\n signal: controller.signal,\n headers: {\n \"User-Agent\": UA,\n Accept: \"application/rss+xml, application/xml;q=0.9, */*;q=0.8\",\n \"Accept-Language\": lang === \"zh\" ? \"zh-CN,zh;q=0.9\" : \"en-US,en;q=0.9\",\n },\n });\n if (res.ok) return parseFeed(await res.text(), lang);\n\n lastErr = `HTTP ${res.status}`;\n await res.body?.cancel(); // 不读走响应体会让连接一直挂着\n // 4xx（除 429）是稳定错误，重试没有意义\n if (res.status < 500 && res.status !== 429) break;\n } catch (err) {\n lastErr = (err as Error).message;\n } finally {\n clearTimeout(timer);\n }\n\n // 指数退避 + 随机抖动，避免多个请求同时重试再次撞上限流\n if (attempt < CONFIG.maxRetries) {\n await sleep(CONFIG.retryBaseMs * 2 ** attempt + Math.random() * 500);\n }\n }\n\n console.warn(`抓取失败 [${lang}] ${lastErr}: ${url}`);\n return [];\n}\n\n// 限制同时在飞的请求数\nasync function mapLimit(items: T[], limit: number, fn: (item: T) => Promise): Promise {\n const results = new Array(items.length);\n let next = 0;\n const workers = Array.from({ length: Math.min(limit, items.length) }, async () => {\n while (true) {\n const i = next++;\n if (i >= items.length) break;\n results[i] = await fn(items[i]);\n }\n });\n await Promise.all(workers);\n return results;\n}\n\nfunction escapeHtml(s: string): string {\n return s\n .replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\");\n}\n\nfunction fmtDate(ms: number): string {\n return new Date(ms).toISOString().slice(0, 10);\n}\n\n// ----------------------------------------------------------------------------\n// 4) 邮件发送：使用 Val Town 内置 std/email，发到你的 Val Town 账号邮箱。\n// 不传 to，免费版即可正常发送（to 留空时默认发给账号所有者）。\n// 如需转投到其他邮箱，在账号邮箱里设一条自动转发规则即可。\n// ----------------------------------------------------------------------------\nasync function sendEmail(subject: string, html: string) {\n await email({ subject, html });\n console.log(\"已通过 std/email 发送到 Val Town 账号邮箱\");\n}\n\n// ----------------------------------------------------------------------------\n// 5) 主流程（Cron 入口）\n// ----------------------------------------------------------------------------\ninterface FetchTask {\n topicIndex: number;\n lang: \"zh\" | \"en\";\n query: string;\n}\n\nfunction buildTasks(): FetchTask[] {\n const tasks: FetchTask[] = [];\n TOPICS.forEach((topic, topicIndex) => {\n for (const lang of [\"zh\", \"en\"] as const) {\n if (lang === \"zh\" && !CONFIG.fetchZh) continue;\n if (lang === \"en\" && !CONFIG.fetchEn) continue;\n const keywords = lang === \"zh\" ? topic.zh : topic.en;\n if (CONFIG.combineQueries) {\n tasks.push({ topicIndex, lang, query: keywords.map((k) => `(${k})`).join(\" OR \") });\n } else {\n keywords.forEach((query) => tasks.push({ topicIndex, lang, query }));\n }\n }\n });\n return tasks;\n}\n\nasync function loadSeen(): Promise> {\n try {\n return (await blob.getJSON(CONFIG.blobKey)) || {};\n } catch {\n return {};\n }\n}\n\nexport default async function (interval: { lastRunAt?: Date } = {}) {\n const startedAt = Date.now();\n const now = startedAt;\n // 兜底时间窗：取“上次运行时间”与“lookbackDays”里更早的那个，避免漏内容\n const lookbackMs = now - CONFIG.lookbackDays * 24 * 3600 * 1000;\n const lastRunMs = interval?.lastRunAt ? new Date(interval.lastRunAt).getTime() : lookbackMs;\n const sinceMs = Math.min(lookbackMs, isNaN(lastRunMs) ? lookbackMs : lastRunMs);\n\n const tasks = buildTasks();\n // 多留 1 天余量，避开 Google 与本地时间窗的边界差\n const windowDays = Math.min(30, Math.ceil((now - sinceMs) / 86400000) + 1);\n\n // 抓取与 blob 读取并发；抓取内部按 concurrency 限流，避免触发 Google 503\n const [seen, feeds] = await Promise.all([\n loadSeen(),\n mapLimit(tasks, CONFIG.concurrency, (t) => fetchFeed(googleNewsUrl(t.query, t.lang, windowDays), t.lang)),\n ]);\n const okCount = feeds.filter((f) => f.length > 0).length;\n console.log(\n `抓取完成：${tasks.length} 个请求，${okCount} 个有结果，耗时 ${Date.now() - startedAt}ms`,\n );\n\n // 按主题归拢抓取结果\n const byTopic: Article[][] = TOPICS.map(() => []);\n feeds.forEach((articles, i) => byTopic[tasks[i].topicIndex].push(...articles));\n\n const grouped: { topic: Topic; items: Article[] }[] = [];\n let totalNew = 0;\n\n TOPICS.forEach((topic, i) => {\n // 主题内去重（按链接），并过滤时间窗 + 全局已推送\n const dedup = new Map();\n for (const a of byTopic[i]) {\n if (a.pubMs < sinceMs) continue;\n if (seen[a.link]) continue;\n if (!dedup.has(a.link)) dedup.set(a.link, a);\n }\n\n // 按发布时间倒序，取前 N 条\n const items = [...dedup.values()].sort((x, y) => y.pubMs - x.pubMs).slice(0, CONFIG.maxItemsPerTopic);\n\n items.forEach((a) => (seen[a.link] = now));\n totalNew += items.length;\n grouped.push({ topic, items });\n });\n\n // 清理去重库，避免无限膨胀\n let toStore = seen;\n const seenEntries = Object.entries(seen);\n if (seenEntries.length > CONFIG.maxSeenLinks) {\n seenEntries.sort((a, b) => b[1] - a[1]);\n toStore = Object.fromEntries(seenEntries.slice(0, CONFIG.maxSeenLinks));\n }\n\n if (totalNew === 0) {\n await blob.setJSON(CONFIG.blobKey, toStore);\n console.log(`本次没有新内容，跳过发送。总耗时 ${Date.now() - startedAt}ms`);\n return { totalNew: 0 };\n }\n\n // 写去重库与发信互不依赖，并发执行\n const html = renderEmail(grouped, totalNew, sinceMs, now);\n const dateStr = new Date(now).toISOString().slice(0, 10);\n await Promise.all([\n blob.setJSON(CONFIG.blobKey, toStore),\n sendEmail(`【车身前沿情报】${dateStr} · 新增 ${totalNew} 条`, html),\n ]);\n\n console.log(`完成：共推送 ${totalNew} 条，总耗时 ${Date.now() - startedAt}ms`);\n return { totalNew };\n}\n\n// ----------------------------------------------------------------------------\n// 6) 邮件模板\n// ----------------------------------------------------------------------------\nfunction renderEmail(\n grouped: { topic: Topic; items: Article[] }[],\n totalNew: number,\n sinceMs: number,\n now: number,\n): string {\n const sinceStr = new Date(sinceMs).toISOString().slice(0, 10);\n const nowStr = new Date(now).toISOString().slice(0, 10);\n\n const sections = grouped\n .filter((g) => g.items.length > 0)\n .map((g) => {\n const rows = g.items\n .map((a) => {\n const flag = a.lang === \"zh\" ? \"国内\" : \"国外\";\n const meta = [a.source, fmtDate(a.pubMs)].filter(Boolean).join(\" · \");\n return `\n

\n \n ${escapeHtml(a.title)}\n \n

\n ${flag}\n ${escapeHtml(meta)}\n

`;\n })\n .join(\"\");\n return `\n

\n ${escapeHtml(g.topic.label)}\n （${g.items.length}）\n

${rows}\n

`;\n })\n .join(\"\");\n\n return `\n

车身开发前沿情报

新材料 · 新工艺 · 新技术｜${sinceStr} ~ ${nowStr}｜共 ${totalNew} 条

\n ${sections}\n

\n 本邮件由部署在 Val Town 的自动化程序生成，数据来源：Google News（中/英）。\n 如需调整关注方向或推送频率，请修改 Val 中的 TOPICS / Cron 配置。\n

`;\n}","createdAt",["D",1784950343283],"branchVersion","branchId","853a422d-e3ad-4c64-85f7-14098d3fdec9","id","44f6b27a-dccf-41dc-ad02-50c2620e967c","biw-tech-rss",["D",1784819628999],"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","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",11,"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":148,"_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":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":149,"_79":150,"_81":151,"_83":25},"tree",[143],"files",[143],"counts",{"_132":61,"_133":134,"_135":61,"_136":137,"_138":139},"contents",[124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":25,"_38":128,"_13":129,"_33":34,"_35":37,"_24":25,"_130":-5,"_27":131},"6e8eb8be-0001-4f52-b5b5-db0f74f029cc","parentId","latest",["D",1784950343283],7,"label",[28],"pulls","branches",1,"forks","envVars",{"_140":61,"_142":61},"connections",{"_140":61,"_141":61},"count","unfilledCount","emptyCount",{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":25,"_38":144,"_13":129,"_33":34,"_35":37,"_24":25,"_130":-5,"_145":146,"_27":147},["D",1784950343283],"children",[],[28],["D",1784819628999],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_121":185,"_186":187,"_188":189,"_190":25,"_191":25,"_192":25,"_193":194,"_195":-5,"_196":-7,"_197":-7,"_198":61,"_199":25,"_200":25,"_201":-5,"_202":25,"_203":25,"_204":25,"_205":-5},"ENV",{"_156":157,"_158":159,"_160":85,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8