perf: 把 content-observer 的优化覆盖扩展到所有重型视频站、缩略图墙、聊天直播站

之前只针对 B 站做了三轴优化（Set 去重 / SKIP_TAGS 跳媒体元素 / mutation+resource 上限自停），但场景类似的站点很多——抖音 / 快手 / TikTok 短视频流、YouTube / Twitch / niconico / AcFun 弹幕聊天、Pornhub / XHamster / XVideos / MissAV / Jable / JavDB 等大量缩略图墙加无限滚动。这一轮把这套保护机制做厚做全。

PerformanceObserver 加双轴过滤：
- SKIP_INITIATOR_TYPES 拒绝 img / video / audio / beacon / track / object / embed / css 这八类 entry。这些资源对识别技术栈零价值（图片是产品 / 缩略图，video / audio 是流媒体本体，css 是样式不是 stylesheet 文件本身），却占掉绝大多数 PerformanceObserver entry。Pornhub / 抖音的资源数能从几千降到几百
- SKIP_RESOURCE_EXT 兜底正则：.ts / .m4s / .mp4 / .webm / .mov / .m3u8 / .mpd / .jpg / .jpeg / .png / .gif / .webp / .avif / .ico / .woff / .woff2 / .ttf / .otf / .eot 这些扩展名直接 skip。HLS 视频流 .ts 分片每分钟产生几百条，不过滤一定打满。entry 携带 query string 也匹配。两轴并联是因为 initiatorType 不一定可靠（某些 SDK 用 fetch 加载 m3u8，initiatorType=fetch 不会被 SKIP_INITIATOR_TYPES 拦下，靠扩展名兜底）

mutation 加 burst 冷却：
- 1 秒滑动窗口，新增节点数累计超过 MUTATION_BURST_THRESHOLD = 300 直接进 5 秒冷却（mutationCooldownUntil = now + 5000）
- 冷却期内整个 MutationObserver 回调直接 return，不入队、不 flush、清掉 pendingMutationNodes 与未调度的 RAF
- 抖音 / 快手 / TikTok feed 滑动一次插入 200-1000 个 DOM 节点，在原本「累计 5000 条自停」之前就已经卡 1-2 秒。Burst 冷却让前 300 条收完就立即停采集 5 秒，给主线程让位
- 5 秒后窗口重新开始计数，如果用户已经从短视频流滑走或停手，新窗口里 mutation 数量会回归正常水平继续采集；如果还在持续滑动，下一个窗口同样很快触发冷却，循环保护

弹幕 / 聊天 / 直播 / feed 容器整个子树拉黑：
- SKIP_CONTAINER_NAMES 是一组正则，匹配元素的 id 或 class token：danmaku / barrage / bullet-comment / bullet-screen / chat / chat-(panel|area|list|box|room|stream|window) / live-chat / comment-(stream|live|list) / feed / webcast
- 命中：B 站 / AcFun / niconico 弹幕容器、Twitch / YouTube live chat、抖音 / TikTok 直播间 webcast 容器、各 SPA 推荐 feed
- 检查时机：collectFromElement 入口和 mutation push 入队前各拦截一次。命中即整个子树跳过，不进 querySelectorAll、不入队
- 实现细节：matchesSkipContainer 把 element.id + className.split(/\s+/) 拼成 token 列表，对 9 条正则做 token 级匹配（不跑 element.matches，避免选择器编译开销）。class token 切分一次，正则数组遍历一次

state.resourceCount 计入跳过前的总数（用作自停阈值），但 addUrl 只对真正入列的资源算"添加成功"，scheduleSend 只在真正添加时触发。这样过滤后的 entry 不会引发不必要的 sendMessage 噪声，但累计阈值仍按"实际收到了多少 entry"工作。

插件版本升级到 1.1.3。

Author: setube

package.json

