From 37546483620a07fe54c8d0b1b752b28e42c02dc5 Mon Sep 17 00:00:00 2001 From: April Hall Date: Tue, 7 Jan 2025 11:51:43 -0500 Subject: [PATCH] fix: Remove un-used file --- src/lib/server/webSocketUtils.ts | 51 -------------------------------- 1 file changed, 51 deletions(-) delete mode 100644 src/lib/server/webSocketUtils.ts diff --git a/src/lib/server/webSocketUtils.ts b/src/lib/server/webSocketUtils.ts deleted file mode 100644 index 1efd890..0000000 --- a/src/lib/server/webSocketUtils.ts +++ /dev/null @@ -1,51 +0,0 @@ -import { parse } from 'url'; -import { WebSocketServer } from 'ws'; -import { nanoid } from 'nanoid'; -import type { Server, WebSocket as WebSocketBase } from 'ws'; -import type { IncomingMessage } from 'http'; -import type { Duplex } from 'stream'; - -export const GlobalThisWSS = Symbol.for('sveltekit.wss'); - -export interface ExtendedWebSocket extends WebSocketBase { - socketId: string; - // userId: string; -} - -// You can define server-wide functions or class instances here -// export interface ExtendedServer extends Server {}; - -export type ExtendedWebSocketServer = Server; - -export type ExtendedGlobal = typeof globalThis & { - [GlobalThisWSS]: ExtendedWebSocketServer; -}; - -export const onHttpServerUpgrade = (req: IncomingMessage, sock: Duplex, head: Buffer) => { - const pathname = req.url ? parse(req.url).pathname : null; - if (pathname !== '/websocket') return; - - const wss = (globalThis as ExtendedGlobal)[GlobalThisWSS]; - - wss.handleUpgrade(req, sock, head, (ws) => { - console.log('[handleUpgrade] creating new connecttion'); - wss.emit('connection', ws, req); - }); -}; - -export const createWSSGlobalInstance = () => { - const wss = new WebSocketServer({ noServer: true }) as ExtendedWebSocketServer; - - (globalThis as ExtendedGlobal)[GlobalThisWSS] = wss; - - wss.on('connection', (ws) => { - ws.socketId = nanoid(); - console.log(`[wss:global] client connected (${ws.socketId})`); - - ws.on('close', () => { - console.log(`[wss:global] client disconnected (${ws.socketId})`); - }); - }); - - return wss; -};