Slince\SmartQQ\Client

Complexity

Total Complexity

45

Size/Duplication

Total Lines	390
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	32

Importance

Changes

0

26 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	3
B	login()	0	23	4
A	makeQrCodeImage()	0	11	3
B	verifyQrCodeStatus()	0	21	5
A	getPtWebQQ()	0	12	3
A	getVfWebQQ()	0	6	1
A	getUinAndPSessionId()	0	11	1
A	setCredential()	0	5	1
A	getCredential()	0	7	2
A	getCookies()	0	4	1
A	setHttpClient()	0	4	1
A	getHttpClient()	0	4	1
A	getGroups()	0	6	1
A	getGroupDetail()	0	6	1
A	getDiscusses()	0	6	1
A	getDiscussDetail()	0	6	1
A	getFriends()	0	6	1
A	getFriendDetail()	0	6	1
A	getFriendQQ()	0	8	1
A	getFriendLnick()	0	6	1
A	getFriendsOnlineStatus()	0	6	1
A	getRecentList()	0	6	1
A	getCurrentUserInfo()	0	6	1
A	pollMessages()	0	6	1
A	sendMessage()	0	12	3
A	sendRequest()	0	21	4

<?php
/**
 * SmartQQ Library
 * @author Tao <taosikai@yeah.net>
 */
namespace Slince\SmartQQ;

use GuzzleHttp\Client as HttpClient;
use GuzzleHttp\Cookie\CookieJar;
use GuzzleHttp\Psr7\Request;
use Psr\Http\Message\ResponseInterface;
use Slince\SmartQQ\Entity\Discuss;
use Slince\SmartQQ\Entity\DiscussDetail;
use Slince\SmartQQ\Entity\Friend;
use Slince\SmartQQ\Entity\Group;
use Slince\SmartQQ\Entity\GroupDetail;
use Slince\SmartQQ\Entity\Profile;
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\GetLnickRequest;
use Slince\SmartQQ\Request\RequestInterface;
use Slince\SmartQQ\Request\GetCurrentUserRequest;
use Slince\SmartQQ\Request\GetDiscussDetailRequest;
use Slince\SmartQQ\Request\GetDiscussesRequest;
use Slince\SmartQQ\Request\GetFriendDetailRequest;
use Slince\SmartQQ\Request\GetFriendsOnlineStatusRequest;
use Slince\SmartQQ\Request\GetFriendsRequest;
use Slince\SmartQQ\Request\GetGroupDetailRequest;
use Slince\SmartQQ\Request\GetGroupsRequest;
use Slince\SmartQQ\Request\GetPtWebQQRequest;
use Slince\SmartQQ\Request\GetQQRequest;
use Slince\SmartQQ\Request\GetQrCodeRequest;
use Slince\SmartQQ\Request\GetRecentListRequest;
use Slince\SmartQQ\Request\GetUinAndPsessionidRequest;
use Slince\SmartQQ\Request\GetVfWebQQRequest;
use Slince\SmartQQ\Request\PollMessagesRequest;
use Slince\SmartQQ\Request\SendDiscusMessageRequest;
use Slince\SmartQQ\Request\SendFriendMessageRequest;
use Slince\SmartQQ\Request\SendGroupMessageRequest;
use Slince\SmartQQ\Request\SendMessageRequest;
use Slince\SmartQQ\Request\VerifyQrCodeRequest;

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

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

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

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

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

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

    /**
     * 开启登录流程自行获取凭证
     * @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 ($status == VerifyQrCodeRequest::STATUS_EXPIRED) {
                $qrSign = $this->makeQrCodeImage($loginQRImage);
                $ptQrToken = Utils::hash33($qrSign);
            } elseif ($status == VerifyQrCodeRequest::STATUS_CERTIFICATION) {
                //授权成功跳出状态检查
                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);
        return $this->credential;
    }

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

    /**
     * 验证二维码状态
     * @param int $ptQrToken qr token
     * @return int
     */
    protected function verifyQrCodeStatus($ptQrToken)
    {
        $request = new VerifyQrCodeRequest($ptQrToken);
        $response = $this->sendRequest($request);
        if (strpos($response->getBody(), '未失效') !== false) {
            $status = VerifyQrCodeRequest::STATUS_UNEXPIRED;
        } elseif (strpos($response->getBody(), '已失效') !== false) {
            $status = VerifyQrCodeRequest::STATUS_EXPIRED;
        } elseif (strpos($response->getBody(), '认证中') !== false) {
            $status = VerifyQrCodeRequest::STATUS_ACCREDITATION;
        } else {
            $status = 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 GetPtWebQQRequest();
        $request->setUri($certificationUrl);
        $this->sendRequest($request);
        foreach ($this->getCookies() as $cookie) {
            if (strcasecmp($cookie->getName(), 'ptwebqq') == 0) {
                return $cookie->getValue();
            }
        }
        throw new RuntimeException("Can not find parameter [ptwebqq]");
    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

    /**
     * @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;
    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

    /**
     * 获取所有的好友
     * @return EntityCollection
     */
    public function getFriends()
    {
        $request = new GetFriendsRequest($this->getCredential());
        $response = $this->sendRequest($request);
        return GetFriendsRequest::parseResponse($response);

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

    /**
     * 获取好友的QQ号
     * @param Friend $friend
     * @return int
     */
    public function getFriendQQ(Friend $friend)
    {
        $request = new GetQQRequest($friend, $this->getCredential());
        $response = $this->sendRequest($request);
        $qq = GetQQRequest::parseResponse($response);

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

        $friend->setQq($qq);
        return $qq;
    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

    /**
     * 发送消息，包括好友消息，群消息，讨论组消息
     * @param RequestMessage $message
     * @return bool
     */
    public function sendMessage(RequestMessage $message)
    {
        if ($message instanceof FriendMessage) {
            $request = new SendFriendMessageRequest($message, $this->getCredential());
        } elseif ($message instanceof GroupMessage) {
            $request = new SendGroupMessageRequest($message, $this->getCredential());
        } else {
            $request = new 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 SendMessageRequest::parseResponse($response);

$response of type object<Psr\Http\Message\ResponseInterface> is not a sub-type of object<GuzzleHttp\Psr7\Response>. It seems like you assume a concrete implementation of the interface Psr\Http\Message\ResponseInterface to be always present.

    }

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