Stats

Core/Services/CollectionsService.cs

@@ -75,4 +75,9 @@ private async Task<Collection> VerifyCollectionExistsAndUserHasAccess(Guid colle
         if (collection.UserEmail != loggedInUser) throw new NoAccessException("You don't have access to this collection");
         return collection;
     }
+
+    public async Task<int> GetTotalCollectionsCount(string email)
+    {
+        return await collectionsRepository.GetTotalCollectionsCount(email);
+    }
 }

Core/Services/PlantService.cs

@@ -134,6 +134,16 @@ public async Task<List<GetCriticalPlantDto>> GetCriticalPlants(string requesterE
 
         return criticalPlants;
     }
+
+    public async Task<int> GetHappyPlantsCount(string userEmail)
+    {
+        return await plantRepository.GetHappyPlantsCount(userEmail);
+    }
+
+    public async Task<int> GetTotalPlantsCount(string userEmail)
+    {
+        return await plantRepository.GetTotalPlantsCount(userEmail);
+    }
 
     private string GenerateRandomNickname()
     {

Infrastructure/Repositories/CollectionsRepository.cs

@@ -67,4 +67,11 @@ public async Task RemovePlantFromCollection(Collection collection, Plant plant)
         collection.Plants.Remove(plant);
         await applicationDbContext.SaveChangesAsync();
     }
+
+    public async Task<int> GetTotalCollectionsCount(string email)
+    {
+        await using var applicationDbContext = await dbContextFactory.CreateDbContextAsync();
+        return await applicationDbContext.Collections
+            .CountAsync(collection => collection.UserEmail == email);
+    }
 }

Infrastructure/Repositories/PlantRepository.cs

@@ -108,10 +108,26 @@
                     .ThenByDescending(log => log.TimeStamp)
                     .FirstOrDefault()
             })
             .OrderBy(p => p.WorstMood.Mood)
             .ThenByDescending(p => p.WorstMood.TimeStamp)
             .Take(3)
             .Select(p => p.Plant)
             .ToListAsync();
     }
+
+    public async Task<int> GetHappyPlantsCount(string userEmail)
+    {
+        await using var context = await dbContextFactory.CreateDbContextAsync();
+        return await context.Plants
+            .Include(plant => plant.ConditionsLogs)
+            .Where(p => p.UserEmail == userEmail && p.ConditionsLogs.Count != 0)
+            .CountAsync(p => p.ConditionsLogs.OrderByDescending(log => log.TimeStamp).FirstOrDefault()!.Mood > 2);
+    }
+
+    public async Task<int> GetTotalPlantsCount(string userEmail)
+    {
+        await using var context = await dbContextFactory.CreateDbContextAsync();
+        return await context.Plants
+            .CountAsync(p => p.UserEmail == userEmail);
+    }
 }

api/Events/Auth/Client/ClientWantsToLogIn.cs

@@ -1,4 +1,5 @@
 using api.Events.Auth.Server;
+using api.Events.Global;
 using api.Extensions;
 using Core.Services;
 using Core.Services.External.BlobStorage;
@@ -48,7 +49,3 @@ public override async Task Handle(ClientWantsToLogInDto dto, IWebSocketConnectio
     }
 }
 
-public class ServerSendsUserInfo : BaseDto
-{
-    public GetUserDto GetUserDto { get; set; } = null!;
-}

api/Events/Global/ServerSendsUserInfo.cs

@@ -0,0 +1,9 @@
+using lib;
+using Shared.Dtos;
+
+namespace api.Events.Global;
+
+public class ServerSendsUserInfo : BaseDto
+{
+    public GetUserDto GetUserDto { get; set; } = null!;
+}

api/Events/Stats/ClientWantsStats.cs

@@ -0,0 +1,48 @@
+using api.Extensions;
+using Core.Services;
+using Fleck;
+using lib;
+using Shared.Models;
+
+namespace api.Events.Stats;
+
+public class ClientWantsStatsDto : BaseDtoWithJwt
+{
+
+}
+
+public class ClientWantsStats(PlantService plantService, CollectionsService collectionsService, JwtService jwtService) : BaseEventHandler<ClientWantsStatsDto>
+{
+    public override async Task Handle(ClientWantsStatsDto dto, IWebSocketConnection socket)
+    {
+        var email = jwtService.GetEmailFromJwt(dto.Jwt!);
+
+        var totalPlants = await plantService.GetTotalPlantsCount(email);
+        var happyPlants = await plantService.GetHappyPlantsCount(email);
+        var collections = await collectionsService.GetTotalCollectionsCount(email);
+
+        var statsDto = new ServerSendsStats
+        {
+            Stats = new Stats
+            {
+                TotalPlants = totalPlants,
+                HappyPlants = happyPlants,
+                Collections = collections
+            }
+        };
+
+        socket.SendDto(statsDto);
+    }
+}
+
+public class ServerSendsStats : BaseDto
+{
+    public Stats Stats { get; set; }
+}
+
+public class Stats
+{
+    public int TotalPlants { get; set; }
+    public int HappyPlants { get; set; }
+    public int Collections { get; set; }
+}

api/Events/User/ClientWantsUserInfo.cs

@@ -0,0 +1,38 @@
+using api.Events.Global;
+using api.Extensions;
+using Core.Services;
+using Core.Services.External.BlobStorage;
+using Fleck;
+using lib;
+using Shared.Dtos;
+using Shared.Models;
+
+namespace api.Events.User;
+
+public class ClientWantsUserInfoDto : BaseDtoWithJwt
+{
+
+}
+
+public class ClientWantsUserInfo(UserService userService, JwtService jwtService, IBlobStorageService blobStorageService)
+    : BaseEventHandler<ClientWantsUserInfoDto>
+{
+    public override async Task Handle(ClientWantsUserInfoDto dto, IWebSocketConnection socket)
+    {
+        var email = jwtService.GetEmailFromJwt(dto.Jwt);
+        var user = await userService.GetUserByEmail(email);
+        var getUserDto = new GetUserDto
+        {
+            UserEmail = user.UserEmail,
+            Username = user.UserName
+        };
+        if (user.BlobUrl != null)
+        {
+            getUserDto.BlobUrl = blobStorageService.GenerateSasUri(user.BlobUrl, false);
+        }
+        socket.SendDto(new ServerSendsUserInfo
+        {
+            GetUserDto = getUserDto
+        });
+    }
+}