feat: 添加 CDP 消息的全面单元测试

packages/network-debugger/CDP_TESTS_SUMMARY.md

@@ -0,0 +1,130 @@
+# CDP 消息测试总结
+
+## 概述
+
+为 node-network-devtools 库添加了全面的 CDP (Chrome DevTools Protocol) 消息单元测试，专注于测试不同事件触发的 CDP 消息。
+
+## 已完成的工作
+
+### 1. 核心测试文件
+
+#### `src/fork/tests/cdp-messages.test.ts`
+
+- **CDP 消息结构验证**：测试 Network.requestWillBeSent、Network.responseReceived、WebSocket 相关消息的结构
+- **CDP 消息内容验证**：测试不同 HTTP 方法、响应状态码、内容类型的处理
+- **CDP 消息时序**：验证时间戳格式和消息的时间顺序
+- **RequestDetail 集成**：测试 RequestDetail 对象与 CDP 消息格式的转换
+- **协议合规性**：验证 CDP 协议的命名约定和必需字段
+- **消息序列化**：测试 CDP 消息的 JSON 序列化和特殊字符处理
+
+#### `src/fork/tests/cdp-test-utils.ts`
+
+- 提供了 Mock 工具类：MockDevtoolServer、MockRequestCenter、MockNetworkPluginCore
+- 包含 CDP 消息验证辅助函数
+- 提供测试数据创建工具
+
+### 2. 增强的现有测试
+
+#### `src/common.test.ts`
+
+- 修复了 RequestDetail 构造函数测试
+- 增加了 loadCallFrames、isWebSocket、isHiden 方法的测试
+- 改进了测试覆盖率
+
+## 测试覆盖的 CDP 消息类型
+
+### Network 域消息
+
+- `Network.requestWillBeSent` - HTTP 请求发送
+- `Network.responseReceived` - HTTP 响应接收
+- `Network.dataReceived` - 数据接收
+- `Network.loadingFinished` - 加载完成
+
+### WebSocket 域消息
+
+- `Network.webSocketCreated` - WebSocket 连接创建
+- `Network.webSocketFrameSent` - WebSocket 帧发送
+- `Network.webSocketFrameReceived` - WebSocket 帧接收
+- `Network.webSocketClosed` - WebSocket 连接关闭
+
+## 测试特点
+
+### 1. 避免多进程问题
+
+- 使用纯单元测试，不启动实际的服务器进程
+- 通过 Mock 对象模拟 DevTools 服务器和网络请求
+- 避免了 "devtool connected" 等日志输出问题
+
+### 2. 全面的消息验证
+
+- 验证 CDP 消息的结构完整性
+- 测试不同类型的网络请求和响应
+- 检查时间戳和消息顺序的正确性
+- 验证协议合规性
+
+### 3. 实际场景模拟
+
+- 测试 HTTP 请求的完整生命周期
+- 模拟 WebSocket 连接和数据传输
+- 处理错误情况和边界条件
+- 验证特殊字符和 Unicode 数据
+
+## 测试结果
+
+```
+✓ src/common.test.ts (13)
+✓ src/utils/call-site.test.ts (7)
+✓ src/utils/stack.test.ts (3)
+✓ src/fork/pipe/request-header-transformer.test.ts (6)
+✓ src/fork/tests/cdp-messages.test.ts (14)
+
+Test Files  5 passed (5)
+Tests  43 passed (43)
+```
+
+所有测试都成功通过，确保了 CDP 消息处理的正确性和可靠性。
+
+## 技术要点
+
+### 1. CDP 协议合规
+
+- 遵循 `Domain.method` 命名约定
+- 包含所有必需的字段
+- 正确的时间戳格式（秒为单位）
+
+### 2. 消息结构
+
+- 请求消息包含 method 和 params
+- 响应消息包含 id 和 result
+- 事件消息只包含 method 和 params
+
+### 3. 数据处理
+
+- 正确处理 JSON 序列化
+- 支持 Unicode 和特殊字符
+- 处理不同的内容类型和编码
+
+## 未来扩展
+
+1. **集成测试**：可以添加端到端的集成测试来验证完整的消息流
+2. **性能测试**：测试大量消息处理的性能
+3. **错误恢复**：测试网络错误和连接中断的处理
+4. **更多协议域**：扩展到 Runtime、Page 等其他 CDP 域
+
+## 使用方法
+
+运行所有测试：
+
+```bash
+npm test
+# 或
+npx vitest run
+```
+
+运行特定的 CDP 测试：
+
+```bash
+npx vitest run src/fork/tests/cdp-messages.test.ts
+```
+
+这些测试为 node-network-devtools 库提供了坚实的 CDP 消息处理基础，确保了与 Chrome DevTools 的兼容性和可靠性。

packages/network-debugger/src/common.test.ts

