im0o
6c8a1c4e0e
任务书承诺这些在分发前已存在。/traffic /logs 补进读白名单（在流式清单 里却不在读白名单里，仪表盘和请求页一开工就 403），PUT /providers/rules 补进写白名单（规则页的立刻更新）。web/stream.ts 把分块流缝成完整的行， 分块边界和行边界无关是它存在的全部理由；shared/format.ts 是连接页和 仪表盘共用的流量数字格式化。
34 lines
1.2 KiB
TypeScript
34 lines
1.2 KiB
TypeScript
/**
|
||
* 把持续吐数据的 HTTP 响应体读成一行一行。
|
||
*
|
||
* 内核的 /traffic、/memory、/logs 在没有 WebSocket 升级时退化成分块流，一行一个
|
||
* JSON。分块的边界和行的边界无关：一次 read 可能拿到半行，也可能拿到好几行。
|
||
* 这里把它们缝成完整的行再交出去，空行丢弃。
|
||
*
|
||
* 停止读取的方式是中止 fetch（AbortController）或 break 出循环，两种都会走到
|
||
* finally 里把流取消掉，不留悬着的连接。
|
||
*/
|
||
export async function* readLines(body: ReadableStream<Uint8Array>): AsyncGenerator<string> {
|
||
const reader = body.getReader()
|
||
const decoder = new TextDecoder()
|
||
let buffer = ''
|
||
try {
|
||
for (;;) {
|
||
const { done, value } = await reader.read()
|
||
if (done) break
|
||
buffer += decoder.decode(value, { stream: true })
|
||
const parts = buffer.split('\n')
|
||
// 最后一段可能是半行，留在缓冲里等下一块补齐
|
||
buffer = parts.pop() ?? ''
|
||
for (const part of parts) {
|
||
const line = part.endsWith('\r') ? part.slice(0, -1) : part
|
||
if (line) yield line
|
||
}
|
||
}
|
||
const rest = buffer.trim()
|
||
if (rest) yield rest
|
||
} finally {
|
||
await reader.cancel().catch(() => {})
|
||
}
|
||
}
|