fixed: check concurrent

Author: zhifengle

README.md

@@ -1,6 +1,6 @@
 # Rss2pan
 
-将 Rss 订阅离线下载到网盘。目前支持 115
+将 Rss 订阅离线下载到 115 网盘。
 
 ## 关于
 
@@ -30,7 +30,7 @@
 ```bash
 # 查看帮助
 rss2pan -h
-# 直接运行。读取 rss.json，进行添加离线任务
+# 直接运行。读取 rss.json，依次添加离线任务
 rss2pan
 # 并发请求 rss 网站。然后再添加 115 离线任务
 rss2pan -m

src/app.rs

@@ -29,7 +29,7 @@ pub fn build_app() -> Command<'static> {
 fn t_cmd() {
     let cmd = build_app();
     let matches = cmd.clone().try_get_matches_from(["rss2pan", "-m"]).unwrap();
-    assert!(matches.contains_id("concurrent"));
+    assert_eq!(matches.get_one::<bool>("concurrent").copied(), Some(true));
     let matches = cmd.clone().try_get_matches_from(["rss2pan"]).unwrap();
     assert_eq!(matches.get_one::<bool>("concurrent").copied(), Some(false));
 }

src/main.rs

@@ -33,7 +33,7 @@ async fn main() -> anyhow::Result<()> {
         }
         return Ok(());
     }
-    if matches.contains_id("concurrent") {
+    if matches.get_one::<bool>("concurrent").copied() == Some(true) {
         if let Err(err) = execute_tasks(&service).await {
             println!("{}", err);
         }

src/yiyiwu.rs

@@ -140,7 +140,16 @@ impl Yiyiwu {
                 .filter(|item| !service.has_item(&item.magnet))
                 .map(|item| &*item.magnet)
                 .collect();
-            // log::debug!("tasks: {:?}", tasks);
+            // 测试用的开关
+            if std::env::var("RSS2PAN_LOG").is_ok() {
+                log::info!(
+                    "[RSS2PAN_LOG] [{}] [{}] has {} tasks",
+                    config.name,
+                    config.url,
+                    tasks.len()
+                );
+                continue;
+            }
             if tasks.len() == 0 {
                 log::info!("[{}] has 0 task", config.name);
                 continue;