Added item event controllers

Fuyu.Backend.BSG/Models/ItemEvents/MergeItemEvent.cs

@@ -0,0 +1,14 @@
+using System.Runtime.Serialization;
+using Fuyu.Common.Hashing;
+
+namespace Fuyu.Backend.BSG.Models.ItemEvents;
+
+[DataContract]
+public class MergeItemEvent : BaseItemEvent
+{
+    [DataMember(Name = "item")]
+    public MongoId Item { get; set; }
+
+    [DataMember(Name = "with")]
+    public MongoId With { get; set; }
+}

Fuyu.Backend.BSG/Models/ItemEvents/SplitItemEvent.cs

@@ -0,0 +1,20 @@
+using System.Runtime.Serialization;
+using Fuyu.Common.Hashing;
+
+namespace Fuyu.Backend.BSG.Models.ItemEvents;
+
+[DataContract]
+public class SplitItemEvent : BaseItemEvent
+{
+    [DataMember(Name = "splitItem")]
+    public MongoId SplitItem { get; set; }
+
+    [DataMember(Name = "newItem")]
+    public MongoId NewItem { get; set; }
+
+    [DataMember(Name = "container")]
+    public RelocateTarget Container { get; set; }
+
+    [DataMember(Name = "count")]
+    public int Count { get; set; }
+}

Fuyu.Backend.BSG/Models/ItemEvents/TransferItemEvent.cs

@@ -0,0 +1,17 @@
+using System.Runtime.Serialization;
+using Fuyu.Common.Hashing;
+
+namespace Fuyu.Backend.BSG.Models.ItemEvents;
+
+[DataContract]
+public class TransferItemEvent : BaseItemEvent
+{
+    [DataMember(Name = "item")]
+    public MongoId Item { get; set; }
+
+    [DataMember(Name = "with")]
+    public MongoId With { get; set; }
+
+    [DataMember(Name = "count")]
+    public int Count { get; set; }
+}

Fuyu.Backend.EFTMain/Controllers/Http/GameProfileItemsMovingController.cs

@@ -45,6 +45,9 @@ public GameProfileItemsMovingController() : base("/client/game/profile/items/mov
         ItemEventRouter.AddController<RagFairAddOfferItemEventController>();
         ItemEventRouter.AddController<RagFairRemoveOfferItemEventController>();
         ItemEventRouter.AddController<RagFairRenewOfferController>();
+        ItemEventRouter.AddController<TransferItemEventController>();
+        ItemEventRouter.AddController<MergeItemEventController>();
+        ItemEventRouter.AddController<SplitItemEventController>();
 
         _eftOrm = EftOrm.Instance;
     }

Fuyu.Backend.EFTMain/Controllers/ItemEvents/MergeItemEventController.cs

@@ -0,0 +1,45 @@
+using System;
+using System.Threading.Tasks;
+using Fuyu.Backend.BSG.Models.ItemEvents;
+using Fuyu.Backend.BSG.Networking;
+
+namespace Fuyu.Backend.EFTMain.Controllers.ItemEvents;
+
+public class MergeItemEventController : AbstractItemEventController<MergeItemEvent>
+{
+    private readonly EftOrm _eftOrm;
+
+    public MergeItemEventController() : base("Merge")
+    {
+        _eftOrm = EftOrm.Instance;
+    }
+
+    public override Task RunAsync(ItemEventContext context, MergeItemEvent request)
+    {
+        var profile = _eftOrm.GetActiveProfile(context.SessionId);
+        var source = profile.Pmc.Inventory.FindItem(request.Item);
+
+        if (source == null)
+        {
+            throw new Exception($"Source item {request.Item} not found on backend");
+        }
+
+        var target = profile.Pmc.Inventory.FindItem(request.With);
+
+        if (target == null)
+        {
+            throw new Exception($"Target item {request.With} not found on backend");
+        }
+
+        var removedItems = profile.Pmc.Inventory.RemoveItem(source);
+
+        if (removedItems.Count == 0)
+        {
+            throw new Exception("Failed to remove source item");
+        }
+
+        target.Updatable.StackObjectsCount += source.Updatable.StackObjectsCount;
+
+        return Task.CompletedTask;
+    }
+}

Fuyu.Backend.EFTMain/Controllers/ItemEvents/SplitItemEventController.cs

