kakserpom / phpdaemon

lib/MongoClientAsyncCollection.php

Indentation +33 added lines, -33 removed lines

@@ -1,8 +1,8 @@ 
 <?php
 class MongoClientAsyncCollection {
-    /**
-     * @var MongoClient
-     */
+	/**
+	 * @var MongoClient
+	 */
 	public $pool;
 	public $name; // Name of collection.
 
@@ -36,7 +36,7 @@ 
 	 * @param array Hash of properties (offset,   opts,  where,  col,  fields,  sort,  hint,  explain,  snapshot,  orderby,  parse_oplog)
 	 * @param string Optional. Distribution key.
 	 * @return void
- 	*/
+	 */
 	public function findOne($cb, $p = array(), $key = '') {
 		$p['col'] = $this->name;
 
@@ -138,34 +138,34 @@ 
 		return $this->pool->remove($this->name, $cond, $cb, $key);
 	}
 
-    /**
-     * Evaluates a code on the server side
-     * @param string Code
-     * @param mixed Callback called when response received
-     * @param string Optional. Distribution key
-     * @return void
-     */
-    public function evaluate($code, $cb, $key = '')
-    {
-        $this->pool->evaluate($code, $cb, $key);
-    }
+	/**
+	 * Evaluates a code on the server side
+	 * @param string Code
+	 * @param mixed Callback called when response received
+	 * @param string Optional. Distribution key
+	 * @return void
+	 */
+	public function evaluate($code, $cb, $key = '')
+	{
+		$this->pool->evaluate($code, $cb, $key);
+	}
 
-    /**
-     * Generation autoincrement
-     * @param Closure $cb called when response received
-     * @param string $key Optional. Distribution key
-     * @return void
-     */
-    public function autoincrement($cb, $key = '')
-    {
-        $this->evaluate(
-            'function () { '
-                . 'return db.autoincrement.findAndModify({ '
-                . 'query: {"_id":"' . $this->name . '"}, update: {$inc:{"id":1}}, new: true, upsert: true }); }',
-            function ($res) use ($cb) {
-                call_user_func($cb, $res);
-            },
-            $key
-        );
-    }
+	/**
+	 * Generation autoincrement
+	 * @param Closure $cb called when response received
+	 * @param string $key Optional. Distribution key
+	 * @return void
+	 */
+	public function autoincrement($cb, $key = '')
+	{
+		$this->evaluate(
+			'function () { '
+				. 'return db.autoincrement.findAndModify({ '
+				. 'query: {"_id":"' . $this->name . '"}, update: {$inc:{"id":1}}, new: true, upsert: true }); }',
+			function ($res) use ($cb) {
+				call_user_func($cb, $res);
+			},
+			$key
+		);
+	}
 }

lib/WebSocketProtocolVE.php

Indentation +141 added lines, -141 removed lines

