From 2b018b874c33fcccbe9cfaefe15b6304f39abf36 Mon Sep 17 00:00:00 2001
From: Tomas Lycken <tlycken@users.noreply.github.com>
Date: Tue, 31 Oct 2017 10:55:59 +0100
Subject: [PATCH] Query all events (#33)

* Implement querying over all events in the store

* Fix naming
---
 .../EventStoreTests/QueryEventsTests.cs        | 16 ++++++++++++++++
 .../EntityFrameworkEventStore.cs               | 18 +++++++++++++++++-
 src/RdbmsEventStore/IEventStream.cs            |  4 ++++
 3 files changed, 37 insertions(+), 1 deletion(-)

diff --git a/src/RdbmsEventStore.EntityFramework.Tests/EventStoreTests/QueryEventsTests.cs b/src/RdbmsEventStore.EntityFramework.Tests/EventStoreTests/QueryEventsTests.cs
index 1c75eb8..3e552d8 100644
--- a/src/RdbmsEventStore.EntityFramework.Tests/EventStoreTests/QueryEventsTests.cs
+++ b/src/RdbmsEventStore.EntityFramework.Tests/EventStoreTests/QueryEventsTests.cs
@@ -46,5 +46,21 @@ public async Task ReturnsEventsAccordingToQuery(string streamId, long expectedCo
             var events = await store.Events(streamId, es => es.Where(e => e.Version > 1));
             Assert.Equal(expectedCount, events.Count());
         }
+
+        [Fact]
+        public async Task ReturnsAllEvents()
+        {
+            var store = _fixture.BuildEventStore(_dbContext) as IEventStream<string, StringEvent, IEventMetadata<string>>;
+            var events = await store.Events();
+            Assert.Equal(5, events.Count());
+        }
+
+        [Fact]
+        public async Task ReturnsAllEventsAccordingToQuery()
+        {
+            var store = _fixture.BuildEventStore(_dbContext) as IEventStream<string, StringEvent, IEventMetadata<string>>;
+            var events = await store.Events(es => es.Where(e => e.Version > 1));
+            Assert.Equal(3, events.Count());
+        }
     }
 }
\ No newline at end of file
diff --git a/src/RdbmsEventStore.EntityFramework/EntityFrameworkEventStore.cs b/src/RdbmsEventStore.EntityFramework/EntityFrameworkEventStore.cs
index 5d8a6d7..6d86fad 100644
--- a/src/RdbmsEventStore.EntityFramework/EntityFrameworkEventStore.cs
+++ b/src/RdbmsEventStore.EntityFramework/EntityFrameworkEventStore.cs
@@ -28,7 +28,23 @@ public EntityFrameworkEventStore(TContext context, IEventFactory<TStreamId, TEve
             _serializer = serializer;
         }
 
-        public Task<IEnumerable<TEvent>> Events(TStreamId streamId) => Events(streamId, query => query);
+        public  Task<IEnumerable<TEvent>> Events() => Events(events => events);
+
+        public async Task<IEnumerable<TEvent>> Events(Func<IQueryable<TEventMetadata>, IQueryable<TEventMetadata>> query)
+        {
+            var storedEvents = await context.Events
+                .AsNoTracking()
+                .Apply(query)
+                .ToListAsync();
+
+            var events = storedEvents
+                .Cast<TPersistedEvent>()
+                .Select(_serializer.Deserialize);
+
+            return events;
+        }
+
+        public Task<IEnumerable<TEvent>> Events(TStreamId streamId) => Events(streamId, events => events);
 
         public async Task<IEnumerable<TEvent>> Events(TStreamId streamId, Func<IQueryable<TEventMetadata>, IQueryable<TEventMetadata>> query)
         {
diff --git a/src/RdbmsEventStore/IEventStream.cs b/src/RdbmsEventStore/IEventStream.cs
index 7606a18..6a61fde 100644
--- a/src/RdbmsEventStore/IEventStream.cs
+++ b/src/RdbmsEventStore/IEventStream.cs
@@ -9,6 +9,10 @@ public interface IEventStream<in TStreamId, TEvent, TEventMetadata>
         where TEvent : IEvent<TStreamId>, TEventMetadata
         where TEventMetadata : IEventMetadata<TStreamId>
     {
+        Task<IEnumerable<TEvent>> Events();
+
+        Task<IEnumerable<TEvent>> Events(Func<IQueryable<TEventMetadata>, IQueryable<TEventMetadata>> query);
+
         Task<IEnumerable<TEvent>> Events(TStreamId streamId);
 
         Task<IEnumerable<TEvent>> Events(TStreamId streamId, Func<IQueryable<TEventMetadata>, IQueryable<TEventMetadata>> query);