Add NotificationCreated analytics event (#43)

Author: Bardin08

src/Api/Endpoints/Notifications/CreateNotificationEndpoint.cs

@@ -6,16 +6,11 @@
 
 namespace Api.Endpoints.Notifications;
 
-internal sealed class CreateNotificationEndpoint :
+internal sealed class CreateNotificationEndpoint(INotificationsService notificationsService) :
     Endpoint<CreateNotificationRequest, ApiResponse<NotificationResponse>, CreateNotificationMapper>
 {
-    private readonly INotificationsService _notificationsService;
-
-    public CreateNotificationEndpoint(INotificationsService notificationsService)
-    {
-        _notificationsService = notificationsService;
-    }
-
+    private readonly INotificationsService _notificationsService = notificationsService;
+    
     public override void Configure()
     {
         Verbs(Http.POST);

src/Api/Endpoints/Templates/CreateTemplateEndpoint.cs

@@ -6,16 +6,11 @@
 
 namespace Api.Endpoints.Templates;
 
-internal sealed class CreateTemplateEndpoint :
+internal sealed class CreateTemplateEndpoint(ITemplatesService templatesService) :
     Endpoint<CreateTemplateRequest, ApiResponse<TemplateResponse>, CreateTemplatesMapper>
 {
-    private readonly ITemplatesService _templatesService;
-
-    public CreateTemplateEndpoint(ITemplatesService templatesService)
-    {
-        _templatesService = templatesService;
-    }
-
+    private readonly ITemplatesService _templatesService = templatesService;
+    
     public override void Configure()
     {
         Verbs(Http.POST);

src/Api/Endpoints/Templates/DeleteTemplatesEndpoint.cs

@@ -5,15 +5,10 @@
 
 namespace Api.Endpoints.Templates;
 
-internal sealed class DeleteTemplatesEndpoint : Endpoint<DeleteTemplatesRequest>
+internal sealed class DeleteTemplatesEndpoint(ITemplatesService templatesService) : Endpoint<DeleteTemplatesRequest>
 {
-    private readonly ITemplatesService _templatesService;
-
-    public DeleteTemplatesEndpoint(ITemplatesService templatesService)
-    {
-        _templatesService = templatesService;
-    }
-
+    private readonly ITemplatesService _templatesService = templatesService;
+    
     public override void Configure()
     {
         Verbs(Http.DELETE);

src/Api/Endpoints/Templates/GetTemplatesEndpoint.cs

@@ -6,16 +6,11 @@
 
 namespace Api.Endpoints.Templates;
 
-internal sealed class GetTemplatesEndpoint :
+internal sealed class GetTemplatesEndpoint(ITemplatesService templatesService) :
     Endpoint<GetTemplatesRequest, ApiResponse<TemplateResponse[]>, GetTemplateMapper>
 {
-    private readonly ITemplatesService _templatesService;
-
-    public GetTemplatesEndpoint(ITemplatesService templatesService)
-    {
-        _templatesService = templatesService;
-    }
-
+    private readonly ITemplatesService _templatesService = templatesService;
+    
     public override void Configure()
     {
         Verbs(Http.GET);

src/Api/Endpoints/Templates/UpdateTemplateEndpoint.cs

@@ -6,16 +6,11 @@
 
 namespace Api.Endpoints.Templates;
 
-internal sealed class UpdateTemplateEndpoint :
+internal sealed class UpdateTemplateEndpoint(ITemplatesService templatesService) :
     Endpoint<UpdateTemplateRequest, ApiResponse<TemplateResponse>, UpdateTemplateMapper>
 {
-    private readonly ITemplatesService _templatesService;
-
-    public UpdateTemplateEndpoint(ITemplatesService templatesService)
-    {
-        _templatesService = templatesService;
-    }
-
+    private readonly ITemplatesService _templatesService = templatesService;
+    
     public override void Configure()
     {
         Verbs(Http.PUT);

src/Core/Core.csproj

@@ -9,7 +9,7 @@
     <ItemGroup>
       <PackageReference Include="ErrorOr" Version="1.3.0" />
       <PackageReference Include="Microsoft.Extensions.Configuration.Abstractions" Version="8.0.0" />
-      <PackageReference Include="trumpee.masstransit.messages" Version="1.0.0.16" />
+      <PackageReference Include="trumpee.masstransit.messages" Version="1.0.0.17" />
     </ItemGroup>
 
     <ItemGroup>

src/Core/Services/NotificationService.cs

@@ -3,13 +3,15 @@
 using Core.Models.Notifications;
 using ErrorOr;
 using Infrastructure.Persistence.MassTransit;
+using Infrastructure.Persistence.MassTransit.Analytics;
 using Infrastructure.Persistence.Mongo.Abstractions;
 using Trumpee.MassTransit.Messages.Notifications;
 
 namespace Core.Services;
 
 internal class NotificationService(
         ITemplateFillerClient massTransitClient,
+        INotificationsAnalyticsClient notificationsAnalyticsClient,
         INotificationsRepository notificationsRepository)
     : INotificationsService
 {
@@ -21,10 +23,15 @@ public async Task<ErrorOr<NotificationDto>> CreateNotification(
         ct.ThrowIfCancellationRequested();
         await notificationsRepository.InsertOne(notification);
 
-        var deliveryRequests = CreateDeliveryRequests(dto);
+        var deliveryRequests = CreateDeliveryRequests(dto).ToList();
 
         await massTransitClient.SendMessages(deliveryRequests, string.Empty);
-
+        foreach (var deliveryRequest in deliveryRequests)
+        {
+            await notificationsAnalyticsClient
+                .SendNotificationCreated(deliveryRequest.NotificationId, ct);
+        }
+        
         dto = dto with { Id = notification.Id.ToString() };
         return dto;
     }

src/Infrastructure/Infrastructure.csproj

@@ -16,7 +16,7 @@
       <PackageReference Include="MongoDB.Driver" Version="2.22.0" />
       <PackageReference Include="MongoDB.Driver.Core" Version="2.22.0" />
       <PackageReference Include="Trumpee.MassTransit" Version="1.0.0.16" />
-      <PackageReference Include="trumpee.masstransit.messages" Version="1.0.0.16" />
+      <PackageReference Include="trumpee.masstransit.messages" Version="1.0.0.17" />
     </ItemGroup>
 
 </Project>

src/Infrastructure/Persistence/DependencyInjection.cs

@@ -36,6 +36,7 @@ private static void AddMassTransit(this IServiceCollection services, IConfigurat
 
         services.AddScoped<ITemplateFillerClient, TemplateFillerClient>();
         services.AddScoped<IUserAnalyticsClient, UserAnalyticsClient>();
+        services.AddScoped<INotificationsAnalyticsClient, NotificationsAnalyticsClient>();
     }
 
     private static void AddAuth0(this IServiceCollection services, IConfiguration config)

src/Infrastructure/Persistence/MassTransit/Analytics/INotificationsAnalyticsClient.cs

@@ -0,0 +1,7 @@
+namespace Infrastructure.Persistence.MassTransit.Analytics;
+
+public interface INotificationsAnalyticsClient
+{
+    Task SendNotificationCreated(string notificationId, CancellationToken ct);
+    Task SendNotificationReceived(string notificationId, CancellationToken ct);
+}

src/Infrastructure/Persistence/MassTransit/Analytics/NotificationsAnalyticsClient.cs

@@ -0,0 +1,34 @@
+using MassTransit;
+using Trumpee.MassTransit;
+using Trumpee.MassTransit.Messages.Analytics.Notifications;
+using Trumpee.MassTransit.Messages.Analytics.Notifications.Payloads;
+
+namespace Infrastructure.Persistence.MassTransit.Analytics;
+
+public class NotificationsAnalyticsClient(
+    ISendEndpointProvider endpointProvider) : INotificationsAnalyticsClient
+{
+    private const string EventSource = "Trumpee Gateway";
+    
+    private readonly ISendEndpointProvider _endpointProvider = endpointProvider;
+    
+    private static readonly string NotificationCreated =
+        QueueNames.Analytics.Notifications(typeof(NotificationCreatedPayload));
+    
+    public Task SendNotificationCreated(string notificationId, CancellationToken ct)
+    {
+        var analyticsEvent = Notification.Created(EventSource, notificationId);
+        return SendEvent(analyticsEvent, NotificationCreated, ct);
+    }
+    
+    public Task SendNotificationReceived(string notificationId, CancellationToken ct)
+    {
+        throw new NotImplementedException();
+    }
+    
+    private async Task SendEvent<T>(T analyticsEvent, string queueName, CancellationToken ct) where T : class
+    {
+        var endpoint = await _endpointProvider.GetSendEndpoint(new Uri(queueName));
+        await endpoint.Send(analyticsEvent, ct);
+    }
+}