Contents

require File.expand_path(File.dirname(__FILE__) + '/../spec_helper')

describe Pupa::Processor::Persistence do
  def _type
    if testing_python_compatibility?
      'person'
    else
      'pupa/person'
    end
  end

  before :all do
    Pupa.session = Moped::Session.new(['localhost:27017'], database: 'pupa_test')
    Pupa.session.collections.each(&:drop)

    Pupa::Processor::Persistence.new(Pupa::Person.new(_id: 'existing', name: 'existing', email: '[e-mail]')).save

    Pupa.session[:people].insert(_type: 'pupa/person', name: 'non-unique')
    Pupa.session[:people].insert(_type: 'pupa/person', name: 'non-unique')
  end

  describe '.find' do
    it 'should return nil if no matches' do
      Pupa::Processor::Persistence.find(_type: _type, name: 'nonexistent').should == nil
    end

    it 'should return a document if one match' do
      Pupa::Processor::Persistence.find(_type: _type, name: 'existing').should be_a(Hash)
    end

    it 'should raise an error if many matches' do
      expect{Pupa::Processor::Persistence.find(_type: 'pupa/person', name: 'non-unique')}.to raise_error(Pupa::Errors::TooManyMatches)
    end
  end

  describe '#save' do
    it 'should insert a document if no matches' do
      Pupa::Processor::Persistence.new(Pupa::Person.new(_id: 'new', name: 'new', email: '[e-mail]')).save.should == [true, 'new']
      Pupa::Processor::Persistence.find(_type: _type, name: 'new')['email'].should == '[e-mail]'
    end

    it 'should update a document if one match' do
      Pupa::Processor::Persistence.new(Pupa::Person.new(_id: 'changed', name: 'existing', email: '[e-mail]')).save.should == [false, 'existing']
      Pupa::Processor::Persistence.find(_type: _type, name: 'existing')['email'].should == '[e-mail]'
    end

    it 'should raise an error if many matches' do
      expect{Pupa::Processor::Persistence.new(Pupa::Person.new(name: 'non-unique')).save}.to raise_error(Pupa::Errors::TooManyMatches)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
pupa-0.0.13	spec/processor/persistence_spec.rb
pupa-0.0.12	spec/processor/persistence_spec.rb