77 lines
1.9 KiB
TypeScript
77 lines
1.9 KiB
TypeScript
|
import * as plugins from './smartsocket.plugins';
|
||
|
|
|
||
|
|
// used in case no other server is supplied
|
||
|
|
import * as http from 'http';
|
||
|
|
import { Smartsocket } from './smartsocket.classes.smartsocket';
|
||
|
|
|
||
|
|
/**
|
||
|
|
* class socketServer
|
||
|
|
* handles the attachment of socketIo to whatever server is in play
|
||
|
|
*/
|
||
|
|
export class SocketServer {
|
||
|
|
private smartsocket: Smartsocket;
|
||
|
|
private httpServer: http.Server;
|
||
|
|
// wether httpServer is standalone
|
||
|
|
private standaloneServer = false;
|
||
|
|
private expressServer: any;
|
||
|
|
|
||
|
|
constructor(smartSocketInstance: Smartsocket) {
|
||
|
|
this.smartsocket = smartSocketInstance;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* starts the server with another server
|
||
|
|
* also works with an express style server
|
||
|
|
*/
|
||
|
|
public async setExternalServer(serverType: 'express' | 'http', serverArg: any) {
|
||
|
|
if (serverType === 'http') {
|
||
|
|
this.httpServer = serverArg;
|
||
|
|
} else if (serverType === 'express') {
|
||
|
|
this.expressServer = serverArg;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* gets the server for socket.io
|
||
|
|
*/
|
||
|
|
public getServerForSocketIo() {
|
||
|
|
if (this.httpServer) {
|
||
|
|
return this.httpServer;
|
||
|
|
} else if (this.expressServer) {
|
||
|
|
return this.expressServer;
|
||
|
|
} else if (!this.httpServer && !this.expressServer) {
|
||
|
|
this.httpServer = new http.Server();
|
||
|
|
this.standaloneServer = true;
|
||
|
|
return this.httpServer;
|
||
|
|
} else {
|
||
|
|
throw new Error('no server specified!');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* starts listening to incoming sockets:
|
||
|
|
*/
|
||
|
|
public async start() {
|
||
|
|
const done = plugins.smartq.defer();
|
||
|
|
|
||
|
|
// handle http servers
|
||
|
|
if (this.httpServer && this.standaloneServer) {
|
||
|
|
this.httpServer.listen(this.smartsocket.options.port, () => {
|
||
|
|
console.log(`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() {}
|
||
|
|
}
|