php cs fixes

Author: makasim

pkg/amqp-ext/Tests/AmqpMessageTest.php

@@ -115,12 +115,4 @@ public function testShouldClearPreviouslySetFlags()
 
         $this->assertSame(AMQP_NOPARAM, $message->getFlags());
     }
-
-    /**
-     * @return PsrMessage
-     */
-    protected function createMessage()
-    {
-        return new AmqpMessage();
-    }
 }

pkg/amqp-ext/Tests/Spec/AmqpMessageTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\AmqpExt\Tests\Spec;
 
 use Enqueue\AmqpExt\AmqpMessage;
@@ -13,4 +14,4 @@ protected function createMessage()
     {
         return new AmqpMessage();
     }
-}
+}

pkg/dbal/Tests/DbalMessageTest.php

@@ -3,7 +3,6 @@
 namespace Enqueue\Dbal\Tests;
 
 use Enqueue\Dbal\DbalMessage;
-use Enqueue\Psr\PsrMessage;
 use Enqueue\Test\ClassExtensionTrait;
 
 class DbalMessageTest extends \PHPUnit_Framework_TestCase

pkg/dbal/Tests/Spec/DbalMessageTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\Dbal\Tests\Spec;
 
 use Enqueue\Dbal\DbalMessage;
@@ -13,4 +14,4 @@ protected function createMessage()
     {
         return new DbalMessage();
     }
-}
+}

pkg/fs/Tests/FsMessageTest.php

@@ -3,7 +3,6 @@
 namespace Enqueue\Fs\Tests;
 
 use Enqueue\Fs\FsMessage;
-use Enqueue\Psr\PsrMessage;
 use Enqueue\Test\ClassExtensionTrait;
 
 class FsMessageTest extends \PHPUnit\Framework\TestCase

pkg/fs/Tests/Spec/FsMessageTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\Fs\Tests\Spec;
 
 use Enqueue\Fs\FsMessage;
@@ -13,4 +14,4 @@ protected function createMessage()
     {
         return new FsMessage();
     }
-}
+}

pkg/null/Tests/Spec/NullMessageTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\Null\Tests\Spec;
 
 use Enqueue\Null\NullMessage;
@@ -13,4 +14,4 @@ protected function createMessage()
     {
         return new NullMessage();
     }
-}
+}

pkg/redis/Tests/RedisMessageTest.php

@@ -2,86 +2,34 @@
 
 namespace Enqueue\Redis\Tests;
 
