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

Compare commits

base: LumeWeb:b1ad8399d335eab0f032035837dfe00263d458e0
Branches Tags
LumeWeb:master
LumeWeb:develop
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1
..
compare: LumeWeb:f89e2716f52cdb6e5cba2871d23b581671efa43e
Branches Tags
LumeWeb:develop
LumeWeb:master
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1

2 Commits
b1ad8399d3 ... f89e2716f5

Author SHA1 Message Date
Derrick Hammer f89e2716f5
*Update dist 2023-02-25 22:47:19 -05:00
Derrick Hammer 84f2f96e12
*Change WS aliases to be conditional 
*Remove on/off aliases since streamx already provides it
 2023-02-25 22:46:34 -05:00
3 changed files with 13 additions and 20 deletions
Show Stats Expand all files Collapse all files

10
dist/socket.d.ts vendored
View File

@ -1,6 +1,4 @@
/// <reference types="node" />
import { Duplex, DuplexEvents, Callback } from "streamx";
import { write } from "fs";
type AddressFamily = "IPv6" | "IPv4";
interface SocketOptions {
allowHalfOpen?: boolean;
@ -20,6 +18,9 @@ export default class Socket extends Duplex {
writable: true;
remotePublicKey: Uint8Array;
private _emulateWebsocket;
addEventListener: typeof this.addListener;
removeEventListener: typeof this.removeListener;
send: typeof this.write;
constructor({ allowHalfOpen, remoteAddress, remotePort, remotePublicKey, write, emulateWebsocket, }?: SocketOptions);
private _connecting;
get connecting(): boolean;
@ -34,11 +35,6 @@ export default class Socket extends Duplex {
port: any;
family: AddressFamily;
};
addEventListener: <TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping">(event: TEvent, listener: TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping" ? DuplexEvents<any, any>[TEvent] : (...args: any[]) => void) => this;
on: <TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping">(event: TEvent, listener: TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping" ? DuplexEvents<any, any>[TEvent] : (...args: any[]) => void) => this;
removeEventListener: <TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping">(event: TEvent, listener: TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping" ? DuplexEvents<any, any>[TEvent] : (...args: any[]) => void) => this;
off: <TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping">(event: TEvent, listener: TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping" ? DuplexEvents<any, any>[TEvent] : (...args: any[]) => void) => this;
send: typeof write;
static isIP(input: string): number;
static isIPv4(input: string): boolean;
static isIPv6(input: string): boolean;

9
dist/socket.js vendored
View File

@ -1,7 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const streamx_1 = require("streamx");
const fs_1 = require("fs");
const IPV4 = "IPv4";
const IPV6 = "IPv6";
class Socket extends streamx_1.Duplex {
@ -27,6 +26,9 @@ class Socket extends streamx_1.Duplex {
this.remoteFamily = type === 6 ? IPV6 : IPV4;
}
if (this._emulateWebsocket) {
this.addEventListener = this.addListener;
this.removeEventListener = this.removeListener;
this.send = this.write;
this.addEventListener("data", (data) =>
// @ts-ignore
this.emit("message", new MessageEvent("data", { data })));
@ -83,11 +85,6 @@ class Socket extends streamx_1.Duplex {
family: this.remoteFamily,
};
}
addEventListener = this.addListener;
on = this.addListener;
removeEventListener = this.removeListener;
off = this.removeListener;
send = fs_1.write;
static isIP(input) {
if (Socket.isIPv4(input)) {
return 4;

14
src/socket.ts
View File

@ -32,6 +32,10 @@ export default class Socket extends Duplex {
public remotePublicKey: Uint8Array;
private _emulateWebsocket: boolean;
declare addEventListener: typeof this.addListener;
declare removeEventListener: typeof this.removeListener;
declare send: typeof this.write;
constructor({
allowHalfOpen = false,
remoteAddress,
@ -57,6 +61,9 @@ export default class Socket extends Duplex {
}
if (this._emulateWebsocket) {
this.addEventListener = this.addListener;
this.removeEventListener = this.removeListener;
this.send = this.write;
this.addEventListener("data", (data: any) =>
// @ts-ignore
this.emit("message", new MessageEvent("data", { data }))
@ -119,13 +126,6 @@ export default class Socket extends Duplex {
};
}
addEventListener = this.addListener;
on = this.addListener;
removeEventListener = this.removeListener;
off = this.removeListener;
send = write;
static isIP(input: string): number {
if (Socket.isIPv4(input)) {
return 4;