simplify logs

meterio · Mar 23, 2023 · a2d4c1e · a2d4c1e
1 parent e21435e
commit a2d4c1e
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 24 deletions.
diff --git a/libs/poolWorker.js b/libs/poolWorker.js
@@ -184,7 +184,7 @@ module.exports = function(logger){
                 logger.debug(logSystem, logComponent, logSubCat, 'We thought a block was found but it was rejected by the daemon, share data: ' + shareData);
 
             else if (isValidBlock)
-                logger.debug(logSystem, logComponent, logSubCat, 'Block found: ' + data.blockHash + ' by ' + data.worker);
+                logger.special(logSystem, logComponent, logSubCat, 'Block found: ' + data.blockHash + ' by ' + data.worker);
 
             if (isValidShare) {
                 if(data.shareDiff > 1000000000)

diff --git a/libs/rewardProcessor.js b/libs/rewardProcessor.js
@@ -104,9 +104,7 @@ function SetupForPool(logger, poolOptions, setupFinished) {
       },
     ],
     function (err) {
-      console.log("cb: err: ", err);
       if (err) {
-        console.log("setup finished", false);
         setupFinished(false);
         return;
       }
@@ -134,7 +132,6 @@ function SetupForPool(logger, poolOptions, setupFinished) {
         }
       }, processingConfig.rewardInterval * 1000);
       setTimeout(processRewards, 100);
-      console.log("setup finished", true);
       setupFinished(true);
     }
   );
@@ -194,7 +191,7 @@ function SetupForPool(logger, poolOptions, setupFinished) {
               }
 
               // calculate worker balances
-              console.log("workers: ", results[0]);
+              console.log("balances: ", results[0]);
               var workers = {};
               for (var w in results[0]) {
                 workers[w] = {
@@ -287,11 +284,11 @@ function SetupForPool(logger, poolOptions, setupFinished) {
                     );
 
                     totalShares += totalSharesInRound;
-                    logger.debug(
-                      logSystem,
-                      logComponent,
-                      `Total shares in round ${round.height}: ${totalSharesInRound}`
-                    );
+                    // logger.debug(
+                    //   logSystem,
+                    //   logComponent,
+                    //   `Total shares in round ${round.height}: ${totalSharesInRound}`
+                    // );
 
                     for (var workerAddress in workerShares) {
                       if (!(workerAddress in pendingShares)) {
@@ -308,13 +305,13 @@ function SetupForPool(logger, poolOptions, setupFinished) {
                 }
               });
 
-              logger.debug(
-                logSystem,
-                logComponent,
-                `Total Shares: ${totalShares}, len(PendingShares): ${
-                  Object.keys(pendingShares).length
-                }`
-              );
+              // logger.debug(
+              //   logSystem,
+              //   logComponent,
+              //   `Total Shares: ${totalShares}, len(PendingShares): ${
+              //     Object.keys(pendingShares).length
+              //   }`
+              // );
               if ("time" in pendingShares) {
                 delete pendingShares["time"];
               }
@@ -331,7 +328,7 @@ function SetupForPool(logger, poolOptions, setupFinished) {
           logger.debug(
             logSystem,
             logComponent,
-            `Read balance/reserve and calculate the actual reward for each worker`
+            `Start to calculate the actual reward for each worker`
           );
           startRPCTimer();
           web3.eth.getEnergy(beneficiary, function (err, bal) {
@@ -372,7 +369,6 @@ function SetupForPool(logger, poolOptions, setupFinished) {
 
             // if actual total reward is not enough for distribute, skip
             if (actualTotalReward.isLessThanOrEqualTo(0)) {
-              logger.debug(logSystem, logComponent, "No reward this interval");
               return callback(new Error("no reward this interval"));
             }
 

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -43,7 +43,7 @@
     "ethers": "^5.4.4",
     "express": "*",
     "extend": "*",
-    "meter-stratum-pool": "^0.2.10",
+    "meter-stratum-pool": "^0.2.12",
     "meterify": "^1.4.7",
     "mysql": "*",
     "node-json-minify": "*",