NEXT-ROUND-PROMPT 更新到下一轮：EAN 回 S03 置顶、剩余5平台/妙手；补 SHEIN≠Temu 规格差异表、cdp3.mjs 备份与丢失重建、钩子方法论说明

cdp3.mjs

@@ -0,0 +1,37 @@
+const BASE = process.env.CDP_BASE || 'http://127.0.0.1:9223';
+export const SAN = s => (s||'').replace(/data:[a-z+/-]+;base64,[A-Za-z0-9+/=\s]{40,}/gi,'<IMG>').replace(/[A-Za-z0-9+/]{100,}={0,2}/g,'<B64>').replace(/\s+/g,' ').trim();
+export async function newTarget(url='about:blank'){
+  const r=await fetch(`${BASE}/json/new?${encodeURIComponent(url)}`,{method:'PUT'});
+  return r.ok? r.json() : (await fetch(`${BASE}/json/new?${encodeURIComponent(url)}`)).json();
+}
+export async function attach(match){
+  const list=await (await fetch(`${BASE}/json/list`)).json();
+  const ps=list.filter(t=>t.type==='page'&&(!match||t.url.includes(match)));
+  if(!ps.length) return null;
+  const c=await CDP.connect(ps[ps.length-1].webSocketDebuggerUrl);
+  await c.send('Page.enable'); await c.send('Runtime.enable'); return c;
+}
+export async function closeAllTabs(){
+  const list=await (await fetch(`${BASE}/json/list`)).json();
+  for(const t of list.filter(x=>x.type==='page')) await fetch(`${BASE}/json/close/${t.id}`).catch(()=>{});
+}
+export class CDP{
+  constructor(ws){this.ws=ws;this.id=0;this.pending=new Map();this.handlers=[];}
+  static async connect(u){const ws=new WebSocket(u);await new Promise((s,j)=>{ws.onopen=s;ws.onerror=j;});
+    const c=new CDP(ws);
+    ws.onmessage=ev=>{const m=JSON.parse(ev.data);
+      if(m.id&&c.pending.has(m.id)){const{res,rej}=c.pending.get(m.id);c.pending.delete(m.id);
+        m.error?rej(new Error(JSON.stringify(m.error))):res(m.result);}
+      else if(m.method){for(const h of c.handlers)h(m);}};
+    return c;}
+  send(method,params={}){const id=++this.id;
+    return new Promise((res,rej)=>{this.pending.set(id,{res,rej});
+      this.ws.send(JSON.stringify({id,method,params}));
+      setTimeout(()=>{if(this.pending.has(id)){this.pending.delete(id);rej(new Error('timeout '+method));}},60000);});}
+  on(f){this.handlers.push(f);}
+  async evalJS(e,aw=true){const r=await this.send('Runtime.evaluate',{expression:e,returnByValue:true,awaitPromise:aw});
+    if(r.exceptionDetails)throw new Error(JSON.stringify(r.exceptionDetails).slice(0,220));return r.result?.value;}
+  async shot(p){const r=await this.send('Page.captureScreenshot',{format:'jpeg',quality:80});
+    const fs=await import('fs'); fs.writeFileSync(p,Buffer.from(r.data,'base64')); return p;}
+  close(){try{this.ws.close();}catch{}}
+}