From b48a048dafb2b2d3167f5df06b9e5878c32d6f60 Mon Sep 17 00:00:00 2001 From: Tim Hess Date: Fri, 3 Nov 2023 09:30:15 -0500 Subject: [PATCH] sort alphabetically --- .../LegacyConnectorsPostProcessors.cs | 54 +++++++++---------- .../LegacyConnectorsPostProcessorsTest.cs | 34 ++++++------ 2 files changed, 44 insertions(+), 44 deletions(-) diff --git a/src/Configuration/src/Kubernetes.ServiceBinding/LegacyConnectorsPostProcessors.cs b/src/Configuration/src/Kubernetes.ServiceBinding/LegacyConnectorsPostProcessors.cs index 322bb041fe..7c32e49153 100644 --- a/src/Configuration/src/Kubernetes.ServiceBinding/LegacyConnectorsPostProcessors.cs +++ b/src/Configuration/src/Kubernetes.ServiceBinding/LegacyConnectorsPostProcessors.cs @@ -6,33 +6,6 @@ namespace Steeltoe.Extensions.Configuration.Kubernetes.ServiceBinding; -internal sealed class RabbitMQLegacyConnectorPostProcessor : IConfigurationPostProcessor -{ - internal const string BindingTypeKey = "rabbitmq"; - - public void PostProcessConfiguration(PostProcessorConfigurationProvider provider, IDictionary configData) - { - if (!provider.IsBindingTypeEnabled(BindingTypeKey)) - { - return; - } - - configData.Filter(ServiceBindingConfigurationProvider.KubernetesBindingsPrefix, ServiceBindingConfigurationProvider.TypeKey, BindingTypeKey).ForEach( - bindingNameKey => - { - // Spring -> spring.rabbitmq.... - // Steeltoe -> rabbitmq:client:.... - var mapper = new ServiceBindingMapper(configData, bindingNameKey, "rabbitmq", "client"); - mapper.MapFromTo("addresses", "uri"); - mapper.MapFromTo("host", "server"); - mapper.MapFromTo("password", "password"); - mapper.MapFromTo("port", "port"); - mapper.MapFromTo("username", "username"); - mapper.MapFromTo("virtual-host", "virtualhost"); - }); - } -} - internal sealed class MySqlLegacyConnectorPostProcessor : IConfigurationPostProcessor { internal const string BindingTypeKey = "mysql"; @@ -100,3 +73,30 @@ public void PostProcessConfiguration(PostProcessorConfigurationProvider provider }); } } + +internal sealed class RabbitMQLegacyConnectorPostProcessor : IConfigurationPostProcessor +{ + internal const string BindingTypeKey = "rabbitmq"; + + public void PostProcessConfiguration(PostProcessorConfigurationProvider provider, IDictionary configData) + { + if (!provider.IsBindingTypeEnabled(BindingTypeKey)) + { + return; + } + + configData.Filter(ServiceBindingConfigurationProvider.KubernetesBindingsPrefix, ServiceBindingConfigurationProvider.TypeKey, BindingTypeKey).ForEach( + bindingNameKey => + { + // Spring -> spring.rabbitmq.... + // Steeltoe -> rabbitmq:client:.... + var mapper = new ServiceBindingMapper(configData, bindingNameKey, "rabbitmq", "client"); + mapper.MapFromTo("addresses", "uri"); + mapper.MapFromTo("host", "server"); + mapper.MapFromTo("password", "password"); + mapper.MapFromTo("port", "port"); + mapper.MapFromTo("username", "username"); + mapper.MapFromTo("virtual-host", "virtualhost"); + }); + } +} diff --git a/src/Configuration/test/Kubernetes.ServiceBinding.Test/LegacyConnectorsPostProcessorsTest.cs b/src/Configuration/test/Kubernetes.ServiceBinding.Test/LegacyConnectorsPostProcessorsTest.cs index d4a667d83b..ea3db77de3 100644 --- a/src/Configuration/test/Kubernetes.ServiceBinding.Test/LegacyConnectorsPostProcessorsTest.cs +++ b/src/Configuration/test/Kubernetes.ServiceBinding.Test/LegacyConnectorsPostProcessorsTest.cs @@ -10,23 +10,6 @@ namespace Steeltoe.Extensions.Configuration.Kubernetes.ServiceBinding.Test; public class LegacyConnectorsPostProcessorsTest : BasePostProcessorsTest { - [Fact] - public void RabbitMQTest_BindingTypeEnabled() - { - var postProcessor = new RabbitMQLegacyConnectorPostProcessor(); - - Dictionary configData = GetConfigData(_testBindingName, RabbitMQPostProcessor.BindingTypeKey, Tuple.Create("addresses", "test-addresses"), Tuple.Create("host", "test-host"), Tuple.Create("password", "test-password"), Tuple.Create("port", "test-port"), Tuple.Create("username", "test-username"), Tuple.Create("virtual-host", "test-virtual-host")); - - // BindingType enabled - postProcessor.PostProcessConfiguration(GetConfigurationProvider(postProcessor, RabbitMQPostProcessor.BindingTypeKey, true), configData); - Assert.Equal("test-addresses", configData["rabbitmq:client:uri"]); - Assert.Equal("test-host", configData["rabbitmq:client:server"]); - Assert.Equal("test-password", configData["rabbitmq:client:password"]); - Assert.Equal("test-port", configData["rabbitmq:client:port"]); - Assert.Equal("test-username", configData["rabbitmq:client:username"]); - Assert.Equal("test-virtual-host", configData["rabbitmq:client:virtualhost"]); - } - [Fact] public void MySqlTest_BindingTypeEnabled() { @@ -63,4 +46,21 @@ public void PostgreSqlTest_BindingTypeEnabled() Assert.Equal("root.cert", configData["postgres:client:sslrootcert"]); Assert.Equal("--cluster=routing-id&opt=val1", configData["postgres:client:options"]); } + + [Fact] + public void RabbitMQTest_BindingTypeEnabled() + { + var postProcessor = new RabbitMQLegacyConnectorPostProcessor(); + + Dictionary configData = GetConfigData(_testBindingName, RabbitMQPostProcessor.BindingTypeKey, Tuple.Create("addresses", "test-addresses"), Tuple.Create("host", "test-host"), Tuple.Create("password", "test-password"), Tuple.Create("port", "test-port"), Tuple.Create("username", "test-username"), Tuple.Create("virtual-host", "test-virtual-host")); + + // BindingType enabled + postProcessor.PostProcessConfiguration(GetConfigurationProvider(postProcessor, RabbitMQPostProcessor.BindingTypeKey, true), configData); + Assert.Equal("test-addresses", configData["rabbitmq:client:uri"]); + Assert.Equal("test-host", configData["rabbitmq:client:server"]); + Assert.Equal("test-password", configData["rabbitmq:client:password"]); + Assert.Equal("test-port", configData["rabbitmq:client:port"]); + Assert.Equal("test-username", configData["rabbitmq:client:username"]); + Assert.Equal("test-virtual-host", configData["rabbitmq:client:virtualhost"]); + } }