Merge branch 'master' into databricks-sql-warehouses

Author: Lokeshchand33

components/coinbase_developer_platform/coinbase_developer_platform.app.mjs

@@ -1,11 +1,43 @@
+import {
+  Coinbase, Webhook,
+} from "@coinbase/coinbase-sdk";
+
 export default {
   type: "app",
   app: "coinbase_developer_platform",
-  propDefinitions: {},
+  propDefinitions: {
+    walletAddress: {
+      type: "string",
+      label: "Address",
+      description: "The address of the wallet to monitor. Example: `0x8fddcc0c5c993a1968b46787919cc34577d6dc5c`",
+    },
+    networkId: {
+      type: "string",
+      label: "Network ID",
+      description: "The network ID of the wallet to monitor. Example: `base-mainnet`",
+      async options() {
+        const networks = Coinbase.networks;
+        return Object.values(networks);
+      },
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    configure() {
+      const apiKeyName = this.$auth.api_key_id;
+      const privateKey = this.$auth.secret_key;
+      Coinbase.configure({
+        apiKeyName,
+        privateKey,
+      });
+    },
+    listWebhooks() {
+      return Webhook.list();
+    },
+    createWebhook(opts) {
+      return Webhook.create(opts);
+    },
+    deleteWebhook(webhook) {
+      return webhook.delete();
     },
   },
-};
+};

components/coinbase_developer_platform/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/coinbase_developer_platform",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Coinbase Developer Platform Components",
   "main": "coinbase_developer_platform.app.mjs",
   "keywords": [
@@ -11,5 +11,9 @@
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@coinbase/coinbase-sdk": "^0.25.0",
+    "@pipedream/platform": "^3.1.0"
   }
-}
+}

components/coinbase_developer_platform/sources/common/base.mjs

@@ -0,0 +1,29 @@
+import coinbase from "../../coinbase_developer_platform.app.mjs";
+import { ConfigurationError } from "@pipedream/platform";
+
+export default {
+  props: {
+    coinbase,
+    db: "$.service.db",
+    http: "$.interface.http",
+  },
+  methods: {
+    _getWebhookId() {
+      return this.db.get("webhookId");
+    },
+    _setWebhookId(webhookId) {
+      this.db.set("webhookId", webhookId);
+    },
+    generateMeta() {
+      throw new ConfigurationError("generateMeta is not implemented");
+    },
+  },
+  async run(event) {
+    const { body } = event;
+    if (!body) {
+      return;
+    }
+    const meta = this.generateMeta(body);
+    this.$emit(body, meta);
+  },
+};

components/coinbase_developer_platform/sources/new-wallet-event/new-wallet-event.mjs

@@ -0,0 +1,70 @@
+import common from "../common/base.mjs";
+import { ConfigurationError } from "@pipedream/platform";
+import sampleEmit from "./test-event.mjs";
+
+export default {
+  ...common,
+  name: "New Wallet Event (Instant)",
+  key: "coinbase_developer_platform-new-wallet-event",
+  description: "Emit new event for each new wallet event. [See the documentation](https://docs.cdp.coinbase.com/webhooks/cdp-sdk#external-address-webhook)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    ...common.props,
+    walletAddress: {
+      propDefinition: [
+        common.props.coinbase,
+        "walletAddress",
+      ],
+    },
+    networkId: {
+      propDefinition: [
+        common.props.coinbase,
+        "networkId",
+      ],
+    },
+  },
+  hooks: {
+    async activate() {
+      this.coinbase.configure();
+      const webhook = await this.coinbase.createWebhook({
+        notificationUri: this.http.endpoint,
+        eventType: "wallet_activity",
+        networkId: this.networkId,
+        eventTypeFilter: {
+          addresses: [
+            this.walletAddress,
+          ],
+          wallet_id: "",
+        },
+      });
+
+      if (!webhook?.model?.id) {
+        throw new ConfigurationError("Failed to create webhook");
+      }
+
+      this._setWebhookId(webhook.model.id);
+    },
+    async deactivate() {
+      this.coinbase.configure();
+      const webhookId = this._getWebhookId();
+      if (webhookId) {
+        const { data: webhooks } = await this.coinbase.listWebhooks();
+        const webhook = webhooks.find((webhook) => webhook.model.id === webhookId);
+        await this.coinbase.deleteWebhook(webhook);
+      }
+    },
+  },
+  methods: {
+    ...common.methods,
+    generateMeta(body) {
+      return {
+        id: body.transactionHash,
+        summary: `New ${body.eventType} event`,
+        ts: Date.parse(body.blockTime),
+      };
+    },
+  },
+  sampleEmit,
+};

