Merge remote-tracking branch 'origin/master' into connect/workflow-sdk-docs

Author: dylburger

components/alchemy/.gitignore

@@ -0,0 +1,58 @@
+import { axios } from "@pipedream/platform";
+import constants from "./common/constants.mjs";
+
+export default {
+  type: "app",
+  app: "alchemy",
+  propDefinitions: {
+    network: {
+      type: "string",
+      label: "Network",
+      description: "Network of the webhook",
+      options: constants.NETWORKS,
+    },
+    query: {
+      type: "string",
+      label: "GraphQL Query",
+      description: "Create a custom GraphQL query or select `Full Block Receipts` to get all log events for every new block",
+      options: [
+        {
+          label: "Full Block Receipts",
+          value: constants.FULL_BLOCK_RECEIPTS,
+        },
+      ],
+    },
+  },
+  methods: {
+    _baseUrl() {
+      return "https://dashboard.alchemy.com/api";
+    },
+    _makeRequest({
+      $ = this,
+      path,
+      ...opts
+    }) {
+      return axios($, {
+        url: `${this._baseUrl()}${path}`,
+        headers: {
+          "X-Alchemy-Token": this.$auth.auth_token,
+        },
+        ...opts,
+      });
+    },
+    createWebhook(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/create-webhook",
+        ...opts,
+      });
+    },
+    deleteWebhook(opts = {}) {
+      return this._makeRequest({
+        method: "DELETE",
+        path: "/delete-webhook",
+        ...opts,
+      });
+    },
+  },
+};

components/alchemy/alchemy.app.mjs

@@ -0,0 +1,82 @@
+const NETWORKS = [
+  "ETH_MAINNET",
+  "ETH_SEPOLIA",
+  "ETH_HOLESKY",
+  "ARBMAINNET",
+  "ARBSEPOLIA",
+  "ARBNOVA_MAINNET",
+  "MATICMAINNET",
+  "MATICMUMBAI",
+  "OPTMAINNET",
+  "OPTGOERLI",
+  "BASE_MAINNET",
+  "BASE_SEPOLIA",
+  "ZKSYNC_MAINNET",
+  "ZKSYNC_SEPOLIA",
+  "LINEA_MAINNET",
+  "LINEA_SEPOLIA",
+  "GNOSIS_MAINNET",
+  "GNOSIS_CHIADO",
+  "FANTOM_MAINNET",
+  "FANTOM_TESTNET",
+  "METIS_MAINNET",
+  "BLAST_MAINNET",
+  "BLAST_SEPOLIA",
+  "SHAPE_SEPOLIA",
+  "ZETACHAIN_MAINNET",
+  "ZETACHAIN_TESTNET",
+  "WORLDCHAIN_MAINNET",
+  "WORLDCHAIN_SEPOLIA",
+  "BNB_MAINNET",
+  "BNB_TESTNET",
+  "AVAX_MAINNET",
+  "AVAX_FUJI",
+  "SONEIUM_MINATO",
+  "GEIST_POLTER",
+];
+
+const FULL_BLOCK_RECEIPTS = `
+{
+  block {
+    hash,
+    number,
+    timestamp,
+    logs(filter: {addresses: [], topics: []}) {
+      data,
+      topics,
+      index,
+      account {
+        address
+      },
+      transaction {
+        hash,
+        nonce,
+        index,
+        from {
+          address
+        },
+        to {
+          address
+        },
+        value,
+        gasPrice,
+        maxFeePerGas,
+        maxPriorityFeePerGas,
+        gas,
+        status,
+        gasUsed,
+        cumulativeGasUsed,
+        effectiveGasPrice,
+        createdContract {
+          address
+        }
+      }
+    }
+  }
+}
+`;
+
+export default {
+  NETWORKS,
+  FULL_BLOCK_RECEIPTS,
+};

components/alchemy/common/constants.mjs

@@ -1,18 +1,18 @@
 {
   "name": "@pipedream/alchemy",
-  "version": "0.0.3",
+  "version": "0.1.0",
   "description": "Pipedream Alchemy Components",
-  "main": "dist/app/alchemy.app.mjs",
+  "main": "alchemy.app.mjs",
   "keywords": [
     "pipedream",
     "alchemy"
   ],
-  "files": [
-    "dist"
-  ],
   "homepage": "https://pipedream.com/apps/alchemy",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
   }
 }

components/alchemy/package.json

