#include "../app/Environment.hpp"
#include "../app/init.hpp"
-#include "../app/TextureIndex.hpp"
#include "../model/Model.hpp"
#include "../io/WorldSave.hpp"
#include "../world/ChunkIndex.hpp"
// TODO: this clutter is a giant mess
InteractiveState::InteractiveState(MasterState &master, uint32_t player_id)
: master(master)
-, shapes()
-, block_types()
+, res()
+, sounds()
, save(master.GetEnv().config.GetWorldPath(master.GetWorldConf().name, master.GetConfig().net.host))
-, world(block_types, master.GetWorldConf())
+, world(res.block_types, master.GetWorldConf())
, player(*world.AddPlayer(master.GetConfig().player.name))
, hud(master.GetEnv(), master.GetConfig(), player)
-, manip(master.GetEnv(), player.GetEntity())
+, manip(master.GetEnv().audio, sounds, player.GetEntity())
, input(world, player, master.GetClient())
, interface(master.GetConfig(), master.GetEnv().keymap, input, *this)
, chunk_receiver(world.Chunks(), save)
, chunk_renderer(player.GetChunks())
-, skeletons()
, loop_timer(16)
-, sky(master.GetEnv().loader.LoadCubeMap("skybox")) {
+, sky(master.GetEnv().loader.LoadCubeMap("skybox"))
+, update_status() {
if (!save.Exists()) {
save.Write(master.GetWorldConf());
}
- TextureIndex tex_index;
- master.GetEnv().loader.LoadShapes("default", shapes);
- master.GetEnv().loader.LoadBlockTypes("default", block_types, tex_index);
- interface.SetInventorySlots(block_types.size() - 1);
- chunk_renderer.LoadTextures(master.GetEnv().loader, tex_index);
+ res.Load(master.GetEnv().loader, "default");
+ sounds.Load(master.GetEnv().loader, res.snd_index);
+ interface.SetInventorySlots(res.block_types.size() - 1);
+ chunk_renderer.LoadTextures(master.GetEnv().loader, res.tex_index);
chunk_renderer.FogDensity(master.GetWorldConf().fog_density);
- skeletons.Load();
loop_timer.Start();
if (save.Exists(player)) {
save.Read(player);
} else {
hud.FocusNone();
}
- hud.Display(block_types[player.GetInventorySlot() + 1]);
+ hud.Display(res.block_types[player.GetInventorySlot() + 1]);
loop_timer.Update(dt);
master.Update(dt);
chunk_receiver.Update(dt);
hud.Render(viewport);
}
-void InteractiveState::MergePlayerCorrection(std::uint16_t pack, const EntityState &state) {
- input.MergePlayerCorrection(pack, state);
+void InteractiveState::Handle(const Packet::SpawnEntity &pack) {
+ uint32_t entity_id;
+ pack.ReadEntityID(entity_id);
+ Entity &entity = world.ForceAddEntity(entity_id);
+ UpdateEntity(entity_id, pack.Seq());
+ pack.ReadEntity(entity);
+ uint32_t skel_id;
+ pack.ReadSkeletonID(skel_id);
+ if (skel_id > 0 && skel_id <= res.models.size()) {
+ Model &skel = res.models.Get(skel_id);
+ skel.Instantiate(entity.GetModel());
+ }
+ cout << "spawned entity #" << entity_id << " (" << entity.Name()
+ << ") at " << entity.AbsolutePosition() << endl;
+}
+
+void InteractiveState::Handle(const Packet::DespawnEntity &pack) {
+ uint32_t entity_id;
+ pack.ReadEntityID(entity_id);
+ ClearEntity(entity_id);
+ for (Entity &entity : world.Entities()) {
+ if (entity.ID() == entity_id) {
+ entity.Kill();
+ cout << "despawned entity #" << entity_id << " (" << entity.Name() << ") at " << entity.AbsolutePosition() << endl;
+ return;
+ }
+ }
+}
+
+void InteractiveState::Handle(const Packet::EntityUpdate &pack) {
+ auto world_iter = world.Entities().begin();
+ auto world_end = world.Entities().end();
+
+ uint32_t count = 0;
+ pack.ReadEntityCount(count);
+
+ for (uint32_t i = 0; i < count; ++i) {
+ uint32_t entity_id = 0;
+ pack.ReadEntityID(entity_id, i);
+
+ while (world_iter != world_end && world_iter->ID() < entity_id) {
+ ++world_iter;
+ }
+ if (world_iter == world_end) {
+ // nothing can be done from here
+ return;
+ }
+ if (world_iter->ID() == entity_id) {
+ if (UpdateEntity(entity_id, pack.Seq())) {
+ pack.ReadEntityState(world_iter->GetState(), i);
+ }
+ }
+ }
+}
+
+bool InteractiveState::UpdateEntity(uint32_t entity_id, uint16_t seq) {
+ auto entry = update_status.find(entity_id);
+ if (entry == update_status.end()) {
+ update_status.emplace(entity_id, UpdateStatus{ seq, loop_timer.Elapsed() });
+ return true;
+ }
+
+ int16_t pack_diff = int16_t(seq) - int16_t(entry->second.last_packet);
+ int time_diff = loop_timer.Elapsed() - entry->second.last_update;
+ entry->second.last_update = loop_timer.Elapsed();
+
+ if (pack_diff > 0 || time_diff > 1500) {
+ entry->second.last_packet = seq;
+ return true;
+ } else {
+ return false;
+ }
+}
+
+void InteractiveState::ClearEntity(uint32_t entity_id) {
+ update_status.erase(entity_id);
+}
+
+void InteractiveState::Handle(const Packet::PlayerCorrection &pack) {
+ uint16_t pack_seq;
+ EntityState corrected_state;
+ pack.ReadPacketSeq(pack_seq);
+ pack.ReadPlayerState(corrected_state);
+ input.MergePlayerCorrection(pack_seq, corrected_state);
}
void InteractiveState::Handle(const Packet::BlockUpdate &pack) {
Block block;
pack.ReadIndex(index, i);
pack.ReadBlock(block, i);
- if (index < Chunk::size && block.type < block_types.size()) {
+ if (index < Chunk::size && block.type < res.block_types.size()) {
manip.SetBlock(*chunk, index, block);
}
}
, state()
, client(config.net)
, init_state(*this)
-, login_packet(-1)
-, update_status()
-, update_timer(16) {
+, login_packet(-1) {
client.GetConnection().SetHandler(this);
- update_timer.Start();
}
void MasterState::Quit() {
void MasterState::Update(int dt) {
- update_timer.Update(dt);
client.Handle();
client.Update(dt);
}
cout << "got entity spawn before world was created" << endl;
return;
}
- uint32_t entity_id;
- pack.ReadEntityID(entity_id);
- Entity &entity = state->GetWorld().ForceAddEntity(entity_id);
- UpdateEntity(entity_id, pack.Seq());
- pack.ReadEntity(entity);
- uint32_t skel_id;
- pack.ReadSkeletonID(skel_id);
- Model *skel = state->GetSkeletons().ByID(skel_id);
- if (skel) {
- skel->Instantiate(entity.GetModel());
- }
- cout << "spawned entity #" << entity_id << " (" << entity.Name()
- << ") at " << entity.AbsolutePosition() << endl;
+ state->Handle(pack);
}
void MasterState::On(const Packet::DespawnEntity &pack) {
cout << "got entity despawn before world was created" << endl;
return;
}
- uint32_t entity_id;
- pack.ReadEntityID(entity_id);
- ClearEntity(entity_id);
- for (Entity &entity : state->GetWorld().Entities()) {
- if (entity.ID() == entity_id) {
- entity.Kill();
- cout << "despawned entity #" << entity_id << " (" << entity.Name() << ") at " << entity.AbsolutePosition() << endl;
- return;
- }
- }
+ state->Handle(pack);
}
void MasterState::On(const Packet::EntityUpdate &pack) {
cout << "got entity update before world was created" << endl;
return;
}
-
- auto world_iter = state->GetWorld().Entities().begin();
- auto world_end = state->GetWorld().Entities().end();
-
- uint32_t count = 0;
- pack.ReadEntityCount(count);
-
- for (uint32_t i = 0; i < count; ++i) {
- uint32_t entity_id = 0;
- pack.ReadEntityID(entity_id, i);
-
- while (world_iter != world_end && world_iter->ID() < entity_id) {
- ++world_iter;
- }
- if (world_iter == world_end) {
- // nothing can be done from here
- return;
- }
- if (world_iter->ID() == entity_id) {
- if (UpdateEntity(entity_id, pack.Seq())) {
- pack.ReadEntityState(world_iter->GetState(), i);
- }
- }
- }
-}
-
-bool MasterState::UpdateEntity(uint32_t entity_id, uint16_t seq) {
- auto entry = update_status.find(entity_id);
- if (entry == update_status.end()) {
- update_status.emplace(entity_id, UpdateStatus{ seq, update_timer.Elapsed() });
- return true;
- }
-
- int16_t pack_diff = int16_t(seq) - int16_t(entry->second.last_packet);
- int time_diff = update_timer.Elapsed() - entry->second.last_update;
- entry->second.last_update = update_timer.Elapsed();
-
- if (pack_diff > 0 || time_diff > 1500) {
- entry->second.last_packet = seq;
- return true;
- } else {
- return false;
- }
-}
-
-void MasterState::ClearEntity(uint32_t entity_id) {
- update_status.erase(entity_id);
+ state->Handle(pack);
}
void MasterState::On(const Packet::PlayerCorrection &pack) {
cout << "got player correction without a player :S" << endl;
return;
}
- uint16_t pack_seq;
- EntityState corrected_state;
- pack.ReadPacketSeq(pack_seq);
- pack.ReadPlayerState(corrected_state);
- state->MergePlayerCorrection(pack_seq, corrected_state);
+ state->Handle(pack);
}
void MasterState::On(const Packet::ChunkBegin &pack) {