[_] feature/Updated dependencies and updated related tests

package.json

@@ -17,7 +17,7 @@
     "@stripe/react-stripe-js": "^2.7.1",
     "@stripe/stripe-js": "^3.5.0",
     "@typeform/embed-react": "^1.19.0",
-    "@vitest/browser": "^2.1.9",
+    "@vitest/browser": "^3.2.4",
     "assert": "^2.1.0",
     "axios": "^1.15.0",
     "bip39": "^3.0.3",
@@ -38,7 +38,7 @@
     "i18next-browser-languagedetector": "^7.2.0",
     "idb": "^6.1.5",
     "js-file-download": "^0.4.12",
-    "lint-staged": "^13.1.0",
+    "lint-staged": "^16.0.0",
     "lodash": "^4.18.1",
     "openpgp": "^6.3.0",
     "os-browserify": "^0.3.0",
@@ -140,7 +140,7 @@
     "@types/react-window": "^1.8.8",
     "@types/wicg-file-system-access": "^2023.10.7",
     "@vitejs/plugin-react": "=4.5.1",
-    "@vitest/coverage-istanbul": "2.1.9",
+    "@vitest/coverage-istanbul": "3.2.4",
     "autoprefixer": "^10.4.16",
     "browserslist": "^4.25.0",
     "buffer": "^6.0.3",
@@ -153,18 +153,18 @@
     "prettier": "^3.3.3",
     "process": "^0.11.10",
     "prop-types": "^15.7.2",
-    "sass": "^1.32.4",
+    "sass": "^1.72.0",
     "stylelint": "^16.10.0",
     "stylelint-config-standard": "^36.0.1",
     "stylelint-scss": "^6.8.1",
-    "tailwindcss": "^3.3.4",
+    "tailwindcss": "^3.4.19",
     "typescript": "^4.4.2",
     "vite": "=6.4.2",
     "vite-plugin-bundle-obfuscator": "^1.7.0",
-    "vite-plugin-node-polyfills": "=0.23.0",
+    "vite-plugin-node-polyfills": "=0.26.0",
     "vite-plugin-static-copy": "^3.1.2",
     "vite-plugin-svgr": "^4.3.0",
-    "vitest": "2.1.9",
+    "vitest": "3.2.4",
     "webpack-bundle-analyzer": "^4.9.1"
   },
   "engines": {
@@ -178,8 +178,9 @@
   "resolutions": {
     "glob": "^10.5.0",
     "js-yaml": "^4.1.1",
-    "vitest/vite": "5.4.21",
     "readdir-glob/minimatch": "5.1.8",
-    "strip-ansi": "6.0.1"
+    "strip-ansi": "6.0.1",
+    "readdir-glob/brace-expansion": "2.0.3",
+    "babel-plugin-macros/yaml": "1.10.3"
   }
 }

src/app/core/constants.ts

