From 5120ae454d93a24e30fcf4aa1efa1b03a1ef2516 Mon Sep 17 00:00:00 2001 From: Convly Date: Mon, 13 Mar 2023 17:06:57 +0100 Subject: [PATCH] Fix build --- .../src/strapi/remote/handlers/utils.ts | 19 ++++++------------- 1 file changed, 6 insertions(+), 13 deletions(-) diff --git a/packages/core/data-transfer/src/strapi/remote/handlers/utils.ts b/packages/core/data-transfer/src/strapi/remote/handlers/utils.ts index 4e91fd115d..f9b700ef57 100644 --- a/packages/core/data-transfer/src/strapi/remote/handlers/utils.ts +++ b/packages/core/data-transfer/src/strapi/remote/handlers/utils.ts @@ -7,6 +7,7 @@ import type { IHandlerOptions, TransferMethod } from './types'; import { ProviderTransferError } from '../../../errors/providers'; type WSCallback = (client: WebSocket, request: IncomingMessage) => void; +type BufferLike = Parameters[0]; const VALID_TRANSFER_COMMANDS = ['init', 'end', 'status'] as const; @@ -85,7 +86,7 @@ export interface Handler { /** * It sends a message to the client */ - send(message: T, cb?: (err?: Error) => void): void; + send(message: T, cb?: (err?: Error) => void): void; /** * It sends a message to the client and waits for a confirmation @@ -185,7 +186,7 @@ export const handlerFactory = return; } - const payload = { + const payload = JSON.stringify({ uuid, data: data ?? null, error: e @@ -194,29 +195,21 @@ export const handlerFactory = message: e?.message, } : null, - }; + }); this.send(payload, (error) => (error ? reject(error) : resolve())); }); }, send(message, cb) { - let payload; - - try { - payload = JSON.stringify(message); - } catch { - payload = message; - } - - ws.send(payload, cb); + ws.send(message, cb); }, confirm(message) { return new Promise((resolve, reject) => { const uuid = randomUUID(); - const payload = { uuid, data: message }; + const payload = JSON.stringify({ uuid, data: message }); this.send(payload, (error) => { if (error) {