[PB-2050]: Feat/maintain data integrity

src/apps/main/config.ts

@@ -37,6 +37,7 @@ export interface AppStore {
   preferedLanguage?: string;
   preferedTheme?: string;
   virtualdriveWindowsLetter: string;
+  dataIntegrityMaintenance?: boolean;
 }
 
 const schema: Schema<AppStore> = {
@@ -103,6 +104,9 @@ const schema: Schema<AppStore> = {
   virtualdriveWindowsLetter: {
     type: 'string',
   },
+  dataIntegrityMaintenance: {
+    type: 'boolean',
+  },
 } as const;
 
 export const defaults: AppStore = {
@@ -127,6 +131,7 @@ export const defaults: AppStore = {
   preferedLanguage: '',
   preferedTheme: 'system',
   virtualdriveWindowsLetter: 'I',
+  dataIntegrityMaintenance: false,
 };
 
 const configStore = new Store({ schema, defaults });

src/apps/sync-engine/dependency-injection/files/FilesContainer.ts

@@ -15,6 +15,7 @@ import { FilePlaceholderConverter } from '../../../../context/virtual-drive/file
 import { FileSyncStatusUpdater } from '../../../../context/virtual-drive/files/application/FileSyncStatusUpdater';
 import { FileCheckerStatusInRoot } from '../../../../context/virtual-drive/files/application/FileCheckerStatusInRoot';
 import { FilesPlaceholderDeleter } from '../../../../context/virtual-drive/files/application/FilesPlaceholderDeleter';
+import { FileIdentityUpdater } from '../../../../context/virtual-drive/files/application/FileIndetityUpdater';
 
 export interface FilesContainer {
   fileFinderByContentsId: FileFinderByContentsId;
@@ -34,4 +35,5 @@ export interface FilesContainer {
   filePlaceholderConverter: FilePlaceholderConverter;
   fileSyncStatusUpdater: FileSyncStatusUpdater;
   filesCheckerStatusInRoot: FileCheckerStatusInRoot;
+  fileIdentityUpdater: FileIdentityUpdater;
 }

src/apps/sync-engine/dependency-injection/files/builder.ts

@@ -31,6 +31,7 @@ import { FileSyncStatusUpdater } from '../../../../context/virtual-drive/files/a
 import { FileContentsUpdater } from '../../../../context/virtual-drive/files/application/FileContentsUpdater';
 import { FileCheckerStatusInRoot } from '../../../../context/virtual-drive/files/application/FileCheckerStatusInRoot';
 import { FilesPlaceholderDeleter } from '../../../../context/virtual-drive/files/application/FilesPlaceholderDeleter';
+import { FileIdentityUpdater } from '../../../../context/virtual-drive/files/application/FileIndetityUpdater';
 
 export async function buildFilesContainer(
   folderContainer: FoldersContainer,
@@ -144,10 +145,13 @@ export async function buildFilesContainer(
     remoteFileSystem
   );
 
+  const fileIdentityUpdater = new FileIdentityUpdater(localFileSystem);
+
   const fileSyncronizer = new FileSyncronizer(
     repository,
     fileSyncStatusUpdater,
     filePlaceholderConverter,
+    fileIdentityUpdater,
     fileCreator,
     sharedContainer.absolutePathToRelativeConverter,
     folderContainer.folderCreator,
@@ -176,6 +180,7 @@ export async function buildFilesContainer(
     filePlaceholderConverter,
     fileSyncStatusUpdater,
     filesCheckerStatusInRoot,
+    fileIdentityUpdater,
   };
 
   return { container, subscribers: [] };

src/context/virtual-drive/files/application/FileIndetityUpdater.ts

@@ -0,0 +1,10 @@
+import { File } from '../domain/File';
+import { LocalFileSystem } from '../domain/file-systems/LocalFileSystem';
+
+export class FileIdentityUpdater {
+  constructor(private readonly localFileSystem: LocalFileSystem) {}
+
+  async run(file: File) {
+    await this.localFileSystem.updateFileIdentity(file.path, file.placeholderId);
+  }
+}

src/context/virtual-drive/files/application/FileSyncronizer.ts

@@ -15,6 +15,7 @@ import { File } from '../domain/File';
 import { FileSyncStatusUpdater } from './FileSyncStatusUpdater';
 import { FilePlaceholderConverter } from './FIlePlaceholderConverter';
 import { FileContentsUpdater } from './FileContentsUpdater';
+import { FileIdentityUpdater } from './FileIndetityUpdater';
 
 export class FileSyncronizer {
   // queue of files to be uploaded
@@ -23,6 +24,7 @@ export class FileSyncronizer {
     private readonly repository: FileRepository,
     private readonly fileSyncStatusUpdater: FileSyncStatusUpdater,
     private readonly filePlaceholderConverter: FilePlaceholderConverter,
+    private readonly fileIdentityUpdater: FileIdentityUpdater,
     private readonly fileCreator: FileCreator,
     private readonly absolutePathToRelativeConverter: AbsolutePathToRelativeConverter,
     private readonly folderCreator: FolderCreator,
@@ -148,6 +150,7 @@ export class FileSyncronizer {
   private async convertAndUpdateSyncStatus(file: File) {
     await Promise.all([
       this.filePlaceholderConverter.run(file),
+      this.fileIdentityUpdater.run(file),
       this.fileSyncStatusUpdater.run(file),
     ]);
   }

src/context/virtual-drive/files/domain/file-systems/LocalFileSystem.ts

@@ -19,4 +19,9 @@ export interface LocalFileSystem {
   getPlaceholderStateByRelativePath(
     relativePath: string
   ): Promise<PlaceholderState>;
+
+  updateFileIdentity(
+    path: File['path'],
+    newIdentity: string
+  ): Promise<void>;
 }

src/context/virtual-drive/files/infrastructure/InMemoryFileRepository.ts

@@ -92,10 +92,13 @@ export class InMemoryFileRepository implements FileRepository {
     if (!this.files.has(file.contentsId)) {
       throw new Error('File not found');
     }
-
+    const oldContentsId = file.contentsId;
     const updatedFile = file.replaceContestsAndSize(newContentsId, newSize);
+    // first delete the old file to be able to add the new one
+    this.files.delete(oldContentsId);
     this.files.set(updatedFile.contentsId, updatedFile.attributes());
-    this.files.delete(file.contentsId);
     return updatedFile;
   }
+
+
 }

src/context/virtual-drive/files/infrastructure/NodeWinLocalFileSystem.ts

@@ -5,6 +5,7 @@ import { LocalFileSystem } from '../domain/file-systems/LocalFileSystem';
 import { RelativePathToAbsoluteConverter } from '../../shared/application/RelativePathToAbsoluteConverter';
 import fs from 'fs/promises';
 import { PlaceholderState } from '../domain/PlaceholderState';
+import Logger from 'electron-log';
 
 export class NodeWinLocalFileSystem implements LocalFileSystem {
   constructor(
@@ -15,7 +16,7 @@ export class NodeWinLocalFileSystem implements LocalFileSystem {
   async getLocalFileId(file: File): Promise<`${string}-${string}`> {
     const win32AbsolutePath = this.relativePathToAbsoluteConverter.run(
       file.path
-    );
+      );
 
     const { ino, dev } = await fs.stat(win32AbsolutePath);
 
@@ -72,4 +73,10 @@ export class NodeWinLocalFileSystem implements LocalFileSystem {
       relativePath
     ) as Promise<PlaceholderState>;
   }
+
+  async updateFileIdentity(path: string, newIdentity: `${string}-${string}`): Promise<void> {
+      Logger.info('[updateFileIdentity]: ', path, newIdentity);
+      const isNotDirectory = true;
+      return this.virtualDrive.updateFileIdentity(path, newIdentity, isNotDirectory);
+  }
 }