\Freyo\LaravelQueueCMQ\Queue\DriverAccount

<?php

namespace Freyo\LaravelQueueCMQ\Queue\Driver;

/*
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)
    {
        $this->host       = $host;
        $this->secretId   = $secretId;
        $this->secretKey  = $secretKey;
        $this->cmq_client = new CMQClient($host, $secretId, $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 = (int)$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 = (int)$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);
    }
}