require 'spec_helper'
require 'timecop'
require 'rspec-sidekiq'

describe DelayedCron do

  describe ".setup" do

    it "yields self" do
      DelayedCron.setup do |config|
        expect(DelayedCron).to eq(config)
      end
    end

    it "sends cron jobs to define_cron_jobs" do
      expect(DelayedCron).to receive(:define_cron_jobs)
      setup(default_interval: 1.hour)
    end

  end

  describe ".define_cron_jobs" do

    it "should have a default_interval" do
      setup(default_interval: 1.hour)
      expect(DelayedCron.default_interval).not_to be_nil
    end

    it "should have a default_time_zone" do
      setup(default_time_zone: "UTC")
      expect(DelayedCron.default_time_zone).to eq "UTC"
    end

    it "should default TZ to Eastern Time when not specified" do
      setup(cron_jobs: [{job: "Test"}])

      expect(DelayedCron.default_time_zone).to eq "Eastern Time (US & Canada)"
    end

    it "should have an array of cron_jobs" do
      setup(default_interval: 1.hour)
      expect(DelayedCron.cron_jobs).to be_an(Array)
    end

    let(:options) do
      {
        default_interval: 1.hour,
        cron_jobs: [
          "SomeClass.long_method",
          { job: "AnotherClass.expensive_method", interval: 1.hour }
        ]
      }
    end

    it "sends cron_jobs to schedule" do
      options[:cron_jobs].each do |cron_job|
        job_is_hash = cron_job.is_a?(Hash)
        klass, method_name = job_is_hash ? cron_job[:job].split(".") : cron_job.split(".")
        interval = job_is_hash ? cron_job[:interval] : options[:default_interval]
        expect(DelayedCron).to receive(:schedule).with(klass, method_name, { interval: interval })
      end
      setup(options)
    end

  end

  describe ".processor" do

    it "returns processor" do
      expect(DelayedCron.processor).to eq(DelayedCron::Jobs::Sidekiq)
    end

  end

  describe ".process_job" do

    it "should call the cron jobs method" do
      klass = build_class("SomeClass", "long_method", {interval: 1.day})
      expect(klass).to receive(:long_method)
      DelayedCron.process_job(klass.name, "long_method", {interval: 1.day})
    end

    it "should reschedule the cron job after processing" do
      klass, name = "SomeClass", "test_method"
      build_class(klass, name, {interval: 1.day})
      expect(DelayedCron).to receive(:schedule).with(klass, name, {interval: 1.day})
      DelayedCron.process_job(klass, name, {interval: 1.day})
    end

  end

  describe "cron_job" do
    context 'if not present' do
      it "schedules cron jobs found in a model" do
        klass, name = "SomeClass", "some_method"
        expect(DelayedCron).to receive(:schedule).with(klass, name, {})
        build_class(klass, name)
      end
    end
    context 'if present and true' do
      it "schedules cron jobs found in a model" do
        klass, name = "SomeClass", "some_method"
        expect(DelayedCron).to receive(:schedule).with(klass, name, {})
        build_class(klass, name, {if: true})
      end
    end
    context 'if present and false' do
      it "schedules cron jobs found in a model" do
        klass, name = "SomeClass", "some_method"
        expect(DelayedCron).not_to receive(:schedule).with(klass, name, {})
        build_class(klass, name, {if: false})
      end
    end
  end

end