From 1497d25822e82c2767dd91fc9b991bd481a755f6 Mon Sep 17 00:00:00 2001
From: Denis Carriere <carriere.denis@gmail.com>
Date: Mon, 15 May 2023 17:42:09 -0400
Subject: [PATCH] fix debug

---
 package.json |  2 +-
 src/index.ts | 30 +++++++-----------------------
 2 files changed, 8 insertions(+), 24 deletions(-)

diff --git a/package.json b/package.json
index f550ebc..83ffcb1 100644
--- a/package.json
+++ b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "substreams",
   "description": "Substreams Javascript consumer",
-  "version": "0.7.0",
+  "version": "0.7.1",
   "homepage": "https://github.com/pinax-network/substreams-js",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
diff --git a/src/index.ts b/src/index.ts
index c5d78c7..c63614b 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -44,27 +44,6 @@ import { IEnumTypeRegistry, IMessageTypeRegistry, IServiceTypeRegistry } from "@
 import { parseAuthorization } from './authorization';
 export type Registry = IMessageTypeRegistry & IEnumTypeRegistry & IServiceTypeRegistry;
 
-// export interface MapOutput extends MapModuleOutput {
-//     data: {
-//         case: "output"
-//         value: Any;
-//     }
-// }
-
-// export interface StoreDelta extends StoreModuleOutput {
-//     data: {
-//         case: "debug_store_outputs"
-//         value: StoreModuleOutput;
-//     }
-// }
-
-// { no: 1, name: "output", kind: "message", T: MapModuleOutput },
-// { no: 2, name: "clock", kind: "message", T: Clock },
-// { no: 3, name: "cursor", kind: "scalar", T: 9 /* ScalarType.STRING */ },
-// { no: 4, name: "final_block_height", kind: "scalar", T: 4 /* ScalarType.UINT64 */ },
-// { no: 10, name: "debug_map_outputs", kind: "message", T: MapModuleOutput, repeated: true },
-// { no: 11, name: "debug_store_outputs", kind: "message", T: StoreModuleOutput, repeated: true },
-
 export const DEFAULT_HOST = "https://mainnet.eth.streamingfast.io:443";
 export const DEFAULT_AUTH = "https://auth.streamingfast.io/v1/auth/issue";
 export const DEFAULT_IPFS = "https://ipfs.pinax.network/ipfs/";
@@ -81,8 +60,8 @@ type MessageEvents = {
     // V2 updates
     // new
     output: (output: MapModuleOutput, clock: Clock) => void;
-    debugStoreOutputs: (output: StoreModuleOutput, clock: Clock) => void;
-    debugMapOutputs: (output: MapModuleOutput, clock: Clock) => void;
+    debugStoreOutputs: (output: StoreModuleOutput[], clock: Clock) => void;
+    debugMapOutputs: (output: MapModuleOutput[], clock: Clock) => void;
     finalBlockHeight: (block_height: bigint, clock: Clock) => void;
     // deprecated
     // mapOutput: (output: MapModuleOutput, clock: Clock) => void;
@@ -235,6 +214,11 @@ export class Substreams extends (EventEmitter as new () => TypedEmitter<MessageE
                 if (!decoded) continue;
                 this.emit("anyMessage", decoded, clock, typeName);
             }
+            // Debug
+            this.emit("debugStoreOutputs", block.debugStoreOutputs, clock);
+            this.emit("debugMapOutputs", block.debugMapOutputs, clock);
+
+            // Final
             this.emit("cursor", block.cursor, clock);
             this.emit("finalBlockHeight", finalBlockHeight, clock);
             last_cursor = block.cursor;