Function handleToolsCall

apps/sim/app/api/mcp/serve/[serverId]/route.ts:680–889

(
  id: RequestId,
  serverId: string,
  params: { name: string; arguments?: Record<string, unknown> } | undefined,
  executeAuthContext?: ExecuteAuthContext | null,
  publicServerOwnerId?: string,
  simViaHeader?: string | null,
  requestSignal?: AbortSignal
)

}

async function handleToolsCall(
  id: RequestId,
  serverId: string,
  params: { name: string; arguments?: Record<string, unknown> } | undefined,
  executeAuthContext?: ExecuteAuthContext | null,
  publicServerOwnerId?: string,
  simViaHeader?: string | null,
  requestSignal?: AbortSignal
): Promise<NextResponse> {
  let abortSignal: ManagedAbortSignal | null = null
  try {
    if (!params?.name) {
      return NextResponse.json(createError(id, ErrorCode.InvalidParams, 'Tool name required'), {
        status: 400,
      })
    }
    abortSignal = createManagedAbortSignal(
      requestSignal ?? new AbortController().signal,
      getMaxExecutionTimeout()
    )
    const abortedBeforeToolLookup = callerAbortedJsonRpcResponse(id, abortSignal)
    if (abortedBeforeToolLookup) return abortedBeforeToolLookup

    const matchingTools = await db
      .select({
        toolName: workflowMcpTool.toolName,
        workflowId: workflowMcpTool.workflowId,
      })
      .from(workflowMcpTool)
      .where(
        and(
          eq(workflowMcpTool.serverId, serverId),
          eq(workflowMcpTool.toolName, params.name),
          isNull(workflowMcpTool.archivedAt)
        )
      )
      .orderBy(asc(workflowMcpTool.id))
      .limit(2)
    const abortedAfterToolLookup = callerAbortedJsonRpcResponse(id, abortSignal)
    if (abortedAfterToolLookup) return abortedAfterToolLookup
    if (matchingTools.length > 1) {
      return NextResponse.json(
        createError(id, ErrorCode.InvalidRequest, `Duplicate tool name: ${params.name}`, {
          code: 'duplicate_tool_name',
          toolName: params.name,
          recovery: 'Rename or remove duplicate workflow MCP tools before calling this tool',
        }),
        { status: 409 }
      )
    }
    const [tool] = matchingTools
    if (!tool) {
      return NextResponse.json(
        createError(id, ErrorCode.InvalidParams, `Tool not found: ${params.name}`),
        {
          status: 404,
        }
      )