Function buildIntegrationToolSchemasUncached

apps/sim/lib/copilot/chat/payload.ts:136–244

(
  userId: string,
  messageId: string | undefined,
  options: Required<BuildIntegrationToolSchemasOptions>,
  workspaceId?: string
)

}

async function buildIntegrationToolSchemasUncached(
  userId: string,
  messageId: string | undefined,
  options: Required<BuildIntegrationToolSchemasOptions>,
  workspaceId?: string
): Promise<ToolSchema[]> {
  const reqLogger = logger.withMetadata({ messageId })
  const integrationTools: ToolSchema[] = []
  try {
    const { createUserToolSchema } = await import('@/tools/params')
    let shouldAppendEmailTagline = false

    try {
      const subscription = await getHighestPrioritySubscription(userId)
      shouldAppendEmailTagline = !subscription || !isPaid(subscription.plan)
    } catch (error) {
      reqLogger.warn('Failed to load subscription for copilot tool descriptions', {
        userId,
        error: toError(error).message,
      })
    }

    let allowedIntegrations: Set<string> | null = null
    let toolIdToBlockType: Map<string, string> | null = null
    if (workspaceId) {
      try {
        const [{ getUserPermissionConfig }, { getAllBlocks }] = await Promise.all([
          import('@/ee/access-control/utils/permission-check'),
          import('@/blocks/registry'),
        ])
        const permissionConfig = await getUserPermissionConfig(userId, workspaceId)
        if (permissionConfig?.allowedIntegrations) {
          allowedIntegrations = new Set(
            permissionConfig.allowedIntegrations.map((i) => i.toLowerCase())
          )
          toolIdToBlockType = new Map()
          for (const blockConfig of getAllBlocks()) {
            const access = blockConfig.tools?.access
            if (!access) continue
            for (const toolId of access) {
              toolIdToBlockType.set(stripVersionSuffix(toolId), blockConfig.type.toLowerCase())
            }
          }
        }
      } catch (error) {
        reqLogger.warn('Failed to load permission config for tool schema filter', {
          userId,
          workspaceId,
          error: toError(error).message,
        })
      }
    }

    for (const { toolId, config: toolConfig, service } of getExposedIntegrationTools()) {
      try {
        if (allowedIntegrations && toolIdToBlockType) {
          const owningBlock = toolIdToBlockType.get(stripVersionSuffix(toolId))
          if (owningBlock && !allowedIntegrations.has(owningBlock)) {