Merge pull request #19 from Devwarlt/dev

PSTk.Redis: support for subscription feature
Devwarlt · Mar 10, 2021 · c28d22b · c28d22b
2 parents ca85191 + d7f3b3a
commit c28d22b
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 5 deletions.
diff --git a/PSTk.Core/PSTk.Core.csproj b/PSTk.Core/PSTk.Core.csproj
@@ -21,7 +21,7 @@
     <EnableNETAnalyzers>true</EnableNETAnalyzers>
     <PackageId>PSTk.Core</PackageId>
     <ApplicationIcon>ICON.ico</ApplicationIcon>
-    <Version>1.1.2</Version>
+    <Version>1.1.3</Version>
   </PropertyGroup>
 
   <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

diff --git a/PSTk.Redis/Database/RedisEngine.cs b/PSTk.Redis/Database/RedisEngine.cs
@@ -15,6 +15,7 @@ public sealed class RedisEngine
 
         private IConnectionMultiplexer connectionMultiplexer;
         private IDatabase database;
+        private ISubscriber subscriber;
 
 #pragma warning disable CS1591 // Missing XML comment for publicly visible type or member
 
@@ -32,6 +33,11 @@ public sealed class RedisEngine
         /// </summary>
         public bool IsConnected => connectionMultiplexer != null && connectionMultiplexer.IsConnected;
 
+        /// <summary>
+        /// Gets <see cref="ISubscriber"/> of current <see cref="IDatabase"/> instance.
+        /// </summary>
+        public ISubscriber Subscriber => subscriber;
+
         /// <summary>
         /// Tries to close <see cref="IConnectionMultiplexer"/> connection synchronously.
         /// </summary>
@@ -51,7 +57,7 @@ public async void CloseAsync()
             if (!IsConnected)
                 return;
 
-            connectionMultiplexer.CloseAsync();
+            await connectionMultiplexer.CloseAsync();
         }
 
         /// <summary>
@@ -70,6 +76,7 @@ public void Start()
                 var connectionStr = GetConnectionStrings();
                 connectionMultiplexer = ConnectionMultiplexer.Connect(connectionStr);
                 database = connectionMultiplexer.GetDatabase(redisSettings.Index);
+                subscriber = connectionMultiplexer.GetSubscriber();
             }
             catch (RedisConnectionException e)
             {
@@ -91,6 +98,7 @@ public async void StartAsync()
                 var connectionStr = GetConnectionStrings();
                 connectionMultiplexer = await ConnectionMultiplexer.ConnectAsync(connectionStr);
                 database = connectionMultiplexer.GetDatabase(redisSettings.Index);
+                subscriber = connectionMultiplexer.GetSubscriber();
             }
             catch (RedisConnectionException e)
             {

diff --git a/PSTk.Redis/PSTk.Redis.csproj b/PSTk.Redis/PSTk.Redis.csproj
@@ -16,7 +16,7 @@
     <RepositoryType>Git</RepositoryType>
     <PackageTags>dotnet;toolkit;game-tools;pserver</PackageTags>
     <ApplicationIcon>ICON.ico</ApplicationIcon>
-    <Version>1.0.1</Version>
+    <Version>1.1.1</Version>
   </PropertyGroup>
 
   <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

diff --git a/nuget-push-all.bat b/nuget-push-all.bat
@@ -14,11 +14,11 @@ IF "%~2"=="" (SET /P TOKEN="Enter API token: ")
 
 ECHO.
 
-SET CORE_PKG_VERSION=1.1.2
+SET CORE_PKG_VERSION=1.1.3
 SET DIAGNOSTICS_PKG_VERSION=1.2.0
 SET EXTENSIONS_PKG_VERSION=1.2.0
 SET NETWORKING_PKG_VERSION=1.1.0
-SET REDIS_PKG_VERSION=1.0.0
+SET REDIS_PKG_VERSION=1.1.1
 SET THREADING_PKG_VERSION=1.3.0
 
 ECHO Packing all distributions...