#1925 & #1928 Specific config handler and throw error if no CloudProv…

…ider - Add AWS & Azure specific config handlers - Add AWSS3Storage configuration - Throw exception if CloudProvider undefined or unknown
CGI-FR · Mar 30, 2023 · 609ebfe · 609ebfe
1 parent 3ae1037
commit 609ebfe
Show file tree

Hide file tree

Showing 17 changed files with 522 additions and 35 deletions.
diff --git a/src/AzureIoTHub.Portal.Domain/ConfigHandler.cs b/src/AzureIoTHub.Portal.Domain/ConfigHandler.cs
@@ -78,5 +78,6 @@ public abstract class ConfigHandler
         public abstract string AWSAccess { get; }
         public abstract string AWSAccessSecret { get; }
         public abstract string AWSRegion { get; }
+        public abstract string AWSS3StorageConnectionString { get; }
     }
 }
diff --git a/src/AzureIoTHub.Portal.Domain/Exceptions/InvalidCloudProviderException.cs b/src/AzureIoTHub.Portal.Domain/Exceptions/InvalidCloudProviderException.cs
@@ -0,0 +1,15 @@
+// Copyright (c) CGI France. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+namespace AzureIoTHub.Portal.Domain.Exceptions
+{
+    using System;
+    using AzureIoTHub.Portal.Domain.Shared.Constants;
+
+    public class InvalidCloudProviderException : BaseException
+    {
+        public InvalidCloudProviderException(string detail, Exception? innerException = null) : base(ErrorTitles.InvalidCloudProvider, detail, innerException)
+        {
+        }
+    }
+}
diff --git a/src/AzureIoTHub.Portal.Domain/Shared/Constants/ErrorTitles.cs b/src/AzureIoTHub.Portal.Domain/Shared/Constants/ErrorTitles.cs
@@ -10,5 +10,11 @@ public static class ErrorTitles
         public const string ResourceNotFound = "Resource Not Found";
 
         public const string ResourceAlreadyExists = "Resource Already Exists";
+
+        public const string InvalidCloudProvider = "Invalid Cloud Provider";
+
+        public const string InvalidCloudProviderUndefined = "The CloudProvider configuration is undefined";
+
+        public const string InvalidCloudProviderIncorrect = "The CloudProvider configuration is incorrect";
     }
 }
diff --git a/src/AzureIoTHub.Portal.Infrastructure/ConfigHandlerBase.cs b/src/AzureIoTHub.Portal.Infrastructure/ConfigHandlerBase.cs
@@ -55,5 +55,6 @@ internal abstract class ConfigHandlerBase : ConfigHandler
         internal const string AWSAccessKey = "AWS:Access";
         internal const string AWSAccessSecretKey = "AWS:AccessSecret";
         internal const string AWSRegionKey = "AWS:Region";
+        internal const string AWSS3StorageConnectionStringKey = "AWS:S3Storage:ConnectionString";
     }
 }
