From c8ca91e90b412e1f7e807c9e8bfe634f5442c21b Mon Sep 17 00:00:00 2001 From: mace Date: Wed, 11 Oct 2023 19:23:18 +0200 Subject: [PATCH] cleanup, sync article url --- src/reader/sync.rs | 49 ++-------------------------------------------- 1 file changed, 2 insertions(+), 47 deletions(-) diff --git a/src/reader/sync.rs b/src/reader/sync.rs index 729dc99..aa22b3c 100644 --- a/src/reader/sync.rs +++ b/src/reader/sync.rs @@ -39,7 +39,8 @@ fn create_feed_item(item: Item, feed: &Feed) { }); let mut connection: diesel::PgConnection = establish_connection(); - let new_feed_item = NewFeedItem::new(feed.id, content.clone(), title.clone(), feed.url.clone()); + let new_feed_item = + NewFeedItem::new(feed.id, content.clone(), title.clone(), item.link.unwrap()); let insert_result = diesel::insert_into(feed_item::table) .values(&new_feed_item) .execute(&mut connection); @@ -75,49 +76,3 @@ pub async fn sync(_req: HttpRequest, data: web::Json) -> impl Responde HttpResponse::Ok() } -// pub async fn sync(req: HttpRequest) -> impl Responder { -// let request = req.clone(); -// let mut connection: diesel::PgConnection = establish_connection(); -// -// let feed: Vec = feed::table.load::(&mut connection).unwrap(); - -// let feed = feeds::get_feed("https://www.heise.de/rss/heise-Rubrik-Wissen.rdf").await.unwrap(); - -// let feed_title: String = feed.title.clone(); -// let feed_items: Vec
= feed -// .into_items() -// .into_iter() -// .map(|item| { -// let title = item.title.unwrap(); -// let frag = Html::parse_fragment(&item.content.unwrap()); -// let mut content = "".to_string(); -// let frag_clone = frag.clone(); -// frag.tree.into_iter().for_each(|node| { -// let selector_img = Selector::parse("img").unwrap(); -// -// for element in frag_clone.select(&selector_img) { -// if !content.starts_with("") -// } -// } -// if let scraper::node::Node::Text(text) = node { -// content.push_str(&text.text); -// } -// }); -// Article { title, content } -// }) -// .collect(); - -// let feed_stream = stream::iter(feed.iter().cloned()).map(|feed: Feed| { -// let feed_list = feeds::get_feed(&feed.url).await.unwrap(); -// // Process feed_list here -// }); -// -// tokio::spawn(feed_stream.for_each(|_| async {})); -// // let feed_list = feeds::get_feed(&feed.url).await.unwrap(); -// // feed.iter().for_each(|feed: &Feed| { -// // }); -// -// HttpResponse::Ok() -// }