require 'spec_helper'
require 'sidekiq/testing'

Sidekiq::Testing.server_middleware do |chain|
  chain.add CanvasSync::JobBatches::Sidekiq::ServerMiddleware
end

CanvasSync.redis { |r| r.flushdb }

def redis_keys
  CanvasSync.redis { |r| r.keys('BID-*') }
end

def dump_redis_keys
  puts redis_keys.inspect
end

def process_tests
  out_buf = StringIO.new
  Sidekiq.logger = Logger.new out_buf

  # Sidekiq.logger.level = :info

  Sidekiq::Worker.drain_all

  output = out_buf.string
  keys = redis_keys
  puts out_buf.string

  [output, keys]
end

def overall_tests(output, keys, file: nil)
  test_name = "Batch Integration Test"
  test_name = File.basename(file, ".*")  if file

  Rspec.describe test_name do
    it "runs overall complete callback" do
      expect(output).to include "Overall Complete"
    end

    it "runs overall success callback" do
      expect(output).to include "Overall Success"
    end

    it "cleans redis keys" do
      expect(keys).to eq([])
    end
  end
end