Add bucket quota apis

.github/actions/setup-smithy/action.yml

@@ -6,9 +6,11 @@ runs:
   steps:
     - name: Install Smithy CLI
       shell: bash
-      env:
-        SMITHY_VERSION: '1.61.0'
       run: |
+        # Extract Smithy version from smithy-build.json
+        SMITHY_VERSION=$(jq -r '.maven.dependencies[] | select(contains("smithy-aws-traits")) | split(":")[2]' smithy-build.json)
+        echo "Installing Smithy CLI version ${SMITHY_VERSION}"
+        
         mkdir -p smithy-install/smithy
         curl -L https://github.com/smithy-lang/smithy/releases/download/${SMITHY_VERSION}/smithy-cli-linux-x86_64.zip -o smithy-install/smithy-cli-linux-x86_64.zip
         unzip -qo smithy-install/smithy-cli-linux-x86_64.zip -d smithy-install

.github/docker-compose.cloudserver-metadata.yml

@@ -7,7 +7,7 @@ services:
       - ./md-config.json:/mnt/standalone_workdir/config.json:ro
 
   cloudserver-metadata:
-    image: ghcr.io/scality/cloudserver:9.1.4
+    image: ghcr.io/scality/cloudserver:9.3.0-preview.1
     platform: linux/amd64
     network_mode: 'host'
     environment:

.github/docker-compose.cloudserver-mongo.yml

@@ -24,7 +24,7 @@ services:
     restart: "no"
 
   cloudserver:
-    image: ghcr.io/scality/cloudserver:9.1.4
+    image: ghcr.io/scality/cloudserver:9.3.0-preview.1
     platform: linux/amd64
     ports:
       - "8000:8000"

examples/bucketQuota.ts

@@ -0,0 +1,47 @@
+import {
+    BucketQuotaClient,
+    CloudserverBucketQuotaClientConfig,
+    GetBucketQuotaCommand
+} from '@scality/cloudserverclient/clients/bucketQuota';
+
+const config: CloudserverBucketQuotaClientConfig = {
+    endpoint: 'http://localhost:8000',
+    credentials: {
+        accessKeyId: 'accessKey1',
+        secretAccessKey: 'verySecretKey1',
+    },
+    region: 'us-east-1',
+    maxAttempts: 1,
+};
+
+const bucketQuotaClient = new BucketQuotaClient(config);
+try {
+    const getBucketQuotaCommand = new GetBucketQuotaCommand({
+        Bucket: 'aBucketName',
+    });
+
+    const quotaData = await bucketQuotaClient.send(getBucketQuotaCommand);
+    // {
+    //     "$metadata": {
+    //         "httpStatusCode": 200,
+    //         "requestId": "aa0681fd844c9a2272fa",
+    //         "extendedRequestId": "aa0681fd844c9a2272fa",
+    //         "attempts": 1,
+    //         "totalRetryDelay": 0
+    //     },
+    //     "Name": "aBucketName",
+    //     "Quota": 42
+    // }
+} catch (error: any) {
+    console.error(error.name); // NoSuchBucket
+    console.error(error.message); // The specified bucket does not exist.
+    // {
+    //     httpStatusCode: 404,
+    //     requestId: "0caf000bc140bb9e62e9",
+    //     extendedRequestId: "0caf000bc140bb9e62e9",
+    //     cfId: undefined,
+    //     attempts: 1,
+    //     totalRetryDelay: 0,
+    // }
+    console.error(error.$metadata);
+}

examples/cloudserverClient.ts

@@ -0,0 +1,27 @@
+// cloudserverClient is a meta client that imports all other clients.
+// In this library, you can either use individual clients (like BackbeatRoutesClient or BucketQuotaClient),
+// or use this global client.
+
+import { 
+    CloudserverClient, 
+    CloudserverClientConfig,
+    GetObjectCommand 
+} from '@scality/cloudserverclient';
+
+const command = new GetObjectCommand({
+    Bucket: 'aBucketName',
+    Key: 'anObjectKey',
+});
+
+const config: CloudserverClientConfig = {
+    endpoint: 'http://localhost:8000',
+    credentials: {
+        accessKeyId: 'accessKey1',
+        secretAccessKey: 'verySecretKey1',
+    },
+    region: 'us-east-1',
+};
+const client = new CloudserverClient(config);
+
+const getData = await client.backbeatRoutes.send(command);
+const bodyStr = await getData.Body.transformToString();

models/batchDelete.smithy → models/backbeatRoutes/batchDelete.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @idempotent
 @http(method: "POST", uri: "/_/backbeat/batchdelete/{Bucket}/{Key+}")

models/commonStructures.smithy → models/backbeatRoutes/commonStructures.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Streaming blob type for binary data transfer
 @streaming

models/deleteBucketIndexes.smithy → models/backbeatRoutes/deleteBucketIndexes.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @http(method: "POST", uri: "/_/backbeat/index/{Bucket}?operation=delete")
 @idempotent

models/deleteObjectFromExpiration.smithy → models/backbeatRoutes/deleteObjectFromExpiration.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @idempotent
 @http(method: "DELETE", uri: "/_/backbeat/expiration/{Bucket}/{Key+}")

models/getBucketCseq.smithy → models/backbeatRoutes/getBucketCseq.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Retrieves bucket sequence information
 @readonly

models/getBucketIndexes.smithy → models/backbeatRoutes/getBucketIndexes.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @readonly
 @http(method: "GET", uri: "/_/backbeat/index/{Bucket}")

models/getBucketMetadata.smithy → models/backbeatRoutes/getBucketMetadata.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @readonly
 @http(method: "GET", uri: "/_/metadata/default/attributes/{Bucket}")

