diff options
Diffstat (limited to 'internal/processing/polls')
| -rw-r--r-- | internal/processing/polls/expiry.go | 4 | ||||
| -rw-r--r-- | internal/processing/polls/vote.go | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/internal/processing/polls/expiry.go b/internal/processing/polls/expiry.go index 59d0f17fe..d02a05f0d 100644 --- a/internal/processing/polls/expiry.go +++ b/internal/processing/polls/expiry.go @@ -116,11 +116,11 @@ func (p *Processor) onExpiry(pollID string) func(context.Context, time.Time) { // Enqueue a status update operation to the client API worker, // this will asynchronously send an update with the Poll close time. - p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{ + p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{ APActivityType: ap.ActivityUpdate, APObjectType: ap.ObjectNote, GTSModel: status, - OriginAccount: status.Account, + Origin: status.Account, }) } } diff --git a/internal/processing/polls/vote.go b/internal/processing/polls/vote.go index 5bc523978..c970fe106 100644 --- a/internal/processing/polls/vote.go +++ b/internal/processing/polls/vote.go @@ -96,11 +96,11 @@ func (p *Processor) PollVote(ctx context.Context, requester *gtsmodel.Account, p poll.IncrementVotes(choices) // Enqueue worker task to handle side-effects of user poll vote(s). - p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{ + p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{ APActivityType: ap.ActivityCreate, APObjectType: ap.ActivityQuestion, GTSModel: vote, // the vote choices - OriginAccount: requester, + Origin: requester, }) // Return converted API model poll. |