fixed issue with mining rewards counter in stats

pk910 · Jul 3, 2023 · 32a3681 · 32a3681
1 parent b3bd199
commit 32a3681
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 14 deletions.
diff --git a/src/modules/pow/PoWClient.ts b/src/modules/pow/PoWClient.ts
@@ -231,10 +231,10 @@ export class PoWClient {
     let verifyValid = PoWShareVerification.processVerificationResult(verifyRes.shareId, this.getFaucetSession().getSessionId(), verifyRes.isValid);
     let verifyReward = BigInt(this.module.getModuleConfig().powShareReward) * BigInt(this.module.getModuleConfig().verifyMinerRewardPerc * 100) / 10000n;
     if(verifyValid && verifyReward > 0n) {
-      await this.getFaucetSession().addReward(verifyReward);
+      let addedReward = await this.getFaucetSession().addReward(verifyReward);
 
       let faucetStats = ServiceManager.GetService(FaucetStatsLog);
-      faucetStats.statVerifyReward += verifyReward;
+      faucetStats.statVerifyReward += addedReward;
 
       this.sendMessage("updateBalance", {
         balance: this.getFaucetSession().getDropAmount().toString(),

diff --git a/src/modules/pow/PoWShareVerification.ts b/src/modules/pow/PoWShareVerification.ts
@@ -194,24 +194,25 @@ export class PoWShareVerification {
       }
     });
 
-    let shareReward: bigint;
+    let shareReward: Promise<bigint>;
     if(this.isInvalid) {
       this.session.slashSession("invalid PoW result hash");
-      shareReward = 0n;
+      shareReward = Promise.resolve(0n);
     }
     else {
       // valid share - add rewards
-      shareReward = BigInt(powConfig.powShareReward);
-      this.session.getFaucetSession().addReward(shareReward).then((amount) => {
-        this.session.activeClient?.sendMessage("updateBalance", {
-          balance: this.session.getFaucetSession().getDropAmount().toString(),
-          reason: "valid share (reward: " + amount.toString() + ")"
-        });
-      });
+      shareReward = this.session.getFaucetSession().addReward(BigInt(powConfig.powShareReward));
     }
-    this.resultDfd.resolve({
-      isValid: !this.isInvalid,
-      reward: shareReward
+
+    shareReward.then((amount) => {
+      this.session.activeClient?.sendMessage("updateBalance", {
+        balance: this.session.getFaucetSession().getDropAmount().toString(),
+        reason: "valid share (reward: " + amount.toString() + ")"
+      });
+      this.resultDfd.resolve({
+        isValid: !this.isInvalid,
+        reward: amount
+      });
     });
   }