highperfocused/public-pool
1
0
Fork 0
mirror of https://github.com/benjamin-wilson/public-pool.git synced 2025-03-27 02:02:10 +01:00
Code Issues Packages Projects Releases Wiki Activity

remove logging

Browse Source
This commit is contained in:
Ben Wilson 2023-08-06 17:45:30 -04:00
parent 32c1a34202
commit 24538d34ce
3 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/ORM/client/client.service.ts
View File

@ -20,13 +20,13 @@ export class ClientService {
public async killDeadClients() {
var tenMinutes = new Date(new Date().getTime() - (10 * 60 * 1000)).toISOString();
var fiveMinutes = new Date(new Date().getTime() - (5 * 60 * 1000)).toISOString();
return await this.clientRepository
.createQueryBuilder()
.update(ClientEntity)
.set({ deletedAt: () => "DATETIME('now')" })
.where("deletedAt IS NULL AND updatedAt < :tenMinutes", { tenMinutes })
.where("deletedAt IS NULL AND updatedAt < :fiveMinutes", { fiveMinutes })
.execute();
}

7
src/models/StratumV1Client.ts
View File

@ -98,7 +98,7 @@ export class StratumV1Client {
private async handleMessage(message: string) {
console.log(`Received from ${this.extraNonceAndSessionId}`, message);
// console.log(`Received from ${this.extraNonceAndSessionId}`, message);
// Parse the message and check if it's the initial subscription message
let parsedMessage = null;
@ -201,10 +201,7 @@ export class StratumV1Client {
if (errors.length === 0) {
this.clientAuthorization = authorizationMessage;
console.log('AUTH START');
//const response = this.buildSubscriptionResponse(authorizationMessage.id);
const success = await this.write(JSON.stringify(this.clientAuthorization.response()) + '\n');
console.log('AUTH FIN');
if (!success) {
return;
}
@ -305,7 +302,6 @@ export class StratumV1Client {
}
}
console.log('test')
if (this.clientSubscription != null
&& this.clientAuthorization != null
@ -563,7 +559,6 @@ export class StratumV1Client {
}
private async write(message: string): Promise<boolean> {
console.log(message)
try {
if (!this.socket.destroyed && !this.socket.writableEnded) {

2
src/services/app.service.ts
View File

@ -36,7 +36,7 @@ export class AppService implements OnModuleInit {
}
}
@Cron(CronExpression.EVERY_10_MINUTES)
@Cron(CronExpression.EVERY_5_MINUTES)
private async killDeadClients() {
if (process.env.NODE_APP_INSTANCE == null || process.env.NODE_APP_INSTANCE == '0') {