CHUNK LOADING KINDA WORKS

pumpkin-protocol/Cargo.toml

@@ -6,6 +6,7 @@ edition.workspace = true
 [dependencies]
 
 pumpkin-macros = { path = "../pumpkin-macros" }
+pumpkin-world =  { path = "../pumpkin-world" }
 
 bytes = "1.7"
 
@@ -29,3 +30,4 @@ fastnbt = { git = "https://github.com/owengage/fastnbt.git" }
 aes = "0.8.4"
 cfb8 = "0.8.1"
 take_mut = "0.2.2"
+itertools = "0.13.0"

pumpkin-protocol/src/bytebuf/packet_id.rs

@@ -3,10 +3,20 @@ use serde::{
     Deserialize, Deserializer, Serialize, Serializer,
 };
 
-use crate::{ClientPacket, ServerPacket, VarInt, VarIntType};
+use crate::{BitSet, ClientPacket, ServerPacket, VarInt, VarIntType};
 
 use super::{deserializer, serializer, ByteBuffer, DeserializerError};
 
+impl Serialize for BitSet {
+    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
+    where
+        S: Serializer,
+    {
+        // TODO: make this right
+        (self.0.clone(), self.1.clone()).serialize(serializer)
+    }
+}
+
 impl Serialize for VarInt {
     fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
     where

pumpkin-protocol/src/client/play/c_center_chunk.rs

@@ -0,0 +1,10 @@
+use pumpkin_macros::packet;
+
+use crate::VarInt;
+
+#[derive(serde::Serialize)]
+#[packet(0x54)]
+pub struct CCenterChunk {
+  pub chunk_x: VarInt,
+  pub chunk_z: VarInt
+}

pumpkin-protocol/src/client/play/c_chunk_data.rs

@@ -0,0 +1,113 @@
+use std::collections::HashMap;
+
+use crate::{bytebuf::ByteBuffer, BitSet, ClientPacket, VarInt};
+use fastnbt::LongArray;
+use itertools::Itertools;
+use pumpkin_macros::packet;
+use pumpkin_world::chunk::ChunkData;
+
+#[packet(0x27)]
+pub struct CChunkData<'a>(pub &'a ChunkData);
+
+impl<'a> ClientPacket for CChunkData<'a> {
+    fn write(&self, buf: &mut crate::bytebuf::ByteBuffer) {
+        // Chunk X
+        buf.put_i32(self.0.position.0);
+        // Chunk Z
+        buf.put_i32(self.0.position.1);
+
+        let heightmap_nbt =
+            fastnbt::to_bytes_with_opts(&self.0.heightmaps, fastnbt::SerOpts::network_nbt())
+                .unwrap();
+        // Heightmaps
+        buf.put_slice(&heightmap_nbt);
+
+        let mut data_buf = ByteBuffer::empty();
+        self.0
+            .blocks
+            .iter()
+            .chunks(16 * 16 * 16)
+            .into_iter()
+            .for_each(|chunk| {
+                let chunk = chunk.collect_vec();
+                let block_count = chunk
+                    .iter()
+                    .filter(|block| ***block != 0 && ***block != 12959 && ***block != 12958)
+                    .count() as i16;
+                // Block count
+                data_buf.put_i16(block_count);
+                //// Block states
+                let palette = chunk.clone().into_iter().dedup().collect_vec();
+                let mut palette_map = HashMap::new();
+                let block_size = 8;
+                // let block_size = {
+                //     let palette_bit_len = palette.len().leading_zeros();
+                //     if palette_bit_len > 3 {
+                //         palette_bit_len
+                //     } else {
+                //         4
+                //     }
+                // };
+                // Bits per entry
+                data_buf.put_u8(block_size as u8);
+                // Palette length
+                data_buf.put_var_int(&VarInt(palette.len() as i32));
+                palette.iter().enumerate().for_each(|(i, id)| {
+                    palette_map.insert(*id, i);
+                    // Palette
+                    data_buf.put_var_int(&VarInt(**id as i32));
+                });
+                let mut block_data_array = Vec::new();
+                for block_clump in chunk.chunks(64 / block_size as usize) {
+                    let mut out_long: i64 = 0;
+                    let mut first = true;
+                    for block in block_clump {
+                        if first {
+                            first = false;
+                        } else {
+                            out_long = out_long << block_size;
+                        }
+                        let index = palette_map
+                            .get(block)
+                            .expect("Its just got added, ofc it should be there");
+                        out_long = out_long | *index as i64;
+                    }
+                    block_data_array.push(out_long);
+                }
+
+                // Data array length
+                data_buf.put_var_int(&VarInt(block_data_array.len() as i32));
+                // Data array
+                for data_int in block_data_array {
+                    data_buf.put_i64(data_int);
+                }
+
+                //// Biomes
+                // TODO: make biomes work
+                data_buf.put_u8(0);
+                data_buf.put_var_int(&VarInt(0));
+                data_buf.put_var_int(&VarInt(0));
+            });
+
+        // Size
+        buf.put_var_int(&VarInt(data_buf.buf().len() as i32));
+        // Data
+        buf.put_slice(&data_buf.buf());
+
+        // TODO: block entities
+        buf.put_var_int(&VarInt(0));
+
+        // TODO
+        buf.put_bit_set(&BitSet(VarInt(1), vec![0]));
+        buf.put_bit_set(&BitSet(VarInt(1), vec![0]));
+        buf.put_bit_set(&BitSet(VarInt(1), vec![0]));
+        buf.put_bit_set(&BitSet(VarInt(1), vec![0]));
+        // buf.put_bit_set(&BitSet(VarInt(0), vec![]));
+        // buf.put_bit_set(&BitSet(VarInt(0), vec![]));
+        // buf.put_bit_set(&BitSet(VarInt(0), vec![]));
+        // buf.put_bit_set(&BitSet(VarInt(0), vec![]));
+
+        buf.put_var_int(&VarInt(0));
+        buf.put_var_int(&VarInt(0));
+    }
+}

