+      expect { delete :destroy, params: {id: @not_running.id} }.to change(Delayed::Job, :count).by(-1)

+      expect { delete :destroy, params: {id: @running.id} }.to change(Delayed::Job, :count).by(0)

+      expect { put :run, params: {id: @not_running.id} }.to change { @not_running.reload.run_at }

+      expect { put :run, params: {id: @failed.id} }.to change { @failed.reload.run_at }

+      expect { put :run, params: {id: @running.id} }.not_to change { @not_running.reload.run_at }

+      get :index, params: {:agent_id => agents(:bob_weather_agent).id}

+        get :index, params: {:agent_id => agents(:jane_weather_agent).id}

+        delete :clear, params: {:agent_id => agents(:bob_weather_agent).id}

+        delete :clear, params: {:agent_id => agents(:jane_weather_agent).id}

+      request.env["omniauth.auth"] = JSON.parse(File.read(Rails.root.join('spec/data_fixtures/services/twitter.json')))

+  end

+  describe "handling a provider with non-standard omniauth options" do

+    it "should update the user's credentials" do

+      request.env["omniauth.auth"] = JSON.parse(File.read(Rails.root.join('spec/data_fixtures/services/37signals.json')))

+      expect {

+        get "37signals"

+      }.to change { users(:bob).services.count }.by(1)

+    end

+      post :create, params: {:scenario_import => { :url => "bad url" }}

+      get :show, params: {:id => scenarios(:bob_weather).to_param}

+        get :show, params: {:id => scenarios(:jane_weather).to_param}

+      get :show, params: {:id => scenarios(:bob_weather).to_param}

+      get :share, params: {:id => scenarios(:bob_weather).to_param}

+        get :share, params: {:id => scenarios(:jane_weather).to_param}

+      get :export, params: {:id => scenarios(:bob_weather).to_param}

+      get :export, params: {:id => scenarios(:bob_weather).to_param}

+        get :export, params: {:id => scenarios(:jane_weather).to_param}

+        get :export, params: {:id => scenarios(:jane_weather).to_param}

+        get :export, params: {:id => scenarios(:jane_weather).to_param}

+      get :edit, params: {:id => scenarios(:bob_weather).to_param}

+        get :edit, params: {:id => scenarios(:jane_weather).to_param}

+        post :create, params: {:scenario => valid_attributes}

+        post :create, params: {:scenario => valid_attributes(:name => "")}

+        post :create, params: {:scenario => valid_attributes(:user_id => users(:jane).id)}

+      }.to raise_error(ActionController::UnpermittedParameters)

+      post :update, params: {:id => scenarios(:bob_weather).to_param, :scenario => { :name => "new_name", :public => "1" }}

+        post :update, params: {:id => scenarios(:jane_weather).to_param, :scenario => { :name => "new_name" }}

+      post :update, params: {:id => scenarios(:bob_weather).to_param, :scenario => { :name => "" }}

+

+    it 'adds an agent to the scenario' do

+      expect {

+        post :update, params: {:id => scenarios(:bob_weather).to_param, :scenario => { :name => "new_name", :public => "1", agent_ids: scenarios(:bob_weather).agent_ids + [agents(:bob_website_agent).id] }}

+      }.to change { scenarios(:bob_weather).reload.agent_ids.length }.by(1)

+    end

+      put :enable_or_disable_all_agents, params: @params

+        delete :destroy, params: {:id => scenarios(:bob_weather).to_param}

+        delete :destroy, params: {:id => scenarios(:jane_weather).to_param}

+        delete :destroy, params: {id: scenarios(:bob_weather).to_param, mode: 'all_agents'}

+      post :toggle_availability, params: {:id => services(:generic).to_param}

+        post :toggle_availability, params: {:id => services(:global).to_param}

+        delete :destroy, params: {:id => services(:generic).to_param}

+        delete :destroy, params: {:id => services(:global).to_param}

+      get :edit, params: {:id => user_credentials(:bob_aws_secret).to_param}

+        get :edit, params: {:id => user_credentials(:jane_aws_secret).to_param}

+      post :import, params: {:file => @file}

+      post :import, params: {:file => @file}

