aboutsummaryrefslogtreecommitdiffstats
path: root/activejob/test/support/integration/adapters/sidekiq.rb
blob: 6ff18fb56aa7635b2ea22daee0a35b8b8f6dcad2 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
require 'sidekiq/cli'
require 'sidekiq/api'

module SidekiqJobsManager

  def setup
    ActiveJob::Base.queue_adapter = :sidekiq
    unless can_run?
      puts "Cannot run integration tests for sidekiq. To be able to run integration tests for sidekiq you need to install and start redis.\n"
      exit
    end
  end

  def clear_jobs
    Sidekiq::ScheduledSet.new.clear
    Sidekiq::Queue.new("integration_tests").clear
  end

  def start_workers
    fork do
      sidekiq = Sidekiq::CLI.instance
      logfile = Rails.root.join("log/sidekiq.log").to_s
      pidfile = Rails.root.join("tmp/sidekiq.pid").to_s
      sidekiq.parse([ "--require", Rails.root.to_s,
                      "--queue",   "integration_tests",
                      "--logfile", logfile,
                      "--pidfile", pidfile,
                      "--environment", "test",
                      "--concurrency", "1",
                      "--timeout", "1",
                      "--daemon",
                      ])
      require 'celluloid'
      require 'sidekiq/scheduled'
      Sidekiq.poll_interval = 0.5
      Sidekiq::Scheduled.const_set :INITIAL_WAIT, 1
      sidekiq.run
    end
    sleep 1
  end

  def stop_workers
    pidfile = Rails.root.join("tmp/sidekiq.pid").to_s
    Process.kill 'TERM', File.open(pidfile).read.to_i
    FileUtils.rm_f pidfile
  rescue
  end

  def can_run?
    begin
      Sidekiq.redis(&:info)
      Sidekiq.logger = nil
    rescue
      return false
    end
    true
  end
end