fix: find bigint paths

Author: ronag

src/utils/multicast-listener.js

@@ -1,6 +1,6 @@
 import * as rxjs from 'rxjs'
 import * as C from '../constants/constants.js'
-import { h64ToString } from '../utils/utils.js'
+import { h64ToString, findBigIntPaths } from '../utils/utils.js'
 import * as timers from '../utils/timers.js'
 
 class Provider {
@@ -35,7 +35,16 @@ class Provider {
             return
           }
 
-          const body = typeof value !== 'string' ? this.#listener._stringify(value) : value
+          if (typeof value !== 'string') {
+            try {
+              value = this.#listener._stringify(value)
+            } catch (err) {
+              const bigIntPaths = /BigInt/.test(err.message) ? findBigIntPaths(value) : undefined
+              throw Object.assign(new Error(`invalid value: ${value}`), { cause: err, data: { name: this.#name, bigIntPaths }})
+            }
+          }
+
+          const body = value
           const hash = h64ToString(body)
           const version = `INF-${hash}`
 

src/utils/unicast-listener.js

@@ -1,5 +1,5 @@
 import * as C from '../constants/constants.js'
-import { h64ToString } from '../utils/utils.js'
+import { h64ToString, findBigIntPaths } from '../utils/utils.js'
 
 class Observer {
   #name
@@ -15,15 +15,22 @@ class Observer {
 
   next(value) {
     let data
-    if (value && typeof value === 'string') {
+    if (value == null) {
+      // Do nothing...
+    } else if (typeof value === 'string') {
       if (value.charAt(0) !== '{' && value.charAt(0) !== '[') {
         throw new Error(`invalid value: ${value}`)
       }
       data = value
-    } else if (value && typeof value === 'object') {
-      data = JSON.stringify(value)
-    } else if (data != null) {
-      throw new Error(`invalid value: ${value}`)
+    } else if (typeof value === 'object') {
+      try {
+        data = JSON.stringify(value)
+      } catch (err) {
+        const bigIntPaths = /BigInt/.test(err.message) ? findBigIntPaths(value) : undefined
+        throw Object.assign(new Error(`invalid value: ${value}`), { cause: err, data: { name: this.#name, bigIntPaths }})
+      }
+    } else {
+      throw Object.assign(new Error(`invalid value: ${value}`), { data: { name: this.#name }})
     }
 
     const version = data ? `INF-${h64ToString(data)}` : ''

src/utils/utils.js

@@ -182,3 +182,19 @@ const HASHER = await xxhash()
 export function h64ToString(str) {
   return HASHER.h64ToString(str)
 }
+
+export function findBigIntPaths(obj, path = "") {
+  const paths = []
+
+  if (typeof obj === "bigint") {
+    return [path]
+  }
+
+  if (typeof obj === "object" && obj !== null) {
+    for (const key of Object.keys(obj)) {
+      paths.push(...findBigIntPaths(obj[key], path ? `${path}.${key}` : key))
+    }
+  }
+
+  return paths
+}