puzzle-org / amqp

src/Workers/Chunks/ChunkAssemblyTrackers/SingleTrackingInMemory.php

Spacing +2 added lines, -2 removed lines

@@ -51,7 +51,7 @@ 
 
     private function ensureHasBeenStarted(Uuid $uuid)
     {
-        if(! $this->hasBeenStarted($uuid))
+        if( ! $this->hasBeenStarted($uuid))
         {
             throw new \LogicException("Chunk assembly tracking has not been initialized ($uuid)");
         }
@@ -69,7 +69,7 @@ 
 
         $playhead = $this->convertPlayhead($playhead);
 
-        if(! array_key_exists($playhead, $this->chunks))
+        if( ! array_key_exists($playhead, $this->chunks))
         {
             throw new \LogicException("Invalid chunk number : $playhead");
         }

src/Workers/Chunks/ChunkAssemblyTrackers/MultipleTracker.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
 
     private function getTracker(Uuid $uuid)
     {
-        if(! isset($this->trackers[$uuid->value()]))
+        if( ! isset($this->trackers[$uuid->value()]))
         {
             $factory = $this->trackerInstanciator;
             $this->trackers[$uuid->value()] = $factory();

src/Workers/Chunks/ChunkAssembler.php

Spacing +2 added lines, -2 removed lines

@@ -51,7 +51,7 @@ 
 
     private function retrieveChunkedMessageMetadata(array $headers)
     {
-        if(! isset($headers['chunkedMessage']))
+        if( ! isset($headers['chunkedMessage']))
         {
             throw new \InvalidArgumentException("Missing chunkedMessage header");
         }
@@ -61,7 +61,7 @@ 
 
     private function retrieveChunkMetadata(array $headers)
     {
-        if(! isset($headers['chunk']))
+        if( ! isset($headers['chunk']))
         {
             throw new \InvalidArgumentException("Missing chunk header");
         }

src/Workers/Chunks/ChunkAssemblyStorages/FileStorage.php

Spacing +2 added lines, -2 removed lines

@@ -25,7 +25,7 @@ 
 
     private function ensureTempDirectoryExists()
     {
-        if(! is_dir($this->tempDirPath))
+        if( ! is_dir($this->tempDirPath))
         {
             mkdir($this->tempDirPath, 0755, true);
         }
@@ -60,7 +60,7 @@ 
     {
         $filepath = $this->computeFilepath($uuid);
 
-        if(! $stream = fopen($filepath, 'r+'))
+        if( ! $stream = fopen($filepath, 'r+'))
         {
             throw new \RuntimeException("Unable to open file $filepath");
         }

Upper-Lower-Casing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
 
         if(is_file($filepath))
         {
-            throw new \LogicException("File $filepath already exists");
+            throw new \LogicException("file $filepath already exists");
         }
 
         $success = touch($filepath);

src/Clients/ChunkedMessageClient.php

Spacing +2 added lines, -2 removed lines

@@ -20,7 +20,7 @@ 
     {
         $this->changeRoutingKeyPrefix(self::DEFAULT_ROUTING_KEY_PREFIX);
 
-        if(! $memory instanceof MemoryManagementStrategy)
+        if( ! $memory instanceof MemoryManagementStrategy)
         {
             $memory = new NullMemoryManagementStrategy();
         }
@@ -43,7 +43,7 @@ 
     {
         $streamedContent = $chunkedMessage->getBodyInTransportFormat();
 
-        if(! $streamedContent instanceof \Generator)
+        if( ! $streamedContent instanceof \Generator)
         {
             return $this->client->publish($exchangeName, $chunkedMessage);
         }

src/Messages/Bodies/StreamedFile.php

Spacing +1 added lines, -1 removed lines

@@ -52,7 +52,7 @@
 
         $stream = fopen($this->filepath, 'r');
 
-        while(! feof($stream))
+        while( ! feof($stream))
         {
             $content = fread($stream, $this->chunkSize->toBytes());
             $playhead++;

src/Messages/Chunks/ChunkedMessageMetadata.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
 
         foreach($requiredKeys as $key)
         {
-            if(! isset($headers[$key]))
+            if( ! isset($headers[$key]))
             {
                 throw new \InvalidArgumentException("Missing $key in chunked message metadata");
             }

Upper-Lower-Casing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
         {
             if(! isset($headers[$key]))
             {
-                throw new \InvalidArgumentException("Missing $key in chunked message metadata");
+                throw new \InvalidArgumentException("missing $key in chunked message metadata");
             }
         }
 

src/Messages/Chunks/ChunkMetadata.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
 
         foreach($requiredKeys as $key)
         {
-            if(! isset($headers[$key]))
+            if( ! isset($headers[$key]))
             {
                 throw new \InvalidArgumentException("Missing $key in chunk metadata");
             }

Upper-Lower-Casing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
         {
             if(! isset($headers[$key]))
             {
-                throw new \InvalidArgumentException("Missing $key in chunk metadata");
+                throw new \InvalidArgumentException("missing $key in chunk metadata");
             }
         }
 

test-receive.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
 
 $consumer = new Insomniac();
 
-$tracker = new MultipleTracker(function () {
+$tracker = new MultipleTracker(function() {
     return new SingleTrackingInMemory();
 });