module Stream
  class ReactionsClient < Client
    def add(kind, activity_id, user_id, data: nil, target_feeds: nil, target_feeds_extra_data: nil)
      data = {
        kind: kind,
        activity_id: activity_id,
        user_id: user_id,
        data: data,
        target_feeds: target_feeds,
        target_feeds_extra_data: target_feeds_extra_data
      }
      make_reaction_request(:post, {}, data)
    end

    def get(reaction_id)
      uri = "/reaction/#{reaction_id}/"
      make_reaction_request(:get, {}, {}, endpoint: uri)
    end

    def update(reaction_id, data: nil, target_feeds: nil)
      data = {
        data: data,
        target_feeds: target_feeds
      }
      uri = "/reaction/#{reaction_id}/"
      make_reaction_request(:put, {}, data, endpoint: uri)
    end

    def delete(reaction_id, soft: false)
      uri = "/reaction/#{reaction_id}/"
      if soft
        make_reaction_request(:delete, { soft: soft }, {}, endpoint: uri)
      else
        make_reaction_request(:delete, {}, {}, endpoint: uri)
      end
    end

    def restore(reaction_id)
      uri = "/reaction/#{reaction_id}/restore/"
      make_reaction_request(:put, {}, {}, endpoint: uri)
    end

    def add_child(kind, parent_id, user_id, data: nil, target_feeds: nil, target_feeds_extra_data: nil)
      data = {
        kind: kind,
        parent: parent_id,
        user_id: user_id,
        data: data,
        target_feeds: target_feeds,
        target_feeds_extra_data: target_feeds_extra_data
      }
      make_reaction_request(:post, {}, data)
    end

    def filter(params = {})
      field = ''
      value = ''
      kind = params.fetch(:kind, '')
      if params[:reaction_id]
        field = 'reaction_id'
        value = params[:reaction_id]
      elsif params[:activity_id]
        field = 'activity_id'
        value = params[:activity_id]
      elsif params[:user_id]
        field = 'user_id'
        value = params[:user_id]
      end
      params.delete(field.to_sym) unless field.empty? && field != 'user_id'
      uri = if kind.nil? || kind.empty?
              "/reaction/#{field}/#{value}/"
            else
              "/reaction/#{field}/#{value}/#{kind}/"
            end
      make_reaction_request(:get, params, {}, endpoint: uri)
    end

    def create_reference(id)
      k = id
      k = id['id'] if id.respond_to?(:keys) && !id['id'].nil?
      "SR:#{k}"
    end

    private

    def make_reaction_request(method, params, data, endpoint: '/reaction/')
      auth_token = Stream::Signer.create_jwt_token('reactions', '*', @api_secret, '*', '*')
      make_request(method, endpoint, auth_token, params, data)
    end
  end
end