diff --git a/src/AzureIoTHub.Portal.Infrastructure/ConfigHandlerFactory.cs b/src/AzureIoTHub.Portal.Infrastructure/ConfigHandlerFactory.cs
@@ -5,6 +5,8 @@ namespace AzureIoTHub.Portal.Infrastructure
 {
     using System;
     using AzureIoTHub.Portal.Domain;
+    using AzureIoTHub.Portal.Domain.Exceptions;
+    using AzureIoTHub.Portal.Domain.Shared.Constants;
     using Microsoft.Extensions.Configuration;
     using Microsoft.Extensions.Hosting;
 
@@ -15,9 +17,19 @@ public static ConfigHandler Create(IHostEnvironment env, IConfiguration config)
             ArgumentNullException.ThrowIfNull(env, nameof(env));
             ArgumentNullException.ThrowIfNull(config, nameof(config));
 
+            if (config[ConfigHandlerBase.CloudProviderKey] == null)
+            {
+                throw new InvalidCloudProviderException(ErrorTitles.InvalidCloudProviderUndefined);
+            }
+
             if (env.IsProduction())
             {
-                return new ProductionConfigHandler(config);
+                return config[ConfigHandlerBase.CloudProviderKey] switch
+                {
+                    CloudProviders.AWS => new ProductionAWSConfigHandler(config),
+                    CloudProviders.Azure => new ProductionAzureConfigHandler(config),
+                    _ => throw new InvalidCloudProviderException(ErrorTitles.InvalidCloudProviderIncorrect),
+                };
             }
 
             return new DevelopmentConfigHandler(config);

diff --git a/src/AzureIoTHub.Portal.Infrastructure/DevelopmentConfigHandler.cs b/src/AzureIoTHub.Portal.Infrastructure/DevelopmentConfigHandler.cs
@@ -87,5 +87,6 @@ internal DevelopmentConfigHandler(IConfiguration config)
         public override string AWSAccess => this.config[AWSAccessKey];
         public override string AWSAccessSecret => this.config[AWSAccessSecretKey];
         public override string AWSRegion => this.config[AWSRegionKey];
+        public override string AWSS3StorageConnectionString => this.config[AWSS3StorageConnectionStringKey];
     }
 }
diff --git a/src/AzureIoTHub.Portal.Infrastructure/ProductionAWSConfigHandler.cs b/src/AzureIoTHub.Portal.Infrastructure/ProductionAWSConfigHandler.cs
@@ -0,0 +1,92 @@
+// Copyright (c) CGI France. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+namespace AzureIoTHub.Portal.Infrastructure
+{
+    using AzureIoTHub.Portal.Domain.Shared.Constants;
+    using Microsoft.Extensions.Configuration;
+
+    internal class ProductionAWSConfigHandler : ConfigHandlerBase
+    {
+        private readonly IConfiguration config;
+
+        internal ProductionAWSConfigHandler(IConfiguration config)
+        {
+            this.config = config;
+        }
+
+        public override string PortalName => this.config[PortalNameKey]!;
+
+        public override int SyncDatabaseJobRefreshIntervalInMinutes => this.config.GetValue(SyncDatabaseJobRefreshIntervalKey, 5);
+
+        public override int MetricExporterRefreshIntervalInSeconds => this.config.GetValue(MetricExporterRefreshIntervalKey, 30);
+
+        public override int MetricLoaderRefreshIntervalInMinutes => this.config.GetValue(MetricLoaderRefreshIntervalKey, 10);
+
+        public override string IoTHubConnectionString => this.config[IoTHubConnectionStringKey]!;
+
+        public override string IoTHubEventHubEndpoint => this.config.GetValue(IoTHubEventHubEndpointKey, string.Empty)!;
+
+        public override string IoTHubEventHubConsumerGroup => this.config.GetValue(IoTHubEventHubConsumerGroupKey, "iothub-portal")!;
+
+        public override string DPSConnectionString => this.config[DPSConnectionStringKey]!;
+
+        public override string DPSEndpoint => this.config[DPSServiceEndpointKey]!;
+
+        public override string DPSScopeID => this.config[DPSIDScopeKey]!;
+
+        public override string StorageAccountConnectionString => throw new NotImplementedException();
+
+        public override int StorageAccountDeviceModelImageMaxAge => throw new NotImplementedException();
+
+        public override bool UseSecurityHeaders => this.config.GetValue(UseSecurityHeadersKey, true);
+
+        public override string OIDCScope => this.config[OIDCScopeKey]!;
+
+        public override string OIDCAuthority => this.config[OIDCAuthorityKey]!;
+
+        public override string OIDCMetadataUrl => this.config[OIDCMetadataUrlKey]!;
+
+        public override string OIDCClientId => this.config[OIDCClientIdKey]!;
+
+        public override string OIDCApiClientId => this.config[OIDCApiClientIdKey]!;
+
+        public override bool OIDCValidateIssuer => this.config.GetValue(OIDCValidateIssuerKey, true);
+
+        public override bool OIDCValidateAudience => this.config.GetValue(OIDCValidateAudienceKey, true);
+
+        public override bool OIDCValidateLifetime => this.config.GetValue(OIDCValidateLifetimeKey, true);
+
+        public override bool OIDCValidateIssuerSigningKey => this.config.GetValue(OIDCValidateIssuerSigningKeyKey, true);
+
+        public override bool OIDCValidateActor => this.config.GetValue(OIDCValidateActorKey, false);
+
+        public override bool OIDCValidateTokenReplay => this.config.GetValue(OIDCValidateTokenReplayKey, false);
+
+        public override bool IsLoRaEnabled => bool.Parse(this.config[IsLoRaFeatureEnabledKey] ?? "true");
+
+        public override string LoRaKeyManagementUrl => this.config[LoRaKeyManagementUrlKey]!;
+
+        public override string LoRaKeyManagementCode => this.config[LoRaKeyManagementCodeKey]!;
+
+        public override string LoRaKeyManagementApiVersion => this.config[LoRaKeyManagementApiVersionKey]!;
+
+        public override bool IdeasEnabled => this.config.GetValue(IdeasEnabledKey, false);
+        public override string IdeasUrl => this.config.GetValue(IdeasUrlKey, string.Empty)!;
+        public override string IdeasAuthenticationHeader => this.config.GetValue(IdeasAuthenticationHeaderKey, "Ocp-Apim-Subscription-Key")!;
+        public override string IdeasAuthenticationToken => this.config.GetValue(IdeasAuthenticationTokenKey, string.Empty)!;
+
+        public override string PostgreSQLConnectionString => this.config[PostgreSQLConnectionStringKey]!;
+
+        public override string MySQLConnectionString => this.config[MySQLConnectionStringKey]!;
+
+        public override string DbProvider => this.config.GetValue(DbProviderKey, DbProviders.PostgreSQL);
+
+        public override string CloudProvider => this.config[CloudProviderKey];
+
+        public override string AWSAccess => this.config[AWSAccessKey];
+        public override string AWSAccessSecret => this.config[AWSAccessSecretKey];
+        public override string AWSRegion => this.config[AWSRegionKey];
+        public override string AWSS3StorageConnectionString => this.config[AWSS3StorageConnectionStringKey];
+    }
+}
diff --git a/...Infrastructure/ProductionConfigHandler.cs → ...structure/ProductionAzureConfigHandler.cs b/...Infrastructure/ProductionConfigHandler.cs → ...structure/ProductionAzureConfigHandler.cs
@@ -6,11 +6,11 @@ namespace AzureIoTHub.Portal.Infrastructure
     using AzureIoTHub.Portal.Domain.Shared.Constants;
     using Microsoft.Extensions.Configuration;
 
