Refactor and migrate to RabbitMQ with MassTransit

Modernized codebase by adopting C# 9.0 features, including primary constructors for `DemoCommand` and `Product` classes. Transitioned from Azure Service Bus to RabbitMQ with MassTransit, removing Azure Service Bus dependencies and related configurations.

Updated `Program.cs` to streamline service registration, added `Serilog` initialization, and reorganized middleware. Enhanced `appsettings.json` and `launchSettings.json` with updated logging, Swagger metadata, and environment profiles.

Refactored `TokenProvider`, `MongoDictionarySerializer`, and `ExternalServiceClient` for improved readability and null safety. Removed unused controllers and Azure Service Bus extensions. Updated project files to conditionally include references based on build configuration.

These changes improve maintainability, align with best practices, and prepare the codebase for future scalability.

Author: GioemaNocco

src/demo/Genocs.Core.Demo.Contracts/DemoCommand.cs

@@ -2,9 +2,7 @@
 
 namespace Genocs.Core.Demo.Contracts;
 
-public class DemoCommand : ICommand
+public class DemoCommand(string payload) : ICommand
 {
-    public string Payload { get; }
-
-    public DemoCommand(string payload) => Payload = payload;
+    public string Payload { get; } = payload;
 }

src/demo/Genocs.Core.Demo.Contracts/OrderRequestEvent.cs

@@ -13,16 +13,9 @@ public class OrderRequest : IEvent
     public List<Product> Basket { get; set; } = default!;
 }
 
-public class Product
+public class Product(string sKU, int count, decimal price)
 {
-    public string SKU { get; private set; }
-    public int Count { get; private set; }
-    public decimal Price { get; private set; }
-
-    public Product(string sKU, int count, decimal price)
-    {
-        SKU = sKU;
-        Count = count;
-        Price = price;
-    }
+    public string SKU { get; private set; } = sKU;
+    public int Count { get; private set; } = count;
+    public decimal Price { get; private set; } = price;
 }

src/demo/Genocs.Core.Demo.HelloWorld/Genocs.Core.Demo.HelloWorld.csproj

@@ -5,19 +5,28 @@
         <Nullable>enable</Nullable>
         <ImplicitUsings>enable</ImplicitUsings>
         <UserSecretsId>genocs</UserSecretsId>
+        <IsPublishable>false</IsPublishable>
+        <IsPackable>false</IsPackable>
     </PropertyGroup>
 
     <ItemGroup>
         <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.8" />
     </ItemGroup>
 
-    <ItemGroup>
+    <ItemGroup Condition="'$(Configuration)' == 'Debug'">
         <ProjectReference Include="..\..\Genocs.Auth\Genocs.Auth.csproj" />
         <ProjectReference Include="..\..\Genocs.Logging\Genocs.Logging.csproj" />
         <ProjectReference Include="..\..\Genocs.OpenTelemetry\Genocs.OpenTelemetry.csproj" />
         <ProjectReference Include="..\..\Genocs.WebApi.Swagger\Genocs.WebApi.Swagger.csproj" />
     </ItemGroup>
 
+    <ItemGroup Condition="'$(Configuration)' != 'Debug'">
+        <PackageReference Include="Genocs.Auth" Version="7.3.*" />
+        <PackageReference Include="Genocs.Logging" Version="7.3.*" />
+        <PackageReference Include="Genocs.OpenTelemetry" Version="7.3.*" />
+        <PackageReference Include="Genocs.WebApi.Swagger" Version="7.3.*" />
+    </ItemGroup>
+
     <ItemGroup>
         <ProjectReference Include="..\Genocs.Core.Demo.Infrastructure\Genocs.Core.Demo.Infrastructure.csproj" />
     </ItemGroup>

src/demo/Genocs.Core.Demo.HelloWorld/Program.cs

@@ -7,6 +7,7 @@
 using Genocs.WebApi.Swagger;
 using Genocs.WebApi.Swagger.Docs;
 using Microsoft.AspNetCore.Authorization.Infrastructure;
+using Serilog;
 
 StaticLogger.EnsureInitialized();
 
@@ -15,9 +16,10 @@
 builder.Host
     .UseLogging();
 
-builder.AddGenocs()
-    .AddOpenTelemetry()
+builder
+    .AddGenocs()
     .AddJwt("simmetric_jwt")
+    .AddOpenTelemetry()
     .AddWebApi()
     .AddSwaggerDocs()
     .AddWebApiSwaggerDocs()
@@ -92,3 +94,5 @@
 app.MapGet("/onlyreader2", () => "ok").RequireAuthorization("Reader2");
 
 app.Run();
+
+Log.CloseAndFlush();

src/demo/Genocs.Core.Demo.HelloWorld/appsettings.Development.json

