Function invokeRegisteredTool

src/utils/tool-registry.ts:250–295

(
  toolName: string,
  toolModule: ImportedToolModule,
  args: unknown,
)

}

async function invokeRegisteredTool(
  toolName: string,
  toolModule: ImportedToolModule,
  args: unknown,
): Promise<ToolResponse> {
  const startedAt = Date.now();

  try {
    const session = createRenderSession('text', { outputStyle: 'minimal' });
    const ctx: ToolHandlerContext = {
      emit: (fragment) => {
        session.emit(fragment);
      },
      attach: session.attach,
    };
    await toolModule.handler(args as Record<string, unknown>, ctx);

    if (ctx.structuredOutput) {
      session.setStructuredOutput?.(ctx.structuredOutput);
    }

    const catalog = registryState.catalog;
    const catalogTool = catalog?.getByMcpName(toolName);
    if (catalog && catalogTool) {
      postProcessSession({
        tool: catalogTool,
        session,
        ctx,
        catalog,
        runtime: 'mcp',
      });
    }

    const response = sessionToToolResponse(session);
    recordMcpInvocation(toolName, startedAt, 'completed');
    return response;
  } catch (error) {
    recordInternalErrorMetric({
      component: 'mcp-tool-registry',
      runtime: 'mcp',
      errorKind: error instanceof Error ? error.name || 'Error' : typeof error,
    });
    recordMcpInvocation(toolName, startedAt, 'infra_error');
    throw error;
  }
}

function registerToolFromManifest(
  toolManifest: ToolManifestEntry,