feat: Shopify

Author: Esieve

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

@@ -1,51 +1,34 @@
-import { readYaml } from "../../common/util";
-import _ from "lodash";
-import path from "path";
-import { OpenAPIV3, OpenAPI } from "openapi-types";
-import { ConfigToType, DataSourcePlugin } from "openblocks-sdk/dataSource";
-import { runOpenApi } from "../openApi";
-import { parseOpenApi, ParseOpenApiOptions } from "../openApi/parse";
+import { kvToRecord } from "../../common/util";
+import { ConfigToType, DataSourcePlugin, PluginContext } from "openblocks-sdk/dataSource";
+import { graphQLQueryConfig } from "../graphql/queryConfig";
+import { runGraphQL } from "../graphql/run";
 
-const spec = readYaml(path.join(__dirname, "./shopify.spec.yaml"));
-
-const dataSourceConfig = {
+export const dataSourceConfig = {
   type: "dataSource",
-  params: [],
+  params: [
+    {
+      type: "textInput",
+      label: "Endpoint",
+      key: "endpoint",
+      rules: [{ required: true }],
+    },
+  ],
 } as const;
 
-const parseOptions: ParseOpenApiOptions = {
-  actionLabel: (method: string, path: string, operation: OpenAPI.Operation) => {
-    return _.upperFirst(operation.operationId || "");
-  },
-};
-
-type DataSourceConfigType = ConfigToType<typeof dataSourceConfig>;
-
-const shopifyPlugin: DataSourcePlugin<any, DataSourceConfigType> = {
+const shopifyPlugin: DataSourcePlugin<
+  ConfigToType<typeof graphQLQueryConfig>,
+  ConfigToType<typeof dataSourceConfig>
+> = {
   id: "shopify",
   name: "Shopify",
-  icon: "shopify.svg",
   category: "api",
+  icon: "shopify.svg",
   dataSourceConfig,
-  queryConfig: async () => {
-    const { actions, categories } = await parseOpenApi(spec, parseOptions);
-    return {
-      type: "query",
-      label: "Action",
-      categories: {
-        label: "Category",
-        items: categories,
-      },
-      actions,
-    };
-  },
-  run: function (actionData, dataSourceConfig): Promise<any> {
-    const runApiDsConfig = {
-      url: "",
-      serverURL: "",
-      dynamicParamsConfig: dataSourceConfig,
-    };
-    return runOpenApi(actionData, runApiDsConfig, spec as OpenAPIV3.Document);
+  queryConfig: graphQLQueryConfig,
+  run: function (actionData, dataSourceConfig, context: PluginContext): Promise<any> {
+    const { query, variables: variableKvs, headers: queryHeaders } = actionData;
+    const variables = kvToRecord(variableKvs);
+    return runGraphQL(dataSourceConfig.endpoint, query, variables, {});
   },
 };