Sha256: b6e923c85ced079b6ccf63d9da3dc3b9ca1f250b22d6317949bc131bbb74af7d

Contents?: true

Size: 1.36 KB

Versions: 3

Compression:

Stored size: 1.36 KB

Contents

RSpec.describe FileStore do
  subject(:store) { FileStore.new STORE_DIR }

  let(:data_io) { StringIO.new }
  let(:index_io) { StringIO.new }

  let(:id) { SecureRandom.uuid }
  let(:type) { 'Test' }

  let(:data) { { one: 9000, two: 'pizza', three: ['foo', 123] } }
  let(:event_one) { Event.new :tested_system, Time.new(2015), data }
  let(:event_two) { Event.new :logged_in, Time.new(2015, 2), data }
  let(:events) { [event_one, event_two] }

  let(:event_stream) { EventStream.new id, type, events }

  describe '#create' do
    before do
      FileStore.new(STORE_DIR).create(SecureRandom.uuid, type)
      FileStore.new(STORE_DIR).create(SecureRandom.uuid, type)
    end

    it 'should be able to restore written data' do
      all = store.all

      expect(all.length).to eq 2
      expect(all.first.type).to eq type
      expect(all.last.type).to eq type
    end
  end

  describe '#read' do
    before do
      FileStore.new(STORE_DIR).create(id, type).write([event_stream])
    end

    it 'should be able to restore written data' do
      restored_stream = store.read([id]).first

      expect(restored_stream.id).to eq id
      expect(restored_stream.type).to eq type
      expect(restored_stream.events.to_a).to eq events
    end
  end

  describe '#write' do
    it 'should write data to disk' do
      expect { store.write [event_stream] }.to_not raise_error
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
aggro-0.0.4 spec/lib/aggro/file_store_spec.rb
aggro-0.0.3 spec/lib/aggro/file_store_spec.rb
aggro-0.0.2 spec/lib/aggro/file_store_spec.rb