+      post :import, params: {:file => file1}

+        post :create, params: {:user_credential => valid_attributes}

+        post :create, params: {:user_credential => valid_attributes(:credential_name => "")}

+        post :create, params: {:user_credential => valid_attributes(:user_id => users(:jane).id)}

+      }.to raise_error(ActionController::UnpermittedParameters)

+      post :update, params: {:id => user_credentials(:bob_aws_key).to_param, :user_credential => { :credential_name => "new_name" }}

+        post :update, params: {:id => user_credentials(:jane_aws_key).to_param, :user_credential => { :credential_name => "new_name" }}

+      post :update, params: {:id => user_credentials(:bob_aws_key).to_param, :user_credential => { :credential_name => "" }}

+        delete :destroy, params: {:id => user_credentials(:bob_aws_key).to_param}

+        delete :destroy, params: {:id => user_credentials(:jane_aws_key).to_param}

+      before do

+        @request.env["devise.mapping"] = Devise.mappings[:user]

+      end

+

+          post :create, params: {

+            :user => {username: 'jdoe', email: 'jdoe@example.com',

+              password: 's3cr3t55', password_confirmation: 's3cr3t55', invitation_code: 'try-huginn'}

+          }

+          post :create, params: {:user => {}}

+        end

+

+        it 'does not allow to set the admin flag' do

+          expect { post :create, params: {:user => {admin: 'true'}} }.to raise_error(ActionController::UnpermittedParameters)

+    post :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => @agent.id, :secret => "my_secret", :key => "value", :another_key => "5"}

+    post :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => @agent.id, :secret => "my_secret", :key => "value", :another_key => "5"}

+    post :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => @agent.id, :secret => "not_my_secret", :no => "go"}

+    get :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => @agent.id, :secret => "my_secret", :key => "value", :another_key => "5"}

+    get :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => @agent.id, :secret => "my_secret", :key => "value", :another_key => "5"}, :format => :json

+    post :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => @agent.id, :secret => "my_secret", :key => "value", :another_key => "5"}, :format => :xml

+    put :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => @agent.id, :secret => "my_secret", :key => "value", :another_key => "5"}, :format => :atom

+    get :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => @agent.id, :secret => "my_secret", :key => "value", :another_key => "5"}

+    post :handle_request, params: {:user_id => users(:jane).to_param, :agent_id => @agent.id, :secret => "my_secret", :no => "go"}

+    post :handle_request, params: {:user_id => users(:bob).to_param, :agent_id => 454545, :secret => "my_secret", :no => "go"}

+      post :update_location, params: {user_id: users(:bob).to_param, secret: "my_secret", longitude: 123, latitude: 45, something: "else"}

+      post :update_location, params: {user_id: users(:bob).to_param, secret: "my_secret", longitude: 123, latitude: 45, something: "else"}

+      post :update_location, params: {user_id: "123", secret: "not_my_secret", longitude: 123, latitude: 45, something: "else"}

+        post :update_location, params: {user_id: users(:bob).to_param, secret: "my_secret2", longitude: 123, latitude: 45, something: "else"}

+            <enclosure url="http://c.1tw.org/images/2015/itsy.png" length="48249" type="image/png" />

+            <description>&lt;a href="http://showgoers.tv/" onmouseover="javascript:void(0)"&gt;Showgoers&lt;/a&gt;: &lt;blockquote&gt; &lt;p&gt;Showgoers is a Chrome browser extension to synchronize your Netflix player with someone else so that you can co-watch the same movie on different computers with no hassle. Syncing up your player is as easy as sharing a URL.&lt;/p&gt; &lt;/blockquote&gt;&lt;script&gt;some code&lt;/script&gt;</description>

+            <li><a href="http://[::1]/path[]?query[]=foo">brackets</a></li>

+</html>

+require 'rails_helper'

+

+describe "Dry running an Agent", js: true do

+  let(:agent)   { agents(:bob_website_agent) }

+  let(:formatting_agent) { agents(:bob_formatting_agent) }

+  let(:user)    { users(:bob) }

+  let(:emitter) { agents(:bob_weather_agent) }

