Function deleteFiles

apps/sim/lib/uploads/core/storage-service.ts:470–502

(
  keys: string[],
  context: StorageContext
)

 * share `context`. Idempotent on missing keys.
 */
export async function deleteFiles(
  keys: string[],
  context: StorageContext
): Promise<{ deleted: number; failed: Array<{ key: string; error: string }> }> {
  if (keys.length === 0) return { deleted: 0, failed: [] }

  const config = getStorageConfig(context)

  if (USE_S3_STORAGE) {
    const { deleteManyFromS3 } = await import('@/lib/uploads/providers/s3/client')
    const { failed } = await deleteManyFromS3(keys, createS3Config(config))
    return { deleted: keys.length - failed.length, failed }
  }

  const failed: Array<{ key: string; error: string }> = []
  let cursor = 0
  const runWorker = async (): Promise<void> => {
    while (cursor < keys.length) {
      const idx = cursor++
      const key = keys[idx]
      try {
        await deleteFile({ key, context })
      } catch (error) {
        failed.push({ key, error: getErrorMessage(error) })
      }
    }
  }

  const workerCount = Math.min(PER_FILE_DELETE_CONCURRENCY, keys.length)
  await Promise.all(Array.from({ length: workerCount }, runWorker))

  return { deleted: keys.length - failed.length, failed }
}

/**
 * Check whether an object exists in the configured cloud storage provider.