Added in some restart logic when the maximum number of errors has occurred.

Author: danwale

Constants.cs

@@ -4,6 +4,7 @@ namespace SolarUseOptimiser
 {
     public class Constants
     {
+        public const string MAX_ERRORS = "MaxErrors";
         public class ConfigSections
         {
             public const string HUAWEI_CONFIG_SECTION = "Huawei";

GrowattProducer.cs

@@ -76,6 +76,12 @@ public GrowattProducer(IConfiguration configuration, ILogger<GrowattProducer> lo
             this.configuration = configuration;
         }
 
+        public async Task Restart(CancellationTokenSource cancellationTokenSource)
+        {
+            initialised = false;
+            await InitialiseAsync(cancellationTokenSource);
+        }
+
         public async Task<IDataSource> InitialiseAsync(CancellationTokenSource cancellationTokenSource)
         {
             if (!initialised)

HuaweiProducer.cs

@@ -76,6 +76,12 @@ public HuaweiProducer(IConfiguration configuration, ILogger<HuaweiProducer> logg
             this.configuration = configuration;
         }
 
+        public async Task Restart(CancellationTokenSource cancellationTokenSource)
+        {
+            initialised = false;
+            await InitialiseAsync(cancellationTokenSource);
+        }
+
         public async Task<IDataSource> InitialiseAsync(CancellationTokenSource cancellationTokenSource)
         {
             if (!initialised)

IDataSource.cs

@@ -27,5 +27,7 @@ bool IsInitialised
         Task<bool> Authenticate(CancellationTokenSource cancellationTokenSource);
 
         SiteMeterPush GetSiteMeterData(string userId, CancellationTokenSource cancellationTokenSource);
+
+        Task Restart(CancellationTokenSource cancellationTokenSource);
     }
 }

IoTaWattProducer.cs

@@ -40,6 +40,12 @@ public IoTaWattProducer(IConfiguration configuration, ILogger<IoTaWattProducer>
             this.configuration = configuration;
         }
 
+        public async Task Restart(CancellationTokenSource cancellationTokenSource)
+        {
+            IsInitialised = false;
+            await InitialiseAsync(cancellationTokenSource);
+        }
+
         public Task<IDataSource> InitialiseAsync(CancellationTokenSource cancellationTokenSource)
         {
             if (!IsInitialised)

PeriodicPoller.cs

@@ -23,6 +23,8 @@ public class PeriodicPoller
 
         private bool initialised = false;
 
+        private int errorCount = 0;
+
         private Timer Timer
         {
             get; set;
@@ -38,6 +40,11 @@ private IDataSource DataSource
             get; set;
         }
 
+        private int MaxErrors
+        {
+            get; set;
+        }
+
         private static CancellationTokenSource CancellationTokenSource;
 
         public PeriodicPoller(IConfiguration configuration, IDataSource dataProducer, IDataTarget dataConsumer, ILogger<PeriodicPoller> logger)
@@ -46,6 +53,21 @@ public PeriodicPoller(IConfiguration configuration, IDataSource dataProducer, ID
             this.DataSource = dataProducer;
             this.DataTarget = dataConsumer;
 
+            try 
+            {
+                this.MaxErrors = configuration.GetValue<int>(Constants.MAX_ERRORS);
+                if (this.MaxErrors == 0)
+                {
+                    logger.LogError("Failed to read the MaxErrors configuration for how many times to have an error before forcing a restart. Using a default of 5.");
+                    this.MaxErrors = 2;
+                }
+            }
+            catch (Exception ex)
+            {
+                logger.LogError(ex, "Failed to read the MaxErrors configuration for how many times to have an error before forcing a restart. Using a default of 5.");
+                this.MaxErrors = 2;
+            }
+
             this.logger = logger;
         }
 
@@ -137,6 +159,7 @@ private void PollGenerationStatistics_Elapsed(object sender, ElapsedEventArgs e)
                     }
                     else
                     {
+                        errorCount++;
                         bool sentErrorDataSuccess = DataTarget.SendErrorData(pushData).GetAwaiter().GetResult();
                         if (sentErrorDataSuccess)
                         {
@@ -146,6 +169,12 @@ private void PollGenerationStatistics_Elapsed(object sender, ElapsedEventArgs e)
                         {
                             logger.LogError("Failed to send the error data to {0}.", DataTarget.Name);
                         }
+                        if (errorCount >= MaxErrors)
+                        {
+                            logger.LogWarning("The maximum number of errors has occurred and the system is being reset.");
+                            DataSource.Restart(CancellationTokenSource);
+                            errorCount = 0;
+                        }
                     }                    
                 }
             }

appsettings.json

@@ -1,4 +1,5 @@
 {
+    "MaxErrors": 2,
     "Routing": {
         "DataSource": "Huawei || Growatt",
         "Target": "ChargeHQ"