@flexent/ws-代用

用于Node.js HTTP服务器的透明WebSocket升级中继.

使用量

子类 WsProxy 执行 processConnection 以认证、打开外出套接字,并指定上游发送的升级请求:

import { connectToUrl, WsProxy, WsProxyContext, WsProxyRelay } from '@flexent/ws-proxy';

class MyProxy extends WsProxy {

    protected async processConnection(ctx: WsProxyContext): Promise<WsProxyRelay> {
        const outbound = await connectToUrl('wss://upstream.example/lease');
        return {
            outbound,
            upgrade: {
                path: '/lease?t=token',
                host: 'upstream.example',
                omitHeaders: ['authorization'],
            },
        };
    }

}

打电话 onUpgrade 从您的 HTTP 服务器中 upgrade 事件可以双向转发 WebSocket 握手和流数据.