push
travis-ci
2 of 2 new or added lines in 1 file covered. (100.0%)
4212 existing lines in 143 files now uncovered.2654 of 7765 relevant lines covered (34.18%)
4.51 hits per line
UNCOV
1
|
class AgentReceiveJob < ActiveJob::Base |
× |
UNCOV
2
|
# Given an Agent id and an array of Event ids, load the Agent, call #receive on it with the Event objects, and then
|
× |
UNCOV
3
|
# save it with an updated `last_receive_at` timestamp.
|
× |
UNCOV
4
|
def perform(agent_id, event_ids) |
× |
UNCOV
5
|
agent = Agent.find(agent_id)
|
× |
UNCOV
6
|
begin
|
× |
UNCOV
7
|
return if agent.unavailable? |
× |
UNCOV
8
|
agent.receive(Event.where(:id => event_ids).order(:id)) |
× |
UNCOV
9
|
agent.last_receive_at = Time.now
|
× |
UNCOV
10
|
agent.save! |
× |
UNCOV
11
|
rescue => e
|
× |
UNCOV
12
|
agent.error "Exception during receive. #{e.message}: #{e.backtrace.join("\n")}"
|
× |
UNCOV
13
|
raise |
× |
UNCOV
14
|
end
|
× |
UNCOV
15
|
end
|
× |
UNCOV
16
|
end
|
× |