diff options
| author | Essem <smswessem@gmail.com> | 2024-06-24 05:29:00 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-06-24 10:29:00 +0000 |
| commit | 54cc204473302eda7e6e7e75b343a14859524ab1 (patch) | |
| tree | f4cd47308b5feea16ffaacf732900975bc87af18 | |
| parent | b3710098a8edcb5cc317a280758b2a772ea722ef (diff) | |
Use WebSocketServer instead of WebSocket.Server in streaming (#30788)
| -rw-r--r-- | streaming/index.js | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/streaming/index.js b/streaming/index.js index 154ecbc02c5..65a63bb1143 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -12,7 +12,7 @@ import { Redis } from 'ioredis'; import { JSDOM } from 'jsdom'; import pg from 'pg'; import pgConnectionString from 'pg-connection-string'; -import WebSocket from 'ws'; +import { WebSocketServer } from 'ws'; import { AuthenticationError, RequestError, extractStatusAndMessage as extractErrorStatusAndMessage } from './errors.js'; import { logger, httpLogger, initializeLogLevel, attachWebsocketHttpLogger, createWebsocketLogger } from './logging.js'; @@ -289,7 +289,7 @@ const CHANNEL_NAMES = [ const startServer = async () => { const pgPool = new pg.Pool(pgConfigFromEnv(process.env)); const server = http.createServer(); - const wss = new WebSocket.Server({ noServer: true }); + const wss = new WebSocketServer({ noServer: true }); // Set the X-Request-Id header on WebSockets: wss.on("headers", function onHeaders(headers, req) { |