aboutsummaryrefslogtreecommitdiff
path: root/src/server/world.hh
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/world.hh')
-rw-r--r--src/server/world.hh59
1 files changed, 59 insertions, 0 deletions
diff --git a/src/server/world.hh b/src/server/world.hh
new file mode 100644
index 0000000..134f63b
--- /dev/null
+++ b/src/server/world.hh
@@ -0,0 +1,59 @@
+#ifndef SERVER_WORLD_HH_
+#define SERVER_WORLD_HH_
+
+#include <cstdint>
+
+#include "server/database.hh"
+#include "server/shared.hh"
+#include "shared/math.hh"
+#include "shared/net/net.hh"
+#include "shared/net/proto.hh"
+#include "shared/player.hh"
+#include "shared/world.hh"
+
+namespace server {
+namespace world {
+
+class chunk : public shared::world::chunk {
+private:
+ bool should_write = false;
+ bool should_update = true;
+
+public:
+ proto::packet packet; // Packet ready for sending, updated in update().
+ void arm_should_update() noexcept {
+ this->should_update = this->should_write = true;
+ }
+ bool get_should_update() noexcept { return this->should_update; }
+
+private:
+ proto::packet make_chunk_packet() const noexcept;
+
+public:
+ // Attempt to read the file using protobuf, otherwise create a new chunk.
+ // chunk(const chunk&) = delete;
+ chunk(const uint64_t& seed, const shared::math::coords& coords) noexcept;
+ ~chunk() noexcept;
+
+ // Update the chunk_packet associated with the chunk if necessary.
+ void update() noexcept {
+ if (!this->should_update) {
+ return;
+ }
+ this->packet = make_chunk_packet();
+ this->should_update = false;
+ }
+ // calling .write before the destrutor will not result in a double write
+ void write() noexcept {
+ if (!this->should_write) {
+ return;
+ }
+ server::database::write_chunk(this->pos, this->packet.chunk_packet());
+ this->should_write = false;
+ }
+};
+
+} // namespace world
+} // namespace server
+
+#endif