activity_fanout.rb in tekeya-0.0.5

- old
+ new

@@ -7,26 +7,19 @@
           include Tekeya::Feed::Activity::Resque
 
           @queue = :activity_queue
 
           # @private
-          def self.perform(entity_id, entity_type, activity_key, score, attachments)
+          def self.perform(entity_id, entity_type, activity_key, score)
             # get the entity class
             entity_type = entity_type.safe_constantize
             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.feed_key
             # keep track of the keys we delete in the trim operation for garbage collection
             removed_keys = []
 
-            # write the activity to the aggregate set and the owner's feed
-            ::Tekeya.redis.multi do
-              write_aggregate(activity_key, attachments)
-              write_to_feed(entity.profile_feed_key, score, activity_key)
-            end
-
             # trim the profile feed
             removed_keys += trim_feed(entity.profile_feed_key)
 
             # Fanout the activity to the owner's trackers
             entity_trackers_feeds.each do |feed_key|
@@ -39,22 +32,9 @@
               removed_keys += trim_feed(feed_key)
             end
 
             # cleanup the garbage
             collect_garbage removed_keys
-          end
-
-          private
-
-          # Writes the activity and its' attachments to the aggregate set
-          #
-          # @param [String] activity_key the key of the activity to be added
-          # @param [Array]  attachments an array of attachments associated with the activity
-          def self.write_aggregate(activity_key, attachments)
-            # save the aggregate set
-            attachments.each do |attachment|
-              ::Tekeya.redis.sadd(activity_key, attachment)
-            end
           end
         end
       end
     end
   end
\ No newline at end of file