Contents

RSpec.describe ROM::Session do
  subject(:session) do
    ROM::Session.new(repo)
  end

  let(:repo) { instance_double(ROM::Repository) }
  let(:create_changeset) { instance_double(ROM::Changeset::Create, relation: relation) }
  let(:delete_changeset) { instance_double(ROM::Changeset::Delete, relation: relation) }
  let(:relation) { double.as_null_object }

  describe '#pending?' do
    it 'returns true before commit' do
      expect(session).to be_pending
    end

    it 'returns false after commit' do
      expect(session.commit!).to_not be_pending
    end
  end

  describe '#commit!' do
    it 'executes ops and restores pristine state' do
      expect(create_changeset).to receive(:commit).and_return(true)

      session.add(create_changeset).commit!
      session.commit!

      expect(session).to be_success
    end

    it 'executes ops and restores pristine state when exception was raised' do
      expect(create_changeset).to_not receive(:commit)
      expect(delete_changeset).to receive(:commit).and_raise(StandardError, 'oops')

      expect {
        session.add(delete_changeset)
        session.add(create_changeset)
        session.commit!
      }.to raise_error(StandardError, 'oops')

      expect(session).to be_failure

      session.commit!
    end
  end
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
rom-repository-1.4.0	spec/unit/session_spec.rb
rom-repository-1.3.3	spec/unit/session_spec.rb
rom-repository-1.3.2	spec/unit/session_spec.rb
rom-repository-1.3.1	spec/unit/session_spec.rb
rom-repository-1.3.0	spec/unit/session_spec.rb
rom-repository-1.2.0	spec/unit/session_spec.rb
rom-repository-1.1.0	spec/unit/session_spec.rb
rom-repository-1.0.2	spec/unit/session_spec.rb
rom-repository-1.0.1	spec/unit/session_spec.rb
rom-repository-1.0.0	spec/unit/session_spec.rb
rom-repository-1.0.0.rc2	spec/unit/session_spec.rb
rom-repository-1.0.0.rc1	spec/unit/session_spec.rb
rom-repository-1.0.0.beta3	spec/unit/session_spec.rb