32 lines
1.2 KiB
TypeScript
32 lines
1.2 KiB
TypeScript
|
import type { OpencodeClient } from "./types"
|
||
|
|
import type { SessionMessage } from "./executor-types"
|
||
|
|
|
||
|
|
export async function fetchSyncResult(
|
||
|
|
client: OpencodeClient,
|
||
|
|
sessionID: string
|
||
|
|
): Promise<{ ok: true; textContent: string } | { ok: false; error: string }> {
|
||
|
|
const messagesResult = await client.session.messages({
|
||
|
|
path: { id: sessionID },
|
||
|
|
})
|
||
|
|
|
||
|
|
if ((messagesResult as { error?: unknown }).error) {
|
||
|
|
return { ok: false, error: `Error fetching result: ${(messagesResult as { error: unknown }).error}\n\nSession ID: ${sessionID}` }
|
||
|
|
}
|
||
|
|
|
||
|
|
const messages = ((messagesResult as { data?: unknown }).data ?? messagesResult) as SessionMessage[]
|
||
|
|
|
||
|
|
const assistantMessages = messages
|
||
|
|
.filter((m) => m.info?.role === "assistant")
|
||
|
|
.sort((a, b) => (b.info?.time?.created ?? 0) - (a.info?.time?.created ?? 0))
|
||
|
|
const lastMessage = assistantMessages[0]
|
||
|
|
|
||
|
|
if (!lastMessage) {
|
||
|
|
return { ok: false, error: `No assistant response found.\n\nSession ID: ${sessionID}` }
|
||
|
|
}
|
||
|
|
|
||
|
|
const textParts = lastMessage?.parts?.filter((p) => p.type === "text" || p.type === "reasoning") ?? []
|
||
|
|
const textContent = textParts.map((p) => p.text ?? "").filter(Boolean).join("\n")
|
||
|
|
|
||
|
|
return { ok: true, textContent }
|
||
|
|
}
|