| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879 |
- require 'spec_helper'
- describe Agents::EmailAgent 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::EmailAgent.new(:name => "something", :options => { :expected_receive_period_in_days => "2", :subject => "something interesting" })
- @checker.user = users(:bob)
- @checker.save!
- expect(ActionMailer::Base.deliveries).to eq([])
- end
- after do
- ActionMailer::Base.deliveries = []
- end
- describe "#receive" do
- it "immediately sends any payloads it receives" do
- event1 = Event.new
- event1.agent = agents(:bob_rain_notifier_agent)
- event1.payload = { :message => "hi!", :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::EmailAgent.async_receive(@checker.id, [event1.id])
- Agents::EmailAgent.async_receive(@checker.id, [event2.id])
- expect(ActionMailer::Base.deliveries.count).to eq(2)
- 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 else you should know about")
- expect(get_message_part(ActionMailer::Base.deliveries.first, /plain/).strip).to eq("hi!\n data: Something you should know about")
- 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!
- 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/)
- end
- it "can take body option for selecting the resulting email's body" do
- @checker.update_attributes :options => @checker.options.merge({
- 'subject' => '{{foo.subject}}',
- 'body' => '{{some_html}}'
- })
- event = Event.new
- event.agent = agents(:bob_rain_notifier_agent)
- event.payload = { :foo => { :subject => "Something you should know about" }, :some_html => "<strong>rain!</strong>" }
- event.save!
- Agents::EmailAgent.async_receive(@checker.id, [event.id])
- expect(ActionMailer::Base.deliveries.count).to eq(1)
- expect(ActionMailer::Base.deliveries.last.to).to eq(["bob@example.com"])
- expect(ActionMailer::Base.deliveries.last.subject).to eq("Something you should know about")
- expect(get_message_part(ActionMailer::Base.deliveries.last, /plain/).strip).to match(/\A\s*<strong>rain\!<\/strong>\s*\z/)
- expect(get_message_part(ActionMailer::Base.deliveries.last, /html/).strip).to match(/<body>\s*<strong>rain\!<\/strong>\s*<\/body>/)
- end
- end
- end
|
