SAM-IT / php-proxy-protocol

src/Header.php

Spacing +6 added lines, -6 removed lines

@@ -131,7 +131,7 @@ 
      */
     protected function getAddresses()
     {
-        return $this->encodeAddress($this->sourceAddress, $this->protocol) . ($this->version == 1 ? " " : "") .$this->encodeAddress($this->targetAddress, $this->protocol);
+        return $this->encodeAddress($this->sourceAddress, $this->protocol) . ($this->version == 1 ? " " : "") . $this->encodeAddress($this->targetAddress, $this->protocol);
     }
 
     protected function encodePort($port, $protocol) {
@@ -220,7 +220,7 @@ 
      */
     public static function parseHeader(&$data)
     {
-        foreach(self::$signatures as $version => $signature) {
+        foreach (self::$signatures as $version => $signature) {
             // Match.
             if (strncmp($data, $signature, strlen($signature)) === 0) {
                 if ($version === 1) {
@@ -263,10 +263,10 @@ 
         $protocol = substr($data, 13, 1);
 
         $pos = 16;
-        $sourceAddress = self::decodeAddress($version, substr($data, $pos, self::$lengths[$protocol] / 2  - 2), $protocol);
-        $pos += self::$lengths[$protocol] / 2  - 2;
-        $targetAddress = self::decodeAddress($version, substr($data, $pos, self::$lengths[$protocol] / 2  - 2), $protocol);
-        $pos += self::$lengths[$protocol] / 2  - 2;
+        $sourceAddress = self::decodeAddress($version, substr($data, $pos, self::$lengths[$protocol] / 2 - 2), $protocol);
+        $pos += self::$lengths[$protocol] / 2 - 2;
+        $targetAddress = self::decodeAddress($version, substr($data, $pos, self::$lengths[$protocol] / 2 - 2), $protocol);
+        $pos += self::$lengths[$protocol] / 2 - 2;
         $sourcePort = unpack('n', substr($data, $pos, 2))[1];
         $targetPort = unpack('n', substr($data, $pos + 2, 2))[1];
 

src/ForwardingServer.php

Indentation +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
 
         $this->forwarder->forward($incoming, $this->forwardAddress, $this->forwardPort)->then(function(Stream $outgoing) use ($incoming) {
             $outgoing->on('init', function() use ($outgoing, $incoming) {
-               $this->emit('connection', [$incoming, $this->createConnection($outgoing->stream, false)]);
+                $this->emit('connection', [$incoming, $this->createConnection($outgoing->stream, false)]);
             });
         });