<?php
namespace App\Common\TencentMQ;

class Subscription
{
	private $topic_name;
	private $subscription_name;
	private $cmq_client;
	private $encoding;
	
	public function __construct($topic_name,$subscription_name,$cmq_client,$encoding = false){
		$this->topic_name = $topic_name;
		$this->subscription_name = $subscription_name;
		$this->cmq_client = $cmq_client;
		$this->encoding = $encoding;
	}
	public function set_encoding($encoding){
		$this->encoding = $encoding; 
	}
	
	/*
	 * create subscription
	 * @type subscription_meta :SubscriptionMeta
	 */
	public function create($subscription_meta){
		$params=array(
				'topicName' => $this->topic_name,
				'subscriptionName' => $this->subscription_name,
				'notifyStrategy' => $subscription_meta->NotifyStrategy,
				'notifyContentFormat' => $subscription_meta->NotifyContentFormat,
		);
		if ($subscription_meta->Endpoint  != ""){
			$params['endpoint'] = $subscription_meta->Endpoint;
		}
		if($subscription_meta->Protocol !=""){
			$params['protocol'] = $subscription_meta->Protocol;
		}

        if(! $subscription_meta->bindindKey != null && is_array($subscription_meta->bindindKey)  && !empty($subscription_meta->bindindKey)){
		$n = 1;
		    foreach ($subscription_meta->bindindKey as $tag)
	 	    {	
			    $key = 'bindindKey.' . $n;
			    $params[$key] = $tag;
			    $n += 1 ;
		    }
	    }
		
	    if(! $subscription_meta->FilterTag != null && is_array($subscription_meta->FilterTag)  && !empty($subscription_meta->FilterTag)){
		$n = 1;
		    foreach ($subscription_meta->FilterTag as $tag)
	 	    {	
			    $key = 'filterTag.' . $n;
			    $params[$key] = $tag;
			    $n += 1 ;
		    }
	    }
		$this->cmq_client->create_subscription($params);
	}
	
	/*
	 * delete subscription
	 */
	public function delete(){
		
		$params=array(
				'topicName' => $this->topic_name,
				'subscriptionName' => $this->subscription_name
		);
		
		$this->cmq_client->delete_subscription($params);
	}
	/*
	 * clear subscription tags 
	 */
	public function clearFilterTags(){
		
		$params=array(
				'topicName' => $this->topic_name,
				'subscriptionName' => $this->subscription_name
		);
		
		$this->cmq_client->clear_filterTags($params);
	}
	

	/*
	 * get attributes
	 * 
	 * @return subscription_meta :SubscriptionMeta
	 */
	public function get_attributes(){
		$params=array(
				'topicName' => $this->topic_name,
				'subscriptionName' => $this->subscription_name
		);
		
		$resp = $this->cmq_client->get_subscription_attributes($params);
		
		$subscription_meta = new SubscriptionMeta();
		$this->__resp2meta($subscription_meta, $resp);
		return $subscription_meta;
	}
	/*
	 * set attributes 
	 * @type subscription_meta : SubscriptionMeta
	 * 
	 */
	public function set_attributes($subscription_meta){
		$params = array(
				'topicName' => $this->topic_name,
				'subscriptionName' => $this->subscription_name
            );
        if ($subscription_meta->NotifyStrategy !=""){
            $params['notifyStrategy'] = $subscription_meta->NotifyStrategy;
        }

        if ($subscription_meta->NotifyContentFormat != ""){
            $params['notifyContentFormat']=$subscription_meta->NotifyContentFormat;
        }


		if ($subscription_meta->Endpoint  != ""){
			$params['endpoint'] = $subscription_meta->Endpoint;
		}
		if($subscription_meta->Protocol !=""){
			$params['protocol'] = $subscription_meta->Protocol;
		}

        if(! $subscription_meta->bindindKey != null && is_array($subscription_meta->bindindKey)  && !empty($subscription_meta->bindindKey)){
		$n = 1;
		    foreach ($subscription_meta->bindindKey as $tag)
	 	    {	
			    $key = 'bindindKey.' . $n;
			    $params[$key] = $tag;
			    $n += 1 ;
		    }
	    }
		
	    if(! $subscription_meta->FilterTag != null && is_array($subscription_meta->FilterTag)  && !empty($subscription_meta->FilterTag)){
		$n = 1;
		    foreach ($subscription_meta->FilterTag as $tag)
	 	    {	
			    $key = 'filterTag.' . $n;
			    $params[$key] = $tag;
			    $n += 1 ;
		    }
	    }

		$this->cmq_client->set_subscription_attributes($params);
		
	}
	
	protected  function __resp2meta($subscription_meta, $resp){
		if (isset($resp['endpoint'])) {
			$subscription_meta->Endpoint = $resp['endpoint'];
		}
		if (isset($resp['protocol'])) {
			$subscription_meta->Protocol = $resp['protocol'];
		}
		if (isset($resp['notifyStrategy'])) {
			$subscription_meta->NotifyStrategy = $resp['notifyStrategy'];
		}
		if (isset($resp['notifyContentFormat'])) {
			$subscription_meta->NotifyContentFormat = $resp['notifyContentFormat'];
		}

    	if( isset($resp['bindindKey'])){
			foreach ($resp['bindindKey'] as $tag){
				array_push($subscription_meta->bindindKey, $tag);
			}
		}
		
		if( isset($resp['filterTags'])){
			foreach ($resp['filterTags'] as $tag){
				array_push($subscription_meta->FilterTag, $tag);
			}
		}
		
	}
}

class SubscriptionMeta
{
	// default NotifyStrategy      BACKOFF_RETRY
	// default NotifyContentFormat JSON
	
	/* 订阅属性
	 @note: 可修改
	 :: Endpoint            推送消息地址
     :: Protocal            协议
     :: FilterTag           订阅 标签
     :: NotifyStrategy      重试策略
     :: NotifyContentFormat 推送消息格式
	 */
	public $Endpoint;
	public $Protocol;
	public $FilterTag;
	public $NotifyStrategy;
	public $NotifyContentFormat;
	

	public function __construct(){
		$this->Endpoint = "";
		$this->Protocol= "";
		$this->FilterTag = array();
		$this->NotifyStrategy = "BACKOFF_RETRY";
		$this->NotifyContentFormat = "JSON";
		$this->bindindKey = array();
	}

	public function __toString(){
		$info = array(
				"endpoint"  => $this->Endpoint,
				"protocol" => $this->Protocol,
				"filterTag" => $this->FilterTag,
				"notifyStrategy" => $this->NotifyStrategy,
				"notifyContentFormat" => $this->NotifyContentFormat,
				"bindingKey" => $this->bindindKey,
		);
		return json_encode($info);
	}
}