refactor: extract iacStack to define resrouces separately

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

Author: Blankll

src/parser/index.ts

@@ -13,7 +13,7 @@ const validateExistence = (path: string) => {
   }
 };
 
-const transformYaml = (iacJson: ServerlessIacRaw, context: ActionContext): ServerlessIac => {
+const transformYaml = (iacJson: ServerlessIacRaw): ServerlessIac => {
   return {
     service: iacJson.service,
     version: iacJson.version,
@@ -23,7 +23,7 @@ const transformYaml = (iacJson: ServerlessIacRaw, context: ActionContext): Serve
     functions: parseFunction(iacJson.functions),
     events: parseEvent(iacJson.events),
     databases: parseDatabase(iacJson.databases),
-    tags: parseTag(iacJson.tags, context),
+    tags: parseTag(iacJson.tags),
   };
 };
 
@@ -35,5 +35,5 @@ export const parseYaml = (context: ActionContext): ServerlessIac => {
 
   validateYaml(iacJson);
 
-  return transformYaml(iacJson, context);
+  return transformYaml(iacJson);
 };

src/parser/tagParser.ts

@@ -1,12 +1,8 @@
-import { ActionContext, TagDomain, Tags } from '../types';
-import { replaceReference } from '../common';
+import { TagDomain, Tags } from '../types';
 
-export const parseTag = (tags: Tags | undefined, context: ActionContext): Array<TagDomain> => {
+export const parseTag = (tags: Tags | undefined): Array<TagDomain> => {
   return [
     { key: 'iac-provider', value: 'ServerlessInsight' },
-    ...Object.entries(tags ?? {}).map(([key, value]) => ({
-      key: replaceReference(key, context),
-      value: replaceReference(value, context),
-    })),
+    ...Object.entries(tags ?? {}).map(([key, value]) => ({ key, value })),
   ];
 };

src/stack/deploy.ts

@@ -1,15 +1,15 @@
 import * as ros from '@alicloud/ros-cdk-core';
 import { ActionContext, ServerlessIac } from '../types';
 import { logger, rosStackDeploy } from '../common';
-import { IacStack } from './iacStack';
+import { RosStack } from './rosStack/rosStack';
 
 export const generateStackTemplate = (
   stackName: string,
   iac: ServerlessIac,
   context: ActionContext,
 ) => {
   const app = new ros.App();
-  new IacStack(app, iac, context);
+  new RosStack(app, iac, context);
 
   const assembly = app.synth();
   const stackArtifact = assembly.getStackByName(stackName);

src/stack/iacStack.ts

@@ -0,0 +1,52 @@
+import * as ros from '@alicloud/ros-cdk-core';
+import { replaceReference } from '../../common';
+import { ActionContext, DatabaseDomain, DatabaseEngineMode, DatabaseEnum } from '../../types';
+import { isEmpty } from 'lodash';
+import * as esServerless from '@alicloud/ros-cdk-elasticsearchserverless';
+
+export const resolveDatabases = (
+  scope: ros.Construct,
+  databases: Array<DatabaseDomain> | undefined,
+  context: ActionContext,
+) => {
+  if (isEmpty(databases)) {
+    return undefined;
+  }
+  databases!.forEach((db) => {
+    if ([DatabaseEnum.ELASTICSEARCH_SERVERLESS].includes(db.type)) {
+      new esServerless.App(
+        scope,
+        replaceReference(db.key, context),
+        {
+          appName: replaceReference(db.name, context),
+          appVersion: db.version,
+          authentication: {
+            basicAuth: [
+              {
+                password: replaceReference(db.security.basicAuth.password, context),
+              },
+            ],
+          },
+          quotaInfo: {
+            cu: db.cu,
+            storage: db.storageSize,
+            appType: db.engineMode === DatabaseEngineMode.TIMESERIES ? 'TRIAL' : 'STANDARD',
+          },
+          // network: [
+          //   {
+          //     type: 'PUBLIC_KIBANA',
+          //     enabled: true,
+          //     whiteIpGroup: [{ groupName: 'default', ips: ['0.0.0.0/24'] }],
+          //   },
+          //   {
+          //     type: 'PUBLIC_ES',
+          //     enabled: true,
+          //     whiteIpGroup: [{ groupName: 'default', ips: ['0.0.0.0/24'] }],
+          //   },
+          // ],
+        },
+        true,
+      );
+    }
+  });
+};