/
githubmirror
/
socket.io
Обзор
Документация
Войти
/
githubmirror
/
socket.io
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
packages/engine.io-client/lib/transports/websocket.node.ts
50 строк
1 KB
Ben McCann
fix(engine.io-client): correctly consume the `ws` package (#5220)
07 янв 2025, 12:53
Не верифицирован
07 янв 2025, 12:53
7fcddcb
Код
Авторство
О чём код?
import * as ws from "ws"; import type { Packet, RawData } from "engine.io-parser"; import { BaseWS } from "./websocket.js"; /** * WebSocket transport based on the `WebSocket` object provided by the `ws` package. * * Usage: Node.js, Deno (compat), Bun (compat) * * @see https://developer.mozilla.org/en-US/docs/Web/API/WebSocket * @see https://caniuse.com/mdn-api_websocket */ export class WS extends BaseWS { createSocket( uri: string, protocols: string | string[] | undefined, opts: Record<string, any>, ): any { if (this.socket?._cookieJar) { opts.headers = opts.headers || {}; opts.headers.cookie = typeof opts.headers.cookie === "string" ? [opts.headers.cookie] : opts.headers.cookie || []; for (const [name, cookie] of this.socket._cookieJar.cookies) { opts.headers.cookie.push(`${name}=${cookie.value}`); } } return new ws.WebSocket(uri, protocols, opts); } doWrite(packet: Packet, data: RawData) { const opts: { compress?: boolean } = {}; if (packet.options) { opts.compress = packet.options.compress; } if (this.opts.perMessageDeflate) { const len = // @ts-ignore "string" === typeof data ? Buffer.byteLength(data) : data.length; if (len < this.opts.perMessageDeflate.threshold) { opts.compress = false; } } this.ws.send(data, opts); } }