Fixed headers handler

example.js

@@ -11,7 +11,7 @@ const customCounter = prometheus.registerCounter("custom_counter");
 
 command.action(async options => {
   // Setup sink for Block Emitter
-  const {emitter} = await setup(options);
+  const { emitter } = await setup(options);
   console.log("setup")
 
   // Stream Blocks
@@ -27,7 +27,7 @@ command.action(async options => {
 
   // Start streaming
   await emitter.start();
-  http.server.close()
+  http.server.close();
   console.log("✅ finished");
 })
 program.parse();

src/commander.ts

@@ -48,10 +48,9 @@ function handleHeaders(value: string, previous: Headers) {
 
     let headers = new Headers();
 
-    for (const header in previous) {
-        const [key, value] = header;
-        headers.set(key, value);
-    }
+    previous.forEach((value, header) => {
+        headers.append(header, value);
+    });
 
     for (const [key, value] of params) {
         headers.append(key, value);

src/restartInactivitySeconds.ts

@@ -17,9 +17,8 @@ export function onRestartInactivitySeconds(emitter: BlockEmitter, restartInactiv
         await setTimeout(CHECK_INACTIVITY_INTERVAL);
         checkInactivity();
     }
-    emitter.on("cursor", (cursor, clock) => {
+    emitter.on("cursor", (_, clock) => {
         lastUpdate = now();
-        console.log(clock.number, emitter.request.stopBlockNum)
         if (clock.number >= emitter.request.stopBlockNum - 1n) {
             isFinished = true;
         };

src/setup.ts

@@ -42,8 +42,6 @@ export async function setup(options: RunOptions) {
     // Cursor
     const cursor = cursorPath.startsWith("http") ? httpCursor : fileCursor;
 
-    console.log(headers);
-
     // Connect Transport
     const startCursor = await cursor.readCursor(cursorPath);
     const registry = createRegistry(substreamPackage);