/**
* XHRBreakpointManager - XHR/Fetch 断点管理
*
* 功能：
* 1. 设置 XHR/Fetch 断点（URL 模式匹配）
* 2. 在网络请求发送前暂停执行
* 3. 追踪请求参数和响应
*
* 设计原则：
* - 使用 CDP DOMDebugger.setXHRBreakpoint
* - 支持通配符模式匹配
* - 提供断点命中统计
*/
import type { CDPSession } from 'puppeteer';
import { logger } from '../../utils/logger.js';
/**
* XHR 断点信息
*/
export interface XHRBreakpoint {
id: string;
urlPattern: string;
enabled: boolean;
hitCount: number;
createdAt: number;
}
/**
* XHR 断点管理器
*
* 🔧 重构：使用共享的 CDP session，不再创建独立 session
*/
export class XHRBreakpointManager {
private xhrBreakpoints: Map<string, XHRBreakpoint> = new Map();
private breakpointCounter = 0;
/**
* @param cdpSession 共享的 CDP Session（由 DebuggerManager 提供）
*/
constructor(private cdpSession: CDPSession) {
logger.info('XHRBreakpointManager initialized with shared CDP session');
}
/**
* 设置 XHR 断点
*
* @param urlPattern URL 模式（支持通配符 *）
* @returns 断点 ID
*/
async setXHRBreakpoint(urlPattern: string): Promise<string> {
try {
// 调用 CDP API 设置 XHR 断点
await this.cdpSession.send('DOMDebugger.setXHRBreakpoint', {
url: urlPattern,
});
// 创建断点信息
const breakpointId = `xhr_${++this.breakpointCounter}`;
this.xhrBreakpoints.set(breakpointId, {
id: breakpointId,
urlPattern,
enabled: true,
hitCount: 0,
createdAt: Date.now(),
});
logger.info(`XHR breakpoint set: ${urlPattern}`, { breakpointId });
return breakpointId;
} catch (error) {
logger.error('Failed to set XHR breakpoint:', error);
throw error;
}
}
/**
* 删除 XHR 断点
*/
async removeXHRBreakpoint(breakpointId: string): Promise<boolean> {
const breakpoint = this.xhrBreakpoints.get(breakpointId);
if (!breakpoint) {
return false;
}
try {
// 调用 CDP API 删除 XHR 断点
await this.cdpSession.send('DOMDebugger.removeXHRBreakpoint', {
url: breakpoint.urlPattern,
});
this.xhrBreakpoints.delete(breakpointId);
logger.info(`XHR breakpoint removed: ${breakpointId}`);
return true;
} catch (error) {
logger.error('Failed to remove XHR breakpoint:', error);
throw error;
}
}
/**
* 获取所有 XHR 断点
*/
getAllXHRBreakpoints(): XHRBreakpoint[] {
return Array.from(this.xhrBreakpoints.values());
}
/**
* 获取特定 XHR 断点
*/
getXHRBreakpoint(breakpointId: string): XHRBreakpoint | undefined {
return this.xhrBreakpoints.get(breakpointId);
}
/**
* 清除所有 XHR 断点
*/
async clearAllXHRBreakpoints(): Promise<void> {
const breakpoints = Array.from(this.xhrBreakpoints.values());
for (const bp of breakpoints) {
try {
await this.cdpSession.send('DOMDebugger.removeXHRBreakpoint', {
url: bp.urlPattern,
});
} catch (error) {
logger.warn(`Failed to remove XHR breakpoint ${bp.id}:`, error);
}
}
this.xhrBreakpoints.clear();
logger.info('All XHR breakpoints cleared');
}
/**
* 🆕 关闭并清理资源
*/
async close(): Promise<void> {
try {
await this.clearAllXHRBreakpoints();
logger.info('XHRBreakpointManager closed');
} catch (error) {
logger.error('Failed to close XHRBreakpointManager:', error);
throw error;
}
}
}
