LumeWeb
/
libhyperproxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

*Update dist

This commit is contained in:
Derrick Hammer 2023-02-25 22:16:59 -05:00
parent bdacd01849
commit 6b42c2400f
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dist/peer.d.ts vendored
View File

@ -14,6 +14,7 @@ export interface DataSocketOptions {
onreceive?: OnReceive;
onsend?: OnSend;
onclose?: OnClose;
emulateWebsocket?: boolean;
}
export interface PeerOptions {
peer: any;
@ -31,6 +32,7 @@ export default class Peer {
private _onreceive;
private _onsend;
private _onclose;
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, }: PeerOptionsWithProxy & DataSocketOptions);
private _emulateWebsocket;
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, emulateWebsocket, }: PeerOptionsWithProxy & DataSocketOptions);
init(): Promise<void>;
}

5
dist/peer.js vendored
View File

@ -14,7 +14,8 @@ class Peer {
_onreceive;
_onsend;
_onclose;
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, }) {
_emulateWebsocket;
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, emulateWebsocket = false, }) {
this._proxy = proxy;
this._peer = peer;
this._muxer = muxer;
@ -22,6 +23,7 @@ class Peer {
this._onreceive = onreceive;
this._onsend = onsend;
this._onclose = onclose;
this._emulateWebsocket = emulateWebsocket;
}
async init() {
const write = async (data, cb) => {
@ -44,6 +46,7 @@ class Peer {
remotePort: self._peer.rawStream.remotePort,
remotePublicKey: self._peer.remotePublicKey,
write,
emulateWebsocket: self._emulateWebsocket,
});
self._socket.on("end", () => channel.close());
let ret = await self._onopen?.(self._socket, m);