Function persistToolMessage

lib/services/cli/glm.ts:184–227

(
  projectId: string,
  content: string,
  metadata: Record<string, unknown>,
  requestId?: string,
  options: { persist?: boolean; isStreaming?: boolean; messageType?: 'tool_use' | 'tool_result' } = {},
)

}

async function persistToolMessage(
  projectId: string,
  content: string,
  metadata: Record<string, unknown>,
  requestId?: string,
  options: { persist?: boolean; isStreaming?: boolean; messageType?: 'tool_use' | 'tool_result' } = {},
) {
  const trimmed = content.trim();
  if (!trimmed) return;

  const { persist = true, isStreaming = false, messageType = 'tool_use' } = options;
  const enrichedMetadata: Record<string, unknown> = {
    cli_type: 'glm',
    ...metadata,
  };

  if (!persist) {
    const realtime = createRealtimeMessage({
      projectId,
      role: 'tool',
      messageType,
      content: trimmed,
      metadata: enrichedMetadata,
      cliSource: 'glm',
      requestId,
      isStreaming,
      isFinal: !isStreaming,
    });
    streamManager.publish(projectId, { type: 'message', data: realtime });
    return;
  }

  await persistAssistantMessage(
    projectId,
    {
      role: 'tool',
      messageType,
      content: trimmed,
      metadata: enrichedMetadata,
    },
    requestId,
    { isStreaming, isFinal: !isStreaming },
  );
}

function createStreamAccumulator(requestId?: string): StreamAccumulator {
  return {