Improved Send Data to Multiple Sockets

Author: Dragon-Developer

scripts/GameServer/GameServer.gml

@@ -7,9 +7,7 @@ function GameServer(_port) : TCPServer(_port) constructor {
 	});
 	rpc.registerHandler("create_ball", function(_position, _socket) {
 		ballPosition = _position;
-		clients.forEach(function(_client_socket) {
-			rpc.sendNotification("create_ball", ballPosition, _client_socket);
-		});
+		rpc.sendNotification("create_ball", ballPosition, sockets);
 	});
 	rpc.registerHandler("set_name", function(_params, _socket) {
 		if (string_length(_params) > 10) {

scripts/Manager/Manager.gml

@@ -6,6 +6,9 @@ function Manager() constructor {
 	static getCount = function() {
 		return struct_names_count(elements);	
 	}
+	static getKeys = function() {
+		return struct_get_names(elements);	
+	}
 	static getElement = function(_key) {
 		if (struct_exists(elements, _key)) {
 			return elements[$ _key];	

scripts/Network/Network.gml

@@ -13,18 +13,23 @@ function Network() constructor {
 	static setDefaultSocket = function(_socket) {
 		self.defaultSocket = _socket;	
 	}
-	/// @function					sendData()
-	/// @description				Send data to server.
-	/// @param {Struct} data		Data to be sent.
-	/// @param {Id.Socket} socket	Socket to send to.
-	static sendData = function(_data, _socket = self.defaultSocket) {
+	/// @function						sendData()
+	/// @description					Send data to socket.
+	/// @param {Struct} data			Data to be sent.
+	/// @param {Id.Socket} [sockets]	Sockets to send to.
+	static sendData = function(_data, _sockets = [self.defaultSocket]) {
+		if (!is_array(_sockets)) {
+			_sockets = [_sockets];	
+		}
 		buffer_seek(buffer, buffer_seek_start, 0);
 		var _json_string = json_stringify(_data);
 		buffer_write(buffer, buffer_text, _json_string);
-		if (raw) {
-			network_send_raw(_socket, buffer, buffer_tell(buffer));
-		} else {
-			network_send_packet(_socket, buffer, buffer_tell(buffer));
-		}
+		array_foreach(_sockets, function(_socket) {
+			if (raw) {
+				network_send_raw(_socket, buffer, buffer_tell(buffer));
+			} else {
+				network_send_packet(_socket, buffer, buffer_tell(buffer));
+			}
+		});
 	}
 }

scripts/Server/Server.gml

@@ -3,7 +3,7 @@ function Server(_type, _port, _max_clients) constructor {
 	self.type = _type;
 	self.port = _port;
 	self.maxClients = _max_clients;
-	self.clients = [];
+	self.sockets = [];
 	self.clients = new Manager();
 	self.serverInstance = undefined;
 	self.network = new Network();
@@ -23,6 +23,7 @@ function Server(_type, _port, _max_clients) constructor {
 	}
 	static addClient = function(_socket) {
 		clients.setElement(_socket, createClient());
+		array_push(sockets, _socket);
 		triggerEvent("connected", _socket);
 	}
 	static hasClient = function(_socket) {
@@ -34,11 +35,15 @@ function Server(_type, _port, _max_clients) constructor {
 	static removeClient = function(_socket) {
 		triggerEvent("disconnected", _socket);
 		clients.removeElement(_socket);
+		var _index = array_get_index(sockets, _socket);
+		if (_index == -1) return;
+		array_delete(sockets, _index, 1);
 	}
 	static destroy = function() {
 		network_destroy(socket);
 		instance_destroy(serverInstance);
 		clients.clearAll();
+		sockets = [];
 	}
 	static setEvent = function(_event, _method) {
 		events[$ _event] = _method;