zaaarf/upub
1
0
Fork 0
forked from alemi/upub
Code Pull requests Activity

feat: cases for dropping jobs

Browse source
This commit is contained in:
əlemi 2024-06-23 23:40:23 +02:00
parent 5302e4ad46
commit f1287b1639
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 18 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
upub/worker/src/dispatcher.rs
View file

@ -1,6 +1,7 @@
use reqwest::StatusCode;
use sea_orm::{ColumnTrait, EntityTrait, Order, QueryFilter, QueryOrder}; use sea_orm::{ColumnTrait, EntityTrait, Order, QueryFilter, QueryOrder};
use upub::{model, traits::process::ProcessorError, Context}; use upub::{model, traits::{fetch::PullError, process::ProcessorError}, Context};
#[derive(Debug, thiserror::Error)] #[derive(Debug, thiserror::Error)]
pub enum JobError { pub enum JobError {
@ -128,7 +129,22 @@ impl JobDispatcher for Context {
match res { match res {
Ok(()) => tracing::debug!("job {} completed", job.activity), Ok(()) => tracing::debug!("job {} completed", job.activity),
Err(JobError::ProcessorError(ProcessorError::AlreadyProcessed)) => tracing::info!("dropping job already processed: {}", job.activity), Err(JobError::Json(x)) =>
tracing::error!("dropping job with invalid json payload: {x}"),
Err(JobError::MissingPayload) =>
tracing::warn!("dropping job without payload"),
Err(JobError::Malformed(f)) =>
tracing::error!("dropping job with malformed activity (missing field {f})"),
Err(JobError::ProcessorError(ProcessorError::AlreadyProcessed)) =>
tracing::info!("dropping job already processed: {}", job.activity),
Err(JobError::ProcessorError(ProcessorError::PullError(PullError::Fetch(StatusCode::FORBIDDEN, e)))) =>
tracing::warn!("dropping job because requested resource is not accessible: {e}"),
Err(JobError::ProcessorError(ProcessorError::PullError(PullError::Fetch(StatusCode::NOT_FOUND, e)))) =>
tracing::warn!("dropping job because requested resource is not available: {e}"),
Err(JobError::ProcessorError(ProcessorError::PullError(PullError::Fetch(StatusCode::GONE, e)))) =>
tracing::warn!("dropping job because requested resource is no longer available: {e}"),
Err(JobError::ProcessorError(ProcessorError::PullError(PullError::Malformed(f)))) =>
tracing::warn!("dropping job because requested resource could not be verified (fetch is invalid AP object: {f})"),
Err(e) => { Err(e) => {
tracing::error!("failed processing job '{}': {e}", job.activity); tracing::error!("failed processing job '{}': {e}", job.activity);
let active = job.clone().repeat(); let active = job.clone().repeat();