phpflo / phpflo-flowtrace

lib/PhpFlo/TraceableNetwork.php

Doc Comments +1 added lines

@@ -69,6 +69,7 @@
     /**
      * Wrap the creation of the callback
      *
+     * @param string $type
      * @return \Closure
      */
     private function trace($type)

Spacing +12 added lines, -12 removed lines

@@ -73,7 +73,7 @@ 
      */
     private function trace($type)
     {
-        $trace = function () use ($type) {
+        $trace = function() use ($type) {
             switch ($type) {
                 case TraceableNetwork::TYPE_DATA:
                     $this->traceData(func_get_args(), $type);
@@ -94,22 +94,22 @@ 
      */
     private function traceData(array $args, $type)
     {
-        $data   = $args[0];
-        $socket = $args[1];
+        $data   = $args[ 0 ];
+        $socket = $args[ 1 ];
 
         if (!is_string($data)) {
             $data = serialize($data);
         }
 
         $to      = $socket->to();
-        $message = "-> {$to['port']} {$to['process']['id']} ";
+        $message = "-> {$to[ 'port' ]} {$to[ 'process' ][ 'id' ]} ";
 
         $from = $socket->from();
-        if (isset($from['process'])) {
-            $message = "{$from['process']['id']} {$from['port']} {$message}";
+        if (isset($from[ 'process' ])) {
+            $message = "{$from[ 'process' ][ 'id' ]} {$from[ 'port' ]} {$message}";
         }
 
-        $this->logger->info("{$message} {$this->actions[$type]} {$data}");
+        $this->logger->info("{$message} {$this->actions[ $type ]} {$data}");
     }
 
     /**
@@ -118,16 +118,16 @@ 
      */
     private function traceAction(array $args, $type)
     {
-        $socket = $args[0];
+        $socket = $args[ 0 ];
 
         $to      = $socket->to();
-        $message = "-> {$to['port']} {$to['process']['id']} ";
+        $message = "-> {$to[ 'port' ]} {$to[ 'process' ][ 'id' ]} ";
 
         $from = $socket->from();
-        if (isset($from['process'])) {
-            $message = "{$from['process']['id']} {$from['port']} {$message}";
+        if (isset($from[ 'process' ])) {
+            $message = "{$from[ 'process' ][ 'id' ]} {$from[ 'port' ]} {$message}";
         }
 
-        $this->logger->debug("{$message} {$this->actions[$type]}");
+        $this->logger->debug("{$message} {$this->actions[ $type ]}");
     }
 }

lib/PhpFlo/Logger/SimpleFile.php

Spacing +5 added lines, -5 removed lines

@@ -40,14 +40,14 @@ 
         $log = pathinfo($logFile);
         // check if $logFile is a dir because of possible stream url
         $isLogdir = is_dir($logFile);
-        if (!$isLogdir && (isset($log['dirname']) && !is_dir($log['dirname']))) {
+        if (!$isLogdir && (isset($log[ 'dirname' ]) && !is_dir($log[ 'dirname' ]))) {
             throw new \InvalidArgumentException(
-                "Directory does not exist: {$log['dirname']}"
+                "Directory does not exist: {$log[ 'dirname' ]}"
             );
         }
 
-        if ($isLogdir || !isset($log['filename'])) {
-            $logFile = $logFile . DIRECTORY_SEPARATOR . self::DEFAULT_FILENAME;
+        if ($isLogdir || !isset($log[ 'filename' ])) {
+            $logFile = $logFile.DIRECTORY_SEPARATOR.self::DEFAULT_FILENAME;
         }
         $this->logFile = $logFile;
 
@@ -67,7 +67,7 @@ 
     {
         if (in_array($level, $this->levels)) {
             file_put_contents(
-                $this->logFile, $message . PHP_EOL, FILE_APPEND
+                $this->logFile, $message.PHP_EOL, FILE_APPEND
             );
         }
     }

examples/linecount/countFromFbp.php

Spacing +4 added lines, -4 removed lines

@@ -5,20 +5,20 @@
  * to "wc -l <filename>"
  */
 
-if (!isset($_SERVER['argv'][1])) {
+if (!isset($_SERVER[ 'argv' ][ 1 ])) {
     die("You must provide a filename\n");
 }
-$fileName = $_SERVER['argv'][1];
+$fileName = $_SERVER[ 'argv' ][ 1 ];
 
 // Include standard autoloader
-require __DIR__ . '/../../vendor/autoload.php';
+require __DIR__.'/../../vendor/autoload.php';
 
 // create network
 $traceableNetwork = new \PhpFlo\TraceableNetwork(
     new PhpFlo\Network(
         new PhpFlo\Builder\ComponentFactory()
     ),
-    new \PhpFlo\Logger\SimpleFile(__DIR__ . DIRECTORY_SEPARATOR . 'flow.log', 'info')
+    new \PhpFlo\Logger\SimpleFile(__DIR__.DIRECTORY_SEPARATOR.'flow.log', 'info')
 );
 $traceableNetwork
     ->boot(__DIR__.'/count.fbp')