Implement sweeps

src/main/java/emu/nebula/data/resources/DailyInstanceRewardGroupDef.java

@@ -9,7 +9,8 @@ import lombok.Getter;
 @Getter
 @ResourceType(name = "DailyInstanceRewardGroup.json")
 public class DailyInstanceRewardGroupDef extends BaseDef {
-    private int Id;
+    private int GroupId;
+    private int DailyRewardType;
     private String BaseAwardPreview;
     
     private transient ItemParamMap firstRewards;
@@ -17,7 +18,7 @@ public class DailyInstanceRewardGroupDef extends BaseDef {
     
     @Override
     public int getId() {
-        return Id;
+        return GroupId + DailyRewardType;
     }
     
     @Override

src/main/java/emu/nebula/game/instance/InstanceManager.java

@@ -82,37 +82,77 @@ public class InstanceManager extends PlayerManager implements GameDatabaseObject
         settleData.setWin(star > 0);
         settleData.setFirst(settleData.isWin() && !log.containsKey(data.getId()));
         
-        // Init player changes
+        // Init player change info
-        var changes = new PlayerChangeInfo();
+        var change = new PlayerChangeInfo();
         
         // Handle win
         if (settleData.isWin()) {
-            // Energy
+            // Reward type
+            int rewardType = this.getRewardType();
+            
+            // Calculate energy and exp
             settleData.setExp(data.getEnergyConsume());
-            getPlayer().consumeEnergy(settleData.getExp(), changes);
+            getPlayer().consumeEnergy(settleData.getExp(), change);
             
             // Awards
-            getPlayer().getInventory().addItem(GameConstants.EXP_ITEM_ID, settleData.getExp(), changes);
+            getPlayer().getInventory().addItem(GameConstants.EXP_ITEM_ID, settleData.getExp(), change);
-            getPlayer().getInventory().addItems(data.getRewards(), changes);
+            getPlayer().getInventory().addItems(data.getRewards(rewardType), change);
             
             if (settleData.isFirst()) {
-                getPlayer().getInventory().addItems(data.getFirstRewards(), changes);
+                getPlayer().getInventory().addItems(data.getFirstRewards(rewardType), change);
             }
             
             // Log
             this.saveInstanceLog(log, logName, data.getId(), star);
         }
         
-        // Log energy
-        if (data.getEnergyConsume() > 0) {
-            changes.add(this.getPlayer().getEnergyProto());
-        }
-        
         // Set extra data
-        changes.setExtraData(settleData);
+        change.setExtraData(settleData);
         
         // Success
-        return changes.setSuccess(true);
+        return change.setSuccess(true);
+    }
+    
+    public PlayerChangeInfo sweepInstance(InstanceData data, Int2IntMap log, int rewardType, int count) {
+        // Sanity check count
+        if (count <= 0) {
+            return null;
+        }
+        
+        // Check if we have 3 starred this instance
+        int stars = log.get(data.getId());
+        
+        if (rewardType > 0) {
+            // Daily instance
+            if (stars != 7) {
+                return null;
+            }
+        } else {
+            // Other instances
+            if (stars != 3) {
+                return null;
+            }
+        }
+        
+        // Check energy cost
+        int energyCost = data.getEnergyConsume() * count;
+        
+        if (this.getPlayer().getEnergy() < energyCost) {
+            return null;
+        }
+        
+        // Init player change info
+        var change = new PlayerChangeInfo();
+        
+        // Consume exp
+        getPlayer().consumeEnergy(energyCost, change);
+        
+        // Awards
+        getPlayer().getInventory().addItem(GameConstants.EXP_ITEM_ID, energyCost, change);
+        getPlayer().getInventory().addItems(data.getRewards(rewardType).mulitply(count), change);
+        
+        // Success
+        return change.setSuccess(true);
     }
 
     // Proto

src/main/java/emu/nebula/server/handlers/HandlerCharGemInstanceSweepReq.java

@@ -0,0 +1,60 @@
+package emu.nebula.server.handlers;
+
+import emu.nebula.net.NetHandler;
+import emu.nebula.net.NetMsgId;
+import emu.nebula.proto.CharGemInstanceSweep.CharGemInstanceSweepReq;
+import emu.nebula.proto.CharGemInstanceSweep.CharGemInstanceSweepResp;
+import emu.nebula.proto.CharGemInstanceSweep.CharGemInstanceSweepReward;
+import emu.nebula.net.HandlerId;
+import emu.nebula.data.GameData;
+import emu.nebula.net.GameSession;
+
+@HandlerId(NetMsgId.char_gem_instance_sweep_req)
+public class HandlerCharGemInstanceSweepReq extends NetHandler {
+
+    @Override
+    public byte[] handle(GameSession session, byte[] message) throws Exception {
+        // Parse request
+        var req = CharGemInstanceSweepReq.parseFrom(message);
+        
+        // Get instance data
+        var data = GameData.getCharGemInstanceDataTable().get(req.getId());
+        if (data == null) {
+            return session.encodeMsg(NetMsgId.char_gem_instance_sweep_failed_ack);
+        }
+        
+        // Sweep
+        var change = session.getPlayer().getInstanceManager().sweepInstance(
+                data,
+                session.getPlayer().getInstanceManager().getCharGemLog(),
+                0,
+                req.getTimes()
+        );
+        
+        // Sanity check
+        if (change == null) {
+            return session.encodeMsg(NetMsgId.char_gem_instance_sweep_failed_ack);
+        }
+        
+        // Build response
+        var rsp = CharGemInstanceSweepResp.newInstance()
+                .setChange(change.toProto());
+        
+        // Cache reward list
+        var rewardList = data.getRewards().toItemTemplateStream().toList();
+        
+        // Add rewards
+        for (int i = 0; i < req.getTimes(); i++) {
+            var reward = CharGemInstanceSweepReward.newInstance()
+                    .setExp(data.getEnergyConsume());
+            
+            rewardList.forEach(reward::addAwardItems);
+            
+            rsp.addRewards(reward);
+        }
+        
+        // Send response
+        return session.encodeMsg(NetMsgId.char_gem_instance_sweep_succeed_ack, rsp);
+    }
+
+}

src/main/java/emu/nebula/server/handlers/HandlerDailyInstanceRaidReq.java

@@ -0,0 +1,65 @@
+package emu.nebula.server.handlers;
+
+import emu.nebula.net.NetHandler;
+import emu.nebula.net.NetMsgId;
+import emu.nebula.proto.DailyInstanceRaid.DailyInstanceRaidReq;
+import emu.nebula.proto.DailyInstanceRaid.DailyInstanceRaidResp;
+import emu.nebula.proto.DailyInstanceRaid.DailyInstanceReward;
+import emu.nebula.net.HandlerId;
+import emu.nebula.data.GameData;
+import emu.nebula.net.GameSession;
+
+@HandlerId(NetMsgId.daily_instance_raid_req)
+public class HandlerDailyInstanceRaidReq extends NetHandler {
+
+    @Override
+    public byte[] handle(GameSession session, byte[] message) throws Exception {
+        // Parse request
+        var req = DailyInstanceRaidReq.parseFrom(message);
+        
+        // Get instance data
+        var data = GameData.getDailyInstanceDataTable().get(req.getId());
+        if (data == null) {
+            return session.encodeMsg(NetMsgId.daily_instance_raid_failed_ack);
+        }
+        
+        // Check reward group
+        if (data.getRewardGroup(req.getRewardType()) == null) {
+            return session.encodeMsg(NetMsgId.daily_instance_raid_failed_ack);
+        }
+        
+        // Sweep
+        var change = session.getPlayer().getInstanceManager().sweepInstance(
+                data,
+                session.getPlayer().getInstanceManager().getDailyInstanceLog(),
+                req.getRewardType(),
+                req.getTimes()
+        );
+        
+        // Sanity check
+        if (change == null) {
+            return session.encodeMsg(NetMsgId.daily_instance_raid_failed_ack);
+        }
+        
+        // Build response
+        var rsp = DailyInstanceRaidResp.newInstance()
+                .setChange(change.toProto());
+        
+        // Cache reward list
+        var rewardList = data.getRewards(req.getRewardType()).toItemProtoStream().toList();
+        
+        // Add rewards
+        for (int i = 0; i < req.getTimes(); i++) {
+            var reward = DailyInstanceReward.newInstance()
+                    .setExp(data.getEnergyConsume());
+            
+            rewardList.forEach(reward::addSelect);
+            
+            rsp.addRewards(reward);
+        }
+        
+        // Send response
+        return session.encodeMsg(NetMsgId.daily_instance_raid_succeed_ack, rsp);
+    }
+
+}

src/main/java/emu/nebula/server/handlers/HandlerRegionBossLevelSweepReq.java

@@ -0,0 +1,60 @@
+package emu.nebula.server.handlers;
+
+import emu.nebula.net.NetHandler;
+import emu.nebula.net.NetMsgId;
+import emu.nebula.proto.RegionBossLevelSweep.RegionBossLevelSweepReq;
+import emu.nebula.proto.RegionBossLevelSweep.RegionBossLevelSweepResp;
+import emu.nebula.proto.RegionBossLevelSweep.RegionBossLevelSweepRewards;
+import emu.nebula.net.HandlerId;
+import emu.nebula.data.GameData;
+import emu.nebula.net.GameSession;
+
+@HandlerId(NetMsgId.region_boss_level_sweep_req)
+public class HandlerRegionBossLevelSweepReq extends NetHandler {
+
+    @Override
+    public byte[] handle(GameSession session, byte[] message) throws Exception {
+        // Parse request
+        var req = RegionBossLevelSweepReq.parseFrom(message);
+        
+        // Get instance data
+        var data = GameData.getRegionBossLevelDataTable().get(req.getId());
+        if (data == null) {
+            return session.encodeMsg(NetMsgId.region_boss_level_sweep_failed_ack);
+        }
+        
+        // Sweep
+        var change = session.getPlayer().getInstanceManager().sweepInstance(
+                data,
+                session.getPlayer().getInstanceManager().getRegionBossLog(),
+                0,
+                req.getTimes()
+        );
+        
+        // Sanity check
+        if (change == null) {
+            return session.encodeMsg(NetMsgId.region_boss_level_sweep_failed_ack);
+        }
+        
+        // Build response
+        var rsp = RegionBossLevelSweepResp.newInstance()
+                .setChange(change.toProto());
+        
+        // Cache reward list
+        var rewardList = data.getRewards().toItemTemplateStream().toList();
+        
+        // Add rewards
+        for (int i = 0; i < req.getTimes(); i++) {
+            var reward = RegionBossLevelSweepRewards.newInstance()
+                    .setExp(data.getEnergyConsume());
+            
+            rewardList.forEach(reward::addAwardItems);
+            
+            rsp.addRewards(reward);
+        }
+        
+        // Send response
+        return session.encodeMsg(NetMsgId.region_boss_level_sweep_succeed_ack, rsp);
+    }
+
+}

src/main/java/emu/nebula/server/handlers/HandlerSkillInstanceSweepReq.java

@@ -0,0 +1,60 @@
+package emu.nebula.server.handlers;
+
+import emu.nebula.net.NetHandler;
+import emu.nebula.net.NetMsgId;
+import emu.nebula.proto.SkillInstanceSweep.SkillInstanceSweepReq;
+import emu.nebula.proto.SkillInstanceSweep.SkillInstanceSweepResp;
+import emu.nebula.proto.SkillInstanceSweep.SkillInstanceSweepRewards;
+import emu.nebula.net.HandlerId;
+import emu.nebula.data.GameData;
+import emu.nebula.net.GameSession;
+
+@HandlerId(NetMsgId.skill_instance_sweep_req)
+public class HandlerSkillInstanceSweepReq extends NetHandler {
+
+    @Override
+    public byte[] handle(GameSession session, byte[] message) throws Exception {
+        // Parse request
+        var req = SkillInstanceSweepReq.parseFrom(message);
+        
+        // Get instance data
+        var data = GameData.getSkillInstanceDataTable().get(req.getId());
+        if (data == null) {
+            return session.encodeMsg(NetMsgId.skill_instance_sweep_failed_ack);
+        }
+        
+        // Sweep
+        var change = session.getPlayer().getInstanceManager().sweepInstance(
+                data,
+                session.getPlayer().getInstanceManager().getSkillInstanceLog(),
+                0,
+                req.getTimes()
+        );
+        
+        // Sanity check
+        if (change == null) {
+            return session.encodeMsg(NetMsgId.skill_instance_sweep_failed_ack);
+        }
+        
+        // Build response
+        var rsp = SkillInstanceSweepResp.newInstance()
+                .setChange(change.toProto());
+        
+        // Cache reward list
+        var rewardList = data.getRewards().toItemTemplateStream().toList();
+        
+        // Add rewards
+        for (int i = 0; i < req.getTimes(); i++) {
+            var reward = SkillInstanceSweepRewards.newInstance()
+                    .setExp(data.getEnergyConsume());
+            
+            rewardList.forEach(reward::addAwardItems);
+            
+            rsp.addRewards(reward);
+        }
+        
+        // Send response
+        return session.encodeMsg(NetMsgId.skill_instance_sweep_succeed_ack, rsp);
+    }
+
+}