femto-feed 0.2.0

use crate::entry::Entry;
use crate::errors::Error;
use feed_rs::parser;
use std::io::BufReader;
use std::sync::mpsc::{Receiver, Sender};

pub struct Worker {
    jobs: Receiver<Option<String>>,
    results: Sender<Entry>,
}

impl Worker {
    pub fn new(results: Sender<Entry>, jobs: Receiver<Option<String>>) -> Worker {
        Worker {
            jobs: jobs,
            results: results,
        }
    }
    pub fn run(&mut self) -> Result<(), Error> {
        loop {
            let job = self.jobs.recv()?;
            match job {
                None => break,
                Some(url) => {
                    println!("{}", url);
                    let r = self.fetch_feed(url.as_str())?;
                    self.adapt(r)?;
                }
            }
        }

        Ok(())
    }

    fn fetch_feed(&mut self, feed_url: &str) -> Result<feed_rs::Feed, Error> {
        let mut response = reqwest::get(feed_url)?;
        let text = response.text()?;
        let mut buf = BufReader::new(text.as_str().as_bytes());
        parser::parse(&mut buf).ok_or(Error::Parse(String::from("nothing parsed")))
    }

    fn adapt(&mut self, feed: feed_rs::Feed) -> Result<(), Error> {
        let feed_title = feed.title.unwrap_or(String::from("unknown")).clone();
        for entry in feed.entries {
            let mut entry = Entry::from(entry);
            entry.from = feed_title.clone();
            self.results.send(entry)?;
        }

        Ok(())
    }
}