ocrm.bsky.social
the game where you go into mines and start crafting! but for consoles (forked directly from smartcmd's github)
1#include "ConsoleInputSource.h"
2#include "..\Minecraft.World\PacketListener.h"
3#include "..\Minecraft.World\JavaIntHash.h"
4
5class MinecraftServer;
6class Connection;
7class ServerPlayer;
8class INetworkPlayer;
9
10using namespace std;
11
12class PlayerConnection : public PacketListener, public ConsoleInputSource
13{
14// public static Logger logger = Logger.getLogger("Minecraft");
15
16public:
17 Connection *connection;
18 bool done;
19 CRITICAL_SECTION done_cs;
20
21 // 4J Stu - Added this so that we can manage UGC privileges
22 PlayerUID m_offlineXUID, m_onlineXUID;
23 bool m_friendsOnlyUGC;
24
25private:
26 MinecraftServer *server;
27 shared_ptr<ServerPlayer> player;
28 int tickCount;
29 int aboveGroundTickCount;
30
31 bool didTick;
32 int lastKeepAliveId;
33 __int64 lastKeepAliveTime;
34 static Random random;
35 __int64 lastKeepAliveTick;
36 int chatSpamTickCount;
37 int dropSpamTickCount;
38
39 bool m_bHasClientTickedOnce;
40
41public:
42 PlayerConnection(MinecraftServer *server, Connection *connection, shared_ptr<ServerPlayer> player);
43 ~PlayerConnection();
44 void tick();
45 void disconnect(DisconnectPacket::eDisconnectReason reason);
46
47private:
48 double xLastOk, yLastOk, zLastOk;
49 bool synched;
50
51public:
52 virtual void handlePlayerInput(shared_ptr<PlayerInputPacket> packet);
53 virtual void handleMovePlayer(shared_ptr<MovePlayerPacket> packet);
54 void teleport(double x, double y, double z, float yRot, float xRot, bool sendPacket = true); // 4J Added sendPacket param
55 virtual void handlePlayerAction(shared_ptr<PlayerActionPacket> packet);
56 virtual void handleUseItem(shared_ptr<UseItemPacket> packet);
57 virtual void onDisconnect(DisconnectPacket::eDisconnectReason reason, void *reasonObjects);
58 virtual void onUnhandledPacket(shared_ptr<Packet> packet);
59 void send(shared_ptr<Packet> packet);
60 void queueSend(shared_ptr<Packet> packet); // 4J Added
61 virtual void handleSetCarriedItem(shared_ptr<SetCarriedItemPacket> packet);
62 virtual void handleChat(shared_ptr<ChatPacket> packet);
63private:
64 void handleCommand(const wstring& message);
65public:
66 virtual void handleAnimate(shared_ptr<AnimatePacket> packet);
67 virtual void handlePlayerCommand(shared_ptr<PlayerCommandPacket> packet);
68 virtual void handleDisconnect(shared_ptr<DisconnectPacket> packet);
69 int countDelayedPackets();
70 virtual void info(const wstring& string);
71 virtual void warn(const wstring& string);
72 virtual wstring getConsoleName();
73 virtual void handleInteract(shared_ptr<InteractPacket> packet);
74 bool canHandleAsyncPackets();
75 virtual void handleClientCommand(shared_ptr<ClientCommandPacket> packet);
76 virtual void handleRespawn(shared_ptr<RespawnPacket> packet);
77 virtual void handleContainerClose(shared_ptr<ContainerClosePacket> packet);
78
79private:
80 unordered_map<int, short, IntKeyHash, IntKeyEq> expectedAcks;
81
82public:
83 // 4J Stu - Handlers only valid in debug mode
84#ifndef _CONTENT_PACKAGE
85 virtual void handleContainerSetSlot(shared_ptr<ContainerSetSlotPacket> packet);
86#endif
87 virtual void handleContainerClick(shared_ptr<ContainerClickPacket> packet);
88 virtual void handleContainerButtonClick(shared_ptr<ContainerButtonClickPacket> packet);
89 virtual void handleSetCreativeModeSlot(shared_ptr<SetCreativeModeSlotPacket> packet);
90 virtual void handleContainerAck(shared_ptr<ContainerAckPacket> packet);
91 virtual void handleSignUpdate(shared_ptr<SignUpdatePacket> packet);
92 virtual void handleKeepAlive(shared_ptr<KeepAlivePacket> packet);
93 virtual void handlePlayerInfo(shared_ptr<PlayerInfoPacket> packet); // 4J Added
94 virtual bool isServerPacketListener();
95 virtual void handlePlayerAbilities(shared_ptr<PlayerAbilitiesPacket> playerAbilitiesPacket);
96 virtual void handleCustomPayload(shared_ptr<CustomPayloadPacket> customPayloadPacket);
97 virtual bool isDisconnected();
98
99 // 4J Added
100 virtual void handleCraftItem(shared_ptr<CraftItemPacket> packet);
101 virtual void handleTradeItem(shared_ptr<TradeItemPacket> packet);
102 virtual void handleDebugOptions(shared_ptr<DebugOptionsPacket> packet);
103 virtual void handleTexture(shared_ptr<TexturePacket> packet);
104 virtual void handleTextureAndGeometry(shared_ptr<TextureAndGeometryPacket> packet);
105 virtual void handleTextureChange(shared_ptr<TextureChangePacket> packet);
106 virtual void handleTextureAndGeometryChange(shared_ptr<TextureAndGeometryChangePacket> packet);
107 virtual void handleServerSettingsChanged(shared_ptr<ServerSettingsChangedPacket> packet);
108 virtual void handleKickPlayer(shared_ptr<KickPlayerPacket> packet);
109 virtual void handleGameCommand(shared_ptr<GameCommandPacket> packet);
110
111 INetworkPlayer *getNetworkPlayer();
112 bool isLocal();
113 bool isGuest();
114
115 // 4J Added as we need to set this from outside sometimes
116 void setPlayer(shared_ptr<ServerPlayer> player) { this->player = player; }
117 shared_ptr<ServerPlayer> getPlayer() { return player; }
118
119 // 4J Added to signal a disconnect from another thread
120 void closeOnTick() { m_bCloseOnTick = true; }
121
122 // 4J Added so that we can send on textures that get received after this connection requested them
123 void handleTextureReceived(const wstring &textureName);
124 void handleTextureAndGeometryReceived(const wstring &textureName);
125
126 void setShowOnMaps(bool bVal);
127
128 void setWasKicked() { m_bWasKicked = true; }
129 bool getWasKicked() { return m_bWasKicked; }
130
131 // 4J Added
132 bool hasClientTickedOnce() { return m_bHasClientTickedOnce; }
133
134private:
135 bool m_bCloseOnTick;
136 vector<wstring> m_texturesRequested;
137
138 bool m_bWasKicked;
139};