@@ -1,8 +1,8 @@
 {
   "app": {
-    "name": "Demo HelloWorld",
-    "service": "api-helloworld",
-    "instance": "01",
+    "name": "Hello World WebApi",
+    "service": "helloworld_webapi",
+    "instance": "1",
     "version": "v1.0",
     "displayBanner": true,
     "displayVersion": true
@@ -65,17 +65,11 @@
       "connectionString": "InstrumentationKey=1496274b-bda7-4ac6-88ab-9f73b4d3c7b8;IngestionEndpoint=https://italynorth-0.in.applicationinsights.azure.com/;LiveEndpoint=https://italynorth.livediagnostics.monitor.azure.com/;ApplicationId=c417f66d-3611-48a2-80fe-5a6d302bed4f"
     }
   },
-  "Logging": {
-    "LogLevel": {
-      "Default": "Debug",
-      "Microsoft.AspNetCore": "Debug"
-    }
-  },
   "swagger": {
     "enabled": true,
     "reDocEnabled": true,
-    "name": "Fiscanner",
-    "title": "Fiscanner API",
+    "name": "HelloWorldWebApi",
+    "title": "Hello World WebAPI",
     "version": "v2",
     "description": "The Fiscanner API provides comprehensive financial scanning and document processing capabilities. This API documentation is fully compliant with OpenAPI 3.0 standards and can be seamlessly integrated with LLM orchestrators such as LangChain, Semantic Kernel, and AutoGen. The documentation is also optimized for use with Microsoft Power Automate and Azure Logic Apps custom connectors, enabling easy workflow automation and integration scenarios.",
     "routePrefix": "swagger",

src/demo/Genocs.Core.Demo.HelloWorld/appsettings.json

@@ -14,10 +14,10 @@ namespace Genocs.Core.Demo.Infrastructure.SecurityAuthentication;
 /// </summary>
 public sealed class TokenProvider(IConfiguration configuration)
 {
-    public string Issuer => configuration["JwtSettings:Issuer"];
-    public string Audience => configuration["JwtSettings:Audience"];
-    public string Key => configuration["JwtSettings:Key"];
-    public int Expiration => int.Parse(configuration["JwtSettings:Expiration"]);
+    public string? Issuer => configuration["JwtSettings:Issuer"];
+    public string? Audience => configuration["JwtSettings:Audience"];
+    public string? Key => configuration["JwtSettings:Key"];
+    public int Expiration => int.Parse(configuration["JwtSettings:Expiration"] ?? "0");
 
     /// <summary>
     /// This method creates a token using the JwtSecurityTokenHandler class.
@@ -32,8 +32,8 @@ public string CreateToken()
         {
             Subject = new ClaimsIdentity(new Claim[]
             {
-                new Claim(ClaimTypes.Name, "username"),
-                new Claim(ClaimTypes.Role, "role")
+                new(ClaimTypes.Name, "username"),
+                new(ClaimTypes.Role, "role")
             }),
             Expires = DateTime.UtcNow.AddMinutes(Expiration),
             SigningCredentials = new SigningCredentials(new SymmetricSecurityKey(key), SecurityAlgorithms.HmacSha256Signature)
@@ -55,8 +55,8 @@ public string CreateTokenWithJsonWebTokenHandler()
         {
             Subject = new ClaimsIdentity(new Claim[]
             {
-                new Claim(ClaimTypes.Name, "username"),
-                new Claim(ClaimTypes.Role, "role")
+                new(ClaimTypes.Name, "username"),
+                new(ClaimTypes.Role, "role")
             }),
             Expires = DateTime.UtcNow.AddMinutes(Expiration),
             SigningCredentials = new SigningCredentials(new SymmetricSecurityKey(key), SecurityAlgorithms.HmacSha256Signature)

src/demo/Genocs.Core.Demo.Infrastructure/SecurityAuthentication/TokenProvider.cs

@@ -9,12 +9,13 @@ public class FileUploadController : ControllerBase
 
     /// <summary>
     /// This is an example of file Upload using API
-    /// Use it as a reference
+    /// Use it as a reference.
     /// </summary>
     /// <param name="files"></param>
     /// <param name="fileTag"></param>
     /// <returns></returns>
-    [Route(""), HttpPost]
+    [Route("")]
+    [HttpPost]
     [ProducesResponseType(StatusCodes.Status200OK, Type = typeof(string))]
     [ProducesResponseType(StatusCodes.Status400BadRequest)]
     public async Task<IActionResult> PostUploadAndEvaluate([FromForm(Name = "docs")] List<IFormFile> files, [FromQuery] string fileTag)

src/demo/Genocs.Core.Demo.WebApi/Controllers/FileUploadController.cs

@@ -56,7 +56,6 @@ await _publishEndpoint.Publish<OrderSubmitted>(new
         return Ok("Sent");
     }
 
-
     //[HttpPost("SubmitOrder")]
     //public async Task<IActionResult> PostSubmitOrder()
     //{