<?php
namespace Hdll\Services\Cmq;

/*
Account 对象非线程安全，如果多线程使用，需要每个线程单独初始化Account对象类
 */
class Account
{
    private $secretId;
    private $secretKey;
    private $cmq_client;

    /*
    @type host: string
    @param host: 访问的url，例如：https://cmq-queue-gz.api.qcloud.com

    @type secretId: string
    @param secretId: 用户的secretId, 腾讯云官网获取

    @type secretKey: string
    @param secretKey:  用户的secretKey，腾讯云官网获取

    @note: Exception
    :: CMQClientParameterException host格式错误
     */


	public function __construct($host = '', $secretId = '', $secretKey = '')
	{
		$config = include alias('@vendor/hdll/services/src/Common/Config') . '/config.php';
		$config = $config['cmq'];
		if (empty($host)){
			$this->host = empty(env('ENVIRONMENT','')) ?$config['intranet_host'] : $config['internet_host'];
		}
		$this->secretId = empty($secretId) ? $config['secretId'] : $secretId;
		$this->secretKey = empty($secretKey) ? $config['secretKey'] : $secretKey;
		$this->cmq_client = new CMQClient($this->host, $this->secretId, $this->secretKey);
	}

	/*
	 * @type sign_method:string
	 * @param sign_method : only support sha1 and sha256
	 */
    public function set_sign_method($sign_method = 'sha1')
    {
        $this->cmq_client->set_sign_method($sign_method);
    }

    /* 设置访问的url

    @type host: string
    @param host: 访问的url，例如：http://cmq-queue-gz.api.tencentyun.com

    @type secretId: string
    @param secretId: 用户的secretId，腾讯云官网获取

    @type secretKey: string
    @param secretKey: 用户的secretKey，腾讯云官网获取

    @note: Exception
    :: CMQClientParameterException host格式错误
     */
    public function set_client($host, $secretId = null, $secretKey = null)
    {
        if ($secretId == null) {
            $secretId = $this->secretId;
        }
        if ($secretKey == null) {
            $secretKey = $this->secretKey;
        }
        $this->cmq_client = new CMQClient($host, $secretId, $secretKey);
    }

    /* 获取queue client

    @rtype: CMQClient object
    @return: 返回使用的CMQClient object
     */
    public function get_client()
    {
        return $this->cmq_client;
    }

    /* 获取Account的一个Queue对象

    @type queue_name: string
    @param queue_name: 队列名

    @rtype: Queue object
    @return: 返回该Account的一个Queue对象
     */
    public function get_queue($queue_name)
    {
        return new Queue($queue_name, $this->cmq_client);
    }

    /* 列出Account的队列

    @type searchWord: string
    @param searchWord: 队列名的前缀

    @type limit: int
    @param limit: list_queue最多返回的队列数

    @type offset: string
    @param offset: list_queue的起始位置，上次list_queue返回的next_offset

    @rtype: tuple
    @return: QueueURL的列表和下次list queue的起始位置; 如果所有queue都list出来，next_offset为"".
     */
    public function list_queue($searchWord = "", $limit = -1, $offset = "")
    {
        $params = array();
        if ($searchWord != "") {
            $params['searchWord'] = $searchWord;
        }
        if ($limit != -1) {
            $params['limit'] = $limit;
        }
        if ($offset != "") {
            $params['offset'] = $offset;
        }

        $ret_pkg = $this->cmq_client->list_queue($params);

        if ($offset == "") {
            $next_offset = count($ret_pkg['queueList']);
        } else {
            $next_offset = $offset + count($ret_pkg['queueList']);
        }
        if ($next_offset >= $ret_pkg['totalCount']) {
            $next_offset = "";
        }

        return array("totalCount" => $ret_pkg['totalCount'],
            "queueList" => $ret_pkg['queueList'], "next_offset" => $next_offset);
    }

    /* 列出Account的主题

    @type searchWord: string
    @param searchWord: 主题关键字

    @type limit: int
    @param limit: 最多返回的主题数目

    @type offset: string
    @param offset: list_topic的起始位置，上次list_topic返回的next_offset

    @rtype: tuple
    @return: TopicURL的列表和下次list topic的起始位置; 如果所有topic都list出来，next_offset为"".
     */
    public function list_topic($searchWord = "", $limit = -1, $offset = "")
    {
        $params = array();
        if ($searchWord != "") {
            $params['searchWord'] = $searchWord;
        }
        if ($limit != -1) {
            $params['limit'] = $limit;
        }
        if ($offset != "") {
            $params['offset'] = $offset;
        }

        $resp = $this->cmq_client->list_topic($params);

        if ($offset == "") {
            $next_offset = count($resp['topicList']);
        } else {
            $next_offset = $offset + count($resp['topicList']);
        }
        if ($next_offset >= $resp['totalCount']) {
            $next_offset = "";
        }

        return array("totalCoult" => $resp['totalCount'],
            "topicList" => $resp['topicList'],
            "next_offset" => $next_offset);
    }

    /* 获取Account的一个Topic对象

    @type topic_name: string
    @param queue_name:

    @rtype: Topic object
    @return: 返回该Account的一个Topic对象
     */
    public function get_topic($topic_name)
    {
        return new Topic($topic_name, $this->cmq_client);
    }

    /* 获取Account的一个Subscription对象

    @type topic_name: string
    @param queue_name:

    @type subscription_name :string
    @param subscription_name:

    @rtype: Subscription object
    @return: 返回该Account的一个Subscription对象
     */
    public function get_subscription($topic_name, $subscription_name)
    {
        return new \Subscription($topic_name, $subscription_name, $this->cmq_client);
    }

}