lib/tekeya/feed/activity/resque/delete_activity.rb in tekeya-0.0.2 vs lib/tekeya/feed/activity/resque/delete_activity.rb in tekeya-0.0.3
- old
+ new
@@ -18,9 +18,10 @@
# get the entity
entity = entity_type.where(entity_type.entity_primary_key.to_sym => entity_id).first
# we only need the feed keys of the trackers
entity_trackers_feeds = entity.trackers.map(&:feed_key)
entity_trackers_feeds << entity.profile_feed_key
+ entity_trackers_feeds << entity.feed_key
# remove the aggregate key from the trackers' feeds and prepare the activity for garbage collection
::Tekeya.redis.multi do
entity_trackers_feeds.each do |feed_key|
if ::Tekeya.redis.zrank(feed_key, activity_aggregate_key)
\ No newline at end of file