1
0
Fork 0
forked from alemi/upub

fix: fetch relay usr or else we cant know internal

This commit is contained in:
əlemi 2024-07-05 00:31:42 +02:00
parent b2d23b7c4c
commit 9311cf25de
Signed by: alemi
GPG key ID: A4895B84D311642C

View file

@ -1,6 +1,6 @@
use apb::{ActivityMut, BaseMut, ObjectMut}; use apb::{ActivityMut, BaseMut, ObjectMut};
use sea_orm::{ActiveValue::{NotSet, Set}, DbErr, EntityTrait, QueryFilter, ColumnTrait}; use sea_orm::{ActiveValue::{NotSet, Set}, DbErr, EntityTrait, QueryFilter, ColumnTrait};
use upub::traits::fetch::PullError; use upub::traits::{fetch::PullError, Fetcher};
#[derive(Debug, Clone, clap::Subcommand)] #[derive(Debug, Clone, clap::Subcommand)]
/// available actions to take on relays /// available actions to take on relays
@ -40,10 +40,7 @@ pub async fn relay(ctx: upub::Context, action: RelayCommand) -> Result<(), PullE
| RelayCommand::Accept { actor } | RelayCommand::Accept { actor }
| RelayCommand::Unfollow { actor } | RelayCommand::Unfollow { actor }
| RelayCommand::Remove { actor } | RelayCommand::Remove { actor }
=> => ctx.fetch_user(actor, ctx.db()).await?.internal,
upub::model::actor::Entity::ap_to_internal(actor, ctx.db())
.await?
.ok_or_else(|| DbErr::RecordNotFound(actor.clone()))?,
}; };
match action { match action {