#
# Specifying rufus-scheduler
#
# Wed Apr 17 06:00:59 JST 2013
#

require 'spec_helper'


describe Rufus::Scheduler::RepeatJob do

  before :each do
    @scheduler = Rufus::Scheduler.new
  end
  after :each do
    @scheduler.shutdown
  end

  describe '#pause' do

    it 'pauses the job' do

      counter = 0

      job =
        @scheduler.schedule_every('0.5s') do
          counter += 1
        end

      counter.should == 0

      while counter < 1; sleep(0.1); end

      job.pause

      sleep(1)

      counter.should == 1
    end
  end

  describe '#paused?' do

    it 'returns true if the job is paused' do

      job = @scheduler.schedule_every('10s') do; end

      job.pause

      job.paused?.should == true
    end

    it 'returns false if the job is not paused' do

      job = @scheduler.schedule_every('10s') do; end

      job.paused?.should == false
    end
  end

  describe '#resume' do

    it 'resumes a paused job' do

      counter = 0

      job =
        @scheduler.schedule_every('0.5s') do
          counter += 1
        end

      job.pause
      job.resume

      sleep(1.5)

      counter.should > 1
    end

    it 'has no effect on a not paused job' do

      job = @scheduler.schedule_every('10s') do; end

      job.resume

      job.paused?.should == false
    end
  end

  describe ':times => i' do

    it 'lets a job unschedule itself after i times' do

      counter = 0

      job =
        @scheduler.schedule_every '0.5s', :times => 3 do
          counter = counter + 1
        end

      sleep(2.6)

      counter.should == 3
    end

    it 'is OK when passed a nil instead of an integer' do

      counter = 0

      job =
        @scheduler.schedule_every '0.5s', :times => nil do
          counter = counter + 1
        end

      sleep(2.5)

      counter.should > 3
    end

    it 'raises when passed something else than nil or an integer' do

      lambda {
        @scheduler.schedule_every '0.5s', :times => 'nada' do; end
      }.should raise_error(ArgumentError)
    end
  end

  describe ':first/:first_in/:first_at => point in time' do

    it 'accepts a Time instance' do

      t = Time.now + 10

      job = @scheduler.schedule_every '0.5s', :first => t do; end

      job.first_at.should == t
    end

    it 'accepts a time string' do

      t = Time.now + 10

      job = @scheduler.schedule_every '0.5s', :first => t.to_s do; end

      job.first_at.to_s.should == t.to_s
      job.first_at.zone.should == t.zone
    end

    it 'only lets the job trigger after the :first' do

      t = Time.now + 1.4
      counter = 0

      job =
        @scheduler.schedule_every '0.5s', :first => t do
          counter = counter + 1
        end

      sleep(1)

      counter.should == 0

      sleep(1)

      counter.should > 0
    end

    it 'raises on points in the past' do

      lambda {

        @scheduler.schedule_every '0.5s', :first => Time.now - 60 do; end

      }.should raise_error(ArgumentError)
    end
  end

  describe ':first/:first_in/:first_at => duration' do

    it 'accepts a duration string' do

      t = Time.now

      job = @scheduler.schedule_every '0.5s', :first => '1h' do; end

      job.first_at.should >= t + 3600
      job.first_at.should < t + 3601
    end

    it 'accepts a duration in seconds (integer)' do

      t = Time.now

      job = @scheduler.schedule_every '0.5s', :first => 3600 do; end

      job.first_at.should >= t + 3600
      job.first_at.should < t + 3601
    end

    it 'raises if the argument cannot be used' do

      lambda {
        @scheduler.every '0.5s', :first => :nada do; end
      }.should raise_error(ArgumentError)
    end
  end

  describe '#first_at=' do

    it 'can be used to set first_at directly' do

      job = @scheduler.schedule_every '0.5s', :first => 3600 do; end
      job.first_at = '2030-12-12 12:00:30'

      job.first_at.strftime('%c').should == 'Thu Dec 12 12:00:30 2030'
    end
  end

  describe ':last/:last_in/:last_at => point in time' do

    it 'accepts a Time instance' do

      t = Time.now + 10

      job = @scheduler.schedule_every '0.5s', :last => t do; end

      job.last_at.should == t
    end

    it 'unschedules the job after the last_at time' do

      t = Time.now + 2
      counter = 0

      job =
        @scheduler.schedule_every '0.5s', :last => t do
          counter = counter + 1
        end

      sleep 3

      counter.should == 3
      @scheduler.jobs.should_not include(job)
    end

    it 'accepts a time string' do

      t = Time.now + 10

      job = @scheduler.schedule_every '0.5s', :last => t.to_s do; end

      job.last_at.to_s.should == t.to_s
      job.last_at.zone.should == t.zone
    end

    it 'raises on a point in the past' do

      lambda {

        @scheduler.every '0.5s', :last => Time.now - 60 do; end

      }.should raise_error(ArgumentError)
    end
  end

  describe ':last/:last_in/:last_at => duration' do

    it 'accepts a duration string' do

      t = Time.now

      job = @scheduler.schedule_every '0.5s', :last_in => '2s' do; end

      job.last_at.should >= t + 2
      job.last_at.should < t + 2.5
    end

    it 'accepts a duration in seconds (integer)' do

      t = Time.now

      job = @scheduler.schedule_every '0.5s', :last_in => 2.0 do; end

      job.last_at.should >= t + 2
      job.last_at.should < t + 2.5
    end

    it 'raises if the argument is worthless' do

      lambda {
        @scheduler.every '0.5s', :last => :nada do; end
      }.should raise_error(ArgumentError)
    end
  end

  describe '#last_at=' do

    it 'can be used to set last_at directly' do

      job = @scheduler.schedule_every '0.5s', :last_in => 10.0 do; end
      job.last_at = '2030-12-12 12:00:30'

      job.last_at.strftime('%c').should == 'Thu Dec 12 12:00:30 2030'
    end
  end
end