[sc-8741] Allow to activate or deactivate a sync

nuclia · Mar 18, 2024 · 128dd9b · 128dd9b
1 parent e6e9da5
commit 128dd9b
Show file tree

Hide file tree

Showing 6 changed files with 12 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "nuclia-sync-agent-app",
-  "version": "1.2.2",
+  "version": "1.2.3",
   "description": "\"This is a Nuclia Sync Agent App\"",
   "main": "build/index.js",
   "scripts": {

diff --git a/server/CHANGELOG.md b/server/CHANGELOG.md
@@ -1,3 +1,7 @@
+# 1.2.3 (2024-03-18)
+
+- Allow to activate/deactivate a sync
+
 # 1.2.2 (2024-03-15)
 
 - Check mimetype of the uploaded links to create either a link or a file

diff --git a/server/src/logic/sync/domain/dto/create-sync.dto.ts b/server/src/logic/sync/domain/dto/create-sync.dto.ts
@@ -14,6 +14,7 @@ export class CreateSyncDto {
       title: this.options.title,
       id: this.options.id,
       filters: this.options.filters,
+      disabled: this.options.disabled,
     };
 
     if (this.options.labels) returnObj.labels = this.options.labels;

diff --git a/server/src/logic/sync/domain/dto/update-sync.dto.ts b/server/src/logic/sync/domain/dto/update-sync.dto.ts
@@ -19,6 +19,7 @@ export class UpdateSyncDto {
     if (this.options.lastSyncGMT) returnObj.lastSyncGMT = this.options.lastSyncGMT;
     if (this.options.foldersToSync) returnObj.foldersToSync = this.options.foldersToSync;
     if (this.options.filters) returnObj.filters = this.options.filters;
+    if (this.options.disabled !== undefined) returnObj.disabled = this.options.disabled;
 
     return returnObj;
   }

diff --git a/server/src/logic/sync/domain/sync.entity.ts b/server/src/logic/sync/domain/sync.entity.ts
@@ -71,6 +71,7 @@ export interface ISyncEntity {
   lastSyncGMT?: string;
   foldersToSync?: SyncItem[];
   filters?: Filters;
+  disabled?: boolean;
 }
 
 export class SyncEntity {
@@ -83,9 +84,10 @@ export class SyncEntity {
   public lastSyncGMT?: string;
   public foldersToSync?: SyncItem[] = [];
   public filters?: Filters;
+  public disabled?: boolean;
 
   constructor(options: ISyncEntity) {
-    const { connector, kb, labels, title, id, lastSyncGMT, foldersToSync, filters } = options;
+    const { connector, kb, labels, title, id, lastSyncGMT, foldersToSync, filters, disabled } = options;
     this.connector = connector;
     this.kb = kb;
     this.labels = labels;
@@ -94,6 +96,7 @@ export class SyncEntity {
     this.lastSyncGMT = lastSyncGMT;
     this.foldersToSync = foldersToSync;
     this.filters = filters;
+    this.disabled = disabled;
     this.setConnectorDefinition();
   }
 

diff --git a/server/src/logic/sync/domain/use-cases/sync-all-folders-data.use-case.ts b/server/src/logic/sync/domain/use-cases/sync-all-folders-data.use-case.ts
@@ -106,7 +106,7 @@ export class SyncAllFolders implements SyncAllFoldersUseCase {
 
   async execute() {
     const syncObjects = await this.repository.getAllSync();
-    const syncObjectValues = Object.values(syncObjects);
+    const syncObjectValues = Object.values(syncObjects).filter((sync) => !sync.disabled);
     if (syncObjectValues.length > 0) {
       await lastValueFrom(
         of(...syncObjectValues).pipe(