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}`);