TestsRabbitMQ - added setUpRabbitMQ and expectMessage helpers

Author: svensp

src/Test/TestsRabbitMQ.php

@@ -34,4 +34,40 @@ protected function makeMessage(string $routingKey, $data) {
 
         return $message;
     }
+
+    protected function setUpRabbitMQ() {
+        $this->rabbitMQ = Mockery::mock( RabbitMQ::class );
+        $this->rabbitMQ->shouldIgnoreMissing($this->rabbitMQ);
+        $this->app->instance(RabbitMQ::class, $this->rabbitMQ);
+    }
+
+    /**
+     * @param string $event
+     * @param array $expectedData
+     */
+    protected function expectMessage( $event, $expectedData ) {
+        $this->rabbitMQ->shouldReceive( 'onExchange' )->with( 'default-exchange', $event )->once()->andReturnSelf();
+        $this->rabbitMQ->shouldReceive( 'publish' )->withArgs(  function ( $data ) use ( $expectedData ) {
+            $anyMatch = false;
+
+            foreach ( $expectedData as $expectedKey => $expectedValue ) {
+
+                if ( !array_key_exists( $expectedKey, $data ) )
+                    return false;
+
+                if( is_float($data[ $expectedKey ]))
+                    $data[ $expectedKey ] = round($data[ $expectedKey ], 9);
+
+                if( is_float($expectedValue))
+                    $expectedValue = round($expectedValue, 9);
+
+                if ( $data[ $expectedKey ] != $expectedValue )
+                    return false;
+
+                $anyMatch = true;
+            }
+
+            return $anyMatch;
+        } )->once()->andReturnSelf();
+    }
 }