Added Buffer Compression Option

Author: Dragon-Developer

objects/obj_client/Other_68.gml

@@ -16,7 +16,7 @@ if (_type == network_type_non_blocking_connect) {
 else if (_type == network_type_data) {
 	var _buffer = async_load[? "buffer"];
 	try {
-		var _json = buffer_read(_buffer, buffer_text);
+		var _json = client.network.readBufferText(_buffer);
 		var _data = json_parse(_json);
 		client.triggerEvent("message", {
 			data: _data,

objects/obj_server/Other_68.gml

@@ -17,7 +17,7 @@ if (_id == server.socket) {
 else if (_type == network_type_data && server.hasClient(_id)) {
 	var _buffer = async_load[? "buffer"];
 	try {
-		var _json = buffer_read(_buffer, buffer_text);
+		var _json = server.network.readBufferText(_buffer);
 		var _data = json_parse(_json);
 		server.triggerEvent("message", {
 			data: _data,

scripts/GameClient/GameClient.gml

@@ -1,4 +1,5 @@
 function GameClient(_ip, _port) : TCPSocket(_ip, _port) constructor {
+	network.setCompress(true);
 	self.ping = 0;
 	rpc.registerHandler("create_ball", function(_pos) {
 		var _inst = instance_create_depth(_pos.x, _pos.y, 0, obj_ball);

scripts/GameServer/GameServer.gml

@@ -1,4 +1,5 @@
 function GameServer(_port) : TCPServer(_port) constructor {
+	network.setCompress(true);
 	static createClient = function() {
 		return new Client();	
 	};

scripts/Network/Network.gml

@@ -4,14 +4,35 @@ function Network() constructor {
 	self.raw = false;
 	self.type = network_socket_tcp;
 	self.defaultSocket = -1;
+	self.compress = false;
 	static setRAW = function(_raw) {
 		self.raw = _raw;
+		return self;
 	}
 	static setType = function(_type) {
 		self.type = _type;	
+		return self;
 	}
 	static setDefaultSocket = function(_socket) {
-		self.defaultSocket = _socket;	
+		self.defaultSocket = _socket;
+		return self;
+	}
+	static setCompress = function(_value) {
+		self.compress = _value;	
+		return self;
+	}
+	/// @function						readBufferText()
+	/// @description					Read the buffer as a text.
+	/// @param {Id.Buffer} buffer		The index of the buffer to read from.
+	/// @returns {String}
+	static readBufferText = function(_buffer) {
+		if (!compress) {
+			return buffer_read(_buffer, buffer_text);
+		}
+		var _decompressed = buffer_decompress(_buffer);	
+		var _text = buffer_read(_decompressed, buffer_text);
+		buffer_delete(_decompressed);
+		return _text;
 	}
 	/// @function						sendData()
 	/// @description					Send data to socket.
@@ -24,6 +45,12 @@ function Network() constructor {
 		buffer_seek(buffer, buffer_seek_start, 0);
 		var _json_string = json_stringify(_data);
 		buffer_write(buffer, buffer_text, _json_string);
+		if (compress) {
+			var _compressed = buffer_compress(buffer, 0, buffer_tell(buffer));
+			buffer_delete(buffer);
+			buffer = _compressed;
+			buffer_seek(buffer, 0, buffer_get_size(_compressed));
+		}
 		array_foreach(_sockets, function(_socket) {
 			if (raw) {
 				network_send_raw(_socket, buffer, buffer_tell(buffer));

scripts/RPC/RPC.gml

@@ -20,6 +20,18 @@ function RPC(_socket) constructor {
 		_data.jsonrpc = "2.0";
 		network.sendData(_data, _socket);
 	}
+	/// @function sendRequest()
+	///
+	/// @description
+	/// Function to send requests by invoking the specified method with the given parameters
+	/// over the provided socket. Allows handling both successful results and errors through callbacks.
+	///
+	/// @param {String} method - Name of the method to be invoked.
+	/// @param {Struct|Array} params - Parameters to be used in the request.
+	/// @param {Function} callback - Function to execute when the result is received successfully.
+	/// @param {Function} errback - Function to execute when an error occurs.
+	/// @param {Function} socket - Socket to which the request will be sent.
+	/// @param {Real} timeout - Time, in seconds, to wait for the request result before timing out.
 	static sendRequest = function(_method, _params, _callback, _errback, _socket = socket, _timeout = timeout) {
 		var _id = generateID();
 		sendJSON({