gravatite/public-pool
1
0
Fork 0
mirror of https://github.com/benjamin-wilson/public-pool.git synced 2026-09-29 09:05:06 -07:00
Code Issues Packages Projects Releases Wiki Activity

typeo

Browse Source
This commit is contained in:
Benjamin Wilson
2025-02-25 19:27:34 -05:00
parent 903aa2628c
commit 326a5a7b33
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ORM/client-statistics/client-statistics.service.ts
+1 -1
View File
@@ -30,7 +30,7 @@ export class ClientStatisticsService {
// }); // });
// } // }
public async updateBulkAsync(clientStatistic: Partial<ClientStatisticsEntity>, lastSeenIndex: number) { public updateBulkAsync(clientStatistic: Partial<ClientStatisticsEntity>, lastSeenIndex: number) {
if(this.bulkAsyncUpdates.length > lastSeenIndex && this.bulkAsyncUpdates[lastSeenIndex].clientId == clientStatistic.clientId && this.bulkAsyncUpdates[lastSeenIndex].time == clientStatistic.time){ if(this.bulkAsyncUpdates.length > lastSeenIndex && this.bulkAsyncUpdates[lastSeenIndex].clientId == clientStatistic.clientId && this.bulkAsyncUpdates[lastSeenIndex].time == clientStatistic.time){
this.bulkAsyncUpdates[lastSeenIndex].shares = clientStatistic.shares; this.bulkAsyncUpdates[lastSeenIndex].shares = clientStatistic.shares;
src/models/StratumV1ClientStatistics.ts
+2 -2
View File
@@ -62,7 +62,7 @@ export class StratumV1ClientStatistics {
} else if (this.currentTimeSlot != timeSlot) { } else if (this.currentTimeSlot != timeSlot) {
// Transitioning to a new time slot, // Transitioning to a new time slot,
// First update the old time slot with the latest data // First update the old time slot with the latest data
this.bulkUpdateIndex = await this.clientStatisticsService.updateBulkAsync({ this.bulkUpdateIndex = this.clientStatisticsService.updateBulkAsync({
time: this.currentTimeSlot, time: this.currentTimeSlot,
clientId: client.id, clientId: client.id,
shares: this.shares, shares: this.shares,
@@ -87,7 +87,7 @@ export class StratumV1ClientStatistics {
// saving to memory for storing later // saving to memory for storing later
this.shares += targetDifficulty; this.shares += targetDifficulty;
this.acceptedCount++; this.acceptedCount++;
this.bulkUpdateIndex = await this.clientStatisticsService.updateBulkAsync({ this.bulkUpdateIndex = this.clientStatisticsService.updateBulkAsync({
time: this.currentTimeSlot, time: this.currentTimeSlot,
clientId: client.id, clientId: client.id,
shares: this.shares, shares: this.shares,