clippy

LemmyNet · Sep 16, 2024 · 3067073 · 3067073
1 parent 277d0e1
commit 3067073
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/migrations/2024-09-16-095656_schedule-post/down.sql b/migrations/2024-09-16-095656_schedule-post/down.sql
@@ -1 +1,3 @@
-alter table post drop column scheduled_time;
+ALTER TABLE post
+    DROP COLUMN scheduled_time;
+
diff --git a/migrations/2024-09-16-095656_schedule-post/up.sql b/migrations/2024-09-16-095656_schedule-post/up.sql
@@ -1 +1,3 @@
-alter table post add column scheduled_time timestamptz;
+ALTER TABLE post
+    ADD COLUMN scheduled_time timestamptz;
+
diff --git a/src/scheduled_tasks.rs b/src/scheduled_tasks.rs
@@ -486,11 +486,17 @@ async fn publish_scheduled_posts(context: &Data<LemmyContext>) {
       diesel::update(post::table)
         .filter(post::id.eq_any(post_ids))
         .set(post::scheduled_time.eq(None::<DateTime<Utc>>))
-        .execute(&mut conn).await.unwrap();
+        .execute(&mut conn)
+        .await
+        .map_err(|e| error!("Failed update scheduled post: {e}"))
+        .ok();
 
       for p in posts {
         let send_activity = SendActivityData::CreatePost(p.0.clone());
-        ActivityChannel::submit_activity(send_activity, context).await.unwrap();
+        ActivityChannel::submit_activity(send_activity, context)
+          .await
+          .inspect_err(|e| error!("Failed federate scheduled post: {e}"))
+          .ok();
         send_webmention(p.0, p.1);
       }
     }