Initial release

CrowdParlay.Communication.sln

@@ -2,11 +2,20 @@
 Microsoft Visual Studio Solution File, Format Version 12.00
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{6397F4A6-059A-4591-AB2F-9E0D28F8E619}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CrowdParlay.Communication", "src\CrowdParlay.Communication\CrowdParlay.Communication.csproj", "{2A29A80A-0CB5-4914-B4D4-9595E667F874}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
 		Release|Any CPU = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{2A29A80A-0CB5-4914-B4D4-9595E667F874}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{2A29A80A-0CB5-4914-B4D4-9595E667F874}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2A29A80A-0CB5-4914-B4D4-9595E667F874}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{2A29A80A-0CB5-4914-B4D4-9595E667F874}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(NestedProjects) = preSolution
+		{2A29A80A-0CB5-4914-B4D4-9595E667F874} = {6397F4A6-059A-4591-AB2F-9E0D28F8E619}
 	EndGlobalSection
 EndGlobal

README.md

@@ -0,0 +1,38 @@
+# Crowd Parlay's .NET *communication* tools
+
+### Technologies
+`C#` `.NET 7` `MassTransit` `RabbitMQ`
+
+### Responsibilities
+- Platform-wide messaging types
+- Common MassTransit configuration
+- RabbitMQ topology maintenance
+
+### Integration
+Given `MassTransit.RabbitMQ` NuGet package and `IServiceCollection services` instance, `CrowdParlay.Communication` gets integrated as follows:
+
+```csharp
+using CrowdParlay.Communication;
+using MassTransit;
+```
+
+```csharp
+services.AddMassTransit(bus => bus.UsingRabbitMq((context, configurator) =>
+{
+    var amqpServerUrl =
+        configuration["RABBITMQ_AMQP_SERVER_URL"]
+        ?? throw new InvalidOperationException("Missing required configuration 'RABBITMQ_AMQP_SERVER_URL'.");
+
+    configurator.Host(amqpServerUrl);
+    configurator.ConfigureEndpoints(context);
+    configurator.ConfigureTopology(); // This extension method is defined in CrowdParlay.Communication
+}));
+```
+
+Now, inject `IPublishEndpoint _broker` to publish messages like that:
+
+```csharp
+// UserCreatedEvent type is defined in CrowdParlay.Communication
+var @event = new UserCreatedEvent(user.Id.ToString(), user.Username, user.DisplayName, user.AvatarUrl);
+await _broker.Publish(@event, cancellationToken);
+```

src/CrowdParlay.Communication/CrowdParlay.Communication.csproj

@@ -0,0 +1,27 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <TargetFramework>net9.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+        <Authors>CrowdParlay</Authors>
+        <Version>2.0.2</Version>
+        <Description>CrowdParlay's common .NET API for platform-wide communication.</Description>
+        <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
+        <RepositoryUrl>https://gitlab.otter.su/crowdparlay/dotnet-communication</RepositoryUrl>
+        <PackageIcon>logo.png</PackageIcon>
+    </PropertyGroup>
+
+    <ItemGroup>
+      <None Include="..\..\docs\logo.png">
+        <Pack>True</Pack>
+        <PackagePath></PackagePath>
+        <Link>logo.png</Link>
+      </None>
+    </ItemGroup>
+
+    <ItemGroup>
+      <PackageReference Include="MassTransit.RabbitMQ" Version="8.5.0" />
+    </ItemGroup>
+
+</Project>

src/CrowdParlay.Communication/MassTransitExtensions.cs

@@ -0,0 +1,18 @@
+using MassTransit;
+
+namespace CrowdParlay.Communication;
+
+public static class MassTransitExtensions
+{
+    public static void ConfigureTopology(this IRabbitMqBusFactoryConfigurator configurator)
+    {
+        configurator.Message<UserCreatedEvent>(x => x.SetEntityName("user"));
+        configurator.Send<UserCreatedEvent>(x => x.UseRoutingKeyFormatter(_ => "user.created"));
+
+        configurator.Message<UserUpdatedEvent>(x => x.SetEntityName("user"));
+        configurator.Send<UserUpdatedEvent>(x => x.UseRoutingKeyFormatter(_ => "user.updated"));
+
+        configurator.Message<UserDeletedEvent>(x => x.SetEntityName("user"));
+        configurator.Send<UserDeletedEvent>(x => x.UseRoutingKeyFormatter(_ => "user.deleted"));
+    }
+}

src/CrowdParlay.Communication/Messages.cs

@@ -0,0 +1,5 @@
+namespace CrowdParlay.Communication;
+
+public record UserCreatedEvent(string UserId, string Username, string DisplayName, string? AvatarUrl);
+public record UserUpdatedEvent(string UserId, string Username, string DisplayName, string? AvatarUrl);
+public record UserDeletedEvent(string UserId);