diff options
Diffstat (limited to 'internal/processing/account/removefollow.go')
| -rw-r--r-- | internal/processing/account/removefollow.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/internal/processing/account/removefollow.go b/internal/processing/account/removefollow.go index 4cfea7790..82020b604 100644 --- a/internal/processing/account/removefollow.go +++ b/internal/processing/account/removefollow.go @@ -80,7 +80,7 @@ func (p *processor) FollowRemove(ctx context.Context, requestingAccount *gtsmode // follow request status changed so send the UNDO activity to the channel for async processing if frChanged { - p.fromClientAPI <- messages.FromClientAPI{ + p.clientWorker.Queue(messages.FromClientAPI{ APObjectType: ap.ActivityFollow, APActivityType: ap.ActivityUndo, GTSModel: >smodel.Follow{ @@ -90,12 +90,12 @@ func (p *processor) FollowRemove(ctx context.Context, requestingAccount *gtsmode }, OriginAccount: requestingAccount, TargetAccount: targetAcct, - } + }) } // follow status changed so send the UNDO activity to the channel for async processing if fChanged { - p.fromClientAPI <- messages.FromClientAPI{ + p.clientWorker.Queue(messages.FromClientAPI{ APObjectType: ap.ActivityFollow, APActivityType: ap.ActivityUndo, GTSModel: >smodel.Follow{ @@ -105,7 +105,7 @@ func (p *processor) FollowRemove(ctx context.Context, requestingAccount *gtsmode }, OriginAccount: requestingAccount, TargetAccount: targetAcct, - } + }) } // return whatever relationship results from all this |