feat: Add Rpc Api to Cronus

Elders · Jun 24, 2022 · b02a2b9 · b02a2b9
1 parent 8f8ff51
commit b02a2b9
Show file tree

Hide file tree

Showing 6 changed files with 35 additions and 5 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -20,6 +20,7 @@
 * Fix overflow of processed count when rebuilding projcetion. ([a9bd003](https://github.com/Elders/Cronus/commit/a9bd003c840332395464647f462dcdaea41b1402))
 
 # [8.1.0](https://github.com/Elders/Cronus/compare/v8.0.6...v8.1.0) (2022-06-15)
+# [8.1.0-preview.1](https://github.com/Elders/Cronus/compare/v8.0.4...v8.1.0-preview.1) (2022-05-27)
 
 
 ### Features
@@ -39,6 +40,8 @@
 ### Bug Fixes
 
 * Resolves a problem where a developer wants to remove an aggregate commit. It is actually a feature, maybe.... ([086ef83](https://github.com/Elders/Cronus/commit/086ef83332bd2fa1472cc1d1b90fe6a32c465aeb))
+* Add Rpc host ([8b1e03b](https://github.com/Elders/Cronus/commit/8b1e03bc3b9e6b3a372adfbec9d599ec551f0363))
+* Trigger pipeline ([3f76e8b](https://github.com/Elders/Cronus/commit/3f76e8b6cc816d81f070e832449702e984e31f83))
 
 ## [8.0.4](https://github.com/Elders/Cronus/compare/v8.0.3...v8.0.4) (2022-05-26)
 

diff --git a/src/Elders.Cronus/Hosting/CronusHost.cs b/src/Elders.Cronus/Hosting/CronusHost.cs
@@ -1,9 +1,10 @@
-using Elders.Cronus.EventStore.Index;
+using System;
+using Elders.Cronus.EventStore.Index;
+using Elders.Cronus.Hosting;
 using Elders.Cronus.Migrations;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using System;
 
 namespace Elders.Cronus
 {
@@ -25,6 +26,7 @@ public sealed class CronusHost : ICronusHost
         private readonly IConsumer<ISystemTrigger> systemTriggers;
         private readonly IConsumer<ISystemProjection> systemProjections;
         private readonly IConsumer<IMigrationHandler> migrations;
+        private readonly IRpcHost rpcHost;
         private readonly IServiceProvider serviceProvider;
         private CronusHostOptions hostOptions;
 
@@ -45,7 +47,7 @@ public sealed class CronusHost : ICronusHost
             IConsumer<ISystemProjection> systemProjections,
             IConsumer<IMigrationHandler> migrations,
             IOptionsMonitor<CronusHostOptions> cronusHostOptions,
-            IServiceProvider serviceProvider)
+            IServiceProvider serviceProvider, IRpcHost rpcHost)
         {
             this.booter = booter;
             this.appServices = appServices ?? throw new ArgumentNullException(nameof(appServices));
@@ -63,6 +65,7 @@ public sealed class CronusHost : ICronusHost
             this.systemProjections = systemProjections;
             this.migrations = migrations;
             this.serviceProvider = serviceProvider;
+            this.rpcHost = rpcHost;
             this.hostOptions = cronusHostOptions.CurrentValue;
             cronusHostOptions.OnChange(Changed);
         }
@@ -93,6 +96,12 @@ public void Start()
                     systemSagas.Start();
                     systemTriggers.Start();
                 }
+
+                if (hostOptions.RpcApiEnabled)
+                {
+                    rpcHost.Start();
+                }
+
             }
             catch (Exception ex)
             {
@@ -123,6 +132,11 @@ public void Stop()
                     systemIndices.Stop();
                     indices.Stop();
                 }
+
+                if (hostOptions.RpcApiEnabled)
+                {
+                    rpcHost.Stop();
+                }
             }
             catch (Exception ex)
             {
@@ -156,6 +170,7 @@ private void Start(CronusHostOptions oldOptions, CronusHostOptions newOptions)
                 if (oldOptions.PortsEnabled == false && newOptions.PortsEnabled == true) ports.Start();
                 if (oldOptions.GatewaysEnabled == false && newOptions.GatewaysEnabled == true) gateways.Start();
                 if (oldOptions.TriggersEnabled == false && newOptions.TriggersEnabled == true) gateways.Start();
+                if (oldOptions.RpcApiEnabled == false && newOptions.RpcApiEnabled == true) rpcHost.Start();
             }
             catch (Exception ex)
             {
@@ -174,6 +189,7 @@ private void Stop(CronusHostOptions oldOptions, CronusHostOptions newOptions)
                 if (oldOptions.PortsEnabled == true && newOptions.PortsEnabled == false) ports.Stop();
                 if (oldOptions.GatewaysEnabled == true && newOptions.GatewaysEnabled == false) gateways.Stop();
                 if (oldOptions.TriggersEnabled == true && newOptions.TriggersEnabled == false) gateways.Stop();
+                if (oldOptions.RpcApiEnabled == true && newOptions.RpcApiEnabled == false) rpcHost.Stop();
             }
             catch (Exception ex)
             {

diff --git a/src/Elders.Cronus/Hosting/CronusHostOptions.cs b/src/Elders.Cronus/Hosting/CronusHostOptions.cs
@@ -12,6 +12,7 @@ public class CronusHostOptions
         public bool TriggersEnabled { get; set; } = true;
         public bool MigrationsEnabled { get; set; } = false;
         public bool SystemServicesEnabled { get; set; } = true;
+        public bool RpcApiEnabled { get; set; } = false;
     }
 
     public class CronusHostOptionsProvider : CronusOptionsProviderBase<CronusHostOptions>

diff --git a/src/Elders.Cronus/Hosting/Heartbeat/CronusHeartbeat.cs b/src/Elders.Cronus/Hosting/Heartbeat/CronusHeartbeat.cs
@@ -45,7 +45,7 @@ public async Task StartBeatingAsync(CancellationToken stoppingToken)
                 }
                 catch (Exception ex)
                 {
-                    // failed to send heartbeat
+                    // failed to send heartbeat 
                     logger.WarnException(ex, () => "Failed to send heartbeat.");
                 }
             }

diff --git a/src/Elders.Cronus/Hosting/IRpcHost.cs b/src/Elders.Cronus/Hosting/IRpcHost.cs
@@ -0,0 +1,10 @@
+using System;
+
+namespace Elders.Cronus.Hosting
+{
+    public interface IRpcHost : IDisposable
+    {
+        void Start();
+        void Stop();
+    }
+}
diff --git a/src/Elders.Cronus/Hosting/StartupScanner.cs b/src/Elders.Cronus/Hosting/StartupScanner.cs
@@ -1,6 +1,6 @@
 using System;
-using System.Collections.Generic;
 using System.Linq;
+using System.Collections.Generic;
 
 namespace Elders.Cronus
 {