+

+  before(:each) do

+    login_as(user)

+  end

+

+  def open_dry_run_modal(agent)

+    visit edit_agent_path(agent)

+    click_on("Dry Run")

+    expect(page).to have_text('Event to send')

+  end

+

+  context 'successful dry runs' do

+    before do

+      stub_request(:get, "http://xkcd.com/").

+        with(:headers => {'Accept-Encoding'=>'gzip,deflate', 'User-Agent'=>'Huginn - https://github.com/cantino/huginn'}).

+        to_return(:status => 200, :body => File.read(Rails.root.join("spec/data_fixtures/xkcd.html")), :headers => {})

+    end

+

+    it 'shows the dry run pop up without previous events and selects the events tab when a event was created' do

+      open_dry_run_modal(agent)

+      click_on("Dry Run")

+      expect(page).to have_text('Biologists play reverse')

+      expect(page).to have_selector(:css, 'li[role="presentation"].active a[href="#tabEvents"]')

+    end

+

+    it 'shows the dry run pop up with previous events and allows use previously received event' do

+      emitter.events << Event.new(payload: {url: "http://xkcd.com/"})

+      agent.sources << emitter

+      agent.options.merge!('url' => '', 'url_from_event' => '{{url}}')

+      agent.save!

+

+      open_dry_run_modal(agent)

+      find('.dry-run-event-sample').click

+      within(:css, '.modal .builder') do

+        expect(page).to have_text('http://xkcd.com/')

+      end

+      click_on("Dry Run")

+      expect(page).to have_text('Biologists play reverse')

+      expect(page).to have_selector(:css, 'li[role="presentation"].active a[href="#tabEvents"]')

+    end

+

+    it 'sends escape characters correctly to the backend' do

+      emitter.events << Event.new(payload: {data: "Line 1\nLine 2\nLine 3"})

+      formatting_agent.sources << emitter

+      formatting_agent.options.merge!('instructions' => {'data' => "{{data | newline_to_br | strip_newlines | split: '<br />' | join: ','}}"})

+      formatting_agent.save!

+

+      open_dry_run_modal(formatting_agent)

+      find('.dry-run-event-sample').click

+      within(:css, '.modal .builder') do

+        expect(page).to have_text('Line 1\nLine 2\nLine 3')

+      end

+      click_on("Dry Run")

+      expect(page).to have_text('Line 1,Line 2,Line 3')

+      expect(page).to have_selector(:css, 'li[role="presentation"].active a[href="#tabEvents"]')

+    end

+  end

+

+  it 'shows the dry run pop up without previous events and selects the log tab when no event was created' do

+    stub_request(:get, "http://xkcd.com/").

+      with(:headers => {'Accept-Encoding'=>'gzip,deflate', 'User-Agent'=>'Huginn - https://github.com/cantino/huginn'}).

+      to_return(:status => 200, :body => "", :headers => {})

+

+    open_dry_run_modal(agent)

+    click_on("Dry Run")

+    expect(page).to have_text('Dry Run started')

+    expect(page).to have_selector(:css, 'li[role="presentation"].active a[href="#tabLog"]')

+  end

+end

+require 'capybara_helper'

+

+describe "form configuring agents", js: true do

+  it 'completes fields with predefined array values' do

+    login_as(users(:bob))

+    visit edit_agent_path(agents(:bob_csv_agent))

+    check('Propagate immediately')

+    select2("serialize", from: "Mode")

+  end

+end

+require 'rails_helper'

+

+describe ScenarioImportsController do

+  let(:user) { users(:bob) }

+

+  before do

+    login_as(user)

+  end

+

+  it 'renders the import form' do

+    visit new_scenario_imports_path

+    expect(page).to have_text('Import a Public Scenario')

+  end

+

+  it 'requires a URL or file uplaod' do

+    visit new_scenario_imports_path

+    click_on 'Start Import'

+    expect(page).to have_text('Please provide either a Scenario JSON File or a Public Scenario URL.')

+  end

+

+  it 'imports a scenario that does not exist yet' do

+    visit new_scenario_imports_path

+    attach_file('Option 2: Upload a Scenario JSON File', File.join(Rails.root, 'data/default_scenario.json'))

