diff options
author | 2024-02-17 15:20:39 +0100 | |
---|---|---|
committer | 2024-02-17 15:20:39 +0100 | |
commit | d3f35e8eba602dd963a395b304c778e0a776869d (patch) | |
tree | b7dde8d924ad19c657d60c584463278522966298 /internal/federation/federatingdb/update.go | |
parent | [chore] Simplify the User-Agent string (#2645) (diff) | |
download | gotosocial-d3f35e8eba602dd963a395b304c778e0a776869d.tar.xz |
[chore] refactor extractFromCtx a bit (#2646)
Diffstat (limited to 'internal/federation/federatingdb/update.go')
-rw-r--r-- | internal/federation/federatingdb/update.go | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/internal/federation/federatingdb/update.go b/internal/federation/federatingdb/update.go index 26ea81f72..bd8ad3106 100644 --- a/internal/federation/federatingdb/update.go +++ b/internal/federation/federatingdb/update.go @@ -53,17 +53,20 @@ func (f *federatingDB) Update(ctx context.Context, asType vocab.Type) error { l.Debug("entering Update") } - receivingAccount, requestingAccount, internal := extractFromCtx(ctx) - if internal { + activityContext := getActivityContext(ctx) + if activityContext.internal { return nil // Already processed. } + requestingAcct := activityContext.requestingAcct + receivingAcct := activityContext.receivingAcct + if accountable, ok := ap.ToAccountable(asType); ok { - return f.updateAccountable(ctx, receivingAccount, requestingAccount, accountable) + return f.updateAccountable(ctx, receivingAcct, requestingAcct, accountable) } if statusable, ok := ap.ToStatusable(asType); ok { - return f.updateStatusable(ctx, receivingAccount, requestingAccount, statusable) + return f.updateStatusable(ctx, receivingAcct, requestingAcct, statusable) } return nil |