organise stuff into utils

src/services/cache/workerProxyElectronCacheStorage.ts

@@ -5,6 +5,7 @@ import {
     ProxiedLimitedCacheStorage,
     ProxiedWorkerLimitedCache,
 } from 'types/cache';
+import { serializeResponse, deserializeToResponse } from 'utils/comlink/proxy';
 
 export default class WorkerProxyElectronCacheStorage
     implements ProxiedLimitedCacheStorage
@@ -38,17 +39,3 @@ function transformPut(
         fn(key, deserializeToResponse(data));
     };
 }
-
-function serializeResponse(response: Response) {
-    return response.arrayBuffer();
-}
-
-function deserializeToResponse(arrayBuffer: ArrayBuffer) {
-    return new Response(arrayBuffer);
-}
-
-// Comlink.transferHandlers.set('RESPONSE', {
-//     canHandle: (obj) => obj instanceof Response,
-//     serialize: (response: Response) => [response.arrayBuffer(), []],
-//     deserialize: (arrayBuffer: ArrayBuffer) => new Response(arrayBuffer),
-// });

src/services/cache/workerReverseProxyElectronCacheStorage.ts

@@ -6,6 +6,7 @@ import {
 } from 'types/cache';
 import WorkerProxyElectronCacheStorage from './workerProxyElectronCacheStorage';
 import { wrap } from 'comlink';
+import { deserializeToResponse, serializeResponse } from 'utils/comlink/proxy';
 
 export default class WorkerReverseProxyElectronCacheStorage
     implements LimitedCacheStorage
@@ -53,17 +54,3 @@ function transformPut(
         fn(key, await serializeResponse(data));
     };
 }
-
-function serializeResponse(response: Response) {
-    return response.arrayBuffer();
-}
-
-function deserializeToResponse(arrayBuffer: ArrayBuffer) {
-    return new Response(arrayBuffer);
-}
-
-// Comlink.transferHandlers.set('RESPONSE', {
-//     canHandle: (obj) => obj instanceof Response,
-//     serialize: (response: Response) => [response.arrayBuffer(), []],
-//     deserialize: (arrayBuffer: ArrayBuffer) => new Response(arrayBuffer),
-// });

src/utils/comlink/proxy.ts

@@ -0,0 +1,7 @@
+export function serializeResponse(response: Response) {
+    return response.arrayBuffer();
+}
+
+export function deserializeToResponse(arrayBuffer: ArrayBuffer) {
+    return new Response(arrayBuffer);
+}

src/utils/comlink/transferHandler.ts

@@ -0,0 +1,10 @@
+import * as Comlink from 'comlink';
+
+export function setupResponseObjectTransferHandler() {
+    const transferHandler: Comlink.TransferHandler<Response, ArrayBuffer> = {
+        canHandle: (obj): obj is Response => obj instanceof Response,
+        serialize: (response: Response) => [response.arrayBuffer() as any, []],
+        deserialize: (arrayBuffer: ArrayBuffer) => new Response(arrayBuffer),
+    };
+    return Comlink.transferHandlers.set('RESPONSE', transferHandler);
+}