lint

server/CHANGELOG.md

@@ -1,6 +1,6 @@
 # 1.3.0 (2024-04-25)
 
-- Support deletion syncing
+- Support deletion syncing (when a file is deleted in a source, the corresponding resource is deleted in the Nuclia Knowledge Box)
 
 # 1.2.21 (2024-04-18)
 

server/src/logic/connector/infrastructure/connectors/gdrive.connector.ts

@@ -275,6 +275,7 @@ export class GDriveImpl extends OAuthBaseConnector implements IConnector {
         } else {
           const nextPage = res['nextPageToken'];
           const items = (res.files || [])
+            // eslint-disable-next-line @typescript-eslint/no-explicit-any
             .filter((item: any) => !item.trashed)
             .map((item: unknown) => this.mapToSyncItem(item));
           const results = {

server/src/logic/sync/domain/sync.entity.ts

@@ -155,15 +155,14 @@ export class SyncEntity {
     const foldersToSyncUpdated: SyncItem[] = (this.foldersToSync ?? []).filter(
       (folder) => folder.status === FileStatus.UPLOADED,
     );
-    const getFilesFoldersUpdated =
-      foldersToSyncUpdated.length > 0
-        ? this.sourceConnector!.getLastModified(
-            this.lastSyncGMT || '2000-01-01T00:00:00.000Z',
-            foldersToSyncUpdated,
-            existings,
-          )
-        : of({ items: [] } as SearchResults);
-
+    let getFilesFoldersUpdated = of({ items: [] } as SearchResults);
+    if (foldersToSyncUpdated.length > 0) {
+      getFilesFoldersUpdated = this.sourceConnector!.getLastModified(
+        this.lastSyncGMT || '2000-01-01T00:00:00.000Z',
+        foldersToSyncUpdated,
+        existings,
+      );
+    }
     const getFilesFolderPending =
       foldersToSyncPending.length > 0
         ? this.sourceConnector!.getFilesFromFolders(foldersToSyncPending)

server/src/logic/sync/domain/use-cases/sync-all-folders-data.use-case.ts

@@ -1,5 +1,5 @@
 /* eslint-disable @typescript-eslint/no-explicit-any */
-import { concatMap, delay, filter, from, lastValueFrom, map, of, switchMap, tap, toArray } from 'rxjs';
+import { concatMap, delay, filter, from, lastValueFrom, map, of, switchMap, toArray } from 'rxjs';
 
 import { EVENTS } from '../../../../events/events';
 import { eventEmitter } from '../../../../server';