feat: add rchash command (#613)

Author: Cafe137

package-lock.json

@@ -63,7 +63,7 @@
   },
   "dependencies": {
     "@ethereumjs/wallet": "^2.0.4",
-    "@ethersphere/bee-js": "^9.2.0",
+    "@ethersphere/bee-js": "^9.4.0",
     "cafe-utility": "^27.14.0",
     "chalk": "^2.4.2",
     "cli-progress": "^3.11.2",

package.json

@@ -7,6 +7,7 @@ import { Cid } from './cid'
 import { CreateBatch } from './create-batch'
 import { GetBee } from './get-bee'
 import { Lock } from './lock'
+import { Rchash } from './rchash'
 import { Redeem } from './redeem'
 import { Unlock } from './unlock'
 
@@ -15,7 +16,7 @@ export class Utility implements GroupCommand {
 
   public readonly description = 'Utility commands related to Swarm and wallets'
 
-  public subCommandClasses = [Cid, Lock, Unlock, GetBee, Redeem, CreateBatch]
+  public subCommandClasses = [Cid, Lock, Unlock, GetBee, Redeem, CreateBatch, Rchash]
 }
 
 export async function createWallet(pathOrPrivateKey: string, console: CommandLog): Promise<Wallet> {

src/command/utility/index.ts

@@ -0,0 +1,32 @@
+import { System } from 'cafe-utility'
+import { LeafCommand } from 'furious-commander'
+import { createSpinner } from '../../utils/spinner'
+import { createKeyValue } from '../../utils/text'
+import { RootCommand } from '../root-command'
+
+export class Rchash extends RootCommand implements LeafCommand {
+  public readonly name = 'rchash'
+
+  public readonly description = 'Check reserve sampling duration'
+
+  public async run(): Promise<void> {
+    super.init()
+    const addresses = await this.bee.getNodeAddresses()
+    const topology = await this.bee.getTopology()
+    let stillRunning = true
+    const promise = this.bee.rchash(topology.depth, addresses.overlay.toHex(), addresses.overlay.toHex())
+    promise.finally(() => {
+      stillRunning = false
+    })
+    const startedAt = Date.now()
+    const spinner = createSpinner('Running rchash...').start()
+    while (stillRunning) {
+      await System.sleepMillis(1000)
+      const duration = (Date.now() - startedAt) / 1000
+      spinner.text = `Running rchash ${duration.toFixed()}s`
+    }
+    spinner.stop()
+    const result = await promise
+    this.console.log(createKeyValue('Reserve sampling duration', result + ' seconds'))
+  }
+}