share updates

This commit is contained in:
Ben Wilson
2024-02-17 18:40:14 -05:00
parent e35bacc648
commit 29e0d884e3
+10 -9
View File
@@ -22,11 +22,6 @@ export class StratumV1ClientStatistics {
} }
private async saveShares(client: ClientEntity) {
}
// We don't want to save them here because it can be DB intensive, stead do it every once in // We don't want to save them here because it can be DB intensive, stead do it every once in
// awhile with saveShares() // awhile with saveShares()
public async addShares(client: ClientEntity, targetDifficulty: number) { public async addShares(client: ClientEntity, targetDifficulty: number) {
@@ -45,12 +40,18 @@ export class StratumV1ClientStatistics {
}); });
if (this.currentTimeSlot == null) { if (this.currentTimeSlot == null) {
this.currentTimeSlot = timeSlot; this.currentTimeSlot = timeSlot;
} await this.clientStatisticsService.insert({
time: this.currentTimeSlot,
if (this.currentTimeSlot != timeSlot) { shares: this.shares,
acceptedCount: this.acceptedCount,
address: client.address,
clientName: client.clientName,
sessionId: client.sessionId
});
this.lastSave = new Date().getTime();
} else if (this.currentTimeSlot != timeSlot) {
await this.clientStatisticsService.insert({ await this.clientStatisticsService.insert({
time: this.currentTimeSlot, time: this.currentTimeSlot,
shares: this.shares, shares: this.shares,