collect streaming servers only if enabled

CHANGELOG.md

@@ -8,6 +8,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Fixed
 * CHECK: update stations with new languagecodes
 * DB: check for empty lists in streaming servers api
+* DB: collect streaming servers only if enabled
 
 ## [0.7.18] 2021-10-10
 ### Changed

src/check/check.rs

@@ -233,6 +233,7 @@ pub fn dbcheck(
     timeout: u64,
     max_depth: u8,
     retries: u8,
+    add_streaming_servers: bool,
 ) -> Result<usize, Box<dyn std::error::Error>> {
     let mut conn = connect(connection_str)?;
     let stations = conn.get_stations_to_check(24, stations_count)?;
@@ -269,22 +270,24 @@ pub fn dbcheck(
     conn.insert_station_check_steps(&steps)?;
     conn.update_station_with_check_data(&inserted, true)?;
 
-    let mut urls_full: Vec<_> = inserted.iter()
-        .filter_map(|station| Url::parse(&station.url).ok())
-        .map(|mut url| {
-            url.set_path("/");
-            url.set_query(None);
-            url.set_fragment(None);
-            url.to_string()
-        })
-        .collect();
+    if add_streaming_servers {
+        let mut urls_full: Vec<_> = inserted.iter()
+            .filter_map(|station| Url::parse(&station.url).ok())
+            .map(|mut url| {
+                url.set_path("/");
+                url.set_query(None);
+                url.set_fragment(None);
+                url.to_string()
+            })
+            .collect();
 
-    urls_full.sort();
-    urls_full.dedup();
+        urls_full.sort();
+        urls_full.dedup();
 
-    conn.insert_streaming_servers(urls_full.drain(..).map(|base_url|{
-        DbStreamingServerNew::new(base_url, None, None, None)
-    }).collect())?;
+        conn.insert_streaming_servers(urls_full.drain(..).map(|base_url|{
+            DbStreamingServerNew::new(base_url, None, None, None)
+        }).collect())?;
+    }
 
     Ok(checked_count)
 }

src/main.rs

@@ -129,6 +129,7 @@ fn jobs(config: config::Config) {
                 config.tcp_timeout.as_secs(),
                 config.max_depth,
                 config.retries,
+                config.check_servers,
             );
             match result {
                 Ok(_) => {}