Add analytics events

Author: Bardin08

src/Api/Endpoints/Auth/RegisterEndpoint.cs

@@ -1,5 +1,6 @@
 using Api.Models.Requests.Auth;
 using Api.Models.Responses;
+using Core.Abstractions;
 using FastEndpoints;
 using Infrastructure.Auth0.Abstractions;
 using Infrastructure.Auth0.Models;
@@ -8,10 +9,12 @@ namespace Api.Endpoints.Auth;
 
 public class RegisterEndpoint(
     IAuthService authService,
+    IUserPreferencesService userPreferencesService,
     ILogger<RegisterEndpoint> logger)
     : Endpoint<RegisterRequest, ApiResponse<UserInfoResponse>>
 {
     private readonly IAuthService _authService = authService;
+    private readonly IUserPreferencesService _userPreferencesService = userPreferencesService;
     private readonly ILogger<RegisterEndpoint> _logger = logger;
 
     public override void Configure()
@@ -35,6 +38,8 @@ public override async Task HandleAsync(
             }
             else
             {
+                await _userPreferencesService.CreateUserPreferences(registrationResponse.UserId, ct);
+
                 var tokenInfo = new UserTokenResponse(
                     registrationResponse.TokenInfo.Token,
                     registrationResponse.TokenInfo.ExpiresIn);

src/Core/Services/UserPreferencesService.cs

@@ -3,6 +3,7 @@
 using Core.Mappers;
 using Core.Models.UserPreferences;
 using ErrorOr;
+using Infrastructure.Persistence.MassTransit.Analytics;
 using Infrastructure.Persistence.Mongo.Abstractions;
 using Infrastructure.Persistence.Mongo.Entities.Preferences;
 using Infrastructure.Persistence.Mongo.Specifications;
@@ -11,9 +12,11 @@
 namespace Core.Services;
 
 public class UserPreferencesService(
+    IUserAnalyticsClient userAnalyticsClient,
     IMongoRepository<UserPreferences> userPreferencesRepository,
     ILogger<UserPreferencesService> logger) : IUserPreferencesService
 {
+    private readonly IUserAnalyticsClient _userAnalyticsClient = userAnalyticsClient;
     private readonly IMongoRepository<UserPreferences> _userPreferencesRepository = userPreferencesRepository;
     private readonly ILogger<UserPreferencesService> _logger = logger;
 
@@ -30,6 +33,10 @@ public async Task<ErrorOr<UserPreferencesDto>> CreateUserPreferences(string user
             var entity = UserPreferencesMapper.ToEntity(defaultPreferences);
             await _userPreferencesRepository.InsertOne(entity);
 
+            // here user mail should be sent
+            await _userAnalyticsClient.SendUserAction(
+                userId, "UserPreferencesCreated", "recipient", "User's Preferences", ct);
+
             return UserPreferencesMapper.ToDto(entity);
         }
         catch (Exception ex)
@@ -54,7 +61,11 @@ public async Task<ErrorOr<UserPreferencesDto>> UpdateUserPreferences(
 
             var entity = UserPreferencesMapper.UpdateEntity(currentPreferences, userPreferences);
             await _userPreferencesRepository.Replace(entity);
-            
+
+            // here user mail should be sent
+            await _userAnalyticsClient.SendUserAction(
+                userPreferences.UserId, "UserPreferencesCreated", "recipient", "User's Preferences", ct);
+
             return UserPreferencesMapper.ToDto(entity);
         }
         catch (Exception ex)