Merge branch 'master' into issue-14493

Author: luancazarine

.github/workflows/docs.yaml

@@ -0,0 +1,24 @@
+name: Lint SDK Markdown Files
+
+on:
+  pull_request:
+    types: [opened, edited, synchronize]
+    paths:
+      - 'packages/sdk/**/*.md'
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+
+      - name: Lint markdown files
+        uses: DavidAnson/markdownlint-cli2-action@v17
+        with:
+          globs: 'packages/sdk/**/*.md'

.github/workflows/pipedream-sdk-markdown-lint.yaml

@@ -6,13 +6,17 @@ on:
     paths:
       - 'packages/sdk/**'
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 jobs:
   test:
     runs-on: ubuntu-latest
 
     steps:
       - name: Checkout code
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
 
       - name: Set up Node.js
         uses: actions/setup-node@v3

.github/workflows/pipedream-sdk-test.yaml

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/air/air.app.mjs

@@ -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/.gitignore

@@ -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/alchemy.app.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/app/alchemy.app.ts

@@ -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);
+  },
+};