feat: init oss resources creation

Signed-off-by: seven <[email protected]>

Author: Blankll

package-lock.json

@@ -53,6 +53,7 @@
     "@alicloud/ros-cdk-apigateway": "^1.4.0",
     "@alicloud/ros-cdk-core": "^1.4.0",
     "@alicloud/ros-cdk-fc3": "^1.4.0",
+    "@alicloud/ros-cdk-oss": "^1.4.0",
     "@alicloud/ros-cdk-ram": "^1.4.0",
     "@alicloud/ros20190910": "^3.5.0",
     "ajv": "^8.17.1",
@@ -67,8 +68,8 @@
   "devDependencies": {
     "@types/i18n": "^0.13.12",
     "@types/jest": "^29.5.13",
-    "@types/node": "^22.7.4",
     "@types/lodash": "^4.17.12",
+    "@types/node": "^22.7.4",
     "@typescript-eslint/eslint-plugin": "^8.8.0",
     "@typescript-eslint/parser": "^8.8.0",
     "eslint": "^8.57.1",

package.json

@@ -9,6 +9,11 @@ export const resolveCode = (location: string): string => {
 
   return fileContent.toString('base64');
 };
+export const readCodeSize = (location: string): number => {
+  const filePath = path.resolve(process.cwd(), location);
+  const stats = fs.statSync(filePath);
+  return stats.size;
+};
 
 const evalCtx = (value: string, ctx: ActionContext): string => {
   const containsStage = value.match(/\$\{ctx.\w+}/);

src/common/iacHelper.ts

@@ -4,7 +4,8 @@ import { ActionContext, EventTypes, ServerlessIac } from '../types';
 import * as fc from '@alicloud/ros-cdk-fc3';
 import * as ram from '@alicloud/ros-cdk-ram';
 import * as agw from '@alicloud/ros-cdk-apigateway';
-import { replaceReference, resolveCode } from '../common';
+import * as oss from '@alicloud/ros-cdk-oss';
+import { readCodeSize, replaceReference, resolveCode } from '../common';
 
 export class IacStack extends ros.Stack {
   private readonly service: string;
@@ -41,7 +42,29 @@ export class IacStack extends ros.Stack {
       replaceReference(`${this.service} stack`, context),
     );
 
+    const codeSize = iac.functions.find(({ code }) => readCodeSize(code) > 15 * 1024 * 1024);
+    if (codeSize) {
+      // creat oss to store code
+      new oss.Bucket(this, replaceReference(`${this.service}_code_object_store`, context), {
+        bucketName: replaceReference(`${this.service}-code-object-store`, context),
+        serverSideEncryptionConfiguration: { sseAlgorithm: 'KMS' },
+      });
+    }
+
     iac.functions.forEach((fnc) => {
+      if (codeSize && readCodeSize(fnc.code) > 15 * 1024 * 1024) {
+        // upload code to oss
+        new oss.RosBucketObject(
+          this,
+          replaceReference(`${this.service}_code_object`, context),
+          {
+            bucket: replaceReference(`${this.service}-code-object-store`, context),
+            objectName: replaceReference(fnc.code, context),
+            source: resolveCode(fnc.code),
+          },
+          true,
+        );
+      }
       new fc.RosFunction(
         this,
         fnc.key,