Add EventsByPersistenceId persistence query back (#133)

* Refactor namespace from Test to Tests

* Add EventsByPersistenceIdSpec and CurrentEventsByPersistenceIdSpec unit tests back

* Replace Source based EventsByPersistenceIdSource with ActorPublisher based EventsByPersistenceIdPublisher

* Add RedisReadJournalProvider back (accidentally deleted in dev)

* Cleanup RedisJournal class from all the leftover commented query support code.

src/Akka.Persistence.Redis.Cluster.Tests/DbUtils.cs

@@ -4,10 +4,9 @@
 // </copyright>
 // -----------------------------------------------------------------------
 
-using System.Linq;
 using StackExchange.Redis;
 
-namespace Akka.Persistence.Redis.Cluster.Test
+namespace Akka.Persistence.Redis.Cluster.Tests
 {
     public static class DbUtils
     {

src/Akka.Persistence.Redis.Cluster.Tests/Query/RedisCurrentEventsByPersistenceIdSpec.cs

@@ -0,0 +1,45 @@
+using Akka.Configuration;
+using Akka.Persistence.Query;
+using Akka.Persistence.Redis.Query;
+using Akka.Persistence.TCK.Query;
+using Xunit;
+using Xunit.Abstractions; //-----------------------------------------------------------------------
+// <copyright file="RedisCurrentEventsByPersistenceIdSpec.cs" company="Akka.NET Project">
+//     Copyright (C) 2017 Akka.NET Contrib <https://github.com/AkkaNetContrib/Akka.Persistence.Redis>
+// </copyright>
+//-----------------------------------------------------------------------
+
+namespace Akka.Persistence.Redis.Cluster.Tests.Query
+{
+    [Collection("RedisClusterSpec")]
+    public class RedisCurrentEventsByPersistenceIdSpec : CurrentEventsByPersistenceIdSpec
+    {
+        public static Config Config(RedisClusterFixture fixture)
+        {
+            DbUtils.Initialize(fixture);
+
+            return ConfigurationFactory.ParseString($@"
+            akka.loglevel = INFO
+            akka.persistence.journal.plugin = ""akka.persistence.journal.redis""
+            akka.persistence.journal.redis {{
+                class = ""Akka.Persistence.Redis.Journal.RedisJournal, Akka.Persistence.Redis""
+                plugin-dispatcher = ""akka.actor.default-dispatcher""
+                configuration-string = ""{fixture.ConnectionString}""
+            }}
+            akka.test.single-expect-default = 3s")
+                        .WithFallback(RedisPersistence.DefaultConfig());
+        }
+
+        public RedisCurrentEventsByPersistenceIdSpec(ITestOutputHelper output, RedisClusterFixture fixture)
+            : base(Config(fixture), nameof(RedisCurrentEventsByPersistenceIdSpec), output)
+        {
+            ReadJournal = Sys.ReadJournalFor<RedisReadJournal>(RedisReadJournal.Identifier);
+        }
+
+        protected override void Dispose(bool disposing)
+        {
+            DbUtils.Clean();
+            base.Dispose(disposing);
+        }
+    }
+}

src/Akka.Persistence.Redis.Cluster.Tests/Query/RedisEventsByPersistenceIdSpec.cs

@@ -0,0 +1,47 @@
+//-----------------------------------------------------------------------
+// <copyright file="RedisEventsByPersistenceIdSpec.cs" company="Akka.NET Project">
+//     Copyright (C) 2017 Akka.NET Contrib <https://github.com/AkkaNetContrib/Akka.Persistence.Redis>
+// </copyright>
+//-----------------------------------------------------------------------
+
+using Akka.Configuration;
+using Akka.Persistence.Query;
+using Akka.Persistence.Redis.Query;
+using Akka.Persistence.TCK.Query;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Akka.Persistence.Redis.Cluster.Tests.Query
+{
+    [Collection("RedisClusterSpec")]
+    public class RedisEventsByPersistenceIdSpec : EventsByPersistenceIdSpec
+    {
+        public static Config Config(RedisClusterFixture fixture)
+        {
+            DbUtils.Initialize(fixture);
+
+            return ConfigurationFactory.ParseString($@"
+            akka.loglevel = INFO
+            akka.persistence.journal.plugin = ""akka.persistence.journal.redis""
+            akka.persistence.journal.redis {{
+                class = ""Akka.Persistence.Redis.Journal.RedisJournal, Akka.Persistence.Redis""
+                plugin-dispatcher = ""akka.actor.default-dispatcher""
+                configuration-string = ""{fixture.ConnectionString}""
+            }}
+            akka.test.single-expect-default = 3s")
+                .WithFallback(RedisPersistence.DefaultConfig());
+        }
+
+        public RedisEventsByPersistenceIdSpec(ITestOutputHelper output, RedisClusterFixture fixture) 
+            : base(Config(fixture), nameof(RedisEventsByPersistenceIdSpec), output)
+        {
+            ReadJournal = Sys.ReadJournalFor<RedisReadJournal>(RedisReadJournal.Identifier);
+        }
+
+        protected override void Dispose(bool disposing)
+        {
+            DbUtils.Clean();
+            base.Dispose(disposing);
+        }
+    }
+}

src/Akka.Persistence.Redis.Cluster.Tests/RedisClusterFixture.cs

@@ -13,7 +13,7 @@
 using Docker.DotNet.Models;
 using Xunit;
 
-namespace Akka.Persistence.Redis.Cluster.Test
+namespace Akka.Persistence.Redis.Cluster.Tests
 {
     [CollectionDefinition("RedisClusterSpec")]
     public sealed class RedisSpecsFixture : ICollectionFixture<RedisClusterFixture>

src/Akka.Persistence.Redis.Cluster.Tests/RedisJournalPerfSpec.cs

@@ -4,13 +4,12 @@
 // </copyright>
 // -----------------------------------------------------------------------
 
-using System;
 using Akka.Configuration;
 using Akka.Persistence.TestKit.Performance;
 using Xunit;
 using Xunit.Abstractions;
 
-namespace Akka.Persistence.Redis.Cluster.Test
+namespace Akka.Persistence.Redis.Cluster.Tests
 {
     [Collection("RedisClusterSpec")]
     public class RedisJournalPerfSpec : JournalPerfSpec

src/Akka.Persistence.Redis.Cluster.Tests/RedisJournalSpec.cs

@@ -9,7 +9,7 @@
 using Xunit;
 using Xunit.Abstractions;
 
-namespace Akka.Persistence.Redis.Cluster.Test
+namespace Akka.Persistence.Redis.Cluster.Tests
 {
     [Collection("RedisClusterSpec")]
     public class RedisJournalSpec : JournalSpec

src/Akka.Persistence.Redis.Cluster.Tests/RedisSettingsSpec.cs

@@ -7,7 +7,7 @@
 using FluentAssertions;
 using Xunit;
 
-namespace Akka.Persistence.Redis.Cluster.Test
+namespace Akka.Persistence.Redis.Cluster.Tests
 {
     public class RedisSettingsSpec : Akka.TestKit.Xunit2.TestKit
     {

src/Akka.Persistence.Redis.Cluster.Tests/RedisSnapshotStoreSpec.cs

@@ -9,7 +9,7 @@
 using Xunit;
 using Xunit.Abstractions;
 
-namespace Akka.Persistence.Redis.Cluster.Test
+namespace Akka.Persistence.Redis.Cluster.Tests
 {
     [Collection("RedisClusterSpec")]
     public class RedisSnapshotStoreSpec : SnapshotStoreSpec

src/Akka.Persistence.Redis.Cluster.Tests/Serialization/RedisJournalSerializationSpec.cs

@@ -9,7 +9,7 @@
 using Xunit;
 using Xunit.Abstractions;
 
-namespace Akka.Persistence.Redis.Cluster.Test.Serialization
+namespace Akka.Persistence.Redis.Cluster.Tests.Serialization
 {
     [Collection("RedisClusterSpec")]
     public class RedisJournalSerializationSpec : JournalSerializationSpec

src/Akka.Persistence.Redis.Cluster.Tests/Serialization/RedisSnapshotStoreSerializationSpec.cs

@@ -9,7 +9,7 @@
 using Xunit;
 using Xunit.Abstractions;
 
-namespace Akka.Persistence.Redis.Cluster.Test.Serialization
+namespace Akka.Persistence.Redis.Cluster.Tests.Serialization
 {
     [Collection("RedisClusterSpec")]
     public class RedisSnapshotStoreSerializationSpec : SnapshotStoreSerializationSpec

src/Akka.Persistence.Redis.Tests/Query/RedisCurrentEventsByPersistenceIdSpec.cs

@@ -0,0 +1,53 @@
+using Akka.Persistence.Redis;
+using Akka.Persistence.Redis.Tests;
+
+//-----------------------------------------------------------------------
+// <copyright file="RedisCurrentEventsByPersistenceIdSpec.cs" company="Akka.NET Project">
+//     Copyright (C) 2017 Akka.NET Contrib <https://github.com/AkkaNetContrib/Akka.Persistence.Redis>
+// </copyright>
+//-----------------------------------------------------------------------
+
+using Akka.Configuration;
+using Akka.Persistence.Query;
+using Akka.Persistence.Redis.Query;
+using Akka.Persistence.TCK.Query;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Akka.Persistence.Redis.Tests.Query
+{
+    [Collection("RedisSpec")]
+    public class RedisCurrentEventsByPersistenceIdSpec : CurrentEventsByPersistenceIdSpec
+    {
+        public const int Database = 1;
+
+        public static Config Config(RedisFixture fixture, int id)
+        {
+            DbUtils.Initialize(fixture);
+
+            return ConfigurationFactory.ParseString($@"
+            akka.loglevel = INFO
+            akka.persistence.journal.plugin = ""akka.persistence.journal.redis""
+            akka.persistence.journal.redis {{
+                class = ""Akka.Persistence.Redis.Journal.RedisJournal, Akka.Persistence.Redis""
+                plugin-dispatcher = ""akka.actor.default-dispatcher""
+                configuration-string = ""{fixture.ConnectionString}""
+                database = {id}
+            }}
+            akka.test.single-expect-default = 3s")
+                        .WithFallback(RedisPersistence.DefaultConfig());
+        }
+
+        public RedisCurrentEventsByPersistenceIdSpec(ITestOutputHelper output, RedisFixture fixture)
+            : base(Config(fixture, Database), nameof(RedisCurrentEventsByPersistenceIdSpec), output)
+        {
+            ReadJournal = Sys.ReadJournalFor<RedisReadJournal>(RedisReadJournal.Identifier);
+        }
+
+        protected override void Dispose(bool disposing)
+        {
+            DbUtils.Clean(Database);
+            base.Dispose(disposing);
+        }
+    }
+}

src/Akka.Persistence.Redis.Tests/Query/RedisEventsByPersistenceIdSpec.cs

@@ -0,0 +1,49 @@
+//-----------------------------------------------------------------------
+// <copyright file="RedisEventsByPersistenceIdSpec.cs" company="Akka.NET Project">
+//     Copyright (C) 2017 Akka.NET Contrib <https://github.com/AkkaNetContrib/Akka.Persistence.Redis>
+// </copyright>
+//-----------------------------------------------------------------------
+
+using Akka.Configuration;
+using Akka.Persistence.Query;
+using Akka.Persistence.Redis.Query;
+using Akka.Persistence.TCK.Query;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Akka.Persistence.Redis.Tests.Query
+{
+    [Collection("RedisSpec")]
+    public class RedisEventsByPersistenceIdSpec : EventsByPersistenceIdSpec
+    {
+        public const int Database = 1;
+
+        public static Config Config(RedisFixture fixture, int id)
+        {
+            DbUtils.Initialize(fixture);
+
+            return ConfigurationFactory.ParseString($@"
+            akka.loglevel = INFO
+            akka.persistence.journal.plugin = ""akka.persistence.journal.redis""
+            akka.persistence.journal.redis {{
+                class = ""Akka.Persistence.Redis.Journal.RedisJournal, Akka.Persistence.Redis""
+                plugin-dispatcher = ""akka.actor.default-dispatcher""
+                configuration-string = ""{fixture.ConnectionString}""
+                database = {id}
+            }}
+            akka.test.single-expect-default = 3s")
+                .WithFallback(RedisPersistence.DefaultConfig());
+        }
+
+        public RedisEventsByPersistenceIdSpec(ITestOutputHelper output, RedisFixture fixture) : base(Config(fixture, Database), nameof(RedisEventsByPersistenceIdSpec), output)
+        {
+            ReadJournal = Sys.ReadJournalFor<RedisReadJournal>(RedisReadJournal.Identifier);
+        }
+
+        protected override void Dispose(bool disposing)
+        {
+            DbUtils.Clean(Database);
+            base.Dispose(disposing);
+        }
+    }
+}