Updated to v1.3.1

Added DeflaterCompression class to compress packets using the DeflaterOutputStream/InflaterOutputStream. Moved the initialization of ByteArrayOutputStream & DataOutputStream to the constructor of PacketBuilder. Added a default buffer size for Client & Server of value 8192 and updated the example & readme file accordingly.

Author: synsejse

.idea/vcs.xml

@@ -24,12 +24,12 @@ private static final String secretKey = "1F16hIQ3SjQ$k1!9";
 
 public static void main(String[] args) throws Exception {
     // Create and start the server
-    Server server = new Server(1024);
+    Server server = new Server();
     server.addListener(createServerListener());
     server.start(3300, 3301);
 
     // Create and connect the client to the server
-    Client client = new Client(1024);
+    Client client = new Client();
     client.addListener(createClientListener());
     client.connect("127.0.0.1", 3300, 3301);
 

README.md

@@ -6,7 +6,7 @@
 
     <groupId>xyz.synse</groupId>
     <artifactId>PacketNet</artifactId>
-    <version>1.3</version>
+    <version>1.3.1</version>
 
     <properties>
         <maven.compiler.source>20</maven.compiler.source>

pom.xml

@@ -22,12 +22,12 @@ public class Test {
 
     public static void main(String[] args) throws Exception {
         // Create and start the server
-        Server server = new Server(1024);
+        Server server = new Server();
         server.addListener(createServerListener());
         server.start(3300, 3301);
 
         // Create and connect the client to the server
-        Client client = new Client(1024);
+        Client client = new Client();
         client.addListener(createClientListener());
         client.connect("127.0.0.1", 3300, 3301);
 

src/main/java/xyz/synse/packetnet/Test.java

@@ -22,10 +22,22 @@ public class Client {
     private Thread tcpThread;
     private Thread udpThread;
 
+    /**
+     * Creates a new instance of the Client class.
+     *
+     * @param bufferSize The size of the buffer for receiving data.
+     */
     public Client(int bufferSize) {
         this.bufferSize = bufferSize;
     }
 
+    /**
+     * Creates a new instance of the Client class with buffer size of 8192 bytes.
+     */
+    public Client() {
+        this(8192);
+    }
+
     /**
      * Connects the client to the server using the specified TCP and UDP ports.
      *

src/main/java/xyz/synse/packetnet/client/Client.java

@@ -1,12 +1,14 @@
 package xyz.synse.packetnet.common.compression;
 
+import xyz.synse.packetnet.common.compression.compressors.DeflaterCompressor;
 import xyz.synse.packetnet.common.compression.compressors.GZipCompressor;
 import xyz.synse.packetnet.common.compression.compressors.LZ4Compressor;
 import xyz.synse.packetnet.common.packets.Packet;
 
 import java.io.IOException;
 
 public class PacketCompressor {
+    public static final ICompressor DEFLATER_COMPRESSOR = new DeflaterCompressor();
     public static final ICompressor GZIP_COMPRESSOR = new GZipCompressor();
     public static final ICompressor LZ4_COMPRESSOR = new LZ4Compressor();
 

src/main/java/xyz/synse/packetnet/common/compression/PacketCompressor.java

@@ -0,0 +1,32 @@
+package xyz.synse.packetnet.common.compression.compressors;
+
+import xyz.synse.packetnet.common.compression.ICompressor;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.util.zip.DeflaterOutputStream;
+import java.util.zip.InflaterOutputStream;
+
+public class DeflaterCompressor implements ICompressor {
+    @Override
+    public byte[] compress(byte[] in) throws IOException {
+        ByteArrayOutputStream out = new ByteArrayOutputStream();
+        DeflaterOutputStream defl = new DeflaterOutputStream(out);
+        defl.write(in);
+        defl.flush();
+        defl.close();
+
+        return out.toByteArray();
+    }
+
+    @Override
+    public byte[] decompress(byte[] in) throws IOException {
+        ByteArrayOutputStream out = new ByteArrayOutputStream();
+        InflaterOutputStream infl = new InflaterOutputStream(out);
+        infl.write(in);
+        infl.flush();
+        infl.close();
+
+        return out.toByteArray();
+    }
+}

src/main/java/xyz/synse/packetnet/common/compression/compressors/DeflaterCompressor.java

@@ -7,11 +7,13 @@
 
 public class PacketBuilder implements AutoCloseable {
     private final short id;
-    private final ByteArrayOutputStream byteOut = new ByteArrayOutputStream();
-    private final DataOutputStream out = new DataOutputStream(byteOut);
+    private final ByteArrayOutputStream byteOut;
+    private final DataOutputStream out;
 
     public PacketBuilder(short id) {
         this.id = id;
+        this.byteOut = new ByteArrayOutputStream();
+        this.out = new DataOutputStream(byteOut);
     }
 
     public PacketBuilder withBytes(byte[] data) {

src/main/java/xyz/synse/packetnet/common/packets/PacketBuilder.java

@@ -32,6 +32,13 @@ public Server(int bufferSize) {
         running = false;
     }
 
+    /**
+     * Creates a new instance of the Server class with buffer size of 8192 bytes.
+     */
+    public Server() {
+        this(8192);
+    }
+
     /**
      * Starts the server on the specified TCP and UDP ports.
      *