From eab5d511d29b55d9301984216e5130bf091b3f91 Mon Sep 17 00:00:00 2001 From: nick-delirium Date: Fri, 7 Apr 2023 15:19:52 +0200 Subject: [PATCH] fix(tracker): testing --- tracker/tracker/src/main/app/index.ts | 3 ++- tracker/tracker/src/webworker/index.ts | 6 ++++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/tracker/tracker/src/main/app/index.ts b/tracker/tracker/src/main/app/index.ts index afa41a094..833cb3aeb 100644 --- a/tracker/tracker/src/main/app/index.ts +++ b/tracker/tracker/src/main/app/index.ts @@ -7,7 +7,7 @@ import Sanitizer from './sanitizer.js' import Ticker from './ticker.js' import Logger, { LogLevel } from './logger.js' import Session from './session.js' -import { gzip } from 'fflate' +import { gzip, gunzip } from 'fflate' import { deviceMemory, jsHeapSizeLimit } from '../modules/performance.js' import type { Options as ObserverOptions } from './observer/top_observer.js' @@ -187,6 +187,7 @@ export default class App { if (batchSize > 1) { gzip(data.batch, { mtime: 0 }, (err, result) => { if (err) console.error(err) + // @ts-ignore this.worker?.postMessage({ type: 'compressed', batch: result }) }) } else { diff --git a/tracker/tracker/src/webworker/index.ts b/tracker/tracker/src/webworker/index.ts index bad1d641b..45418d54d 100644 --- a/tracker/tracker/src/webworker/index.ts +++ b/tracker/tracker/src/webworker/index.ts @@ -10,7 +10,7 @@ import { ToWorkerData, FromWorkerData } from '../common/interaction.js' import QueueSender from './QueueSender.js' import BatchWriter from './BatchWriter.js' -declare function postMessage(message: FromWorkerData): void +declare function postMessage(message: FromWorkerData, transfer?: any[]): void enum WorkerStatus { NotActive, @@ -117,7 +117,9 @@ self.onmessage = ({ data }: any): any => { }, data.connAttemptCount, data.connAttemptGap, - (batch) => postMessage({ type: 'compress', batch }), + (batch) => { + postMessage({ type: 'compress', batch }, [batch.buffer]) + }, ) writer = new BatchWriter( data.pageNo,