Add themed gear events with gold & XP bonuses

src/Application/Common/Interfaces/ICrpgDbContext.cs

@@ -13,6 +13,7 @@
 using Crpg.Domain.Entities.Settings;
 using Crpg.Domain.Entities.Settlements;
 using Crpg.Domain.Entities.Terrains;
+using Crpg.Domain.Entities.Themes;
 using Crpg.Domain.Entities.Users;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.ChangeTracking;
@@ -60,6 +61,8 @@ public interface ICrpgDbContext
     DbSet<QuestDefinition> QuestDefinitions { get; set; }
     DbSet<UserQuest> UserQuests { get; set; }
     DbSet<WeeklyQuestAssignment> WeeklyQuestAssignments { get; set; }
+    DbSet<Theme> Themes { get; set; }
+    DbSet<ThemeEvent> ThemeEvents { get; set; }
 
     EntityEntry<TEntity> Entry<TEntity>(TEntity entity) where TEntity : class;
     Task<int> SaveChangesAsync(CancellationToken cancellationToken = default);

src/Application/Common/Results/CommonErrors.cs

@@ -569,4 +569,16 @@ public static Error UserItemMaxRankReached(int userItemId, int maxRank) =>
         Title = "Quest not completed",
         Detail = $"Quest with id '{userQuestId}' requires {requiredValue} but current progress is {currentValue}",
     };
+
+    public static Error ThemeNotFound(int themeId) => new(ErrorType.NotFound, ErrorCode.ThemeNotFound)
+    {
+        Title = "Theme not found",
+        Detail = $"Theme with id '{themeId}' could not be found.",
+    };
+
+    internal static Error ThemeEventNotFound(int themeEventId) => new(ErrorType.NotFound, ErrorCode.ThemeEventNotFound)
+    {
+        Title = "Theme event not found",
+        Detail = $"Theme event with id '{themeEventId}' could not be found.",
+    };
 }

src/Application/Common/Results/ErrorCode.cs

@@ -100,4 +100,6 @@ public enum ErrorCode
     QuestExpired,
     QuestDefinitionNotFound,
     QuestNotCompleted,
+    ThemeNotFound,
+    ThemeEventNotFound,
 }

src/Application/Items/Commands/AddThemesToItemsCommand.cs

@@ -0,0 +1,69 @@
+using Crpg.Application.Common.Interfaces;
+using Crpg.Application.Common.Mediator;
+using Crpg.Application.Common.Results;
+using FluentValidation;
+using Microsoft.EntityFrameworkCore;
+
+namespace Crpg.Application.Items.Commands;
+
+/// <summary>
+/// Adds a set of themes to several item families at once. The themes are applied to every rank variant sharing one
+/// of the given <see cref="Crpg.Domain.Entities.Items.Item.BaseId"/>s, so upgrades stay in sync. Existing themes on
+/// those items are preserved; themes already present are not duplicated.
+/// </summary>
+public record AddThemesToItemsCommand : IMediatorRequest
+{
+    public IList<string> BaseIds { get; init; } = new List<string>();
+    public IList<int> ThemeIds { get; init; } = new List<int>();
+
+    public class Validator : AbstractValidator<AddThemesToItemsCommand>
+    {
+        public Validator()
+        {
+            RuleFor(r => r.BaseIds).NotEmpty();
+            RuleFor(r => r.ThemeIds).NotEmpty();
+        }
+    }
+
+    internal class Handler(ICrpgDbContext db) : IMediatorRequestHandler<AddThemesToItemsCommand>
+    {
+        public async ValueTask<Result> Handle(AddThemesToItemsCommand req, CancellationToken cancellationToken)
+        {
+            var baseIds = req.BaseIds.Distinct().ToList();
+            var items = await db.Items
+                .Include(i => i.Themes)
+                .Where(i => baseIds.Contains(i.BaseId))
+                .ToListAsync(cancellationToken);
+
+            var foundBaseIds = items.Select(i => i.BaseId).ToHashSet();
+            string? missingBaseId = baseIds.FirstOrDefault(id => !foundBaseIds.Contains(id));
+            if (missingBaseId != null)
+            {
+                return new(CommonErrors.ItemNotFound(missingBaseId));
+            }
+
+            var themeIds = req.ThemeIds.Distinct().ToList();
+            var themes = await db.Themes.Where(t => themeIds.Contains(t.Id)).ToListAsync(cancellationToken);
+            if (themes.Count != themeIds.Count)
+            {
+                int missingThemeId = themeIds.First(id => themes.All(t => t.Id != id));
+                return new(CommonErrors.ThemeNotFound(missingThemeId));
+            }
+
+            foreach (var item in items)
+            {
+                foreach (var theme in themes)
+                {
+                    if (item.Themes.All(t => t.Id != theme.Id))
+                    {
+                        item.Themes.Add(theme);
+                    }
+                }
+            }
+
+            await db.SaveChangesAsync(cancellationToken);
+
+            return Result.NoErrors;
+        }
+    }
+}

