GitHub-Mirror/huginn
2
0
Fork 0
mirror of https://github.com/Fishwaldo/huginn.git synced 2025-03-15 19:31:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #1890 from dsander/order-stream-agents

Browse source 
Order TwitterStreamAgents in setup_workers
This commit is contained in:
Dominik Sander 2017-02-01 21:44:20 +01:00 • committed by GitHub
commit 0fccdc8471
2 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/models/agents/twitter_stream_agent.rb
View file

@ -125,7 +125,7 @@ module Agents
end
def self.setup_worker
Agents::TwitterStreamAgent.active.group_by { |agent| agent.twitter_oauth_token }.map do |oauth_token, agents|
Agents::TwitterStreamAgent.active.order(:id).group_by { |agent| agent.twitter_oauth_token }.map do |oauth_token, agents|
if Agents::TwitterStreamAgent.dependencies_missing?
STDERR.puts Agents::TwitterStreamAgent.twitter_dependencies_missing
STDERR.flush

9
spec/models/agents/twitter_stream_agent_spec.rb
View file

@ -134,12 +134,13 @@ describe Agents::TwitterStreamAgent do
end
it "returns now workers if no agent is active" do
mock(Agents::TwitterStreamAgent).active { [] }
@agent.destroy
expect(Agents::TwitterStreamAgent.active).to be_empty
expect(Agents::TwitterStreamAgent.setup_worker).to eq([])
end
it "returns a worker for an active agent" do
mock(Agents::TwitterStreamAgent).active { [@agent] }
expect(Agents::TwitterStreamAgent.active).to eq([@agent])
workers = Agents::TwitterStreamAgent.setup_worker
expect(workers).to be_a(Array)
expect(workers.length).to eq(1)
@ -151,9 +152,9 @@ describe Agents::TwitterStreamAgent do
it "correctly maps keywords to agents" do
agent2 = @agent.dup
agent2.id = 123455
agent2.options[:filters] = ['agent2']
mock(Agents::TwitterStreamAgent).active { [@agent, agent2] }
agent2.save!
expect(Agents::TwitterStreamAgent.active.order(:id).pluck(:id)).to eq([@agent.id, agent2.id])
workers = Agents::TwitterStreamAgent.setup_worker
filter_to_agent_map = workers.first.config[:filter_to_agent_map]