Chrl\AppBundle\Service\GameService

Complexity

Total Complexity

23

Size/Duplication

Total Lines	269
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	findGame()	0	17	3
A	getActiveGames()	0	5	1
A	getInactiveGames()	0	5	1
B	getCurrentUser()	0	29	5
D	checkAnswer()	0	115	9
A	askQuestion()	0	22	1
A	getRandomQuestion()	0	12	1
A	getTopUsers()	0	17	1

<?php

namespace Chrl\AppBundle\Service;

use Chrl\AppBundle\Entity\PointLog;
use Chrl\AppBundle\Entity\Question;
use Doctrine\ORM\EntityManager;
use Doctrine\ORM\EntityManagerInterface;
use Chrl\AppBundle\Entity\Game;
use Chrl\AppBundle\Entity\User;
use Chrl\AppBundle\BuktopuhaBotApi;

/**
 * Game service
 *
 * @category Symfony
 * @package  Chrl_Buktopuha
 * @author   Kirill Kholodilin <charlie@chrl.ru>
 * @license  http://www.gnu.org/copyleft/gpl.html GNU General Public License
 * @link     https://take2.ru/
 */

class GameService
{
    /** @var EntityManager */
    public $em;
    /** @var BuktopuhaBotApi */
    private $botApi;

    private $config;

    public function __construct(BuktopuhaBotApi $telegramBotApi, $config, EntityManagerInterface $entityManager)
    {
        $this->em = $entityManager;

$entityManager is of type object<Doctrine\ORM\EntityManagerInterface>, but the property $em was declared to be of type object<Doctrine\ORM\EntityManager>. Are you sure that you always receive this specific sub-class here, or does it make sense to add an instanceof check?

        $this->botApi = $telegramBotApi;
        $this->config = $config;
    }


    /**
     * @return Game
     */
    public function findGame(array $message)
    {
        $game = $this->em->getRepository('AppBundle:Game')->findOneBy(['chatId'=>$message['chat']['id']]);
        if (!$game) {
            // create game
            $game = new Game();
            $game->status = 0;
            $game->chatId = $message['chat']['id'];
            $game->title = isset($message['chat']['title'])
                ? $message['chat']['title']
                : 'No title';

            $this->em->persist($game);
            $this->em->flush();
        }
        return $game;
    }


    public function getCurrentUser(array $message)
    {
        $user = $this->em->getRepository('AppBundle:User')->findOneBy(['tgId'=>$message['from']['id']]);
        if (!$user) {
            $user = new User();
            $user->setName(
                (
                    isset($message['from']['first_name'])
                    ? $message['from']['first_name']
                    : ''
                )
                .' '.
                (
                isset($message['from']['last_name'])
                    ? $message['from']['last_name']
                    : ''
                )
            );
            $user->setAlias(isset($message['from']['username'])? $message['from']['username']:'username');
            $user->setTgId($message['from']['id']);
            $user->setGame($this->findGame($message));
            $user->setChatId($message['chat']['id']);
            $user->setPoints(0);

            $this->em->persist($user);
            $this->em->flush();
        }
        return $user;
    }

    public function getActiveGames()
    {
        $games = $this->em->getRepository('AppBundle:Game')->findBy(['status'=>1]);
        return $games;
    }
    public function getInactiveGames()
    {
        $games = $this->em->getRepository('AppBundle:Game')->findBy(['status'=>0]);
        return $games;
    }


