Skip to content

Commit 4b88f84

Browse files
committed
Add promise to Core#listen
1 parent cde5db7 commit 4b88f84

File tree

1 file changed

+14
-7
lines changed

1 file changed

+14
-7
lines changed

src/core.js

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -157,7 +157,7 @@ class Core extends CoreBase {
157157

158158
logger.success('Initialized!');
159159

160-
this.listen();
160+
await this.listen();
161161
}
162162

163163
return true;
@@ -199,7 +199,7 @@ class Core extends CoreBase {
199199
/**
200200
* Opens HTTP server
201201
*/
202-
listen() {
202+
async listen() {
203203
const httpPort = this.config('port');
204204
const httpHost = this.config('bind');
205205
const wsPort = this.config('ws.port') || httpPort;
@@ -217,11 +217,18 @@ class Core extends CoreBase {
217217
logger.warn('Missing files in "dist/" directory. Did you forget to run "npm run build" ?');
218218
}
219219

220-
this.httpServer.listen(httpPort, httpHost, () => {
221-
logger.success(`Using '${session}' sessions`);
222-
logger.success(`Serving '${dist}'`);
223-
logger.success(`WebSocket listening on ${proto('ws')}${host(wsPort)}`);
224-
logger.success(`Server listening on ${proto('http')}${host(httpPort)}`);
220+
return new Promise((resolve, reject) => {
221+
try {
222+
this.httpServer.listen(httpPort, httpHost, () => {
223+
logger.success(`Using '${session}' sessions`);
224+
logger.success(`Serving '${dist}'`);
225+
logger.success(`WebSocket listening on ${proto('ws')}${host(wsPort)}`);
226+
logger.success(`Server listening on ${proto('http')}${host(httpPort)}`);
227+
resolve();
228+
});
229+
} catch (e) {
230+
reject(e);
231+
}
225232
});
226233
}
227234

0 commit comments

Comments
 (0)