fix(tmp): tmp setup

Author: dasein108

src/contexts/backend/backend.tsx

@@ -331,6 +331,10 @@ function BackendProvider({ children }: { children: React.ReactNode }) {
         isDbInitialized,
         isSyncInitialized,
         isReady,
+        testCase: async () => {
+          console.log('----test case clic', backgroundWorkerInstance);
+          await backgroundWorkerInstance.testCase();
+        },
       } as BackendProviderContextType),
     [
       isReady,

src/features/ipfs/Drive/BackendStatus.tsx

@@ -70,11 +70,17 @@ function BackendStatus() {
     (store) => store.backend
   );
 
+  const { testCase } = useBackend();
+
   const downloadLogsOnClick = () => {
     const logs = cyblog.getLogs();
     downloadJson(logs, `cyblog_${new Date().toISOString()}.json`);
   };
 
+  const testOnClick = async () => {
+    await testCase();
+  };
+
   return (
     <Display color={Colors.GREEN}>
       <div className={styles.list}>
@@ -117,6 +123,9 @@ function BackendStatus() {
           <Button small onClick={downloadLogsOnClick}>
             🐞 download logs
           </Button>
+          <Button small onClick={testOnClick}>
+            test abort signal
+          </Button>
         </div>
       </div>
     </Display>

src/services/QueueManager/QueueManager.ts

@@ -190,9 +190,15 @@ class QueueManager {
     }).pipe(
       timeout({
         each: settings.timeout,
-        with: () =>
+        with: (timeoutInfo) =>
           throwError(() => {
+            console.log(
+              '----timeout triggered',
+              timeoutInfo.lastValue?.cid,
+              timeoutInfo.lastValue?.source
+            );
             controller?.abort('timeout');
+
             return new QueueItemTimeoutError(settings.timeout);
           }),
       }),

src/services/backend/workers/background/worker.ts

@@ -303,6 +303,34 @@ const createBackgroundWorkerApi = () => {
     restartSync: (name: SyncEntryName) => syncService.restart(name),
     setParams: (params: Partial<SyncServiceParams>) =>
       params$.next({ ...params$.value, ...params }),
+
+    testCase: () => {
+      console.log('>>> test case fired');
+      (async () => {
+        const controller = new AbortController();
+        setTimeout(() => {
+          controller.abort();
+          console.log('>>> abort triggered');
+        }, 1000); // Abort after 1 second
+
+        try {
+          const response = await fetch(
+            'https://gateway.ipfs.cybernode.ai/ipfs/QmPRHHTeWzgBoRvbYMg4Q3ZVviu3VDP5rTPLgXotYpiuba',
+            {
+              method: 'GET',
+              signal: controller.signal,
+            }
+          );
+          // Handle the response
+        } catch (error) {
+          if (error.name === 'AbortError') {
+            console.log('>>> Fetch aborted');
+          } else {
+            console.error('>>> Fetch error:', error);
+          }
+        }
+      })();
+    },
   };
 };
 

src/services/backend/workers/factoryMethods.ts

@@ -5,7 +5,7 @@ type WorkerType = SharedWorker | Worker;
 
 const isSharedWorkersSupported = typeof SharedWorker !== 'undefined';
 
-const isSharedWorkerUsed = isSharedWorkersSupported && !process.env.IS_DEV;
+const isSharedWorkerUsed = isSharedWorkersSupported; //&& !process.env.IS_DEV;
 
 // apply serializers for custom types
 function installTransferHandlers() {

src/services/ipfs/utils/utils-ipfs.ts

@@ -170,6 +170,10 @@ const fetchIPFSContentFromGateway = async (
     ? await fetchIPFSContentMeta(cid, node, controller?.signal)
     : emptyMeta;
 
+  controller?.signal &&
+    controller?.signal.onabort((ev) => {
+      console.log('-----aborted', cid);
+    });
   const contentUrl = `${CYBER_GATEWAY_URL}/ipfs/${cid}`;
   const response = await fetch(contentUrl, {
     method: 'GET',

webpack.config.dev.js

@@ -19,9 +19,9 @@ module.exports = merge(commonConfig, {
     historyApiFallback: true,
   },
   plugins: [
-    new ReactRefreshWebpackPlugin({
-      overlay: false,
-    }),
+    // new ReactRefreshWebpackPlugin({
+    //   overlay: false,
+    // }),
     new webpack.DefinePlugin({
       ...commonConfig.plugins.find(
         (plugin) => plugin.constructor.name === 'DefinePlugin'