fix: improved logging

common/protocol/src/index.ts

@@ -47,7 +47,7 @@ import {
   isStorageBalanceLow,
 } from "./methods";
 import { ICacheProvider, IMetrics, IRuntime } from "./types";
-import { REFRESH_TIME, sleep, standardizeError } from "./utils";
+import { IDLE_TIME, sleep, standardizeError } from "./utils";
 import { SupportedChains } from "@kyvejs/sdk/dist/constants";
 import { storageProviderFactory } from "./reactors/storageProviders";
 import { compressionFactory } from "./reactors/compression";
@@ -319,7 +319,7 @@ export class Validator {
 
     // until data is not available we wait and idle
     while (!(await this.isDataAvailable())) {
-      await sleep(REFRESH_TIME);
+      await sleep(IDLE_TIME);
     }
 
     if (!(await this.isDataAvailable())) {

common/protocol/src/methods/checks/isDataAvailable.ts

@@ -11,16 +11,14 @@ import { Validator, standardizeError } from "../..";
  * @return {Promise<boolean>}
  */
 export async function isDataAvailable(this: Validator): Promise<boolean> {
-  let nextKey: string = "";
-
   try {
     // log debug method
     if (this.pool.data!.current_key) {
       this.logger.debug(`this.runtime.nextKey(${this.pool.data!.current_key})`);
     }
 
     // get the next key to node has to fetch
-    nextKey = this.pool.data!.current_key
+    const nextKey = this.pool.data!.current_key
       ? await this.runtime.nextKey(this, this.pool.data!.current_key)
       : this.pool.data!.start_key;
 
@@ -47,9 +45,7 @@ export async function isDataAvailable(this: Validator): Promise<boolean> {
 
     return true;
   } catch (err) {
-    this.logger.warn(
-      `Data not available for next key: ${nextKey}: Retrying in 10s ...`
-    );
+    this.logger.warn(`Data not available for next key. Retrying in 60s ...`);
     this.logger.debug(standardizeError(err));
 
     return false;