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-03-15 08:14:29 -04:00
parent c1d495a54b
commit 8e0edc4bcd
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
4 changed files with 24 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dist/peer.d.ts vendored
View File

@ -27,6 +27,7 @@ export interface DataSocketOptions {
onclose?: OnClose;
onchannel?: OnChannel;
emulateWebsocket?: boolean;
createDefaultMessage?: boolean;
}
export interface PeerOptions {
peer: any;
@ -45,7 +46,8 @@ export default class Peer {
private _onclose;
private _onchannel;
private _emulateWebsocket;
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, onchannel, emulateWebsocket, }: PeerOptionsWithProxy & DataSocketOptions);
private _createDefaultMessage;
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, onchannel, emulateWebsocket, createDefaultMessage, }: PeerOptionsWithProxy & DataSocketOptions);
private _socket?;
get socket(): Socket;
private _channel?;

29
dist/peer.js vendored
View File

@ -15,7 +15,8 @@ class Peer {
_onclose;
_onchannel;
_emulateWebsocket;
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, onchannel, emulateWebsocket = false, }) {
_createDefaultMessage;
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, onchannel, emulateWebsocket = false, createDefaultMessage = true, }) {
this._proxy = proxy;
this._peer = peer;
this._muxer = muxer;
@ -25,6 +26,7 @@ class Peer {
this._onclose = onclose?.bind(undefined, this);
this._onchannel = onchannel?.bind(undefined, this);
this._emulateWebsocket = emulateWebsocket;
this._createDefaultMessage = createDefaultMessage;
}
_socket;
get socket() {
@ -36,12 +38,15 @@ class Peer {
}
async init() {
const self = this;
let pipe;
this._socket = new socket_js_1.default({
remoteAddress: self._peer.rawStream.remoteHost,
remotePort: self._peer.rawStream.remotePort,
remotePublicKey: self._peer.remotePublicKey,
async write(data, cb) {
pipe.send(data);
if (pipe) {
pipe.send(data);
}
await self._onsend?.(data);
cb();
},
@ -69,15 +74,17 @@ class Peer {
await self._onclose?.(self._socket);
},
});
const pipe = this._channel.addMessage({
async onmessage(m) {
if (m instanceof Uint8Array) {
m = buffer_1.Buffer.from(m);
}
self._socket.emit("data", m);
await self._onreceive?.(m);
},
});
if (this._createDefaultMessage) {
pipe = this._channel.addMessage({
async onmessage(m) {
if (m instanceof Uint8Array) {
m = buffer_1.Buffer.from(m);
}
self._socket.emit("data", m);
await self._onreceive?.(m);
},
});
}
await this._onchannel?.(this._channel);
await this._channel.open();
}

2
dist/proxy.d.ts vendored
View File

@ -9,7 +9,7 @@ export default class Proxy {
private _listen;
private _socketOptions;
private _autostart;
constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, onchannel, listen, autostart, emulateWebsocket, }: ProxyOptions);
constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, onchannel, listen, autostart, emulateWebsocket, createDefaultMessage, }: ProxyOptions);
private _swarm;
get swarm(): any;
private _protocol;

3
dist/proxy.js vendored
View File

@ -9,7 +9,7 @@ class Proxy {
_listen;
_socketOptions;
_autostart;
constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, onchannel, listen = false, autostart = false, emulateWebsocket = false, }) {
constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, onchannel, listen = false, autostart = false, emulateWebsocket = false, createDefaultMessage = true, }) {
this._swarm = swarm;
this._protocol = protocol;
this._listen = listen;
@ -21,6 +21,7 @@ class Proxy {
onclose,
onchannel,
emulateWebsocket,
createDefaultMessage,
};
this.init();
}