spec/lib/timeout_worker_spec.rb

	timeout_worker_spec.rb revision 25fded88391e73fd7a1306bb1da1c24232f94cfd


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
require 'spec_helper'

describe TimeoutWorker do

  context 'when a timeout is not set' do

    let(:worker) { TimeoutWorker.new }

    before do
      Settings.stub(:ontology_parse_timeout) { nil }
    end

    after do
      Settings.unstub(:ontology_parse_timeout)
    end

    it 'will complain with an error' do
      expect { worker.timeout_limit }.to raise_error(TimeoutWorker::TimeOutNotSetError)
    end

  end

  context 'when a timeout has been set' do
    let(:worker) { TimeoutWorker.new }
    let(:ontology_version) { create :ontology_version }
    let(:ontology) { ontology_version.ontology }

    context 'when the timeout is reached' do
      let(:offset_hours) { (Settings.ontology_parse_timeout + 1) * 3600 }
      let(:start_unix_timestamp) { TimeoutWorker.time_since_epoch(Time.now - offset_hours) }


      before do
        worker.perform(start_unix_timestamp, ontology_version.id)
        ontology_version.reload
      end

      it 'will set the state of the ontology version to failed' do
        expect(ontology_version.state).to eq('failed')
      end

      it 'will set the error message of the ontology version accordingly' do
        expect(ontology_version.last_error).to include('The job reached the timeout limit')
      end

      it 'will set the state of the ontology to failed' do
        expect(ontology.state).to eq('failed')
      end

    end

  end

end