This commit is contained in:
2026-07-10 16:32:07 +02:00
parent 46b8488b09
commit 12378c3649
7 changed files with 12 additions and 23 deletions

View File

@@ -242,5 +242,4 @@ impl SocialQuery for CompositeSocialAdapter {
let following = self.get_following(follower).await?;
Ok(following.iter().any(|a| a.identity == *target))
}
}

View File

@@ -67,10 +67,7 @@ struct FakeSocialWithFollowing(Vec<SocialActor>);
#[async_trait]
impl domain::ports::SocialQuery for FakeSocialWithFollowing {
async fn get_following(
&self,
_: &UserId,
) -> Result<Vec<SocialActor>, DomainError> {
async fn get_following(&self, _: &UserId) -> Result<Vec<SocialActor>, DomainError> {
Ok(self.0.clone())
}
async fn get_followers(&self, _: &UserId) -> Result<Vec<SocialActor>, DomainError> {

View File

@@ -10,10 +10,7 @@ use super::{
queries::SocialQry,
};
pub async fn execute_command(
deps: &SocialCommandDeps,
cmd: SocialCmd,
) -> Result<(), DomainError> {
pub async fn execute_command(deps: &SocialCommandDeps, cmd: SocialCmd) -> Result<(), DomainError> {
let event = match cmd {
SocialCmd::Follow {
follower_id,
@@ -58,18 +55,12 @@ pub async fn execute_command(
.await?;
DomainEvent::FollowerRemoved { owner, follower }
}
SocialCmd::Block {
blocker_id,
target,
} => {
SocialCmd::Block { blocker_id, target } => {
let blocker = UserId::from_uuid(blocker_id);
deps.social_command.block(&blocker, &target).await?;
DomainEvent::ActorBlocked { blocker, target }
}
SocialCmd::Unblock {
blocker_id,
target,
} => {
SocialCmd::Unblock { blocker_id, target } => {
let blocker = UserId::from_uuid(blocker_id);
deps.social_command.unblock(&blocker, &target).await?;
DomainEvent::ActorUnblocked { blocker, target }

View File

@@ -39,9 +39,9 @@ async fn follow_emits_follow_requested_event() {
&deps,
SocialCmd::Follow {
follower_id: Uuid::new_v4(),
target: FollowTarget::Identity(SocialIdentity::Local(UserId::from_uuid(
Uuid::new_v4(),
))),
target: FollowTarget::Identity(SocialIdentity::Local(
UserId::from_uuid(Uuid::new_v4()),
)),
},
)
.await

View File

@@ -41,7 +41,11 @@ pub struct NoopSocialCommand;
#[async_trait]
impl super::SocialCommand for NoopSocialCommand {
async fn follow(&self, _: &UserId, _: &crate::value_objects::FollowTarget) -> Result<(), DomainError> {
async fn follow(
&self,
_: &UserId,
_: &crate::value_objects::FollowTarget,
) -> Result<(), DomainError> {
Ok(())
}
async fn unfollow(&self, _: &UserId, _: &SocialIdentity) -> Result<(), DomainError> {

View File

@@ -61,7 +61,6 @@ pub trait SocialQuery: Send + Sync {
follower: &UserId,
target: &SocialIdentity,
) -> Result<bool, DomainError>;
}
#[async_trait]

View File

@@ -1105,5 +1105,4 @@ impl SocialQuery for InMemorySocialRepository {
*f == follower.value() && t == target && *state == FollowState::Accepted
}))
}
}