Skobkin\Bundle\PointToolsBundle\Service\Telegram\InlineQueryProcessor

Complexity

Total Complexity

4

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
B	process()	0	29	3

<?php

namespace Skobkin\Bundle\PointToolsBundle\Service\Telegram;


use Doctrine\ORM\EntityManagerInterface;
use Skobkin\Bundle\PointToolsBundle\Repository\UserRepository;
use unreal4u\TelegramAPI\Telegram\Methods\AnswerInlineQuery;
use unreal4u\TelegramAPI\Telegram\Types\Inline\Query;
use unreal4u\TelegramAPI\Telegram\Types\InputMessageContent\Text;
use unreal4u\TelegramAPI\TgLog;

class InlineQueryProcessor
{
    /**
     * @var EntityManagerInterface
     */
    private $em;

    /**
     * @var UserRepository
     */
    private $userRepo;

    /**
     * @var TgLog
     */
    private $client;


    public function __construct(EntityManagerInterface $em, TgLog $client)
    {
        $this->em = $em;
        $this->client = $client;

        $this->userRepo = $em->getRepository('SkobkinPointToolsBundle:User');
    }

    public function process(Query $inlineQuery)
    {
        if (mb_strlen($inlineQuery->query) < 2) {
            return;
        }

        $answerInlineQuery = new AnswerInlineQuery();
        $answerInlineQuery->inline_query_id = $inlineQuery->id;

        foreach ($this->em->getRepository('SkobkinPointToolsBundle:User')->findUsersLikeLogin($inlineQuery->query) as $user) {
            $article = new Query\Result\Article();
            $article->title = $user->getLogin();

            $contentText = new Text();
            $contentText->message_text = sprintf(
                "@%s:\nName: %s\nSubscribers: %d",
                $user->getLogin(),
                $user->getName(),
                $user->getSubscribers()->count()
            );

            $article->input_message_content = $contentText;
            $article->id = md5($user->getId());

            $answerInlineQuery->addResult($article);
        }

        $this->client->performApiRequest($answerInlineQuery);
    }
}