From a35d0d06f2fc1e9759db74e8e248acbea159ac9a Mon Sep 17 00:00:00 2001
From: nick-delirium <nikita@openreplay.com>
Date: Fri, 28 Feb 2025 17:28:52 +0100
Subject: [PATCH] tracker: rm idlecb

---
 tracker/tracker/package.json                  |  2 +-
 .../tracker/src/NetworkWorker/BatchWriter.ts  | 60 +++++++++----------
 2 files changed, 30 insertions(+), 32 deletions(-)

diff --git a/tracker/tracker/package.json b/tracker/tracker/package.json
index db79130df..cdf21e6fa 100644
--- a/tracker/tracker/package.json
+++ b/tracker/tracker/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@openreplay/tracker",
   "description": "The OpenReplay tracker main package",
-  "version": "16.0.1-1",
+  "version": "16.0.1-2",
   "keywords": [
     "logging",
     "replay"
diff --git a/tracker/tracker/src/NetworkWorker/BatchWriter.ts b/tracker/tracker/src/NetworkWorker/BatchWriter.ts
index ceb921d4e..795d69747 100644
--- a/tracker/tracker/src/NetworkWorker/BatchWriter.ts
+++ b/tracker/tracker/src/NetworkWorker/BatchWriter.ts
@@ -92,38 +92,36 @@ export default class BatchWriter {
   }
 
   writeMessage(message: Message) {
-    requestIdleCb(() => {
-      // @ts-ignore
-      if (message[0] === 'q_end') {
-        this.finaliseBatch()
-        return this.onOfflineEnd()
-      }
-      if (message[0] === Messages.Type.Timestamp) {
-        this.timestamp = message[1] // .timestamp
-      }
-      if (message[0] === Messages.Type.SetPageLocation) {
-        this.url = message[1] // .url
-      }
-      if (this.writeWithSize(message)) {
-        return
-      }
-      // buffer overflow, send already written data first then try again
+    // @ts-ignore
+    if (message[0] === 'q_end') {
       this.finaliseBatch()
-      if (this.writeWithSize(message)) {
-        return
-      }
-      // buffer is too small. Creating one with maximal capacity for this message only
-      this.encoder = new MessageEncoder(this.beaconSizeLimit)
-      this.prepare()
-      if (!this.writeWithSize(message)) {
-        console.warn('OpenReplay: beacon size overflow. Skipping large message.', message, this)
-      } else {
-        this.finaliseBatch()
-      }
-      // reset encoder to normal size
-      this.encoder = new MessageEncoder(this.beaconSize)
-      this.prepare()
-    })
+      return this.onOfflineEnd()
+    }
+    if (message[0] === Messages.Type.Timestamp) {
+      this.timestamp = message[1] // .timestamp
+    }
+    if (message[0] === Messages.Type.SetPageLocation) {
+      this.url = message[1] // .url
+    }
+    if (this.writeWithSize(message)) {
+      return
+    }
+    // buffer overflow, send already written data first then try again
+    this.finaliseBatch()
+    if (this.writeWithSize(message)) {
+      return
+    }
+    // buffer is too small. Creating one with maximal capacity for this message only
+    this.encoder = new MessageEncoder(this.beaconSizeLimit)
+    this.prepare()
+    if (!this.writeWithSize(message)) {
+      console.warn('OpenReplay: beacon size overflow. Skipping large message.', message, this)
+    } else {
+      this.finaliseBatch()
+    }
+    // reset encoder to normal size
+    this.encoder = new MessageEncoder(this.beaconSize)
+    this.prepare()
   }
 
   finaliseBatch() {