@@ -7,160 +7,160 @@
  */
 
 class WebSocketProtocolVE extends WebSocketProtocol {
-    const STRING = 0x00;
-    const BINARY = 0x80;
+	const STRING = 0x00;
+	const BINARY = 0x80;
  
-    public function onHandshake() {
-        return true;
-    }
-
-    /**
-     * Returns handshaked data for reply
-     * @param string Received data (no use in this class)
-     * @return string Handshaked data
-     */
-
-    public function getHandshakeReply($data) {
-        if ($this->onHandshake()) {
-            if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'])) {
-                $this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = '';
-            }
-
-            $reply = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n"
-                . "Upgrade: WebSocket\r\n"
-                . "Connection: Upgrade\r\n"
-                . "Sec-WebSocket-Origin: " . $this->connection->server['HTTP_ORIGIN'] . "\r\n"
-                . "Sec-WebSocket-Location: ws://" . $this->connection->server['HTTP_HOST'] . $this->connection->server['REQUEST_URI'] . "\r\n";
+	public function onHandshake() {
+		return true;
+	}
+
+	/**
+	 * Returns handshaked data for reply
+	 * @param string Received data (no use in this class)
+	 * @return string Handshaked data
+	 */
+
+	public function getHandshakeReply($data) {
+		if ($this->onHandshake()) {
+			if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'])) {
+				$this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = '';
+			}
+
+			$reply = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n"
+				. "Upgrade: WebSocket\r\n"
+				. "Connection: Upgrade\r\n"
+				. "Sec-WebSocket-Origin: " . $this->connection->server['HTTP_ORIGIN'] . "\r\n"
+				. "Sec-WebSocket-Location: ws://" . $this->connection->server['HTTP_HOST'] . $this->connection->server['REQUEST_URI'] . "\r\n";
 			if ($this->connection->pool->config->expose->value) {
 				$reply .= 'X-Powered-By: phpDaemon/' . Daemon::$version . "\r\n";
 			}
-            if (isset($this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'])) {
-                $reply .= "Sec-WebSocket-Protocol: " . $this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'] . "\r\n";
-            }
-            $reply .= "\r\n";
-            return $reply;
-        }
-        return false;
-    }
-
-    /**
-     * Computes key for Sec-WebSocket.
-     * @param string Key
-     * @return string Result
-     */
-
-    protected function _computeKey($key) {
-        $spaces = 0;
-        $digits = '';
+			if (isset($this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'])) {
+				$reply .= "Sec-WebSocket-Protocol: " . $this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'] . "\r\n";
+			}
+			$reply .= "\r\n";
+			return $reply;
+		}
+		return false;
+	}
+
+	/**
+	 * Computes key for Sec-WebSocket.
+	 * @param string Key
+	 * @return string Result
+	 */
+
+	protected function _computeKey($key) {
+		$spaces = 0;
+		$digits = '';
     
-        for ($i = 0, $s = strlen($key); $i < $s; ++$i) {
-            $c = binarySubstr($key, $i, 1);
-
-            if ($c === "\x20") {
-                ++$spaces;
-            }
-            elseif (ctype_digit($c)) {
-                $digits .= $c;
-            }
-        }
+		for ($i = 0, $s = strlen($key); $i < $s; ++$i) {
+			$c = binarySubstr($key, $i, 1);
+
+			if ($c === "\x20") {
+				++$spaces;
+			}
+			elseif (ctype_digit($c)) {
+				$digits .= $c;
+			}
+		}
         
-        if ($spaces > 0) {
-            $result = (float) floor($digits / $spaces);
-        } else {
-            $result = (float) $digits;
-        }
+		if ($spaces > 0) {
+			$result = (float) floor($digits / $spaces);
+		} else {
+			$result = (float) $digits;
+		}
         
-        return pack('N', $result);
-    }
-
-    public function encodeFrame($data, $type) {
-        // Binary
-        $type = $this->getFrameType($type);
-        if (($type & self::BINARY) === self::BINARY)
-        {
-            $n = strlen($data);
-            $len = '';
-            $pos = 0;
-
-            char:
-
-            ++$pos;
-            $c = $n >> 0 & 0x7F;
-            $n = $n >> 7;
-
-            if ($pos != 1)
-            {
-                $c += 0x80;
-            }
+		return pack('N', $result);
+	}
+
+	public function encodeFrame($data, $type) {
+		// Binary
+		$type = $this->getFrameType($type);
+		if (($type & self::BINARY) === self::BINARY)
+		{
+			$n = strlen($data);
+			$len = '';
+			$pos = 0;
+
+			char:
+
+			++$pos;
+			$c = $n >> 0 & 0x7F;
+			$n = $n >> 7;
+
+			if ($pos != 1)
+			{
+				$c += 0x80;
+			}
             
-            if ($c != 0x80)
-            {
-                $len = chr($c) . $len;
-                goto char;
-            };
+			if ($c != 0x80)
+			{
+				$len = chr($c) . $len;
+				goto char;
+			};
             
-            return chr(self::BINARY) . $len . $data ;
-        }
-        // String
-        else {
-            return chr(self::STRING) . $data . "\xFF" ;
-        }
-    }
-
-    public function onRead() {
+			return chr(self::BINARY) . $len . $data ;
+		}
+		// String
+		else {
+			return chr(self::STRING) . $data . "\xFF" ;
+		}
+	}
+
+	public function onRead() {
 		while ($this->connection && (($buflen = strlen($this->connection->buf)) >= 2)) {
 			$frametype = ord(binarySubstr($this->connection->buf, 0, 1)); 
-            if (($frametype & 0x80) === 0x80) {
-                $len = 0 ;
-                $i = 0 ;
-
-                do {
-                    $b = ord(binarySubstr($this->connection->buf, ++$i, 1));
-                    $n = $b & 0x7F ;
-                    $len *= 0x80 ;
-                    $len += $n ;
-                } while ($b > 0x80) ;
-
-                if ($this->connection->pool->maxAllowedPacket <= $len)
-                {
-                    // Too big packet
-                    $this->connection->finish() ;
-                    return FALSE ;
-                }
-
-                if ($buflen < $len + 2)
-                {
-                    // not enough data yet
-                    return FALSE ;
-                } 
+			if (($frametype & 0x80) === 0x80) {
+				$len = 0 ;
+				$i = 0 ;
+
+				do {
+					$b = ord(binarySubstr($this->connection->buf, ++$i, 1));
+					$n = $b & 0x7F ;
+					$len *= 0x80 ;
+					$len += $n ;
+				} while ($b > 0x80) ;
+
+				if ($this->connection->pool->maxAllowedPacket <= $len)
+				{
+					// Too big packet
+					$this->connection->finish() ;
+					return FALSE ;
+				}
+
+				if ($buflen < $len + 2)
+				{
+					// not enough data yet
+					return FALSE ;
+				} 
                     
-                $decodedData = binarySubstr($this->connection->buf, 2, $len) ;
-                $this->connection->buf = binarySubstr($this->connection->buf, 2 + $len) ;
+				$decodedData = binarySubstr($this->connection->buf, 2, $len) ;
+				$this->connection->buf = binarySubstr($this->connection->buf, 2 + $len) ;
                   
-                $this->connection->onFrame($decodedData, $frametype);
-            }
-            else {
-            	if (($p = strpos($this->connection->buf, "\xFF")) !== FALSE) {
-                    if ($this->connection->pool->maxAllowedPacket <= $p - 1) {                   {
-                        // Too big packet
-                        $this->connection->finish() ;
-                        return FALSE ;
-                    }
+				$this->connection->onFrame($decodedData, $frametype);
+			}
+			else {
+				if (($p = strpos($this->connection->buf, "\xFF")) !== FALSE) {
+					if ($this->connection->pool->maxAllowedPacket <= $p - 1) {                   {
+						// Too big packet
+						$this->connection->finish() ;
+						return FALSE ;
+					}
                         
-                    $decodedData = binarySubstr($this->connection->buf, 1, $p - 1) ;                    
-                    $this->connection->buf = binarySubstr($this->connection->buf, $p + 1) ;                    
-                    $this->connection->onFrame($decodedData, $frametype);
+					$decodedData = binarySubstr($this->connection->buf, 1, $p - 1) ;                    
+					$this->connection->buf = binarySubstr($this->connection->buf, $p + 1) ;                    
+					$this->connection->onFrame($decodedData, $frametype);
                     
-                }
-                else {
-                    if ($this->connection->pool->maxAllowedPacket <= strlen($this->connection->buf))
-                    {
-                        // Too big packet
-                        $this->connection->finish() ;
-                        return FALSE ;
-                    }
-                }
-            }
-        }
-    }
+				}
+				else {
+					if ($this->connection->pool->maxAllowedPacket <= strlen($this->connection->buf))
+					{
+						// Too big packet
+						$this->connection->finish() ;
+						return FALSE ;
+					}
+				}
+			}
+		}
+	}
 }

lib/ConnectionPool.php

Indentation +7 added lines, -7 removed lines

@@ -39,7 +39,7 @@ 
 	/**
 	 * Called when the worker is ready to go.
 	 * @return void
-	*/
+	 */
 	public function onReady() {
 		$this->enable();
 	}	
@@ -119,11 +119,11 @@ 
 	
 	
  	/**
-	 * Process default config
-	 * @todo move it to Daemon_Config class
-	 * @param array {"setting": "value"}
-	 * @return void
-	 */
+ 	 * Process default config
+ 	 * @todo move it to Daemon_Config class
+ 	 * @param array {"setting": "value"}
+ 	 * @return void
+ 	 */
 	public function processDefaultConfig($settings = array()) {
 		foreach ($settings as $k => $v) {
 			$k = strtolower(str_replace('-', '', $k));
@@ -158,7 +158,7 @@ 
 	/**
 	 * Enable socket events
 	 * @return void
-	*/
+	 */
 	public function enable() {
 		if ($this->enabled) {
 			return;

lib/Daemon.php

Indentation +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
 		Daemon::$reusePort = 1 === preg_match("~BSD~i", php_uname('s'));
 		
 		if (Daemon::$reusePort && !defined("SO_REUSEPORT"))
-		    define("SO_REUSEPORT", 0x200);	// FIXME: this is a BSD-only hack
+			define("SO_REUSEPORT", 0x200);	// FIXME: this is a BSD-only hack
 	}
 
 	public static function loadModuleIfAbsent($mod) {

lib/IRCBouncer.php

Indentation +1 added lines, -1 removed lines

@@ -337,7 +337,7 @@
 	 * Called when new data received
 	 * @param string New data
 	 * @return void
-	*/
+	 */
 	public function stdin($buf) {
 		Timer::setTimeout($this->keepaliveTimer);
 		$this->buf .= $buf;

lib/BoundSocket.php

Indentation +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
 	/**
 	 * Enable socket events
 	 * @return void
-	*/
+	 */
 	public function enable() {
 		if ($this->enabled) {
 			return;

lib/XMPPClient.php

Indentation +3 added lines, -3 removed lines

@@ -234,9 +234,9 @@ 
 	 * @param string $subject
 	 */
 	public function message($to, $body, $type = 'chat', $subject = null, $payload = null) {
-	    if (is_null($type)) {
+		if (is_null($type)) {
 			$type = 'chat';
-	    }
+		}
 	    
 		$to	  = htmlspecialchars($to);
 		$body	= htmlspecialchars($body);
@@ -324,7 +324,7 @@ 
 	 * Called when new data received
 	 * @param string New data
 	 * @return void
-	*/
+	 */
 	public function stdin($buf) {
 		Timer::setTimeout($this->keepaliveTimer);
 		//Daemon::log(Debug::dump(['read', $buf]));

lib/WebSocketProtocolV13.php

Indentation +66 added lines, -66 removed lines

@@ -29,53 +29,53 @@ 
 	}
 
 	public function onHandshake(){
-        if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_KEY'])	|| !isset($this->connection->server['HTTP_SEC_WEBSOCKET_VERSION'])) {
+		if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_KEY'])	|| !isset($this->connection->server['HTTP_SEC_WEBSOCKET_VERSION'])) {
 			return false;
 		}
 		if ($this->connection->server['HTTP_SEC_WEBSOCKET_VERSION'] != '13' && $this->connection->server['HTTP_SEC_WEBSOCKET_VERSION'] != '8') {
-            return false;
-        }
+			return false;
+		}
 
 		return true;
 	}
 
-    /**
-     * Returns handshaked data for reply
+	/**
+	 * Returns handshaked data for reply
 	 * @param string Received data (no use in this class)
-     * @return string Handshaked data
-     */
+	 * @return string Handshaked data
+	 */
 
-    public function getHandshakeReply($data) {
-        if ($this->onHandshake()) {
-	    	if (isset($this->connection->server['HTTP_ORIGIN'])) {
+	public function getHandshakeReply($data) {
+		if ($this->onHandshake()) {
+			if (isset($this->connection->server['HTTP_ORIGIN'])) {
 				$this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = $this->connection->server['HTTP_ORIGIN'];
 			}
-            if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN']))
+			if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN']))
 			{
-                $this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = '' ;
-            }
-            $reply = "HTTP/1.1 101 Switching Protocols\r\n"
-                . "Upgrade: WebSocket\r\n"
-                . "connection: Upgrade\r\n"
-                . "Date: ".date('r')."\r\n"
-                . "Sec-WebSocket-Origin: " . $this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] . "\r\n"
-                . "Sec-WebSocket-Location: ws://" . $this->connection->server['HTTP_HOST'] . $this->connection->server['REQUEST_URI'] . "\r\n"
-                . "Sec-WebSocket-Accept: " . base64_encode(sha1(trim($this->connection->server['HTTP_SEC_WEBSOCKET_KEY']) . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11", true)) . "\r\n";
+				$this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = '' ;
+			}
+			$reply = "HTTP/1.1 101 Switching Protocols\r\n"
+				. "Upgrade: WebSocket\r\n"
+				. "connection: Upgrade\r\n"
+				. "Date: ".date('r')."\r\n"
+				. "Sec-WebSocket-Origin: " . $this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] . "\r\n"
+				. "Sec-WebSocket-Location: ws://" . $this->connection->server['HTTP_HOST'] . $this->connection->server['REQUEST_URI'] . "\r\n"
+				. "Sec-WebSocket-Accept: " . base64_encode(sha1(trim($this->connection->server['HTTP_SEC_WEBSOCKET_KEY']) . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11", true)) . "\r\n";
 
-            if (isset($this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'])) {
-                $reply .= "Sec-WebSocket-Protocol: " . $this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'] . "\r\n";
-            }
+			if (isset($this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'])) {
+				$reply .= "Sec-WebSocket-Protocol: " . $this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'] . "\r\n";
+			}
 
 			if ($this->connection->pool->config->expose->value) {
 				$reply .= 'X-Powered-By: phpDaemon/' . Daemon::$version . "\r\n";
 			}
 
-            $reply .= "\r\n";
-            return $reply ;
-        }
+			$reply .= "\r\n";
+			return $reply ;
+		}
 
 		return false;
-    }
+	}
 
 	/**
 	 * Data encoding, according to related IETF draft
@@ -83,7 +83,7 @@ 
 	 * @see http://tools.ietf.org/html/draft-ietf-hybi-thewebsocketprotocol-10#page-16
 	 */
 
-    protected function encodeFrame($data, $type = 'STRING') {
+	protected function encodeFrame($data, $type = 'STRING') {
 		$fin = 1;
 		$rsv1 = 0;
 		$rsv2 = 0;
@@ -93,40 +93,40 @@ 
 			$rsv1 = 1;
 		}
 		return $this->encodeFragment($data, $type, $fin, $rsv1, $rsv2, $rsv3);
-    }
+	}
 
 	protected function encodeFragment($data, $type, $fin = 1, $rsv1 = 0, $rsv2 = 0, $rsv3 = 0) {
-        $mask =	chr(rand(0, 0xFF)) .
+		$mask =	chr(rand(0, 0xFF)) .
  						chr(rand(0, 0xFF)) . 
 						chr(rand(0, 0xFF)) . 
 						chr(rand(0, 0xFF)) ;
 		$packet = chr(bindec($fin . $rsv1 . $rsv2 . $rsv3 . str_pad(decbin($this->getFrameType($type)), 4, '0', STR_PAD_LEFT)));
-        $dataLength = strlen($data);
+		$dataLength = strlen($data);
 		$isMasked = false;
 		$isMaskedInt = $isMasked ? 128 : 0;
-        if ($dataLength <= 125)
-        {
-            $packet .= chr($dataLength + $isMaskedInt);
-        }
-        elseif ($dataLength <= 65535)
-        {
-            $packet .=	chr(126 + $isMaskedInt) . // 126 + 128
-            			chr($dataLength >> 8) .
-            			chr($dataLength & 0xFF);
-        }
-        else {
-            $packet .=	chr(127 + $isMaskedInt) . // 127 + 128
-             			chr($dataLength >> 56) .
-           				chr($dataLength >> 48) .
-            			chr($dataLength >> 40) .
-             			chr($dataLength >> 32) .
-             			chr($dataLength >> 24) .
-             			chr($dataLength >> 16) .
-               			chr($dataLength >>  8) .
-             			chr($dataLength & 0xFF);
-        }
-        if ($isMasked) { 
-        	$packet .=	$mask . $this->mask($data, $mask);
+		if ($dataLength <= 125)
+		{
+			$packet .= chr($dataLength + $isMaskedInt);
+		}
+		elseif ($dataLength <= 65535)
+		{
+			$packet .=	chr(126 + $isMaskedInt) . // 126 + 128
+						chr($dataLength >> 8) .
+						chr($dataLength & 0xFF);
+		}
+		else {
+			$packet .=	chr(127 + $isMaskedInt) . // 127 + 128
+			 			chr($dataLength >> 56) .
+		   				chr($dataLength >> 48) .
+						chr($dataLength >> 40) .
+			 			chr($dataLength >> 32) .
+			 			chr($dataLength >> 24) .
+			 			chr($dataLength >> 16) .
+			   			chr($dataLength >>  8) .
+			 			chr($dataLength & 0xFF);
+		}
+		if ($isMasked) { 
+			$packet .=	$mask . $this->mask($data, $mask);
 		} else {
  			$packet .= $data;
 		}
@@ -134,8 +134,8 @@ 
 	}
 	public function mask ($data, $mask) {
    		for ($i = 0, $l = strlen($data), $ml = strlen($mask); $i < $l; $i++) {
-	     	$data[$i] = $data[$i] ^ $mask[$i % $ml] ;
-	     }
+		 	$data[$i] = $data[$i] ^ $mask[$i % $ml] ;
+		 }
 		return $data;
 	}
 	/**
@@ -193,7 +193,7 @@ 
 	 * @see http://tools.ietf.org/html/draft-ietf-hybi-thewebsocketprotocol-10#page-16
 	 */
 
-    public function onRead() {
+	public function onRead() {
 		$data = '';
 		while ($this->connection && (($buflen = strlen($this->connection->buf)) >= 1)) {
 			$p = 0; // offset
@@ -204,15 +204,15 @@ 
 			$rsv3 = (bool) $firstBits[3];
 			$opcode = (int) bindec(substr($firstBits, 4, 4));
 			if ($opcode === 0x8) { // CLOSE
-        		$this->connection->finish();
-            	return;
+				$this->connection->finish();
+				return;
 			}
 			$opcodeName = $this->opcodes[$opcode];
 			$second = ord(binarySubstr($this->connection->buf, $p++, 1)); // second byte integer (masked, payload length)
 			$fin =	(bool) ($first >> 7);
-        	$isMasked   = (bool) ($second >> 7);
-        	$dataLength = $second & 0x7f;
-          	if ($dataLength === 0x7e) { // 2 bytes-length
+			$isMasked   = (bool) ($second >> 7);
+			$dataLength = $second & 0x7f;
+		  	if ($dataLength === 0x7e) { // 2 bytes-length
 				if ($buflen < $p + 2) {
 					return; // not enough data yet
 				}
@@ -223,9 +223,9 @@ 
 				if ($buflen < $p + 4) {
 					return; // not enough data yet
 				}
-            	$dataLength = $this->bytes2int(binarySubstr($this->connection->buf, $p, 4));
-            	$p += 4;
-            }
+				$dataLength = $this->bytes2int(binarySubstr($this->connection->buf, $p, 4));
+				$p += 4;
+			}
 			if ($this->connection->pool->maxAllowedPacket <= $dataLength) {
 				// Too big packet
 				$this->connection->finish();
@@ -262,5 +262,5 @@ 
 				}
 			}
 		}
-    }
+	}
 }
\ No newline at end of file

lib/XMLStream.php

Indentation +4 added lines, -4 removed lines

@@ -142,10 +142,10 @@
 
 
 /**
-	 * Get next ID
-	 *
-	 * @return integer
-	 */
+ * Get next ID
+ *
+ * @return integer
+ */
 	public function getId() {
 		$this->lastid++;
 		return $this->lastid;