feat(headless): add remove notifications method

packages/client/src/api/api.service.ts

@@ -71,6 +71,12 @@ export class ApiService {
     return await this.httpClient.delete(`/widgets/messages/${messageId}`, {});
   }
 
+  async removeMessages(messageId: string[]): Promise<any> {
+    return await this.httpClient.post(`/widgets/messages/bulk/delete`, {
+      messageId: messageId,
+    });
+  }
+
   async removeAllMessages(feedId?: string): Promise<any> {
     const url = feedId
       ? `/widgets/messages?feedId=${feedId}`

packages/headless/src/lib/headless.service.ts

@@ -38,6 +38,7 @@ import {
   IUpdateUserPreferencesVariables,
   IUpdateUserGlobalPreferencesVariables,
   UpdateResult,
+  EmptyObject,
 } from './types';
 
 export const NOTIFICATION_CENTER_TOKEN_KEY = 'nc_token';
@@ -806,6 +807,53 @@ export class HeadlessService {
       });
   }
 
+  public async removeNotifications({
+    messageIds,
+    listener,
+    onSuccess,
+    onError,
+  }: {
+    messageIds: string[];
+    listener: (
+      result: UpdateResult<EmptyObject, unknown, { messageIds: string[] }>
+    ) => void;
+    onSuccess?: (obj: EmptyObject) => void;
+    onError?: (error: unknown) => void;
+  }) {
+    this.assertSessionInitialized();
+
+    const { result, unsubscribe } = this.queryService.subscribeMutation<
+      EmptyObject,
+      unknown,
+      { messageIds: string[] }
+    >({
+      options: {
+        mutationFn: (variables) =>
+          this.api.removeMessages(variables.messageIds),
+        onSuccess: (data) => {
+          this.queryClient.refetchQueries(NOTIFICATIONS_QUERY_KEY, {
+            exact: false,
+          });
+        },
+      },
+      listener: (res) => this.callUpdateListener(res, listener),
+    });
+
+    result
+      .mutate({ messageIds })
+      .then((data) => {
+        onSuccess?.(data);
+
+        return data;
+      })
+      .catch((error) => {
+        onError?.(error);
+      })
+      .finally(() => {
+        unsubscribe();
+      });
+  }
+
   public async updateAction({
     messageId,
     actionButtonType,

packages/headless/src/lib/types.ts

@@ -77,3 +77,4 @@ export type UpdateResult<
 
 export type IMessageId = string | string[];
 export type IFeedId = string | string[];
+export type EmptyObject = Record<string, never>;