[PB-1737]: Feat/rebranding

package.json

@@ -1,11 +1,11 @@
 {
   "name": "internxt-drive",
-  "version": "2.0.6",
+  "version": "2.0.9",
   "author": "Internxt <[email protected]>",
   "description": "Internxt Drive client UI",
   "license": "AGPL-3.0",
   "repository": {
-    "url": "https://github.com/internxt/drive-desktop"
+    "url": "https://github.com/internxt/pc-cloud"
   },
   "scripts": {
     "build": "concurrently \"npm run build:main\" \"npm run build:renderer\" \"npm run build:sync-engine\"",
@@ -46,7 +46,7 @@
     ]
   },
   "build": {
-    "productName": "Internxt Drive",
+    "productName": "PC Cloud",
     "beforeBuild": "./beforeBuild.js",
     "appId": "com.internxt.drive",
     "asar": true,
@@ -107,7 +107,7 @@
     },
     "directories": {
       "app": "release/app",
-      "buildResources": "assets",
+      "buildResources": "assets/brands/pc-cloud",
       "output": "release/build"
     },
     "extraResources": [

release/app/package.json

@@ -1,6 +1,6 @@
 {
   "name": "internxt-drive",
-  "version": "2.0.6",
+  "version": "2.0.9",
   "description": "Internxt Drive client UI",
   "main": "./dist/main/main.js",
   "author": "Internxt <[email protected]>",

release/app/yarn.lock

@@ -1066,7 +1066,7 @@ uuid@^9.0.0:
   resolved "https://registry.npmjs.org/uuid/-/uuid-9.0.0.tgz"
   integrity sha512-MXcSTerfPa4uqyzStbRoTgt5XIe3x5+42+q1sDuy3R5MDk66URdLMOZe5aPX/SQd+kuYAh0FdP/pO28IkQyTeg==
 
-virtual-drive@../../../../node-win:
+virtual-drive@../../../node-win:
   version "1.0.1"
   dependencies:
     dotenv "^16.4.1"

src/apps/main/auto-launch/service.ts

@@ -7,7 +7,7 @@ import {
 } from './linux-desktop-entry';
 
 const appFolder = Path.dirname(process.execPath);
-const appExe = Path.resolve(appFolder, 'Internxt Drive.exe');
+const appExe = Path.resolve(appFolder, 'Pc Cloud.exe');
 const exeName = Path.basename(process.execPath);
 
 const path = process.platform === 'win32' ? appExe : undefined;

src/apps/main/background-processes/sync-engine.ts

@@ -3,6 +3,7 @@
 import Logger from 'electron-log';
 import eventBus from '../event-bus';
 import nodeSchedule from 'node-schedule';
+import * as Sentry from '@sentry/electron/main';
 
 let worker: BrowserWindow | null = null;
 let workerIsRunning = false;
@@ -45,7 +46,7 @@
         Logger.warn('Health check failed, relaunching the worker');
         workerIsRunning = false;
         worker?.destroy();
         spawnSyncEngineWorker();
       });
 
   healthCheckSchedule = nodeSchedule.scheduleJob('*/30 * * * * *', async () => {
@@ -85,6 +86,7 @@
     })
     .catch((err) => {
       Logger.error('[MAIN] Error loading sync engine worker', err);
+      Sentry.captureException(err);
     });
 
   worker.on('close', () => {
@@ -125,6 +127,7 @@
   const stopPromise = new Promise<void>((resolve, reject) => {
     ipcMain.once('SYNC_ENGINE_STOP_ERROR', (_, error: Error) => {
       Logger.error('[MAIN] Error stopping sync engine worker', error);
+      Sentry.captureException(error);
       reject(error);
     });
 
@@ -151,6 +154,7 @@
   } catch (err) {
     // TODO: handle error
     Logger.error(err);
+    Sentry.captureException(err);
   } finally {
     worker?.destroy();
     workerIsRunning = false;
@@ -175,6 +179,7 @@
       'ERROR_ON_STOP_AND_CLEAR_SYNC_ENGINE_PROCESS',
       (_, error: Error) => {
         Logger.error('[MAIN] Error stopping sync engine worker', error);
+        Sentry.captureException(error);
         reject(error);
       }
     );
@@ -202,6 +207,7 @@
   } catch (err) {
     // TODO: handle error
     Logger.error(err);
+    Sentry.captureException(err);
   } finally {
     worker?.destroy();
     workerIsRunning = false;
@@ -215,6 +221,15 @@
   } catch (err) {
     // TODO: handle error
     Logger.error(err);
+    Sentry.captureException(err);
+  }
+}
+
+export function fallbackSyncEngine() {
+  try {
+    worker?.webContents.send('FALLBACK_SYNC_ENGINE_PROCESS');
+  } catch (err) {
+    Logger.error(err);
   }
 }
 

src/apps/main/logger.ts

@@ -16,7 +16,7 @@ if (process.env.NODE_ENV !== 'development') {
 // Handle open logs
 
 ipcMain.on('open-logs', () => {
-  const logfilePath = log.transports.file.getFile().path;
-  const logFolderPath = path.dirname(logfilePath);
+  const logFilePath = log.transports.file.getFile().path;
+  const logFolderPath = path.dirname(logFilePath);
   shell.openPath(logFolderPath);
 });

src/apps/main/main.ts

@@ -54,6 +54,12 @@ import { setCleanUpFunction } from './quit';
 import { stopSyncEngineWatcher } from './background-processes/sync-engine';
 import { Theme } from '../shared/types/Theme';
 
+const gotTheLock = app.requestSingleInstanceLock();
+
+if (!gotTheLock) {
+  app.quit();
+}
+
 Logger.log(`Running ${packageJson.version}`);
 
 Logger.log('Initializing Sentry for main process');
@@ -73,10 +79,6 @@ function checkForUpdates() {
   autoUpdater.checkForUpdatesAndNotify();
 }
 
-if (process.platform === 'darwin') {
-  app.dock.hide();
-}
-
 if (process.env.NODE_ENV === 'production') {
   // eslint-disable-next-line @typescript-eslint/no-var-requires
   const sourceMapSupport = require('source-map-support');

src/apps/main/preload.d.ts

@@ -167,5 +167,7 @@ declare interface Window {
     startRemoteSync: () => Promise<void>;
     openUrl: (url: string) => Promise<void>;
     getPreferredAppLanguage: () => Promise<Array<string>>;
+    syncManually: () => Promise<void>;
+    getRecentlywasSyncing: () => Promise<boolean>;
   };
 }

src/apps/main/preload.js

@@ -296,5 +296,12 @@ contextBridge.exposeInMainWorld('electron', {
   getPreferredAppLanguage() {
     return ipcRenderer.invoke('APP:PREFERRED_LANGUAGE');
   },
+  syncManually() {
+    return ipcRenderer.invoke('SYNC_MANUALLY');
+  },
+  getRecentlywasSyncing()  {
+    return ipcRenderer.invoke('CHECK_SYNC_IN_PROGRESS');
+  },
+
   path,
 });

src/apps/main/realtime.ts

@@ -3,6 +3,7 @@ import { io, Socket } from 'socket.io-client';
 import { obtainToken } from './auth/service';
 import eventBus from './event-bus';
 import { broadcastToWindows } from './windows';
+import { reportError } from '../renderer/utils/errors';
 
 type XHRRequest = {
   getResponseHeader: (headerName: string) => string[] | null;
@@ -57,6 +58,7 @@ function cleanAndStartRemoteNotifications() {
 
   socket.on('connect_error', (error) => {
     logger.error('❌ Remote notifications connect error: ', error);
+    reportError(error);
   });
 
   socket.on('event', (data) => {

src/apps/main/remote-sync/RemoteSyncManager.ts

@@ -6,6 +6,7 @@ import {
   RemoteSyncedFile,
   SyncConfig,
   SYNC_OFFSET_MS,
+  WAITING_AFTER_SYNCING
 } from './helpers';
 import { reportError } from '../bug-report/service';
 
@@ -24,6 +25,8 @@ export class RemoteSyncManager {
   > = [];
   private totalFilesSynced = 0;
   private totalFoldersSynced = 0;
+  private lastSyncingFinishedTimestamp: Date | null = null;
+
   constructor(
     private db: {
       files: DatabaseCollectionAdapter<DriveFile>;
@@ -47,10 +50,15 @@ export class RemoteSyncManager {
     if (typeof callback !== 'function') return;
     this.onStatusChangeCallbacks.push(callback);
   }
+
   getSyncStatus(): RemoteSyncStatus {
     return this.status;
   }
 
+  private getLastSyncingFinishedTimestamp() {
+    return this.lastSyncingFinishedTimestamp;
+  }
+
   /**
    * Check if the RemoteSyncManager is in SYNCED status
    *
@@ -60,10 +68,22 @@ export class RemoteSyncManager {
     return this.status === 'SYNCED';
   }
 
+  /**
+   * Consult if recently the RemoteSyncManager was syncing
+   * @returns True if the RemoteSyncManager was syncing recently
+   * @returns False if the RemoteSyncManager was not syncing recently
+   */
+  recentlyWasSyncing() {
+    const passedTime = Date.now() - ( this.getLastSyncingFinishedTimestamp()?.getTime() ?? Date.now() );
+    return passedTime < WAITING_AFTER_SYNCING;
+  }
+
   resetRemoteSync() {
     this.changeStatus('IDLE');
     this.filesSyncStatus = 'IDLE';
     this.foldersSyncStatus = 'IDLE';
+    this._placeholdersStatus = 'IDLE';
+    this.lastSyncingFinishedTimestamp = null;
     this.totalFilesSynced = 0;
     this.totalFoldersSynced = 0;
   }
@@ -148,6 +168,7 @@ export class RemoteSyncManager {
     return true;
   }
   private changeStatus(newStatus: RemoteSyncStatus) {
+    this.addLastSyncingFinishedTimestamp();
     if (newStatus === this.status) return;
     Logger.info(`RemoteSyncManager ${this.status} -> ${newStatus}`);
     this.status = newStatus;
@@ -157,6 +178,12 @@ export class RemoteSyncManager {
     });
   }
 
+  private addLastSyncingFinishedTimestamp() {
+    if (this.status !== 'SYNCING') return;
+    Logger.info('Adding last syncing finished timestamp');
+    this.lastSyncingFinishedTimestamp = new Date();
+  }
+
   private checkRemoteSyncStatus() {
     if (this._placeholdersStatus === 'SYNCING') {
       this.changeStatus('SYNCING');

src/apps/main/remote-sync/handlers.ts

@@ -2,14 +2,17 @@ import eventBus from '../event-bus';
 import { RemoteSyncManager } from './RemoteSyncManager';
 import { DriveFilesCollection } from '../database/collections/DriveFileCollection';
 import { DriveFoldersCollection } from '../database/collections/DriveFolderCollection';
-import { clearRemoteSyncStore } from './helpers';
+import { clearRemoteSyncStore, RemoteSyncStatus } from './helpers';
 import { getNewTokenClient } from '../../shared/HttpClient/main-process-client';
 import Logger from 'electron-log';
 import { ipcMain } from 'electron';
 import { reportError } from '../bug-report/service';
 import { sleep } from '../util';
 import { broadcastToWindows } from '../windows';
-import { updateSyncEngine } from '../background-processes/sync-engine';
+import {
+  updateSyncEngine,
+  fallbackSyncEngine,
+} from '../background-processes/sync-engine';
 
 let initialSyncReady = false;
 const driveFilesCollection = new DriveFilesCollection();
@@ -77,14 +80,27 @@ ipcMain.handle('get-remote-sync-status', () =>
   remoteSyncManager.getSyncStatus()
 );
 
-eventBus.on('RECEIVED_REMOTE_CHANGES', async () => {
+export async function updateRemoteSync(): Promise<void> {
   // Wait before checking for updates, could be possible
   // that we received the notification, but if we check
   // for new data we don't receive it
   await sleep(2_000);
-
   await remoteSyncManager.startRemoteSync();
   updateSyncEngine();
+}
+export async function fallbackRemoteSync(): Promise<void> {
+  await sleep(2_000);
+  fallbackSyncEngine();
+}
+
+ipcMain.handle('SYNC_MANUALLY', async () => {
+  Logger.info('[Manual Sync] Received manual sync event');
+  await updateRemoteSync();
+  await fallbackRemoteSync();
+});
+
+eventBus.on('RECEIVED_REMOTE_CHANGES', async () => {
+  await updateRemoteSync();
 });
 
 eventBus.on('USER_LOGGED_IN', async () => {
@@ -104,16 +120,18 @@ eventBus.on('USER_LOGGED_OUT', () => {
 
 ipcMain.on('CHECK_SYNC', (event) => {
   Logger.info('Checking sync');
-  event.sender.send(
-    'CHECK_SYNC_ENGINE_RESPONSE',
-    'Dato obtenido del proceso de sincronización'
-  );
+  event.sender.send('CHECK_SYNC_ENGINE_RESPONSE', '');
 });
 
 ipcMain.on('CHECK_SYNC_CHANGE_STATUS', async (_, placeholderStates) => {
-  await sleep(2_000);
-  Logger.info('[SYNC ENGINE] Changing status');
-  remoteSyncManager.placeholderStatus = 'SYNCING';
-  await sleep(7_00);
+  Logger.info('[SYNC ENGINE] Changing status', placeholderStates);
+  await sleep(5_000);
   remoteSyncManager.placeholderStatus = placeholderStates;
 });
+
+ipcMain.handle('CHECK_SYNC_IN_PROGRESS', async () => {
+  const syncingStatus: RemoteSyncStatus = 'SYNCING';
+  const isSyncing = remoteSyncManager.getSyncStatus() === syncingStatus;
+  const recentlySyncing = remoteSyncManager.recentlyWasSyncing();
+  return isSyncing || recentlySyncing; // If it's syncing or recently was syncing
+});

src/apps/main/remote-sync/helpers.ts

@@ -99,6 +99,7 @@ export type SyncConfig = {
 };
 
 export const SYNC_OFFSET_MS = 0;
+export const WAITING_AFTER_SYNCING = 1000 * 60 * 3;
 
 export const lastSyncedAtIsNewer = (
   itemUpdatedAt: Date,

src/apps/main/thumbnails/application/create-and-upload-thumbnail.ts

@@ -3,6 +3,7 @@ import Logger from 'electron-log';
 import { ThumbnailUploaderFactory } from '../infrastructure/ThumbnailUploaderFactory';
 import { obtainImageToThumbnailIt } from './obtain-image-to-thumbnail-it';
 import { reziseImage } from './resize-image';
+import * as Sentry from '@sentry/electron/main';
 
 export async function createAndUploadThumbnail(id: number, name: string) {
   const uploader = ThumbnailUploaderFactory.build();
@@ -17,5 +18,6 @@ export async function createAndUploadThumbnail(id: number, name: string) {
 
   await uploader.upload(id, thumbnail).catch((err) => {
     Logger.error('[THUMBNAIL] Error uploading thumbnail: ', err);
+    Sentry.captureException(err);
   });
 }

src/apps/main/token-scheduler/TokenScheduler.ts

@@ -1,6 +1,7 @@
 import Logger from 'electron-log';
 import jwtDecode, { JwtPayload } from 'jwt-decode';
 import nodeSchedule from 'node-schedule';
+import * as Sentry from '@sentry/electron/main';
 
 const FIVE_SECONDS = 5 * 60;
 
@@ -20,7 +21,7 @@ export class TokenScheduler {
       return decoded.exp || TokenScheduler.MAX_TIME;
     } catch (err) {
       Logger.error('[TOKEN] Token could be not decoded');
-
+      Sentry.captureException(err); // Use the 'Sentry' module to capture the exception
       return TokenScheduler.MAX_TIME;
     }
   }

src/apps/main/tray/tray.ts

@@ -117,9 +117,10 @@ export const setTrayStatus = (status: TrayMenuState) => {
 };
 
 export function setupTrayIcon() {
+  const brandPath = '/brands/pc-cloud/';
   const RESOURCES_PATH = app.isPackaged
-    ? path.join(process.resourcesPath, 'assets')
-    : path.join(__dirname, '../../../../assets');
+    ? path.join(process.resourcesPath, 'assets', brandPath)
+    : path.join(__dirname, '../../../../assets', brandPath);
 
   const iconsPath = path.join(RESOURCES_PATH, 'tray');