fructify / reload

src/Protocol/WebSocket/MessageQueue.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
     }
     public function add($data)
     {
-        $this->data.=$data;
+        $this->data .= $data;
     }
 
     public function __toString()

src/Protocol/WebSocket/Frame.php

Spacing +3 added lines, -3 removed lines

@@ -110,7 +110,7 @@ 
 
     public function appendData($data)
     {
-        $this->data.=$data;
+        $this->data .= $data;
         $this->updatePayloadLength($this->data, $this->secondByte, $this->extendedPayload);
     }
 
@@ -152,7 +152,7 @@ 
         }
         $maskingKey = $this->generateMaskingKey();
 
-        return $maskingKey . $this->applyMask($maskingKey, $payload);
+        return $maskingKey.$this->applyMask($maskingKey, $payload);
     }
 
     public function getPayloadLength($encodedData)
@@ -249,7 +249,7 @@ 
     {
         $this->isCoalesced = true;
 
-        return pack('CC', $this->firstByte, $this->secondByte) . $this->extendedPayload . $this->maskPayload($this->data);
+        return pack('CC', $this->firstByte, $this->secondByte).$this->extendedPayload.$this->maskPayload($this->data);
     }
 
     protected function updatePayloadLength($data, &$secondByte, &$extendedPayload)

src/Protocol/WebSocket/WebSocket.php

Spacing +2 added lines, -2 removed lines