models/getMetadata.smithy → models/backbeatRoutes/getMetadata.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @http(method: "GET", uri: "/_/backbeat/metadata/{Bucket}/{Key+}")
 @readonly

models/getObject.smithy → models/backbeatRoutes/getObject.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @readonly
 @http(method: "GET", uri: "/{Bucket}/{Key+}", code: 200)

models/getObjectList.smithy → models/backbeatRoutes/getObjectList.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @readonly
 @http(method: "GET", uri: "/_/metadata/default/bucket/{Bucket}")

models/getRaftBuckets.smithy → models/backbeatRoutes/getRaftBuckets.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Retrieves buckets associated with a specific Raft log ID
 @readonly

models/getRaftId.smithy → models/backbeatRoutes/getRaftId.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @readonly
 @http(method: "GET", uri: "/_/metadata/admin/buckets/{Bucket}/id")

models/getRaftLog.smithy → models/backbeatRoutes/getRaftLog.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Retrieves Raft log entries for a specific log ID
 @readonly

models/listLifecycleCurrents.smithy → models/backbeatRoutes/listLifecycleCurrents.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// List lifecycle current objects operation
 @readonly

models/listLifecycleNonCurrents.smithy → models/backbeatRoutes/listLifecycleNonCurrents.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// List lifecycle non-current objects operation
 @readonly

models/listLifecycleOrphans.smithy → models/backbeatRoutes/listLifecycleOrphans.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// List lifecycle orphan objects operation
 @readonly

models/multipleBackendAbortMPU.smithy → models/backbeatRoutes/multipleBackendAbortMPU.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Aborts a multipart upload for multiple backend storage
 @idempotent

models/multipleBackendCompleteMPU.smithy → models/backbeatRoutes/multipleBackendCompleteMPU.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Completes a multipart upload for multiple backend storage
 @http(method: "POST", uri: "/_/backbeat/multiplebackenddata/{Bucket}/{Key+}?operation=completempu")

models/multipleBackendDeleteObject.smithy → models/backbeatRoutes/multipleBackendDeleteObject.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @idempotent
 @http(method: "DELETE", uri: "/_/backbeat/multiplebackenddata/{Bucket}/{Key+}?operation=deleteobject", code: 200)

models/multipleBackendDeleteObjectTagging.smithy → models/backbeatRoutes/multipleBackendDeleteObjectTagging.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Removes tags from an object in multiple backend storage
 @idempotent

models/multipleBackendHeadObject.smithy → models/backbeatRoutes/multipleBackendHeadObject.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Retrieves metadata for an object from multiple backend storage
 @readonly

models/multipleBackendInitiateMPU.smithy → models/backbeatRoutes/multipleBackendInitiateMPU.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Initiates a multipart upload for multiple backend storage
 @http(method: "POST", uri: "/_/backbeat/multiplebackenddata/{Bucket}/{Key+}?operation=initiatempu")

models/multipleBackendPutMPUPart.smithy → models/backbeatRoutes/multipleBackendPutMPUPart.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 use aws.auth#unsignedPayload
 

models/multipleBackendPutObject.smithy → models/backbeatRoutes/multipleBackendPutObject.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 use aws.auth#unsignedPayload
 

models/multipleBackendPutObjectTagging.smithy → models/backbeatRoutes/multipleBackendPutObjectTagging.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 /// Adds or updates tags for an object in multiple backend storage
 @http(method: "POST", uri: "/_/backbeat/multiplebackenddata/{Bucket}/{Key+}?operation=puttagging")

models/putBucketIndexes.smithy → models/backbeatRoutes/putBucketIndexes.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @http(method: "POST", uri: "/_/backbeat/index/{Bucket}?operation=add")
 operation PutBucketIndexes {

models/putMetadata.smithy → models/backbeatRoutes/putMetadata.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 @http(method: "PUT", uri: "/_/backbeat/metadata/{Bucket}/{Key+}")
 operation PutMetadata {

models/putdata.smithy → models/backbeatRoutes/putdata.smithy

@@ -1,5 +1,5 @@
 $version: "2.0"
-namespace cloudserver.client
+namespace cloudserver.backbeatRoutes
 
 use aws.auth#unsignedPayload
 

models/quotas/deleteBucketQuota.smithy

@@ -0,0 +1,14 @@
+$version: "2.0"
+
+namespace cloudserver.bucketquota
+
+@http(method: "DELETE", uri: "/{Bucket}?quota=true")
+@idempotent
+operation DeleteBucketQuota {
+    input := {
+        @required
+        @httpLabel
+        Bucket: String
+    }
+    output := {}
+}

models/quotas/getBucketQuota.smithy

@@ -0,0 +1,17 @@
+$version: "2.0"
+
+namespace cloudserver.bucketquota
+
+@http(method: "GET", uri: "/{Bucket}?quota=true")
+@readonly
+operation GetBucketQuota {
+    input := {
+        @required
+        @httpLabel
+        Bucket: String
+    }
+    output := {
+        Name: String
+        Quota: Long
+    }
+}

models/quotas/updateBucketQuota.smithy

@@ -0,0 +1,23 @@
+$version: "2.0"
+namespace cloudserver.bucketquota
+
+@http(method: "PUT", uri: "/{Bucket}?quota=true")
+@idempotent
+operation UpdateBucketQuota {
+    input: QuotaConfiguration
+    output: UpdateBucketQuotaOutput
+}
+
+structure QuotaConfiguration {
+    @required
+    @httpLabel
+    Bucket: String
+
+    @required
+    Quota: Long
+}
+
+structure UpdateBucketQuotaOutput {
+    @httpPayload
+    body: String
+}