add sequel tests

Author: lukaszreszke

contrib/ruby_event_store-sequel/lib/ruby_event_store/sequel/event_repository.rb

@@ -68,13 +68,22 @@ def link_to_stream(event_ids, stream, expected_version)
       end
 
       def position_in_stream(event_id, stream)
-        record = @db[:event_store_events_in_streams].where(event_id: event_id, stream: stream.name).first
+        record =
+          @db[:event_store_events_in_streams]
+            .select(::Sequel[:event_store_events_in_streams][:position])
+            .where(
+              ::Sequel[:event_store_events_in_streams][:event_id] => event_id,
+              ::Sequel[:event_store_events_in_streams][:stream] => stream.name
+            )
+            .first
         raise EventNotFoundInStream.new if record.nil?
         record[:position]
       end
 
       def global_position(event_id)
-        record = @db[:event_store_events].where(event_id: event_id).first
+        record = @db[:event_store_events]
+                    .select(::Sequel[:event_store_events][:id])
+                   .where(::Sequel[:event_store_events][:event_id] => event_id).first
         raise EventNotFound.new(event_id) if record.nil?
         record[:id] - 1
       end
@@ -266,7 +275,16 @@ def find_event_id(specification_event_id, specification_stream_name)
 
       def read_from_global_stream(specification)
         dataset =
-          @db[:event_store_events].select(:event_id, :event_type, :data, :metadata, :created_at, :valid_at).order(:id)
+          @db[:event_store_events]
+            .select(
+              ::Sequel[:event_store_events][:event_id],
+              ::Sequel[:event_store_events][:event_type],
+              ::Sequel[:event_store_events][:data],
+              ::Sequel[:event_store_events][:metadata],
+              ::Sequel[:event_store_events][:created_at],
+              ::Sequel[:event_store_events][:valid_at]
+            )
+            .order(:id)
 
         dataset = dataset.where(event_type: specification.with_types) if specification.with_types?
         dataset = dataset.where(event_id: specification.with_ids) if specification.with_ids?

contrib/ruby_event_store-sequel/spec/event_repository_spec.rb

@@ -131,6 +131,30 @@ module Sequel
         expect(event_record[:valid_at]).to eq(t2)
       end
 
+      specify do
+        repository.append_to_stream(
+          [event0 = SRecord.new, event1 = SRecord.new],
+          stream = Stream.new("stream"),
+          ExpectedVersion.auto
+        )
+
+        expect {
+          repository.position_in_stream(event0.event_id, stream)
+        }.to match_query /SELECT\s+.event_store_events_in_streams.\..position. FROM .event_store_events_in_streams.*/
+      end
+
+      specify do
+        repository.append_to_stream(
+          [event = SRecord.new],
+          Stream.new("stream"),
+          ExpectedVersion.any
+        )
+        expect {
+          repository.global_position(event.event_id)
+        }.to match_query /SELECT\s+.event_store_events.\..id. FROM .event_store_events.*/
+      end
+
+
 
       private