+    click_on 'Start Import'

+    expect(page).to have_text('This scenario has a few agents to get you started. Feel free to change them or delete them as you see fit!')

+    expect(page).not_to have_text('This Scenario already exists in your system.')

+    check('I confirm that I want to import these Agents.')

+    click_on 'Finish Import'

+    expect(page).to have_text('Import successful!')

+  end

+

+  it 'asks to accept conflicts when the scenario was modified' do

+    DefaultScenarioImporter.seed(user)

+    agent = user.agents.where(name: 'Rain Notifier').first

+    agent.options['expected_receive_period_in_days'] = 9001

+    agent.save!

+    visit new_scenario_imports_path

+    attach_file('Option 2: Upload a Scenario JSON File', File.join(Rails.root, 'data/default_scenario.json'))

+    click_on 'Start Import'

+    expect(page).to have_text('This Scenario already exists in your system.')

+    expect(page).to have_text('9001')

+    check('I confirm that I want to import these Agents.')

+    click_on 'Finish Import'

+    expect(page).to have_text('Import successful!')

+  end

+end

+require 'capybara_helper'

+

+describe "handling undefined agents" do

+  before do

+    login_as(users(:bob))

+    agent = agents(:bob_website_agent)

+    agent.update_attribute(:type, 'Agents::UndefinedAgent')

+  end

+

+  it 'renders the error page' do

+    visit agents_path

+    expect(page).to have_text("Error: Agent(s) are 'missing in action'")

+    expect(page).to have_text('Undefined Agent')

+  end

+

+  it 'deletes all undefined agents' do

+    visit agents_path

+    click_on('Delete Missing Agents')

+    expect(page).to have_text('Your Agents')

+  end

+end

+bob_formatting_agent:

+  type: Agents::EventFormattingAgent

+  user: bob

+  name: "Formatting Agent"

+  guid: <%= SecureRandom.hex %>

+  keep_events_for: <%= 45.days %>

+  options: <%= { instructions: {}, mode: 'clean' }.to_json.inspect %>

+

+  name: "bob basecamp agent"

+  options: <%= {

+      :project_id => "12345",

+    }.to_json.inspect %>

+

+bob_csv_agent:

+  type: Agents::CsvAgent

+  user: bob

+  name: "Bob's CsvAgent"

+  guid: <%= SecureRandom.hex %>

+  name: "jane basecamp agent"

+  options: <%= {

+      :project_id => "12345",

+    }.to_json.inspect %>

+      expect { @checker.send_notification({}) }.to raise_error(StandardError, /Invalid response from Boxcar:/)

+      stub(HTTParty).post { {"Response" => "Not authorized"} }

+      expect { @checker.send_notification({}) }.to raise_error(StandardError, /Not authorized/)

+      stub(HTTParty).post { {"error" => {"message" => "Sample error"}} }

+      expect { @checker.send_notification({}) }.to raise_error(StandardError, /Sample error/)

+          "hovertext" => "A small text"

+            <description>Secret hovertext: A small text</description>

+              'description' => 'Secret hovertext: A small text',

+      context 'with more events' do

+        let!(:event4) do

+          agents(:bob_website_agent).create_event payload: {

+            'site_title' => 'XKCD',

+            'url' => 'http://imgs.xkcd.com/comics/comic1.png',

+            'title' => 'Comic 1',

+            'date' => '',

+            'hovertext' => 'Hovertext for Comic 1'

+          }

+        end

+

+        let!(:event5) do

+          agents(:bob_website_agent).create_event payload: {

+            'site_title' => 'XKCD',

+            'url' => 'http://imgs.xkcd.com/comics/comic2.png',

+            'title' => 'Comic 2',

+            'date' => '',

+            'hovertext' => 'Hovertext for Comic 2'

+          }

+        end

+

+        let!(:event6) do

+          agents(:bob_website_agent).create_event payload: {

+            'site_title' => 'XKCD',

+            'url' => 'http://imgs.xkcd.com/comics/comic3.png',

+            'title' => 'Comic 3',

+            'date' => '',

+            'hovertext' => 'Hovertext for Comic 3'

+          }

