From 5c230d132e9d961c4c1e7c00b07517c3448451c2 Mon Sep 17 00:00:00 2001 From: Ben Date: Tue, 3 Oct 2023 08:02:27 -0400 Subject: [PATCH] end socket on timeout --- src/services/stratum-v1.service.ts | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/services/stratum-v1.service.ts b/src/services/stratum-v1.service.ts index 016f300..9ea1f9b 100644 --- a/src/services/stratum-v1.service.ts +++ b/src/services/stratum-v1.service.ts @@ -45,8 +45,8 @@ export class StratumV1Service implements OnModuleInit { private startSocketServer() { const server = new Server(async (socket: Socket) => { - //5 min - socket.setTimeout(1000 * 60 * 5); + //1 min + socket.setTimeout(1000 * 60); const client = new StratumV1Client( socket, @@ -69,6 +69,11 @@ export class StratumV1Service implements OnModuleInit { } }); + socket.on('timeout', () => { + console.log('socket timeout'); + socket.end(); + }); + socket.on('error', async (error: Error) => { }); // //console.log(`Client disconnected, socket error, ${client.extraNonceAndSessionId}`);