claude rework

src/reader/sync.rs

@@ -19,38 +19,19 @@ use rss::Item;
 use scraper::{Html, Selector};
 
 fn get_date(date_str: &str) -> Result<NaiveDateTime, chrono::ParseError> {
-    // let format_string = "%a, %d %b %Y %H:%M:%S %z";
-    let format_string = "%Y-%m-%dT%H:%M:%S%Z";
-
-    let result = parse(date_str).unwrap();
-    log::info!("Date: {:?}", result);
-
-    match NaiveDateTime::parse_from_str(&result.to_string(), format_string) {
-        Ok(r) => Ok(r),
-        Err(_) => {
-            let datetime = DateTime::parse_from_rfc2822(date_str);
-            match datetime {
-                Ok(r) => NaiveDateTime::parse_from_str(&r.to_rfc3339(), format_string),
-                Err(_) => match DateTime::parse_from_rfc2822(date_str) {
-                    Ok(r) => NaiveDateTime::parse_from_str(&r.to_rfc3339(), format_string),
-                    Err(e) => Err(e),
-                },
-            }
-        }
+    if let Ok(result) = parse(date_str) {
+        log::info!("Date: {:?}", result);
+        return Ok(result.with_timezone(&Local).naive_local());
     }
+
+    DateTime::parse_from_rfc2822(date_str).map(|dt| dt.with_timezone(&Local).naive_local())
 }
 
 fn create_feed_item(item: Item, feed: &Feed, connection: &mut PgConnection) {
     let item_title = item.title.clone().unwrap();
     log::info!("Create feed item: {}", item_title);
 
-    let base_content: &str = match item.content() {
-        Some(c) => c,
-        None => match item.description() {
-            Some(c) => c,
-            None => "",
-        },
-    };
+    let base_content: &str = item.content().or(item.description()).unwrap_or_default();
 
     let frag = Html::parse_fragment(base_content);
     let mut content = "".to_string();
@@ -133,3 +114,79 @@ pub async fn sync(_req: HttpRequest, data: web::Json<JsonUser>) -> impl Responde
 
     HttpResponse::Ok()
 }
+
+#[cfg(test)]
+mod tests {
+    use crate::models::feed::new_feed::NewFeed;
+    use crate::models::user::new_user::NewUser;
+    use crate::models::user::rss_user::User;
+    use crate::schema::users;
+    use crate::test_helpers::unique_suffix;
+
+    use super::*;
+
+    #[test]
+    fn get_date_parses_iso8601_dates() {
+        assert!(get_date("2024-01-01T12:00:00Z").is_ok());
+    }
+
+    #[test]
+    fn get_date_parses_rfc2822_dates() {
+        assert!(get_date("Tue, 03 Jun 2025 10:00:00 GMT").is_ok());
+    }
+
+    #[test]
+    fn get_date_returns_err_for_unparseable_dates() {
+        assert!(get_date("not-a-date").is_err());
+    }
+
+    #[actix_web::test]
+    async fn create_feed_item_does_not_duplicate_existing_items() {
+        let mut connection = establish_connection();
+        let suffix = unique_suffix();
+
+        let new_user = NewUser::new(
+            format!("sync_test_{suffix}"),
+            format!("sync_{suffix}@example.test"),
+            "secret".to_string(),
+        );
+        let user: User = diesel::insert_into(users::table)
+            .values(&new_user)
+            .get_result(&mut connection)
+            .unwrap();
+
+        let new_feed = NewFeed::new(
+            format!("Sync test feed {suffix}"),
+            format!("https://example.test/feed/{suffix}"),
+            user.id,
+        );
+        let feed: Feed = diesel::insert_into(feed::table)
+            .values(&new_feed)
+            .get_result(&mut connection)
+            .unwrap();
+
+        let mut item = Item::default();
+        item.set_title(Some(format!("Sync test article {suffix}")));
+        item.set_link(Some(format!("https://example.test/article/{suffix}")));
+        item.set_content(Some("<p>Hello world</p>".to_string()));
+
+        create_feed_item(item.clone(), &feed, &mut connection);
+        create_feed_item(item, &feed, &mut connection);
+
+        let items: Vec<FeedItem> = feed_item::table
+            .filter(feed_id.eq(feed.id))
+            .load(&mut connection)
+            .unwrap();
+        assert_eq!(1, items.len(), "duplicate feed items should not be created");
+
+        diesel::delete(feed_item::table.filter(feed_id.eq(feed.id)))
+            .execute(&mut connection)
+            .ok();
+        diesel::delete(feed::table.filter(feed::id.eq(feed.id)))
+            .execute(&mut connection)
+            .ok();
+        diesel::delete(users::table.filter(users::id.eq(user.id)))
+            .execute(&mut connection)
+            .ok();
+    }
+}