diff --git a/src/ORM/client-statistics/client-statistics.service.ts b/src/ORM/client-statistics/client-statistics.service.ts index c803d7a..7870d14 100644 --- a/src/ORM/client-statistics/client-statistics.service.ts +++ b/src/ORM/client-statistics/client-statistics.service.ts @@ -30,7 +30,7 @@ export class ClientStatisticsService { // }); // } - public async updateBulkAsync(clientStatistic: Partial, lastSeenIndex: number) { + public updateBulkAsync(clientStatistic: Partial, lastSeenIndex: number) { if(this.bulkAsyncUpdates.length > lastSeenIndex && this.bulkAsyncUpdates[lastSeenIndex].clientId == clientStatistic.clientId && this.bulkAsyncUpdates[lastSeenIndex].time == clientStatistic.time){ this.bulkAsyncUpdates[lastSeenIndex].shares = clientStatistic.shares; diff --git a/src/models/StratumV1ClientStatistics.ts b/src/models/StratumV1ClientStatistics.ts index 1bbe5d6..6e4692d 100644 --- a/src/models/StratumV1ClientStatistics.ts +++ b/src/models/StratumV1ClientStatistics.ts @@ -62,7 +62,7 @@ export class StratumV1ClientStatistics { } else if (this.currentTimeSlot != timeSlot) { // Transitioning to a new time slot, // First update the old time slot with the latest data - this.bulkUpdateIndex = await this.clientStatisticsService.updateBulkAsync({ + this.bulkUpdateIndex = this.clientStatisticsService.updateBulkAsync({ time: this.currentTimeSlot, clientId: client.id, shares: this.shares, @@ -87,7 +87,7 @@ export class StratumV1ClientStatistics { // saving to memory for storing later this.shares += targetDifficulty; this.acceptedCount++; - this.bulkUpdateIndex = await this.clientStatisticsService.updateBulkAsync({ + this.bulkUpdateIndex = this.clientStatisticsService.updateBulkAsync({ time: this.currentTimeSlot, clientId: client.id, shares: this.shares,