class SplitIoClient::Cache::Stores::LocalhostSplitStore

def call
  if ENV['SPLITCLIENT_ENV'] == 'test'
    store_splits
  else
    splits_thread
    if defined?(PhusionPassenger)
      PhusionPassenger.on_event(:starting_worker_process) do |forked|
        splits_thread if forked
      end
    end
  end
end

def initialize(splits_repository, config, status_manager = nil)
  @splits_repository = splits_repository
  @config = config
  @status_manager = status_manager
end

def load_features
  yaml_extensions = ['.yml', '.yaml']
  if yaml_extensions.include? File.extname(@config.split_file)
    parse_yaml_features
  else
    @config.logger.warn('Localhost mode: .split mocks ' \
      'will be deprecated soon in favor of YAML files, which provide more ' \
      'targeting power. Take a look in our documentation.')
    parse_plain_text_features
  end
end

def parse_plain_text_features
  splits = File.open(@config.split_file).each_with_object({}) do |line, memo|
    feature, treatment = line.strip.split(' ')
    next if line.start_with?('#') || line.strip.empty?
    memo[feature] = [{ treatment: treatment }]
  end
  LocalhostSplitBuilder.build_splits(splits)
end

def parse_yaml_features
  splits = YAML.safe_load(File.read(@config.split_file)).each_with_object({}) do |feature, memo|
    feat_symbolized_keys = symbolize_feat_keys(feature)
    feat_name = feature.keys.first
    if memo[feat_name]
      memo[feat_name] << feat_symbolized_keys
    else
      memo[feat_name] = [feat_symbolized_keys]
    end
  end
  LocalhostSplitBuilder.build_splits(splits)
end

def splits_thread
  @config.threads[:split_store] = Thread.new do
    @config.logger.info('Starting feature flags fetcher service')
    loop do
      store_splits
      sleep(StoreUtils.random_interval(@config.features_refresh_rate))
    end
  end
end

def store_split(split)
  @config.logger.debug("storing feature flag (#{split[:name]})") if @config.debug_enabled
  @splits_repository.update([split], [], -1)
end

def store_splits
  load_features.each do |split|
    store_split(split)
  end
  @status_manager.ready! if @status_manager
rescue StandardError => e
  @config.logger.error('Error while parsing the split file. ' \
    'Check that the input file matches the expected format')
  @config.log_found_exception(__method__.to_s, e)
end

def symbolize_feat_keys(yaml_feature)
  yaml_feature.values.first.each_with_object({}) do |(k, v), memo|
    memo[k.to_sym] = k == 'config' ? v.to_json : v
  end
end