diff options
Diffstat (limited to 'internal/processing/account/createblock.go')
| -rw-r--r-- | internal/processing/account/createblock.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/internal/processing/account/createblock.go b/internal/processing/account/createblock.go index 6e05866d7..e1bad0d38 100644 --- a/internal/processing/account/createblock.go +++ b/internal/processing/account/createblock.go @@ -113,7 +113,7 @@ func (p *processor) BlockCreate(ctx context.Context, requestingAccount *gtsmodel // 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{ @@ -123,12 +123,12 @@ func (p *processor) BlockCreate(ctx context.Context, requestingAccount *gtsmodel }, OriginAccount: requestingAccount, TargetAccount: targetAccount, - } + }) } // 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{ @@ -138,17 +138,17 @@ func (p *processor) BlockCreate(ctx context.Context, requestingAccount *gtsmodel }, OriginAccount: requestingAccount, TargetAccount: targetAccount, - } + }) } // handle the rest of the block process asynchronously - p.fromClientAPI <- messages.FromClientAPI{ + p.clientWorker.Queue(messages.FromClientAPI{ APObjectType: ap.ActivityBlock, APActivityType: ap.ActivityCreate, GTSModel: block, OriginAccount: requestingAccount, TargetAccount: targetAccount, - } + }) return p.RelationshipGet(ctx, requestingAccount, targetAccountID) } |