feat: enable bucket versioning (#270)

* docs(cli): add laf cli docs; * chore: fix doc link * feat: enable bucket versioning in sys server;
labring · Aug 14, 2022 · f7c3efd · f7c3efd
1 parent 59a15c7
commit f7c3efd
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 3 deletions.
diff --git a/deploy/docker-compose/docker-compose.yml b/deploy/docker-compose/docker-compose.yml
@@ -21,7 +21,7 @@ services:
       - laf_shared_network
 
   oss:
-    image: 'bitnami/minio:2022.4.12'
+    image: 'bitnami/minio:2022.8.11'
     environment:
       - MINIO_ROOT_USER=${MINIO_ROOT_USER}
       - MINIO_ROOT_PASSWORD=${MINIO_ROOT_PASSWORD}

diff --git a/docker-compose.yml b/docker-compose.yml
@@ -35,7 +35,7 @@ services:
       - laf_shared_network
 
   oss:
-    image: 'bitnami/minio:2022.4.12'
+    image: 'bitnami/minio:2022.8.11'
     environment:
       - MINIO_ROOT_USER=minio-root-user
       - MINIO_ROOT_PASSWORD=minio-root-password

diff --git a/packages/system-server/src/support/minio.ts b/packages/system-server/src/support/minio.ts
@@ -2,7 +2,7 @@ import assert = require("assert")
 import * as cp from 'child_process'
 import { promisify } from 'util'
 import { STSClient, AssumeRoleCommand } from '@aws-sdk/client-sts'
-import { CreateBucketCommand, DeleteBucketCommand, DeleteBucketPolicyCommand, PutBucketPolicyCommand, S3 } from '@aws-sdk/client-s3'
+import { CreateBucketCommand, DeleteBucketCommand, DeleteBucketPolicyCommand, PutBucketPolicyCommand, PutBucketVersioningCommand, S3 } from '@aws-sdk/client-s3'
 import { logger } from "./logger"
 import Config from "../config"
 import { IApplicationData } from "./application"
@@ -175,6 +175,18 @@ export class MinioAgent {
       await this.setBucketQuota(name, quota)
     }
 
+    const version_cmd = new PutBucketVersioningCommand({
+      Bucket: name,
+      VersioningConfiguration: {
+        Status: 'Enabled'
+      }
+    })
+
+    const version_res = await s3.send(version_cmd)
+    if (version_res?.$metadata?.httpStatusCode === 200) {
+      logger.info(`bucket ${name} versioning enabled`)
+    }
+
     return res
   }