src/Application/Items/Commands/RemoveThemesFromItemsCommand.cs

@@ -0,0 +1,63 @@
+using Crpg.Application.Common.Interfaces;
+using Crpg.Application.Common.Mediator;
+using Crpg.Application.Common.Results;
+using FluentValidation;
+using Microsoft.EntityFrameworkCore;
+
+namespace Crpg.Application.Items.Commands;
+
+/// <summary>
+/// Removes a set of themes from several item families at once. The themes are removed from every rank variant
+/// sharing one of the given <see cref="Crpg.Domain.Entities.Items.Item.BaseId"/>s, so upgrades stay in sync. Any
+/// other themes on those items are preserved; themes that aren't present are ignored.
+/// </summary>
+public record RemoveThemesFromItemsCommand : IMediatorRequest
+{
+    public IList<string> BaseIds { get; init; } = new List<string>();
+    public IList<int> ThemeIds { get; init; } = new List<int>();
+
+    public class Validator : AbstractValidator<RemoveThemesFromItemsCommand>
+    {
+        public Validator()
+        {
+            RuleFor(r => r.BaseIds).NotEmpty();
+            RuleFor(r => r.ThemeIds).NotEmpty();
+        }
+    }
+
+    internal class Handler(ICrpgDbContext db) : IMediatorRequestHandler<RemoveThemesFromItemsCommand>
+    {
+        public async ValueTask<Result> Handle(RemoveThemesFromItemsCommand req, CancellationToken cancellationToken)
+        {
+            var baseIds = req.BaseIds.Distinct().ToList();
+            var items = await db.Items
+                .Include(i => i.Themes)
+                .Where(i => baseIds.Contains(i.BaseId))
+                .ToListAsync(cancellationToken);
+
+            var foundBaseIds = items.Select(i => i.BaseId).ToHashSet();
+            string? missingBaseId = baseIds.FirstOrDefault(id => !foundBaseIds.Contains(id));
+            if (missingBaseId != null)
+            {
+                return new(CommonErrors.ItemNotFound(missingBaseId));
+            }
+
+            var themeIds = req.ThemeIds.Distinct().ToList();
+            var themes = await db.Themes.Where(t => themeIds.Contains(t.Id)).ToListAsync(cancellationToken);
+            if (themes.Count != themeIds.Count)
+            {
+                int missingThemeId = themeIds.First(id => themes.All(t => t.Id != id));
+                return new(CommonErrors.ThemeNotFound(missingThemeId));
+            }
+
+            foreach (var item in items)
+            {
+                item.Themes.RemoveAll(t => themeIds.Contains(t.Id));
+            }
+
+            await db.SaveChangesAsync(cancellationToken);
+
+            return Result.NoErrors;
+        }
+    }
+}

src/Application/Items/Commands/SetItemThemesCommand.cs

