Slince\SmartQQ\Client

Complexity

Total Complexity

50

Size/Duplication

Total Lines	498
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	34

Importance

Changes

0

29 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	20	4
A	login()	0	26	4
A	makeQrCodeImage()	0	11	3
A	verifyQrCodeStatus()	0	22	5
A	getPtWebQQ()	0	12	3
A	getVfWebQQ()	0	7	1
A	getUinAndPSessionId()	0	12	1
A	setCredential()	0	5	1
A	getCredential()	0	8	2
A	getCookies()	0	4	1
A	setHttpClient()	0	4	1
A	getHttpClient()	0	4	1
A	setEventDispatcher()	0	4	1
A	getEventDispatcher()	0	4	1
A	getGroups()	0	7	1
A	getGroupDetail()	0	7	1
A	getDiscusses()	0	7	1
A	getDiscussDetail()	0	7	1
A	getFriends()	0	7	1
A	getFriendDetail()	0	7	1
A	getFriendQQ()	0	11	1
A	getFriendLnick()	0	7	1
A	getFriendsOnlineStatus()	0	7	1
A	getRecentList()	0	7	1
A	getCurrentUserInfo()	0	7	1
A	pollMessages()	0	7	1
A	getMessageHandler()	0	7	2
A	sendMessage()	0	13	3
A	sendRequest()	0	25	4

<?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\Client as HttpClient;
use GuzzleHttp\Cookie\CookieJar;
use GuzzleHttp\Psr7\Request as HttpRequest;
use GuzzleHttp\Psr7\Response as HttpResponse;
use Slince\EventDispatcher\Dispatcher;
use Slince\EventDispatcher\DispatcherInterface;
use Slince\SmartQQ\Entity;
use Slince\SmartQQ\Exception\InvalidArgumentException;
use Slince\SmartQQ\Exception\RuntimeException;
use Slince\SmartQQ\Message\Request\FriendMessage;
use Slince\SmartQQ\Message\Request\GroupMessage;
use Slince\SmartQQ\Message\Request\Message as RequestMessage;
use Slince\SmartQQ\Message\Response\Message as ResponseMessage;
use Slince\SmartQQ\Request;


class Client
{
    /**
     * @var Credential
     */
    protected $credential;

    /**
     * 客户端id(固定值).
     *
     * @var int
     */
    protected static $clientId = 53999199;

    /**
     * 获取ptwebqq的地址
     *
     * @var string
     */
    protected $certificationUrl;

    /**
     * @var HttpClient
     */
    protected $httpClient;

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

    /**
     * @var CookieJar
     */
    protected $cookies;

    /**
     * @var MessageHandler
     */
    protected $messageHandler;