-use Enqueue\Psr\PsrMessage;
 use Enqueue\Redis\RedisMessage;
 use Enqueue\Test\ClassExtensionTrait;
 
 class RedisMessageTest extends \PHPUnit\Framework\TestCase
 {
     use ClassExtensionTrait;
 
-    public function testShouldImplementMessageInterface()
-    {
-        $this->assertClassImplements(PsrMessage::class, RedisMessage::class);
-    }
-
     public function testShouldImplementJsonSerializableInterface()
     {
         $this->assertClassImplements(\JsonSerializable::class, RedisMessage::class);
     }
 
-    public function testCouldConstructMessageWithBody()
-    {
-        $message = new RedisMessage('body');
-
-        $this->assertSame('body', $message->getBody());
-    }
-
-    public function testCouldConstructMessageWithProperties()
-    {
-        $message = new RedisMessage('', ['key' => 'value']);
-
-        $this->assertSame(['key' => 'value'], $message->getProperties());
-    }
-
-    public function testCouldConstructMessageWithHeaders()
-    {
-        $message = new RedisMessage('', [], ['key' => 'value']);
-
-        $this->assertSame(['key' => 'value'], $message->getHeaders());
-    }
-
-    public function testCouldSetGetBody()
-    {
-        $message = new RedisMessage();
-        $message->setBody('body');
-
-        $this->assertSame('body', $message->getBody());
-    }
-
-    public function testCouldSetGetProperties()
-    {
-        $message = new RedisMessage();
-        $message->setProperties(['key' => 'value']);
-
-        $this->assertSame(['key' => 'value'], $message->getProperties());
-    }
-
-    public function testCouldSetGetHeaders()
-    {
-        $message = new RedisMessage();
-        $message->setHeaders(['key' => 'value']);
-
-        $this->assertSame(['key' => 'value'], $message->getHeaders());
-    }
-
-    public function testCouldSetGetRedelivered()
+    public function testCouldConstructMessageWithoutArguments()
     {
         $message = new RedisMessage();
 
-        $message->setRedelivered(true);
-        $this->assertTrue($message->isRedelivered());
-
-        $message->setRedelivered(false);
-        $this->assertFalse($message->isRedelivered());
+        $this->assertSame('', $message->getBody());
+        $this->assertSame([], $message->getProperties());
+        $this->assertSame([], $message->getHeaders());
     }
 
-    public function testCouldSetGetCorrelationId()
+    public function testCouldBeConstructedWithOptionalArguments()
     {
-        $message = new RedisMessage();
-        $message->setCorrelationId('the-correlation-id');
+        $message = new RedisMessage('theBody', ['barProp' => 'barPropVal'], ['fooHeader' => 'fooHeaderVal']);
 
-        $this->assertSame('the-correlation-id', $message->getCorrelationId());
+        $this->assertSame('theBody', $message->getBody());
+        $this->assertSame(['barProp' => 'barPropVal'], $message->getProperties());
+        $this->assertSame(['fooHeader' => 'fooHeaderVal'], $message->getHeaders());
     }
 
     public function testShouldSetCorrelationIdAsHeader()
@@ -92,14 +40,6 @@ public function testShouldSetCorrelationIdAsHeader()
         $this->assertSame(['correlation_id' => 'the-correlation-id'], $message->getHeaders());
     }
 
-    public function testCouldSetGetMessageId()
-    {
-        $message = new RedisMessage();
-        $message->setMessageId('the-message-id');
-
-        $this->assertSame('the-message-id', $message->getMessageId());
-    }
-
     public function testCouldSetMessageIdAsHeader()
     {
         $message = new RedisMessage();
@@ -108,14 +48,6 @@ public function testCouldSetMessageIdAsHeader()
         $this->assertSame(['message_id' => 'the-message-id'], $message->getHeaders());
     }
 
-    public function testCouldSetGetTimestamp()
-    {
-        $message = new RedisMessage();
-        $message->setTimestamp(12345);
-
-        $this->assertSame(12345, $message->getTimestamp());
-    }
-
     public function testCouldSetTimestampAsHeader()
     {
         $message = new RedisMessage();
@@ -124,22 +56,7 @@ public function testCouldSetTimestampAsHeader()
         $this->assertSame(['timestamp' => 12345], $message->getHeaders());
     }
 
-    public function testShouldReturnNullAsDefaultReplyTo()
-    {
-        $message = new RedisMessage();
-
-        $this->assertSame(null, $message->getReplyTo());
-    }
-
-    public function testShouldAllowGetPreviouslySetReplyTo()
-    {
-        $message = new RedisMessage();
-        $message->setReplyTo('theQueueName');
-
-        $this->assertSame('theQueueName', $message->getReplyTo());
-    }
-
-    public function testShouldAllowGetPreviouslySetReplyToAsHeader()
+    public function testShouldSetReplyToAsHeader()
     {
         $message = new RedisMessage();
         $message->setReplyTo('theQueueName');

pkg/redis/Tests/RedisProducerTest.php

@@ -54,7 +54,7 @@ public function testShouldCallLPushOnSend()
         $redisMock
             ->expects($this->once())
             ->method('lpush')
-            ->with('aDestination', '{"body":null,"properties":[],"headers":[]}')
+            ->with('aDestination', '{"body":"","properties":[],"headers":[]}')
         ;
 
         $producer = new RedisProducer($redisMock);

pkg/redis/Tests/Spec/RedisMessageTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\Redis\Tests\Spec;
 
 use Enqueue\Psr\Spec\PsrMessageSpec;
@@ -13,4 +14,4 @@ protected function createMessage()
     {
         return new RedisMessage();
     }
-}
+}