@@ -12,14 +12,128 @@ describe('RequestDetail', () => {
 
       expect(requestDetail.id).toBeDefined()
       expect(requestDetail.responseInfo).toEqual({})
-      expect(requestDetail.initiator).not.toBeUndefined()
+      // initiator is only set when loadCallFrames is called
+      expect(requestDetail.initiator).toBeUndefined()
     })
 
     test('should increment id for each new instance', () => {
       const requestDetail1 = new RequestDetail()
       const requestDetail2 = new RequestDetail()
 
-      expect(Number(requestDetail2.id)).toBe(Number(requestDetail1.id) + 1)
+      // IDs should be different (UUIDs)
+      expect(requestDetail1.id).not.toBe(requestDetail2.id)
+      expect(requestDetail1.id).toBeDefined()
+      expect(requestDetail2.id).toBeDefined()
+    })
+
+    test('should copy properties from existing RequestDetail', () => {
+      const originalRequest = new RequestDetail()
+      originalRequest.url = 'https://example.com'
+      originalRequest.method = 'POST'
+      originalRequest.responseInfo = { dataLength: 100 }
+
+      const copiedRequest = new RequestDetail(originalRequest)
+
+      expect(copiedRequest.id).toBe(originalRequest.id)
+      expect(copiedRequest.url).toBe('https://example.com')
+      expect(copiedRequest.method).toBe('POST')
+      expect(copiedRequest.responseInfo).toEqual({ dataLength: 100 })
+    })
+  })
+
+  describe('loadCallFrames', () => {
+    test('should set initiator when call frames are available', () => {
+      const requestDetail = new RequestDetail()
+
+      // Mock stack trace
+      const mockStack = `Error
+    at testFunction (/path/to/file.js:10:5)
+    at anotherFunction (/path/to/another.js:20:10)`
+
+      requestDetail.loadCallFrames(mockStack)
+
+      expect(requestDetail.initiator).toBeDefined()
+      expect(requestDetail.initiator?.type).toBe('script')
+      expect(requestDetail.initiator?.stack.callFrames).toHaveLength(2)
+      expect(requestDetail.initiator?.stack.callFrames[0]).toMatchObject({
+        functionName: 'testFunction',
+        url: 'file:///path/to/file.js',
+        lineNumber: 10,
+        columnNumber: 5
+      })
+    })
+
+    test('should set initiator even with empty stack (current call frames)', () => {
+      const requestDetail = new RequestDetail()
+
+      requestDetail.loadCallFrames('')
+
+      // loadCallFrames will always generate some call frames from the current stack
+      expect(requestDetail.initiator).toBeDefined()
+      expect(requestDetail.initiator?.type).toBe('script')
+      expect(requestDetail.initiator?.stack.callFrames).toBeDefined()
+    })
+  })
+
+  describe('isWebSocket', () => {
+    test('should return true for WebSocket requests with Upgrade header', () => {
+      const requestDetail = new RequestDetail()
+      requestDetail.requestHeaders = { Upgrade: 'websocket' }
+
+      expect(requestDetail.isWebSocket()).toBe(true)
+    })
+
+    test('should return true for WebSocket requests with lowercase upgrade header', () => {
+      const requestDetail = new RequestDetail()
+      requestDetail.requestHeaders = { upgrade: 'websocket' }
+
+      expect(requestDetail.isWebSocket()).toBe(true)
+    })
+
+    test('should return false for non-WebSocket requests', () => {
+      const requestDetail = new RequestDetail()
+      requestDetail.requestHeaders = { 'Content-Type': 'application/json' }
+
+      expect(requestDetail.isWebSocket()).toBe(false)
+    })
+
+    test('should return false when no headers are set', () => {
+      const requestDetail = new RequestDetail()
+
+      expect(requestDetail.isWebSocket()).toBe(false)
+    })
+  })
+
+  describe('isHiden', () => {
+    test('should return true for hidden localhost WebSocket requests', () => {
+      const requestDetail = new RequestDetail()
+      requestDetail.requestHeaders = { Upgrade: 'websocket' }
+      requestDetail.url = 'http://localhost/'
+
+      expect(requestDetail.isHiden()).toBe(true)
+    })
+
+    test('should return true for hidden localhost ws requests', () => {
+      const requestDetail = new RequestDetail()
+      requestDetail.requestHeaders = { Upgrade: 'websocket' }
+      requestDetail.url = 'ws://localhost/'
+
+      expect(requestDetail.isHiden()).toBe(true)
+    })
+
+    test('should return false for non-localhost WebSocket requests', () => {
+      const requestDetail = new RequestDetail()
+      requestDetail.requestHeaders = { Upgrade: 'websocket' }
+      requestDetail.url = 'wss://example.com/socket'
+
+      expect(requestDetail.isHiden()).toBe(false)
+    })
+
+    test('should return false for non-WebSocket requests', () => {
+      const requestDetail = new RequestDetail()
+      requestDetail.url = 'http://localhost/'
+
+      expect(requestDetail.isHiden()).toBe(false)
     })
   })
 })