37 lines
959 B
TypeScript
37 lines
959 B
TypeScript
|
import Proxy from "./proxy.js";
|
||
|
|
import Socket from "./socket.js";
|
||
|
|
export type OnOpen = (socket: Socket, data: any) => {
|
||
|
|
connect: boolean;
|
||
|
|
} | Promise<{
|
||
|
|
connect: boolean;
|
||
|
|
}> | Promise<void> | void;
|
||
|
|
export type OnData = (data: any) => void;
|
||
|
|
export type OnReceive = OnData;
|
||
|
|
export type OnClose = OnData;
|
||
|
|
export type OnSend = OnData;
|
||
|
|
export interface DataSocketOptions {
|
||
|
|
onopen?: OnOpen;
|
||
|
|
onreceive?: OnReceive;
|
||
|
|
onsend?: OnSend;
|
||
|
|
onclose?: OnClose;
|
||
|
|
}
|
||
|
|
export interface PeerOptions {
|
||
|
|
peer: any;
|
||
|
|
muxer: any;
|
||
|
|
}
|
||
|
|
export interface PeerOptionsWithProxy extends PeerOptions {
|
||
|
|
proxy: Proxy;
|
||
|
|
}
|
||
|
|
export default class Peer {
|
||
|
|
private _proxy;
|
||
|
|
private _peer;
|
||
|
|
private _muxer;
|
||
|
|
private _socket?;
|
||
|
|
private _onopen;
|
||
|
|
private _onreceive;
|
||
|
|
private _onsend;
|
||
|
|
private _onclose;
|
||
|
|
constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, }: PeerOptionsWithProxy & DataSocketOptions);
|
||
|
|
init(): Promise<void>;
|
||
|
|
}
|