improve http readCursor handling

pinax-network · Dec 1, 2023 · 1d1d557 · 1d1d557
1 parent 5d6e2f3
commit 1d1d557
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "substreams-sink",
-    "version": "0.13.3",
+    "version": "0.13.4",
     "description": "Substreams Sink",
     "type": "module",
     "exports": "./dist/index.js",

diff --git a/src/cursor/httpCursor.ts b/src/cursor/httpCursor.ts
@@ -13,7 +13,29 @@ export async function readCursor(cursorPath: string, httpCursorAuth?: string) {
     if (!response.ok) {
         return "";
     }
+    const text = await response.text();
 
-    const data: any = await response.json();
-    return data[0] && data[0].Value ? data[0].Value : "";
+    /**
+     * Consul KV
+     * https://developer.hashicorp.com/consul/api-docs/kv
+     *
+     * @example
+     * [{"Value":"n-5SB30M-16YouthlRFszqWwLpcyB1JpXQPsLRNL1..."}]
+     */
+    try {
+        const data = JSON.parse(text) as { Value: string }[];
+        if ( data.length ) {
+            const value = data[0]?.Value;
+            if ( value ) return value;
+        }
+    /**
+     * Simple HTTP text response
+     *
+     * @example
+     * n-5SB30M-16YouthlRFszqWwLpcyB1JpXQPsLRNL1...
+     */
+    } catch (error) {
+        if ( text ) return text;
+    }
+    return "";
 }