T3Bot\Commands\TellCommand

Complexity

Total Complexity

21

Size/Duplication

Total Lines	174
Duplicated Lines	6.32 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	11	11	1
A	process()	0	11	2
A	processPresenceChange()	0	16	5
A	getNotificationsForUser()	0	11	1
A	markNotificationAsDelivered()	0	11	1
A	processTextMessage()	0	5	1
A	processTell()	0	20	4
A	processReviewMessage()	0	18	4
A	processForgeMessage()	0	11	2

<?php
/**
 * T3Bot.
 *
 * @author Frank Nägler <frank.naegler@typo3.org>
 *
 * @link http://www.t3bot.de
 * @link http://wiki.typo3.org/T3Bot
 */
namespace T3Bot\Commands;

use Slack\Payload;
use Slack\RealTimeClient;

/**
 * Class TellCommand.
 *
 * @property array helpCommands
 * @property string commandName
 */
class TellCommand extends AbstractCommand
{
    const PRESENCE_ACTIVE = 'active';
    const PRESENCE_AWAY = 'away';

    /**
     * AbstractCommand constructor.
     *
     * @param Payload $payload
     * @param RealTimeClient $client
     * @param array|null $configuration
     */
    public function __construct(Payload $payload, RealTimeClient $client, array $configuration = null)
    {
        $this->commandName = 'tell';
        $this->helpCommands = [
            'help' => 'shows this help',
            'tell [@to-user] about review:[Gerrit-ID]' => 'tell the target user about the given review',
            'tell [@to-user] about forge:[Issue-ID]' => 'tell the target user about the given forge issue',
            'tell [@to-user] [your message]' => 'tell the target user your message',
        ];
        parent::__construct($payload, $client, $configuration);
    }

    /**
     * @return bool|string
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    public function process()
    {
        $message = $this->payload->getData()['text'];
        $this->params = array_map('trim', explode(' ', $message));
        $result = false;
        if ($this->params[0] === 'tell') {
            $result = $this->processTell();
        }

        return $result;
    }

    /**
     * @param string $user
     * @param string $presence
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    public function processPresenceChange($user, $presence)
    {
        if ($presence === self::PRESENCE_ACTIVE) {
            $notifications = $this->getNotificationsForUser($user);
            foreach ($notifications as $notification) {
                if (strpos($notification['message'], 'review:') === 0) {
                    $this->processReviewMessage($notification, $user);
                } elseif (strpos($notification['message'], 'forge:') === 0) {
                    $this->processForgeMessage($notification, $user);
                } else {
                    $this->processTextMessage($notification, $user);
                }
                $this->markNotificationAsDelivered($notification['id']);
            }
        }
    }

    /**
     * @param string $user
     *
     * @return array
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function getNotificationsForUser(string $user) : array
    {
        $queryBuilder = $this->getDatabaseConnection()->createQueryBuilder();
        return $queryBuilder
            ->select('*')
            ->from('notifications')
            ->where($queryBuilder->expr()->eq('to_user', $queryBuilder->createNamedParameter($user)))
            ->andWhere($queryBuilder->expr()->eq('delivered', $queryBuilder->createNamedParameter('0000-00-00 00:00:00')))
            ->execute()
            ->fetchAll();
    }

    /**
     * @param int $id
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function markNotificationAsDelivered(int $id)
    {
        $now = new \DateTime();
        $now->setTimestamp(time());
        $this->getDatabaseConnection()->update(
            'notifications',
            ['delivered' => $now],
            ['id' => $id],
            ['datetime']
        );
    }

    /**
     * @param array $notification
     * @param string $user
     */
    protected function processReviewMessage(array $notification, string $user)
    {
        $parts = explode(':', $notification['message']);
        $refId = (int) trim($parts[1]);
        $result = $this->queryGerrit('change:' . $refId);
        $msg = '*Hi <@' . $user . '>, <@' . $notification['from_user'] . '>'
            . ' ask you to look at this patch:*';

        if (is_array($result)) {
            foreach ($result as $item) {
                if ((int) $item->_number === $refId) {
                    $message = $this->buildReviewMessage($item);
                    $message->setText($msg);
                    $this->sendResponse($message, $user);
                }
            }
        }
    }

    /**
     * @param array $notification
     * @param string $user
     */
    protected function processForgeMessage(array $notification, string $user)
    {
        $parts = explode(':', $notification['message']);
        $issueNumber = (int) trim($parts[1]);
        $result = $this->queryForge('issues/' . $issueNumber);
        if ($result) {
            $msg = '*Hi <@' . $user . '>, <@' . $notification['from_user'] . '>'
                . ' ask you to look at this issue:*';
            $this->sendResponse($msg . chr(10) . $this->buildIssueMessage($result->issue), $user);
        }
    }

    /**
     * @param array $notification
     * @param string $user
     */
    protected function processTextMessage(array $notification, string $user)
    {
        $msg = '*Hi <@' . $user . '>, here is a message from <@' . $notification['from_user'] . '>' . ' for you:*';
        $this->sendResponse($msg . chr(10) . $notification['message'], $user);
    }

    /**
     * @return string
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function processTell() : string
    {
        $params = $this->params;
        array_shift($params);
        $toUser = array_shift($params);
        $toUser = str_replace(['<', '>', '@'], '', $toUser);
        if ($params[0] === 'about'
            && (strpos($params[1], 'review:') !== false || strpos($params[1], 'forge:') !== false)) {
            $message = $params[1];
        } else {
            $message = implode(' ', $params);
        }
        $this->getDatabaseConnection()->insert('notifications', [
            'from_user' => $this->payload->getData()['user'],
            'to_user' => $toUser,
            'message' => $message,
        ]);

        return 'OK, I will tell <@' . $toUser . '> about your message';
    }
}