diff options
Diffstat (limited to 'internal/federation/federatingdb/update.go')
| -rw-r--r-- | internal/federation/federatingdb/update.go | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/internal/federation/federatingdb/update.go b/internal/federation/federatingdb/update.go index a2a9777d1..803c476d6 100644 --- a/internal/federation/federatingdb/update.go +++ b/internal/federation/federatingdb/update.go @@ -43,20 +43,24 @@ import ( func (f *federatingDB) Update(ctx context.Context, asType vocab.Type) error { log.DebugKV(ctx, "update", serialize{asType}) + // Mark activity as handled. + f.storeActivityID(asType) + + // Extract relevant values from passed ctx. activityContext := getActivityContext(ctx) if activityContext.internal { return nil // Already processed. } - requestingAcct := activityContext.requestingAcct - receivingAcct := activityContext.receivingAcct + requesting := activityContext.requestingAcct + receiving := activityContext.receivingAcct if accountable, ok := ap.ToAccountable(asType); ok { - return f.updateAccountable(ctx, receivingAcct, requestingAcct, accountable) + return f.updateAccountable(ctx, receiving, requesting, accountable) } if statusable, ok := ap.ToStatusable(asType); ok { - return f.updateStatusable(ctx, receivingAcct, requestingAcct, statusable) + return f.updateStatusable(ctx, receiving, requesting, statusable) } log.Debugf(ctx, "unhandled object type: %T", asType) |