migrate-from-resque-to-sidekiq.rb

require 'resque'
require 'resque_scheduler'
require 'sidekiq'

ENV['REDIS_URL'] = ENV['REDISTOGO_URL'] if ENV['REDISTOGO_URL']

delayed_jobs = Resque.delayed_queue_peek(0, 5000)

to_insert = delayed_jobs.inject([]) do |result, timestamp|
  jobs_at_time = Resque.delayed_timestamp_peek(timestamp, 0, 50000).map do |hash|
    hash['at'] = timestamp
    hash['queue'] = 'default'
    hash
  end

  result.concat(jobs_at_time)
end

to_insert += Resque.queues.inject([]) { |r,q| r + Resque.peek(q, 0, 50000).map { |j| j['queue'] = 'default'; j } }

require 'pry'; binding.pry

::Sidekiq.redis = {:namespace => 'sidekiq'}

::Sidekiq.redis do |r|
  require 'pry'; binding.pry
end

to_insert.each do |job|
  ::Sidekiq::Client.push(job)
end

::Sidekiq.redis do |r|
  require 'pry'; binding.pry
end