Merge branch 'master' into issue-18337

Author: michelle0927

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/financial_data/financial_data.app.mjs

@@ -0,0 +1,11 @@
+export default {
+  type: "app",
+  app: "financial_data",
+  propDefinitions: {},
+  methods: {
+    // this.$auth contains connected account data
+    authKeys() {
+      console.log(Object.keys(this.$auth));
+    },
+  },
+};

components/financial_data/package.json

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

components/gong/actions/list-calls/list-calls.mjs

@@ -5,7 +5,7 @@ export default {
   name: "List calls",
   description: "List calls. [See the documentation](https://us-66463.app.gong.io/settings/api/documentation#get-/v2/calls)",
   type: "action",
-  version: "0.0.3",
+  version: "0.0.4",
   props: {
     app,
     fromDateTime: {
@@ -22,16 +22,26 @@ export default {
         "toDateTime",
       ],
     },
+    cursor: {
+      optional: true,
+      type: "string",
+      label: "Cursor",
+      description: "The cursor to start from. This is returned by the previous step",
+    },
   },
   run({ $: step }) {
     const {
       app,
+      cursor,
       ...params
     } = this;
 
     return app.listCalls({
       step,
-      params,
+      params: {
+        ...params,
+        cursor,
+      },
       summary: (response) => `Successfully listed calls with request ID \`${response.requestId}\``,
     });
   },

components/gong/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/gong",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "description": "Pipedream Gong Components",
   "main": "gong.app.mjs",
   "keywords": [

components/google_sheets/actions/update-row/update-row.mjs

@@ -10,7 +10,7 @@ export default {
   key: "google_sheets-update-row",
   name: "Update Row",
   description: "Update a row in a spreadsheet. [See the documentation](https://developers.google.com/sheets/api/reference/rest/v4/spreadsheets.values/update)",
-  version: "0.1.13",
+  version: "0.1.14",
   type: "action",
   props: {
     googleSheets,
@@ -55,13 +55,15 @@ export default {
       },
       reloadProps: true,
     },
+    hasHeaders: common.props.hasHeaders,
     row: {
       propDefinition: [
         googleSheets,
         "row",
       ],
+      min: 1,
+      reloadProps: true,
     },
-    hasHeaders: common.props.hasHeaders,
   },
   async additionalProps() {
     const {
@@ -83,7 +85,7 @@ export default {
     }
 
     const props = {};
-    if (hasHeaders && row) {
+    if (hasHeaders) {
       try {
         const worksheet = await this.getWorksheetById(sheetId, worksheetId);
         const { values } = await this.googleSheets.getSpreadsheetValues(sheetId, `${worksheet?.properties?.title}!1:1`);
@@ -92,7 +94,7 @@ export default {
           throw new ConfigurationError("Could not find a header row. Please either add headers and click \"Refresh fields\" or set 'Does the first row of the sheet have headers?' to false.");
         }
 
-        const { values: rowValues } = !isNaN(row)
+        const { values: rowValues } = (!isNaN(row) && row > 0)
           ? await this.googleSheets.getSpreadsheetValues(sheetId, `${worksheet?.properties?.title}!${row}:${row}`)
           : {};
 
@@ -162,6 +164,10 @@ export default {
       cells = this.googleSheets.sanitizedArray(this.myColumnData);
     }
 
+    if (isNaN(row) || row < 1) {
+      throw new ConfigurationError("Please enter a valid row number in `Row Number`.");
+    }
+
     // validate input
     if (!cells || !cells.length) {
       throw new ConfigurationError("Please enter an array of elements in `Row Values`.");