require File.expand_path('../test_helper', __FILE__)

describe 'gitdocs runner' do
  before { ENV['TEST'] = 'true' }

  describe 'syncing' do
    it 'should clone files' do
      with_clones(3) do |clone1, clone2, clone3|
        File.open(File.join(clone1, 'test'), 'w') { |f| f << 'testing' }
        sleep 3
        assert_equal 'testing', File.read(File.join(clone1, 'test'))
        assert_equal 'testing', File.read(File.join(clone2, 'test'))
        assert_equal 'testing', File.read(File.join(clone3, 'test'))
      end
    end

    it 'should resolve conflicts files' do
      with_clones(3) do |clone1, clone2, clone3|
        File.open(File.join(clone1, 'test.txt'), 'w') { |f| f << 'testing' }
        sleep 3
        File.open(File.join(clone1, 'test.txt'), 'w') { |f| f << "testing\n1" }
        File.open(File.join(clone2, 'test.txt'), 'w') { |f| f << "testing\n2" }
        sleep 3
        assert_includes 2..3, Dir[File.join(clone2, '*.txt')].to_a.size
        assert_includes 2..3, Dir[File.join(clone3, '*.txt')].to_a.size
      end
    end
  end

  describe 'public methods' do
    let(:runner) { Gitdocs::Runner.new(share)}

    let(:share)      { stub(polling_interval: 1, notification: true) }
    let(:notifier)   { stub }
    let(:repository) { stub(root: 'root_path') }
    before do
      Gitdocs::Notifier.stubs(:new).with(true).returns(notifier)
      Gitdocs::Repository.stubs(:new).with(share).returns(repository)
    end

    describe '#root' do
      subject { runner.root }
      it { subject.must_equal 'root_path' }
    end

    describe '#sync_changes' do
      subject { runner.sync_changes }

      before { repository.expects(:pull).returns(pull_result) }

      describe 'when invalid' do
        let(:pull_result) { nil }
        it { subject.must_equal nil }
      end

      describe 'when no remote present' do
        let(:pull_result) { :no_remote }
        it { subject.must_equal nil }
      end

      describe 'when merge is conflicted' do
        let(:pull_result) { ['file'] }
        before do
          notifier.expects(:warn).with(
            'There were some conflicts',
            "* file"
          )
          runner.expects(:push_changes)
        end
        it { subject.must_equal nil }
      end

      describe 'when merge is ok' do
        let(:pull_result) { :ok }
        before do
          runner.instance_variable_set(:@last_synced_revision, :oid)
          repository.stubs(:current_oid).returns(:next_oid)
          repository.stubs(:author_count).with(:oid).returns('Alice' => 1, 'Bob' => 2)
          notifier.expects(:info).with(
            'Updated with 3 changes',
            "In 'root_path':\n* Alice (1 change)\n* Bob (2 changes)"
          )
          runner.expects(:push_changes)
        end
        it { subject.must_equal nil }
        it { subject ; runner.instance_variable_get(:@last_synced_revision).must_equal :next_oid }
      end
    end

    describe '#push_changes' do
      subject { runner.push_changes }

      before { repository.expects(:push).returns(push_result) }

      describe 'when invalid' do
        let(:push_result) { nil }
        it { subject.must_equal nil }
      end

      describe 'when no remote present' do
        let(:push_result) { :no_remote }
        it { subject.must_equal nil }
      end

      describe 'when nothing happened' do
        let(:push_result) { :nothing }
        it { subject.must_equal nil }
      end

      describe 'when there is an error' do
        let(:push_result) { 'error' }
        before do
          notifier.expects(:error)
            .with('BAD Could not push changes in root_path', 'error')
        end
        it { subject.must_equal nil }
      end

      describe 'when push is conflicted' do
        let(:push_result) { :conflict }
        before do
          notifier.expects(:warn)
            .with('There was a conflict in root_path, retrying', '')
        end
        it { subject.must_equal nil }
      end

      describe 'when merge is ok' do
        let(:push_result) { :ok }
        before do
          runner.instance_variable_set(:@last_synced_revision, :oid)
          repository.stubs(:current_oid).returns(:next_oid)
          repository.stubs(:author_count).with(:oid).returns('Alice' => 1, 'Bob' => 2)
          notifier.expects(:info)
            .with('Pushed 3 changes', "'root_path' has been pushed")
        end
        it { subject.must_equal nil }
        it { subject ; runner.instance_variable_get(:@last_synced_revision).must_equal :next_oid }
      end
    end
  end
end