@@ -0,0 +1,54 @@
+using System.Text.Json.Serialization;
+using AutoMapper;
+using Crpg.Application.Common.Interfaces;
+using Crpg.Application.Common.Mediator;
+using Crpg.Application.Common.Results;
+using Crpg.Application.Items.Models;
+using Microsoft.EntityFrameworkCore;
+
+namespace Crpg.Application.Items.Commands;
+
+/// <summary>
+/// Replaces the set of themes assigned to an item family. The themes are applied to every rank variant sharing the
+/// given <see cref="Crpg.Domain.Entities.Items.Item.BaseId"/>, so upgrades stay in sync.
+/// </summary>
+public record SetItemThemesCommand : IMediatorRequest<ItemViewModel>
+{
+    [JsonIgnore]
+    public string BaseId { get; init; } = string.Empty;
+    public IList<int> ThemeIds { get; init; } = new List<int>();
+
+    internal class Handler(ICrpgDbContext db, IMapper mapper) : IMediatorRequestHandler<SetItemThemesCommand, ItemViewModel>
+    {
+        public async ValueTask<Result<ItemViewModel>> Handle(SetItemThemesCommand req, CancellationToken cancellationToken)
+        {
+            var items = await db.Items
+                .Include(i => i.Themes)
+                .Where(i => i.BaseId == req.BaseId)
+                .ToListAsync(cancellationToken);
+            if (items.Count == 0)
+            {
+                return new(CommonErrors.ItemNotFound(req.BaseId));
+            }
+
+            var themeIds = req.ThemeIds.Distinct().ToList();
+            var themes = await db.Themes.Where(t => themeIds.Contains(t.Id)).ToListAsync(cancellationToken);
+            if (themes.Count != themeIds.Count)
+            {
+                int missingThemeId = themeIds.First(id => themes.All(t => t.Id != id));
+                return new(CommonErrors.ThemeNotFound(missingThemeId));
+            }
+
+            foreach (var item in items)
+            {
+                item.Themes.Clear();
+                item.Themes.AddRange(themes);
+            }
+
+            await db.SaveChangesAsync(cancellationToken);
+
+            var representative = items.OrderBy(i => i.Rank).First();
+            return new(mapper.Map<ItemViewModel>(representative));
+        }
+    }
+}

src/Application/Items/Models/ItemCreation.cs

@@ -1,3 +1,4 @@
+using Crpg.Application.Themes.Models;
 using Crpg.Domain.Entities;
 using Crpg.Domain.Entities.Items;
 
@@ -20,4 +21,5 @@ public record ItemCreation
     public ItemArmorComponentViewModel? Armor { get; init; }
     public ItemMountComponentViewModel? Mount { get; init; }
     public IList<ItemWeaponComponentViewModel> Weapons { get; init; } = Array.Empty<ItemWeaponComponentViewModel>();
+    public IList<ThemeViewModel> Themes { get; init; } = Array.Empty<ThemeViewModel>();
 }

src/Application/Items/Models/ItemViewModel.cs

@@ -1,6 +1,7 @@
 using System.Text.Json.Serialization;
 using AutoMapper;
 using Crpg.Application.Common.Mappings;
+using Crpg.Application.Themes.Models;
 using Crpg.Domain.Entities;
 using Crpg.Domain.Entities.Items;
 
@@ -26,6 +27,7 @@ public record ItemViewModel : IMapFrom<Item>
     public ItemMountComponentViewModel? Mount { get; init; }
     public IList<ItemWeaponComponentViewModel> Weapons { get; init; } = Array.Empty<ItemWeaponComponentViewModel>();
     public bool Enabled { get; init; }
+    public IList<ThemeViewModel> Themes { get; init; } = Array.Empty<ThemeViewModel>();
 
     public void Mapping(Profile profile)
     {

src/Application/Items/Queries/GetItemsQuery.cs

@@ -27,6 +27,8 @@ public async ValueTask<Result<IList<ItemViewModel>>> Handle(GetItemsQuery req, C
                 .OrderBy(i => i.Price)
                 .Where(i => i.Enabled)
                 .Where(i => i.Rank == 0)
+                .Include(i => i.Themes)
+                .AsSplitQuery()
                 .ToListAsync(cancellationToken);
 
             return new(_mapper.Map<IList<ItemViewModel>>(items));

src/Application/Items/Queries/GetUserItemsQuery.cs

@@ -21,6 +21,7 @@ public async ValueTask<Result<IList<UserItemViewModel>>> Handle(GetUserItemsQuer
             var userItems = await _db.UserItems
                 .AsSplitQuery()
                 .Include(ui => ui.Item)
+                    .ThenInclude(i => i!.Themes)
                 .Include(ui => ui.ClanArmoryItem)
                     .ThenInclude(cai => cai!.Lender)
                         .ThenInclude(cm => cm!.User)