components/coinbase_developer_platform/sources/new-wallet-event/test-event.mjs

@@ -0,0 +1,15 @@
+export default {
+  "blockHash": "0x351bd04dfe350fca186cd47080220283a75d07018ed251748a4ad19e7f327caf",
+  "blockNumber": 20305354,
+  "blockTime": "2024-09-27T21:16:40.000Z",
+  "contractAddress": "0xab39a8b6801b0b6aa20e9a1953c861ec0a57d175",
+  "eventType": "erc20_transfer",
+  "from": "0x10db590ffa5b7bc46cffbd436180e01b6c5c0af6",
+  "logIndex": "121",
+  "network": "base-sepolia",
+  "to": "0x4a9ab171e31daff484c70921f2f5e89a8fe12f59",
+  "transactionHash": "0x940db3006449456b386397ab42114134d745d2876196226444601670f3e99db8",
+  "transactionIndex": "19",
+  "value": "1000000",
+  "webhookId": "66bd79d0b9c200eae1a43165"
+}

components/databricks/actions/cancel-all-runs/cancel-all-runs.mjs

@@ -0,0 +1,52 @@
+import app from "../../databricks.app.mjs";
+
+export default {
+  key: "databricks-cancel-all-runs",
+  name: "Cancel All Runs",
+  description: "Cancel all active runs for a job. The runs are canceled asynchronously, so it doesn't prevent new runs from being started. [See the documentation](https://docs.databricks.com/api/workspace/jobs/cancelallruns)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    // eslint-disable-next-line pipedream/props-label, pipedream/props-description
+    info: {
+      type: "alert",
+      alertType: "info",
+      content: "Either a **Job** or **All Queued Runs** must be provided.",
+    },
+    jobId: {
+      optional: true,
+      propDefinition: [
+        app,
+        "jobId",
+      ],
+    },
+    allQueuedRuns: {
+      type: "boolean",
+      label: "All Queued Runs",
+      description: "Optional boolean parameter to cancel all queued runs. If no **Job ID** is provided, all queued runs in the workspace are canceled.",
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      jobId,
+      allQueuedRuns,
+    } = this;
+
+    await app.cancelAllRuns({
+      $,
+      data: {
+        job_id: jobId,
+        all_queued_runs: allQueuedRuns,
+      },
+    });
+
+    $.export("$summary", "Successfully initiated cancellation of all runs");
+
+    return {
+      success: true,
+    };
+  },
+};

components/databricks/actions/cancel-run/cancel-run.mjs

@@ -0,0 +1,37 @@
+import app from "../../databricks.app.mjs";
+
+export default {
+  key: "databricks-cancel-run",
+  name: "Cancel Run",
+  description: "Cancel a job run. The run is canceled asynchronously, so it may still be running when this request completes. [See the documentation](https://docs.databricks.com/api/workspace/jobs/cancelrun)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    runId: {
+      propDefinition: [
+        app,
+        "runId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      runId,
+    } = this;
+
+    await app.cancelRun({
+      $,
+      data: {
+        run_id: runId,
+      },
+    });
+
+    $.export("$summary", `Successfully initiated cancellation of run with ID \`${runId}\`.`);
+
+    return {
+      success: true,
+    };
+  },
+};