@@ -3,6 +3,7 @@ export const HTTP_CODES = {
   MAX_SPACE_USED: 420,
   FORBIDDEN: 403,
   NOT_FOUND: 404,
+  INTERNAL_SERVER_ERROR: 500,
 };
 export enum ErrorMessages {
   ServerUnavailable = 'Server Unavailable',

src/app/drive/services/download.service/createFileDownloadStream.test.ts

@@ -1,5 +1,11 @@
 import { describe, expect, vi, beforeEach, test } from 'vitest';
 import { DriveFileData } from '../../types';
+import createFileDownloadStream from './createFileDownloadStream';
+import fetchFileStream from './fetchFileStream';
+import fetchFileStreamUsingCredentials from './fetchFileStreamUsingCredentials';
+
+vi.mock('./fetchFileStream', () => ({ default: vi.fn() }));
+vi.mock('./fetchFileStreamUsingCredentials', () => ({ default: vi.fn() }));
 
 const mockReadableStream = new ReadableStream();
 
@@ -13,23 +19,13 @@ const baseFile: DriveFileData = {
 describe('createFileDownloadStream', () => {
   const mockProgress = vi.fn();
 
-  beforeEach(async () => {
+  beforeEach(() => {
     vi.clearAllMocks();
-    vi.resetModules();
+    vi.mocked(fetchFileStream).mockResolvedValue(mockReadableStream);
+    vi.mocked(fetchFileStreamUsingCredentials).mockResolvedValue(mockReadableStream);
   });
 
-  test('When sharing options (credentials) are not provided, then fetchFileStream is called', async () => {
-    vi.doMock('./fetchFileStream', () => ({
-      default: vi.fn().mockResolvedValue(mockReadableStream),
-    }));
-
-    vi.doMock('./fetchFileStreamUsingCredentials', () => ({
-      default: vi.fn().mockResolvedValue(mockReadableStream),
-    }));
-    const createFileDownloadStream = (await import('./createFileDownloadStream')).default;
-    const fetchFileStream = (await import('./fetchFileStream')).default;
-    const fetchFileStreamUsingCredentials = (await import('./fetchFileStreamUsingCredentials')).default;
-
+  test('When sharing options are not provided, then the file is downloaded using the default method', async () => {
     const result = await createFileDownloadStream(baseFile, true, mockProgress);
 
     expect(fetchFileStream).toHaveBeenCalledWith(
@@ -40,22 +36,23 @@ describe('createFileDownloadStream', () => {
     expect(result).toBe(mockReadableStream);
   });
 
-  test('When sharing options (credentials) are provided, then fetchFileStreamUsingCredentials is called', async () => {
+  test('When a cancellation signal is provided without sharing options, then it is forwarded to the download', async () => {
+    const abortController = new AbortController();
+
+    await createFileDownloadStream(baseFile, false, mockProgress, abortController);
+
+    expect(fetchFileStream).toHaveBeenCalledWith(
+      { ...baseFile, bucketId: baseFile.bucket },
+      { isWorkspace: false, updateProgressCallback: mockProgress, abortController },
+    );
+  });
+
+  test('When sharing options with credentials are provided, then the file is downloaded using those credentials', async () => {
     const abortController = new AbortController();
     const sharingOptions = {
       credentials: { user: 'test-user', pass: 'test-pass' },
       mnemonic: 'test-mnemonic',
     };
-    vi.doMock('./fetchFileStream', () => ({
-      default: vi.fn().mockResolvedValue(mockReadableStream),
-    }));
-
-    vi.doMock('./fetchFileStreamUsingCredentials', () => ({
-      default: vi.fn().mockResolvedValue(mockReadableStream),
-    }));
-    const createFileDownloadStream = (await import('./createFileDownloadStream')).default;
-    const fetchFileStream = (await import('./fetchFileStream')).default;
-    const fetchFileStreamUsingCredentials = (await import('./fetchFileStreamUsingCredentials')).default;
 
     const result = await createFileDownloadStream(baseFile, false, mockProgress, abortController, sharingOptions);
 

src/app/drive/services/network.service/index.ts

@@ -4,6 +4,7 @@ import { Abortable } from 'app/network/Abortable';
 import { createUploadWebWorker } from '../../../../WebWorker';
 import localStorageService from 'services/local-storage.service';
 import { createWorkerMessageHandlerPromise } from '../worker.service/uploadWorkerUtils';
+import { notifyUserWithCooldown } from 'app/core/factory/sdk/retryStrategies';
 import { EnvironmentConfig, IUploadParams } from './types';
 
 export const MAX_ALLOWED_UPLOAD_SIZE = 40 * 1024 * 1024 * 1024;
@@ -77,7 +78,7 @@ export class Network {
 
     worker.postMessage({ bucketId, params: payload, type: 'upload' });
 
-    return createWorkerMessageHandlerPromise(worker, params, continueUploadOptions);
+    return createWorkerMessageHandlerPromise(worker, params, continueUploadOptions, notifyUserWithCooldown);
   }
 }
 

src/app/drive/services/thumbnail.service.test.ts

@@ -1,13 +1,17 @@
-import { afterEach, beforeEach, describe, expect, test, vi } from 'vitest';
+import { Thumbnail } from '@internxt/sdk/dist/drive/storage/types';
 import Resizer from 'react-image-file-resizer';
-import { ErrorLoadingVideoFileError } from './errors/thumbnail.service.errors';
-import { getVideoFrame, getImageThumbnail, downloadThumbnail } from './thumbnail.service';
 import localStorageService from 'services/local-storage.service';
+import { afterEach, beforeEach, describe, expect, test, vi } from 'vitest';
 import fetchFileBlob from './download.service/fetchFileBlob';
-import { Thumbnail } from '@internxt/sdk/dist/drive/storage/types';
-
-vi.mock('react-image-file-resizer');
-vi.mock('services/local-storage.service');
+import { ErrorLoadingVideoFileError } from './errors/thumbnail.service.errors';
+import { downloadThumbnail, getImageThumbnail, getVideoFrame } from './thumbnail.service';
+
+vi.mock('react-image-file-resizer', () => ({
+  default: { imageFileResizer: vi.fn() },
+}));
+vi.mock('services/local-storage.service', () => ({
+  default: { getUser: vi.fn() },
+}));
 vi.mock('./download.service/fetchFileBlob');
 
 const flushPromises = () => new Promise((resolve) => setTimeout(resolve, 0));
@@ -196,16 +200,13 @@ describe('Thumbnail Service', () => {
 
     beforeEach(() => {
       vi.clearAllMocks();
+      (Resizer as any).imageFileResizer = vi.fn();
       URL.createObjectURL = vi.fn(() => 'blob:mock-url');
 
       mockImage = { onload: null, onerror: null };
       globalThis.Image = vi.fn(() => mockImage) as any;
     });
 
-    afterEach(() => {
-      vi.restoreAllMocks();
-    });
-
     test('When image is valid, then it should return a resized thumbnail', async () => {
       const imageFile = new File(['image-content'], 'test-image.jpg', { type: 'image/jpeg' });
       const mockThumbnailFile = new File(['thumbnail'], 'thumbnail.png', { type: 'image/png' });

src/app/drive/services/worker.service/uploadWorkerUtils.ts

@@ -3,7 +3,6 @@ import DatabaseUploadRepository from 'app/repositories/DatabaseUploadRepository'
 import { TaskStatus } from 'app/tasks/types';
 import { IUploadParams } from '../network.service/types';
 import { WORKER_MESSAGE_STATES } from './types/upload';
-import { notifyUserWithCooldown } from 'app/core/factory/sdk/retryStrategies';
 
 /**
  * Checks the upload progress for the specified task.
@@ -84,13 +83,13 @@ const handleCheckUploadStatus = async ({ continueUploadOptions, worker }) => {
   });
 };
 
-const messageResultHandlers = {
+const buildMessageResultHandlers = (onRateLimited: () => void) => ({
   [WORKER_MESSAGE_STATES.SUCCESS]: handleSuccess,
   [WORKER_MESSAGE_STATES.ERROR]: handleError,
   [WORKER_MESSAGE_STATES.ABORT]: handleAbort,
   [WORKER_MESSAGE_STATES.CHECK_UPLOAD_STATUS]: handleCheckUploadStatus,
-  [WORKER_MESSAGE_STATES.RATE_LIMITED]: notifyUserWithCooldown,
-};
+  [WORKER_MESSAGE_STATES.RATE_LIMITED]: () => onRateLimited(),
+});
 
 /**
  * Handles messages received from the Web Worker.
@@ -102,13 +101,13 @@ const messageResultHandlers = {
  * @param {Worker} worker - The Web Worker instance.
  * @param {Object} continueUploadOptions - Options for continuing an upload.
  */
-const handleMessage = (msgData, params, resolve, reject, worker, continueUploadOptions) => {
+const handleMessage = (msgData, params, resolve, reject, worker, continueUploadOptions, onRateLimited: () => void) => {
   if (msgData.progress) {
     handleProgress({ msgData, params });
     return;
   }
 
-  const messageHandler = messageResultHandlers[msgData.result];
+  const messageHandler = buildMessageResultHandlers(onRateLimited)[msgData.result];
 
   if (messageHandler) {
     messageHandler({ msgData, params, resolve, reject, worker, continueUploadOptions });
@@ -125,6 +124,7 @@ const handleMessage = (msgData, params, resolve, reject, worker, continueUploadO
  * @param {IUploadParams} params - Upload parameters.
  * @param {Object} continueUploadOptions - Options for continuing an upload.
  * @param {string} continueUploadOptions.taskId - The task ID for continuing the upload.
+ * @param {Function} onRateLimited - Callback invoked when the worker signals a rate limit.
  *
  * @returns {[Promise<string>, Abortable | undefined]} A tuple containing a Promise that resolves to a file ID
  * and an Abortable object for aborting the upload (if applicable).
@@ -135,13 +135,14 @@ const createWorkerMessageHandlerPromise = (
   continueUploadOptions: {
     taskId: string;
   },
+  onRateLimited: () => void,
 ): [Promise<string>, Abortable | undefined] => {
   return [
     new Promise((resolve, reject) => {
       worker.addEventListener('error', reject);
       worker.addEventListener('message', (msg) => {
         console.log('[MAIN_THREAD]: Message received from worker', msg);
-        handleMessage(msg.data, params, resolve, reject, worker, continueUploadOptions);
+        handleMessage(msg.data, params, resolve, reject, worker, continueUploadOptions, onRateLimited);
       });
     }),
     {

src/app/network/NetworkFacade.test.ts

@@ -10,7 +10,9 @@ import {
   NoContentReceivedError,
 } from './errors/download.errors';
 
-vi.mock('@internxt/sdk/dist/network/download');
+vi.mock('@internxt/sdk/dist/network/download', () => ({
+  downloadFile: vi.fn(),
+}));
 vi.mock('services/stream.service', () => ({
   binaryStreamToBlob: vi.fn(),
   buildProgressStream: vi.fn(),

src/app/network/upload-utils.test.ts

@@ -2,7 +2,13 @@ import { describe, it, expect, vi, beforeEach } from 'vitest';
 import axios, { AxiosError } from 'axios';
 import { uploadFileUint8Array } from './upload-utils';
 
-vi.mock('axios');
+vi.mock('axios', async () => {
+  const { AxiosError } = await vi.importActual<typeof import('axios')>('axios');
+  return {
+    default: { isCancel: vi.fn(), create: vi.fn() },
+    AxiosError,
+  };
+});
 
 describe('uploadFileUint8Array error handling', () => {
   let mockAxiosInstance: any;

src/app/share/services/redirections.service.test.ts

@@ -116,8 +116,13 @@ describe('handlePrivateSharedFolderAccess', () => {
 
   describe('Error scenarios', () => {
     it('should handle 403 error (access denied) and navigate to request access', async () => {
-      const error403 = new AxiosError('Forbidden');
-      error403.status = 403;
+      const error403 = new AxiosError('Forbidden', undefined, undefined, undefined, {
+        status: 403,
+        data: {},
+        statusText: 'Forbidden',
+        headers: {},
+        config: {} as never,
+      });
       (shareService.getSharedFolderContent as Mock).mockRejectedValue(error403);
 
       await handlePrivateSharedFolderAccess({
@@ -136,8 +141,13 @@ describe('handlePrivateSharedFolderAccess', () => {
     });
 
     it('should handle 404 error (folder not found) and show appropriate error', async () => {
-      const error404 = new AxiosError('Not Found');
-      error404.status = 404;
+      const error404 = new AxiosError('Not Found', undefined, undefined, undefined, {
+        status: 404,
+        data: {},
+        statusText: 'Not Found',
+        headers: {},
+        config: {} as never,
+      });
       (shareService.getSharedFolderContent as Mock).mockRejectedValue(error404);
 
       await handlePrivateSharedFolderAccess({
@@ -154,8 +164,13 @@ describe('handlePrivateSharedFolderAccess', () => {
     });
 
     it('should handle generic error and show default error message', async () => {
-      const genericError = new AxiosError('Server Error');
-      genericError.status = 500;
+      const genericError = new AxiosError('Server Error', undefined, undefined, undefined, {
+        status: 500,
+        data: {},
+        statusText: 'Internal Server Error',
+        headers: {},
+        config: {} as never,
+      });
       (shareService.getSharedFolderContent as Mock).mockRejectedValue(genericError);
 
       await handlePrivateSharedFolderAccess({
@@ -188,9 +203,40 @@ describe('handlePrivateSharedFolderAccess', () => {
       expect(navigateToFolder).not.toHaveBeenCalled();
     });
 
+    it('should handle workspace 403 error and navigate to request access', async () => {
+      const error403 = new AxiosError('Forbidden', undefined, undefined, undefined, {
+        status: 403,
+        data: {},
+        statusText: 'Forbidden',
+        headers: {},
+        config: {} as never,
+      });
+      const mockPromise = Promise.reject(error403);
+      (workspacesService.getAllWorkspaceTeamSharedFolderFiles as Mock).mockReturnValue([mockPromise]);
+
+      await handlePrivateSharedFolderAccess({
+        folderUUID: mockFolderUUID,
+        history,
+        navigateToFolder,
+        onError,
+        workspaceItemData: { workspaceId: mockWorkspaceId },
+      });
+
+      expect(navigationService.push).toHaveBeenCalledWith(AppView.RequestAccess, {
+        folderuuid: mockFolderUUID,
+      });
+      expect(navigateToFolder).not.toHaveBeenCalled();
+      expect(onError).not.toHaveBeenCalled();
+    });
+
     it('should handle workspace generic error', async () => {
-      const workspaceError = new AxiosError('Workspace Error');
-      workspaceError.status = 500;
+      const workspaceError = new AxiosError('Workspace Error', undefined, undefined, undefined, {
+        status: 500,
+        data: {},
+        statusText: 'Internal Server Error',
+        headers: {},
+        config: {} as never,
+      });
       const mockPromise = Promise.reject(workspaceError);
       (workspacesService.getAllWorkspaceTeamSharedFolderFiles as Mock).mockReturnValue([mockPromise]);