alemi/upub
alemi/upub
1
0
Fork 1
Code Issues 4 Pull requests Projects Releases Packages 1 Wiki Activity Actions

fix: nuke task but for real i swear

Browse source
This commit is contained in:
əlemi 2024-06-24 02:38:12 +02:00
parent 48a8ff9fef
commit 206bc4d0db
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
upub/cli/src/nuke.rs
View file

@ -51,14 +51,14 @@ pub async fn nuke(ctx: upub::Context, for_real: bool, delete_posts: bool) -> Res
continue; continue;
}; };
let target = if matches!(activity.activity_type, apb::ActivityType::Follow) { let (target, undone) = if matches!(activity.activity_type, apb::ActivityType::Follow) {
activity.id.clone() (oid.clone(), activity.id.clone())
} else { } else {
let follow_activity = upub::model::activity::Entity::find_by_ap_id(&oid) let follow_activity = upub::model::activity::Entity::find_by_ap_id(&oid)
.one(ctx.db()) .one(ctx.db())
.await? .await?
.ok_or(sea_orm::DbErr::RecordNotFound(oid.clone()))?; .ok_or(sea_orm::DbErr::RecordNotFound(oid.clone()))?;
follow_activity.id (follow_activity.object.unwrap_or_default(), follow_activity.id)
}; };
let aid = ctx.aid(&upub::Context::new_id()); let aid = ctx.aid(&upub::Context::new_id());
@ -66,7 +66,7 @@ pub async fn nuke(ctx: upub::Context, for_real: bool, delete_posts: bool) -> Res
.set_id(Some(&aid)) .set_id(Some(&aid))
.set_activity_type(Some(apb::ActivityType::Undo)) .set_activity_type(Some(apb::ActivityType::Undo))
.set_actor(apb::Node::link(activity.actor.clone())) .set_actor(apb::Node::link(activity.actor.clone()))
.set_object(apb::Node::link(oid)) .set_object(apb::Node::link(undone))
.set_to(apb::Node::links(vec![target])) .set_to(apb::Node::links(vec![target]))
.set_published(Some(chrono::Utc::now())); .set_published(Some(chrono::Utc::now()));
@ -83,7 +83,7 @@ pub async fn nuke(ctx: upub::Context, for_real: bool, delete_posts: bool) -> Res
payload: Set(Some(undo_activity)), payload: Set(Some(undo_activity)),
}; };
tracing::debug!("undoing {}", activity.id); tracing::info!("undoing {}", activity.id);
if for_real { if for_real {
upub::model::job::Entity::insert(job).exec(ctx.db()).await?; upub::model::job::Entity::insert(job).exec(ctx.db()).await?;
@ -123,7 +123,7 @@ pub async fn nuke(ctx: upub::Context, for_real: bool, delete_posts: bool) -> Res
payload: Set(Some(undo_activity)), payload: Set(Some(undo_activity)),
}; };
tracing::debug!("deleting {}", object.id); tracing::info!("deleting {}", object.id);
if for_real { if for_real {
upub::model::job::Entity::insert(job).exec(ctx.db()).await?; upub::model::job::Entity::insert(job).exec(ctx.db()).await?;