Silently ignore duplicate jobs

Author: augustuswm

Cargo.lock

@@ -10,6 +10,7 @@ async-trait = { workspace = true }
 base64 = { workspace = true }
 chrono = { workspace = true }
 config = { workspace = true }
+diesel = { workspace = true }
 google-drive3 = { workspace = true }
 google-storage1 = { workspace = true }
 hex = { workspace = true }

rfd-processor/Cargo.toml

@@ -1,3 +1,4 @@
+use diesel::result::{Error as DieselError, DatabaseErrorKind};
 use rfd_model::{
     storage::{JobStore, StoreError},
     NewJob,
@@ -34,9 +35,16 @@ pub async fn scanner(ctx: Arc<Context>) -> Result<(), ScannerError> {
             match JobStore::upsert(&ctx.db.storage, update.clone().into()).await {
                 Ok(job) => tracing::trace!(?job.id, "Added job to the queue"),
                 Err(err) => {
-                    // TODO: Do not warn on uniqueness violations. It is expected that the scanner
-                    // picks ups redundant jobs for RFDs that have not changed since the last scan
-                    tracing::warn!(?err, ?update, "Failed to add job")
+                    match err {
+                        StoreError::Db(DieselError::DatabaseError(DatabaseErrorKind::UniqueViolation, _)) => {
+                            // Nothing to do here, we expect uniqueness conflicts. It is expected
+                            // that the scanner picks ups redundant jobs for RFDs that have not
+                            // changed since the last scan
+                        }
+                        err => {
+                            tracing::warn!(?err, ?update, "Failed to add job")
+                        }
+                    }
                 }
             }
         }