class SplitIoClient::Cache::Fetchers::SplitFetcher

def call
  if ENV['SPLITCLIENT_ENV'] == 'test'
    fetch_splits
    return
  end
  splits_thread
end

def fetch_splits(fetch_options = { cache_control_headers: false, till: nil })
  @semaphore.synchronize do
    data = splits_since(@splits_repository.get_change_number, fetch_options)
    SplitIoClient::Helpers::RepositoryHelper.update_feature_flag_repository(@splits_repository, data[:splits], data[:till], @config)
    @splits_repository.set_segment_names(data[:segment_names])
    @config.logger.debug("segments seen(#{data[:segment_names].length}): #{data[:segment_names].to_a}") if @config.debug_enabled
    { segment_names: data[:segment_names], success: true }
  end
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
  { segment_names: [], success: false }
end

def initialize(splits_repository, api_key, config, telemetry_runtime_producer)
  @splits_repository = splits_repository
  @api_key = api_key
  @config = config
  @semaphore = Mutex.new
  @telemetry_runtime_producer = telemetry_runtime_producer
end

def splits_api
  @splits_api ||= SplitIoClient::Api::Splits.new(@api_key, @config, @telemetry_runtime_producer)
end

def splits_since(since, fetch_options = { cache_control_headers: false, till: nil })
  splits_api.since(since, fetch_options)
end

def splits_thread
  @config.threads[:split_fetcher] = Thread.new do
    @config.logger.info('Starting feature flags fetcher service') if @config.debug_enabled
    loop do
      fetch_splits
      sleep_for = SplitIoClient::Cache::Stores::StoreUtils.random_interval(@config.features_refresh_rate)
      @config.logger.debug("Feature flags fetcher is sleeping for: #{sleep_for} seconds") if @config.debug_enabled
      sleep(sleep_for)
    end
  end
end

def stop_splits_thread
  SplitIoClient::Helpers::ThreadHelper.stop(:split_fetcher, @config)
end