Sha256: 3793c59b408691db6ba711817d17701cc66c6917b8190d13890975845cdc1dc1
Contents?: true
Size: 1.34 KB
Versions: 15
Compression:
Stored size: 1.34 KB
Contents
require 'spec_helper' require 'spec/support/rack_test' require 'spec/support/uses_redis' require 'spec/support/uses_dotenv' require 'spec/support/events' require 'routemaster/drain/mapping' require 'json' describe Routemaster::Drain::Mapping do uses_dotenv uses_redis let(:app) { described_class.new } let(:listener) { double 'listener' } before { app.subscribe(listener, prefix: true) } let(:path) { '/' } let(:payload) { [1,2,3,1].map { |idx| make_event(idx) }.to_json } let(:environment) {{ 'CONTENT_TYPE' => 'application/json' }} let(:perform) { post path, payload, environment } before { authorize 'd3m0', 'x' } it 'succeeds' do perform expect(last_response.status).to eq(204) end it 'filters events' do expect(listener).to receive(:on_events_received) do |payload| expect(payload.size).to eq(3) # the second 1 is filtered end perform end let(:map) { Routemaster::Dirty::Map.new } it 'uses dirty map' do payload1 = [1,2,3,1].map { |idx| make_event(idx) }.to_json payload2 = [1,4,5,2].map { |idx| make_event(idx) }.to_json post path, payload1, environment expect(map.count).to eq(3) map.sweep_one("https://example.com/stuff/1") { true } post path, payload2, environment expect(map.count).to eq(4) # 2, 3, 4, 5 (1 is a repeat event, filtered out) end end
Version data entries
15 entries across 15 versions & 1 rubygems