Bump protocol version

src/io/decoder.ts

@@ -32,7 +32,7 @@ type DecoderState = { state: number; header: Header | undefined; buf: Buffer };
 const WAITING_FOR_HEADER = 0;
 const WAITING_FOR_BODY = 1;
 
-export const SUPPORTED_PROTOCOL_VERSION = 0;
+export const SUPPORTED_PROTOCOL_VERSION = 1;
 
 function initalDecoderState(buf: Buffer): DecoderState {
   return {

test/protocol_stream.test.ts

@@ -23,6 +23,7 @@ import { Header, Message } from "../src/types/types";
 import stream from "stream";
 import { setTimeout } from "timers/promises";
 import { CompletablePromise } from "../src/utils/promises";
+import { SUPPORTED_PROTOCOL_VERSION } from "../src/io/decoder";
 
 // The following test suite is taken from headers.rs
 describe("Header", () => {
@@ -89,7 +90,9 @@ describe("Restate Streaming Connection", () => {
           id: Buffer.from("abcd"),
           debugId: "abcd",
           knownEntries: 1337,
-        })
+        }),
+        undefined,
+        SUPPORTED_PROTOCOL_VERSION
       )
     );
 

test/protoutils.ts

@@ -67,6 +67,7 @@ import { expect } from "@jest/globals";
 import { jsonSerialize, formatMessageAsJson } from "../src/utils/utils";
 import { rlog } from "../src/logger";
 import { ErrorCodes, RestateErrorCodes } from "../src/types/errors";
+import { SUPPORTED_PROTOCOL_VERSION } from "../src/io/decoder";
 
 export function startMessage(
   knownEntries?: number,
@@ -86,7 +87,7 @@ export function startMessage(
       partialState: partialState !== false,
     }),
     undefined,
-    0,
+    SUPPORTED_PROTOCOL_VERSION,
     undefined
   );
 }