ros/automaker
1
0
Fork 0
mirror of https://github.com/AutoMaker-Org/automaker.git synced 2026-02-05 09:33:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix storage for long term

Browse Source
This commit is contained in:
SuperComboGamer
2025-12-14 13:24:11 -05:00
parent 038caeb2a0
commit 999ed5b51b
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
apps/server/src/services/agent-service.ts
View File

@@ -46,6 +46,7 @@ interface SessionMetadata {
archived?: boolean; archived?: boolean;
tags?: string[]; tags?: string[];
model?: string; model?: string;
sdkSessionId?: string; // Claude SDK session ID for conversation continuity
} }
export class AgentService { export class AgentService {
@@ -76,11 +77,15 @@ export class AgentService {
}) { }) {
if (!this.sessions.has(sessionId)) { if (!this.sessions.has(sessionId)) {
const messages = await this.loadSession(sessionId); const messages = await this.loadSession(sessionId);
const metadata = await this.loadMetadata();
const sessionMetadata = metadata[sessionId];
this.sessions.set(sessionId, { this.sessions.set(sessionId, {
messages, messages,
isRunning: false, isRunning: false,
abortController: null, abortController: null,
workingDirectory: workingDirectory || process.cwd(), workingDirectory: workingDirectory || process.cwd(),
sdkSessionId: sessionMetadata?.sdkSessionId, // Load persisted SDK session ID
}); });
} }
@@ -223,12 +228,14 @@ export class AgentService {
const toolUses: Array<{ name: string; input: unknown }> = []; const toolUses: Array<{ name: string; input: unknown }> = [];
for await (const msg of stream) { for await (const msg of stream) {
// Capture SDK session ID from any message // Capture SDK session ID from any message and persist it
if (msg.session_id && !session.sdkSessionId) { if (msg.session_id && !session.sdkSessionId) {
session.sdkSessionId = msg.session_id; session.sdkSessionId = msg.session_id;
console.log( console.log(
`[AgentService] Captured SDK session ID: ${msg.session_id}` `[AgentService] Captured SDK session ID: ${msg.session_id}`
); );
// Persist the SDK session ID to ensure conversation continuity across server restarts
await this.updateSession(sessionId, { sdkSessionId: msg.session_id });
} }
if (msg.type === "assistant") { if (msg.type === "assistant") {