require 'gorgon/failures_printer'

describe Gorgon::FailuresPrinter do
  let(:job_state) { double("Job State", :add_observer => nil,
                         :is_job_complete? => true, :is_job_cancelled? => false,
                         :each_failed_test => nil,
                         :each_running_file => nil)}
  let(:fd) {double("File descriptor", :write => nil)}

  subject do
    Gorgon::FailuresPrinter.new({}, job_state)
  end

  it { should respond_to :update }

  describe "#initialize" do
    it "add its self to observers of job_state" do
      expect(job_state).to receive(:add_observer)
      Gorgon::FailuresPrinter.new({}, job_state)
    end
  end

  describe "#update" do
    before do
      @printer = Gorgon::FailuresPrinter.new({}, job_state)
    end

    context "job is not completed nor cancelled" do
      it "doesn't output anything" do
        allow(job_state).to receive(:is_job_complete?).and_return(false)
        expect(File).not_to receive(:open)
        @printer.update({})
      end
    end

    context "job is completed" do
      it "outputs failed tests return by job_state#each_failed_test" do
        allow(job_state).to receive(:each_failed_test).and_yield({:filename => "file1.rb"}).and_yield({:filename => "file2.rb"})
        expect(File).to receive(:open).with(Gorgon::FailuresPrinter::DEFAULT_OUTPUT_FILE, 'w+').and_yield fd
        expect(fd).to receive(:write).with(Yajl::Encoder.encode(["file1.rb", "file2.rb"]))
        @printer.update({})
      end

      it "outputs failed tests to 'failed_files' in configuration" do
        printer = Gorgon::FailuresPrinter.new({failed_files: 'a-file-somewhere.json'}, job_state)
        expect(File).to receive(:open).with('a-file-somewhere.json', 'w+')
        printer.update({})
      end
    end

    context "job is cancelled" do
      before do
        allow(job_state).to receive(:is_job_complete?).and_return(false)
        allow(job_state).to receive(:is_job_cancelled?).and_return(true)
      end

      it "outputs failed tests return by job_state#each_failed_test" do
        allow(job_state).to receive(:each_failed_test).and_yield({:filename => "file1.rb"}).and_yield({:filename => "file2.rb"})
        expect(File).to receive(:open).with(Gorgon::FailuresPrinter::DEFAULT_OUTPUT_FILE, 'w+').and_yield fd
        expect(fd).to receive(:write).once.with(Yajl::Encoder.encode(["file1.rb", "file2.rb"]))
        @printer.update({})
      end

      it "outputs still-running files returns by job_state#each_running_file" do
        allow(job_state).to receive(:each_running_file).and_yield("host1", "file1.rb").and_yield("host2", "file2.rb")
        allow(File).to receive(:open).and_yield fd
        expect(fd).to receive(:write).once.with(Yajl::Encoder.encode(["file1.rb", "file2.rb"]))
        @printer.update({})
      end
    end
  end
end