mirror of
https://github.com/Grasscutters/Grasscutter.git
synced 2025-01-12 09:32:59 +08:00
f139818224
* feature(2.7 version): support 2.7 version & upload new protos 1. Support GC in GI 2.7.0; 2. Upload new protos; 3. Fix some bugs cuz by new protos. BREAKING CHANGE: all * fix(database helper): fix player uid issues * fix(ability embryo): uint32 to fixed32 * fix(proto): map mark rename MAP_MARK_FROM_TYPE_NOE to MAP_MARK_FROM_TYPE_NONE * fix(game version): change game version to 2.7.0 * perf(proto): remove unused protos 1. Remove unused protos; 2. Temporarily commented out some of the proto fields. * fix(proto): uint32 to fixed32
61 lines
2.1 KiB
Java
61 lines
2.1 KiB
Java
package emu.grasscutter.game.player;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
|
|
import emu.grasscutter.net.packet.BasePacket;
|
|
import emu.grasscutter.net.proto.ForwardTypeOuterClass.ForwardType;
|
|
|
|
public class InvokeHandler<T> {
|
|
private final List<T> entryListForwardAll;
|
|
private final List<T> entryListForwardAllExceptCur;
|
|
private final List<T> entryListForwardHost;
|
|
private final Class<? extends BasePacket> packetClass;
|
|
|
|
public InvokeHandler(Class<? extends BasePacket> packetClass) {
|
|
this.entryListForwardAll = new ArrayList<>();
|
|
this.entryListForwardAllExceptCur = new ArrayList<>();
|
|
this.entryListForwardHost = new ArrayList<>();
|
|
this.packetClass = packetClass;
|
|
}
|
|
|
|
public synchronized void addEntry(ForwardType forward, T entry) {
|
|
switch (forward) {
|
|
case FORWARD_TYPE_TO_ALL -> entryListForwardAll.add(entry);
|
|
case FORWARD_TYPE_TO_ALL_EXCEPT_CUR, FORWARD_TYPE_TO_ALL_EXIST_EXCEPT_CUR -> entryListForwardAllExceptCur.add(entry);
|
|
case FORWARD_TYPE_TO_HOST -> entryListForwardHost.add(entry);
|
|
default -> {
|
|
}
|
|
}
|
|
}
|
|
|
|
public synchronized void update(Player player) {
|
|
if (player.getWorld() == null || player.getScene() == null) {
|
|
this.entryListForwardAll.clear();
|
|
this.entryListForwardAllExceptCur.clear();
|
|
this.entryListForwardHost.clear();
|
|
return;
|
|
}
|
|
|
|
try {
|
|
if (entryListForwardAll.size() > 0) {
|
|
BasePacket packet = packetClass.getDeclaredConstructor(List.class).newInstance(this.entryListForwardAll);
|
|
player.getScene().broadcastPacket(packet);
|
|
this.entryListForwardAll.clear();
|
|
}
|
|
if (entryListForwardAllExceptCur.size() > 0) {
|
|
BasePacket packet = packetClass.getDeclaredConstructor(List.class).newInstance(this.entryListForwardAllExceptCur);
|
|
player.getScene().broadcastPacketToOthers(player, packet);
|
|
this.entryListForwardAllExceptCur.clear();
|
|
}
|
|
if (entryListForwardHost.size() > 0) {
|
|
BasePacket packet = packetClass.getDeclaredConstructor(List.class).newInstance(this.entryListForwardHost);
|
|
player.getWorld().getHost().sendPacket(packet);
|
|
this.entryListForwardHost.clear();
|
|
}
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
}
|