Function pullIntegrations

packages/cli/src/commands/integrations.ts:86–159

* Execute the integrations pull command.

(options: IntegrationsPullOptions)

 * Execute the integrations pull command.
 */
async function pullIntegrations(options: IntegrationsPullOptions): Promise<void> {
  const token = resolveToken(options)
  const baseUrl = options.url ?? DEFAULT_API_URL
  const filePath = options.file ?? DEFAULT_INTEGRATIONS_FILE
  const envFilePath = options.envFile ?? DEFAULT_ENV_FILE

  log(chalk.dim(`Fetching integrations from ${baseUrl}...`))

  // Fetch integrations from API
  const fetchedIntegrations = await fetchIntegrations(baseUrl, token)

  if (fetchedIntegrations.length === 0) {
    log(chalk.yellow('No integrations found in your workspace.'))
    return
  }

  log(chalk.dim(`Found ${fetchedIntegrations.length} integration(s).`))

  // Read existing document (if any) - preserves comments and formatting
  const existingDoc = await readIntegrationsDocument(filePath)
  debug(`Read existing document from ${filePath}: ${existingDoc ? 'found' : 'not found'}`)
  const doc = existingDoc ?? createNewDocument()

  // Merge API integrations into document and extract secrets
  const { secrets, stats, skipped } = mergeApiIntegrationsIntoDocument(doc, fetchedIntegrations)

  // Log any invalid or unsupported integrations that were skipped (debug mode only)
  for (const skippedIntegration of skipped) {
    debug(
      `Skipping invalid or unsupported integration "${skippedIntegration.name}" (${skippedIntegration.type}) [${skippedIntegration.id}]:`
    )
    for (const issue of skippedIntegration.issues) {
      debug(`  ${issue.code} [${issue.path.join('.')}]: ${issue.message}`)
    }
  }

  // Ensure schema comment is set
  if (doc.commentBefore == null || !doc.commentBefore.includes('yaml-language-server')) {
    doc.commentBefore = SCHEMA_COMMENT
  }

  const secretCount = Object.keys(secrets).length
  if (secretCount > 0) {
    debug(`Extracted ${secretCount} secret(s) to store in ${envFilePath}`)
  }

  // Write secrets to .env file
  if (secretCount > 0) {
    await updateDotEnv(envFilePath, secrets)
    log(chalk.dim(`Updated ${envFilePath} with ${secretCount} secret(s)`))
  }

  // Write YAML file (with comments and formatting preserved)
  await writeIntegrationsFile(filePath, doc)

  // Get final count of integrations in the document
  const finalIntegrations = doc.get('integrations')
  const finalCount = isSeq(finalIntegrations) ? finalIntegrations.items.length : 0