Update iot-gateway js file. (#94)

flomesh-io · Nov 16, 2023 · 6fd16e2 · 6fd16e2
1 parent 8191f27
commit 6fd16e2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/iot-gateway/pjs/rest.js b/iot-gateway/pjs/rest.js
@@ -201,7 +201,7 @@ pipy()
     msg => (
       (
         /// debug = console.log('query config:', msg?.body?.toString?.()),
-        resp = JSON.decode(msg?.body),
+        resp = (msg?.body?.toString?.().charAt(0) === '{') && JSON.decode(msg?.body),
       ) => (
         (msg?.head?.status === 401) ? (
           deviceConfig.strapiJwt = null,
@@ -240,7 +240,7 @@ pipy()
     .replaceMessage(
       msg => (
         (
-          resp = JSON.decode(msg?.body),
+          resp = (msg?.body?.toString?.().charAt(0) === '{') && JSON.decode(msg?.body),
         ) => (
           (msg?.head?.status === 200 && resp?.data?.id > 0) ? (
             [new Message('OK'), new StreamEnd]

diff --git a/iot-gateway/pjs/worker.js b/iot-gateway/pjs/worker.js
@@ -56,7 +56,7 @@ pipy({
 .replaceMessage(
   msg => (
     msg?.body && (
-      _dataJson = JSON.decode(msg?.body),
+      _dataJson = (msg?.body?.toString?.().charAt(0) === '{') && JSON.decode(msg?.body),
       (_dataJson?.ts > 0) && (
         delete _dataJson.id,
         _dataJson.created_at = new Date(_dataJson.ts * 1000).toISOString(),