@@ -33,11 +33,11 @@
     public function handshake($request)
     {
         $key = $request->headers->get('Sec-WebSocket-Key');
-        if(
+        if (
             strtolower($request->headers->get('Upgrade')) != 'websocket' ||
             !$this->checkProtocolVrsion($request) ||
             !$this->checkSecKey($key)
-          ){
+          ) {
             return false;
         }
         $acceptKey = $this->generateAcceptKey($key);

src/Protocol/WebSocketProtocol.php

Spacing +3 added lines, -3 removed lines

@@ -35,7 +35,7 @@ 
     protected function initEvent()
     {
         $this->websocket = new WebSocket\WebSocket();
-        $this->conn->on('data', function($data){
+        $this->conn->on('data', function($data) {
             $this->onData($data);
         });
     }
@@ -43,10 +43,10 @@ 
     protected function onData($data)
     {
         $frame = $this->websocket->onMessage($data);
-        if(!($frame instanceof WebSocket\Frame)) {
+        if (!($frame instanceof WebSocket\Frame)) {
             return;
         }
-        if(($command = json_decode($frame->getData(), true)) === null){
+        if (($command = json_decode($frame->getData(), true)) === null) {
             return;
         }
         $this->conn->emit('command', array($command));

src/Protocol/HttpProtocol.php

Spacing +11 added lines, -11 removed lines

@@ -20,7 +20,7 @@ 
 
     protected function initEvent(SocketServer $socket)
     {
-        $socket->on('connection', function(SocketConnection $conn){
+        $socket->on('connection', function(SocketConnection $conn) {
             $this->onConnect($conn);
         });
     }
@@ -40,7 +40,7 @@ 
 
     protected function handleRequest(SocketConnection $conn, Request $request)
     {
-        switch($request->getPathInfo()){
+        switch ($request->getPathInfo()) {
             case '/livereload':
                 $this->initWebSocket($conn, $request);
                 break;
@@ -58,21 +58,21 @@ 
     protected function initWebSocket(SocketConnection $conn, Request $request)
     {
         $conn->removeAllListeners('data');
-        return new WebSocketProtocol($conn,  $this->app, $request);
+        return new WebSocketProtocol($conn, $this->app, $request);
     }
 
     protected function getRequestChangedFiles(Request $request)
     {
-        if(($files = $request->query->get('files')) != null){
+        if (($files = $request->query->get('files')) != null) {
             return explode(',', $files);
         }
         $requestJson = json_decode($request->getContent(), true);
-        return isset($requestJson['files'])?(is_array($requestJson['files'])?$requestJson['files']:[$requestJson['files']]):[];
+        return isset($requestJson['files']) ? (is_array($requestJson['files']) ? $requestJson['files'] : [$requestJson['files']]) : [];
     }
 
     protected function notifyChanged(SocketConnection $conn, Request $request)
     {
-        foreach($this->getRequestChangedFiles($request) as $file){
+        foreach ($this->getRequestChangedFiles($request) as $file) {
             $this->app->getOutput()->writeln(strftime('%T')." - info - Receive request reload $file", OutputInterface::VERBOSITY_VERBOSE);
             $this->app->reloadFile($file);
         }
@@ -82,8 +82,8 @@ 
 
     protected function serveFile(SocketConnection $conn, $file)
     {
-        if(($path = realpath($file)) === null){
-            return ;
+        if (($path = realpath($file)) === null) {
+            return;
         }
         $content = file_get_contents($file);
         $response = new Response($content);
@@ -101,7 +101,7 @@ 
     protected function doHttpHandshake($data)
     {
         $pos = strpos($data, "\r\n\r\n");
-        if($pos === false){
+        if ($pos === false) {
             return false;
         }
         $body = substr($data, $pos + 4);
@@ -119,8 +119,8 @@ 
     protected function parseHeaders($rawHeaders)
     {
         $headers = array();
-        foreach($rawHeaders as $headerLine){
-            if(($pos = strpos($headerLine, ':')) === false){
+        foreach ($rawHeaders as $headerLine) {
+            if (($pos = strpos($headerLine, ':')) === false) {
                 continue;
             }
             $headers['HTTP_'.str_replace('-', '_', trim(strtoupper(substr($headerLine, 0, $pos))))] = trim(substr($headerLine, $pos + 1));

src/Protocol/LivereloadProtocol.php

Spacing +4 added lines, -4 removed lines

@@ -41,10 +41,10 @@ 
 
     protected function initEvent()
     {
-        $this->conn->on('command', function($command){
+        $this->conn->on('command', function($command) {
             $this->dispatchCommand($command);
         });
-        $this->conn->on('close', function(){
+        $this->conn->on('close', function() {
             $this->shutdown();
         });
     }
@@ -62,7 +62,7 @@ 
 
     protected function dispatchCommand($command)
     {
-        switch($command['command']){
+        switch ($command['command']) {
             case 'hello':
                 $this->processCommandHello($command);
                 break;
@@ -73,7 +73,7 @@ 
 
     protected function processCommandHello($command)
     {
-        if($this->connected){
+        if ($this->connected) {
            return;
         }
         $this->app->getOutput()->writeln(strftime('%T')." - info - Livereload protocol initialized.", OutputInterface::VERBOSITY_VERBOSE);

src/Command/RunCommand.php

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
         $output->writeln('Quit the server with CONTROL-C.');
         $output->writeln('');
         $app = new ServerApplication($host, $port);
-        if(!$noWatching){
+        if (!$noWatching) {
             $config = $this->loadConfig($input, $output);
             $app->watching($config['period'], $config);
         }
@@ -41,10 +41,10 @@ 
     protected function loadConfig(InputInterface $input, OutputInterface $output)
     {
         $configFile = $input->getOption('config');
-        if($configFile === null){
+        if ($configFile === null) {
             $configFile = 'livereload.json';
         }
-        if(!file_exists($configFile)){
+        if (!file_exists($configFile)) {
             throw new \Exception("$configFile not found.");
         }
 

src/Command/InitCommand.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
     protected function execute(InputInterface $input, OutputInterface $output)
     {
         $forceRewrite = $input->getOption('force');
-        if(!$forceRewrite && file_exists('livereload.json')){
+        if (!$forceRewrite && file_exists('livereload.json')) {
             $output->writeln("<error>livereload.json file exists.\nplease use --force to overwrite.</error>");
             return;
         }

src/Application/ServerApplication.php

Spacing +12 added lines, -12 removed lines

@@ -52,23 +52,23 @@ 
     {
         $this->watchConfig = $config;
         $this->scanFiles();
-        $this->loop->addPeriodicTimer($time, function(){
+        $this->loop->addPeriodicTimer($time, function() {
             $this->watchingFileChange();
         });
     }
 
     protected function scanFiles($scanNewFile = true)
     {
-        foreach($this->watchConfig['watch'] as $path => $file){
+        foreach ($this->watchConfig['watch'] as $path => $file) {
             $finder = new Finder();
-            try{
-                foreach($finder->in($path)->name($file)->followLinks() as $file){
-                    if($file->getRealPath() && !isset($this->watchingFiles[$file->getRealpath()])){
-                        $this->watchingFiles[$file->getRealpath()] = $scanNewFile?$file->getMTime():0;
+            try {
+                foreach ($finder->in($path)->name($file)->followLinks() as $file) {
+                    if ($file->getRealPath() && !isset($this->watchingFiles[$file->getRealpath()])) {
+                        $this->watchingFiles[$file->getRealpath()] = $scanNewFile ? $file->getMTime() : 0;
                     }
                 }
             }
-            catch(\InvalidArgumentException $e){
+            catch (\InvalidArgumentException $e) {
                 continue;
             }
         }
@@ -77,9 +77,9 @@ 
     protected function watchingFileChange()
     {
         $this->scanFiles(false);
-        foreach($this->watchingFiles as $file => $time){
+        foreach ($this->watchingFiles as $file => $time) {
             $mtime = @filemtime($file);
-            if($mtime && $mtime > $time){
+            if ($mtime && $mtime > $time) {
                 $this->watchingFiles[$file] = $mtime;
                 $this->reloadFile($file);
             }
@@ -100,7 +100,7 @@ 
 
     public function addClient(Protocol\LivereloadProtocol $client)
     {
-        if(!in_array($client, $this->clients)){
+        if (!in_array($client, $this->clients)) {
             $this->clients[] = $client;
         }
     }
@@ -108,7 +108,7 @@ 
     public function removeClient(Protocol\LivereloadProtocol $client)
     {
         $index = array_search($client, $this->clients, true);
-        if($index === false){
+        if ($index === false) {
             return;
         }
         unset($this->clients[$index]);
@@ -116,7 +116,7 @@ 
 
     public function reloadFile($file)
     {
-        foreach($this->clients as $client){
+        foreach ($this->clients as $client) {
             $client->reload($file, $this->config);
         }
     }