LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-05-13 23:56:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: stop inferring agent scope from transcript paths

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-08 11:23:24 +01:00
parent 430f8b2b1a
commit d69fdeee2c
4 changed files with 6 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/agents/pi-embedded-runner/compaction-successor-transcript.ts
View File

@@ -123,13 +123,7 @@ export async function rotateTranscriptFileAfterCompaction(params: {
}
function resolveAgentIdFromTranscriptPath(transcriptPath: string): string {
const resolved = path.resolve(transcriptPath);
const sessionsDir = path.dirname(resolved);
const agentDir = path.dirname(sessionsDir);
const agentsDir = path.dirname(agentDir);
if (path.basename(sessionsDir) === "sessions" && path.basename(agentsDir) === "agents") {
return normalizeAgentId(path.basename(agentDir));
}
void transcriptPath;
return DEFAULT_AGENT_ID;
}

10
src/agents/transcript/session-manager.ts
View File

@@ -8,7 +8,7 @@ import {
replaceSqliteSessionTranscriptEvents,
resolveSqliteSessionTranscriptScopeForPath,
} from "../../config/sessions/transcript-store.sqlite.js";
import { DEFAULT_AGENT_ID, normalizeAgentId } from "../../routing/session-key.js";
import { DEFAULT_AGENT_ID } from "../../routing/session-key.js";
import type {
FileEntry,
SessionContext,
@@ -56,13 +56,7 @@ function resolveDefaultSessionDir(cwd: string): string {
}
function resolveAgentIdFromSessionPath(sessionFile: string): string {
const resolved = path.resolve(sessionFile);
const sessionsDir = path.dirname(resolved);
const agentDir = path.dirname(sessionsDir);
const agentsDir = path.dirname(agentDir);
if (path.basename(sessionsDir) === "sessions" && path.basename(agentsDir) === "agents") {
return normalizeAgentId(path.basename(agentDir));
}
void sessionFile;
return DEFAULT_AGENT_ID;
}

10
src/agents/transcript/transcript-state.ts
View File

@@ -6,7 +6,7 @@ import {
replaceSqliteSessionTranscriptEvents,
resolveSqliteSessionTranscriptScopeForPath,
} from "../../config/sessions/transcript-store.sqlite.js";
import { DEFAULT_AGENT_ID, normalizeAgentId } from "../../routing/session-key.js";
import { DEFAULT_AGENT_ID } from "../../routing/session-key.js";
import type {
FileEntry,
SessionContext,
@@ -49,13 +49,7 @@ function generateEntryId(byId: { has(id: string): boolean }): string {
}
function resolveAgentIdFromTranscriptPath(sessionFile: string): string {
const resolved = path.resolve(sessionFile);
const sessionsDir = path.dirname(resolved);
const agentDir = path.dirname(sessionsDir);
const agentsDir = path.dirname(agentDir);
if (path.basename(sessionsDir) === "sessions" && path.basename(agentsDir) === "agents") {
return normalizeAgentId(path.basename(agentDir));
}
void sessionFile;
return DEFAULT_AGENT_ID;
}

8
src/auto-reply/reply/session-transcript-replay.ts
View File

@@ -94,13 +94,7 @@ export async function replayRecentUserAssistantMessages(params: {
}
function resolveAgentIdFromSessionPath(sessionFile: string): string {
const resolved = path.resolve(sessionFile);
const sessionsDir = path.dirname(resolved);
const agentDir = path.dirname(sessionsDir);
const agentsDir = path.dirname(agentDir);
if (path.basename(sessionsDir) === "sessions" && path.basename(agentsDir) === "agents") {
return path.basename(agentDir);
}
void sessionFile;
return DEFAULT_AGENT_ID;
}