Merge pull request #3813 from novuhq/v0.16.x

v0.16.4
novuhq · Jul 18, 2023 · 2a0d0f4 · 2a0d0f4
2 parents e6bac1c + 11d5ee7
commit 2a0d0f4
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 2 deletions.
diff --git a/packages/node/src/lib/subscribers/subscriber.interface.ts b/packages/node/src/lib/subscribers/subscriber.interface.ts
@@ -31,6 +31,7 @@ export interface ISubscribers {
   );
   getUnseenCount(subscriberId: string, seen: boolean);
   markMessageSeen(subscriberId: string, messageId: string);
+  markMessageRead(subscriberId: string, messageId: string);
   markMessageActionSeen(subscriberId: string, messageId: string, type: string);
 }
 

diff --git a/packages/node/src/lib/subscribers/subscribers.spec.ts b/packages/node/src/lib/subscribers/subscribers.spec.ts
@@ -207,7 +207,20 @@ describe('test use of novus node package - Subscribers class', () => {
 
     expect(mockedAxios.post).toHaveBeenCalled();
     expect(mockedAxios.post).toHaveBeenCalledWith(
-      '/subscribers/test-message-seen/messages/message-123/seen'
+      '/subscribers/test-message-seen/messages/markAs',
+      { mark: { seen: true }, messageId: 'message-123' }
+    );
+  });
+
+  test('should mark subscriber feed message as read', async () => {
+    mockedAxios.post.mockResolvedValue({});
+
+    await novu.subscribers.markMessageRead('test-message-read', 'message-123');
+
+    expect(mockedAxios.post).toHaveBeenCalled();
+    expect(mockedAxios.post).toHaveBeenCalledWith(
+      '/subscribers/test-message-read/messages/markAs',
+      { mark: { read: true }, messageId: 'message-123' }
     );
   });
 

diff --git a/packages/node/src/lib/subscribers/subscribers.ts b/packages/node/src/lib/subscribers/subscribers.ts
@@ -102,7 +102,15 @@ export class Subscribers extends WithHttp implements ISubscribers {
 
   async markMessageSeen(subscriberId: string, messageId: string) {
     return await this.http.post(
-      `/subscribers/${subscriberId}/messages/${messageId}/seen`
+      `/subscribers/${subscriberId}/messages/markAs`,
+      { messageId, mark: { seen: true } }
+    );
+  }
+
+  async markMessageRead(subscriberId: string, messageId: string) {
+    return await this.http.post(
+      `/subscribers/${subscriberId}/messages/markAs`,
+      { messageId, mark: { read: true } }
     );
   }