@@ -1,7 +1,7 @@
 {
   "name": "stackprism",
   "private": true,
-  "version": "1.1.2",
+  "version": "1.1.3",
   "type": "module",
   "description": "StackPrism 用于检测网页前端、后端、CDN、SaaS、广告营销、统计、登录、支付、网站程序和主题模板线索。",
   "scripts": {

src/content/content-observer.ts

@@ -5,9 +5,25 @@
   const MAX_MUTATION_COUNT = 5000
   const MAX_RESOURCE_COUNT = 1500
   const SEND_DELAY = 900
+  const MUTATION_BURST_WINDOW_MS = 1000
+  const MUTATION_BURST_THRESHOLD = 300
+  const MUTATION_COOLDOWN_MS = 5000
   const CONTEXT_INVALIDATED_PATTERN = /extension context invalidated|context invalidated/i
   const OBSERVER_INSTANCE_KEY = '__stackPrismContentObserver__'
   const SKIP_TAGS = new Set(['VIDEO', 'AUDIO', 'CANVAS', 'PICTURE', 'SOURCE', 'TRACK', 'SVG', 'IMG'])
+  const SKIP_INITIATOR_TYPES = new Set(['img', 'video', 'audio', 'beacon', 'track', 'object', 'embed', 'css'])
+  const SKIP_RESOURCE_EXT = /\.(ts|m4s|mp4|webm|mov|m3u8|mpd|jpg|jpeg|png|gif|webp|avif|ico|woff2?|ttf|otf|eot)(\?.*)?$/i
+  const SKIP_CONTAINER_NAMES = [
+    /danmaku/i,
+    /bullet[\s_-]*(comment|screen|chat)/i,
+    /barrage/i,
+    /(^|[\s._#-])chat([\s._#-]|$)/i,
+    /chat-?(panel|area|list|box|room|stream|window)/i,
+    /live-?chat/i,
+    /comment-?(stream|live|list)/i,
+    /(^|[\s._-])feed([\s._-]|$)/i,
+    /webcast/i
+  ]
   const state = {
     startedAt: Date.now(),
     updatedAt: Date.now(),
@@ -39,6 +55,9 @@
   let wrappedReplaceState = null
   let pendingMutationNodes = []
   let pendingMutationFrame = 0
+  let mutationBurstWindowStart = Date.now()
+  let mutationBurstCount = 0
+  let mutationCooldownUntil = 0
 
   // ----- 底层 helper -----
 
@@ -197,9 +216,25 @@
   const SUBTREE_SCAN_LIMIT = 200
   const SUBTREE_SELECTOR = 'script[src], link[href], iframe[src], [id], [class], [data-v-app], [ng-version], astro-island, astro-slot'
 
+  const matchesSkipContainer = element => {
+    const tokens = []
+    const id = element.id
+    if (id) tokens.push(id)
+    const className = typeof element.className === 'string' ? element.className : element.getAttribute?.('class') || ''
+    if (className) {
+      for (const piece of className.split(/\s+/)) if (piece) tokens.push(piece)
+    }
+    if (!tokens.length) return false
+    for (const re of SKIP_CONTAINER_NAMES) {
+      for (const token of tokens) if (re.test(token)) return true
+    }
+    return false
+  }
+
   const collectFromElement = element => {
     let changed = false
     if (SKIP_TAGS.has(element.tagName)) return changed
+    if (matchesSkipContainer(element)) return changed
     changed = collectElementIfRelevant(element) || changed
     if (!element.querySelectorAll || !element.childElementCount) return changed
     const matches = element.querySelectorAll(SUBTREE_SELECTOR)
@@ -369,15 +404,18 @@
     try {
       const observer = new PerformanceObserver(list => {
         if (stopped) return
+        let added = 0
         for (const entry of list.getEntries()) {
-          addUrl('resources', entry.name)
+          if (SKIP_INITIATOR_TYPES.has(entry.initiatorType)) continue
+          if (SKIP_RESOURCE_EXT.test(entry.name)) continue
+          if (addUrl('resources', entry.name)) added += 1
           state.resourceCount += 1
         }
         if (state.resourceCount >= MAX_RESOURCE_COUNT) {
           observer.disconnect()
           performanceObserver = null
         }
-        scheduleSend()
+        if (added) scheduleSend()
       })
       performanceObserver = observer
       observer.observe({ type: 'resource', buffered: true })
@@ -426,14 +464,32 @@
     const root = document.documentElement || document
     const observer = new MutationObserver(mutations => {
       if (stopped) return
+      const now = Date.now()
+      if (now < mutationCooldownUntil) return
+      if (now - mutationBurstWindowStart > MUTATION_BURST_WINDOW_MS) {
+        mutationBurstWindowStart = now
+        mutationBurstCount = 0
+      }
       for (const mutation of mutations) {
         for (const node of mutation.addedNodes) {
           if (node.nodeType !== Node.ELEMENT_NODE) continue
           if (SKIP_TAGS.has(node.tagName)) continue
+          if (matchesSkipContainer(node)) continue
           state.mutationCount += 1
+          mutationBurstCount += 1
           pendingMutationNodes.push(node)
         }
       }
+      if (mutationBurstCount >= MUTATION_BURST_THRESHOLD) {
+        mutationCooldownUntil = now + MUTATION_COOLDOWN_MS
+        pendingMutationNodes = []
+        if (pendingMutationFrame) {
+          if (typeof cancelAnimationFrame === 'function') cancelAnimationFrame(pendingMutationFrame)
+          else clearTimeout(pendingMutationFrame)
+          pendingMutationFrame = 0
+        }
+        return
+      }
       if (state.mutationCount >= MAX_MUTATION_COUNT) {
         observer.disconnect()
         mutationObserver = null