Pageon\SlackWebhookMonolog\Slack\Payload

Complexity

Total Complexity

18

Size/Duplication

Total Lines	147
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	0	Features	4

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	generatePayload()	0	10	2
A	generatePayloadForSlackConfig()	0	8	2
A	generatePayloadForCustomUser()	0	5	1
A	setIcon()	0	9	2
A	setUsername()	0	8	2
A	setChannel()	0	8	2
A	setErrorData()	0	8	2
A	hasErrorData()	0	4	1
A	setMessage()	0	8	2
A	jsonSerialize()	0	4	1

<?php

namespace Pageon\SlackWebhookMonolog\Slack;

use JsonSerializable;
use Pageon\SlackWebhookMonolog\Monolog\Interfaces\ErrorInterface;
use Pageon\SlackWebhookMonolog\Slack\Interfaces\ConfigInterface as SlackConfigInterface;

/**
 * Turns the record into a payload for slack.
 *
 * Class Payload
 *
 * @author Jelmer Prins <jelmer@$pageon.be>
 */
class Payload implements JsonSerializable
{
    /**
     * @var array The data from the error handler
     */
    private $record;

    /**
     * The data that will be send to the api.
     *
     * @var array
     */
    private $payload;

    /**
     * Extra error data.
     *
     * @var ErrorInterface
     */
    private $errorData;

    /**
     * Contains some extra information like channel and user etc that can be used in the payload.
     *
     * @var SlackConfigInterface
     */
    private $slackConfig;

    /**
     * Payload constructor.
     *
     * @param array $record
     * @param SlackConfigInterface $slackConfig
     */
    public function __construct(array $record, SlackConfigInterface $slackConfig = null)
    {
        $this->record = $record;
        $this->slackConfig = $slackConfig;

        $this->generatePayload();
    }

    private function generatePayload()
    {
        $this->setErrorData();

        $this->setMessage();

        if ($this->slackConfig !== null) {
            $this->generatePayloadForSlackConfig();
        }
    }

    /**
     * Generate the payload for the slack config
     */
    private function generatePayloadForSlackConfig()
    {
        $this->setChannel();

        if ($this->slackConfig->hasCustomUser()) {
            $this->generatePayloadForCustomUser();
        }
    }

    private function generatePayloadForCustomUser()
    {
        $this->setIcon();
        $this->setUsername();
    }

    /**
     * Set a custom icon if available.
     */
    private function setIcon()
    {
        if (!$this->slackConfig->getCustomUser()->hasIcon()) {
            return;
        }

        $iconType = 'icon_' . $this->slackConfig->getCustomUser()->getIcon()->getType();
        $this->payload[$iconType] = $this->slackConfig->getCustomUser()->getIcon();
    }

    /**
     * Set a custom username if available.
     */
    private function setUsername()
    {
        if (!$this->slackConfig->getCustomUser()->hasUsername()) {
            return;
        }

        $this->payload['username'] = $this->slackConfig->getCustomUser()->getUsername();
    }

    /**
     * Set a custom channel if available.
     */
    private function setChannel()
    {
        if (!$this->slackConfig->getWebhook()->hasCustomChannel()) {
            return;
        }

        $this->payload['channel'] = $this->slackConfig->getWebhook()->getCustomChannel();
    }

    /**
     * If available set the error data.
     */
    private function setErrorData()
    {
        if (!isset($this->record['context']['error'])) {
            return;
        }

        $this->errorData = $this->record['context']['error'];
    }

    /**
     * Check if we have the extra error data.
     *
     * @return bool
     */
    private function hasErrorData()
    {
        return $this->errorData !== null;
    }

    private function setMessage()
    {
        $this->payload['text'] = sprintf(
            '*%s:* %s',
            $this->record['level_name'],
            $this->hasErrorData() ? $this->errorData->getMessage() : $this->record['message']
        );
    }

    /**
     * @inheritdoc
     */
    public function jsonSerialize()
    {
        return $this->payload;
    }
}