Merge pull request novuhq#4004 from novuhq/execution-detail-no-write-…

…concern feat: execution detail no write concern
Basfar · Aug 22, 2023 · 602f83b · 602f83b
2 parents 53d2acd + fa84003
commit 602f83b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/apps/webhook/src/webhooks/usecases/execution-details/create-execution-details.usecase.ts b/apps/webhook/src/webhooks/usecases/execution-details/create-execution-details.usecase.ts
@@ -19,7 +19,7 @@ export class CreateExecutionDetails {
       command.channel
     );
 
-    await this.executionDetailsRepository.create(executionDetailsEntity);
+    await this.executionDetailsRepository.create(executionDetailsEntity, { writeConcern: 1 });
   }
 
   private mapWebhookEventIntoEntity(

diff --git a/libs/dal/src/repositories/base-repository.ts b/libs/dal/src/repositories/base-repository.ts
@@ -109,13 +109,16 @@ export class BaseRepository<T_DBModel, T_MappedEntity, T_Enforcement = object> {
     }
   }
 
-  async create(data: FilterQuery<T_DBModel> & T_Enforcement): Promise<T_MappedEntity> {
+  async create(data: FilterQuery<T_DBModel> & T_Enforcement, options: IOptions = {}): Promise<T_MappedEntity> {
     const expireAt = this.calcExpireDate(this.MongooseModel.modelName, data);
     if (expireAt) {
       data = { ...data, expireAt };
     }
     const newEntity = new this.MongooseModel(data);
-    const saved = await newEntity.save();
+
+    const saveOptions = options?.writeConcern ? { w: options?.writeConcern } : {};
+
+    const saved = await newEntity.save(saveOptions);
 
     return this.mapEntity(saved);
   }
@@ -175,3 +178,7 @@ export class BaseRepository<T_DBModel, T_MappedEntity, T_Enforcement = object> {
     return plainToInstance<T_MappedEntity, T_MappedEntity[]>(this.entity, JSON.parse(JSON.stringify(data)));
   }
 }
+
+interface IOptions {
+  writeConcern?: number | 'majority';
+}