    /**
     * Checks if the answer is correct, and asks next question
     *
     * @param array $message
     */
    public function checkAnswer($message)
    {
        $game = $this->findGame($message);
        $user = $this->getCurrentUser($message);

        if ($game->status == 1) {
            /** @var Question $question */
            $question = $this->em->getRepository('AppBundle:Question')->find($game->lastQuestion);

            if (!$question) {
                return;
            }

            if (mb_strtoupper($question->a1, 'UTF-8') == mb_strtoupper($message['text'], 'UTF-8')) {
                // Correct answer!

                $user->setPoints($user->getPoints()+$question->price);
                $this->em->persist($user);

                // Log points

                $pl = new PointLog();
                $pl->date = new \DateTime("now");
                $pl->day = date('d');
                $pl->month = date('m');
                $pl->year = date('Y');
                $pl->points = $question->price;
                $pl->userId = $user->getId();
                $pl->gameId = $game->getId();

                $this->em->persist($pl);

                $seconds = new \Datetime('now');
                $seconds = $seconds->getTimestamp() - $game->lastQuestionTime->getTimestamp();

                $this->botApi->sendMessage(
                    $game->chatId,
                    json_decode('"\ud83d\udc4d"').' Correct in *'.$seconds.'* secs! @'.$user->getAlias().' gets *'.
                    $question->price.'* and now has *'.$user->getPoints().'* points!',
                    'markdown',
                    false,
                    $message['message_id']
                );

                $question->correct++;
                $this->em->persist($question);

                if ($user->fastestAnswer > $seconds) {
                    $user->fastestAnswer = $seconds;
                    $user->setPoints($user->getPoints() + 50);

                    $this->em->persist($user);

                    $pl = new PointLog();
                    $pl->date = new \DateTime("now");
                    $pl->day = date('d');
                    $pl->month = date('m');
                    $pl->year = date('Y');
                    $pl->points = 50;
                    $pl->userId = $user->getId();
                    $pl->gameId = $game->getId();

                    $this->em->persist($pl);

                    $this->botApi->sendMessage(
                        $game->chatId,
                        '@'.$user->getAlias().' gets additional *50* points for his fastest answer ever!',
                        'markdown',
                        false
                    );
                }

                $this->askQuestion($game);
            } else {
                // Incorrect answer
                $game->incorrectTries++;
                $hint = $game->hint;

                if (mb_substr_count($hint, '*', 'UTF-8') >= mb_strlen($hint, 'UTF-8')/2) {
                    //tell hint

                    for ($t = 0; $t< mb_strlen($hint); $t++) {
                        if (mb_substr($hint, $t, 1, 'UTF-8') == '*') {
                            if (rand(0, 1)==1) {
                                $hint = mb_substr($hint, 0, $t, 'UTF-8')
                                        .mb_substr($question->a1, $t, 1)
                                        .mb_substr($hint, $t+1);
                                break;
                            }
                        }
                    }

                    $game->hint = $hint;

                    $this->botApi->sendMessage(
                        $game->chatId,
                        '<b>Hint</b>: '.$hint,
                        'html'
                    );
                } else {
                    $this->botApi->sendMessage(
                        $game->chatId,
                        'Noone answered, correct answer was: *'.$question->a1.'*',
                        'markdown'
                    );
                    $this->em->persist($game);
                    $this->em->flush();
                    $this->askQuestion($game);
                }
            }

            $this->em->persist($game);
            $this->em->flush();
        }
    }

    /**
     * Asks question in the game
     *
     * @param Game $game
     */

    public function askQuestion(Game $game)
    {
        $question = $this->getRandomQuestion();

        $question->played++;

        $game->lastQuestion = $question->getId();
        $game->lastQuestionTime = new \DateTime('now');
        $game->incorrectTries = 0;
        $game->hint = str_repeat('*', mb_strlen($question->a1, 'UTF-8'));

        $this->em->persist($game);
        $this->em->persist($question);
        $this->em->flush();

        $this->botApi->sendMessage(
            $game->chatId,
            '*[question]* '.
            $question->text.' _('.mb_strlen($question->a1, 'UTF-8'). ' letters)_',
            'markdown'
        );
    }

    /**
     * Gets random question from database
     *
     * @return Question
     * @throws \Doctrine\ORM\NoResultException
     * @throws \Doctrine\ORM\NonUniqueResultException
     */
    public function getRandomQuestion()
    {
        $count = $this->em->createQueryBuilder()
            ->select('COUNT(u)')->from('AppBundle:Question', 'u')
            ->getQuery()
            ->getSingleScalarResult();

        return $this->em->createQuery('SELECT c FROM AppBundle:Question c ORDER BY c.id ASC')
            ->setFirstResult(rand(0, $count - 1))
            ->setMaxResults(1)
            ->getSingleResult();
    }

    public function getTopUsers()
    {
        $top = $this->em->createQueryBuilder()
            ->select(
                array(
                    'SUM(u.points) points',
                    'u.name',
                )
            )->from('AppBundle:User', 'u')
            ->groupBy('u.id')
            ->orderBy('u.points', 'desc')
            ->setMaxResults(10)
            ->getQuery()
            ->getArrayResult();

        return $top;
    }
}