lee/rea
1
0 Fork 0
mirror of https://github.com/morluto/rea.git synced 2026-10-23 15:12:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(gdb): own command record snapshots and stream groups

Browse Source
This commit is contained in:
morluto committed 2026-10-22 08:40:36 +08:00
1 parent 2604059961
commit 1fbfbf74ef
2 files changed
+22 -63
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

src/gdb/GdbCommandRecords.ts
+10
View File
@@ -0,0 +1,10 @@
/** Snapshot ordered MI records and retain their raw stream encodings. */
export const snapshotGdbCommandRecords = (records: readonly string[]) => {
const snapshot = [...records];
return {
records: snapshot,
console: snapshot.filter((line) => line.startsWith("~")).join("\n"),
target: snapshot.filter((line) => line.startsWith("@")).join("\n"),
log: snapshot.filter((line) => line.startsWith("&")).join("\n"),
};
};
src/gdb/GdbSessionManager.ts
+12 -63
View File
@@ -1,3 +1,4 @@
import { snapshotGdbCommandRecords } from "./GdbCommandRecords.js";
import { randomUUID } from "node:crypto";
import { constants as fsConstants } from "node:fs";
import { isUtf8 } from "node:buffer";
@@ -958,16 +959,7 @@ export class GdbSessionManager {
? {
command: "GDB startup",
mi: "",
records: [...session.lines],
console: session.lines
.filter((line) => line.startsWith("~"))
.join("\n"),
target: session.lines
.filter((line) => line.startsWith("@"))
.join("\n"),
log: session.lines
.filter((line) => line.startsWith("&"))
.join("\n"),
...snapshotGdbCommandRecords(session.lines),
process_exit_observed: true,
process_exit_code: session.exitCode,
process_exit_signal: session.exitSignal,
@@ -981,16 +973,7 @@ export class GdbSessionManager {
? {
command: "GDB startup",
mi: "",
records: [...session.lines],
console: session.lines
.filter((line) => line.startsWith("~"))
.join("\n"),
target: session.lines
.filter((line) => line.startsWith("@"))
.join("\n"),
log: session.lines
.filter((line) => line.startsWith("&"))
.join("\n"),
...snapshotGdbCommandRecords(session.lines),
output_truncated: session.recentRecordsTruncated,
completion_status: "unknown" as const,
}
@@ -1641,18 +1624,11 @@ export class GdbSessionManager {
clearTimeout(pending.timer);
session.pending.delete(token);
pending.cleanup();
const records = [...pending.lines];
pending.resolve({
command: "",
mi: pending.terminalRecord ?? "",
records,
console: records
.filter((record) => record.startsWith("~"))
.join("\n"),
target: records
.filter((record) => record.startsWith("@"))
.join("\n"),
log: records.filter((record) => record.startsWith("&")).join("\n"),
...snapshotGdbCommandRecords(pending.lines),
output_truncated: pending.outputTruncated,
...(pending.outputInvalidUtf8
? { output_invalid_utf8: true as const }
@@ -1677,14 +1653,11 @@ export class GdbSessionManager {
clearTimeout(pending.timer);
session.pending.delete(token);
pending.cleanup();
const records = [...pending.lines];
pending.resolve({
command: "",
mi: line,
records,
console: records.filter((record) => record.startsWith("~")).join("\n"),
target: records.filter((record) => record.startsWith("@")).join("\n"),
log: records.filter((record) => record.startsWith("&")).join("\n"),
...snapshotGdbCommandRecords(pending.lines),
output_truncated: pending.outputTruncated,
...(pending.outputInvalidUtf8
? { output_invalid_utf8: true as const }
@@ -1723,15 +1696,12 @@ export class GdbSessionManager {
for (const pending of session.pending.values()) {
clearTimeout(pending.timer);
pending.cleanup();
const records = [...pending.lines];
pending.reject(
new GdbProtocolFailureError(message, {
command: pending.command,
mi: "",
records,
console: records.filter((line) => line.startsWith("~")).join("\n"),
target: records.filter((line) => line.startsWith("@")).join("\n"),
log: records.filter((line) => line.startsWith("&")).join("\n"),
...snapshotGdbCommandRecords(pending.lines),
output_truncated: pending.outputTruncated,
...(pending.outputInvalidUtf8
? { output_invalid_utf8: true as const }
@@ -1915,14 +1885,7 @@ export class GdbSessionManager {
new GdbCommandProcessExitError({
command: pending.command,
mi: "",
records: [...pending.lines],
console: pending.lines
.filter((line) => line.startsWith("~"))
.join("\n"),
target: pending.lines
.filter((line) => line.startsWith("@"))
.join("\n"),
log: pending.lines.filter((line) => line.startsWith("&")).join("\n"),
...snapshotGdbCommandRecords(pending.lines),
process_exit_observed: true,
process_exit_code: code,
process_exit_signal: signalCode,
@@ -1991,14 +1954,7 @@ export class GdbSessionManager {
const partial: GdbCommandResult = {
command: pending.evidenceCommand,
mi: "",
records: [...pending.lines],
console: pending.lines
.filter((line) => line.startsWith("~"))
.join("\n"),
target: pending.lines
.filter((line) => line.startsWith("@"))
.join("\n"),
log: pending.lines.filter((line) => line.startsWith("&")).join("\n"),
...snapshotGdbCommandRecords(pending.lines),
output_truncated: pending.outputTruncated,
...(pending.outputInvalidUtf8
? { output_invalid_utf8: true as const }
@@ -2122,14 +2078,7 @@ export class GdbSessionManager {
const partial: GdbCommandResult = {
command: pending.evidenceCommand,
mi: "",
records: [...pending.lines],
console: pending.lines
.filter((line) => line.startsWith("~"))
.join("\n"),
target: pending.lines
.filter((line) => line.startsWith("@"))
.join("\n"),
log: pending.lines.filter((line) => line.startsWith("&")).join("\n"),
...snapshotGdbCommandRecords(pending.lines),
output_truncated: pending.outputTruncated,
...(pending.outputInvalidUtf8
? { output_invalid_utf8: true as const }