Skip to content

Commit 2e74fa3

Browse files
committed
fix: websocket
1 parent e89714b commit 2e74fa3

File tree

1 file changed

+18
-18
lines changed

1 file changed

+18
-18
lines changed

src/service/websocket-service.ts

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -272,27 +272,27 @@ export default class WebSocketService {
272272
return;
273273
}
274274

275+
const port = process.env.WEBSOCKET_PORT ? parseInt(process.env.WEBSOCKET_PORT, 10) : 8080;
276+
275277
if (process.env.NODE_ENV == 'production') {
276278
this.setupAdapter();
277-
} else {
278-
const port = process.env.WEBSOCKET_PORT ? parseInt(process.env.WEBSOCKET_PORT, 10) : 8080;
279+
}
279280

280-
// Only start listening if not already listening
281-
if (!this.server.listening) {
282-
this.server.listen(port, () => {
283-
this.logger.info(`WebSocket opened on port ${port}.`);
284-
});
285-
// Handle EADDRINUSE error gracefully (e.g., in tests where port might already be in use)
286-
this.server.on('error', (error: NodeJS.ErrnoException) => {
287-
if (error.code === 'EADDRINUSE') {
288-
this.logger.warn(`Port ${port} is already in use. WebSocket server may already be running.`);
289-
} else {
290-
this.logger.error('WebSocket server error:', error);
291-
}
292-
});
293-
} else {
294-
this.logger.trace(`WebSocket server already listening on port ${port}, skipping listen call`);
295-
}
281+
// Only start listening if not already listening
282+
if (!this.server.listening) {
283+
this.server.listen(port, () => {
284+
this.logger.info(`WebSocket opened on port ${port}.`);
285+
});
286+
// Handle EADDRINUSE error gracefully (e.g., in tests where port might already be in use)
287+
this.server.on('error', (error: NodeJS.ErrnoException) => {
288+
if (error.code === 'EADDRINUSE') {
289+
this.logger.warn(`Port ${port} is already in use. WebSocket server may already be running.`);
290+
} else {
291+
this.logger.error('WebSocket server error:', error);
292+
}
293+
});
294+
} else {
295+
this.logger.trace(`WebSocket server already listening on port ${port}, skipping listen call`);
296296
}
297297

298298
// Authenticate before allowing any socket events to race it.

0 commit comments

Comments
 (0)