TelegramBot\APIPollClient

Complexity

Total Complexity

10

Size/Duplication

Total Lines	94
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

97.62%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	poll()	0	12	1
A	send()	0	12	1
A	markMessageHandled()	0	4	1
A	getResponseHeaders()	0	7	1
A	botCommand()	0	6	2
A	assembleUri()	0	9	1
A	postDataEncoder()	0	10	2

<?php

namespace TelegramBot;

use TelegramBot\APIMessage;
use React\HttpClient\Client;
use React\HttpClient\Request;

class APIPollClient
{
    /** @var string */
  private $botToken;
  /** @var int */
  private $offset;
  /** @var \React\HttpClient\Client */
  private $client;

  /**
   * @param string $botToken
   */
  public function __construct(string $botToken, Client $client)
  {
      $this->botToken = $botToken;
      $this->client = $client;
  }

  /**
   * @param CallableInterface $responseHandler
   */
  public function poll($responseHandler)
  {
      $request = $this->client->request(
      'GET',
      $this->botCommand('getUpdates', ['offset' => $this->offset])
    );
      $request->on('response', $responseHandler);
      $request->on('error', function ($data) {
          throw new \Exception($data);
      });
      $request->end();
  }

  /**
   * @param string $answer
   * @param APIMessage $message
   */
  public function send($answer, APIMessage $message)
  {
      $responseData = $this->postDataEncoder($message->getResponseData($answer));

      $responseCall = $this->client->request(
      'POST',
      $this->botCommand('sendMessage'),
      $this->getResponseHeaders($responseData)
    );

      $responseCall->end($responseData);
  }

    public function markMessageHandled(APIMessage $message)
    {
        $this->offset = $message->getUpdateId() +1;
    }

    public function getResponseHeaders(string $responseString) :array
    {
        return [
      'Content-Type' =>  'application/x-www-form-urlencoded',
      'Content-Length' => strlen($responseString)
    ];
    }


    private function botCommand(string $command, array $params = []) :string
    {
        $params = (count($params)) ? '?' . $this->postDataEncoder($params) : '';

        return $this->assembleUri($command, $params);
    }


    private function assembleUri($command, $params) :string
    {
        return sprintf(
      'https://api.telegram.org/bot%s/%s%s',
      $this->botToken,
      $command,
      $params
    );
    }

    private function postDataEncoder(array $data) :string
    {
        $string = '';

        foreach ($data as $k => $v) {
            $string .= $k . '=' . urlencode($v) . '&';
        }

        return $string;
    }
}