Class: Fino::Redis::Adapter

Inherits:
Object
  • Object
show all
Includes:
Adapter
Defined in:
lib/fino/redis/adapter.rb

Constant Summary collapse

DEFAULT_REDIS_NAMESPACE = 
"fino"
SETTINGS_NAMESPACE = 
"s"
PERSISTED_SETTINGS_KEYS_REDIS_KEY = 
"psl"
SCOPE_PREFIX = 
"s"
VARIANT_PREFIX = 
"v"
VALUE_KEY = 
"v"

Instance Method Summary collapse

Constructor Details

#initialize(redis, namespace: DEFAULT_REDIS_NAMESPACE) ⇒ Adapter

Returns a new instance of Adapter.



15
16
17
18
 
# File 'lib/fino/redis/adapter.rb', line 15

def initialize(redis, namespace: DEFAULT_REDIS_NAMESPACE)
  @redis = redis
  @redis_namespace = namespace
end

Instance Method Details

#clear(setting_key) ⇒ Object 



57
58
59
60
61
62
63
64
 
# File 'lib/fino/redis/adapter.rb', line 57

def clear(setting_key)
  _, cleared = redis.multi do |r|
    r.del(redis_key_for(setting_key))
    r.srem(build_redis_key(PERSISTED_SETTINGS_KEYS_REDIS_KEY), setting_key)
  end

  cleared == 1
end

#fetch_raw_overrides_from(raw_adapter_data) ⇒ Object 



70
71
72
73
74
75
76
77
 
# File 'lib/fino/redis/adapter.rb', line 70

def fetch_raw_overrides_from(raw_adapter_data)
  raw_adapter_data.each_with_object({}) do |(key, value), memo|
    next unless key.start_with?("#{SCOPE_PREFIX}/")

    scope = key.split("/", 3)[1]
    memo[scope] = value
  end
end

#fetch_raw_variants_from(raw_adapter_data) ⇒ Object 



79
80
81
82
83
84
85
86
87
 
# File 'lib/fino/redis/adapter.rb', line 79

def fetch_raw_variants_from(raw_adapter_data)
  raw_adapter_data.each_with_object([]) do |(key, value), memo|
    next unless key.start_with?("#{VARIANT_PREFIX}/")

    percentage = key.split("/", 3)[1]

    memo << { percentage: percentage.to_f, value: value }
  end
end

#fetch_value_from(raw_adapter_data) ⇒ Object 



66
67
68
 
# File 'lib/fino/redis/adapter.rb', line 66

def fetch_value_from(raw_adapter_data)
  raw_adapter_data.key?(VALUE_KEY) ? raw_adapter_data.delete(VALUE_KEY) : Fino::EMPTINESS
end

#read(setting_key) ⇒ Object 



20
21
22
 
# File 'lib/fino/redis/adapter.rb', line 20

def read(setting_key)
  redis.hgetall(redis_key_for(setting_key))
end

#read_multi(setting_keys) ⇒ Object 



24
25
26
27
28
29
30
 
# File 'lib/fino/redis/adapter.rb', line 24

def read_multi(setting_keys)
  keys = setting_keys.map { |setting_key| redis_key_for(setting_key) }

  redis.pipelined do |pipeline|
    keys.each { |key| pipeline.hgetall(key) }
  end
end

#read_persisted_setting_keys ⇒ Object 



53
54
55
 
# File 'lib/fino/redis/adapter.rb', line 53

def read_persisted_setting_keys
  redis.smembers(build_redis_key(PERSISTED_SETTINGS_KEYS_REDIS_KEY))
end

#write(setting_definition, value, overrides, variants) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/fino/redis/adapter.rb', line 32

def write(setting_definition, value, overrides, variants)
  serialize_value = ->(raw_value) { setting_definition.type_class.serialize(raw_value) }

  hash = { VALUE_KEY => serialize_value.call(value) }

  overrides.each do |scope, value|
    hash["#{SCOPE_PREFIX}/#{scope}/#{VALUE_KEY}"] = serialize_value.call(value)
  end

  variants.each do |variant|
    next if variant.value == Fino::AbTesting::Variant::CONTROL_VALUE

    hash["#{VARIANT_PREFIX}/#{variant.percentage}/#{VALUE_KEY}"] = serialize_value.call(variant.value)
  end

  redis.multi do |r|
    r.mapped_hreplace(redis_key_for(setting_definition.key), hash)
    r.sadd(build_redis_key(PERSISTED_SETTINGS_KEYS_REDIS_KEY), setting_definition.key)
  end
end