use external http
This commit is contained in:
+5
-2
@@ -10,7 +10,6 @@ export class RPCServer<
|
|||||||
InterfaceT extends T.RPCInterface = T.RPCInterface,
|
InterfaceT extends T.RPCInterface = T.RPCInterface,
|
||||||
> {
|
> {
|
||||||
|
|
||||||
private ws = http.createServer()
|
|
||||||
private pio = PromiseIO.createServer()
|
private pio = PromiseIO.createServer()
|
||||||
private visibility: T.Visibility
|
private visibility: T.Visibility
|
||||||
private closeHandler: T.CloseHandler
|
private closeHandler: T.CloseHandler
|
||||||
@@ -28,7 +27,8 @@ export class RPCServer<
|
|||||||
constructor(
|
constructor(
|
||||||
private port: number,
|
private port: number,
|
||||||
private exporters: T.ExporterArray<InterfaceT> = [],
|
private exporters: T.ExporterArray<InterfaceT> = [],
|
||||||
conf: T.ServerConf<InterfaceT> = {}
|
private conf: T.ServerConf<InterfaceT> = {},
|
||||||
|
private ws = http.createServer()
|
||||||
) {
|
) {
|
||||||
if (!conf.visibility) this.visibility = "0.0.0.0"
|
if (!conf.visibility) this.visibility = "0.0.0.0"
|
||||||
|
|
||||||
@@ -67,6 +67,8 @@ export class RPCServer<
|
|||||||
\n`+ badRPC.toString() + `
|
\n`+ badRPC.toString() + `
|
||||||
\n>------------OFFENDING RPC`)
|
\n>------------OFFENDING RPC`)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
this.startWebsocket()
|
this.startWebsocket()
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -81,6 +83,7 @@ export class RPCServer<
|
|||||||
this.initRPCs(socket)
|
this.initRPCs(socket)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
if(this.conf.selfStart == null || this.conf.selfStart == true)
|
||||||
this.pio.listen(this.port)
|
this.pio.listen(this.port)
|
||||||
|
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
|
|||||||
@@ -28,6 +28,7 @@ export type ExporterArray<InterfaceT extends RPCInterface = RPCInterface> = I.RP
|
|||||||
export type ConnectedSocket<T extends RPCInterface = RPCInterface> = RPCSocket & AsyncIfc<T>
|
export type ConnectedSocket<T extends RPCInterface = RPCInterface> = RPCSocket & AsyncIfc<T>
|
||||||
|
|
||||||
export type ServerConf<InterfaceT extends RPCInterface> = {
|
export type ServerConf<InterfaceT extends RPCInterface> = {
|
||||||
|
selfStart?: boolean
|
||||||
accessFilter?: AccessFilter<InterfaceT>
|
accessFilter?: AccessFilter<InterfaceT>
|
||||||
connectionHandler?: ConnectionHandler
|
connectionHandler?: ConnectionHandler
|
||||||
errorHandler?: ErrorHandler
|
errorHandler?: ErrorHandler
|
||||||
|
|||||||
Reference in New Issue
Block a user