Obtain forging results (UI is broken though).

src/main/java/emu/grasscutter/data/excels/ForgeData.java

@@ -13,6 +13,7 @@ public class ForgeData extends GameResource {
     private int id;
     private int playerLevel;
     private int forgeType;
+    private int resultItemId;
     private int resultItemCount;
     private int forgeTime;
     private int queueNum;
@@ -33,6 +34,10 @@ public class ForgeData extends GameResource {
         return forgeType;
     }
 
+    public int getResultItemId() {
+        return resultItemId;
+    }
+
     public int getResultItemCount() {
         return resultItemCount;
     }

src/main/java/emu/grasscutter/game/managers/ForgingManager/ForgingManager.java

@@ -1,21 +1,27 @@
 package emu.grasscutter.game.managers.ForgingManager;
 
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 import emu.grasscutter.Grasscutter;
 import emu.grasscutter.data.GameData;
 import emu.grasscutter.data.common.ItemParamData;
 import emu.grasscutter.data.excels.ForgeData;
+import emu.grasscutter.data.excels.ItemData;
 import emu.grasscutter.game.inventory.GameItem;
 import emu.grasscutter.game.inventory.ItemType;
 import emu.grasscutter.game.player.Player;
 import emu.grasscutter.net.proto.ForgeStartReqOuterClass;
 import emu.grasscutter.net.proto.ForgeQueueDataOuterClass.ForgeQueueData;
+import emu.grasscutter.net.proto.ForgeQueueManipulateReqOuterClass.ForgeQueueManipulateReq;
+import emu.grasscutter.net.proto.ForgeQueueManipulateTypeOuterClass.ForgeQueueManipulateType;
+import emu.grasscutter.net.proto.ForgeStartReqOuterClass.ForgeStartReq;
 import emu.grasscutter.net.proto.RetcodeOuterClass.Retcode;
 import emu.grasscutter.server.packet.send.PacketForgeDataNotify;
 import emu.grasscutter.server.packet.send.PacketForgeFormulaDataNotify;
 import emu.grasscutter.server.packet.send.PacketForgeGetQueueDataRsp;
+import emu.grasscutter.server.packet.send.PacketForgeQueueManipulateRsp;
 import emu.grasscutter.server.packet.send.PacketForgeStartRsp;
 import emu.grasscutter.utils.Utils;
 
@@ -104,7 +110,7 @@ public class ForgingManager {
 	/**********
 		Initiate forging process.
 	**********/
-	public void startForging(ForgeStartReqOuterClass.ForgeStartReq req) {
+	public void handleForgeStartReq(ForgeStartReq req) {
 		// Refuse if all queues are already full.
 		if (this.player.getActiveForges().size() >= this.determineNumberOfQueues()) {
 			this.player.sendPacket(new PacketForgeStartRsp(Retcode.RET_FORGE_QUEUE_FULL));
@@ -165,4 +171,74 @@ public class ForgingManager {
 		this.player.sendPacket(new PacketForgeStartRsp(Retcode.RET_SUCC));
 		this.sendForgeDataNotify();
 	}
+
+	/**********
+		Forge queue manipulation (obtaining results and cancelling forges).
+	**********/
+	private void obtainItems(int queueId) {
+		// Determin how many items are finished.
+		int currentTime = Utils.getCurrentSeconds();
+		ActiveForgeData forge = this.player.getActiveForges().get(queueId - 1);
+
+		int finished = forge.getFinishedCount(currentTime);
+		int unfinished = forge.getUnfinishedCount(currentTime);
+
+		// Sanity check: Are any items finished?
+		if (finished <= 0) {
+			return;
+		}
+
+		// Give finished items to the player.
+		ForgeData data = GameData.getForgeDataMap().get(forge.getForgeId());
+		ItemData resultItemData = GameData.getItemDataMap().get(data.getResultItemId());
+
+		GameItem addItem = new GameItem(resultItemData, data.getResultItemCount() * finished);
+		this.player.getInventory().addItem(addItem);
+
+		// Replace active forge with a new one for the unfinished items, if there are any.
+		if (unfinished > 0) {
+			ActiveForgeData remainingForge = new ActiveForgeData();
+
+			remainingForge.setForgeId(forge.getForgeId());
+			remainingForge.setAvatarId(forge.getAvatarId());
+			remainingForge.setCount(unfinished);
+			remainingForge.setForgeTime(forge.getForgeTime());
+
+			// We simple restart the forge. This will increase the time, but is easier for now.
+			// ToDo: Make this more accurate.
+			remainingForge.setStartTime(currentTime);
+
+			this.player.getActiveForges().set(queueId - 1, remainingForge);
+		}
+		// Otherwise, completely remove it.
+		else {
+			this.player.getActiveForges().remove(queueId - 1);
+		}
+
+		// Send response.
+		this.player.sendPacket(new PacketForgeQueueManipulateRsp(Retcode.RET_SUCC, ForgeQueueManipulateType.FORGE_QUEUE_MANIPULATE_TYPE_RECEIVE_OUTPUT, List.of(addItem), List.of(), List.of()));
+		this.sendForgeDataNotify();
+	}
+
+	private void cancelForge(int queueId) {
+		
+	}
+
+	public void handleForgeQueueManipulateReq(ForgeQueueManipulateReq req) {
+		// Get info from the request.
+		int queueId = req.getForgeQueueId();
+		var manipulateType = req.getManipulateType();
+		
+		// Handle according to the manipulation type.
+		switch (manipulateType) {
+			case FORGE_QUEUE_MANIPULATE_TYPE_RECEIVE_OUTPUT:
+				this.obtainItems(queueId);
+				break;
+			case FORGE_QUEUE_MANIPULATE_TYPE_STOP_FORGE:
+				this.cancelForge(queueId);
+				break;
+			default:
+				break; //Should never happen.
+		}
+	}
 }

src/main/java/emu/grasscutter/server/packet/recv/HandlerForgeQueueManipulateReq.java

@@ -0,0 +1,16 @@
+package emu.grasscutter.server.packet.recv;
+
+import emu.grasscutter.net.packet.Opcodes;
+import emu.grasscutter.net.packet.PacketOpcodes;
+import emu.grasscutter.net.proto.ForgeQueueManipulateReqOuterClass.ForgeQueueManipulateReq;
+import emu.grasscutter.net.packet.PacketHandler;
+import emu.grasscutter.server.game.GameSession;
+
+@Opcodes(PacketOpcodes.ForgeQueueManipulateReq)
+public class HandlerForgeQueueManipulateReq extends PacketHandler {
+	@Override
+	public void handle(GameSession session, byte[] header, byte[] payload) throws Exception {
+    	ForgeQueueManipulateReq req = ForgeQueueManipulateReq.parseFrom(payload);
+		session.getPlayer().getForgingManager().handleForgeQueueManipulateReq(req);
+	}
+}

src/main/java/emu/grasscutter/server/packet/recv/HandlerForgeStartReq.java

@@ -17,7 +17,7 @@ public class HandlerForgeStartReq extends PacketHandler {
     @Override
     public void handle(GameSession session, byte[] header, byte[] payload) throws Exception {
         ForgeStartReqOuterClass.ForgeStartReq req = ForgeStartReqOuterClass.ForgeStartReq.parseFrom(payload);
-        session.getPlayer().getForgingManager().startForging(req);
+        session.getPlayer().getForgingManager().handleForgeStartReq(req);
     }
 
 }

src/main/java/emu/grasscutter/server/packet/send/PacketForgeQueueManipulateRsp.java

@@ -0,0 +1,43 @@
+package emu.grasscutter.server.packet.send;
+
+import java.util.List;
+
+import emu.grasscutter.game.inventory.GameItem;
+import emu.grasscutter.net.packet.BasePacket;
+import emu.grasscutter.net.packet.PacketOpcodes;
+import emu.grasscutter.net.proto.ForgeQueueManipulateRspOuterClass.ForgeQueueManipulateRsp;
+import emu.grasscutter.net.proto.ForgeQueueManipulateTypeOuterClass.ForgeQueueManipulateType;
+import emu.grasscutter.net.proto.ItemParamOuterClass.ItemParam;
+import emu.grasscutter.net.proto.RetcodeOuterClass.Retcode;
+
+public class PacketForgeQueueManipulateRsp extends BasePacket {
+
+    public PacketForgeQueueManipulateRsp(Retcode retcode, ForgeQueueManipulateType type, List<GameItem> output, List<GameItem> refund, List<GameItem> extra) {
+        super(PacketOpcodes.ForgeQueueManipulateRsp);
+
+        ForgeQueueManipulateRsp.Builder builder = ForgeQueueManipulateRsp.newBuilder()
+                .setRetcode(retcode.getNumber());
+        
+        for (GameItem item : output) {
+            ItemParam toAdd = ItemParam.newBuilder()
+                .setItemId(item.getItemId())
+                .setCount(item.getCount())
+                .build();
+
+            builder.addOutputItemList(toAdd);
+        }
+
+        for (GameItem item : refund) {
+            ItemParam toAdd = ItemParam.newBuilder()
+                .setItemId(item.getItemId())
+                .setCount(item.getCount())
+                .build();
+
+            builder.addReturnItemList(toAdd);
+        }
+
+        // ToDo: Add extra items when once we have handling for it.
+
+        this.setData(builder.build());
+    }
+}