Add Redis DB Fixture (#16)

* make redis db fixture public + tests

* public redis extensions now use interface

src/Ephemerally.Redis.Xunit/EphemeralRedisMultiplexerFixture.cs

@@ -12,6 +12,8 @@ public EphemeralRedisMultiplexerFixture() { }
     protected EphemeralRedisMultiplexerFixture(IRedisInstanceFixture redisInstanceFixture)
         : base(redisInstanceFixture) { }
 
+    public IEphemeralRedisDatabase GetDatabase(int db = -1) => Multiplexer.GetDatabase() as IEphemeralRedisDatabase;
+
     protected override async Task<IConnectionMultiplexer> CreateMultiplexerAsync()
     {
         var implementation = await base.CreateMultiplexerAsync();

src/Ephemerally.Redis.Xunit/PooledEphemeralRedisDatabaseFixture.cs

@@ -4,7 +4,11 @@
 
 namespace Ephemerally.Redis.Xunit;
 
-internal class PooledEphemeralRedisDatabaseFixture : PooledEphemeralRedisMultiplexerFixture
+public class PooledEphemeralRedisDatabaseFixture<TRedisInstance>()
+    : PooledEphemeralRedisDatabaseFixture(new TRedisInstance())
+    where TRedisInstance : IRedisInstanceFixture, new();
+
+public class PooledEphemeralRedisDatabaseFixture : PooledEphemeralRedisMultiplexerFixture
 {
     private readonly Lazy<Task<IEphemeralRedisDatabase>> _database;
 
@@ -13,7 +17,13 @@ internal class PooledEphemeralRedisDatabaseFixture : PooledEphemeralRedisMultipl
     public PooledEphemeralRedisDatabaseFixture()
     {
         _database = new(CreateDatabaseAsync);
-    }  
+    }
+
+    protected PooledEphemeralRedisDatabaseFixture(IRedisInstanceFixture redisInstanceFixture)
+        : base(redisInstanceFixture)
+    {
+        _database = new(CreateDatabaseAsync);
+    }
 
     protected virtual async Task<IEphemeralRedisDatabase> CreateDatabaseAsync()
     {

src/Ephemerally.Redis/PublicExtensions.cs

@@ -6,18 +6,19 @@ namespace Ephemerally;
 
 public static class PublicExtensions
 {
-    public static EphemeralRedisDatabase AsEphemeral(this IDatabase database) =>
-        database is null or EphemeralRedisDatabase
-            ? (EphemeralRedisDatabase)database
+    public static IEphemeralRedisDatabase AsEphemeral(this IDatabase database) =>
+        database is null or IEphemeralRedisDatabase
+            ? (IEphemeralRedisDatabase)database
             : database.ToEphemeral();
 
-    public static EphemeralRedisDatabase ToEphemeral(this IDatabase database) =>
-        new(new RedisDatabaseEphemeral(database));
+    public static IEphemeralRedisDatabase ToEphemeral(this IDatabase database) =>
+        new EphemeralRedisDatabase(new RedisDatabaseEphemeral(database));
 
-    public static EphemeralRedisDatabase GetEphemeralDatabase(
+    public static IEphemeralRedisDatabase GetEphemeralDatabase(
         this IConnectionMultiplexer multiplexer,
-        int db = -1) =>
-        multiplexer.GetDatabase(db).AsEphemeral();
+        int db = -1,
+        object asyncState = null) =>
+        multiplexer.GetDatabase(db, asyncState).AsEphemeral();
 
     #region EphemeralConnectionMultiplexer
 

tests/Ephemerally.Redis.Tests/Fixtures/PooledEphemeralRedisDatabaseFixtureTests.cs

@@ -0,0 +1,34 @@
+using Ephemerally.Redis.Xunit;
+using Shouldly;
+
+namespace Ephemerally.Redis.Tests.Fixtures;
+
+public class PooledEphemeralRedisDatabaseFixtureTests6 : PooledEphemeralRedisDatabaseFixtureTests<RedisInstanceFixture6>;
+
+public class PooledEphemeralRedisDatabaseFixtureTests7 : PooledEphemeralRedisDatabaseFixtureTests<RedisInstanceFixture7>;
+
+[Collection(RedisTestCollection.Name)]
+public abstract class PooledEphemeralRedisDatabaseFixtureTests<TRedisFixture> : IAsyncLifetime
+    where TRedisFixture : class, IRedisInstanceFixture, new()
+{
+    // Arrange
+    private readonly PooledEphemeralRedisDatabaseFixture<TRedisFixture> _fixture = new();
+
+    [RedisFact]
+    public async Task Fixture_database_should_not_be_null()
+    {
+        // Act
+        var database = _fixture.Database;
+
+        // Assert
+        database.ShouldNotBeNull();
+    }
+
+    #region IAsyncLifetime Members
+
+    public Task InitializeAsync() => _fixture.InitializeAsync();
+
+    public Task DisposeAsync() => _fixture.DisposeAsync();
+
+    #endregion
+}