Publisher::generateMetadata() - Code Metrics - Inspection of "added drivers" - kbond/php-queue - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#3)

by Kevin

created 2015-11-26 16:30 UTC

Publisher::generateMetadata() A

↳ Parent: Publisher

Complexity

Conditions	3
Paths	3

Size

Total Lines	14
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	3.576

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	14
ccs	3
cts	5
cp	0.6
rs	9.4286
cc	3
eloc	7
nc	3
nop	1
crap	3.576

<?php

namespace Zenstruck\Queue;

use SimpleBus\Asynchronous\Publisher\Publisher as SimpleBusPublisher;
use SimpleBus\Serialization\Envelope\Serializer\MessageInEnvelopSerializer;

/**
 * @author Kevin Bond <[email protected]>
 */
final class Publisher implements SimpleBusPublisher
{
    private $driver;
    private $serializer;

    public function __construct(Driver $driver, MessageInEnvelopSerializer $serializer)
    {
        $this->driver = $driver;
        $this->serializer = $serializer;
    }

    /**
     * {@inheritdoc}
     */
    public function publish($message)
    {
        \Assert\that($message)->isObject();

        $this->driver->push(
            new Payload($this->serializer->wrapAndSerialize($message), $this->generateMetadata($message))
        );
    }

    /**
     * @param object $message
     *
     * @return string
     */
    private function generateMetadata($message)
    {
        $class = get_class($message);

        if ($message instanceof \JsonSerializable) {
            return sprintf('%s: %s', $class, json_encode($message));
        }

        if (method_exists($message, '__toString')) {
            return sprintf('%s: %s', $class, $message);
        }

        return $class;
    }
}


1		<?php
2
3		namespace Zenstruck\Queue;
4
5		use SimpleBus\Asynchronous\Publisher\Publisher as SimpleBusPublisher;
6		use SimpleBus\Serialization\Envelope\Serializer\MessageInEnvelopSerializer;
7
8		/**
9		* @author Kevin Bond <[email protected]>
10		*/
11		final class Publisher implements SimpleBusPublisher
12		{
13		private $driver;
14		private $serializer;
15
16	3	public function __construct(Driver $driver, MessageInEnvelopSerializer $serializer)
17		{
18	3	$this->driver = $driver;
19	3	$this->serializer = $serializer;
20		}
21
22		/**
23		* {@inheritdoc}
24		*/
25	3	public function publish($message)
26		{
27		\Assert\that($message)->isObject();
28
29	3	$this->driver->push(
30		new Payload($this->serializer->wrapAndSerialize($message), $this->generateMetadata($message))
31		);
32	3	}
33
34		/**
35		* @param object $message
36		*
37		* @return string
38		*/
39	3	private function generateMetadata($message)
40		{
41		$class = get_class($message);
42
43	3	if ($message instanceof \JsonSerializable) {
44		return sprintf('%s: %s', $class, json_encode($message));
45		}
46
47		if (method_exists($message, '__toString')) {
48		return sprintf('%s: %s', $class, $message);
49		}
50
51	1	return $class;
52		}
53		}
54

kbond / php-queue

Pull Request — master (#3)

Publisher::generateMetadata() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like