mathias
/
rss-reader
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

cleanup, sync article url

master
Mathias Rothenhaeusler 2023-10-11 19:23:18 +02:00
parent 3129c521b4
commit c8ca91e90b
1 changed files with 2 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
src/reader/sync.rs
View File

@ -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<JsonUser>) -> 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> = feed::table.load::<Feed>(&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<Article> = 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("<img") {
// content.push_str(&element.html());
// content.push_str("<br>")
// }
// }
// 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()
// }