summaryrefslogtreecommitdiffstats
path: root/src/game/client/receive.cc
diff options
context:
space:
mode:
authoruntodesu <kirill@untode.su>2025-12-11 15:14:26 +0500
committeruntodesu <kirill@untode.su>2025-12-11 15:14:26 +0500
commitf40d09cb8f712e87691af4912f3630d92d692779 (patch)
tree7ac3a4168ff722689372fd489c6f94d0a2546e8f /src/game/client/receive.cc
parent8bcbd2729388edc63c82d77d314b583af1447c49 (diff)
downloadvoxelius-f40d09cb8f712e87691af4912f3630d92d692779.tar.bz2
voxelius-f40d09cb8f712e87691af4912f3630d92d692779.zip
Shuffle stuff around
- Use the new and improved hierarchy I figured out when making Prospero chat - Re-add NSIS scripts, again from Prospero - Update most build and utility scripts with their most recent versions
Diffstat (limited to 'src/game/client/receive.cc')
-rw-r--r--src/game/client/receive.cc192
1 files changed, 192 insertions, 0 deletions
diff --git a/src/game/client/receive.cc b/src/game/client/receive.cc
new file mode 100644
index 0000000..a253911
--- /dev/null
+++ b/src/game/client/receive.cc
@@ -0,0 +1,192 @@
+#include "client/pch.hh"
+
+#include "client/receive.hh"
+
+#include "shared/entity/head.hh"
+#include "shared/entity/player.hh"
+#include "shared/entity/transform.hh"
+#include "shared/entity/velocity.hh"
+
+#include "shared/world/dimension.hh"
+
+#include "shared/protocol.hh"
+
+#include "client/entity/factory.hh"
+
+#include "client/gui/chat.hh"
+#include "client/gui/gui_screen.hh"
+#include "client/gui/message_box.hh"
+#include "client/gui/window_title.hh"
+
+#include "client/sound/sound.hh"
+
+#include "client/globals.hh"
+#include "client/session.hh"
+
+static bool synchronize_entity_id(world::Dimension* dimension, entt::entity entity)
+{
+ if(dimension->entities.valid(entity)) {
+ // Entity ID already exists
+ return true;
+ }
+
+ auto created = dimension->entities.create(entity);
+
+ if(created == entity) {
+ // Synchronized successfully
+ return true;
+ }
+
+ session::disconnect("protocol.entity_id_desync");
+ spdlog::critical("receive: entity desync: network {} resolved as client {}", static_cast<std::uint64_t>(entity),
+ static_cast<std::uint64_t>(created));
+
+ gui::message_box::reset();
+ gui::message_box::set_title("disconnected.disconnected");
+ gui::message_box::set_subtitle("protocol.entity_id_desync");
+ gui::message_box::add_button("disconnected.back", [](void) {
+ globals::gui_screen = GUI_PLAY_MENU;
+ gui::window_title::update();
+ });
+
+ globals::gui_screen = GUI_MESSAGE_BOX;
+
+ return false;
+}
+
+static void on_dimension_info_packet(const protocol::DimensionInfo& packet)
+{
+ if(session::peer) {
+ if(globals::dimension) {
+ delete globals::dimension;
+ globals::dimension = nullptr;
+ globals::player = entt::null;
+ }
+
+ globals::dimension = new world::Dimension(packet.name.c_str(), packet.gravity);
+ }
+}
+
+static void on_chunk_voxels_packet(const protocol::ChunkVoxels& packet)
+{
+ if(session::peer && globals::dimension) {
+ auto chunk = globals::dimension->create_chunk(packet.chunk);
+ chunk->set_voxels(packet.voxels);
+
+ world::ChunkUpdateEvent event;
+ event.dimension = globals::dimension;
+ event.cpos = packet.chunk;
+ event.chunk = chunk;
+
+ globals::dispatcher.trigger(event);
+
+ return;
+ }
+}
+
+static void on_entity_head_packet(const protocol::EntityHead& packet)
+{
+ if(session::peer && globals::dimension) {
+ if(synchronize_entity_id(globals::dimension, packet.entity)) {
+ auto& component = globals::dimension->entities.get_or_emplace<entity::Head>(packet.entity);
+ auto& prevcomp = globals::dimension->entities.get_or_emplace<entity::client::HeadPrev>(packet.entity);
+
+ // Store the previous component state
+ prevcomp.angles = component.angles;
+ prevcomp.offset = component.offset;
+
+ // Assign the new component state
+ component.angles = packet.angles;
+ }
+ }
+}
+
+static void on_entity_transform_packet(const protocol::EntityTransform& packet)
+{
+ if(session::peer && globals::dimension) {
+ if(synchronize_entity_id(globals::dimension, packet.entity)) {
+ auto& component = globals::dimension->entities.get_or_emplace<entity::Transform>(packet.entity);
+ auto& prevcomp = globals::dimension->entities.get_or_emplace<entity::client::TransformPrev>(packet.entity);
+
+ // Store the previous component state
+ prevcomp.angles = component.angles;
+ prevcomp.chunk = component.chunk;
+ prevcomp.local = component.local;
+
+ // Assign the new component state
+ component.angles = packet.angles;
+ component.chunk = packet.chunk;
+ component.local = packet.local;
+ }
+ }
+}
+
+static void on_entity_velocity_packet(const protocol::EntityVelocity& packet)
+{
+ if(session::peer && globals::dimension) {
+ if(synchronize_entity_id(globals::dimension, packet.entity)) {
+ auto& component = globals::dimension->entities.get_or_emplace<entity::Velocity>(packet.entity);
+ component.value = packet.value;
+ }
+ }
+}
+
+static void on_entity_player_packet(const protocol::EntityPlayer& packet)
+{
+ if(session::peer && globals::dimension) {
+ if(synchronize_entity_id(globals::dimension, packet.entity)) {
+ entity::client::create_player(globals::dimension, packet.entity);
+ }
+ }
+}
+
+static void on_spawn_player_packet(const protocol::SpawnPlayer& packet)
+{
+ if(session::peer && globals::dimension) {
+ if(synchronize_entity_id(globals::dimension, packet.entity)) {
+ entity::client::create_player(globals::dimension, packet.entity);
+
+ globals::player = packet.entity;
+ globals::gui_screen = GUI_SCREEN_NONE;
+
+ gui::client_chat::refresh_timings();
+
+ gui::window_title::update();
+ }
+ }
+}
+
+static void on_remove_entity_packet(const protocol::RemoveEntity& packet)
+{
+ if(globals::dimension) {
+ if(packet.entity == globals::player) {
+ globals::player = entt::null;
+ }
+
+ globals::dimension->entities.destroy(packet.entity);
+ }
+}
+
+static void on_generic_sound_packet(const protocol::GenericSound& packet)
+{
+ sound::play_generic(packet.sound.c_str(), packet.looping, packet.pitch);
+}
+
+static void on_entity_sound_packet(const protocol::EntitySound& packet)
+{
+ sound::play_entity(packet.entity, packet.sound.c_str(), packet.looping, packet.pitch);
+}
+
+void client_receive::init(void)
+{
+ globals::dispatcher.sink<protocol::DimensionInfo>().connect<&on_dimension_info_packet>();
+ globals::dispatcher.sink<protocol::ChunkVoxels>().connect<&on_chunk_voxels_packet>();
+ globals::dispatcher.sink<protocol::EntityHead>().connect<&on_entity_head_packet>();
+ globals::dispatcher.sink<protocol::EntityTransform>().connect<&on_entity_transform_packet>();
+ globals::dispatcher.sink<protocol::EntityVelocity>().connect<&on_entity_velocity_packet>();
+ globals::dispatcher.sink<protocol::EntityPlayer>().connect<&on_entity_player_packet>();
+ globals::dispatcher.sink<protocol::SpawnPlayer>().connect<&on_spawn_player_packet>();
+ globals::dispatcher.sink<protocol::RemoveEntity>().connect<&on_remove_entity_packet>();
+ globals::dispatcher.sink<protocol::GenericSound>().connect<&on_generic_sound_packet>();
+ globals::dispatcher.sink<protocol::EntitySound>().connect<&on_entity_sound_packet>();
+}