Add dynamo spec version

Thomasr · Thomasr · commit a3fc99471da0 · 2024-08-05T12:30:45.000-04:00
diff --git a/server/node-service/src/plugins/dynamodb/dataSourceConfig.ts b/server/node-service/src/plugins/dynamodb/dataSourceConfig.ts
@@ -1,5 +1,8 @@
 import { ConfigToType } from "lowcoder-sdk/dataSource";
-
+import { specsToOptions } from "../../common/util";
+const specs = {
+  "v1.0": ""
+}
 const dataSourceConfig = {
   type: "dataSource",
   params: [
@@ -27,6 +30,14 @@ const dataSourceConfig = {
       label: "Region",
       defaultValue: "us-west-1",
     },
+    {
+      label: "Spec Version",
+      key: "specVersion",
+      type: "select",
+      tooltip: "Version of the spec file.",
+      placeholder: "v1.0",
+      options: specsToOptions(specs)
+    },
   ],
 } as const;
 
diff --git a/server/node-service/src/plugins/dynamodb/index.ts b/server/node-service/src/plugins/dynamodb/index.ts
@@ -3,13 +3,19 @@ import dataSourceConfig, { DataSourceDataType } from "./dataSourceConfig";
 import queryConfig, { ActionDataType } from "./queryConfig";
 import { runDynamoDbQuery } from "./run";
 
+const specs = {
+  "v1.0": queryConfig
+}
+
 const dynamoDBPlugin: DataSourcePlugin<ActionDataType, DataSourceDataType> = {
   id: "dynamodb",
   name: "DynamoDB",
   category: "database",
   icon: "dynamodb.svg",
   dataSourceConfig,
-  queryConfig,
+  queryConfig: async (data) => {
+    return specs[data.specVersion as keyof typeof specs]
+  },
   run: async function (actionData, dataSourceConfig): Promise<any> {
     return runDynamoDbQuery(actionData, dataSourceConfig);
   },
diff --git a/server/node-service/src/plugins/n8n/index.ts b/server/node-service/src/plugins/n8n/index.ts
@@ -7,7 +7,6 @@ import spec from "./spec.json";
 import { specsToOptions } from "../../common/util";
 const specs = {
   "v1.0": spec,
-  "v2.0": spec,
 }
 
 export function prepareServerUrl(url: string) {
@@ -70,8 +69,8 @@ const n8nPlugin: DataSourcePlugin<any, DataSourceConfigType> = {
   icon: "n8n.svg",
   category: "api",
   dataSourceConfig,
-  queryConfig: async () => {
-    const { actions, categories } = await parseOpenApi(spec as OpenAPI.Document, parseOptions);
+  queryConfig: async (data) => {
+    const { actions, categories } = await parseOpenApi(specs[data.specVersion as keyof typeof specs] as OpenAPI.Document, parseOptions);
     return {
       type: "query",
       label: "Operation",
@@ -92,7 +91,7 @@ const n8nPlugin: DataSourcePlugin<any, DataSourceConfigType> = {
       },
       specVersion: dataSourceConfig.specVersion
     };
-    return runOpenApi(actionData, runApiDsConfig, spec as OpenAPIV3.Document);
+    return runOpenApi(actionData, runApiDsConfig, specs[dataSourceConfig.specVersion as keyof typeof specs] as OpenAPIV3.Document);
   },
 };
 
