feat: more status command output

package.json

@@ -71,6 +71,7 @@
     "lodash.get": "^4.4.2",
     "lodash.merge": "^4.6.2",
     "lodash.set": "^4.3.2",
+    "node-fetch": "^2.6.0",
     "node-graceful": "^3.0.0",
     "pretty-bytes": "^5.3.0",
     "pretty-ms": "^7.0.0",

src/commands/status/core.js

@@ -0,0 +1,174 @@
+const { table } = require('table');
+const fetch = require('node-fetch');
+const chalk = require('chalk');
+
+const BaseCommand = require('../../oclif/command/BaseCommand');
+const CoreService = require('../../core/CoreService');
+
+const ContainerIsNotPresentError = require('../../docker/errors/ContainerIsNotPresentError');
+
+class CoreStatusCommand extends BaseCommand {
+  /**
+   * @param {Object} args
+   * @param {Object} flags
+   * @param {DockerCompose} dockerCompose
+   * @param {CoreService} coreService
+   * @param {Config} config
+   * @return {Promise<void>}
+   */
+  async runWithDependencies(
+    args,
+    flags,
+    dockerCompose,
+    createRpcClient,
+    config,
+  ) {
+    const rows = [];
+
+    const coreService = new CoreService(
+      createRpcClient(
+        {
+          port: config.get('core.rpc.port'),
+          user: config.get('core.rpc.user'),
+          pass: config.get('core.rpc.password'),
+        },
+      ),
+      dockerCompose.docker.getContainer('core'),
+    );
+
+    const insightURLs = {
+      evonet: 'http://insight.evonet.networks.dash.org:3001/insight-api',
+      testnet: 'https://testnet-insight.dashevo.org/insight-api',
+      mainnet: 'https://insight.dash.org/insight-api',
+    };
+
+    // Collect data
+    const {
+      result: {
+        blocks: coreBlocks,
+        chain: coreChain,
+        difficulty: coreDifficulty,
+        headers: coreHeaders,
+        verificationprogress: coreVerificationProgress,
+      },
+    } = await coreService.getRpcClient().getBlockchainInfo();
+    const { result: networkInfo } = await coreService.getRpcClient().getNetworkInfo();
+    const { result: mnsyncStatus } = await coreService.getRpcClient().mnsync('status');
+    const { result: peerInfo } = await coreService.getRpcClient().getPeerInfo();
+    const latestVersionRes = await fetch('https://api.github.com/repos/dashpay/dash/releases/latest');
+    let {
+      tag_name: latestVersion,
+    } = await latestVersionRes.json();
+    latestVersion = latestVersion.substring(1);
+    const corePortStateRes = await fetch(`https://mnowatch.org/${config.options.core.p2p.port}/`);
+    let corePortState = await corePortStateRes.text();
+    let coreVersion = networkInfo.subversion.replace(/\/|\(.*?\)|Dash Core:/g, '');
+    let explorerBlockHeightRes;
+    let explorerBlockHeight;
+    if (insightURLs[config.options.network]) {
+      explorerBlockHeightRes = await fetch(`${insightURLs[config.options.network]}/status`);
+      ({
+        info: {
+          blocks: explorerBlockHeight,
+        },
+      } = await explorerBlockHeightRes.json());
+    }
+    const sentinelVersion = (await dockerCompose.execCommand(
+      config.toEnvs(),
+      'sentinel',
+      'python bin/sentinel.py -v',
+    )).out.split('\n')[0].replace(/Dash Sentinel v/, '');
+    let sentinelState = (await dockerCompose.execCommand(
+      config.toEnvs(),
+      'sentinel',
+      'python bin/sentinel.py',
+    )).out.split('\n')[0];
+
+    // Determine status
+    let status;
+    try {
+      ({
+        State: {
+          Status: status,
+        },
+      } = await dockerCompose.inspectService(config.toEnvs(), 'core'));
+    } catch (e) {
+      if (e instanceof ContainerIsNotPresentError) {
+        status = 'not started';
+      }
+    }
+    if (status === 'running' && mnsyncStatus.AssetName !== 'MASTERNODE_SYNC_FINISHED') {
+      status = `syncing ${(coreVerificationProgress * 100).toFixed(2)}%`;
+    }
+
+    // Apply colors
+    if (status === 'running') {
+      status = chalk.green(status);
+    } else if (status.startsWith('syncing')) {
+      status = chalk.yellow(status);
+    } else {
+      status = chalk.red(status);
+    }
+
+    if (coreVersion === latestVersion) {
+      coreVersion = chalk.green(coreVersion);
+    } else if (coreVersion.match(/\d+.\d+/)[0] === latestVersion.match(/\d+.\d+/)[0]) {
+      coreVersion = chalk.yellow(coreVersion);
+    } else {
+      coreVersion = chalk.red(coreVersion);
+    }
+
+    if (corePortState === 'OPEN') {
+      corePortState = chalk.green(corePortState);
+    } else {
+      corePortState = chalk.red(corePortState);
+    }
+
+    let blocks;
+    if (coreBlocks === coreHeaders || coreBlocks >= explorerBlockHeight) {
+      blocks = chalk.green(coreBlocks);
+    } else if ((explorerBlockHeight - coreBlocks) < 3) {
+      blocks = chalk.yellow(coreBlocks);
+    } else {
+      blocks = chalk.red(coreBlocks);
+    }
+
+    if (sentinelState === '') {
+      sentinelState = chalk.green('No errors');
+    } else {
+      sentinelState = chalk.red(sentinelState);
+    }
+
+    // Build table
+    rows.push(['Version', coreVersion]);
+    rows.push(['Latest version', latestVersion]);
+    rows.push(['Network', coreChain]);
+    rows.push(['Status', status]);
+    rows.push(['Sync asset', mnsyncStatus.AssetName]);
+    rows.push(['Peer count', peerInfo.length]);
+    rows.push(['P2P service', `${config.options.externalIp}:${config.options.core.p2p.port}`]);
+    rows.push(['P2P port', `${config.options.core.p2p.port} ${corePortState}`]);
+    rows.push(['RPC service', `127.0.0.1:${config.options.core.rpc.port}`]);
+    rows.push(['Block height', blocks]);
+    rows.push(['Header height', coreHeaders]);
+    if (insightURLs[config.options.network]) {
+      rows.push(['Remote block height', explorerBlockHeight]);
+    }
+    rows.push(['Difficulty', coreDifficulty]);
+    rows.push(['Sentinel version', sentinelVersion]);
+    rows.push(['Sentinel status', (sentinelState)]);
+
+    const output = table(rows, { singleLine: true });
+
+    // eslint-disable-next-line no-console
+    console.log(output);
+  }
+}
+
+CoreStatusCommand.description = 'Show core status details';
+
+CoreStatusCommand.flags = {
+  ...BaseCommand.flags,
+};
+
+module.exports = CoreStatusCommand;

src/commands/status/host.js

@@ -16,8 +16,9 @@ class HostStatusCommand extends BaseCommand {
     rows.push(['Hostname', os.hostname()]);
     rows.push(['Uptime', prettyMs(os.uptime() * 1000)]);
     rows.push(['Platform', os.platform()]);
+    rows.push(['Arch', os.arch()]);
     rows.push(['Username', os.userInfo().username]);
-    rows.push(['Loadavg', os.loadavg()]);
+    rows.push(['Loadavg', os.loadavg().map((load) => load.toFixed(2))]);
     rows.push(['Diskfree', 0]); // Waiting for feature: https://github.com/nodejs/node/pull/31351
     rows.push(['Memory', `${prettyByte(os.totalmem())} / ${prettyByte(os.freemem())}`]);
     rows.push(['CPUs', os.cpus().length]);