From a057004cd2aac9e59ae2ad5a097afaf15e801418 Mon Sep 17 00:00:00 2001
From: SantaSpeen <SantaSpeen@gmail.com>
Date: Sat, 8 Jul 2023 18:57:18 +0300
Subject: [PATCH] Decompress data

---
 README.md        |  5 ++++-
 src/core/core.py | 10 +++++-----
 2 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/README.md b/README.md
index 4e8295e..84dcdb5 100644
--- a/README.md
+++ b/README.md
@@ -15,10 +15,13 @@ BeamingDrive Multiplayer (BeamMP) server compatible with BeamMP clients.
     - [x] Connecting to the world
     - [x] Chat
     - [ ] ABG: (compressed data)
-      - [ ] Decompress data
+      - [x] Decompress data
       - [ ] Vehicle data
+    - [ ] Players synchronizations
   - [ ] UDP Server part:
     - [ ] Players synchronizations
+    - [ ] Ping
+    - [ ] Player counter
   - [x] Additional:
     - [x] Events System
     - [x] Plugins support
diff --git a/src/core/core.py b/src/core/core.py
index 9bd82c1..03f02c7 100644
--- a/src/core/core.py
+++ b/src/core/core.py
@@ -5,6 +5,7 @@
 # Licence: FPA
 # (c) kuitoi.su 2023
 import asyncio
+import zlib
 
 from core import utils
 from .tcp_server import TCPServer
@@ -87,17 +88,16 @@ class Client:
             return b""
 
         data = await self.reader.read(101 * MB)
+        self.log.debug(f"header: `{header}`; int_header: `{int_header}`; data: `{data}`;")
 
         if len(data) != int_header:
             self.log.debug(f"WARN Expected to read {int_header} bytes, instead got {len(data)}")
 
-        self.log.debug(f"header: `{header}`; int_header: `{int_header}`; data: `{data}`;")
-        # TODO: ABG: DeComp(Data)
         abg = b"ABG:"
         if len(data) > len(abg) and data.startswith(abg):
-            data = data[len(abg):]
-            return b""
-            # return DeComp(Data);
+            data = zlib.decompress(data[len(abg):])
+            self.log.debug(f"ABG: {data}")
+            return data
         return data
 
     async def sync_resources(self):