Sha256: bd0955eef4ab50103d1ebe87c4fdb8b056198c1a4df6566d3f26b8adc2e10b5b
Contents?: true
Size: 1.8 KB
Versions: 19
Compression:
Stored size: 1.8 KB
Contents
module Prefab
class ConfigResolver
def initialize(base_client, config_loader)
@lock = Concurrent::ReadWriteLock.new
@local_store = {}
@namespace = base_client.namespace
@config_loader = config_loader
make_local
end
def to_s
str = ""
@lock.with_read_lock do
@local_store.each do |k, v|
value = v[:value]
str << "|#{k}| |#{value_of(value)}|#{value_of(value).class}\n"
end
end
str
end
def get(property)
config = @lock.with_read_lock do
@local_store[property]
end
config ? value_of(config[:value]) : nil
end
def update
make_local
end
def export_api_deltas
@config_loader.get_api_deltas
end
private
def value_of(config_value)
case config_value.type
when :string
config_value.string
when :int
config_value.int
when :double
config_value.double
when :bool
config_value.bool
when :feature_flag
config_value.feature_flag
end
end
def make_local
store = {}
@config_loader.calc_config.each do |prop, value|
property = prop
namespace = ""
split = prop.split(":")
if split.size > 1
property = split[1..-1].join
namespace = split[0]
end
if (namespace == "") || @namespace.start_with?(namespace)
existing = store[property]
if existing.nil?
store[property] = { namespace: namespace, value: value }
elsif existing[:namespace].split(".").size < namespace.split(".").size
store[property] = { namespace: namespace, value: value }
end
end
end
@lock.with_write_lock do
@local_store = store
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems