Transport.js
2.19 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
/**
* Transport - 传输层抽象基类
*
* 定义传输层接口，所有传输实现（子进程、WebSocket等）都需要实现这个接口。
*/
const { EventEmitter } = require('events');
/**
* 传输层基类
*
* Events:
* - 'message': 收到结构化 JSON 消息
* - 'output': 收到非 JSON 文本输出
* - 'stderr': 收到标准错误输出
* - 'error': 发生错误
* - 'close': 连接关闭
*/
class Transport extends EventEmitter {
constructor() {
super();
this.buffer = '';
}
/**
* 处理接收到的原始数据（NDJSON 缓冲分包）
* 子类在收到数据时调用此方法，自动解析 JSON 行并发出对应事件。
* @param {string|Buffer} chunk - 原始数据块
* @protected
*/
_handleData(chunk) {
this.buffer += chunk.toString();
// 按换行符分割 (支持 \r\n 和 \n)
const lines = this.buffer.split(/\r?\n/);
// 保留不完整的行
this.buffer = lines.pop() || '';
for (const line of lines) {
if (!line.trim()) continue;
// 处理 Bridge 转发的 stderr
if (line.trim().startsWith('{')) {
try {
const msg = JSON.parse(line);
if (msg._stderr !== undefined) {
this.emit('stderr', msg._stderr);
continue;
}
this.emit('message', msg);
} catch (e) {
this.emit('output', line);
}
} else {
this.emit('output', line);
}
}
}
/**
* 建立连接
* @param {string} command - 命令
* @param {string[]} args - 参数列表
* @param {object} options - 选项
* @returns {Promise<void>}
*/
async connect(command, args, options = {}) {
throw new Error('Transport.connect() must be implemented');
}
/**
* 发送消息
* @param {object} msg - 要发送的消息对象
*/
send(msg) {
throw new Error('Transport.send() must be implemented');
}
/**
* 关闭连接
*/
close() {
throw new Error('Transport.close() must be implemented');
}
/**
* 检查是否已连接
* @returns {boolean}
*/
get isConnected() {
throw new Error('Transport.isConnected getter must be implemented');
}
}
module.exports = { Transport };