T3Bot\Commands\BeerCommand

Complexity

Total Complexity

15

Size/Duplication

Total Lines	174
Duplicated Lines	6.9 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

98.61%

Importance

Changes	2
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	12	12	1
A	processAll()	0	4	1
A	processTop10()	0	10	2
A	processStats()	0	12	3
A	processFor()	0	19	3
A	checkSpendingOfLastBeer()	0	15	2
A	getBeerCountByUsername()	0	11	1
A	getBeerCountAll()	0	9	1
A	getBeerTop10()	0	12	1

<?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 BeerCommand.
 *
 * @property string commandName
 * @property array helpCommands
 */
class BeerCommand extends AbstractCommand
{
    /**
     * AbstractCommand constructor.
     *
     * @param Payload $payload
     * @param RealTimeClient $client
     * @param array|null $configuration
     */
    public function __construct(Payload $payload, RealTimeClient $client, array $configuration = null)
    {
        $this->commandName = 'beer';
        $this->helpCommands = [
            'help' => 'shows this help',
            'stats [username]' => 'show beer counter for [username]',
            'for [username]' => 'give [username] a T3Beer',
            'all' => 'show all beer counter',
            'top10' => 'show TOP 10',
        ];
        parent::__construct($payload, $client, $configuration);
    }

    /**
     * stats for all beer counter.
     *
     * @return string
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function processAll() : string
    {
        return 'Yeah, ' . $this->getBeerCountAll() . ' :t3beer: spend to all people';
    }

    /**
     * stats for TOP 10.
     *
     * @return string
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function processTop10() : string
    {
        $rows = $this->getBeerTop10();
        $text = ['*Yeah, here are the TOP 10*'];
        foreach ($rows as $row) {
            $text[] = '<@' . $row['username'] . '> has received ' . $row['cnt'] . ' :t3beer:';
        }

        return implode(chr(10), $text);
    }

    /**
     * stats for beer counter.
     *
     * @return string
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function processStats() : string
    {
        $params = $this->params;
        array_shift($params);
        $username = trim($params[0]);
        if (strpos($username, '<') === 0 && $username[1] === '@') {
            $username = str_replace(['<', '>', '@'], '', $username);

            return '<@' . $username . '> has received ' . $this->getBeerCountByUsername($username) . ' :t3beer: so far';
        }
        return '*Sorry, a username must start with a @-sign:*';
    }

    /**
     * give someone a beer.
     *
     * @return string
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function processFor() : string
    {
        $from_user = $this->payload->getData()['user'];
        $username = trim($this->params[1]);
        if (strpos($username, '<@') === 0) {
            $username = str_replace(['<', '>', '@'], '', $username);
            if ($this->checkSpendingOfLastBeer($username, $from_user)) {
                $this->getDatabaseConnection()->insert('beers', [
                    'to_user' => $username,
                    'from_user' => $from_user,
                    'tstamp' => time()
                ]);
                return 'Yeah, one more :t3beer: for <@' . $username . '>' . chr(10) . '<@' . $username . '> has received '
                    . $this->getBeerCountByUsername($username) . ' :t3beer: so far';
            }
            return 'You spend one :t3beer: to <@' . $username . '> within in last 24 hours. Too much beer is unhealthy ;)';
        }
        return '*Sorry, a username must start with a @-sign:*';
    }

    /**
     * @param string $username
     * @param string $from_user
     *
     * @return bool
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function checkSpendingOfLastBeer(string $username, string $from_user) : bool
    {
        $queryBuilder = $this->getDatabaseConnection()
            ->createQueryBuilder();
        $record = $queryBuilder
            ->select('tstamp')
            ->from('beers')
            ->where($queryBuilder->expr()->eq('to_user', $queryBuilder->createNamedParameter($username)))
            ->andWhere($queryBuilder->expr()->eq('from_user', $queryBuilder->createNamedParameter($from_user)))
            ->orderBy('tstamp', 'DESC')
            ->setMaxResults(1)
            ->execute()
            ->fetch();
        return empty($record) || $record['tstamp'] + 86400 < time();
    }

    /**
     * @param $username
     *
     * @return int
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function getBeerCountByUsername($username) : int
    {
        $queryBuilder = $this->getDatabaseConnection()
            ->createQueryBuilder();
        return $queryBuilder
            ->select('*')
            ->from('beers')
            ->where($queryBuilder->expr()->eq('to_user', $queryBuilder->createNamedParameter($username)))
            ->execute()
            ->rowCount();
    }

    /**
     * @return int
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function getBeerCountAll() : int
    {
        return $this->getDatabaseConnection()
            ->createQueryBuilder()
            ->select('*')
            ->from('beers')
            ->execute()
            ->rowCount();
    }

    /**
     * @return array
     *
     * @throws \Doctrine\DBAL\DBALException
     */
    protected function getBeerTop10() : array
    {
        return $this->getDatabaseConnection()
            ->createQueryBuilder()
            ->select('count(*) AS cnt', 'to_user AS username')
            ->from('beers')
            ->groupBy('to_user')
            ->orderBy('cnt', 'DESC')
            ->setMaxResults(10)
            ->execute()
            ->fetchAll();
    }
}