Add basic data pipeline operators dev/gw-encoding-refactor

2 files changed, 5 insertions, 3 deletions

diff --git a/src/gateway/util/Send.ts b/src/gateway/util/Send.ts

index 6a9c639d7..a42c9f3c6 100644
--- a/src/gateway/util/Send.ts
+++ b/src/gateway/util/Send.ts
@@ -20,8 +20,7 @@ import { Payload, WebSocket } from "@spacebar/gateway";
 import fs from "node:fs/promises";
 import path from "node:path";
 
-import { ErlpackType, JSONReplacer } from "@spacebar/util";
-import * as erlpack from "harmony-erlpack";
+import { JSONReplacer } from "@spacebar/util";
 
 // let erlpack: ErlpackType | null = null;
 // try {
diff --git a/src/gateway/util/WebSocket.ts b/src/gateway/util/WebSocket.ts

index 41dc93c11..7efc89383 100644
--- a/src/gateway/util/WebSocket.ts
+++ b/src/gateway/util/WebSocket.ts
@@ -19,9 +19,10 @@
 import { Intents, ListenEventOpts, Permissions, Session } from "@spacebar/util";
 import WS from "ws";
 import { Deflate, Inflate } from "fast-zlib";
-import { Capabilities } from "./Capabilities";
 import { Decoder, Encoder } from "@toondepauw/node-zstd";
+import { Capabilities } from "./Capabilities";
 import { QoSPayload } from "../opcodes/Heartbeat";
+import { DataPipelineOperator } from "../events/Connection";
 
 export interface WebSocket extends WS {
     recentTransactions: string[];
@@ -31,6 +32,8 @@ export interface WebSocket extends WS {
     accessToken: string;
     encoding: "etf" | "json";
     compress?: "zlib-stream" | "zstd-stream";
+    encodeProcessor: DataPipelineOperator;
+    decodeProcessor: DataPipelineOperator;
     ipAddress?: string;
     userAgent?: string; // for cdn request signing
     fingerprint?: string;