@@ -0,0 +1,98 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Fuyu.Backend.BSG.Models.ItemEvents;
+using Fuyu.Backend.BSG.Networking;
+using Fuyu.Backend.BSG.Services;
+
+namespace Fuyu.Backend.EFTMain.Controllers.ItemEvents;
+
+public class SplitItemEventController : AbstractItemEventController<SplitItemEvent>
+{
+    private readonly EftOrm _eftOrm;
+
+    public SplitItemEventController() : base("Split")
+    {
+        _eftOrm = EftOrm.Instance;
+    }
+
+    // TODO: Clean this up later. Probably using methods on grids themselves.
+    public override Task RunAsync(ItemEventContext context, SplitItemEvent request)
+    {
+        var profile = _eftOrm.GetActiveProfile(context.SessionId);
+        var sourceItemStack = profile.Pmc.Inventory.GetItemAndChildren(ItemService.Instance, request.SplitItem);
+
+        if (sourceItemStack.Count == 0)
+        {
+            throw new Exception($"Failed to find source item {request.SplitItem}");
+        }
+
+        var sourceItem = sourceItemStack[0];
+
+        if (sourceItem.Updatable.StackObjectsCount < request.Count)
+        {
+            throw new Exception($"Stack count mismatch");
+        }
+
+        var targetLocationItem = profile.Pmc.Inventory.FindItem(request.Container.Id);
+
+        if (targetLocationItem == null)
+        {
+            throw new Exception($"Failed to find target container {request.Container.Id}");
+        }
+
+        if (request.Container.Location != null)
+        {
+            if (!targetLocationItem.Matrices.TryGetValue(request.Container.Container, out var matrix))
+            {
+                throw new Exception($"Failed to get matrix for slot {request.Container.Container}");
+            }
+
+            (int width, int height) = ItemService.Instance.CalculateItemSize(sourceItemStack, request.Container.Location.r);
+            var x = request.Container.Location.x;
+            var y = request.Container.Location.y;
+
+            for (var dy = 0; dy < height; dy++)
+            {
+                for (var dx = 0; dx < width; dx++)
+                {
+                    var tempX = x + dx;
+                    var tempY = y + dy;
+
+                    if (matrix[tempX, tempY])
+                    {
+                        throw new Exception("Overlap");
+                    }
+
+                    matrix[tempX, tempY] = true;
+                }
+            }
+        }
+
+        sourceItem.Updatable.StackObjectsCount -= request.Count;
+
+        var newItemStacks =
+            ItemFactoryService.Instance.CreateItemsFromTradeRequest(sourceItemStack, request.Count);
+
+        var newItemStack = newItemStacks[0];
+        var newItem = newItemStack[0];
+
+        var mapping = new Dictionary<string, string>
+        {
+            { newItem.Id, request.NewItem }
+        };
+
+        ItemService.Instance.RegenerateItemIds(newItemStack, mapping);
+
+        foreach (var item in newItemStack)
+        {
+            profile.Pmc.Inventory.ItemsMap[item.Id] = item;
+        }
+
+        newItem.Location = request.Container.Location;
+        newItem.ParentId = request.Container.Id;
+        newItem.SlotId = request.Container.Container;
+
+        return Task.CompletedTask;
+    }
+}

Fuyu.Backend.EFTMain/Controllers/ItemEvents/TransferItemEventController.cs

@@ -0,0 +1,47 @@
+using System;
+using System.Threading.Tasks;
+using Fuyu.Backend.BSG.Models.ItemEvents;
+using Fuyu.Backend.BSG.Networking;
+
+namespace Fuyu.Backend.EFTMain.Controllers.ItemEvents;
+
+public class TransferItemEventController : AbstractItemEventController<TransferItemEvent>
+{
+    private readonly EftOrm _eftOrm;
+
+    public TransferItemEventController() : base("Transfer")
+    {
+        _eftOrm = EftOrm.Instance;
+    }
+
+    public override Task RunAsync(ItemEventContext context, TransferItemEvent request)
+    {
+        var profile = _eftOrm.GetActiveProfile(context.SessionId);
+        var item = profile.Pmc.Inventory.FindItem(request.Item);
+
+        if (item == null)
+        {
+            throw new Exception($"Source item {request.Item} not found on backend");
+        }
+
+        if (item.Updatable.StackObjectsCount < request.Count)
+        {
+            throw new Exception(
+                $"Client-backend count mismatch. Got {request.Count}, have {item.Updatable.StackObjectsCount.Value}"
+            );
+        }
+
+        item.Updatable.StackObjectsCount -= request.Count;
+
+        var with = profile.Pmc.Inventory.FindItem(request.With);
+
+        if (with == null)
+        {
+            throw new Exception($"Target item {request.With} not found on backend");
+        }
+
+        with.Updatable.StackObjectsCount += request.Count;
+
+        return Task.CompletedTask;
+    }
+}