Merge pull request #70 from Particular/john/env

Read envs file

Author: irinascurtu

README.md

@@ -10,49 +10,35 @@ To run the code sample you have 3 options in terms of transports:
 The RabbitMQ Broker is started as part of the docker compose process
 >
 
-Run docker command bellow from the `src` folder in a CLI
+Run docker command below from the `src` folder in a CLI
 ```cmd
 docker compose -f docker-compose-base.yml -f compose-rabbitmq.yml --env-file rabbit.env up -d
 ```
 ## **Azure ServiceBus**
 
-Configure the access to your Azure Service Bus namespace by editing the variables in `asb.env`  
+Configure the access to your Azure Service Bus namespace by editing the variables in `src/asb.env`  
 
-```cmd
+```env
 CONNECTIONSTRING="Endpoint=sb://[NAMESPACE].servicebus.windows.net/;SharedAccessKeyName=[KEYNAME];SharedAccessKey=[KEY]"
 ```
 
-Set the same environment variables on your machine:
-
-```cmd
-setx CONNECTIONSTRING_AZURESERVICEBUS "Endpoint=sb://[NAMESPACE].servicebus.windows.net/;SharedAccessKeyName=[KEYNAME];SharedAccessKey=[KEY]"
-```
-
-Run docker command bellow from the `src` folder in a CLI
+Run docker command below from the `src` folder in a CLI
 
 ```cmd
 docker compose -f docker-compose-base.yml -f compose-azure.yml --env-file asb.env up -d
 ```
 
 ## **Amazon SQS**
 
-Configure the access to your SQS namespace by editing the variables in `sqs.env`  
+Configure the access to your SQS namespace by editing the variables in `src/sqs.env`  
 
-```cmd
+```env
 AWS_REGION="<region>"
 AWS_ACCESS_KEY_ID="<access-key>"
 AWS_SECRET_ACCESS_KEY="<secret-access-key>"
 ```
 
-Set the same environment variables on your machine:
-
-```cmd
-setx AWS_REGION "<region>"
-setx AWS_ACCESS_KEY_ID "<access-key>"
-setx AWS_SECRET_ACCESS_KEY "<secret-access-key>"
-```
-
-Run docker command bellow from the `src` folder in a CLI
+Run docker command below from the `src` folder in a CLI
 
 ```cmd
 docker compose -f docker-compose-base.yml -f compose-sqs.yml --env-file sqs.env up -d

src/Helper/BusRegistrationConfiguratorExt.cs

@@ -1,4 +1,5 @@
-using MassTransit;
+using dotenv.net;
+using MassTransit;
 
 public static class BusRegistrationConfiguratorExt
 {
@@ -10,10 +11,11 @@ public static void SetupTransport(this IBusRegistrationConfigurator x, string[]
         {
             x.UsingAmazonSqs((ctx, cfg) =>
             {
-                cfg.Host(Environment.GetEnvironmentVariable("AWS_REGION"), h =>
+                var envs = DotEnv.Read(new DotEnvOptions(envFilePaths: [Path.GetFullPath("../../../sqs.env")]));
+                cfg.Host(envs["AWS_REGION"], h =>
                 {
-                    h.AccessKey(Environment.GetEnvironmentVariable("AWS_ACCESS_KEY_ID"));
-                    h.SecretKey(Environment.GetEnvironmentVariable("AWS_SECRET_ACCESS_KEY"));
+                    h.AccessKey(envs["AWS_ACCESS_KEY_ID"]);
+                    h.SecretKey(envs["AWS_SECRET_ACCESS_KEY"]);
                 });
 
                 cfg.ConfigureEndpoints(ctx);
@@ -22,10 +24,10 @@ public static void SetupTransport(this IBusRegistrationConfigurator x, string[]
         }
         else if (args.Contains("--azureservicebus"))
         {
-
+            var envs = DotEnv.Read(new DotEnvOptions(envFilePaths: [Path.GetFullPath("../../../asb.env")], ignoreExceptions: false));
             x.UsingAzureServiceBus((context, cfg) =>
             {
-                cfg.Host(Environment.GetEnvironmentVariable("CONNECTIONSTRING_AZURESERVICEBUS"));
+                cfg.Host(envs["CONNECTIONSTRING"]);
 
                 cfg.ConfigureEndpoints(context);
             });
@@ -64,8 +66,9 @@ public static void SetupTransport(this IBusRegistrationConfigurator x, string[]
 
             if (cfg is IServiceBusReceiveEndpointConfigurator sb)
             {
-                sb.ConfigureDeadLetterQueueDeadLetterTransport();
-                sb.ConfigureDeadLetterQueueErrorTransport();
+                // Uncomment this code to use deadletter
+                //sb.ConfigureDeadLetterQueueDeadLetterTransport();
+                //sb.ConfigureDeadLetterQueueErrorTransport();
             }
         });
     }

src/Helper/Helper.csproj

@@ -6,6 +6,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="dotenv.net" Version="3.2.1" />
     <PackageReference Include="MassTransit.Azure.ServiceBus.Core" Version="8.3.0" />
     <PackageReference Include="MassTransit.RabbitMQ" Version="8.3.0" />
     <PackageReference Include="MassTransit.AmazonSQS" Version="8.3.0" />

src/asb.env

@@ -1,3 +1,3 @@
 TRANSPORTTYPE="NetStandardAzureServiceBus"
 # Update this variable with the value from Azure portal 
-CONNECTIONSTRING="Endpoint=sb://[NAMESPACE].servicebus.windows.net/;SharedAccessKeyName=[KEYNAME];SharedAccessKey=[KEY]"
+CONNECTIONSTRING="Endpoint=sb://masstr.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=XzF01z+3BcP5qWJUq7ba0Nm00nM7T7wS3+ASbMUaZ1Q="

src/sqs.env

@@ -1,6 +1,6 @@
 TRANSPORTTYPE="AmazonSQS"
 
 # Update these variable values
-AWS_REGION="<region>"
-AWS_ACCESS_KEY_ID="<access-key>"
-AWS_SECRET_ACCESS_KEY="<secret-access-key>"
+AWS_REGION="us-east-1"
+AWS_ACCESS_KEY_ID="AKIAJQHSOSAFGR4X6FPQ"
+AWS_SECRET_ACCESS_KEY="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"