Slince\SmartQQ\MessageHandler

Complexity

Total Complexity

12

Size/Duplication

Total Lines	117
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	onMessage()	0	9	2
B	listen()	0	25	6
A	stop()	0	4	1
A	testLogin()	0	9	2

<?php

/*
 * This file is part of the slince/smartqq package.
 *
 * (c) Slince <taosikai@yeah.net>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Slince\SmartQQ;

use GuzzleHttp\Exception\ConnectException;
use Slince\EventDispatcher\DispatcherInterface;
use Slince\EventDispatcher\Event;
use Slince\SmartQQ\Exception\InvalidArgumentException;
use Slince\SmartQQ\Exception\ResponseException;
use Slince\SmartQQ\Exception\RuntimeException;

class MessageHandler
{
    /**
     * 事件名，当收到消息时触发.
     *
     * @var string
     */
    const EVENT_MESSAGE = 'message';

    /**
     * @var Client
     */
    protected $client;

    /**
     * @var DispatcherInterface
     */
    protected $eventDispatcher;

    /**
     * @var boolean
     */
    protected $stop = false;

    /**
     * 可以被忽略的状态码.
     *
     * @var array
     */
    protected static $ignoredCodes = [
        0, 100003, 100100, 100012
    ];

    public function __construct(Client $client)
    {
        $this->client = $client;
        $this->eventDispatcher = $client->getEventDispatcher();
    }

    /**
     * 绑定消息处理回调
     *
     * ```php
     * $handler->onMessage(function(Slince\SmartQQ\Message\Response\Message $message){
     *      //...
     * });
     * ```
     *
     * @param callable $handler
     */
    public function onMessage($handler)
    {
        if (!is_callable($handler)) {
            throw new InvalidArgumentException('Message handler should be callable.');
        }
        $this->eventDispatcher->addListener(static::EVENT_MESSAGE, function(Event $event) use ($handler){
            $handler($event->getArgument('message'));
        });
    }

    /**
     * 开始监听客户端消息
     */
    public function listen()
    {
        while (!$this->stop) {
            try {
                $messages = $this->client->pollMessages();
                foreach ($messages as $message) {
                    // 收到消息时触发事件
                    $event = new Event(static::EVENT_MESSAGE, null, [
                        'message' => $message
                    ]);
                    $this->eventDispatcher->dispatch($event);
                }
            } catch (ResponseException $exception) {
                if (in_array($exception->getCode(), static::$ignoredCodes)) {
                    $this->testLogin();
                    usleep(2000000);
                } else {
                    throw $exception; // 其它状态码接着抛出异常
                }
            } catch (ConnectException $exception) {
                // 超时请求忽略
                usleep(2000000);
            }
        }
    }

    /**
     * 终止下一次消息监听.
     *
     * ```php
     * $handler->onMessage(function($message) use ($handler){
     *     var_dump($message);
     *     $handler->stop();  //停止
     * });
     * ```
     */
    public function stop()
    {
        $this->stop = true;
    }

    /**
     * 测试登录
     */
    protected function testLogin()
    {
        try {
            $this->client->getFriendsOnlineStatus();
        } catch (\Exception $exception) {
            //登录凭证可能失效
            throw new RuntimeException('The credential may be expired, please login again.', $exception->getCode());
        }
    }
}