From 3cc414185a57be9869d3f4632c571724db09621a Mon Sep 17 00:00:00 2001
From: adman <adman.else@gmail.com>
Date: Fri, 10 Apr 2026 14:30:35 +0200
Subject: [PATCH] implement compression threshold setting

---
 server/login_server.go | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/server/login_server.go b/server/login_server.go
index e8701ba..d13ce42 100644
--- a/server/login_server.go
+++ b/server/login_server.go
@@ -39,7 +39,7 @@ type LoginServer struct {
 	ServerPort           uint16
 	Requested            NameAndUUID
 	Given                *NameAndUUID
-	CompressionThreshold int32 //FIXME: implement this
+	CompressionThreshold int32
 	Status               []byte
 	CompatibleVersions   []int32
 }
@@ -85,7 +85,7 @@ func (l *LoginServer) SetCompressionThreshold(threshold int32) (err error) {
 	if err != nil {
 		return
 	}
-	l.CompressionThreshold = threshold
+	l.RawConn.SetCompressionThreshold(threshold)
 	return
 }
 
@@ -94,6 +94,13 @@ func (l *LoginServer) OnLoginStart(packet *v1_21_8.LoginToServerPacketLoginStart
 	if l.Given == nil {
 		l.Given = &l.Requested
 	}
+	if l.CompressionThreshold < 0 {
+		err = l.SetCompressionThreshold(l.CompressionThreshold)
+		if err != nil {
+			return
+		}
+	}
+
 	err = l.Send(&v1_21_8.LoginToClientPacketSuccess{
 		Uuid:       l.Given.UUID,
 		Username:   l.Given.Name,