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-15 22:38:07 -04:00
parent f11e3fed78
commit a8419313b5
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dist/proxies/multiSocket.d.ts vendored
View File

@ -1,8 +1,9 @@
/// <reference types="node" />
import Proxy, { ProxyOptions } from "../proxy.js";
import type { TcpSocketConnectOpts } from "net";
import Peer, { DataSocketOptions, PeerOptions } from "../peer.js";
import { DataSocketOptions, PeerOptions } from "../peer.js";
import { PeerEntity } from "./multiSocket/types.js";
import Peer from "./multiSocket/peer.js";
export interface MultiSocketProxyOptions extends ProxyOptions {
socketClass?: any;
server: boolean;

14
dist/proxies/multiSocket.js vendored
View File

@ -10,6 +10,7 @@ const serialize_error_1 = require("serialize-error");
const b4a_1 = __importDefault(require("b4a"));
const util_js_1 = require("../util.js");
const dummySocket_js_1 = __importDefault(require("./multiSocket/dummySocket.js"));
const peer_js_1 = __importDefault(require("./multiSocket/peer.js"));
const socketEncoding = {
preencode(state, m) {
compact_encoding_1.uint.preencode(state, m.id);
@ -54,7 +55,15 @@ const errorSocketEncoding = {
};
const nextSocketId = (0, util_js_1.idFactory)(1);
class MultiSocketProxy extends proxy_js_1.default {
handlePeer({ peer, muxer, ...options }) { }
handlePeer({ peer, muxer, ...options }) {
new peer_js_1.default({
...this.socketOptions,
proxy: this,
peer,
muxer,
...options,
});
}
socketClass;
_peers = new Map();
_nextPeer = (0, util_js_1.roundRobinFactory)(this._peers);
@ -62,9 +71,6 @@ class MultiSocketProxy extends proxy_js_1.default {
_allowedPorts = [];
constructor(options) {
super(options);
this._socketOptions.onchannel = this.handleNewPeerChannel.bind(this);
this._socketOptions.onclose = this.handleClosePeer.bind(this);
this._socketOptions.onopen = this.handlePeer.bind(this);
if (options.socketClass) {
this.socketClass = options.socketClass;
}