run method

@override Future<void> run()

Runs this command.

The return value is wrapped in a Future if necessary and returned by CommandRunner.runCommand.

Implementation

@override
Future<void> run() async {
  final args = argResults!;
  final rest = args.rest;
  if (rest.isEmpty) throw CliError('usage: node metrics <id> [--since 1h]');
  final since = args['since'] as String?;

  final client = _apiClientFrom(args);
  try {
    final points = await client.metrics(
      rest.first,
      since: since ?? '1h',
      limit: int.tryParse(args['limit'] as String) ?? 200,
    );
    if (args['json'] as bool) {
      stdout.writeln(
        const JsonEncoder.withIndent(
          '  ',
        ).convert([for (final p in points) p.toJson()]),
      );
      return;
    }
    if (points.isEmpty) {
      stdout.writeln('no samples (the node may not have heartbeated yet)');
      return;
    }
    stdout.writeln('AT                        CPU%    MEM%   DISK%');
    // Newest first from the API; print oldest first so it reads as a timeline.
    for (final p in points.reversed) {
      final mem = _pct(p.memoryUsedBytes, p.memoryTotalBytes);
      final disk = _pct(p.storageUsedBytes, p.storageCapacityBytes);
      stdout.writeln(
        '${p.at.toLocal().toString().padRight(26)}'
        '${p.cpuPercent.toStringAsFixed(1).padLeft(5)}  '
        '${mem.padLeft(6)}  ${disk.padLeft(6)}',
      );
    }
  } finally {
    client.close();
  }
}