kakserpom / phpdaemon

app-examples/Example.php

Doc Comments +2 added lines, -2 removed lines

@@ -14,7 +14,7 @@ 
 	 * Setting default config options
 	 * Overriden from AppInstance::getConfigDefaults
 	 * Uncomment and return array with your default options
-	 * @return array|false
+	 * @return boolean
 	 */
 	protected function getConfigDefaults() {
 		return false;
@@ -48,7 +48,7 @@ 
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleRequest($this, $upstream, $req);

Spacing +1 added lines, -1 removed lines

@@ -85,7 +85,7 @@
 $user = posix_getpwuid(posix_getuid());
 $group = posix_getgrgid(posix_getgid());
 ?>
-<br />My user/group: <?php echo $user['name'].'/'.$group['name']; ?>
+<br />My user/group: <?php echo $user['name'] . '/' . $group['name']; ?>
 <?php
 $displaystate = TRUE;
 

app-examples/ExampleDNSClient.php

Doc Comments +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleDNSClientRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleDNSClientRequest($this, $upstream, $req);

Spacing +1 added lines, -1 removed lines

@@ -58,7 +58,7 @@
 	 * @return integer Status.
 	 */
 	public function run() {		
-		try {$this->header('Content-Type: text/plain');} catch (Exception $e) {}
+		try {$this->header('Content-Type: text/plain'); } catch (Exception $e) {}
 		var_dump($this->job->getResult('query'));
 		var_dump($this->job->getResult('resolve'));
 	}

app-examples/ExampleFs.php

Doc Comments +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleFsRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleFsRequest($this, $upstream, $req);

Spacing +2 added lines, -2 removed lines

@@ -23,7 +23,7 @@ 
 	public function init() {
 		$req = $this;
 		$this->sleep(1, true);
-		FS::readfile('/etc/filesystems', function ($file, $data) use ($req) {
+		FS::readfile('/etc/filesystems', function($file, $data) use ($req) {
 			$req->fileData = $data;
 			$req->wakeup();
 		});
@@ -35,7 +35,7 @@ 
 	 */
 	public function run() {
 		$this->header('Content-Type: text/plain');
-		echo "Contents of /etc/filesystems:\n". $this->fileData;
+		echo "Contents of /etc/filesystems:\n" . $this->fileData;
 	}
 	
 }

app-examples/ExampleHTTPClient.php

Doc Comments +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleHTTPClientRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleHTTPClientRequest($this, $upstream, $req);

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
 	 */
 	public function init() {
 
-		try {$this->header('Content-Type: text/html');} catch (Exception $e) {}
+		try {$this->header('Content-Type: text/html'); } catch (Exception $e) {}
 
 			$this->appInstance->httpclient->post(
 				['http://phpdaemon.net/Example/', 'foo' => 'bar'], ['postField' => 'value'],

app-examples/ExampleICMP.php

Doc Comments +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleICMPRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleICMPRequest($this, $upstream, $req);

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
 				
 		$job('pingjob', function($name, $job) use ($req) { // registering job named 'pingjob'
 		
-			ICMPClient::getInstance()->sendPing('8.8.8.8', function ($latency) use ($name, $job) {
+			ICMPClient::getInstance()->sendPing('8.8.8.8', function($latency) use ($name, $job) {
 				$job->setResult($name, $latency); 	
 			});
 		});

app-examples/ExamplePubSub.php

Doc Comments +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExamplePubSubTestPageRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExamplePubSubTestPageRequest($this, $upstream, $req);

Spacing +5 added lines, -5 removed lines

@@ -8,7 +8,7 @@ 
 	 */
 	public function onReady() {
 		$appInstance = $this; // a reference to this application instance for ExampleWebSocketRoute
-		WebSocketServer::getInstance()->addRoute('ExamplePubSub', function ($client) use ($appInstance) {
+		WebSocketServer::getInstance()->addRoute('ExamplePubSub', function($client) use ($appInstance) {
 			return new ExamplePubSubWebSocketRoute($client, $appInstance);
 		});
 		$this->sql = MySQLClient::getInstance();
@@ -21,18 +21,18 @@ 
 					return;
 				}
 				$pubsub->event = setTimeout(function($timer) use ($pubsub, $appInstance) {
-					$appInstance->sql->getConnection(function ($sql) use ($pubsub) {
+					$appInstance->sql->getConnection(function($sql) use ($pubsub) {
 						if (!$sql->connected) {
 							return;
 						}
-						$sql->query('SELECT COUNT(*) `num` FROM `dle_users`', function ($sql, $success) use ($pubsub) {
+						$sql->query('SELECT COUNT(*) `num` FROM `dle_users`', function($sql, $success) use ($pubsub) {
 							$pubsub->pub(sizeof($sql->resultRows) ? $sql->resultRows[0]['num'] : 'null');
 						});
 					});
 					$timer->timeout(5e6); // 5 seconds
 				}, 0);
 			})
-			->onDeactivation(function ($pubsub) {
+			->onDeactivation(function($pubsub) {
 				if (isset($pubsub->event)) {
 					Timer::cancelTimeout($pubsub->event);
 				}
@@ -64,7 +64,7 @@ 
 		$req = json_decode($data, true);
 		if ($req['type'] === 'subscribe') {
 			$eventName = $req['event'];
-			$this->appInstance->pubsub->sub($req['event'], $this, function ($data) use ($ws, $eventName) {
+			$this->appInstance->pubsub->sub($req['event'], $this, function($data) use ($ws, $eventName) {
 				$ws->sendObject(array(
 					'type' => 'event',
 					'event' => $eventName,

app-examples/ExampleSandbox.php

Doc Comments +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleSandboxRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleSandboxRequest($this, $upstream, $req);

Spacing +2 added lines, -2 removed lines

@@ -62,10 +62,10 @@
 			'allow_url_fopen'  => 'false',
 			'disable_functions'=>'exec,shell_exec,passthru,system',
 			'disable_classes'  => '',
-			'output_handler'   => array($this,'out')
+			'output_handler'   => array($this, 'out')
 		));
 
-		$sandbox->ini_set('html_errors',true);
+		$sandbox->ini_set('html_errors', true);
 		$sandbox->call_user_func(function() {
 			echo "Hello World!";
 		});

app-examples/ExampleWebSocket.php

Doc Comments +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleWebSocketTestPageRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleWebSocketTestPageRequest($this, $upstream, $req);

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 	public function onReady() {
 		$appInstance = $this; // a reference to this application instance for ExampleWebSocketRoute
 		// URI /exampleApp should be handled by ExampleWebSocketRoute
-		WebSocketServer::getInstance()->addRoute('exampleApp', function ($client) use ($appInstance) {
+		WebSocketServer::getInstance()->addRoute('exampleApp', function($client) use ($appInstance) {
 			return new ExampleWebSocketRoute($client, $appInstance);
 		});
 	}

app-examples/ExampleWithMemcache.php

Doc Comments +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleWithMemcacheRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleWithMemcacheRequest($this, $upstream, $req);

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
 	 * @return void
 	 */
 	public function init() {
-		try {$this->header('Content-Type: text/html');} catch (Exception $e) {}
+		try {$this->header('Content-Type: text/html'); } catch (Exception $e) {}
 		$req = $this;
 		
 		$job = $this->job = new ComplexJob(function() use ($req) { // called when job is done
@@ -73,7 +73,7 @@ 
 } else {
 	echo '<h1>Something went wrong! We have no result.</h1>';
 }
-echo '<br />Request (http) took: '.round(microtime(TRUE) - $this->attrs->server['REQUEST_TIME_FLOAT'],6);
+echo '<br />Request (http) took: ' . round(microtime(TRUE) - $this->attrs->server['REQUEST_TIME_FLOAT'], 6);
 ?>
 </body>
 </html>