github/openclaw
1
1
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-02-19 18:39:20 -05:00
Code Issues Packages Projects Releases Wiki Activity

refactor(gateway): share transcript path/fd helpers

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-18 18:35:04 +00:00
parent 37143cf70c
commit 079bf25fee
1 changed files with 29 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
src/gateway/session-utils.fs.ts
View File

@@ -423,27 +423,21 @@ function extractFirstUserMessageFromTranscriptChunk(
return null;
}
export function readFirstUserMessageFromTranscript(
function findExistingTranscriptPath(
sessionId: string,
storePath: string | undefined,
sessionFile?: string,
agentId?: string,
opts?: { includeInterSession?: boolean },
): string | null {
const candidates = resolveSessionTranscriptCandidates(sessionId, storePath, sessionFile, agentId);
const filePath = candidates.find((p) => fs.existsSync(p));
if (!filePath) {
return null;
}
return candidates.find((p) => fs.existsSync(p)) ?? null;
}
function withOpenTranscriptFd<T>(filePath: string, read: (fd: number) => T | null): T | null {
let fd: number | null = null;
try {
fd = fs.openSync(filePath, "r");
const chunk = readTranscriptHeadChunk(fd);
if (!chunk) {
return null;
}
return extractFirstUserMessageFromTranscriptChunk(chunk, opts);
return read(fd);
} catch {
// file read error
} finally {
@@ -454,6 +448,27 @@ export function readFirstUserMessageFromTranscript(
return null;
}
export function readFirstUserMessageFromTranscript(
sessionId: string,
storePath: string | undefined,
sessionFile?: string,
agentId?: string,
opts?: { includeInterSession?: boolean },
): string | null {
const filePath = findExistingTranscriptPath(sessionId, storePath, sessionFile, agentId);
if (!filePath) {
return null;
}
return withOpenTranscriptFd(filePath, (fd) => {
const chunk = readTranscriptHeadChunk(fd);
if (!chunk) {
return null;
}
return extractFirstUserMessageFromTranscriptChunk(chunk, opts);
});
}
const LAST_MSG_MAX_BYTES = 16384;
const LAST_MSG_MAX_LINES = 20;
@@ -495,29 +510,19 @@ export function readLastMessagePreviewFromTranscript(
sessionFile?: string,
agentId?: string,
): string | null {
const candidates = resolveSessionTranscriptCandidates(sessionId, storePath, sessionFile, agentId);
const filePath = candidates.find((p) => fs.existsSync(p));
const filePath = findExistingTranscriptPath(sessionId, storePath, sessionFile, agentId);
if (!filePath) {
return null;
}
let fd: number | null = null;
try {
fd = fs.openSync(filePath, "r");
return withOpenTranscriptFd(filePath, (fd) => {
const stat = fs.fstatSync(fd);
const size = stat.size;
if (size === 0) {
return null;
}
return readLastMessagePreviewFromOpenTranscript({ fd, size });
} catch {
// file error
} finally {
if (fd !== null) {
fs.closeSync(fd);
}
}
return null;
});
}
const PREVIEW_READ_SIZES = [64 * 1024, 256 * 1024, 1024 * 1024];