Sha256: 468f6d822c2b6cb31f03fbc501f477e41f212931db181d8d1d7f1cd6fc49bb39
Contents?: true
Size: 1.94 KB
Versions: 7
Compression:
Stored size: 1.94 KB
Contents
module SplitIoClient module Cache module Senders class ImpressionsFormatter def initialize(impressions_repository) @impressions_repository = impressions_repository end def call(raw_impressions) impressions = raw_impressions ? raw_impressions : @impressions_repository.clear formatted_impressions = [] filtered_impressions = filter_impressions(impressions) return [] if impressions.empty? || filtered_impressions.empty? formatted_impressions = unique_features(filtered_impressions).each_with_object([]) do |feature, memo| current_impressions = filtered_impressions .select { |i| i[:feature] == feature } .map do |i| { keyName: i[:impressions]['key_name'], treatment: i[:impressions]['treatment'], time: i[:impressions]['time'] } end memo << { testName: feature, keyImpressions: current_impressions } end formatted_impressions end private def unique_features(impressions) impressions.map { |i| i[:feature] }.uniq end # Filter seen impressions by impression_hash def filter_impressions(unfiltered_impressions) impressions_seen = [] unfiltered_impressions.each_with_object([]) do |impression, impressions| impression_hash = impression_hash(impression) next if impressions_seen.include?(impression_hash) impressions_seen << impression_hash impressions << impression end end def impression_hash(impression) "#{impression[:feature]}:" \ "#{impression[:impressions]['key_name']}:" \ "#{impression[:impressions]['treatment']}" end end end end end
Version data entries
7 entries across 7 versions & 1 rubygems