diff options
Diffstat (limited to 'internal/processing/status/boost.go')
| -rw-r--r-- | internal/processing/status/boost.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/internal/processing/status/boost.go b/internal/processing/status/boost.go index 5fae695fd..1c1da4ca7 100644 --- a/internal/processing/status/boost.go +++ b/internal/processing/status/boost.go @@ -89,12 +89,12 @@ func (p *Processor) BoostCreate( } // Process side effects asynchronously. - p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{ + p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{ APObjectType: ap.ActivityAnnounce, APActivityType: ap.ActivityCreate, GTSModel: boost, - OriginAccount: requester, - TargetAccount: target.Account, + Origin: requester, + Target: target.Account, }) return p.c.GetAPIStatus(ctx, requester, boost) @@ -141,12 +141,12 @@ func (p *Processor) BoostRemove( if boost != nil { // Status was boosted. Process unboost side effects asynchronously. - p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{ + p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{ APObjectType: ap.ActivityAnnounce, APActivityType: ap.ActivityUndo, GTSModel: boost, - OriginAccount: requester, - TargetAccount: target.Account, + Origin: requester, + Target: target.Account, }) } |