@@ -0,0 +1,77 @@
+import alchemy from "../../alchemy.app.mjs";
+
+export default {
+  key: "alchemy-new-graphql-query-instant",
+  name: "New GraphQL Query (Instant)",
+  description: "Emit new event when a new GraphQL query is uploaded to Alchemy's Custom Webhook service. [See the documentation](https://docs.alchemy.com/reference/create-webhook)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    alchemy,
+    db: "$.service.db",
+    http: {
+      type: "$.interface.http",
+      customResponse: true,
+    },
+    network: {
+      propDefinition: [
+        alchemy,
+        "network",
+      ],
+    },
+    query: {
+      propDefinition: [
+        alchemy,
+        "query",
+      ],
+    },
+  },
+  hooks: {
+    async activate() {
+      const { data: { id } } = await this.alchemy.createWebhook({
+        data: {
+          network: this.network,
+          webhook_type: "GRAPHQL",
+          webhook_url: this.http.endpoint,
+          graphql_query: this.query,
+        },
+      });
+      this._setHookId(id);
+    },
+    async deactivate() {
+      const hookId = this._getHookId();
+      if (hookId) {
+        await this.alchemy.deleteWebhook({
+          params: {
+            webhook_id: hookId,
+          },
+        });
+      }
+    },
+  },
+  methods: {
+    _getHookId() {
+      return this.db.get("hookId");
+    },
+    _setHookId(hookId) {
+      this.db.set("hookId", hookId);
+    },
+    generateMeta(body) {
+      return {
+        id: body.id,
+        summary: `New Event ID: ${body.id}`,
+        ts: Date.parse(body.createdAt),
+      };
+    },
+  },
+  async run(event) {
+    this.http.respond({
+      status: 200,
+    });
+
+    const { body } = event;
+    const meta = this.generateMeta(body);
+    this.$emit(body, meta);
+  },
+};

components/alchemy/sources/new-graphql-query-instant/new-graphql-query-instant.mjs

@@ -1,13 +1,11 @@
-import { defineApp } from "@pipedream/types";
-
-export default defineApp({
+export default {
   type: "app",
-  app: "alchemy",
+  app: "cats",
   propDefinitions: {},
   methods: {
     // this.$auth contains connected account data
     authKeys() {
       console.log(Object.keys(this.$auth));
     },
   },
-});
+};

components/alchemy/app/alchemy.app.ts renamed to components/cats/cats.app.mjs

@@ -0,0 +1,15 @@
+{
+  "name": "@pipedream/cats",
+  "version": "0.0.1",
+  "description": "Pipedream CATS Components",
+  "main": "cats.app.mjs",
+  "keywords": [
+    "pipedream",
+    "cats"
+  ],
+  "homepage": "https://pipedream.com/apps/cats",
+  "author": "Pipedream <[email protected]> (https://pipedream.com/)",
+  "publishConfig": {
+    "access": "public"
+  }
+}

components/cats/package.json

@@ -0,0 +1,79 @@
+import checkvist from "../../checkvist.app.mjs";
+import { STATUS_OPTIONS } from "../../common/constants.mjs";
+import { parseObject } from "../../common/utils.mjs";
+
+export default {
+  key: "checkvist-create-list-item",
+  name: "Create List Item",
+  description: "Creates a new list item within a specified list. [See the documentation](https://checkvist.com/auth/api)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    checkvist,
+    listId: {
+      propDefinition: [
+        checkvist,
+        "listId",
+      ],
+    },
+    content: {
+      type: "string",
+      label: "Content",
+      description: "Block of text containing items to add. Indentations indicate nested list items.",
+    },
+    parentId: {
+      propDefinition: [
+        checkvist,
+        "parentId",
+        ({ listId }) => ({
+          listId,
+        }),
+      ],
+      optional: true,
+    },
+    tags: {
+      type: "string[]",
+      label: "Tags",
+      description: "An array of tags.",
+      optional: true,
+    },
+    dueDate: {
+      type: "string",
+      label: "Due Date",
+      description: "Due for the task, in Checkvist's smart syntax format.",
+      optional: true,
+    },
+    position: {
+      type: "integer",
+      label: "Position",
+      description: "1-based position of the task (omit to add to the end of the list).",
+      optional: true,
+    },
+    status: {
+      type: "string",
+      label: "Status",
+      description: "Task status",
+      options: STATUS_OPTIONS,
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const response = await this.checkvist.createListItem({
+      $,
+      listId: this.listId,
+      data: {
+        task: {
+          content: this.content,
+          parent_id: this.parentId || 0,
+          tags: parseObject(this.tags)?.join(","),
+          due_date: this.dueDate,
+          position: this.position,
+          status: this.status,
+        },
+      },
+    });
+
+    $.export("$summary", `Successfully created a new list item in list with ID ${this.listId}`);
+    return response;
+  },
+};