Enable wallet activity events support for webhooks at wallet level

CHANGELOG.md

@@ -2,9 +2,11 @@
 
 ## Unreleased
 
+## [0.7.0] - 2024-09-24
 ### Added
 - Add `deployNFT` method to `WalletAddress` and `Wallet` to deploy an ERC721, updated `SmartContract` class to support deployment and fetching contract details
 - Add `deployMultiToken` method to `WalletAddress` and `Wallet` to deploy an ERC1155, updated `SmartContract` class to support deployment and fetching contract details
+- Add `createWebhook` method to `Wallet` to deploy a wallet activity webhook, updated `Webhook` class to disallow users from specifying webhook signature. Webhook signature is now generated by the API. 
 
 ## [0.6.1] - 2024-09-23
 

jest.config.js

@@ -11,9 +11,9 @@ module.exports = {
   coverageThreshold: {
     "./src/coinbase/**": {
       branches: 77,
-      functions: 90,
+      functions: 85,
       statements: 85,
-      lines: 87,
+      lines: 85,
     },
   },
 };

src/client/api.ts

@@ -783,6 +783,25 @@ export interface CreateWalletRequestWallet {
      */
     'use_server_signer'?: boolean;
 }
+/**
+ * 
+ * @export
+ * @interface CreateWalletWebhookRequest
+ */
+export interface CreateWalletWebhookRequest {
+    /**
+     * The URL to which the notifications will be sent
+     * @type {string}
+     * @memberof CreateWalletWebhookRequest
+     */
+    'notification_uri': string;
+    /**
+     * The custom header to be used for x-webhook-signature header on callbacks, so developers can verify the requests are coming from Coinbase.
+     * @type {string}
+     * @memberof CreateWalletWebhookRequest
+     */
+    'signature_header'?: string;
+}
 /**
  * 
  * @export
@@ -9288,6 +9307,44 @@ export class WalletsApi extends BaseAPI implements WalletsApiInterface {
  */
 export const WebhooksApiAxiosParamCreator = function (configuration?: Configuration) {
     return {
+        /**
+         * Create a new webhook scoped to a wallet
+         * @summary Create a new webhook scoped to a wallet
+         * @param {string} walletId The ID of the wallet to create the webhook for.
+         * @param {CreateWalletWebhookRequest} [createWalletWebhookRequest] 
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        createWalletWebhook: async (walletId: string, createWalletWebhookRequest?: CreateWalletWebhookRequest, options: RawAxiosRequestConfig = {}): Promise<RequestArgs> => {
+            // verify required parameter 'walletId' is not null or undefined
+            assertParamExists('createWalletWebhook', 'walletId', walletId)
+            const localVarPath = `/v1/wallets/{wallet_id}/webhooks`
+                .replace(`{${"wallet_id"}}`, encodeURIComponent(String(walletId)));
+            // use dummy base URL string because the URL constructor only accepts absolute URLs.
+            const localVarUrlObj = new URL(localVarPath, DUMMY_BASE_URL);
+            let baseOptions;
+            if (configuration) {
+                baseOptions = configuration.baseOptions;
+            }
+
+            const localVarRequestOptions = { method: 'POST', ...baseOptions, ...options};
+            const localVarHeaderParameter = {} as any;
+            const localVarQueryParameter = {} as any;
+
+
+
+            localVarHeaderParameter['Content-Type'] = 'application/json';
+
+            setSearchParams(localVarUrlObj, localVarQueryParameter);
+            let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
+            localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};
+            localVarRequestOptions.data = serializeDataIfNeeded(createWalletWebhookRequest, localVarRequestOptions, configuration)
+
+            return {
+                url: toPathString(localVarUrlObj),
+                options: localVarRequestOptions,
+            };
+        },
         /**
          * Create a new webhook
          * @summary Create a new webhook
@@ -9444,6 +9501,20 @@ export const WebhooksApiAxiosParamCreator = function (configuration?: Configurat
 export const WebhooksApiFp = function(configuration?: Configuration) {
     const localVarAxiosParamCreator = WebhooksApiAxiosParamCreator(configuration)
     return {
+        /**
+         * Create a new webhook scoped to a wallet
+         * @summary Create a new webhook scoped to a wallet
+         * @param {string} walletId The ID of the wallet to create the webhook for.
+         * @param {CreateWalletWebhookRequest} [createWalletWebhookRequest] 
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        async createWalletWebhook(walletId: string, createWalletWebhookRequest?: CreateWalletWebhookRequest, options?: RawAxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Webhook>> {
+            const localVarAxiosArgs = await localVarAxiosParamCreator.createWalletWebhook(walletId, createWalletWebhookRequest, options);
+            const localVarOperationServerIndex = configuration?.serverIndex ?? 0;
+            const localVarOperationServerBasePath = operationServerMap['WebhooksApi.createWalletWebhook']?.[localVarOperationServerIndex]?.url;
+            return (axios, basePath) => createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration)(axios, localVarOperationServerBasePath || basePath);
+        },
         /**
          * Create a new webhook
          * @summary Create a new webhook
@@ -9508,6 +9579,17 @@ export const WebhooksApiFp = function(configuration?: Configuration) {
 export const WebhooksApiFactory = function (configuration?: Configuration, basePath?: string, axios?: AxiosInstance) {
     const localVarFp = WebhooksApiFp(configuration)
     return {
+        /**
+         * Create a new webhook scoped to a wallet
+         * @summary Create a new webhook scoped to a wallet
+         * @param {string} walletId The ID of the wallet to create the webhook for.
+         * @param {CreateWalletWebhookRequest} [createWalletWebhookRequest] 
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        createWalletWebhook(walletId: string, createWalletWebhookRequest?: CreateWalletWebhookRequest, options?: RawAxiosRequestConfig): AxiosPromise<Webhook> {
+            return localVarFp.createWalletWebhook(walletId, createWalletWebhookRequest, options).then((request) => request(axios, basePath));
+        },
         /**
          * Create a new webhook
          * @summary Create a new webhook
@@ -9559,6 +9641,17 @@ export const WebhooksApiFactory = function (configuration?: Configuration, baseP
  * @interface WebhooksApi
  */
 export interface WebhooksApiInterface {
+    /**
+     * Create a new webhook scoped to a wallet
+     * @summary Create a new webhook scoped to a wallet
+     * @param {string} walletId The ID of the wallet to create the webhook for.
+     * @param {CreateWalletWebhookRequest} [createWalletWebhookRequest] 
+     * @param {*} [options] Override http request option.
+     * @throws {RequiredError}
+     * @memberof WebhooksApiInterface
+     */
+    createWalletWebhook(walletId: string, createWalletWebhookRequest?: CreateWalletWebhookRequest, options?: RawAxiosRequestConfig): AxiosPromise<Webhook>;
+
     /**
      * Create a new webhook
      * @summary Create a new webhook
@@ -9610,6 +9703,19 @@ export interface WebhooksApiInterface {
  * @extends {BaseAPI}
  */
 export class WebhooksApi extends BaseAPI implements WebhooksApiInterface {
+    /**
+     * Create a new webhook scoped to a wallet
+     * @summary Create a new webhook scoped to a wallet
+     * @param {string} walletId The ID of the wallet to create the webhook for.
+     * @param {CreateWalletWebhookRequest} [createWalletWebhookRequest] 
+     * @param {*} [options] Override http request option.
+     * @throws {RequiredError}
+     * @memberof WebhooksApi
+     */
+    public createWalletWebhook(walletId: string, createWalletWebhookRequest?: CreateWalletWebhookRequest, options?: RawAxiosRequestConfig) {
+        return WebhooksApiFp(this.configuration).createWalletWebhook(walletId, createWalletWebhookRequest, options).then((request) => request(this.axios, this.basePath));
+    }
+
     /**
      * Create a new webhook
      * @summary Create a new webhook

src/coinbase/types.ts

@@ -52,6 +52,8 @@ import {
   CreateSmartContractRequest,
   SmartContract as SmartContractModel,
   DeploySmartContractRequest,
+  WebhookEventTypeFilter,
+  CreateWalletWebhookRequest,
 } from "./../client/api";
 import { Address } from "./address";
 import { Wallet } from "./wallet";
@@ -1038,6 +1040,21 @@ export type ListHistoricalBalancesResult = {
 };
 
 export interface WebhookApiClient {
+  /**
+   * Create a new webhook for a wallet
+   *
+   * @summary Create a new webhook for a wallet
+   * @param {string} [walletId]
+   * @param {CreateWalletWebhookRequest} [createWalletWebhookRequest]
+   * @param {*} [options] - Override http request option.
+   * @throws {RequiredError}
+   */
+  createWalletWebhook(
+    walletId?: string,
+    createWalletWebhookRequest?: CreateWalletWebhookRequest,
+    options?: RawAxiosRequestConfig,
+  ): AxiosPromise<WebhookModel>;
+
   /**
    * Create a new webhook
    *
@@ -1187,6 +1204,7 @@ export type CreateWebhookOptions = {
   networkId: string;
   notificationUri: string;
   eventType: WebhookEventType;
+  eventTypeFilter?: WebhookEventTypeFilter;
   eventFilters?: Array<WebhookEventFilter>;
   signatureHeader?: string;
 };

src/coinbase/wallet.ts

@@ -39,6 +39,7 @@ import { StakingBalance } from "./staking_balance";
 import { PayloadSignature } from "./payload_signature";
 import { ContractInvocation } from "../coinbase/contract_invocation";
 import { SmartContract } from "./smart_contract";
+import { Webhook } from "./webhook";
 
 /**
  * A representation of a Wallet. Wallets come with a single default Address, but can expand to have a set of Addresses,
@@ -750,6 +751,21 @@ export class Wallet {
     return (await this.getDefaultAddress()).createPayloadSignature(unsignedPayload);
   }
 
+  /**
+   * Creates a Webhook for a wallet, monitors all wallet addresses for onchain events.
+   *
+   * @param notificationUri - The URI to which the webhook notifications will be sent.
+   *
+   * @returns The newly created webhook instance.
+   */
+  public async createWebhook(notificationUri: string): Promise<Webhook> {
+    const result = await Coinbase.apiClients.webhook!.createWalletWebhook(this.getId(), {
+      notification_uri: notificationUri,
+    });
+
+    return Webhook.init(result.data);
+  }
+
   /**
    * Invokes a contract with the given data.
    *

src/coinbase/webhook.ts

@@ -1,4 +1,9 @@
-import { Webhook as WebhookModel, WebhookEventType, WebhookEventFilter } from "../client/api";
+import {
+  Webhook as WebhookModel,
+  WebhookEventType,
+  WebhookEventFilter,
+  WebhookEventTypeFilter,
+} from "../client/api";
 import { Coinbase } from "./coinbase";
 import { CreateWebhookOptions } from "./types";
 
@@ -40,24 +45,23 @@ export class Webhook {
    * @param options.networkId - The network ID for which the webhook is created.
    * @param options.notificationUri - The URI where notifications should be sent.
    * @param options.eventType - The type of event for the webhook.
+   * @param options.eventTypeFilter - Filter for wallet activity event type.
    * @param options.eventFilters - Filters applied to the events that determine which specific events trigger the webhook.
-   * @param options.signatureHeader - The custom header to be used for x-webhook-signature header on callbacks,
-   *   so developers can verify the requests are coming from Coinbase.
    * @returns A promise that resolves to a new instance of Webhook.
    */
   public static async create({
     networkId,
     notificationUri,
     eventType,
+    eventTypeFilter,
     eventFilters = [],
-    signatureHeader = "",
   }: CreateWebhookOptions): Promise<Webhook> {
     const result = await Coinbase.apiClients.webhook!.createWebhook({
       network_id: networkId,
       notification_uri: notificationUri,
       event_type: eventType,
+      event_type_filter: eventTypeFilter,
       event_filters: eventFilters,
-      signature_header: signatureHeader,
     });
 
     return new Webhook(result.data);
@@ -131,6 +135,15 @@ export class Webhook {
     return this.model?.event_type;
   }
 
+  /**
+   * Returns the event type filter of the webhook.
+   *
+   * @returns The filter which will be used to filter for events of a certain event type
+   */
+  public getEventTypeFilter(): WebhookEventTypeFilter | undefined {
+    return this.model?.event_type_filter;
+  }
+
   /**
    * Returns the event filters applied to the webhook.
    *
@@ -186,6 +199,7 @@ export class Webhook {
     return (
       `Webhook { id: '${this.getId()}', networkId: '${this.getNetworkId()}', ` +
       `eventType: '${this.getEventType()}', eventFilter: ${JSON.stringify(this.getEventFilters())}, ` +
+      `eventTypeFilter: ${JSON.stringify(this.getEventTypeFilter())}, ` +
       `notificationUri: '${this.getNotificationURI()}', signatureHeader: '${this.getSignatureHeader()}' }`
     );
   }