Contents

module Tekeya
  module Feed
    module Activity
      module Resque
        # A resque worker to copy activities when an entity tracks another
        class UntrackFeed
          include Tekeya::Feed::Activity::Resque

          @queue = :activity_queue

          # @private
          def self.perform(untracked_feed_key, untracker_feed_key)
            # get the keys to the activities so we can decrement the counters later
            activity_keys = ::Tekeya.redis.zrange(untracked_feed_key, 0, -1)
            return if activity_keys.empty?

            ::Tekeya.redis.multi do
              # delete the latest activities of the untracked entity from the tracker feed
              ::Tekeya.redis.zrem(untracker_feed_key, activity_keys)

              # increment the activity counter
              activity_keys.each do |activity_key|
                activity_counter_key = "#{activity_key}:counter"
                ::Tekeya.redis.decr(activity_counter_key)
              end
            end

            # trim the tracker feed and cleanup
            collect_garbage trim_feed(untracker_feed_key)
          end
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
tekeya-0.0.10	lib/tekeya/feed/activity/resque/untrack_feed.rb
tekeya-0.0.9	lib/tekeya/feed/activity/resque/untrack_feed.rb