Add missing enrichment for feeds and support activities (#133)

fixes #119

Author: ferhatelmas

lib/stream/activities.rb

@@ -36,8 +36,24 @@ def get_activities(params = {})
           timestamps: timestamps
         }
       end
+
+      uri = params[:enrich] || params[:reactions] ? '/enrich/activities/' : '/activities/'
+      if params[:reactions].respond_to?(:keys)
+        params[:withOwnReactions] = true if params[:reactions][:own]
+        params[:withRecentReactions] = true if params[:reactions][:recent]
+        params[:withReactionCounts] = true if params[:reactions][:counts]
+        params[:withOwnChildren] = true if params[:reactions][:children]
+        user_id = params[:reactions][:user_id]
+        params[:user_id] = user_id if user_id
+        kinds = params[:reactions][:kinds]
+        if kinds
+          params[:reactionKindsFilter] = kinds.is_a?(Array) ? kinds.join(',') : kinds
+        end
+      end
+      %i[enrich reactions].each { |k| params.delete(k) }
+
       signature = Stream::Signer.create_jwt_token('activities', '*', @api_secret, '*')
-      make_request(:get, '/activities/', signature, params)
+      make_request(:get, uri, signature, params)
     end
 
     #

lib/stream/feed.rb

@@ -44,6 +44,13 @@ def get(params = {})
         params[:withOwnReactions] = true if params[:reactions][:own]
         params[:withRecentReactions] = true if params[:reactions][:recent]
         params[:withReactionCounts] = true if params[:reactions][:counts]
+        params[:withOwnChildren] = true if params[:reactions][:children]
+        user_id = params[:reactions][:user_id]
+        params[:user_id] = user_id if user_id
+        kinds = params[:reactions][:kinds]
+        if kinds
+          params[:reactionKindsFilter] = kinds.is_a?(Array) ? kinds.join(',') : kinds
+        end
       end
       %i[enrich reactions].each { |k| params.delete(k) }
 

spec/integration_spec.rb

@@ -616,6 +616,39 @@
         expect(res).to eq(activity)
       end
 
+      example 'activity own reaction enrichment' do
+        activity = @feed42.add_activity({ actor: 'jim', verb: 'buy', object: 'wallet' })
+        reaction = @client.reactions.add('like', activity['id'], 'jim')
+        reaction.delete('duration')
+
+        response = @client.get_activities(ids: [activity['id']], reactions: { own: true })
+        expect(response['results'][0]['own_reactions']['like'][0]).to eq reaction
+      end
+      example 'activity recent reaction enrichment' do
+        activity = @feed42.add_activity({ actor: 'jim', verb: 'buy', object: 'wallet' })
+        reaction = @client.reactions.add('dislike', activity['id'], 'jim')
+        reaction.delete('duration')
+
+        response = @client.get_activities(ids: [activity['id']], reactions: { recent: true })
+        expect(response['results'][0]['latest_reactions']['dislike'][0]).to eq reaction
+      end
+      example 'activity reaction counts enrichment' do
+        activity = @feed42.add_activity({ actor: 'jim', verb: 'buy', object: 'wallet' })
+        @client.reactions.add('like', activity['id'], 'jim')
+
+        response = @client.get_activities(ids: [activity['id']], reactions: { counts: true })
+        expect(response['results'][0]['reaction_counts']['like']).to eq 1
+      end
+      example 'activity reaction kinds enrichment filtering' do
+        activity = @feed42.add_activity({ actor: 'jim', verb: 'buy', object: 'wallet' })
+        @client.reactions.add('like', activity['id'], 'jim')
+        @client.reactions.add('comment', activity['id'], 'jim')
+
+        response = @client.get_activities(ids: [activity['id']], reactions: { counts: true, kinds: ['like'] })
+        expect(response['results'][0]['reaction_counts']['like']).to eq 1
+        expect(response['results'][0]['reaction_counts']['comment']).to eq nil
+      end
+
       example 'partial update' do
         activity_a = @feed42.add_activity({
                                             actor: 'bob',