stream-ruby/lib/stream/activities.rb at 6769eb0818045f7a50084b3795b9c59d24476ea9 · GetStream/stream-ruby · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
module Stream
  module Activities
    #
    # Get activities directly, via ID or Foreign ID + timestamp
    #
    # @param [Hash<:ids, :foreign_id_times>] params the request params (ids or list of <:foreign_id, :time> objects)
    #
    # @return the found activities, if any.
    #
    # @example Retrieve by activity IDs
    #   @client.get_activities(
    #     ids: [
    #       '4b39fda2-d6e2-42c9-9abf-5301ef071b12',
    #       '89b910d3-1ef5-44f8-914e-e7735d79e817'
    #     ]
    #   )
    #
    # @example Retrieve by Foreign IDs + timestamps
    #   @client.get_activities(
    #     foreign_id_times: [
    #       { foreign_id: 'post:1000', time: '2016-11-10T13:20:00.000000' },
    #       { foreign_id: 'like:2000', time: '2018-01-07T09:15:59.123456' }
    #     ]
    #   )
    #
    def get_activities(params = {})
      if params[:foreign_id_times]
        foreign_ids = []
        timestamps = []
        params[:foreign_id_times].each do |e|
          foreign_ids << e[:foreign_id]
          timestamps << e[:time]
        end
        params = {
          foreign_ids: foreign_ids,
          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[:withFirstReactions] = true if params[:reactions][:first]
        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) }

      # Handle multiple IDs by joining with commas
      params[:ids] = params[:ids].join(',') if params[:ids]&.is_a?(Array)

      signature = Stream::Signer.create_jwt_token('activities', '*', @api_secret, '*')
      make_request(:get, uri, signature, params)
    end

    #
    # Partial update activity, via activity ID or Foreign ID + timestamp
    #
    # @param [Hash<:id, :foreign_id, :time, :set, :unset>] data the request params (id and foreign_id+timestamp mutually exclusive)
    #
    # @return the updated activity.
    #
    # @example Identify using activity ID
    #   @client.activity_partial_update(
    #     id: "4b39fda2-d6e2-42c9-9abf-5301ef071b12",
    #     set: {
    #       "product.price.eur": 12.99,
    #       "colors": {
    #         "blue": "#0000ff",
    #         "green": "#00ff00",
    #       }
    #     },
    #     unset: [ "popularity", "size.xl" ]
    #   )
    #
    # @example Identify using Foreign ID + timestamp
    #   @client.activity_partial_update(
    #     foreign_id: 'product:123',
    #     time: '2016-11-10T13:20:00.000000',
    #     set: {
    #      "product.price.eur": 12.99,
    #      "colors": {
    #        "blue": "#0000ff",
    #        "green": "#00ff00",
    #      }
    #     },
    #     unset: [ "popularity", "size.xl" ]
    #   )
    #
    def activity_partial_update(data = {})
      signature = Stream::Signer.create_jwt_token('activities', '*', @api_secret, '*')
      make_request(:post, '/activity/', signature, {}, data)
    end

    #
    # Batch partial activity update
    #
    # @param [Array< Hash<:id, :foreign_id, :time, :set, :unset> >] changes the list of changes to be applied
    #
    # @return the updated activities
    #
    # @example Identify using activity IDs
    #   @client.batch_activity_partial_update([
    #     {
    #       id: "4b39fda2-d6e2-42c9-9abf-5301ef071b12",
    #       set: {
    #         "product.price.eur": 12.99,
    #         "colors": {
    #           "blue": "#0000ff",
    #           "green": "#00ff00",
    #         }
    #       },
    #       unset: [ "popularity", "size.x2" ]
    #     },
    #     {
    #       id: "8d2dcad8-1e34-11e9-8b10-9cb6d0925edd",
    #       set: {
    #         "product.price.eur": 17.99,
    #         "colors": {
    #           "red": "#ff0000",
    #           "green": "#00ff00",
    #         }
    #       },
    #       unset: [ "rating" ]
    #     }
    #   ])
    #
    # @example Identify using Foreign IDs + timestamps
    #   @client.batch_activity_partial_update([
    #     {
    #       foreign_id: "product:123",
    #       time: '2016-11-10T13:20:00.000000',
    #       set: {
    #         "product.price.eur": 22.99,
    #         "colors": {
    #           "blue": "#0000ff",
    #           "green": "#00ff00",
    #         }
    #       },
    #       unset: [ "popularity", "size.x2" ]
    #     },
    #     {
    #       foreign_id: "product:1234",
    #       time: '2017-11-10T13:20:00.000000',
    #       set: {
    #         "product.price.eur": 37.99,
    #         "colors": {
    #           "black": "#000000",
    #           "white": "#ffffff",
    #         }
    #       },
    #       unset: [ "rating" ]
    #     }
    #   ])
    #
    def batch_activity_partial_update(changes = [])
      signature = Stream::Signer.create_jwt_token('activities', '*', @api_secret, '*')
      make_request(:post, '/activity/', signature, {}, { changes: changes })
    end
  end
end