-    internal class ProductionConfigHandler : ConfigHandlerBase
+    internal class ProductionAzureConfigHandler : ConfigHandlerBase
     {
         private readonly IConfiguration config;
 
-        internal ProductionConfigHandler(IConfiguration config)
+        internal ProductionAzureConfigHandler(IConfiguration config)
         {
             this.config = config;
         }
@@ -84,8 +84,11 @@ internal ProductionConfigHandler(IConfiguration config)
 
         public override string CloudProvider => this.config[CloudProviderKey];
 
-        public override string AWSAccess => this.config[AWSAccessKey];
-        public override string AWSAccessSecret => this.config[AWSAccessSecretKey];
-        public override string AWSRegion => this.config[AWSRegionKey];
+        public override string AWSAccess => throw new NotImplementedException();
+
+        public override string AWSAccessSecret => throw new NotImplementedException();
+
+        public override string AWSRegion => throw new NotImplementedException();
+        public override string AWSS3StorageConnectionString => throw new NotImplementedException();
     }
 }
diff --git a/src/AzureIoTHub.Portal.Infrastructure/Seeds/DeviceModelCommandSeeder.cs b/src/AzureIoTHub.Portal.Infrastructure/Seeds/DeviceModelCommandSeeder.cs
@@ -36,7 +36,7 @@ public static async Task MigrateDeviceModelCommands(this PortalDbContext ctx, Co
                 });
 #pragma warning restore CS8629 // Nullable value type may be null.
 
