Function completeEnvelopeFromTranscript

src/host/transcript.ts:296–361

(
  envelope: MemxTurnEnvelope,
  pending?: MemxTurnEnvelope | null,
  options: { timeoutMs?: number; intervalMs?: number } = {},
)

}

export async function completeEnvelopeFromTranscript(
  envelope: MemxTurnEnvelope,
  pending?: MemxTurnEnvelope | null,
  options: { timeoutMs?: number; intervalMs?: number } = {},
): Promise<MemxTurnEnvelope> {
  if (envelope.messages.some((message) => message.role === "assistant" && message.content.trim())) {
    return envelope;
  }
  const expectedUserText = [...(pending?.messages ?? [])]
    .reverse()
    .find((message) => message.role === "user" && message.content.trim())?.content;
  const transcriptPath =
    envelope.metadata && typeof envelope.metadata.transcriptPath === "string"
      ? envelope.metadata.transcriptPath
      : pending?.metadata && typeof pending.metadata.transcriptPath === "string"
        ? pending.metadata.transcriptPath
      : undefined;
  const timeoutMs = parsePositiveInt(
    options.timeoutMs !== undefined
      ? String(options.timeoutMs)
      : process.env["MEMX_TRANSCRIPT_CAPTURE_TIMEOUT_MS"],
    MEMX_TRANSCRIPT_CAPTURE_TIMEOUT_MS,
  );
  const intervalMs = parsePositiveInt(
    options.intervalMs !== undefined
      ? String(options.intervalMs)
      : process.env["MEMX_TRANSCRIPT_CAPTURE_INTERVAL_MS"],
    MEMX_TRANSCRIPT_CAPTURE_INTERVAL_MS,
  );
  const startedAt = Date.now();
  let capture: TranscriptAssistantCapture | null = null;
  do {
    capture = await extractAssistantFromTranscript({
      hostId: envelope.hostId,
      transcriptPath,
      sessionId: envelope.sessionId,
      expectedUserText,
    });
    if (capture || timeoutMs === 0) {
      break;
    }
    const remainingMs = timeoutMs - (Date.now() - startedAt);
    if (remainingMs <= 0) {
      break;
    }
    await sleep(Math.min(intervalMs, remainingMs));
  } while (Date.now() - startedAt <= timeoutMs);
  if (!capture) {
    return {
      ...envelope,
      metadata: {
        ...(envelope.metadata ?? {}),
        transcriptAssistantCapture: "missing",
      },
    };
  }
  return {
    ...envelope,