95 lines
2.6 KiB
TypeScript
95 lines
2.6 KiB
TypeScript
import * as plugins from './smartsocket.plugins.js';
|
|
import * as pluginsTyped from './smartsocket.pluginstyped.js';
|
|
|
|
// used in case no other server is supplied
|
|
import { Smartsocket } from './smartsocket.classes.smartsocket.js';
|
|
import { logger } from './smartsocket.logging.js';
|
|
|
|
/**
|
|
* class socketServer
|
|
* handles the attachment of socketIo to whatever server is in play
|
|
*/
|
|
export class SocketServer {
|
|
private smartsocket: Smartsocket;
|
|
private httpServerDeferred: plugins.smartpromise.Deferred<any>;
|
|
private httpServer: pluginsTyped.http.Server | pluginsTyped.https.Server;
|
|
|
|
/**
|
|
* wether httpServer is standalone
|
|
*/
|
|
private standaloneServer = false;
|
|
|
|
constructor(smartSocketInstance: Smartsocket) {
|
|
this.smartsocket = smartSocketInstance;
|
|
}
|
|
|
|
/**
|
|
* starts the server with another server
|
|
* also works with an express style server
|
|
*/
|
|
public async setExternalServer(
|
|
serverType: 'smartexpress',
|
|
serverArg: pluginsTyped.smartexpress.Server
|
|
) {
|
|
this.httpServerDeferred = plugins.smartpromise.defer();
|
|
await serverArg.startedPromise;
|
|
this.httpServer = serverArg.httpServer;
|
|
this.httpServerDeferred.resolve();
|
|
}
|
|
|
|
/**
|
|
* gets the server for socket.io
|
|
*/
|
|
public async getServerForSocketIo() {
|
|
if (this.httpServerDeferred) {
|
|
await this.httpServerDeferred.promise;
|
|
}
|
|
if (this.httpServer) {
|
|
return this.httpServer;
|
|
} else {
|
|
const httpModule = await this.smartsocket.smartenv.getSafeNodeModule('http');
|
|
this.httpServer = new httpModule.Server();
|
|
this.standaloneServer = true;
|
|
return this.httpServer;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* starts listening to incoming sockets:
|
|
*/
|
|
public async start() {
|
|
const done = plugins.smartpromise.defer();
|
|
|
|
// handle http servers
|
|
// in case an external server has been set "this.standaloneServer" should be false
|
|
if (this.httpServer && this.standaloneServer) {
|
|
if (!this.smartsocket.options.port) {
|
|
logger.log('error', 'there should be a port specifed for smartsocket!');
|
|
throw new Error('there should be a port specified for smartsocket');
|
|
}
|
|
this.httpServer.listen(this.smartsocket.options.port, () => {
|
|
logger.log(
|
|
'success',
|
|
`Server started in standalone mode on ${this.smartsocket.options.port}`
|
|
);
|
|
done.resolve();
|
|
});
|
|
} else {
|
|
done.resolve();
|
|
}
|
|
|
|
// nothing else to do if express server is set
|
|
await done.promise;
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* closes the server
|
|
*/
|
|
public async stop() {
|
|
if (this.httpServer) {
|
|
this.httpServer.close();
|
|
}
|
|
}
|
|
}
|