+        end

+

+        describe 'limiting' do

+          it 'can select the last `events_to_show` events' do

+            agent.options['events_to_show'] = 2

+            content, _status, _content_type = agent.receive_web_request({ 'secret' => 'secret2' }, 'get', 'application/json')

+            expect(content['items'].map {|i| i["title"] }).to eq(["Comic 3", "Comic 2"])

+          end

+        end

+      end

+

+          agent.options['events_order'] = ['{{hovertext}}']

+          agent.options['events_list_order'] = ['{{title}}']

+        it 'can reorder the last `events_to_show` events based on a Liquid expression' do

+          agent.options['events_to_show'] = 2

+          asc_content, _status, _content_type = agent.receive_web_request({ 'secret' => 'secret2' }, 'get', 'application/json')

+          expect(asc_content['items'].map {|i| i["title"] }).to eq(["Evolving", "Evolving again"])

+

+          agent.options['events_to_show'] = 40

+          agent.options['events_list_order'] = [['{{title}}', 'string', true]]

+    @checker = Agents::EmailDigestAgent.new(:name => "something", :options => {:expected_receive_period_in_days => "2", :subject => "something interesting"})

+    @checker1 = Agents::EmailDigestAgent.new(:name => "something", :options => {:expected_receive_period_in_days => "2", :subject => "something interesting", :content_type => "text/plain"})

+      event1.payload = {:data => "Something you should know about"}

+      event2.payload = {:data => "Something else you should know about"}

+      expect(@checker.reload.memory['events']).to match([event1.id, event2.id])

+      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(@checker.reload.memory[:events]).to be_empty

+      expect(@checker.reload.memory[:events]).not_to be_empty

+      expect(@checker.reload.memory[:events]).to be_empty

+

+      @checker1.memory[:events] = [1, 2, 3, 4]

+  it_behaves_like 'FileHandlingConsumer'

+

+  it 'renders the description markdown without errors' do

+    expect { @checker.description }.not_to raise_error

+  end

+

+    it 'makes a multipart request when receiving a file_pointer' do

+      WebMock.reset!

+      stub_request(:post, "http://www.example.com/").

+        with(:body => "-------------RubyMultipartPost\r\nContent-Disposition: form-data; name=\"default\"\r\n\r\nvalue\r\n-------------RubyMultipartPost\r\nContent-Disposition: form-data; name=\"file\"; filename=\"local.path\"\r\nContent-Length: 8\r\nContent-Type: \r\nContent-Transfer-Encoding: binary\r\n\r\ntestdata\r\n-------------RubyMultipartPost--\r\n\r\n",

+             :headers => {'Accept-Encoding'=>'gzip,deflate', 'Content-Length'=>'307', 'Content-Type'=>'multipart/form-data; boundary=-----------RubyMultipartPost', 'User-Agent'=>'Huginn - https://github.com/cantino/huginn'}).

+        to_return(:status => 200, :body => "", :headers => {})

+      event = Event.new(payload: {file_pointer: {agent_id: 111, file: 'test'}})

+      io_mock = mock()

+      mock(@checker).get_io(event) { StringIO.new("testdata") }

+      @checker.options['no_merge'] = true

+      @checker.receive([event])

+    end

+    @checker = Agents::PushoverAgent.new(name: 'Some Name',

+                                         options: {

+                                           token: 'x',

+                                           user: 'x',

+                                           message: "{{ message | default: text | default: 'Some Message' }}",

+                                           device: "{{ device | default: 'Some Device' }}",

+                                           title: "{{ title | default: 'Some Message Title' }}",

+                                           url: "{{ url | default: 'http://someurl.com' }}",

+                                           url_title: "{{ url_title | default: 'Some Url Title' }}",

+                                           priority: "{{ priority | default: 0 }}",

+                                           timestamp: "{{ timestamp | default: 'false' }}",

+                                           sound: "{{ sound | default: 'pushover' }}",

+                                           retry: "{{ retry | default: 0 }}",

+                                           expire: "{{ expire | default: 0 }}",

+                                           expected_receive_period_in_days: '1'

+                                         })

+