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

bug

Browse Source
This commit is contained in:
Benjamin Wilson
2025-02-26 17:07:04 -05:00
parent fd24807c55
commit 8584c442dc
2 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ORM/client-statistics/client-statistics.service.ts
+8 -1
View File
@@ -33,7 +33,14 @@ export class ClientStatisticsService {
// } // }
public updateBulkAsync(clientStatistic: Partial<ClientStatisticsEntity>) { public updateBulkAsync(clientStatistic: Partial<ClientStatisticsEntity>) {
this.bulkAsyncUpdates[clientStatistic.client + clientStatistic.time.toString()] = clientStatistic; const key = clientStatistic.clientId + clientStatistic.time.toString();
if(this.bulkAsyncUpdates[key] != null){
this.bulkAsyncUpdates[key].shares = clientStatistic.shares;
this.bulkAsyncUpdates[key].acceptedCount = clientStatistic.acceptedCount;
return;
}
this.bulkAsyncUpdates[clientStatistic.clientId + clientStatistic.time.toString()] = clientStatistic;
} }
public async doBulkAsyncUpdate(){ public async doBulkAsyncUpdate(){
src/services/app.service.ts
+1 -1
View File
@@ -51,7 +51,7 @@ export class AppService implements OnModuleInit {
} }
setInterval(async () => { setInterval(async () => {
console.log('Bulk update client stats'); //console.log('Bulk update client stats');
await this.clientStatisticsService.doBulkAsyncUpdate(); await this.clientStatisticsService.doBulkAsyncUpdate();
}, 1000 * 60 * 1); }, 1000 * 60 * 1);