summaryrefslogtreecommitdiff
path: root/internal/processing/common
diff options
context:
space:
mode:
Diffstat (limited to 'internal/processing/common')
-rw-r--r--internal/processing/common/status.go21
1 files changed, 3 insertions, 18 deletions
diff --git a/internal/processing/common/status.go b/internal/processing/common/status.go
index 01f2ab72d..532b531e5 100644
--- a/internal/processing/common/status.go
+++ b/internal/processing/common/status.go
@@ -306,25 +306,10 @@ func (p *Processor) InvalidateTimelinedStatus(ctx context.Context, accountID str
return gtserror.Newf("db error getting lists for account %s: %w", accountID, err)
}
- // Start new log entry with
- // the above calling func's name.
- l := log.
- WithContext(ctx).
- WithField("caller", log.Caller(3)).
- WithField("accountID", accountID).
- WithField("statusID", statusID)
-
- // Unprepare item from home + list timelines, just log
- // if something goes wrong since this is not a showstopper.
-
- if err := p.state.Timelines.Home.UnprepareItem(ctx, accountID, statusID); err != nil {
- l.Errorf("error unpreparing item from home timeline: %v", err)
- }
-
+ // Unprepare item from home + list timelines.
+ p.state.Caches.Timelines.Home.MustGet(accountID).UnprepareByStatusIDs(statusID)
for _, list := range lists {
- if err := p.state.Timelines.List.UnprepareItem(ctx, list.ID, statusID); err != nil {
- l.Errorf("error unpreparing item from list timeline %s: %v", list.ID, err)
- }
+ p.state.Caches.Timelines.List.MustGet(list.ID).UnprepareByStatusIDs(statusID)
}
return nil