add default limit of 200,000 objects max for empty bucket

Author: itslenny

src/config.ts

@@ -97,6 +97,7 @@ type StorageConfigType = {
   responseSMaxAge: number
   anonKeyAsync: Promise<string>
   serviceKeyAsync: Promise<string>
+  emptyBucketMax: number
   storageBackendType: StorageBackendType
   tenantId: string
   requestUrlLengthLimit: number
@@ -311,6 +312,10 @@ export function getConfig(options?: { reload?: boolean }): StorageConfigType {
     ),
     // Storage
     storageBackendType: getOptionalConfigFromEnv('STORAGE_BACKEND') as StorageBackendType,
+    emptyBucketMax: parseInt(
+      getOptionalConfigFromEnv('STORAGE_EMPTY_BUCKET_MAX') || '200000',
+      10
+    ),
 
     // Storage - File
     storageFilePath: getOptionalConfigFromEnv(

src/internal/errors/codes.ts

@@ -49,6 +49,14 @@ export const ERRORS = {
       message: `The bucket you tried to delete is not empty`,
       originalError: e,
     }),
+  UnableToEmptyBucket: (bucket: string, e?: Error) =>
+    new StorageBackendError({
+      code: ErrorCode.InvalidRequest,
+      resource: bucket,
+      httpStatusCode: 409,
+      message: `Unable to empty the bucket because it contains too many objects`,
+      originalError: e,
+    }),
   NoSuchBucket: (bucket: string, e?: Error) =>
     new StorageBackendError({
       code: ErrorCode.NoSuchBucket,

src/storage/storage.ts

@@ -8,7 +8,7 @@ import { ObjectStorage } from './object'
 import { InfoRenderer } from '@storage/renderer/info'
 import { ObjectAdminDeleteBatch } from './events'
 
-const { requestUrlLengthLimit } = getConfig()
+const { requestUrlLengthLimit, emptyBucketMax } = getConfig()
 
 /**
  * Storage
@@ -182,6 +182,11 @@ export class Storage {
   async emptyBucket(bucketId: string) {
     await this.findBucket(bucketId, 'name')
 
+    const count = await this.countObjects(bucketId)
+    if (count > emptyBucketMax) {
+      throw ERRORS.UnableToEmptyBucket(bucketId)
+    }
+
     while (true) {
       const objects = await this.db.listObjects(
         bucketId,