Merge pull request #368 from bitfinexcom/staging

Release version to master

package.json

@@ -1,6 +1,6 @@
 {
   "name": "bfx-reports-framework",
-  "version": "4.16.0",
+  "version": "4.17.0",
   "description": "Bitfinex reports framework",
   "main": "worker.js",
   "license": "Apache-2.0",

workers/api.framework.report.wrk.js

@@ -1,5 +1,7 @@
 'use strict'
 
+const fs = require('node:fs')
+
 const WrkReportServiceApi = require(
   'bfx-report/workers/api.service.report.wrk'
 )
@@ -143,6 +145,31 @@ class WrkReportFrameWorkApi extends WrkReportServiceApi {
     }
 
     this.setInitFacs(facs)
+    this.rmLokueDbIfJSONDamaged()
+  }
+
+  rmLokueDbIfJSONDamaged () {
+    for (const fac of this.conf.init.facilities) {
+      // eslint-disable-next-line no-unused-vars
+      const [type, facName, ns, label, opts] = fac
+
+      if (facName !== 'bfx-facs-lokue') {
+        continue
+      }
+
+      const { dbPathAbsolute, name } = opts
+      const baseLokueDbFileName = ['lokue', name, label].join('_')
+      const pathToLokueDbFile = path.join(
+        dbPathAbsolute,
+        `${baseLokueDbFileName}.db.json`
+      )
+
+      try {
+        require(pathToLokueDbFile)
+      } catch (err) {
+        fs.rmSync(pathToLokueDbFile, { force: true, maxRetries: 3 })
+      }
+    }
   }
 
   async initService (deps) {

workers/loc.api/sync/progress/index.js

@@ -95,8 +95,14 @@ class Progress extends EventEmitter {
       return
     }
 
+    const serializedError = (
+      progress?.serializedError ??
+      progress?.stack ??
+      progress
+    )
+
     this.logger.error(
-      `PROGRESS:SYNC: ${progress.stack || progress}`
+      `PROGRESS:SYNC: ${serializedError}`
     )
   }