X-Git-Url: https://git.localhorst.tv/?a=blobdiff_plain;f=src%2Fnet%2FClientConnection.hpp;h=c37540907851f7cd8c1f9cc8cf4dfca3ff193941;hb=68f47f2824989b21ff9a480a367a6d0a41804f41;hp=8c5306c07945d4f80d4af15c44400d160508126e;hpb=c6ca9d21e45af5ea7caeec722a9b59fdf3aa3b24;p=blank.git diff --git a/src/net/ClientConnection.hpp b/src/net/ClientConnection.hpp index 8c5306c..c375409 100644 --- a/src/net/ClientConnection.hpp +++ b/src/net/ClientConnection.hpp @@ -3,7 +3,9 @@ #include "Connection.hpp" #include "ConnectionHandler.hpp" +#include "../app/IntervalTimer.hpp" +#include #include @@ -30,15 +32,44 @@ public: void DetachPlayer(); bool HasPlayer() const noexcept { return player; } Entity &Player() noexcept { return *player; } + const Entity &Player() const noexcept { return *player; } + +private: + struct SpawnStatus { + // the entity in question + Entity *const entity = nullptr; + // sequence number of the spawn packet or -1 after it's been ack'd + std::int32_t spawn_pack = -1; + // sequence number of the despawn packet or -1 if no despawn has been sent + std::int32_t despawn_pack = -1; + + explicit SpawnStatus(Entity &); + ~SpawnStatus(); + }; + +private: + void OnPacketReceived(std::uint16_t) override; + void OnPacketLost(std::uint16_t) override; void On(const Packet::Login &) override; void On(const Packet::Part &) override; void On(const Packet::PlayerUpdate &) override; + bool CanSpawn(const Entity &) const noexcept; + bool CanDespawn(const Entity &) const noexcept; + + void SendSpawn(SpawnStatus &); + void SendDespawn(SpawnStatus &); + void SendUpdate(SpawnStatus &); + private: Server &server; Connection conn; Entity *player; + std::list spawns; + unsigned int confirm_wait; + std::uint16_t player_update_pack; + IntervalTimer player_update_timer; };