still aint working

Author: OmniacDev

src/jvmMain/kotlin/experimental/network/connection/BedrockPeer.kt

@@ -48,6 +48,7 @@ class BedrockPeer(val rakSession: RakSession) {
     fun close() {
         for (session in sessions.values) {
             session.close(null)
+            session.onClose()
         }
     }
 

src/jvmMain/kotlin/network/connection/BedrockSession.kt

@@ -28,6 +28,8 @@ import org.chorus_oss.chorus.registry.CreativeItemRegistry
 import org.chorus_oss.chorus.registry.Registries
 import org.chorus_oss.chorus.utils.Loggable
 import org.chorus_oss.protocol.core.Packet
+import org.chorus_oss.protocol.core.ProtoVAR
+import org.chorus_oss.protocol.core.types.UInt
 import org.chorus_oss.protocol.packets.CraftingDataPacket
 import org.chorus_oss.protocol.packets.NetworkSettingsPacket
 import org.chorus_oss.protocol.types.DisconnectFailReason
@@ -168,11 +170,16 @@ class BedrockSession(val peer: BedrockPeer, val subClientId: Int) : Loggable {
             targetSubClientID = 0u,
         )
 
-        val raw = Buffer().also {
+        val wrapper = Buffer().also {
             PacketHeader.serialize(header, it)
             it.write(buf.readByteArray())
         }
 
+        val raw = Buffer().apply {
+            ProtoVAR.UInt.serialize(wrapper.size.toUInt(), this)
+            write(wrapper, wrapper.size)
+        }
+
         peer.sendRaw(RakPriority.Normal, raw)
     }
 

src/jvmMain/kotlin/network/process/handler/SpawnResponseHandler.kt

@@ -232,7 +232,7 @@ class SpawnResponseHandler(session: BedrockSession) : BedrockSessionPacketHandle
             serverAuthoritativeSound = false,
             tickDeathSystemsEnabled = false,
         )
-        player.sendPacket(packet)
+        player.sendPacketImmediately(packet)
     }
 
     override fun handle(packet: Packet) {