diff --git a/src/index_feed.rs b/src/index_feed.rs index ee7365e..8a0791e 100644 --- a/src/index_feed.rs +++ b/src/index_feed.rs @@ -1,3 +1,5 @@ +#![allow(dead_code)] + use diesel::prelude::*; use diesel; use rss; @@ -98,8 +100,18 @@ fn complete_index_from_source( req.read_to_string(&mut buf)?; let chan = rss::Channel::from_str(&buf)?; + complete_index(mutex, chan, &source)?; + + Ok(()) +} + +fn complete_index( + mutex: Arc>, + chan: rss::Channel, + parent: &Source +) -> Result<()>{ let tempdb = mutex.lock().unwrap(); - let pd = index_channel(&tempdb, &chan, &source)?; + let pd = index_channel(&tempdb, &chan, parent)?; drop(tempdb); index_channel_items(mutex.clone(), chan.items(), &pd)?;