Contents

# frozen_string_literal: true

require 'test_helper'

class TestEvaluatedKeysAggregator < Minitest::Test
  MAX_WAIT = 2
  SLEEP_TIME = 0.01

  def test_push
    aggregator = Prefab::EvaluatedKeysAggregator.new(client: new_client, max_keys: 2, sync_interval: 1000)

    aggregator.push('key.1')
    aggregator.push('key.2')

    assert_equal 2, aggregator.data.size

    # we've reached the limit, so no more
    aggregator.push('key.3')
    assert_equal 2, aggregator.data.size
  end

  def test_sync
    client = new_client(namespace: 'this.is.a.namespace')

    client.get 'key.1', 'default', {}
    client.get 'key.1', 'default', {}
    client.get 'key.2', 'default', {}

    requests = wait_for_post_requests(client) do
      client.evaluated_keys_aggregator.send(:sync)
    end

    assert_equal [[
      '/api/v1/evaluated-keys',
      PrefabProto::EvaluatedKeys.new(
        keys: ['key.1', 'key.2'],
        namespace: 'this.is.a.namespace'
      )
    ]], requests
  end

  private

  def new_client(overrides = {})
    super(**{
      prefab_datasources: Prefab::Options::DATASOURCES::ALL,
      initialization_timeout_sec: 0,
      on_init_failure: Prefab::Options::ON_INITIALIZATION_FAILURE::RETURN,
      api_key: '123-development-yourapikey-SDK',
      collect_sync_interval: 1000, # we'll trigger sync manually in our test
      collect_keys: true
    }.merge(overrides))
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
prefab-cloud-ruby-0.24.6	test/test_evaluated_keys_aggregator.rb
prefab-cloud-ruby-0.24.5	test/test_evaluated_keys_aggregator.rb
prefab-cloud-ruby-0.24.4	test/test_evaluated_keys_aggregator.rb