fix(tracker): testing
This commit is contained in:
parent
6c10d55236
commit
eab5d511d2
2 changed files with 6 additions and 3 deletions
|
|
@ -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 {
|
||||
|
|
|
|||
|
|
@ -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,
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue