summaryrefslogtreecommitdiff
path: root/internal/processing/status
diff options
context:
space:
mode:
Diffstat (limited to 'internal/processing/status')
-rw-r--r--internal/processing/status/boost.go12
-rw-r--r--internal/processing/status/create.go4
-rw-r--r--internal/processing/status/delete.go6
-rw-r--r--internal/processing/status/fave.go12
4 files changed, 17 insertions, 17 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,
})
}
diff --git a/internal/processing/status/create.go b/internal/processing/status/create.go
index d758fc0fb..80cc65c7f 100644
--- a/internal/processing/status/create.go
+++ b/internal/processing/status/create.go
@@ -143,11 +143,11 @@ func (p *Processor) Create(
}
// send it back to the client API worker for async side-effects.
- p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{
+ p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{
APObjectType: ap.ObjectNote,
APActivityType: ap.ActivityCreate,
GTSModel: status,
- OriginAccount: requester,
+ Origin: requester,
})
if status.Poll != nil {
diff --git a/internal/processing/status/delete.go b/internal/processing/status/delete.go
index 261086bdb..700909f44 100644
--- a/internal/processing/status/delete.go
+++ b/internal/processing/status/delete.go
@@ -51,12 +51,12 @@ func (p *Processor) Delete(ctx context.Context, requestingAccount *gtsmodel.Acco
}
// Process delete side effects.
- p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{
+ p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{
APObjectType: ap.ObjectNote,
APActivityType: ap.ActivityDelete,
GTSModel: targetStatus,
- OriginAccount: requestingAccount,
- TargetAccount: requestingAccount,
+ Origin: requestingAccount,
+ Target: requestingAccount,
})
return apiStatus, nil
diff --git a/internal/processing/status/fave.go b/internal/processing/status/fave.go
index 7b71725ab..dd961c082 100644
--- a/internal/processing/status/fave.go
+++ b/internal/processing/status/fave.go
@@ -107,12 +107,12 @@ func (p *Processor) FaveCreate(ctx context.Context, requestingAccount *gtsmodel.
}
// Process new status fave side effects.
- p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{
+ p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{
APObjectType: ap.ActivityLike,
APActivityType: ap.ActivityCreate,
GTSModel: gtsFave,
- OriginAccount: requestingAccount,
- TargetAccount: targetStatus.Account,
+ Origin: requestingAccount,
+ Target: targetStatus.Account,
})
return p.c.GetAPIStatus(ctx, requestingAccount, targetStatus)
@@ -137,12 +137,12 @@ func (p *Processor) FaveRemove(ctx context.Context, requestingAccount *gtsmodel.
}
// Process remove status fave side effects.
- p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{
+ p.state.Workers.Client.Queue.Push(&messages.FromClientAPI{
APObjectType: ap.ActivityLike,
APActivityType: ap.ActivityUndo,
GTSModel: existingFave,
- OriginAccount: requestingAccount,
- TargetAccount: targetStatus.Account,
+ Origin: requestingAccount,
+ Target: targetStatus.Account,
})
return p.c.GetAPIStatus(ctx, requestingAccount, targetStatus)