More splitting.
This commit is contained in:
parent
6bf65f2d92
commit
9251b21bc5
@ -1,3 +1,5 @@
|
|||||||
|
#![allow(dead_code)]
|
||||||
|
|
||||||
use diesel::prelude::*;
|
use diesel::prelude::*;
|
||||||
use diesel;
|
use diesel;
|
||||||
use rss;
|
use rss;
|
||||||
@ -98,8 +100,18 @@ fn complete_index_from_source(
|
|||||||
req.read_to_string(&mut buf)?;
|
req.read_to_string(&mut buf)?;
|
||||||
let chan = rss::Channel::from_str(&buf)?;
|
let chan = rss::Channel::from_str(&buf)?;
|
||||||
|
|
||||||
|
complete_index(mutex, chan, &source)?;
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn complete_index(
|
||||||
|
mutex: Arc<Mutex<SqliteConnection>>,
|
||||||
|
chan: rss::Channel,
|
||||||
|
parent: &Source
|
||||||
|
) -> Result<()>{
|
||||||
let tempdb = mutex.lock().unwrap();
|
let tempdb = mutex.lock().unwrap();
|
||||||
let pd = index_channel(&tempdb, &chan, &source)?;
|
let pd = index_channel(&tempdb, &chan, parent)?;
|
||||||
drop(tempdb);
|
drop(tempdb);
|
||||||
|
|
||||||
index_channel_items(mutex.clone(), chan.items(), &pd)?;
|
index_channel_items(mutex.clone(), chan.items(), &pd)?;
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user