pumpkin-protocol/src/client/play/mod.rs

@@ -1,4 +1,6 @@
+mod c_center_chunk;
 mod c_change_difficulty;
+mod c_chunk_data;
 mod c_chunk_data_update_light;
 mod c_disguised_chat_message;
 mod c_entity_animation;
@@ -20,7 +22,9 @@ mod c_update_entity_pos;
 mod c_update_entity_rot;
 mod player_action;
 
+pub use c_center_chunk::*;
 pub use c_change_difficulty::*;
+pub use c_chunk_data::*;
 pub use c_chunk_data_update_light::*;
 pub use c_disguised_chat_message::*;
 pub use c_entity_animation::*;

pumpkin-protocol/src/packet_encoder.rs

@@ -32,7 +32,7 @@ impl PacketEncoder {
             .encode(&mut writer)
             .map_err(|_| PacketError::EncodeID)?;
         packet.write(&mut packet_buf);
-
+        
         writer
             .write(packet_buf.buf())
             .map_err(|_| PacketError::EncodeFailedWrite)?;

pumpkin-world/Cargo.toml

@@ -4,8 +4,14 @@ version.workspace = true
 edition.workspace = true
 
 [dependencies]
-pumpkin-protocol = { path = "../pumpkin-protocol"}
-fastanvil = "0.31"
+# fastanvil = "0.31"
 fastnbt = { git = "https://github.com/owengage/fastnbt.git" }
 fastsnbt = "0.2"
-tokio.workspace = true
+tokio.workspace = true
+itertools = "0.13.0"
+thiserror = "1.0.63"
+futures = "0.3.30"
+flate2 = "1.0.31"
+serde = { version = "1.0.205", features = ["derive"] }
+lazy_static = "1.5.0"
+serde_json = "1.0.122"