-                if (config is ProductionConfigHandler)
+                if (config is ProductionAzureConfigHandler)
                 {
                     _ = await table.DeleteEntityAsync(item.PartitionKey, item.RowKey);
                 }

diff --git a/src/AzureIoTHub.Portal.Infrastructure/Seeds/DeviceModelPropertySeeder.cs b/src/AzureIoTHub.Portal.Infrastructure/Seeds/DeviceModelPropertySeeder.cs
@@ -36,7 +36,7 @@ public static async Task MigrateDeviceModelProperties(this PortalDbContext ctx,
                 });
 #pragma warning restore CS8629 // Nullable value type may be null.
 
-                if (config is ProductionConfigHandler)
+                if (config is ProductionAzureConfigHandler)
                 {
                     _ = await table.DeleteEntityAsync(item.PartitionKey, item.RowKey);
                 }

diff --git a/src/AzureIoTHub.Portal.Infrastructure/Seeds/DeviceModelSeeder.cs b/src/AzureIoTHub.Portal.Infrastructure/Seeds/DeviceModelSeeder.cs
@@ -44,7 +44,7 @@ public static async Task MigrateDeviceModels(this PortalDbContext ctx, ConfigHan
                 });
 #pragma warning restore CS8629 // Nullable value type may be null.
 
-                if (config is ProductionConfigHandler)
+                if (config is ProductionAzureConfigHandler)
                 {
                     _ = await table.DeleteEntityAsync(item.PartitionKey, item.RowKey);
                 }

diff --git a/src/AzureIoTHub.Portal.Infrastructure/Seeds/DeviceTagSeeder.cs b/src/AzureIoTHub.Portal.Infrastructure/Seeds/DeviceTagSeeder.cs
@@ -33,7 +33,7 @@ public static async Task MigrateDeviceTags(this PortalDbContext ctx, ConfigHandl
                 });
 #pragma warning restore CS8629 // Nullable value type may be null.
 
-                if (config is ProductionConfigHandler)
+                if (config is ProductionAzureConfigHandler)
                 {
                     _ = await table.DeleteEntityAsync(item.PartitionKey, item.RowKey);
                 }

diff --git a/src/AzureIoTHub.Portal.Infrastructure/Seeds/EdgeDeviceModelCommandSeeder.cs b/src/AzureIoTHub.Portal.Infrastructure/Seeds/EdgeDeviceModelCommandSeeder.cs
@@ -33,7 +33,7 @@ public static async Task MigrateEdgeDeviceModelCommands(this PortalDbContext ctx
                 });
 #pragma warning restore CS8629 // Nullable value type may be null.
 
-                if (config is ProductionConfigHandler)
+                if (config is ProductionAzureConfigHandler)
                 {
                     _ = await table.DeleteEntityAsync(item.PartitionKey, item.RowKey);
                 }

diff --git a/src/AzureIoTHub.Portal.Infrastructure/Seeds/EdgeDeviceModelSeeder.cs b/src/AzureIoTHub.Portal.Infrastructure/Seeds/EdgeDeviceModelSeeder.cs
@@ -32,7 +32,7 @@ public static async Task MigrateEdgeDeviceModels(this PortalDbContext ctx, Confi
                 });
 #pragma warning restore CS8629 // Nullable value type may be null.
 
-                if (config is ProductionConfigHandler)
+                if (config is ProductionAzureConfigHandler)
                 {
                     _ = await table.DeleteEntityAsync(item.PartitionKey, item.RowKey);
                 }

