import 'package:toolbox/core/extension/numx.dart';

import 'time_seq.dart';

class NetSpeedPart extends TimeSeqIface<NetSpeedPart> {
  final String device;
  final BigInt bytesIn;
  final BigInt bytesOut;
  final int time;

  NetSpeedPart(this.device, this.bytesIn, this.bytesOut, this.time);

  @override
  bool same(NetSpeedPart other) => device == other.device;
}

class NetSpeed extends TimeSeq<NetSpeedPart> {
  NetSpeed(super.pre, super.now);

  List<String> get devices => now.map((e) => e.device).toList();

  BigInt get _timeDiff => BigInt.from(now[0].time - pre[0].time);

  double _speedIn(int i) => (now[i].bytesIn - pre[i].bytesIn) / _timeDiff;
  double _speedOut(int i) => (now[i].bytesOut - pre[i].bytesOut) / _timeDiff;
  BigInt _sizeIn(int i) => now[i].bytesIn;
  BigInt _sizeOut(int i) => now[i].bytesOut;

  String speedIn({String? device, bool all = false}) {
    if (pre[0].device == '' || now[0].device == '') return '0kb/s';
    if (all) {
      var speed = 0.0;
      for (var i = 0; i < now.length; i++) {
        speed += _speedIn(i);
      }
      return buildStandardOutput(speed);
    }
    final idx = deviceIdx(device);
    return buildStandardOutput(_speedIn(idx));
  }

  String sizeIn({String? device, bool all = false}) {
    if (pre[0].device == '' || now[0].device == '') return '0kb';
    if (all) {
      var size = BigInt.from(0);
      for (var i = 0; i < now.length; i++) {
        size += _sizeIn(i);
      }
      return size.convertBytes;
    }
    final idx = deviceIdx(device);
    return _sizeIn(idx).convertBytes;
  }

  String speedOut({String? device, bool all = false}) {
    if (pre[0].device == '' || now[0].device == '') return '0kb/s';
    if (all) {
      var speed = 0.0;
      for (var i = 0; i < now.length; i++) {
        speed += _speedOut(i);
      }
      return buildStandardOutput(speed);
    }
    final idx = deviceIdx(device);
    return buildStandardOutput(_speedOut(idx));
  }

  String sizeOut({String? device, bool all = false}) {
    if (pre[0].device == '' || now[0].device == '') return '0kb';
    if (all) {
      var size = BigInt.from(0);
      for (var i = 0; i < now.length; i++) {
        size += _sizeOut(i);
      }
      return size.convertBytes;
    }
    final idx = deviceIdx(device);
    return _sizeOut(idx).convertBytes;
  }

  int deviceIdx(String? device) {
    if (device != null) {
      for (var item in now) {
        if (item.device == device) {
          return now.indexOf(item);
        }
      }
    }
    return 0;
  }

  String buildStandardOutput(double speed) => '${speed.convertBytes}/s';
}

/// [raw] example:
/// Inter-|   Receive                                                |  Transmit
///   face |bytes    packets errs drop fifo frame compressed multicast|bytes    packets errs drop fifo colls carrier compressed
///   lo: 45929941  269112    0    0    0     0          0         0 45929941  269112    0    0    0     0       0          0
///   eth0: 48481023  505772    0    0    0     0          0         0 36002262  202307    0    0    0     0       0          0
List<NetSpeedPart> parseNetSpeed(String raw, int time) {
  final split = raw.split('\n');
  if (split.length < 4) {
    return [];
  }

  final results = <NetSpeedPart>[];
  for (final item in split.sublist(2, split.length - 1)) {
    final data = item.trim().split(':');
    final device = data.first;
    final bytes = data.last.trim().split(' ');
    bytes.removeWhere((element) => element == '');
    final bytesIn = BigInt.parse(bytes.first);
    final bytesOut = BigInt.parse(bytes[8]);
    results.add(NetSpeedPart(device, bytesIn, bytesOut, time));
  }
  return results;
}