Postman Echo as Data Source

Author: FalkWolsky

server/node-service/src/controllers/plugins.ts

@@ -17,6 +17,10 @@ export async function listPlugins(req: Request, res: Response) {
 export async function runPluginQuery(req: Request, res: Response) {
   const { pluginName, dsl, context, dataSourceConfig } = req.body;
   const ctx = pluginServices.getPluginContext(req);
+
+
+  console.log("pluginName: ", pluginName, "dsl: ", dsl, "context: ", context, "dataSourceConfig: ", dataSourceConfig, "ctx: ", ctx);
+
   const result = await pluginServices.runPluginQuery(
     pluginName,
     dsl,

server/node-service/src/plugins/index.ts

@@ -34,6 +34,7 @@ import didPlugin from "./did";
 import bigQueryPlugin from "./bigQuery";
 import appConfigPlugin from "./appconfig";
 import tursoPlugin from "./turso";
+import postmanEchoPlugin from "./postmanEcho";
 
 let plugins: (DataSourcePlugin | DataSourcePluginFactory)[] = [
   s3Plugin,
@@ -71,6 +72,7 @@ let plugins: (DataSourcePlugin | DataSourcePluginFactory)[] = [
   bigQueryPlugin,
   appConfigPlugin,
   tursoPlugin,
+  postmanEchoPlugin,
 ];
 
 try {

server/node-service/src/plugins/openApi/index.ts

@@ -82,6 +82,8 @@ export async function runOpenApi(
   const { actionName, ...otherActionData } = actionData;
   const { serverURL } = dataSourceConfig;
 
+
+
   let operation, realOperationId, definition: OpenAPI.Document | undefined;
 
   for (const {id, def} of await getDefinitions(spec, openApiSpecDereferenced)) {
@@ -114,6 +116,7 @@ export async function runOpenApi(
   try {
     const { parameters, requestBody } = normalizeParams(otherActionData, operation, isOas3Spec);
     let securities = extractSecurityParams(dataSourceConfig, definition);
+
     const response = await SwaggerClient.execute({
       spec: definition,
       operationId: realOperationId,
@@ -122,6 +125,7 @@ export async function runOpenApi(
       securities,
       responseContentType: "application/json",
       userFetch: async (url: string, req: RequestInit) => {
+        console.log("req", req);
         return fetch(url, req);
       },
       requestInterceptor: (req: any) => {

server/node-service/src/plugins/postmanEcho/index.ts

@@ -0,0 +1,53 @@
+import { readYaml } from "../../common/util";
+import _ from "lodash";
+import path from "path";
+import { OpenAPIV3, OpenAPI } from "openapi-types";
+import { ConfigToType, DataSourcePlugin } from "lowcoder-sdk/dataSource";
+import { runOpenApi } from "../openApi";
+import { parseOpenApi, ParseOpenApiOptions } from "../openApi/parse";
+
+import spec from './postmanEcho.spec.json';
+
+
+const dataSourceConfig = {
+  type: "dataSource",
+  params: []
+} as const;
+
+const parseOptions: ParseOpenApiOptions = {
+  actionLabel: (method: string, path: string, operation: OpenAPI.Operation) => {
+    return _.upperFirst(operation.summary ? operation.summary : operation.operationId || "");
+  },
+};
+
+type DataSourceConfigType = ConfigToType<typeof dataSourceConfig>;
+
+const postmanEchoPlugin: DataSourcePlugin<any, DataSourceConfigType> = {
+  id: "postmanEcho",
+  name: "Postman Echo",
+  icon: "postmanEcho.svg",
+  category: "api",
+  dataSourceConfig,
+  queryConfig: async () => {
+    const { actions, categories } = await parseOpenApi(spec as unknown as OpenAPI.Document, parseOptions);
+    return {
+      type: "query",
+      label: "Action",
+      categories: {
+        label: "Resources",
+        items: categories,
+      },
+      actions,
+    };
+  },
+  run: function (actionData, dataSourceConfig): Promise<any> {
+    const runApiDsConfig = {
+      url: "",
+      serverURL: "",
+      dynamicParamsConfig: dataSourceConfig,
+    };
+    return runOpenApi(actionData, runApiDsConfig, spec as OpenAPIV3.Document);
+  },
+};
+
+export default postmanEchoPlugin;