torrent_task 0.1.2

BitTorrent download client package written by pure Dart language.

example/torrent_task_example.dart

import 'dart:async';

import 'package:dartorrent_common/dartorrent_common.dart';
import 'package:torrent_model/torrent_model.dart';
import 'package:torrent_task/torrent_task.dart';

void main() async {
  try {
    var torrentFile = 'example/test8.torrent';
    var savePath = 'g:/bttest/';
    var model = await Torrent.parse(torrentFile);
    var task = TorrentTask.newTask(model, savePath);
    Timer timer;
    Timer timer1;
    var startTime = DateTime.now().millisecondsSinceEpoch;
    task.onTaskComplete(() {
      print(
          'Complete! spend time : ${((DateTime.now().millisecondsSinceEpoch - startTime) / 6000).toStringAsFixed(2)} minutes');
      timer?.cancel();
      timer1?.cancel();
      task.stop();
    });
    task.onStop(() async {
      print('Task Stopped');
    });
    var map = await task.start();

    // ignore: unawaited_futures
    findPublicTrackers().listen((alist) {
      alist.forEach((element) {
        task.startAnnounceUrl(element, model.infoHashBuffer);
      });
    });

    model.nodes?.forEach((element) {
      task.addDHTNode(element);
    });

    print(map);

    timer = Timer.periodic(Duration(seconds: 2), (timer) async {
      var progress = '${(task.progress * 100).toStringAsFixed(2)}%';
      var ads = '${((task.downloadSpeed) * 1000 / 1024).toStringAsFixed(2)}';
      var aps = '${((task.uploadSpeed) * 1000 / 1024).toStringAsFixed(2)}';
      var ds = '${((task.downloadSpeed2) * 1000 / 1024).toStringAsFixed(2)}';
      var ps = '${((task.uploadSpeed2) * 1000 / 1024).toStringAsFixed(2)}';
      var active = task.connectedPeersNumber;
      var seeders = task.seederNumber;
      var all = task.allPeersNumber;
      print(
          'Progress : $progress , Peers:($active/$seeders/$all) . Download speed : ($ads/$ds)kb/s , upload speed : ($aps/$ps)kb/s');
    });
  } catch (e) {
    print(e);
  }
  // timer1 = Timer.periodic(Duration(seconds: randomInt(21)), (timer) async {
  //   task.pause();
  //   await Future.delayed(Duration(seconds: randomInt(121)));
  //   task.resume();
  // });
}