feat: add vault events

src/common/interfaces/event.interface.ts

@@ -54,6 +54,26 @@ import {
   FeatureFlag,
   FeatureFlagResponse,
 } from '../../feature-flags/interfaces';
+import {
+  VaultDataCreatedEventData,
+  VaultDataCreatedEventResponseData,
+  VaultDataUpdatedEventData,
+  VaultDataUpdatedEventResponseData,
+  VaultDataReadEventData,
+  VaultDataReadEventResponseData,
+  VaultDataDeletedEventData,
+  VaultDataDeletedEventResponseData,
+  VaultMetadataReadEventData,
+  VaultMetadataReadEventResponseData,
+  VaultNamesListedEventData,
+  VaultNamesListedEventResponseData,
+  VaultKekCreatedEventData,
+  VaultKekCreatedEventResponseData,
+  VaultDekReadEventData,
+  VaultDekReadEventResponseData,
+  VaultDekDecryptedEventData,
+  VaultDekDecryptedEventResponseData,
+} from '../../vault/interfaces/vault-event.interface';
 
 export interface EventBase {
   id: string;
@@ -732,6 +752,96 @@ export interface FlagRuleUpdatedEventResponse extends EventResponseBase {
   data: FeatureFlagResponse;
 }
 
+export interface VaultDataCreatedEvent extends EventBase {
+  event: 'vault.data.created';
+  data: VaultDataCreatedEventData;
+}
+
+export interface VaultDataCreatedEventResponse extends EventResponseBase {
+  event: 'vault.data.created';
+  data: VaultDataCreatedEventResponseData;
+}
+
+export interface VaultDataUpdatedEvent extends EventBase {
+  event: 'vault.data.updated';
+  data: VaultDataUpdatedEventData;
+}
+
+export interface VaultDataUpdatedEventResponse extends EventResponseBase {
+  event: 'vault.data.updated';
+  data: VaultDataUpdatedEventResponseData;
+}
+
+export interface VaultDataReadEvent extends EventBase {
+  event: 'vault.data.read';
+  data: VaultDataReadEventData;
+}
+
+export interface VaultDataReadEventResponse extends EventResponseBase {
+  event: 'vault.data.read';
+  data: VaultDataReadEventResponseData;
+}
+
+export interface VaultDataDeletedEvent extends EventBase {
+  event: 'vault.data.deleted';
+  data: VaultDataDeletedEventData;
+}
+
+export interface VaultDataDeletedEventResponse extends EventResponseBase {
+  event: 'vault.data.deleted';
+  data: VaultDataDeletedEventResponseData;
+}
+
+export interface VaultNamesListedEvent extends EventBase {
+  event: 'vault.names.listed';
+  data: VaultNamesListedEventData;
+}
+
+export interface VaultNamesListedEventResponse extends EventResponseBase {
+  event: 'vault.names.listed';
+  data: VaultNamesListedEventResponseData;
+}
+
+export interface VaultMetadataReadEvent extends EventBase {
+  event: 'vault.metadata.read';
+  data: VaultMetadataReadEventData;
+}
+
+export interface VaultMetadataReadEventResponse extends EventResponseBase {
+  event: 'vault.metadata.read';
+  data: VaultMetadataReadEventResponseData;
+}
+
+export interface VaultKekCreatedEvent extends EventBase {
+  event: 'vault.kek.created';
+  data: VaultKekCreatedEventData;
+}
+
+export interface VaultKekCreatedEventResponse extends EventResponseBase {
+  event: 'vault.kek.created';
+  data: VaultKekCreatedEventResponseData;
+}
+
+export interface VaultDekReadEvent extends EventBase {
+  event: 'vault.dek.read';
+  data: VaultDekReadEventData;
+}
+
+export interface VaultDekReadEventResponse extends EventResponseBase {
+  event: 'vault.dek.read';
+  data: VaultDekReadEventResponseData;
+}
+
+export interface VaultDekDecryptedEvent extends EventBase {
+  event: 'vault.dek.decrypted';
+  data: VaultDekDecryptedEventData;
+}
+
+export interface VaultDekDecryptedEventResponse extends EventResponseBase {
+  event: 'vault.dek.decrypted';
+  data: VaultDekDecryptedEventResponseData;
+}
+
 export type Event =
   | AuthenticationEmailVerificationSucceededEvent
   | AuthenticationMfaSucceededEvent
@@ -797,7 +907,16 @@ export type Event =
   | FlagCreatedEvent
   | FlagUpdatedEvent
   | FlagDeletedEvent
-  | FlagRuleUpdatedEvent;
+  | FlagRuleUpdatedEvent
+  | VaultDataCreatedEvent
+  | VaultDataUpdatedEvent
+  | VaultDataReadEvent
+  | VaultDataDeletedEvent
+  | VaultNamesListedEvent
+  | VaultMetadataReadEvent
+  | VaultKekCreatedEvent
+  | VaultDekReadEvent
+  | VaultDekDecryptedEvent;
 
 export type EventResponse =
   | AuthenticationEmailVerificationSucceededEventResponse
@@ -864,6 +983,15 @@ export type EventResponse =
   | FlagCreatedEventResponse
   | FlagUpdatedEventResponse
   | FlagDeletedEventResponse
-  | FlagRuleUpdatedEventResponse;
+  | FlagRuleUpdatedEventResponse
+  | VaultDataCreatedEventResponse
+  | VaultDataUpdatedEventResponse
+  | VaultDataReadEventResponse
+  | VaultDataDeletedEventResponse
+  | VaultNamesListedEventResponse
+  | VaultMetadataReadEventResponse
+  | VaultKekCreatedEventResponse
+  | VaultDekReadEventResponse
+  | VaultDekDecryptedEventResponse;
 
 export type EventName = Event['event'];

src/common/serializers/event.serializer.ts

@@ -26,6 +26,17 @@ import { deserializeApiKey } from '../../api-keys/serializers/api-key.serializer
 import { deserializeOrganizationRoleEvent } from '../../authorization/serializers/organization-role.serializer';
 import { deserializePermission } from '../../authorization/serializers/permission.serializer';
 import { deserializeFeatureFlag } from '../../feature-flags/serializers/feature-flag.serializer';
+import {
+  deserializeVaultDataCreatedEvent,
+  deserializeVaultDataUpdatedEvent,
+  deserializeVaultDataReadEvent,
+  deserializeVaultDataDeletedEvent,
+  deserializeVaultNamesListedEvent,
+  deserializeVaultMetadataReadEvent,
+  deserializeVaultKekCreatedEvent,
+  deserializeVaultDekReadEvent,
+  deserializeVaultDekDecryptedEvent,
+} from '../../vault/serializers/vault-event.serializer';
 
 export const deserializeEvent = (event: EventResponse): Event => {
   const eventBase: EventBase = {
@@ -224,5 +235,59 @@ export const deserializeEvent = (event: EventResponse): Event => {
         event: event.event,
         data: deserializeFeatureFlag(event.data),
       };
+    case 'vault.data.created':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultDataCreatedEvent(event.data),
+      };
+    case 'vault.data.updated':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultDataUpdatedEvent(event.data),
+      };
+    case 'vault.data.read':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultDataReadEvent(event.data),
+      };
+    case 'vault.data.deleted':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultDataDeletedEvent(event.data),
+      };
+    case 'vault.names.listed':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultNamesListedEvent(event.data),
+      };
+    case 'vault.metadata.read':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultMetadataReadEvent(event.data),
+      };
+    case 'vault.kek.created':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultKekCreatedEvent(event.data),
+      };
+    case 'vault.dek.read':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultDekReadEvent(event.data),
+      };
+    case 'vault.dek.decrypted':
+      return {
+        ...eventBase,
+        event: event.event,
+        data: deserializeVaultDekDecryptedEvent(event.data),
+      };
   }
 };