feat(dal): create topic subscribers schema and entity

libs/dal/src/repositories/subscriber/subscriber.entity.ts

@@ -1,7 +1,9 @@
 import { ChatProviderIdEnum, PushProviderIdEnum } from '@novu/shared';
 
+export type SubscriberId = string;
+
 export class SubscriberEntity {
-  _id?: string;
+  _id?: SubscriberId;
 
   firstName: string;
 

libs/dal/src/repositories/topic/index.ts

@@ -1 +1,2 @@
 export * from './topic.entity';
+export * from './topic-subscribers.entity';

libs/dal/src/repositories/topic/topic-subscribers.entity.ts

@@ -0,0 +1,13 @@
+import { Types } from 'mongoose';
+
+import { EnvironmentId, OrganizationId, TopicId, UserId } from './topic.entity';
+
+import { SubscriberId } from '../subscriber/subscriber.entity';
+
+export class TopicSubscribersEntity {
+  _environmentId: EnvironmentId;
+  _organizationId: OrganizationId;
+  _userId: UserId;
+  topicId: TopicId;
+  subscribers: [SubscriberId];
+}

libs/dal/src/repositories/topic/topic-subscribers.schema.ts

@@ -0,0 +1,35 @@
+import * as mongoose from 'mongoose';
+import { Schema } from 'mongoose';
+
+import { TopicSubscribersEntity } from './topic-subscribers.entity';
+
+import { schemaOptions } from '../schema-default.options';
+
+const topicSubscribersSchema = new Schema(
+  {
+    _environmentId: {
+      type: Schema.Types.ObjectId,
+      ref: 'Environment',
+      index: true,
+      required: true,
+    },
+    _organizationId: {
+      type: Schema.Types.ObjectId,
+      ref: 'Organization',
+      index: true,
+      required: true,
+    },
+    _userId: {
+      type: Schema.Types.ObjectId,
+      ref: 'User',
+      index: true,
+      required: true,
+    },
+    subscribers: [{ type: Schema.Types.ObjectId, ref: 'Subscriber', required: true }],
+  },
+  schemaOptions
+);
+
+// eslint-disable-next-line @typescript-eslint/naming-convention
+export const TopicSubscribers =
+  mongoose.models.Topic || mongoose.model<TopicSubscribersEntity>('TopicSubscribers', topicSubscribersSchema);

libs/dal/src/repositories/topic/topic.entity.ts

@@ -1,10 +1,10 @@
 import { Types } from 'mongoose';
 
-type EnvironmentId = Types.ObjectId;
-type OrganizationId = Types.ObjectId;
-type TopicId = Types.ObjectId;
+export type EnvironmentId = Types.ObjectId;
+export type OrganizationId = Types.ObjectId;
+export type TopicId = Types.ObjectId;
 type TopicKey = string;
-type UserId = Types.ObjectId;
+export type UserId = Types.ObjectId;
 
 export class TopicEntity {
   _id: TopicId;