fix: catch flush error and send to callback (#1)

* fix: catch flush error and send to callback

* release: 0.1.1

Author: joway

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sensorsdata-sdk",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "SDK of sensorsdata Written in Typescript",
   "main": "dist/src/sensors-analytics.js",
   "scripts": {

src/sensors-analytics.ts

@@ -129,22 +129,27 @@ export class SensorsAnalytics extends Writable {
 
     this.dataQueue.push(envelope)
     const now = Date.now()
-    if (
-      this.debug ||
-      this.dataQueue.length >= this.options.buffCount ||
-      now >= this.nextSubmitTime
-    ) {
-      if (this.timer) {
-        clearTimeout(this.timer)
+    try {
+      if (
+        this.debug ||
+        this.dataQueue.length >= this.options.buffCount ||
+        now >= this.nextSubmitTime
+      ) {
+        if (this.timer) {
+          clearTimeout(this.timer)
+        }
+        await this.flush()
+      } else {
+        if (this.timer) {
+          clearTimeout(this.timer)
+        }
+        this.timer = setTimeout(() => this.flush(), this.nextSubmitTime - now)
       }
-      await this.flush()
-    } else {
-      if (this.timer) {
-        clearTimeout(this.timer)
-      }
-      this.timer = setTimeout(() => this.flush(), this.nextSubmitTime - now)
+
+      callback()
+    } catch (err) {
+      callback(err)
     }
-    callback()
   }
 
   async submit(messages: object[]) {
@@ -255,7 +260,7 @@ export class SensorsAnalytics extends Writable {
     await this.submit(this.popAllData())
   }
   async close() {
-    await new Promise(resolve => {
+    await new Promise((resolve) => {
       super.end(() => resolve())
     })
     await this.flush()