.gitignore

@@ -1,5 +1,7 @@
 target
 *.mp3
 *.webm
-/subscriptions.txt
-/downloaded.txt
+subscriptions.txt
+downloaded.txt
+coverage
+*.profraw

.woodpecker.yml

@@ -1,6 +1,7 @@
-pipeline:
+steps:
   build:
-    image: rust
+    image: rust:latest
+    pull: true
     commands:
       - rustup component add rustfmt clippy
       - cargo --version

Cargo.lock

@@ -1014,6 +1014,7 @@ name = "podal"
 version = "0.1.0"
 dependencies = [
  "atom_syndication",
+ "bytes",
  "clap",
  "reqwest",
  "scraper",

Cargo.toml

@@ -10,6 +10,7 @@ atom_syndication = "0.12.1"
 reqwest = { version = "0.11.18", features = ["json", "blocking"] }
 scraper = "0.17.1"
 clap = "4.3.19"
+bytes = "1.4.0"
 
 [dev-dependencies]
 tempfile = "*"

justfile

@@ -0,0 +1,23 @@
+coverage-init:
+  cargo install grcov
+  rustup component add llvm-tools
+
+coverage:
+  #!/usr/bin/env bash
+  set -e
+  rm -rf ./target
+  just clean
+  export RUSTFLAGS="-Zinstrument-coverage" LLVM_PROFILE_FILE="just-%p-%m.profraw"
+  cargo +nightly build
+  cargo +nightly test
+  just generate
+  just server
+
+generate:
+  grcov . --binary-path ./target/debug/ -s . -t html --branch --ignore-not-existing --ignore "./target/" -o ./coverage/
+
+server:
+  cd ./coverage && python3 -m http.server 8001
+
+clean:
+  rm -rf ./*.prof* ./coverage/

src/errors.rs

@@ -1,12 +1,14 @@
-use std::{fmt::Display, str::Utf8Error, string::FromUtf8Error};
+use std::{str::Utf8Error, string::FromUtf8Error};
 
 #[derive(Debug)]
 pub struct Error {
-    details: String,
+    pub details: String,
 }
-impl Display for Error {
-    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-        f.write_str(self.details.to_string().as_str())
+impl Error {
+    pub fn message(details: &str) -> Self {
+        Self {
+            details: details.to_string(),
+        }
     }
 }
 impl From<Utf8Error> for Error {

src/feed/find.rs

@@ -1,15 +1,14 @@
+use crate::network::NetworkEnv;
 use crate::prelude::*;
 
-use crate::fetch::FetchGet;
-
-pub fn find(site: &str, channel_name: &str, e: &FetchGet) -> Result<String> {
+pub fn find(site: &str, channel_name: &str, e: &NetworkEnv) -> Result<String> {
     if let Some(channel_prefix) = channel_name.chars().next() {
         if channel_prefix != '@' {
             return Err(format!("Channel Name must begin with an '@': {}", channel_name).into());
         }
     }
     let channel_url = format!("{}{}", site, channel_name);
-    let response = (e)(&channel_url)?;
+    let response = (e.fetch_as_text)(&channel_url)?;
     let rss_url = scraper::Html::parse_document(&response)
         .select(&scraper::Selector::parse("link[title='RSS']").unwrap())
         .next()
@@ -23,15 +22,20 @@ pub fn find(site: &str, channel_name: &str, e: &FetchGet) -> Result<String> {
 
 #[cfg(test)]
 mod tests {
-    use crate::fetch::Response;
+
+    use crate::errors::Error;
 
     use super::*;
     #[test]
     fn finds_rss_url() -> Result<()> {
         //given
-        let fetch_get = &(get as FetchGet);
+        let network_env = NetworkEnv {
+            fetch_as_text: dummy_fetch_as_text,
+            fetch_as_bytes: dummy_fetch_as_bytes,
+            download_as_mp3: dummy_download_as_mp3,
+        };
         //when
-        let result = find("site", "@channel", fetch_get)?;
+        let result = find("site", "@channel", &network_env)?;
         //then
         assert_eq!(result, "the-rss-url");
         Ok(())
@@ -40,15 +44,19 @@ mod tests {
     #[test]
     fn error_if_channel_name_is_invalid() -> Result<()> {
         //given
-        let fetch_get = &(get as FetchGet);
+        let network_env = NetworkEnv {
+            fetch_as_text: dummy_fetch_as_text,
+            fetch_as_bytes: dummy_fetch_as_bytes,
+            download_as_mp3: dummy_download_as_mp3,
+        };
         //when
-        let result = find("site", "invalid-channel-name", fetch_get);
+        let result = find("site", "invalid-channel-name", &network_env);
         //then
         assert!(result.is_err());
         Ok(())
     }
 
-    fn get(_url: &str) -> Result<Response> {
+    fn dummy_fetch_as_text(_url: &str) -> Result<String> {
         Ok(r#"
         <html>
         <link title="RSS" href="the-rss-url">
@@ -56,4 +64,10 @@ mod tests {
         "#
         .to_string())
     }
+    fn dummy_fetch_as_bytes(_url: &str) -> Result<bytes::Bytes> {
+        Err(Error::message("Not implemented"))
+    }
+    fn dummy_download_as_mp3(_url: &str) -> Result<()> {
+        Err(Error::message("Not implemented"))
+    }
 }

src/feed/get.rs

@@ -1,9 +0,0 @@
-use crate::prelude::*;
-
-use atom_syndication::Feed;
-
-pub fn reqwest_blocking_get(url: &str) -> Result<Feed> {
-    let content = reqwest::blocking::get(url)?.bytes()?;
-    let channel = Feed::read_from(&content[..])?;
-    Ok(channel)
-}

src/feed/mod.rs

@@ -1,18 +1,14 @@
 use crate::prelude::*;
 
-use crate::fetch::FetchGet;
+use crate::network::NetworkEnv;
+use atom_syndication::Feed;
 
 mod find;
-mod get;
 
-use atom_syndication::Feed;
 pub use find::find;
-pub use get::reqwest_blocking_get;
 
-pub struct FeedEnv {
-    pub find: FeedFind,
-    pub get: FeedGet,
+pub fn get(url: &str, e: &NetworkEnv) -> Result<Feed> {
+    let content = (e.fetch_as_bytes)(url)?;
+    let channel = Feed::read_from(&content[..])?;
+    Ok(channel)
 }
-
-pub type FeedFind = fn(&str, &str, &FetchGet) -> Result<String>;
-pub type FeedGet = fn(&str) -> Result<Feed>;

src/fetch.rs

@@ -1,34 +0,0 @@
-use crate::prelude::*;
-
-use atom_syndication::Link;
-use std::process::Command;
-
-pub struct FetchEnv {
-    pub download: FetchDownload,
-    pub get: FetchGet,
-}
-
-pub type FetchDownload = fn(&Link) -> Result<()>;
-pub type FetchGet = fn(&str) -> Result<Response>;
-
-pub fn download(link: &Link) -> Result<()> {
-    let cmd = "yt-dlp";
-    // println!("{} --extract-audio --audio-format mp3 {}", cmd, &link.href);
-    let output = Command::new(cmd)
-        .arg("--extract-audio")
-        .arg("--audio-format")
-        .arg("mp3")
-        .arg(&link.href)
-        .output()?;
-    if !output.stderr.is_empty() {
-        eprintln!("Error: {}", String::from_utf8(output.stderr)?);
-        println!("{}", String::from_utf8(output.stdout)?);
-    }
-    Ok(())
-}
-
-pub type Response = String;
-
-pub fn get(url: &str) -> Result<Response> {
-    Ok(reqwest::blocking::get(url)?.text()?)
-}

src/file/env.rs

@@ -0,0 +1,26 @@
+use std::fs::{File, OpenOptions};
+use std::io::Write;
+
+pub struct FileEnv {
+    pub open: FileOpen,
+    pub append_line: FileAppendLine,
+}
+impl Default for FileEnv {
+    fn default() -> Self {
+        Self {
+            open: |path| File::open(path),
+            append_line: |file_name, line| {
+                let mut file = OpenOptions::new()
+                    .write(true)
+                    .append(true)
+                    .create(true)
+                    .open(file_name)
+                    .unwrap();
+                writeln!(file, "{}", line)?;
+                Ok(())
+            },
+        }
+    }
+}
+pub type FileOpen = fn(path: &str) -> std::io::Result<File>;
+pub type FileAppendLine = fn(paht: &str, line: &str) -> std::io::Result<()>;

src/file/mod.rs

@@ -0,0 +1,4 @@
+mod env;
+pub mod read;
+
+pub use env::FileEnv;

src/file/read.rs

@@ -1,10 +1,10 @@
 use crate::prelude::*;
 
-use std::fs::File;
+use crate::file::FileEnv;
 use std::io::{BufRead, BufReader};
 
-pub fn lines_from(file_name: &str) -> Result<Vec<String>> {
-    let file = File::open(file_name)?;
+pub fn lines_from(file_name: &str, e: &FileEnv) -> Result<Vec<String>> {
+    let file = (e.open)(file_name)?;
     let reader = BufReader::new(file);
     let mut lines = vec![];
     for line in reader.lines().flatten() {
@@ -27,11 +27,12 @@ mod tests {
         //given
         let (dir, file_name) = create_text_file(
             "subscriptions.txt",
-            include_bytes!("../test/data/subscriptions.txt"),
+            include_bytes!("../../test/data/subscriptions.txt"),
         )?;
+        let file_env = FileEnv::default();
 
         //when
-        let result = lines_from(&file_name)?;
+        let result = lines_from(&file_name, &file_env)?;
 
         //then
         drop(dir);
@@ -44,11 +45,12 @@ mod tests {
         //given
         let (dir, file_name) = create_text_file(
             "subscriptions.txt",
-            include_bytes!("../test/data/subscriptions-blank-line.txt"),
+            include_bytes!("../../test/data/subscriptions-blank-line.txt"),
         )?;
+        let file_env = FileEnv::default();
 
         //when
-        let result = lines_from(&file_name)?;
+        let result = lines_from(&file_name, &file_env)?;
 
         //then
         drop(dir);
@@ -61,11 +63,12 @@ mod tests {
         //given
         let (dir, file_name) = create_text_file(
             "subscriptions.txt",
-            include_bytes!("../test/data/subscriptions-comment.txt"),
+            include_bytes!("../../test/data/subscriptions-comment.txt"),
         )?;
+        let file_env = FileEnv::default();
 
         //when
-        let result = lines_from(&file_name)?;
+        let result = lines_from(&file_name, &file_env)?;
 
         //then
         drop(dir);

src/history/add.rs

@@ -1,18 +1,10 @@
+use crate::file::FileEnv;
 use crate::prelude::*;
 
-use atom_syndication::Link;
-use std::fs::OpenOptions;
-use std::io::prelude::*;
+use super::Link;
 
-pub fn add(link: &Link, file_name: &str) -> Result<()> {
-    let mut file = OpenOptions::new()
-        .write(true)
-        .append(true)
-        .create(true)
-        .open(file_name)
-        .unwrap();
-
-    writeln!(file, "{}", link.href)?;
+pub fn add(link: &Link, file_name: &str, e: &FileEnv) -> Result<()> {
+    (e.append_line)(file_name, &link.href)?;
     Ok(())
 }
 
@@ -42,7 +34,7 @@ mod tests {
             length: None,
         };
         //when
-        add(&link, &file_name)?;
+        add(&link, &file_name, &FileEnv::default())?;
 
         //then
         let content: Vec<String> = read_text_file(&file_name)?;
@@ -71,7 +63,7 @@ mod tests {
             length: None,
         };
         //when
-        add(&link, &file_name)?;
+        add(&link, &file_name, &FileEnv::default())?;
 
         //then
         let content: Vec<String> = read_text_file(&file_name)?;

src/history/find.rs

@@ -1,11 +1,11 @@
-use crate::prelude::*;
+use crate::{file::FileEnv, prelude::*};
 
-use atom_syndication::Link;
-use std::fs::File;
 use std::io::{BufRead, BufReader};
 
-pub fn find(link: &Link, file_name: &str) -> Result<bool> {
-    if let Ok(file) = File::open(file_name) {
+use super::Link;
+
+pub fn find(link: &Link, file_name: &str, e: &FileEnv) -> Result<bool> {
+    if let Ok(file) = (e.open)(file_name) {
         let reader = BufReader::new(file);
         for line in reader.lines() {
             if line? == link.href {
@@ -34,14 +34,13 @@ mod test {
             title: None,
             length: None,
         };
-
         //when
-        let result = find(&link, &file_name)?;
+        let result = find(&link, &file_name, &FileEnv::default())?;
 
         //then
         drop(dir);
 
-        assert_eq!(result, true);
+        assert!(result);
 
         Ok(())
     }
@@ -61,12 +60,12 @@ mod test {
         };
 
         //when
-        let result = find(&link, &file_name)?;
+        let result = find(&link, &file_name, &FileEnv::default())?;
 
         //then
         drop(dir);
 
-        assert_eq!(result, false);
+        assert!(!result);
 
         Ok(())
     }
@@ -88,12 +87,12 @@ mod test {
         };
 
         //when
-        let result = find(&link, &file_name)?;
+        let result = find(&link, &file_name, &FileEnv::default())?;
 
         //then
         drop(dir);
 
-        assert_eq!(result, false);
+        assert!(!result);
 
         Ok(())
     }

src/history/mod.rs

@@ -1,17 +1,7 @@
-use crate::prelude::*;
-
 mod add;
 mod find;
 
 pub use add::add;
 pub use find::find;
 
-type Link = atom_syndication::Link;
-
-pub struct HistoryEnv {
-    pub find: HistoryFind,
-    pub add: HistoryAdd,
-}
-
-pub type HistoryFind = fn(&Link, &str) -> Result<bool>;
-pub type HistoryAdd = fn(&Link, &str) -> Result<()>;
+pub type Link = atom_syndication::Link;

src/lib.rs

@@ -1,34 +1,33 @@
+use prelude::*;
+
 mod errors;
 pub mod feed;
-pub mod fetch;
+pub mod file;
 pub mod history;
+pub mod network;
 pub mod prelude;
-mod subscriptions;
 
 #[cfg(test)]
 mod test_utils;
 
-use feed::FeedEnv;
-use fetch::FetchEnv;
-use history::HistoryEnv;
-use prelude::*;
+use file::FileEnv;
+use network::NetworkEnv;
 
 pub struct Env {
-    pub feed: FeedEnv,
-    pub history: HistoryEnv,
-    pub fetch: FetchEnv,
+    pub network: NetworkEnv,
+    pub file: FileEnv,
 }
 
 pub fn run(subscriptions: &str, history: &str, site: &str, e: Env) -> Result<()> {
-    for channel_name in subscriptions::lines_from(subscriptions)? {
+    for channel_name in file::read::lines_from(subscriptions, &e.file)? {
         println!("Channel: {}", channel_name);
-        let feed_url = (e.feed.find)(site, &channel_name, &e.fetch.get)?;
-        for entry in (e.feed.get)(&feed_url)?.entries() {
+        let feed_url = feed::find(site, &channel_name, &e.network)?;
+        for entry in feed::get(&feed_url, &e.network)?.entries() {
             if let Some(link) = entry.links().get(0).cloned() {
-                if !(e.history.find)(&link, history)? {
+                if !history::find(&link, history, &e.file)? {
                     println!("Downloading {}: {}", &channel_name, entry.title().as_str());
-                    (e.fetch.download)(&link)?;
-                    (e.history.add)(&link, history)?;
+                    (e.network.download_as_mp3)(&link.href)?;
+                    history::add(&link, history, &e.file)?;
                 }
             }
         }

src/main.rs

@@ -1,7 +1,7 @@
+use podal::file::FileEnv;
+use podal::network::NetworkEnv;
 use podal::prelude::*;
 
-use podal::{feed::FeedEnv, fetch::FetchEnv, history::HistoryEnv};
-
 fn main() -> Result<()> {
     println!("Podal");
     let subscriptions = "subscriptions.txt";
@@ -13,19 +13,8 @@ fn main() -> Result<()> {
         history,
         site,
         podal::Env {
-            feed: FeedEnv {
-                find: podal::feed::find,
-                get: podal::feed::reqwest_blocking_get,
-            },
-
-            history: HistoryEnv {
-                find: podal::history::find,
-                add: podal::history::add,
-            },
-            fetch: FetchEnv {
-                download: podal::fetch::download,
-                get: podal::fetch::get,
-            },
+            network: NetworkEnv::default(),
+            file: FileEnv::default(),
         },
     )?;
 

src/network/env.rs

@@ -0,0 +1,32 @@
+use std::process::Command;
+
+use crate::prelude::*;
+
+pub struct NetworkEnv {
+    pub fetch_as_text: fn(url: &str) -> Result<String>,
+    pub fetch_as_bytes: fn(url: &str) -> Result<bytes::Bytes>,
+    pub download_as_mp3: fn(url: &str) -> Result<()>,
+}
+impl Default for NetworkEnv {
+    fn default() -> Self {
+        Self {
+            fetch_as_text: |url| Ok(reqwest::blocking::get(url)?.text()?),
+            fetch_as_bytes: |url| Ok(reqwest::blocking::get(url)?.bytes()?),
+            download_as_mp3: |url| {
+                let cmd = "yt-dlp";
+                // println!("{} --extract-audio --audio-format mp3 {}", cmd, &link.href);
+                let output = Command::new(cmd)
+                    .arg("--extract-audio")
+                    .arg("--audio-format")
+                    .arg("mp3")
+                    .arg(url)
+                    .output()?;
+                if !output.stderr.is_empty() {
+                    eprintln!("Error: {}", String::from_utf8(output.stderr)?);
+                    println!("{}", String::from_utf8(output.stdout)?);
+                }
+                Ok(())
+            },
+        }
+    }
+}

src/network/mod.rs

@@ -0,0 +1,3 @@
+mod env;
+
+pub use env::NetworkEnv;