|
@@ -33,7 +33,7 @@ describe Agent do
|
|
|
|
|
|
describe ".bulk_check" do
|
|
|
before do
|
|
|
- @weather_agent_count = Agents::WeatherAgent.where(:schedule => "midnight", :disabled => false).count
|
|
|
+ @weather_agent_count = Agents::WeatherAgent.where(schedule: "midnight", disabled: false).count
|
|
|
end
|
|
|
|
|
|
it "should run all Agents with the given schedule" do
|
|
@@ -142,7 +142,7 @@ describe Agent do
|
|
|
default_schedule "2pm"
|
|
|
|
|
|
def check
|
|
|
- create_event :payload => {}
|
|
|
+ create_event payload: {}
|
|
|
end
|
|
|
|
|
|
def validate_options
|
|
@@ -154,8 +154,8 @@ describe Agent do
|
|
|
cannot_be_scheduled!
|
|
|
|
|
|
def receive(events)
|
|
|
- events.each do |event|
|
|
|
- create_event :payload => { :events_received => 1 }
|
|
|
+ events.each do |_event|
|
|
|
+ create_event payload: { events_received: 1 }
|
|
|
end
|
|
|
end
|
|
|
end
|
|
@@ -167,7 +167,7 @@ describe Agent do
|
|
|
|
|
|
describe Agents::SomethingSource do
|
|
|
let(:new_instance) do
|
|
|
- agent = Agents::SomethingSource.new(:name => "some agent")
|
|
|
+ agent = Agents::SomethingSource.new(name: "some agent")
|
|
|
agent.user = users(:bob)
|
|
|
agent
|
|
|
end
|
|
@@ -190,7 +190,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "sets the default on new instances, allows setting new schedules, and prevents invalid schedules" do
|
|
|
- @checker = Agents::SomethingSource.new(:name => "something")
|
|
|
+ @checker = Agents::SomethingSource.new(name: "something")
|
|
|
@checker.user = users(:bob)
|
|
|
expect(@checker.schedule).to eq("2pm")
|
|
|
@checker.save!
|
|
@@ -205,7 +205,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "should have an empty schedule if it cannot_be_scheduled" do
|
|
|
- @checker = Agents::CannotBeScheduled.new(:name => "something")
|
|
|
+ @checker = Agents::CannotBeScheduled.new(name: "something")
|
|
|
@checker.user = users(:bob)
|
|
|
expect(@checker.schedule).to be_nil
|
|
|
expect(@checker).to be_valid
|
|
@@ -221,7 +221,7 @@ describe Agent do
|
|
|
|
|
|
describe "#create_event" do
|
|
|
before do
|
|
|
- @checker = Agents::SomethingSource.new(:name => "something")
|
|
|
+ @checker = Agents::SomethingSource.new(name: "something")
|
|
|
@checker.user = users(:bob)
|
|
|
@checker.save!
|
|
|
end
|
|
@@ -242,7 +242,7 @@ describe Agent do
|
|
|
|
|
|
describe ".async_check" do
|
|
|
before do
|
|
|
- @checker = Agents::SomethingSource.new(:name => "something")
|
|
|
+ @checker = Agents::SomethingSource.new(name: "something")
|
|
|
@checker.user = users(:bob)
|
|
|
@checker.save!
|
|
|
end
|
|
@@ -283,7 +283,8 @@ describe Agent do
|
|
|
|
|
|
describe ".receive!" do
|
|
|
before do
|
|
|
- stub_request(:any, /darksky/).to_return(:body => File.read(Rails.root.join("spec/data_fixtures/weather.json")), :status => 200)
|
|
|
+ stub_request(:any, /darksky/).to_return(body: File.read(Rails.root.join("spec/data_fixtures/weather.json")),
|
|
|
+ status: 200)
|
|
|
end
|
|
|
|
|
|
it "should use available events" do
|
|
@@ -360,7 +361,7 @@ describe Agent do
|
|
|
|
|
|
it "should group events" do
|
|
|
count = 0
|
|
|
- allow_any_instance_of(Agents::TriggerAgent).to receive(:receive) { |agent, events|
|
|
|
+ allow_any_instance_of(Agents::TriggerAgent).to receive(:receive) { |_agent, events|
|
|
|
count += 1
|
|
|
expect(events.map(&:user).map(&:username).uniq.length).to eq(1)
|
|
|
}
|
|
@@ -381,7 +382,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "should ignore events that were created before a particular Link" do
|
|
|
- agent2 = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent2 = Agents::SomethingSource.new(name: "something")
|
|
|
agent2.user = users(:bob)
|
|
|
agent2.save!
|
|
|
agent2.check
|
|
@@ -436,14 +437,14 @@ describe Agent do
|
|
|
describe "creating a new agent and then calling .receive!" do
|
|
|
it "should not backfill events for a newly created agent" do
|
|
|
Event.delete_all
|
|
|
- sender = Agents::SomethingSource.new(:name => "Sending Agent")
|
|
|
+ sender = Agents::SomethingSource.new(name: "Sending Agent")
|
|
|
sender.user = users(:bob)
|
|
|
sender.save!
|
|
|
- sender.create_event :payload => {}
|
|
|
- sender.create_event :payload => {}
|
|
|
+ sender.create_event payload: {}
|
|
|
+ sender.create_event payload: {}
|
|
|
expect(sender.events.count).to eq(2)
|
|
|
|
|
|
- receiver = Agents::CannotBeScheduled.new(:name => "Receiving Agent")
|
|
|
+ receiver = Agents::CannotBeScheduled.new(name: "Receiving Agent")
|
|
|
receiver.user = users(:bob)
|
|
|
receiver.sources << sender
|
|
|
receiver.save!
|
|
@@ -451,7 +452,7 @@ describe Agent do
|
|
|
expect(receiver.events.count).to eq(0)
|
|
|
Agent.receive!
|
|
|
expect(receiver.events.count).to eq(0)
|
|
|
- sender.create_event :payload => {}
|
|
|
+ sender.create_event payload: {}
|
|
|
Agent.receive!
|
|
|
expect(receiver.events.count).to eq(1)
|
|
|
end
|
|
@@ -460,32 +461,32 @@ describe Agent do
|
|
|
describe "creating agents with propagate_immediately = true" do
|
|
|
it "should schedule subagent events immediately" do
|
|
|
Event.delete_all
|
|
|
- sender = Agents::SomethingSource.new(:name => "Sending Agent")
|
|
|
+ sender = Agents::SomethingSource.new(name: "Sending Agent")
|
|
|
sender.user = users(:bob)
|
|
|
sender.save!
|
|
|
|
|
|
receiver = Agents::CannotBeScheduled.new(
|
|
|
- :name => "Receiving Agent",
|
|
|
+ name: "Receiving Agent",
|
|
|
)
|
|
|
receiver.propagate_immediately = true
|
|
|
receiver.user = users(:bob)
|
|
|
receiver.sources << sender
|
|
|
receiver.save!
|
|
|
|
|
|
- sender.create_event :payload => {"message" => "new payload"}
|
|
|
+ sender.create_event payload: { "message" => "new payload" }
|
|
|
expect(sender.events.count).to eq(1)
|
|
|
expect(receiver.events.count).to eq(1)
|
|
|
- #should be true without calling Agent.receive!
|
|
|
+ # should be true without calling Agent.receive!
|
|
|
end
|
|
|
|
|
|
it "should only schedule receiving agents that are set to propagate_immediately" do
|
|
|
Event.delete_all
|
|
|
- sender = Agents::SomethingSource.new(:name => "Sending Agent")
|
|
|
+ sender = Agents::SomethingSource.new(name: "Sending Agent")
|
|
|
sender.user = users(:bob)
|
|
|
sender.save!
|
|
|
|
|
|
im_receiver = Agents::CannotBeScheduled.new(
|
|
|
- :name => "Immediate Receiving Agent",
|
|
|
+ name: "Immediate Receiving Agent",
|
|
|
)
|
|
|
im_receiver.propagate_immediately = true
|
|
|
im_receiver.user = users(:bob)
|
|
@@ -493,20 +494,20 @@ describe Agent do
|
|
|
|
|
|
im_receiver.save!
|
|
|
slow_receiver = Agents::CannotBeScheduled.new(
|
|
|
- :name => "Slow Receiving Agent",
|
|
|
+ name: "Slow Receiving Agent",
|
|
|
)
|
|
|
slow_receiver.user = users(:bob)
|
|
|
slow_receiver.sources << sender
|
|
|
slow_receiver.save!
|
|
|
|
|
|
- sender.create_event :payload => {"message" => "new payload"}
|
|
|
+ sender.create_event payload: { "message" => "new payload" }
|
|
|
expect(sender.events.count).to eq(1)
|
|
|
expect(im_receiver.events.count).to eq(1)
|
|
|
- #we should get the quick one
|
|
|
- #but not the slow one
|
|
|
+ # we should get the quick one
|
|
|
+ # but not the slow one
|
|
|
expect(slow_receiver.events.count).to eq(0)
|
|
|
Agent.receive!
|
|
|
- #now we should have one in both
|
|
|
+ # now we should have one in both
|
|
|
expect(im_receiver.events.count).to eq(1)
|
|
|
expect(slow_receiver.events.count).to eq(1)
|
|
|
end
|
|
@@ -514,7 +515,7 @@ describe Agent do
|
|
|
|
|
|
describe "validations" do
|
|
|
it "calls validate_options" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
agent.options[:bad] = true
|
|
|
expect(agent).to have(1).error_on(:base)
|
|
@@ -523,7 +524,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "makes options symbol-indifferent before validating" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
agent.options["bad"] = true
|
|
|
expect(agent).to have(1).error_on(:base)
|
|
@@ -532,7 +533,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "makes memory symbol-indifferent before validating" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
agent.memory["bad"] = 2
|
|
|
agent.save
|
|
@@ -540,7 +541,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "should work when assigned a hash or JSON string" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.memory = {}
|
|
|
expect(agent.memory).to eq({})
|
|
|
expect(agent.memory["foo"]).to be_nil
|
|
@@ -578,11 +579,11 @@ describe Agent do
|
|
|
agent.options = 5
|
|
|
expect(agent.options["hi"]).to eq(2)
|
|
|
expect(agent).to have(1).errors_on(:options)
|
|
|
- expect(agent.errors_on(:options)).to include("cannot be set to an instance of #{2.class}") # Integer (ruby >=2.4) or Fixnum (ruby <2.4)
|
|
|
+ expect(agent.errors_on(:options)).to include("cannot be set to an instance of #{2.class}") # Integer (ruby >=2.4) or Fixnum (ruby <2.4)
|
|
|
end
|
|
|
|
|
|
it "should not allow source agents owned by other people" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
agent.source_ids = [agents(:bob_weather_agent).id]
|
|
|
expect(agent).to have(0).errors_on(:sources)
|
|
@@ -593,7 +594,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "should not allow target agents owned by other people" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
agent.receiver_ids = [agents(:bob_weather_agent).id]
|
|
|
expect(agent).to have(0).errors_on(:receivers)
|
|
@@ -604,7 +605,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "should not allow controller agents owned by other people" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
agent.controller_ids = [agents(:bob_weather_agent).id]
|
|
|
expect(agent).to have(0).errors_on(:controllers)
|
|
@@ -615,7 +616,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "should not allow control target agents owned by other people" do
|
|
|
- agent = Agents::CannotBeScheduled.new(:name => "something")
|
|
|
+ agent = Agents::CannotBeScheduled.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
agent.control_target_ids = [agents(:bob_weather_agent).id]
|
|
|
expect(agent).to have(0).errors_on(:control_targets)
|
|
@@ -626,7 +627,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "should not allow scenarios owned by other people" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
|
|
|
agent.scenario_ids = [scenarios(:bob_weather).id]
|
|
@@ -643,7 +644,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "validates keep_events_for" do
|
|
|
- agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ agent = Agents::SomethingSource.new(name: "something")
|
|
|
agent.user = users(:bob)
|
|
|
expect(agent).to be_valid
|
|
|
agent.keep_events_for = nil
|
|
@@ -669,11 +670,11 @@ describe Agent do
|
|
|
before do
|
|
|
@time = "2014-01-01 01:00:00 +00:00"
|
|
|
travel_to @time do
|
|
|
- @agent = Agents::SomethingSource.new(:name => "something")
|
|
|
+ @agent = Agents::SomethingSource.new(name: "something")
|
|
|
@agent.keep_events_for = 5.days
|
|
|
@agent.user = users(:bob)
|
|
|
@agent.save!
|
|
|
- @event = @agent.create_event :payload => { "hello" => "world" }
|
|
|
+ @event = @agent.create_event payload: { "hello" => "world" }
|
|
|
expect(@event.expires_at.to_i).to be_within(2).of(5.days.from_now.to_i)
|
|
|
end
|
|
|
end
|
|
@@ -695,9 +696,9 @@ describe Agent do
|
|
|
it "updates events' expires_at" do
|
|
|
travel_to @time do
|
|
|
expect {
|
|
|
- @agent.options[:foo] = "bar1"
|
|
|
- @agent.keep_events_for = 3.days
|
|
|
- @agent.save!
|
|
|
+ @agent.options[:foo] = "bar1"
|
|
|
+ @agent.keep_events_for = 3.days
|
|
|
+ @agent.save!
|
|
|
}.to change { @event.reload.expires_at }
|
|
|
expect(@event.expires_at.to_i).to be_within(2).of(3.days.from_now.to_i)
|
|
|
end
|
|
@@ -731,18 +732,20 @@ describe Agent do
|
|
|
@sender = Agents::SomethingSource.new(
|
|
|
name: 'Agent (2)',
|
|
|
options: { foo: 'bar2' },
|
|
|
- schedule: '5pm')
|
|
|
+ schedule: '5pm'
|
|
|
+ )
|
|
|
@sender.user = users(:bob)
|
|
|
@sender.save!
|
|
|
- @sender.create_event :payload => {}
|
|
|
- @sender.create_event :payload => {}
|
|
|
+ @sender.create_event payload: {}
|
|
|
+ @sender.create_event payload: {}
|
|
|
expect(@sender.events.count).to eq(2)
|
|
|
|
|
|
@receiver = Agents::CannotBeScheduled.new(
|
|
|
name: 'Agent',
|
|
|
options: { foo: 'bar3' },
|
|
|
keep_events_for: 3.days,
|
|
|
- propagate_immediately: true)
|
|
|
+ propagate_immediately: true
|
|
|
+ )
|
|
|
@receiver.user = users(:bob)
|
|
|
@receiver.sources << @sender
|
|
|
@receiver.memory[:test] = 1
|
|
@@ -752,19 +755,19 @@ describe Agent do
|
|
|
it "should create a clone of a given agent for editing" do
|
|
|
sender_clone = users(:bob).agents.build_clone(@sender)
|
|
|
|
|
|
- expect(sender_clone.attributes).to eq(Agent.new.attributes.
|
|
|
- update(@sender.slice(:user_id, :type,
|
|
|
- :options, :schedule, :keep_events_for, :propagate_immediately)).
|
|
|
- update('name' => 'Agent (2) (2)', 'options' => { 'foo' => 'bar2' }))
|
|
|
+ expect(sender_clone.attributes).to eq(Agent.new.attributes
|
|
|
+ .update(@sender.slice(:user_id, :type,
|
|
|
+ :options, :schedule, :keep_events_for, :propagate_immediately))
|
|
|
+ .update('name' => 'Agent (2) (2)', 'options' => { 'foo' => 'bar2' }))
|
|
|
|
|
|
expect(sender_clone.source_ids).to eq([])
|
|
|
|
|
|
receiver_clone = users(:bob).agents.build_clone(@receiver)
|
|
|
|
|
|
- expect(receiver_clone.attributes).to eq(Agent.new.attributes.
|
|
|
- update(@receiver.slice(:user_id, :type,
|
|
|
- :options, :schedule, :keep_events_for, :propagate_immediately)).
|
|
|
- update('name' => 'Agent (3)', 'options' => { 'foo' => 'bar3' }))
|
|
|
+ expect(receiver_clone.attributes).to eq(Agent.new.attributes
|
|
|
+ .update(@receiver.slice(:user_id, :type,
|
|
|
+ :options, :schedule, :keep_events_for, :propagate_immediately))
|
|
|
+ .update('name' => 'Agent (3)', 'options' => { 'foo' => 'bar3' }))
|
|
|
|
|
|
expect(receiver_clone.source_ids).to eq([@sender.id])
|
|
|
end
|
|
@@ -782,7 +785,7 @@ describe Agent do
|
|
|
|
|
|
context "when .receive_web_request is defined" do
|
|
|
before do
|
|
|
- @agent = Agents::WebRequestReceiver.new(:name => "something")
|
|
|
+ @agent = Agents::WebRequestReceiver.new(name: "something")
|
|
|
@agent.user = users(:bob)
|
|
|
@agent.save!
|
|
|
|
|
@@ -794,46 +797,49 @@ describe Agent do
|
|
|
|
|
|
it "calls the .receive_web_request hook, updates last_web_request_at, and saves" do
|
|
|
request = ActionDispatch::Request.new({
|
|
|
- 'action_dispatch.request.request_parameters' => { :some_param => "some_value" },
|
|
|
+ 'action_dispatch.request.request_parameters' => { some_param: "some_value" },
|
|
|
'REQUEST_METHOD' => "POST",
|
|
|
'HTTP_ACCEPT' => 'text/html'
|
|
|
})
|
|
|
|
|
|
@agent.trigger_web_request(request)
|
|
|
- expect(@agent.reload.memory['last_request']).to eq([ { "some_param" => "some_value" }, "post", "text/html" ])
|
|
|
+ expect(@agent.reload.memory['last_request']).to eq([{ "some_param" => "some_value" }, "post", "text/html"])
|
|
|
expect(@agent.last_web_request_at.to_i).to be_within(1).of(Time.now.to_i)
|
|
|
end
|
|
|
end
|
|
|
|
|
|
context "when .receive_web_request is defined with just request" do
|
|
|
before do
|
|
|
- @agent = Agents::WebRequestReceiver.new(:name => "something")
|
|
|
+ @agent = Agents::WebRequestReceiver.new(name: "something")
|
|
|
@agent.user = users(:bob)
|
|
|
@agent.save!
|
|
|
|
|
|
def @agent.receive_web_request(request)
|
|
|
- memory['last_request'] = [request.params, request.method_symbol.to_s, request.format, {'HTTP_X_CUSTOM_HEADER' => request.headers['HTTP_X_CUSTOM_HEADER']}]
|
|
|
+ memory['last_request'] =
|
|
|
+ [request.params, request.method_symbol.to_s, request.format,
|
|
|
+ { 'HTTP_X_CUSTOM_HEADER' => request.headers['HTTP_X_CUSTOM_HEADER'] }]
|
|
|
['Ok!', 200]
|
|
|
end
|
|
|
end
|
|
|
|
|
|
it "calls the .trigger_web_request with headers, and they get passed to .receive_web_request" do
|
|
|
request = ActionDispatch::Request.new({
|
|
|
- 'action_dispatch.request.request_parameters' => { :some_param => "some_value" },
|
|
|
+ 'action_dispatch.request.request_parameters' => { some_param: "some_value" },
|
|
|
'REQUEST_METHOD' => "POST",
|
|
|
'HTTP_ACCEPT' => 'text/html',
|
|
|
'HTTP_X_CUSTOM_HEADER' => "foo"
|
|
|
})
|
|
|
|
|
|
@agent.trigger_web_request(request)
|
|
|
- expect(@agent.reload.memory['last_request']).to eq([ { "some_param" => "some_value" }, "post", "text/html", {'HTTP_X_CUSTOM_HEADER' => "foo"} ])
|
|
|
+ expect(@agent.reload.memory['last_request']).to eq([{ "some_param" => "some_value" }, "post", "text/html",
|
|
|
+ { 'HTTP_X_CUSTOM_HEADER' => "foo" }])
|
|
|
expect(@agent.last_web_request_at.to_i).to be_within(1).of(Time.now.to_i)
|
|
|
end
|
|
|
end
|
|
|
|
|
|
context "when .receive_webhook is defined" do
|
|
|
before do
|
|
|
- @agent = Agents::WebRequestReceiver.new(:name => "something")
|
|
|
+ @agent = Agents::WebRequestReceiver.new(name: "something")
|
|
|
@agent.user = users(:bob)
|
|
|
@agent.save!
|
|
|
|
|
@@ -845,7 +851,7 @@ describe Agent do
|
|
|
|
|
|
it "outputs a deprecation warning and calls .receive_webhook with the params" do
|
|
|
request = ActionDispatch::Request.new({
|
|
|
- 'action_dispatch.request.request_parameters' => { :some_param => "some_value" },
|
|
|
+ 'action_dispatch.request.request_parameters' => { some_param: "some_value" },
|
|
|
'REQUEST_METHOD' => "POST",
|
|
|
'HTTP_ACCEPT' => 'text/html'
|
|
|
})
|
|
@@ -890,7 +896,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "sets expires_at on created events" do
|
|
|
- event = agents(:jane_weather_agent).create_event :payload => { 'hi' => 'there' }
|
|
|
+ event = agents(:jane_weather_agent).create_event payload: { 'hi' => 'there' }
|
|
|
expect(event.expires_at.to_i).to be_within(5).of(agents(:jane_weather_agent).keep_events_for.seconds.from_now.to_i)
|
|
|
end
|
|
|
end
|
|
@@ -901,7 +907,7 @@ describe Agent do
|
|
|
end
|
|
|
|
|
|
it "does not set expires_at on created events" do
|
|
|
- event = agents(:jane_website_agent).create_event :payload => { 'hi' => 'there' }
|
|
|
+ event = agents(:jane_website_agent).create_event payload: { 'hi' => 'there' }
|
|
|
expect(event.expires_at).to be_nil
|
|
|
end
|
|
|
end
|
|
@@ -925,7 +931,8 @@ describe Agent do
|
|
|
|
|
|
describe ".drop_pending_events" do
|
|
|
before do
|
|
|
- stub_request(:any, /darksky/).to_return(body: File.read(Rails.root.join("spec/data_fixtures/weather.json")), status: 200)
|
|
|
+ stub_request(:any, /darksky/).to_return(body: File.read(Rails.root.join("spec/data_fixtures/weather.json")),
|
|
|
+ status: 200)
|
|
|
end
|
|
|
|
|
|
it "should drop pending events while the agent was disabled when set to true" do
|
|
@@ -979,7 +986,8 @@ describe AgentDrop do
|
|
|
},
|
|
|
},
|
|
|
schedule: 'every_1h',
|
|
|
- keep_events_for: 2.days)
|
|
|
+ keep_events_for: 2.days
|
|
|
+ )
|
|
|
@wsa1.user = users(:bob)
|
|
|
@wsa1.save!
|
|
|
|
|
@@ -996,7 +1004,8 @@ describe AgentDrop do
|
|
|
},
|
|
|
},
|
|
|
schedule: 'every_12h',
|
|
|
- keep_events_for: 2.days)
|
|
|
+ keep_events_for: 2.days
|
|
|
+ )
|
|
|
@wsa2.user = users(:bob)
|
|
|
@wsa2.save!
|
|
|
|
|
@@ -1012,7 +1021,8 @@ describe AgentDrop do
|
|
|
skip_created_at: 'false',
|
|
|
},
|
|
|
keep_events_for: 2.days,
|
|
|
- propagate_immediately: true)
|
|
|
+ propagate_immediately: true
|
|
|
+ )
|
|
|
@efa.user = users(:bob)
|
|
|
@efa.sources << @wsa1 << @wsa2
|
|
|
@efa.memory[:test] = 1
|
|
@@ -1039,7 +1049,7 @@ describe AgentDrop do
|
|
|
expect(interpolate(t, @wsa1)).to eq('http://xkcd.com/')
|
|
|
expect(interpolate(t, @wsa2)).to eq('http://dilbert.com/')
|
|
|
expect(interpolate('{{agent.options.instructions.message}}',
|
|
|
- @efa)).to eq('{{agent.name}}: {{title}} {{url}}')
|
|
|
+ @efa)).to eq('{{agent.name}}: {{title}} {{url}}')
|
|
|
end
|
|
|
|
|
|
it 'should have .sources' do
|