Merge pull request #9 from yosemiteyss/feat/update-1.0.3

update version to 1.0.3

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 1.0.3
+- Add forcedMetaDL torrent state
+- Add checking and moving torrent filter
+- Add subscribeTorrentsList stream
+- Fix forcedDL enum value
+
 ## 1.0.2
 - Fix upload torrent files failed.
 

lib/src/v2/torrents/dto/torrent_filter.dart

@@ -10,6 +10,8 @@ enum TorrentFilter {
   stalled('stalled'),
   stalledUploading('stalled_uploading'),
   stalledDownloading('stalled_downloading'),
+  checking('checking'),
+  moving('moving'),
   errored('errored');
 
   const TorrentFilter(this.value);

lib/src/v2/torrents/dto/torrent_state.dart

@@ -45,6 +45,9 @@ enum TorrentState {
   @JsonValue('metaDL')
   metaDL,
 
+  @JsonValue('forcedMetaDL')
+  forcedMetaDL,
+
   /// Torrent is paused and has NOT finished downloading
   @JsonValue('pausedDL')
   pausedDL,
@@ -62,8 +65,8 @@ enum TorrentState {
   checkingDL,
 
   /// Torrent is forced to downloading to ignore queue limit
-  @JsonValue('forceDL')
-  forceDL,
+  @JsonValue('forcedDL')
+  forcedDL,
 
   /// Checking resume data on qBt startup
   @JsonValue('checkingResumeData')

lib/src/v2/torrents/torrents_controller.dart

@@ -23,6 +23,7 @@ class TorrentsController {
   final ApiClient _apiClient;
 
   /// Get torrent list
+  /// [options] - The options to filter the torrents.
   Future<List<TorrentInfo>> getTorrentsList({
     required TorrentListOptions options,
   }) async {
@@ -33,6 +34,17 @@ class TorrentsController {
     return data.map((e) => TorrentInfo.fromJson(e)).toList();
   }
 
+  /// Subscribe to torrent list changes by polling.
+  /// [options] - The options to filter the torrents.
+  /// [interval] - The polling interval.
+  Stream<List<TorrentInfo>> subscribeTorrentsList({
+    required TorrentListOptions options,
+    Duration interval = const Duration(seconds: 5),
+  }) {
+    return Stream.periodic(interval, (_) => getTorrentsList(options: options))
+        .asyncExpand(Stream.fromFuture);
+  }
+
   /// Get torrent generic properties
   /// [hash] - The hash of the torrent you want to get the generic properties of.
   Future<TorrentProperties> getProperties({required String hash}) async {

pubspec.yaml

@@ -1,6 +1,6 @@
 name: qbittorrent_api
 description: This package provides methods for making requests to qBittorrent Web API using Dart.
-version: 1.0.2
+version: 1.0.3
 repository: https://github.com/yosemiteyss/qbittorrent_api
 
 environment: