import 'dart:async';

import 'package:flutter/foundation.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:get/state_manager.dart';

int times = 30;

Future<int> valueNotifier() {
  final c = Completer<int>();
  final value = ValueNotifier<int>(0);
  final timer = Stopwatch();
  timer.start();

  value.addListener(() {
    if (times == value.value) {
      timer.stop();
      print(
          """${value.value} listeners notified | [VALUE_NOTIFIER] time: ${timer.elapsedMicroseconds}ms""");
      c.complete(timer.elapsedMicroseconds);
    }
  });

  for (var i = 0; i < times + 1; i++) {
    value.value = i;
  }

  return c.future;
}

Future<int> getValue() {
  final c = Completer<int>();
  final value = Value<int>(0);
  final timer = Stopwatch();
  timer.start();

  value.addListener(() {
    if (times == value.value) {
      timer.stop();
      print(
          """${value.value} listeners notified | [GETX_VALUE] time: ${timer.elapsedMicroseconds}ms""");
      c.complete(timer.elapsedMicroseconds);
    }
  });

  for (var i = 0; i < times + 1; i++) {
    value.value = i;
  }

  return c.future;
}

Future<int> stream() {
  final c = Completer<int>();

  final value = StreamController<int>();
  final timer = Stopwatch();
  timer.start();

  value.stream.listen((v) {
    if (times == v) {
      timer.stop();
      print(
          """$v listeners notified | [STREAM] time: ${timer.elapsedMicroseconds}ms""");
      c.complete(timer.elapsedMicroseconds);
      value.close();
    }
  });

  for (var i = 0; i < times + 1; i++) {
    value.add(i);
  }

  return c.future;
}

Future<int> getStream() {
  final c = Completer<int>();

  final value = GetStream<int>();
  final timer = Stopwatch();
  timer.start();

  value.listen((v) {
    if (times == v) {
      timer.stop();
      print(
          """$v listeners notified | [GET_STREAM] time: ${timer.elapsedMicroseconds}ms""");
      c.complete(timer.elapsedMicroseconds);
    }
  });

  for (var i = 0; i < times + 1; i++) {
    value.add(i);
  }

  return c.future;
}

Future<int> miniStream() {
  final c = Completer<int>();

  final value = MiniStream<int>();
  final timer = Stopwatch();
  timer.start();

  value.listen((v) {
    if (times == v) {
      timer.stop();
      print(
          """$v listeners notified | [MINI_STREAM] time: ${timer.elapsedMicroseconds}ms""");
      c.complete(timer.elapsedMicroseconds);
    }
  });

  for (var i = 0; i < times + 1; i++) {
    value.add(i);
  }

  return c.future;
}

void main() {
  test('percentage test', () {
    print('============================================');
    print('PERCENTAGE TEST');

    const referenceValue = 200;
    const requestedValue = 100;

    print('''
referenceValue is ${calculePercentage(referenceValue, requestedValue)}% more than requestedValue''');
    expect(calculePercentage(referenceValue, requestedValue), 100);
  });
  test('run benchmarks from ValueNotifier', () async {
    times = 30;
    print('============================================');
    print('VALUE_NOTIFIER X GETX_VALUE TEST');
    print('-----------');
    await getValue();
    await valueNotifier();
    print('-----------');

    times = 30000;
    final getx = await getValue();
    final dart = await valueNotifier();
    print('-----------');

    print('ValueNotifier delay $dart ms to made $times requests');
    print('GetValue delay $getx ms to made $times requests');
    print('-----------');
    print('''
GetValue is ${calculePercentage(dart, getx).round()}% faster than Default ValueNotifier with $times requests''');
  });

  test('run benchmarks from Streams', () async {
    times = 30;
    print('============================================');
    print('DART STREAM X GET_STREAM X GET_MINI_STREAM TEST');
    print('-----------');
    var getx = await getStream();
    var mini = await miniStream();
    var dart = await stream();
    print('-----------');
    print('''
GetStream is ${calculePercentage(dart, mini).round()}% faster than Default Stream with $times requests''');
    print('-----------');

    times = 30000;
    dart = await stream();
    getx = await getStream();
    mini = await miniStream();

    times = 60000;
    dart = await stream();
    getx = await getStream();
    mini = await miniStream();
    print('-----------');
    print('dart_stream delay $dart ms to made $times requests');
    print('getx_stream delay $getx ms to made $times requests');
    print('getx_mini_stream delay $mini ms to made $times requests');
    print('-----------');
    print('''
GetStream is ${calculePercentage(dart, mini).round()}% faster than Default Stream with $times requests''');
  });
}

int calculePercentage(int dart, int getx) {
  return (dart / getx * 100).round() - 100;
}