    public function __construct(
        Credential $credential = null,
        HttpClient $httpClient = null,
        DispatcherInterface $eventDispatcher = null
    )
    {
        if (!is_null($credential)) {
            $this->setCredential($credential);
        }
        if (is_null($httpClient)) {
            $httpClient = new HttpClient([
                'verify' => false,
            ]);
        }
        if (is_null($eventDispatcher)) {
            $eventDispatcher = new Dispatcher();
        }
        $this->httpClient = $httpClient;
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * 开启登录流程自行获取凭证
     *
     * @param string $loginQRImage 二维码图片位置
     *
     * @return Credential
     */
    public function login($loginQRImage)
    {
        //如果登录则重置cookie
        $this->cookies = new CookieJar();
        $qrSign = $this->makeQrCodeImage($loginQRImage);
        $ptQrToken = Utils::hash33($qrSign);
        while (true) {
            $status = $this->verifyQrCodeStatus($ptQrToken);
            if (Request\VerifyQrCodeRequest::STATUS_EXPIRED == $status) {
                $qrSign = $this->makeQrCodeImage($loginQRImage);
                $ptQrToken = Utils::hash33($qrSign);
            } elseif (Request\VerifyQrCodeRequest::STATUS_CERTIFICATION == $status) {
                //授权成功跳出状态检查
                break;
            }
            sleep(1);
        }
        $ptWebQQ = $this->getPtWebQQ($this->certificationUrl);
        $vfWebQQ = $this->getVfWebQQ($ptWebQQ);
        list($uin, $pSessionId) = $this->getUinAndPSessionId($ptWebQQ);
        $this->credential = new Credential($ptWebQQ, $vfWebQQ, $pSessionId, $uin, static::$clientId, $this->cookies);
        //获取在线状态避免103
        $this->getFriendsOnlineStatus();

        return $this->credential;
    }

    /**
     * 创建登录所需的二维码
     *
     * @param string $loginQRImage
     *
     * @return string
     */
    protected function makeQrCodeImage($loginQRImage)
    {
        $response = $this->sendRequest(new Request\GetQrCodeRequest());
        Utils::getFilesystem()->dumpFile($loginQRImage, $response->getBody());
        foreach ($this->getCookies() as $cookie) {
            if (0 == strcasecmp($cookie->getName(), 'qrsig')) {
                return $cookie->getValue();
            }
        }
        throw new RuntimeException('Can not find parameter [qrsig]');
    }

    /**
     * 验证二维码状态
     *
     * @param int $ptQrToken qr token
     *
     * @return int
     */
    protected function verifyQrCodeStatus($ptQrToken)
    {
        $request = new Request\VerifyQrCodeRequest($ptQrToken);
        $response = $this->sendRequest($request);
        if (false !== strpos($response->getBody(), '未失效')) {
            $status = Request\VerifyQrCodeRequest::STATUS_UNEXPIRED;
        } elseif (false !== strpos($response->getBody(), '已失效')) {
            $status = Request\VerifyQrCodeRequest::STATUS_EXPIRED;
        } elseif (false !== strpos($response->getBody(), '认证中')) {
            $status = Request\VerifyQrCodeRequest::STATUS_ACCREDITATION;
        } else {
            $status = Request\VerifyQrCodeRequest::STATUS_CERTIFICATION;
            //找出认证url
            if (preg_match("#'(http.+)'#U", strval($response->getBody()), $matches)) {
                $this->certificationUrl = trim($matches[1]);
            } else {
                throw new RuntimeException('Can not find certification url');
            }
        }

        return $status;
    }

    /**
     * 获取ptwebqq的参数值
     *
     * @param string $certificationUrl
     *
     * @return string
     */
    protected function getPtWebQQ($certificationUrl)
    {
        $request = new Request\GetPtWebQQRequest();
        $request->setUri($certificationUrl);
        $this->sendRequest($request);
        foreach ($this->getCookies() as $cookie) {
            if (0 == strcasecmp($cookie->getName(), 'ptwebqq')) {
                return $cookie->getValue();
            }
        }
        throw new RuntimeException('Can not find parameter [ptwebqq]');
    }

    /**
     * @param string $ptWebQQ
     *
     * @return string
     */
    protected function getVfWebQQ($ptWebQQ)
    {
        $request = new Request\GetVfWebQQRequest($ptWebQQ);
        $response = $this->sendRequest($request);

        return Request\GetVfWebQQRequest::parseResponse($response);
    }

    /**
     * 获取pessionid和uin.
     *
     * @param string $ptWebQQ
     *
     * @return array
     */
    protected function getUinAndPSessionId($ptWebQQ)
    {
        $request = new Request\GetUinAndPsessionidRequest([
            'ptwebqq' => $ptWebQQ,
            'clientid' => static::$clientId,
            'psessionid' => '',
            'status' => 'online',
        ]);
        $response = $this->sendRequest($request);

        return Request\GetUinAndPsessionidRequest::parseResponse($response);
    }

    /**
     * @param Credential $credential
     */
    public function setCredential(Credential $credential)
    {
        $this->cookies = $credential->getCookies();
        $this->credential = $credential;
    }

    /**
     * @return Credential
     */
    public function getCredential()
    {
        if (!$this->credential) {
            throw new InvalidArgumentException('Please login first or set a credential');
        }

        return $this->credential;
    }

    /**
     * @return CookieJar
     */
    public function getCookies()
    {
        return $this->cookies;
    }

    /**
     * @param HttpClient $httpClient
     */
    public function setHttpClient($httpClient)
    {
        $this->httpClient = $httpClient;
    }

    /**
     * @return HttpClient
     */
    public function getHttpClient()
    {
        return $this->httpClient;
    }

    /**
     * @param DispatcherInterface $eventDispatcher
     */
    public function setEventDispatcher($eventDispatcher)
    {
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * @return DispatcherInterface
     */
    public function getEventDispatcher()
    {
        return $this->eventDispatcher;
    }

    /**
     * 获取所有的群.
     *
     * @return EntityCollection
     */
    public function getGroups()
    {
        $request = new Request\GetGroupsRequest($this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetGroupsRequest::parseResponse($response);
    }

    /**
     * 获取群详细信息.
     *
     * @param Entity\Group $group
     *
     * @return Entity\GroupDetail
     */
    public function getGroupDetail(Entity\Group $group)
    {
        $request = new Request\GetGroupDetailRequest($group, $this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetGroupDetailRequest::parseResponse($response);
    }

    /**
     * 获取所有讨论组.
     *
     * @return EntityCollection
     */
    public function getDiscusses()
    {
        $request = new Request\GetDiscussesRequest($this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetDiscussesRequest::parseResponse($response);
    }

    /**
     * 获取讨论组详情.
     *
     * @param Entity\Discuss $discuss
     *
     * @return Entity\DiscussDetail
     */
    public function getDiscussDetail(Entity\Discuss $discuss)
    {
        $request = new Request\GetDiscussDetailRequest($discuss, $this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetDiscussDetailRequest::parseResponse($response);
    }

    /**
     * 获取所有的好友.
     *
     * @return EntityCollection|Entity\Friend[]
     */
    public function getFriends()
    {
        $request = new Request\GetFriendsRequest($this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetFriendsRequest::parseResponse($response);
    }

    /**
     * 获取好友的详细信息.
     *
     * @param Entity\Friend $friend
     *
     * @return Entity\Profile
     */
    public function getFriendDetail(Entity\Friend $friend)
    {
        $request = new Request\GetFriendDetailRequest($friend, $this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetFriendDetailRequest::parseResponse($response);
    }

    /**
     * 获取好友的QQ号.
     *
     * @param Entity\Friend $friend
     *
     * @return int
     * @deprecated 此接口 Smartqq 官方已经不再提供
     */
    public function getFriendQQ(Entity\Friend $friend)
    {
        @trigger_error('The api is not supported now',E_USER_DEPRECATED);

It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended.

        $request = new Request\GetQQRequest($friend, $this->getCredential());
        $response = $this->sendRequest($request);
        $qq = Request\GetQQRequest::parseResponse($response);
        $friend->setQq($qq);

        return $qq;
    }

    /**
     * 获取好友的个性签名.
     *
     * @param Entity\Friend $friend
     *
     * @return string
     */
    public function getFriendLnick(Entity\Friend $friend)
    {
        $request = new Request\GetLnickRequest($friend, $this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetLnickRequest::parseResponse($response, $friend);
    }

    /**
     * 获取好友在线状态
     *
     * @return EntityCollection
     */
    public function getFriendsOnlineStatus()
    {
        $request = new Request\GetFriendsOnlineStatusRequest($this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetFriendsOnlineStatusRequest::parseResponse($response);
    }

    /**
     * 获取最近的会话.
     *
     * @return EntityCollection
     */
    public function getRecentList()
    {
        $request = new Request\GetRecentListRequest($this->getCredential());
        $response = $this->sendRequest($request);

        return Request\GetRecentListRequest::parseResponse($response);
    }

    /**
     * 获取当前登录用户信息.
     *
     * @return Entity\Profile
     */
    public function getCurrentUserInfo()
    {
        $request = new Request\GetCurrentUserRequest();
        $response = $this->sendRequest($request);

        return Request\GetCurrentUserRequest::parseResponse($response);
    }

    /**
     * 轮询消息,
     * client并不会组装信息，只是将接口返回的信息完整抽象并返回
     * 如果需要查询信息对应的数据，如发送人、发送群，请自行获取.
     *
     * @return ResponseMessage[]
     */
    public function pollMessages()
    {
        $request = new Request\PollMessagesRequest($this->getCredential());
        $response = $this->sendRequest($request);

        return Request\PollMessagesRequest::parseResponse($response);
    }

    /**
     * 获取 Message handler.
     *
     * @return MessageHandler
     */
    public function getMessageHandler()
    {
        if (null !== $this->messageHandler) {
            return $this->messageHandler;
        }
        return $this->messageHandler = new MessageHandler($this);
    }

    /**
     * 发送消息，包括好友消息，群消息，讨论组消息.
     *
     * @param RequestMessage $message
     *
     * @return bool
     */
    public function sendMessage(RequestMessage $message)
    {
        if ($message instanceof FriendMessage) {
            $request = new Request\SendFriendMessageRequest($message, $this->getCredential());
        } elseif ($message instanceof GroupMessage) {
            $request = new Request\SendGroupMessageRequest($message, $this->getCredential());
        } else {
            $request = new Request\SendDiscusMessageRequest($message, $this->getCredential());

$message of type object<Slince\SmartQQ\Message\Request\Message> is not a sub-type of object<Slince\SmartQQ\Message\Request\DiscussMessage>. It seems like you assume a child class of the class Slince\SmartQQ\Message\Request\Message to be always present.

        }
        $response = $this->sendRequest($request);

        return Request\SendMessageRequest::parseResponse($response);
    }


    /**
     * @param Request\RequestInterface $request
     *
     * @return HttpResponse
     */
    protected function sendRequest(Request\RequestInterface $request)
    {
        $options = [
            'cookies' => $this->getCookies(),
        ];
        if ($parameters = $request->getParameters()) {
            if (Request\RequestInterface::REQUEST_METHOD_GET == $request->getMethod()) {
                $options['query'] = $parameters;
            } else {
                $options['form_params'] = $parameters;
            }
        }
        //如果有referer需要伪造该信息
        if ($referer = $request->getReferer()) {
            $options['headers'] = [
                'Referer' => $referer,
            ];
        }
        $response = $this->httpClient->send(
            new HttpRequest($request->getMethod(), $request->getUri()),
            $options
        );

        return $response;
    }
}