IrishDan\NotificationBundle\Adapter\DatabaseMessageAdapter

Complexity

Total Complexity

5

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	5

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	format()	0	22	2
A	dispatch()	0	13	2

<?php

namespace IrishDan\NotificationBundle\Adapter;


use IrishDan\NotificationBundle\DatabaseNotifiableInterface;
use IrishDan\NotificationBundle\DatabaseNotificationManager;
use IrishDan\NotificationBundle\Message\MessageInterface;
use IrishDan\NotificationBundle\Notification\NotificationInterface;

class DatabaseMessageAdapter extends BaseMessageAdapter implements MessageAdapterInterface
{
    protected $databaseNotificationManager;

    public function __construct(DatabaseNotificationManager $databaseNotificationManager)
    {
        $this->databaseNotificationManager = $databaseNotificationManager;
    }

    /**
     * Generates a message object
     *
     * @param NotificationInterface $notification
     * @return \IrishDan\NotificationBundle\Message\Message
     */
    public function format(NotificationInterface $notification)
    {
        parent::format($notification);

        /** @var DatabaseNotifiableInterface $notifiable */
        $notifiable = $notification->getNotifiable();
        if (!$notifiable instanceof DatabaseNotifiableInterface) {
            $this->createFormatterException(DatabaseNotifiableInterface::class, $this->channelName);
        }

        // Build the dispatch data array.
        $dispatchData = [
            'id' => $notifiable->getIdentifier(),
            'notifiable' => $notifiable,
            'uuid' => $notification->getUuid(),
            'type' => get_class($notification),
        ];

        $messageData = self::createMessagaData($notification->getDataArray());

        return self::createMessage($dispatchData, $messageData, $this->channelName);
    }

    public function dispatch(MessageInterface $message)
    {
        $dispatchData = $message->getDispatchData();
        $messageData = $message->getMessageData();
        $data = $dispatchData + $messageData;

        $databaseNotification = $this->databaseNotificationManager->createDatabaseNotification($data);
        if ($databaseNotification) {
            return true;
        }

        return false;
    }
}