Chore: Update ws package (#24477)

ee/server/services/ddp-streamer/Client.ts

@@ -184,9 +184,9 @@ export class Client extends EventEmitter {
 		this.timeout = setTimeout(this.handleIdle, timeout);
 	}
 
-	handler = async (payload: string): Promise<void> => {
+	handler = async (payload: WebSocket.Data, isBinary: boolean): Promise<void> => {
 		try {
-			const packet = server.parse(payload);
+			const packet = server.parse(payload, isBinary);
 			this.emit('message', packet);
 			if (this.wait) {
 				return new Promise((resolve) => this.once(DDP_EVENTS.LOGGED, () => resolve(this.process(packet.msg, packet))));

ee/server/services/ddp-streamer/Server.ts

@@ -1,5 +1,6 @@
 import { EventEmitter } from 'events';
 
+import type WebSocket from 'ws';
 import ejson from 'ejson';
 import { v1 as uuidv1 } from 'uuid';
 
@@ -42,7 +43,12 @@ export class Server extends EventEmitter {
 
 	serialize = ejson.stringify;
 
-	parse = (packet: string): IPacket => {
+	parse = (data: WebSocket.Data, isBinary: boolean): IPacket => {
+		if (isBinary) {
+			throw new MeteorError(500, 'Binary data not supported');
+		}
+		const packet = data.toString();
+
 		const payload = packet.startsWith('[') ? JSON.parse(packet)[0] : packet;
 		return ejson.parse(payload);
 	};

ee/server/services/package.json

@@ -46,7 +46,7 @@
 		"sodium-plus": "^0.9.0",
 		"underscore.string": "^3.3.6",
 		"uuid": "^7.0.3",
-		"ws": "^7.5.5"
+		"ws": "^8.5.0"
 	},
 	"devDependencies": {
 		"@types/cookie": "^0.4.1",
@@ -56,7 +56,7 @@
 		"@types/fibers": "^3.1.1",
 		"@types/mongodb": "^3.6.19",
 		"@types/node": "^14.17.4",
-		"@types/ws": "^7.4.7",
+		"@types/ws": "^8.2.2",
 		"pino-pretty": "^7.5.0",
 		"pm2": "^5.1.2",
 		"ts-node": "^10.5.0",