describe Travis::Services::RemoveLog do
  let(:repo)    { Factory(:repository) }
  let(:job)     { Factory(:test, repository: repo, state: :created) }
  let(:user)    { Factory(:user) }
  let(:service) { described_class.new(user, params) }
  let(:params)  { { id: job.id, reason: 'Because reason!'} }

  context 'when job is not finished' do
    before :each do
      job.stubs(:finished?).returns false
      user.stubs(:permission?).with(:push, anything).returns true
    end

    it 'raises JobUnfinished error' do
      lambda {
        service.run
      }.should raise_error Travis::JobUnfinished
    end
  end

  context 'when user does not have push permissions' do
    before :each do
      user.stubs(:permission?).with(:push, anything).returns false
    end

    it 'raises AuthorizationDenied' do
      lambda {
        service.run
      }.should raise_error Travis::AuthorizationDenied
    end
  end

  context 'when a job is found' do
    before do
      find_by_id = stub
      find_by_id.stubs(:find_by_id).returns job
      job.stubs(:finished?).returns true
      service.stubs(:scope).returns find_by_id
      user.stubs(:permission?).with(:push, anything).returns true
    end

    it 'runs successfully' do
      result = service.run
      result.removed_by.should == user
      result.removed_at.should be_truthy
      result.should be_truthy
    end

    it "updates logs with desired information" do
      service.run
      service.log.content.should =~ Regexp.new(user.name)
      service.log.content.should =~ Regexp.new(params[:reason])
    end

    it "uses a log part for storing the content" do
      service.run
      service.log.parts.first.content.should =~ Regexp.new(user.name)
      service.log.parts.first.content.should =~ Regexp.new(params[:reason])
    end

    context 'when log is already removed' do
      it 'raises LogAlreadyRemoved error' do
        service.run
        lambda {
          service.run
        }.should raise_error Travis::LogAlreadyRemoved
      end
    end
  end

  context 'when a job is not found' do
    before :each do
      find_by_id = stub
      find_by_id.stubs(:find_by_id).raises(ActiveRecord::SubclassNotFound)
      service.stubs(:scope).returns(find_by_id)
    end

    it 'raises ActiveRecord::RecordNotFound exception' do
      lambda { service.run }.should raise_error(ActiveRecord::RecordNotFound)
    end
  end

end

describe Travis::Services::RemoveLog::Instrument do
  let(:service)   { Travis::Services::RemoveLog.new(user, params) }
  let(:repo)      { Factory(:repository) }
  let(:user)      { Factory(:user) }
  let(:job)       { Factory(:test, repository: repo, state: :passed) }
  let(:params)    { { id: job.id, reason: 'Because Science!' } }
  let(:publisher) { Travis::Notification::Publisher::Memory.new }
  let(:event)     { publisher.events.last }

  before :each do
    Travis::Notification.publishers.replace([publisher])
    service.stubs(:run_service)
    user.stubs(:permission?).with(:push, anything).returns true
  end

  it 'publishes a event' do
    service.run
    event.should publish_instrumentation_event(
      event: 'travis.services.remove_log.run:completed',
      message: "Travis::Services::RemoveLog#run:completed for <Job id=#{job.id}> (svenfuchs)",
    )
  end
end