podal/src/lib.rs

// https://www.phind.com/agent?cache=clke9xk39001cmj085upzho1t

use std::fs::File;

use atom_syndication::Link;

mod errors;
mod feed;
mod history;
pub mod prelude;

use prelude::*;

pub fn run(subscriptions: &str, history: &str, site: &str) -> Result<()> {
    for channel_name in lines_from(subscriptions)? {
        let channel_name = channel_name?;
        println!("Channel: {}", channel_name);
        let feed_url = feed::get_feed_url(site, &channel_name)?;
        for entry in feed::get_feed(feed_url)?.entries() {
            if let Some(link) = entry.links().get(0).cloned() {
                if !history::is_already_downloaded(&link, history)? {
                    println!("Downloading {}: {}", &channel_name, entry.title().as_str());
                    download_audio(&link)?;
                    history::mark_as_downloaded(&link, history)?;
                }
            }
        }
    }
    Ok(())
}

// read list of rss feed URLs from file 'feeds.txt'
fn lines_from(file_name: &str) -> Result<std::io::Lines<std::io::BufReader<std::fs::File>>> {
    use std::io::{BufRead, BufReader};

    let file = File::open(file_name)?;
    let reader = BufReader::new(file);
    Ok(reader.lines())
}

fn download_audio(link: &Link) -> Result<()> {
    use std::process::Command;

    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(())
}