Function dispatchToolMessage

lib/services/cli/codex.ts:350–426

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

  Buffer.from(value, 'utf-8').toString('base64');

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

  const { messageType = 'tool_use', persist = true, isStreaming = false, streamedToolHashes } = options;

  // Enhanced duplicate detection for tool messages
  const toolHash = encodeHash(`${messageType}:${trimmedContent}:${JSON.stringify(metadata)}`).substring(0, 16);
  if (streamedToolHashes?.has(toolHash)) {
    console.debug(`[CodexService] Tool message already processed (hash: ${toolHash}), skipping`);
    return;
  }

  const enrichedMetadata: Record<string, unknown> = {
    cli_type: 'codex',
    ...(metadata ?? {}),
  };
  const snakeToolName = typeof enrichedMetadata['tool_name'] === 'string' ? (enrichedMetadata['tool_name'] as string) : undefined;
  const camelToolName = typeof enrichedMetadata['toolName'] === 'string' ? (enrichedMetadata['toolName'] as string) : undefined;
  if (!camelToolName && snakeToolName) {
    enrichedMetadata['toolName'] = snakeToolName;
  }
  if (!snakeToolName && camelToolName) {
    enrichedMetadata['tool_name'] = camelToolName;
  }

  if (streamedToolHashes) {
    streamedToolHashes.add(toolHash);
  }

  if (!persist) {
    const transientMetadata = {
      ...enrichedMetadata,
      isTransientToolMessage: true,
    };
    const realtime = createRealtimeMessage({
      projectId,
      role: 'tool',
      messageType,
      content: trimmedContent,
      metadata: transientMetadata,
      cliSource: 'codex',
      requestId,
      isStreaming,
      isFinal: !isStreaming,