improvements of sockethandler, possibility for maniacontrol to maniacontrol connections

2015-06-22 22:52:26 +02:00
parent 687bb7be1b
commit 35de1b1b87
6 changed files with 192 additions and 18 deletions
--- a/core/Communication/Communication.php
+++ b/core/Communication/Communication.php
@ -0,0 +1,103 @@
+<?php
+
+namespace ManiaControl\Communication;
+
+/**
+ * Class for Communicating with other ManiaControls
+ * to call @see ManiaControl\Communication\CommunicationManager\createCommunication
+ *
+ * @author    ManiaControl Team <mail@maniacontrol.com>
+ * @copyright 2014-2015 ManiaControl Team
+ * @license   http://www.gnu.org/licenses/ GNU General Public License, Version 3
+ */
+class Communication {
+	private $socket;
+	private $ip;
+	private $port;
+	private $encryptionPassword;
+
+	private $buffer       = "";
+	private $messageQueue = array();
+
+	public function __construct($ip, $port, $encryptionPassword) {
+		$this->ip                 = $ip;
+		$this->port               = $port;
+		$this->encryptionPassword = $encryptionPassword;
+	}
+
+	/** Create an Connection */
+	public function createConnection() {
+		$errno        = null;
+		$errstr       = null;
+		$this->socket = @fsockopen($this->ip, $this->port, $errno, $errstr, 2);
+
+		//socket_set_nonblock($this->socket);
+		stream_set_blocking($this->socket, 0);
+
+		if ($errno != 0 || !$this->socket) {
+			var_dump($errstr);
+			return false;
+		}
+		return true;
+	}
+
+	/**
+	 * Call an Method Asynchronously
+	 *
+	 * @param callable $function
+	 * @param          $method
+	 * @param string   $data
+	 * @return null
+	 */
+	public function call(callable $function, $method, $data = "") {
+		//TODO throw an exception or smth
+		if (!$this->socket) {
+			return null;
+		}
+
+		$data = json_encode(array("method" => $method, "data" => $data));
+
+		$data = openssl_encrypt($data, CommunicationManager::ENCRYPTION_METHOD, $this->encryptionPassword, OPENSSL_RAW_DATA, CommunicationManager::ENCRYPTION_IV);
+
+		array_push($this->messageQueue, $function);
+
+		// Write Request on Socket
+		fwrite($this->socket, strlen($data) . "\n" . $data);
+	}
+
+	/**
+	 * Process data on every Tick
+	 */
+	public function tick() {
+		$data = fgets($this->socket, 1024); // reads as much as possible OR nothing at all
+		if (strlen($data) > 0) { // got new data
+			$this->buffer .= $data; // append new data to buffer
+			// handle the data the exact same way
+			$arr = explode("\n", $this->buffer, 2);
+			while (count($arr) == 2 && strlen($arr[1]) >= (int) $arr[0]) {
+				// received full message
+				$len          = (int) $arr[0];
+				$msg          = substr($arr[1], 0, $len); // clip msg
+				$this->buffer = substr($this->buffer, strlen((string) $len) + 1 /* newline */ + $len); // clip buffer
+
+				// Decode Message
+				$data = openssl_decrypt($msg, CommunicationManager::ENCRYPTION_METHOD, $this->encryptionPassword, OPENSSL_RAW_DATA, CommunicationManager::ENCRYPTION_IV);
+				$data = json_decode($data);
+
+				// Received something!
+				//Call Function with Data
+				call_user_func(array_shift($this->messageQueue), $data->error, $data->data);
+
+				// next msg
+				$arr = explode("\n", $this->buffer, 2);
+			}
+		}
+	}
+
+	/** Closes the connection, don't call yourself, let it do the Communication Manager */
+	public function closeConnection() {
+		if ($this->socket) {
+			fclose($this->socket);
+		}
+	}
+}