chore: forward notify message to notify notification (#110)

* chore: forward notify message to notify notification

* chore: fix typo

* test: update unit test to reflect changes

* chore: run prettier

* chore: bump version

Author: devceline

package-lock.json

@@ -1,7 +1,7 @@
 {
   "name": "@walletconnect/notify-client",
   "description": "WalletConnect Notify Client",
-  "version": "1.1.3",
+  "version": "1.1.4",
   "author": "WalletConnect, Inc. <walletconnect.com>",
   "homepage": "https://github.com/walletconnect/notify-client-js/",
   "license": "Apache-2.0",

packages/notify-client/package.json

@@ -903,6 +903,11 @@ export class NotifyEngine extends INotifyEngine {
         topic,
         params: { message: messageClaims.msg },
       });
+      this.client.emit("notify_notification", {
+        id: payload.id,
+        topic,
+        params: { notification: messageClaims.msg },
+      });
     };
 
   protected onNotifyMessageResponse: INotifyEngine["onNotifyMessageResponse"] =

packages/notify-client/src/controllers/engine.ts

@@ -17,6 +17,7 @@ export declare namespace NotifyClientTypes {
   type Event =
     | "notify_subscription"
     | "notify_message"
+    | "notify_notification"
     | "notify_delete"
     | "notify_update"
     | "notify_subscriptions_changed";
@@ -34,6 +35,10 @@ export declare namespace NotifyClientTypes {
     message: NotifyClientTypes.NotifyNotification;
   };
 
+  type NotifyNotificationRequestEventArgs = {
+    notification: NotifyClientTypes.NotifyNotification;
+  };
+
   type NotifyDeleteRequestEventArgs = { id: number; topic: string };
 
   interface BaseEventArgs<T = unknown> {
@@ -49,6 +54,7 @@ export declare namespace NotifyClientTypes {
       }
     >;
     notify_message: BaseEventArgs<NotifyMessageRequestEventArgs>;
+    notify_notification: BaseEventArgs<NotifyNotificationRequestEventArgs>;
     notify_delete: BaseEventArgs<NotifyResponseEventArgs>;
     notify_update: BaseEventArgs<
       NotifyResponseEventArgs & {

packages/notify-client/src/types/client.ts

@@ -261,19 +261,29 @@ describe("Notify", () => {
           let gotNotifyMessageResponse = false;
           let notifyMessageEvent: any;
 
+          let gotNotifyNotificationResponse = false;
+          let notifyNotificationEvent: any;
+
           wallet.once("notify_message", (event) => {
             console.log("notify_message", event);
             gotNotifyMessageResponse = true;
             notifyMessageEvent = event;
           });
 
+          wallet.once("notify_notification", (event) => {
+            gotNotifyNotificationResponse = true;
+            notifyNotificationEvent = event;
+          });
+
           const sendResponse = await sendNotifyMessage(account, "Test");
 
           expect(sendResponse.status).toBe(200);
 
           await waitForEvent(() => gotNotifyMessageResponse);
+          await waitForEvent(() => gotNotifyNotificationResponse);
 
           expect(notifyMessageEvent.params.message.body).toBe("Test");
+          expect(notifyNotificationEvent.params.notification.body).toBe("Test");
         });
 
         it("reads the dapp's did.json from memory after the initial fetch", async () => {