Zanzara\UpdateMode\UpdateMode

Complexity

Total Complexity

3

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	processUpdate()	0	13	2

<?php

declare(strict_types=1);

namespace Zanzara\UpdateMode;

use Psr\Container\ContainerInterface;
use React\EventLoop\LoopInterface;
use Zanzara\Config;
use Zanzara\Context;
use Zanzara\Listener\Listener;
use Zanzara\Telegram\Telegram;
use Zanzara\Telegram\Type\Update;
use Zanzara\Zanzara;
use Zanzara\ZanzaraLogger;
use Zanzara\ZanzaraMapper;

/**
 *
 */
abstract class UpdateMode implements UpdateModeInterface
{

    /**
     * @var ContainerInterface
     */
    protected $container;

    /**
     * @var Zanzara
     */
    protected $zanzara;

    /**
     * @var Telegram
     */
    protected $telegram;

    /**
     * @var Config
     */
    protected $config;

    /**
     * @var ZanzaraLogger
     */
    protected $logger;

    /**
     * @var LoopInterface
     */
    protected $loop;

    /**
     * @var ZanzaraMapper
     */
    protected $zanzaraMapper;

    /**
     * @param ContainerInterface $container
     * @param Zanzara $zanzara
     * @param Telegram $telegram
     * @param Config $config
     * @param ZanzaraLogger $logger
     * @param LoopInterface $loop
     * @param ZanzaraMapper $zanzaraMapper
     */
    public function __construct(ContainerInterface $container, Zanzara $zanzara, Telegram $telegram, Config $config,
                                ZanzaraLogger $logger, LoopInterface $loop, ZanzaraMapper $zanzaraMapper)
    {
        $this->container = $container;
        $this->zanzara = $zanzara;
        $this->telegram = $telegram;
        $this->config = $config;
        $this->logger = $logger;
        $this->loop = $loop;
        $this->zanzaraMapper = $zanzaraMapper;
    }

    /**
     * @param Update $update
     */
    protected function processUpdate(Update $update)
    {
        $update->detectUpdateType();
        $this->zanzara->resolveListeners($update)
            ->then(function ($listeners) use ($update) {
                /** @var Listener[] $listeners */
                foreach ($listeners as $listener) {
                    $context = new Context($update, $this->container);
                    $middlewareTip = $listener->getTip();
                    $middlewareTip($context);
                }
            })->otherwise(function ($e) use ($update) {

The method otherwise() does not exist on React\Promise\PromiseInterface. It seems like you code against a sub-type of said class. However, the method does not exist in Zanzara\Test\PromiseWrapper\ZanzaraPromise or React\Promise\CancellablePromiseInterface. Are you sure you never get one of those?

                $this->logger->error("Unable to resolve listeners for update $update, reason: $e");
            });
    }

}