|
1 | 1 | package com.cleanroommc.modularui.network; |
2 | 2 |
|
3 | | -import com.cleanroommc.modularui.ModularUI; |
4 | | -import com.cleanroommc.modularui.network.packets.PacketSyncHandler; |
5 | 3 | import com.cleanroommc.modularui.value.sync.ModularSyncManager; |
6 | | -import com.cleanroommc.modularui.value.sync.SyncHandler; |
7 | 4 |
|
| 5 | +import net.minecraft.client.Minecraft; |
| 6 | +import net.minecraft.client.entity.EntityPlayerSP; |
8 | 7 | import net.minecraft.entity.player.EntityPlayer; |
9 | 8 | import net.minecraft.entity.player.EntityPlayerMP; |
10 | | -import net.minecraft.network.PacketBuffer; |
| 9 | +import net.minecraft.item.ItemStack; |
11 | 10 | import net.minecraftforge.fml.relauncher.Side; |
12 | 11 | import net.minecraftforge.fml.relauncher.SideOnly; |
13 | 12 |
|
14 | | -import it.unimi.dsi.fastutil.ints.Int2ReferenceOpenHashMap; |
15 | | -import it.unimi.dsi.fastutil.objects.Reference2IntOpenHashMap; |
16 | | - |
17 | | -import java.io.IOException; |
| 13 | +import org.jetbrains.annotations.ApiStatus; |
18 | 14 |
|
| 15 | +@ApiStatus.Experimental |
19 | 16 | public abstract class ModularNetwork { |
20 | 17 |
|
21 | 18 | // These need to be separate instances, otherwise they would access the same maps in singleplayer. |
22 | | - @SideOnly(Side.CLIENT) |
23 | | - public static final ModularNetwork CLIENT = new ModularNetwork(true) { |
24 | | - @Override |
25 | | - protected void sendPacket(IPacket packet, EntityPlayer player) { |
26 | | - NetworkHandler.sendToServer(packet); |
27 | | - } |
28 | | - }; |
29 | | - public static final ModularNetwork SERVER = new ModularNetwork(false) { |
30 | | - @Override |
31 | | - protected void sendPacket(IPacket packet, EntityPlayer player) { |
32 | | - NetworkHandler.sendToPlayer(packet, (EntityPlayerMP) player); |
33 | | - } |
34 | | - }; |
| 19 | + // You have to make sure you are choosing the logical side you are currently on otherwise you can mess things badly, since |
| 20 | + // there is no validation. |
| 21 | + public static final Client CLIENT = new Client(); |
| 22 | + public static final Server SERVER = new Server(); |
35 | 23 |
|
36 | | - public static ModularNetwork get(boolean client) { |
| 24 | + public static ModularNetworkSide get(boolean client) { |
37 | 25 | return client ? CLIENT : SERVER; |
38 | 26 | } |
39 | 27 |
|
40 | | - public static ModularNetwork get(Side side) { |
| 28 | + public static ModularNetworkSide get(Side side) { |
41 | 29 | return side.isClient() ? CLIENT : SERVER; |
42 | 30 | } |
43 | 31 |
|
44 | | - public static ModularNetwork get(EntityPlayer player) { |
| 32 | + public static ModularNetworkSide get(EntityPlayer player) { |
45 | 33 | return get(NetworkUtils.isClient(player)); |
46 | 34 | } |
47 | 35 |
|
48 | | - private final boolean client; |
49 | | - private final Int2ReferenceOpenHashMap<ModularSyncManager> activeScreens = new Int2ReferenceOpenHashMap<>(); |
50 | | - private final Reference2IntOpenHashMap<ModularSyncManager> inverseActiveScreens = new Reference2IntOpenHashMap<>(); |
| 36 | + public static final class Client extends ModularNetworkSide { |
51 | 37 |
|
52 | | - private ModularNetwork(boolean client) { |
53 | | - this.client = client; |
54 | | - } |
| 38 | + private Client() { |
| 39 | + super(true); |
| 40 | + } |
55 | 41 |
|
56 | | - public boolean isClient() { |
57 | | - return client; |
58 | | - } |
| 42 | + public void activate(int nid, ModularSyncManager msm) { |
| 43 | + activateInternal(nid, msm); |
| 44 | + } |
59 | 45 |
|
60 | | - protected abstract void sendPacket(IPacket packet, EntityPlayer player); |
| 46 | + @Override |
| 47 | + void sendPacket(IPacket packet, EntityPlayer player) { |
| 48 | + NetworkHandler.sendToServer(packet); |
| 49 | + } |
61 | 50 |
|
62 | | - public void activate(int networkId, ModularSyncManager manager) { |
63 | | - if (activeScreens.containsKey(networkId)) throw new IllegalStateException("Network ID " + networkId + " is already active."); |
64 | | - activeScreens.put(networkId, manager); |
65 | | - inverseActiveScreens.put(manager, networkId); |
66 | | - } |
| 51 | + @Override |
| 52 | + void closeContainer(EntityPlayer player) { |
| 53 | + // mimics EntityPlayerSP.closeScreenAndDropStack() but without closing the screen |
| 54 | + player.inventory.setItemStack(ItemStack.EMPTY); |
| 55 | + player.openContainer = player.inventoryContainer; |
| 56 | + } |
67 | 57 |
|
68 | | - public void deactivate(ModularSyncManager manager) { |
69 | | - int id = inverseActiveScreens.removeInt(manager); |
70 | | - activeScreens.remove(id); |
71 | | - } |
| 58 | + @SideOnly(Side.CLIENT) |
| 59 | + public void closeContainer(int networkId, boolean dispose, EntityPlayerSP player) { |
| 60 | + closeContainer(networkId, dispose, player, true); |
| 61 | + } |
72 | 62 |
|
73 | | - public void receivePacket(PacketSyncHandler packet) { |
74 | | - ModularSyncManager msm = activeScreens.get(packet.networkId); |
75 | | - if (msm == null) return; // silently discard packets for inactive screens |
76 | | - try { |
77 | | - int id = packet.action ? 0 : packet.packet.readVarInt(); |
78 | | - msm.receiveWidgetUpdate(packet.panel, packet.key, packet.action, id, packet.packet); |
79 | | - } catch (IndexOutOfBoundsException e) { |
80 | | - ModularUI.LOGGER.error("Failed to read packet for sync handler {} in panel {}", packet.key, packet.panel); |
81 | | - } catch (IOException e) { |
82 | | - ModularUI.LOGGER.throwing(e); |
| 63 | + @SideOnly(Side.CLIENT) |
| 64 | + public void closeAll() { |
| 65 | + closeAll(Minecraft.getMinecraft().player); |
83 | 66 | } |
84 | 67 | } |
85 | 68 |
|
86 | | - public void sendSyncHandlerPacket(String panel, SyncHandler syncHandler, PacketBuffer buffer, EntityPlayer player) { |
87 | | - ModularSyncManager msm = syncHandler.getSyncManager().getModularSyncManager(); |
88 | | - if (!inverseActiveScreens.containsKey(msm)) return; |
89 | | - int id = inverseActiveScreens.getInt(msm); |
90 | | - sendPacket(new PacketSyncHandler(id, panel, syncHandler.getKey(), false, buffer), player); |
91 | | - } |
| 69 | + public static final class Server extends ModularNetworkSide { |
| 70 | + |
| 71 | + private int nextId = -1; |
| 72 | + |
| 73 | + private Server() { |
| 74 | + super(false); |
| 75 | + } |
| 76 | + |
| 77 | + public int activate(ModularSyncManager msm) { |
| 78 | + if (++nextId > 100_000) nextId = 0; |
| 79 | + activateInternal(nextId, msm); |
| 80 | + return nextId; |
| 81 | + } |
92 | 82 |
|
93 | | - public void sendActionPacket(ModularSyncManager msm, String panel, String key, PacketBuffer buffer, EntityPlayer player) { |
94 | | - if (!inverseActiveScreens.containsKey(msm)) return; |
95 | | - int id = inverseActiveScreens.getInt(msm); |
96 | | - sendPacket(new PacketSyncHandler(id, panel, key, true, buffer), player); |
| 83 | + @Override |
| 84 | + protected void sendPacket(IPacket packet, EntityPlayer player) { |
| 85 | + NetworkHandler.sendToPlayer(packet, (EntityPlayerMP) player); |
| 86 | + } |
| 87 | + |
| 88 | + @Override |
| 89 | + void closeContainer(EntityPlayer player) { |
| 90 | + ((EntityPlayerMP) player).closeContainer(); |
| 91 | + } |
| 92 | + |
| 93 | + public void closeContainer(int networkId, boolean dispose, EntityPlayerMP player) { |
| 94 | + closeContainer(networkId, dispose, player, true); |
| 95 | + } |
97 | 96 | } |
98 | 97 | } |
0 commit comments