Function deleteManyFromS3

apps/sim/lib/uploads/providers/s3/client.ts:299–336

(
  keys: string[],
  customConfig?: S3Config
)

 * against the per-prefix DELETE rate limit (3500/sec).
 */
export async function deleteManyFromS3(
  keys: string[],
  customConfig?: S3Config
): Promise<{ failed: Array<{ key: string; error: string }> }> {
  const failed: Array<{ key: string; error: string }> = []
  if (keys.length === 0) return { failed }

  const config = customConfig || { bucket: S3_CONFIG.bucket, region: S3_CONFIG.region }
  const s3Client = getS3Client()

  for (let i = 0; i < keys.length; i += S3_DELETE_OBJECTS_MAX_KEYS) {
    const chunk = keys.slice(i, i + S3_DELETE_OBJECTS_MAX_KEYS)
    try {
      const response = await s3Client.send(
        new DeleteObjectsCommand({
          Bucket: config.bucket,
          Delete: {
            Objects: chunk.map((Key) => ({ Key })),
            Quiet: true,
          },
        })
      )
      for (const error of response.Errors ?? []) {
        if (error.Key) {
          failed.push({
            key: error.Key,
            error: error.Message ?? error.Code ?? 'unknown',
          })
        }
      }
    } catch (error) {
      const message = getErrorMessage(error)
      for (const Key of chunk) failed.push({ key: Key, error: message })
    }
  }

  return { failed }
}

/**
 * Initiate a multipart upload for S3