feat: add user preference change to event log

Unleash · Nov 5, 2024 · c402d39 · c402d39
1 parent 1897f8a
commit c402d39
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 15 deletions.
diff --git a/src/lib/features/user-subscriptions/user-subscriptions-service.ts b/src/lib/features/user-subscriptions/user-subscriptions-service.ts
@@ -1,4 +1,8 @@
-import type { IUnleashConfig, IUnleashStores } from '../../types';
+import {
+    UserPreferenceEvent,
+    type IUnleashConfig,
+    type IUnleashStores,
+} from '../../types';
 import type { Logger } from '../../logger';
 import type { IAuditUser } from '../../types/user';
 import type {
@@ -35,13 +39,13 @@ export default class UserSubscriptionService {
         };
 
         await this.userUnsubscribeStore.delete(entry);
-        // TODO: log an event
-        // await this.eventService.storeEvent(
-        //     new UserSubscriptionEvent({
-        //         data: { ...entry, action: 'subscribed' },
-        //         auditUser,
-        //     }),
-        // );
+        await this.eventService.storeEvent(
+            new UserPreferenceEvent({
+                userId,
+                data: { subscription, action: 'subscribed' },
+                auditUser,
+            }),
+        );
     }
 
     async unsubscribe(
@@ -55,12 +59,12 @@ export default class UserSubscriptionService {
         };
 
         await this.userUnsubscribeStore.insert(entry);
-        // TODO: log an event
-        // await this.eventService.storeEvent(
-        //     new UserSubscriptionEvent({
-        //         data: { ...entry, action: 'unsubscribed' },
-        //         auditUser,
-        //     }),
-        // );
+        await this.eventService.storeEvent(
+            new UserPreferenceEvent({
+                userId,
+                data: { subscription, action: 'unsubscribed' },
+                auditUser,
+            }),
+        );
     }
 }
diff --git a/src/lib/types/events.ts b/src/lib/types/events.ts
@@ -204,6 +204,8 @@ export const ACTIONS_CREATED = 'actions-created' as const;
 export const ACTIONS_UPDATED = 'actions-updated' as const;
 export const ACTIONS_DELETED = 'actions-deleted' as const;
 
+export const USER_PREFERENCE_UPDATED = 'user-preference-updated' as const;
+
 export const IEventTypes = [
     APPLICATION_CREATED,
     FEATURE_CREATED,
@@ -351,6 +353,7 @@ export const IEventTypes = [
     ACTIONS_CREATED,
     ACTIONS_UPDATED,
     ACTIONS_DELETED,
+    USER_PREFERENCE_UPDATED,
 ] as const;
 export type IEventType = (typeof IEventTypes)[number];
 
@@ -2024,3 +2027,18 @@ function mapUserToData(user: IUserEventData): any {
         rootRole: user.rootRole,
     };
 }
+
+export class UserPreferenceEvent extends BaseEvent {
+    readonly userId;
+    readonly data: any;
+
+    constructor(eventData: {
+        userId: number;
+        data: any;
+        auditUser: IAuditUser;
+    }) {
+        super(USER_PREFERENCE_UPDATED, eventData.auditUser);
+        this.userId = eventData.userId;
+        this.data = eventData.data;
+    }
+}