Passing env vars around

Author: johnsimons

src/Helper/BusRegistrationConfiguratorExt.cs

@@ -5,25 +5,75 @@ public static class BusRegistrationConfiguratorExt
 {
     public static void SetupTransport(this IBusRegistrationConfigurator x, string[] args)
     {
-        string selectedTransport = Environment.GetEnvironmentVariable("TRANSPORT_TYPE") ?? "RabbitMQ";
+        var selectedTransport = Environment.GetEnvironmentVariable("TRANSPORT_TYPE") ?? "RabbitMQ";
+        string envFile;
 
         switch (selectedTransport)
         {
+            case "AmazonSQS":
+                var awsRegion = Environment.GetEnvironmentVariable("AWS_REGION");
+                var awsClientId = Environment.GetEnvironmentVariable("AWS_ACCESS_KEY_ID");
+                var awsSecret = Environment.GetEnvironmentVariable("AWS_SECRET_ACCESS_KEY");
+                envFile = Path.GetFullPath("../../../sqs.env");
+                if (File.Exists(envFile))
+                {
+                    var envs = DotEnv.Read(new DotEnvOptions(envFilePaths: [envFile]));
+                    awsRegion = envs["AWS_REGION"];
+                    awsClientId = envs["AWS_ACCESS_KEY_ID"];
+                    awsSecret = envs["AWS_SECRET_ACCESS_KEY"];
+                }
+
+                x.UsingAmazonSqs((ctx, cfg) =>
+                {
+                    cfg.Host(awsRegion, h =>
+                    {
+                        h.AccessKey(awsClientId);
+                        h.SecretKey(awsSecret);
+                    });
+
+                    cfg.ConfigureEndpoints(ctx);
+                });
+                break;
             case "AzureServiceBus":
-                string connectionString = Environment.GetEnvironmentVariable("CONNECTION_STRING");
+                var connectionString = Environment.GetEnvironmentVariable("CONNECTION_STRING");
+                envFile = Path.GetFullPath("../../../asb.env");
+                if (File.Exists(envFile))
+                {
+                    var envs = DotEnv.Read(new DotEnvOptions(envFilePaths: [envFile], ignoreExceptions: false));
+                    connectionString = envs["CONNECTION_STRING"];
+                }
+
                 x.UsingAzureServiceBus((context, cfg) =>
-                   {
-                       cfg.Host(connectionString);
-                       cfg.ConfigureEndpoints(context);
-                   });
+                {
+                    cfg.Host(connectionString);
+
+                    cfg.ConfigureEndpoints(context);
+                });
+
                 break;
             case "RabbitMQ":
+                var host = Environment.GetEnvironmentVariable("RABBITMQ_HOST");
+                var port = Environment.GetEnvironmentVariable("RABBITMQ_PORT") ?? "5672";
+                var vHost = Environment.GetEnvironmentVariable("RABBITMQ_VIRTUALHOST");
+                var username = Environment.GetEnvironmentVariable("RABBITMQ_MANAGEMENT_API_USERNAME");
+                var password = Environment.GetEnvironmentVariable("RABBITMQ_MANAGEMENT_API_PASSWORD");
+                envFile = Path.GetFullPath("../../../rabbit.env");
+                if (File.Exists(envFile))
+                {
+                    var envs = DotEnv.Read(new DotEnvOptions(envFilePaths: [envFile], ignoreExceptions: false));
+                    host = envs["RABBITMQ_HOST"];
+                    port = envs["RABBITMQ_PORT"];
+                    vHost = envs["RABBITMQ_VIRTUALHOST"];
+                    username = envs["RABBITMQ_MANAGEMENT_API_USERNAME"];
+                    password = envs["RABBITMQ_MANAGEMENT_API_PASSWORD"];
+                }
+
                 x.UsingRabbitMq((context, cfg) =>
                 {
-                    cfg.Host("rabbitmq", 5672, "/", h =>
+                    cfg.Host(host, ushort.Parse(port), vHost, h =>
                     {
-                        h.Username("guest");
-                        h.Password("guest");
+                        h.Username(username);
+                        h.Password(password);
                     });
                     cfg.ConfigureEndpoints(context);
                 });

src/MassTransitShowcaseDemo.sln

@@ -2,11 +2,6 @@ Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio Version 17
 VisualStudioVersion = 17.9.34902.65
 MinimumVisualStudioVersion = 15.0.26730.12
-Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{7D29C905-CE3A-4D93-8271-7BA09CEE1631}"
-	ProjectSection(SolutionItems) = preProject
-		Directory.Build.props = Directory.Build.props
-	EndProjectSection
-EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ClientUI", "ClientUI\ClientUI.csproj", "{918001C1-B9F6-4E81-894B-128271E8D910}"
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Messages", "Messages\Messages.csproj", "{CFF586B0-0FA1-4F3C-B860-44BE86B0F341}"

src/compose-rabbitmq-user.yml

@@ -8,4 +8,32 @@ services:
     environment:
       - LICENSINGCOMPONENT_RABBITMQ_APIURL=${RABBITMQ_MANAGEMENT_API_URL}
       - LICENSINGCOMPONENT_RABBITMQ_USERNAME=${RABBITMQ_MANAGEMENT_API_USERNAME}
-      - LICENSINGCOMPONENT_RABBITMQ_PASSWORD=${RABBITMQ_MANAGEMENT_API_PASSWORD}
+      - LICENSINGCOMPONENT_RABBITMQ_PASSWORD=${RABBITMQ_MANAGEMENT_API_PASSWORD}
+  clientui:
+    environment:
+      - RABBITMQ_MANAGEMENT_API_USERNAME
+      - RABBITMQ_MANAGEMENT_API_PASSWORD
+      - RABBITMQ_HOST
+      - RABBITMQ_PORT
+      - RABBITMQ_VIRTUALHOST
+  sales:
+    environment:
+      - RABBITMQ_MANAGEMENT_API_USERNAME
+      - RABBITMQ_MANAGEMENT_API_PASSWORD
+      - RABBITMQ_HOST
+      - RABBITMQ_PORT
+      - RABBITMQ_VIRTUALHOST
+  shipping:
+    environment:
+      - RABBITMQ_MANAGEMENT_API_USERNAME
+      - RABBITMQ_MANAGEMENT_API_PASSWORD
+      - RABBITMQ_HOST
+      - RABBITMQ_PORT
+      - RABBITMQ_VIRTUALHOST
+  billing:
+    environment:
+      - RABBITMQ_MANAGEMENT_API_USERNAME
+      - RABBITMQ_MANAGEMENT_API_PASSWORD
+      - RABBITMQ_HOST
+      - RABBITMQ_PORT
+      - RABBITMQ_VIRTUALHOST