Keine Beschreibung http://j1x-huginn.herokuapp.com

email_digest_agent_spec.rb 4.2KB

    require 'rails_helper' describe Agents::EmailDigestAgent do it_behaves_like EmailConcern def get_message_part(mail, content_type) mail.body.parts.find { |p| p.content_type.match content_type }.body.raw_source end before do @checker = Agents::EmailDigestAgent.new(:name => "something", :options => {:expected_receive_period_in_days => "2", :subject => "something interesting"}) @checker.user = users(:bob) @checker.save! @checker1 = Agents::EmailDigestAgent.new(:name => "something", :options => {:expected_receive_period_in_days => "2", :subject => "something interesting", :content_type => "text/plain"}) @checker1.user = users(:bob) @checker1.save! end after do ActionMailer::Base.deliveries = [] end describe "#receive" do it "queues any payloads it receives" do event1 = Event.new event1.agent = agents(:bob_rain_notifier_agent) event1.payload = {:data => "Something you should know about"} event1.save! event2 = Event.new event2.agent = agents(:bob_weather_agent) event2.payload = {:data => "Something else you should know about"} event2.save! Agents::EmailDigestAgent.async_receive(@checker.id, [event1.id, event2.id]) expect(@checker.reload.memory['events']).to match([event1.id, event2.id]) end end describe "#check" do it "should send an email" do Agents::EmailDigestAgent.async_check(@checker.id) expect(ActionMailer::Base.deliveries).to eq([]) payloads = [ {:data => "Something you should know about"}, {:title => "Foo", :url => "http://google.com", :bar => 2}, {"message" => "hi", :woah => "there"}, {"test" => 2} ] events = payloads.map do |payload| Event.new.tap do |event| event.agent = agents(:bob_weather_agent) event.payload = payload event.save! end end Agents::DigestAgent.async_receive(@checker.id, events.map(&:id)) @checker.sources << agents(:bob_weather_agent) Agents::DigestAgent.async_check(@checker.id) expect(ActionMailer::Base.deliveries.last.to).to eq(["bob@example.com"]) expect(ActionMailer::Base.deliveries.last.subject).to eq("something interesting") expect(get_message_part(ActionMailer::Base.deliveries.last, /plain/).strip).to eq("Event\n data: Something you should know about\n\nFoo\n bar: 2\n url: http://google.com\n\nhi\n woah: there\n\nEvent\n test: 2") expect(@checker.reload.memory[:events]).to be_empty end it "logs and re-raises mailer errors" do mock(SystemMailer).send_message(anything) { raise Net::SMTPAuthenticationError.new("Wrong password") } @checker.memory[:events] = [1] @checker.save! expect { Agents::EmailDigestAgent.async_check(@checker.id) }.to raise_error(/Wrong password/) expect(@checker.reload.memory[:events]).not_to be_empty expect(@checker.logs.last.message).to match(/Error sending digest mail .* Wrong password/) end it "can receive complex events and send them on" do stub_request(:any, /wunderground/).to_return(:body => File.read(Rails.root.join("spec/data_fixtures/weather.json")), :status => 200) stub.any_instance_of(Agents::WeatherAgent).is_tomorrow?(anything) { true } @checker.sources << agents(:bob_weather_agent) Agent.async_check(agents(:bob_weather_agent).id) Agent.receive! expect(@checker.reload.memory[:events]).not_to be_empty Agents::EmailDigestAgent.async_check(@checker.id) plain_email_text = get_message_part(ActionMailer::Base.deliveries.last, /plain/).strip html_email_text = get_message_part(ActionMailer::Base.deliveries.last, /html/).strip expect(plain_email_text).to match(/avehumidity/) expect(html_email_text).to match(/avehumidity/) expect(@checker.reload.memory[:events]).to be_empty end it "should send email with correct content type" do Agents::EmailDigestAgent.async_check(@checker1.id) expect(ActionMailer::Base.deliveries).to eq([]) @checker1.memory[:events] = [1, 2, 3, 4] @checker1.save! Agents::EmailDigestAgent.async_check(@checker1.id) expect(ActionMailer::Base.deliveries.last.content_type).to eq("text/plain; charset=UTF-8") end end end