diff --git a/src/AzureIoTHub.Portal.Tests.Unit/Infrastructure/ConfigHandlerFactoryTest.cs b/src/AzureIoTHub.Portal.Tests.Unit/Infrastructure/ConfigHandlerFactoryTest.cs
@@ -3,7 +3,10 @@
 
 namespace AzureIoTHub.Portal.Tests.Unit.Infrastructure
 {
+    using AzureIoTHub.Portal.Domain.Exceptions;
+    using AzureIoTHub.Portal.Domain.Shared.Constants;
     using AzureIoTHub.Portal.Infrastructure;
+    using FluentAssertions;
     using Microsoft.Extensions.Configuration;
     using Microsoft.Extensions.Hosting;
     using Moq;
@@ -31,6 +34,8 @@ public void WhenUsingDevEnvironmentShouldReturnDevelopmentConfigHandler()
             // Arrange
             _ = this.mockHostEnvironment.Setup(c => c.EnvironmentName)
                 .Returns(Environments.Development);
+            _ = this.mockConfiguration.Setup(cnf => cnf[ConfigHandlerBase.CloudProviderKey])
+                    .Returns(CloudProviders.Azure);
 
             // Act
             var result = ConfigHandlerFactory.Create(this.mockHostEnvironment.Object, this.mockConfiguration.Object);
@@ -41,17 +46,67 @@ public void WhenUsingDevEnvironmentShouldReturnDevelopmentConfigHandler()
 
 
         [Test]
-        public void WhenUsingProdEnvironmentShouldReturnProductionConfigHandler()
+        public void WhenUsingProdAzureEnvironmentShouldReturnProductionAzureConfigHandler()
         {
             // Arrange
             _ = this.mockHostEnvironment.Setup(c => c.EnvironmentName)
                     .Returns(Environments.Production);
+            _ = this.mockConfiguration.Setup(cnf => cnf[ConfigHandlerBase.CloudProviderKey])
+                    .Returns(CloudProviders.Azure);
 
             // Act
             var result = ConfigHandlerFactory.Create(this.mockHostEnvironment.Object, this.mockConfiguration.Object);
 
             // Assert
-            Assert.IsAssignableFrom<ProductionConfigHandler>(result);
+            Assert.IsAssignableFrom<ProductionAzureConfigHandler>(result);
+        }
+
+        [Test]
+        public void WhenUsingProdAWSEnvironmentShouldReturnProductionAWSConfigHandler()
+        {
+            // Arrange
+            _ = this.mockHostEnvironment.Setup(c => c.EnvironmentName)
+                    .Returns(Environments.Production);
+            _ = this.mockConfiguration.Setup(cnf => cnf[ConfigHandlerBase.CloudProviderKey])
+                    .Returns(CloudProviders.AWS);
+
+            // Act
+            var result = ConfigHandlerFactory.Create(this.mockHostEnvironment.Object, this.mockConfiguration.Object);
+
+            // Assert
+            Assert.IsAssignableFrom<ProductionAWSConfigHandler>(result);
+        }
+
+        [Test]
+        public void WhenNoConfigCloudProviderShouldThrowInvalidCloudProviderException()
+        {
+            // Arrange
+            _ = this.mockHostEnvironment.Setup(c => c.EnvironmentName)
+                    .Returns(Environments.Production);
+            _ = this.mockConfiguration.Setup(cnf => cnf[ConfigHandlerBase.CloudProviderKey])
+                    .Returns((string)null);
+
+            // Act
+            var result = () => ConfigHandlerFactory.Create(this.mockHostEnvironment.Object, this.mockConfiguration.Object);
+
+            // Assert
+            _ = result.Should().Throw<InvalidCloudProviderException>().WithMessage(ErrorTitles.InvalidCloudProviderUndefined);
+        }
+
+        [Test]
+        public void WhenWrongCloudProviderShouldThrowInvalidCloudProviderException()
+        {
+            // Arrange
+            _ = this.mockHostEnvironment.Setup(c => c.EnvironmentName)
+                    .Returns(Environments.Production);
+            _ = this.mockConfiguration.Setup(cnf => cnf[ConfigHandlerBase.CloudProviderKey])
+                    .Returns("Test");
+
+            // Act
+            var result = () => ConfigHandlerFactory.Create(this.mockHostEnvironment.Object, this.mockConfiguration.Object);
+
+            // Assert
+            _ = result.Should().Throw<InvalidCloudProviderException>().WithMessage(ErrorTitles.InvalidCloudProviderIncorrect);
         }
     }
 }