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-04-16 07:11:59 -04:00
parent bc85076e7f
commit cfd5f69cfb
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
5 changed files with 21 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
dist/peer.js vendored
View File

@ -33,12 +33,21 @@ class Peer {
const self = this; const self = this;
this._channel = await this._muxer.createChannel({ this._channel = await this._muxer.createChannel({
protocol: this._proxy.protocol, protocol: this._proxy.protocol,
onopen: this.handleChannelOnOpen.bind(this), onopen: async (m) => {
onclose: this.handleChannelOnClose.bind(this), await this.handleChannelOnOpen(m);
// @ts-ignore
await this._onopen?.(this._channel);
},
onclose: async (socket) => {
await this.handleChannelOnClose(socket);
// @ts-ignore
await this._onclose?.();
},
}); });
await this.initMessages(); await this.initMessages();
await this._onchannel?.(this._channel); await this._onchannel?.(this._channel);
await this._channel.open(); await this._channel.open();
this._proxy.emit("peerChannelOpen", this);
} }
async init() { async init() {
await this.initSocket(); await this.initSocket();

1
dist/proxies/basic/peer.js vendored
View File

@ -41,7 +41,6 @@ class Peer extends peer_js_1.default {
} }
async handleChannelOnClose(socket) { async handleChannelOnClose(socket) {
this._socket?.destroy(); this._socket?.destroy();
await this._onclose?.(this._socket);
} }
async initMessages() { async initMessages() {
const self = this; const self = this;

10
dist/proxies/multiSocket.js vendored
View File

@ -149,7 +149,7 @@ class MultiSocketProxy extends proxy_js_1.default {
} }
async _registerOpenSocketMessage(peer) { async _registerOpenSocketMessage(peer) {
const self = this; const self = this;
const message = peer.channel.addMessage({ const message = await peer.channel.addMessage({
encoding: { encoding: {
preencode: compact_encoding_1.json.preencode, preencode: compact_encoding_1.json.preencode,
encode: compact_encoding_1.json.encode, encode: compact_encoding_1.json.encode,
@ -183,7 +183,7 @@ class MultiSocketProxy extends proxy_js_1.default {
} }
async _registerWriteSocketMessage(peer) { async _registerWriteSocketMessage(peer) {
const self = this; const self = this;
const message = peer.channel.addMessage({ const message = await peer.channel.addMessage({
encoding: writeSocketEncoding, encoding: writeSocketEncoding,
onmessage(m) { onmessage(m) {
self._sockets.get(m.id)?.push(m.data); self._sockets.get(m.id)?.push(m.data);
@ -195,7 +195,7 @@ class MultiSocketProxy extends proxy_js_1.default {
} }
async _registerCloseSocketMessage(peer) { async _registerCloseSocketMessage(peer) {
const self = this; const self = this;
const message = peer.channel.addMessage({ const message = await peer.channel.addMessage({
encoding: socketEncoding, encoding: socketEncoding,
onmessage(m) { onmessage(m) {
self._sockets.get(m.id)?.end(); self._sockets.get(m.id)?.end();
@ -207,7 +207,7 @@ class MultiSocketProxy extends proxy_js_1.default {
} }
async _registerTimeoutSocketMessage(peer) { async _registerTimeoutSocketMessage(peer) {
const self = this; const self = this;
const message = peer.channel.addMessage({ const message = await peer.channel.addMessage({
encoding: socketEncoding, encoding: socketEncoding,
onmessage(m) { onmessage(m) {
// @ts-ignore // @ts-ignore
@ -220,7 +220,7 @@ class MultiSocketProxy extends proxy_js_1.default {
} }
async _registerErrorSocketMessage(peer) { async _registerErrorSocketMessage(peer) {
const self = this; const self = this;
const message = peer.channel.addMessage({ const message = await peer.channel.addMessage({
encoding: errorSocketEncoding, encoding: errorSocketEncoding,
onmessage(m) { onmessage(m) {
// @ts-ignore // @ts-ignore

1
dist/proxies/multiSocket/peer.d.ts vendored
View File

@ -2,6 +2,7 @@ import BasePeer from "../../peer.js";
import Socket from "../../socket.js"; import Socket from "../../socket.js";
import MultiSocketProxy from "../multiSocket.js"; import MultiSocketProxy from "../multiSocket.js";
export default class Peer extends BasePeer { export default class Peer extends BasePeer {
protected initMessages(): Promise<void>;
protected _proxy: MultiSocketProxy; protected _proxy: MultiSocketProxy;
protected initSocket(): Promise<void>; protected initSocket(): Promise<void>;
get stream(): any; get stream(): any;

8
dist/proxies/multiSocket/peer.js vendored
View File

@ -5,6 +5,9 @@ var __importDefault = (this && this.__importDefault) || function (mod) {
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
const peer_js_1 = __importDefault(require("../../peer.js")); const peer_js_1 = __importDefault(require("../../peer.js"));
class Peer extends peer_js_1.default { class Peer extends peer_js_1.default {
async initMessages() {
await this._proxy.handleNewPeerChannel(this);
}
async initSocket() { } async initSocket() { }
get stream() { get stream() {
return this._muxer.stream; return this._muxer.stream;
@ -12,9 +15,6 @@ class Peer extends peer_js_1.default {
async handleChannelOnClose(socket) { async handleChannelOnClose(socket) {
return this._proxy.handleClosePeer(this); return this._proxy.handleClosePeer(this);
} }
async handleChannelOnOpen(m) { async handleChannelOnOpen(m) { }
await this._proxy.handleNewPeerChannel(this);
this._proxy.emit("peerOpen", this);
}
} }
exports.default = Peer; exports.default = Peer;