Aucune description http://j1x-huginn.herokuapp.com

http_status_agent_spec.rb 11KB

    require 'rails_helper' class MockResponse < Struct.new(:status, :headers, :url) alias_method :to_hash, :to_h end describe 'HttpStatusAgent' do let(:agent) do Agents::HttpStatusAgent.new(:name => SecureRandom.uuid, :options => valid_params).tap do |a| a.service = services(:generic) a.user = users(:jane) a.options['url'] = 'http://google.com' a.options['headers_to_save'] = 'Server' a.save! def a.interpolate_with(e, &block) @the_event = e block.call end def a.interpolated @the_event.payload end def a.create_event event @the_created_events ||= [] @the_created_events << event end def a.the_created_events @the_created_events || [] end def a.faraday @faraday ||= Struct.new(:programmed_responses).new({}).tap do |f| def f.get url programmed_responses[url] || raise('invalid url') end def f.set url, response, time = nil sleep(time/1000) if time programmed_responses[url] = response end end end end end let(:valid_params) { {} } describe "working" do it "should be working when the last status is 200" do agent.memory['last_status'] = '200' expect(agent.working?).to eq(true) end it "should be working when the last status is 304" do agent.memory['last_status'] = '304' expect(agent.working?).to eq(true) end it "should not be working if the status is 0" do agent.memory['last_status'] = '0' expect(agent.working?).to eq(false) end it "should not be working if the status is missing" do agent.memory['last_status'] = nil expect(agent.working?).to eq(false) end it "should not be working if the status is -1" do agent.memory['last_status'] = '-1' expect(agent.working?).to eq(false) end end describe "check" do before do def agent.interpolated @interpolated ||= { :url => SecureRandom.uuid, :headers_to_save => '' } end def agent.check_this_url url, local_headers @url = url @local_headers = local_headers end def agent.checked_url @url end end it "should check the url" do agent.check expect(agent.checked_url).to eq(agent.interpolated[:url]) end end describe "receive" do describe "with an event with a successful ping" do let(:successful_url) { SecureRandom.uuid } let(:status_code) { 200 } let(:header) { SecureRandom.uuid } let(:header_value) { SecureRandom.uuid } let(:event_with_a_successful_ping) do agent.faraday.set(successful_url, MockResponse.new(status_code, {}, successful_url)) Event.new.tap { |e| e.payload = { url: successful_url, headers_to_save: "" } } end let(:events) do [event_with_a_successful_ping] end it "should create one event" do agent.receive events expect(agent.the_created_events.count).to eq(1) end it "should note that the successful response succeeded" do agent.receive events expect(agent.the_created_events[0][:payload]['response_received']).to eq(true) end it "should return the status code" do agent.receive events expect(agent.the_created_events[0][:payload]['status']).to eq('200') end it "should remember the status" do agent.receive events expect(agent.memory['last_status']).to eq('200') end it "should record the time spent waiting for the reply" do agent.receive events expect(agent.the_created_events[0][:payload]['elapsed_time']).not_to be_nil end it "should not return a header" do agent.receive events expect(agent.the_created_events[0][:payload]['headers']).to be_nil end describe "but the last status code was 200" do before { agent.memory['last_status'] = '200' } describe "and no duplication settings have been set" do it "should create one event" do agent.receive events expect(agent.the_created_events.count).to eq(1) end end describe "and change settings have been set to true" do before { agent.options['changes_only'] = 'true' } it "should NOT create any events" do agent.receive events expect(agent.the_created_events.count).to eq(0) end describe "but actually, the ping failed" do let(:failing_url) { SecureRandom.uuid } let(:event_with_a_failing_ping) { Event.new.tap { |e| e.payload = { url: failing_url, headers_to_save: "" } } } let(:events) do [event_with_a_successful_ping, event_with_a_failing_ping] end it "should create an event" do agent.receive events expect(agent.the_created_events.count).to eq(1) end end end describe "and change settings have been set to false" do before { agent.options['changes_only'] = 'false' } it "should create one event" do agent.receive events expect(agent.the_created_events.count).to eq(1) end end end describe "but the status code is not 200" do let(:status_code) { 500 } it "should return the status code" do agent.receive events expect(agent.the_created_events[0][:payload]['status']).to eq('500') end it "should remember the status" do agent.receive events expect(agent.memory['last_status']).to eq('500') end end it "should return the original url" do agent.receive events expect(agent.the_created_events[0][:payload]['url']).to eq(successful_url) end it "should return the final url" do agent.receive events expect(agent.the_created_events[0][:payload]['final_url']).to eq(successful_url) end it "should return whether the url redirected" do agent.receive events expect(agent.the_created_events[0][:payload]['redirected']).to eq(false) end describe "but the ping returns a status code of 0" do let(:event_with_a_successful_ping) do agent.faraday.set(successful_url, MockResponse.new(0, {}, successful_url)) Event.new.tap { |e| e.payload = { url: successful_url, headers_to_save: "" } } end it "should create one event" do agent.receive events expect(agent.the_created_events.count).to eq(1) end it "should note that no response was received" do agent.receive events expect(agent.the_created_events[0][:payload]['response_received']).to eq(false) end it "should return the original url" do agent.receive events expect(agent.the_created_events[0][:payload]['url']).to eq(successful_url) end it "should remember no status" do agent.memory['last_status'] = '200' agent.receive events expect(agent.memory['last_status']).to be_nil end end describe "but the ping returns a status code of -1" do let(:event_with_a_successful_ping) do agent.faraday.set(successful_url, MockResponse.new(-1, {}, successful_url)) Event.new.tap { |e| e.payload = { url: successful_url, headers_to_save: "" } } end it "should create one event" do agent.receive events expect(agent.the_created_events.count).to eq(1) end it "should note that no response was received" do agent.receive events expect(agent.the_created_events[0][:payload]['response_received']).to eq(false) end it "should return the original url" do agent.receive events expect(agent.the_created_events[0][:payload]['url']).to eq(successful_url) end end describe "and with one event with a failing ping" do let(:failing_url) { SecureRandom.uuid } let(:event_with_a_failing_ping) { Event.new.tap { |e| e.payload = { url: failing_url, headers_to_save: "" } } } let(:events) do [event_with_a_successful_ping, event_with_a_failing_ping] end it "should create two events" do agent.receive events expect(agent.the_created_events.count).to eq(2) end it "should note that the failed response failed" do agent.receive events expect(agent.the_created_events[1][:payload]['response_received']).to eq(false) end it "should note that the successful response succeeded" do agent.receive events expect(agent.the_created_events[0][:payload]['response_received']).to eq(true) end it "should return the original url on both events" do agent.receive events expect(agent.the_created_events[0][:payload]['url']).to eq(successful_url) expect(agent.the_created_events[1][:payload]['url']).to eq(failing_url) end it "should record the time spent waiting for the reply" do agent.receive events expect(agent.the_created_events[0][:payload]['elapsed_time']).not_to be_nil expect(agent.the_created_events[1][:payload]['elapsed_time']).not_to be_nil end end describe "with a header specified" do let(:event_with_a_successful_ping) do agent.faraday.set(successful_url, MockResponse.new(status_code, {header => header_value}, successful_url)) Event.new.tap { |e| e.payload = { url: successful_url, headers_to_save: header } } end it "should return the header value" do agent.receive events expect(agent.the_created_events[0][:payload]['headers']).not_to be_nil expect(agent.the_created_events[0][:payload]['headers'][header]).to eq(header_value) end end describe "with existing and non-existing headers specified" do let(:nonexistant_header) { SecureRandom.uuid } let(:event_with_a_successful_ping) do agent.faraday.set(successful_url, MockResponse.new(status_code, {header => header_value}, successful_url)) Event.new.tap { |e| e.payload = { url: successful_url, headers_to_save: header + "," + nonexistant_header } } end it "should return the existing header's value" do agent.receive events expect(agent.the_created_events[0][:payload]['headers'][header]).to eq(header_value) end it "should return nil for the nonexistant header" do agent.receive events expect(agent.the_created_events[0][:payload]['headers'][nonexistant_header]).to be_nil end end end describe "validations" do before do expect(agent).to be_valid end it "should validate url" do agent.options['url'] = "" expect(agent).not_to be_valid agent.options['url'] = "http://www.google.com" expect(agent).to be_valid end end end end