/**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 */

#include "message_queue.h"

MessageQueue::MessageQueue(const rocketmq::MQMessageQueue& other){
    messageQueue = other;
}

void MessageQueue::__construct(Php::Parameters &params){
    std::string topic = params[0];
    std::string brokerName = params[1];
    int queueId = params[2];

    this->messageQueue = rocketmq::MQMessageQueue(topic, brokerName, queueId);
}

Php::Value MessageQueue::getTopic(){
    return this->messageQueue.getTopic();
}

void MessageQueue::setTopic(Php::Parameters &param){
    std::string topic = param[0];
    this->messageQueue.setTopic(topic);
}

Php::Value MessageQueue::getBrokerName(){
    return this->messageQueue.getBrokerName();
}

void MessageQueue::setBrokerName(Php::Parameters &param){
    std::string brokerName = param[0];
    this->messageQueue.setBrokerName(brokerName);
}

Php::Value MessageQueue::getQueueId() {
    return this->messageQueue.getQueueId();
}

void MessageQueue::setQueueId(Php::Parameters &param){
    return this->messageQueue.setQueueId(param[0]);
}

void registerMessageQueue(Php::Namespace &rocketMQNamespace){
    Php::Class<MessageQueue> messageQueueClass("MessageQueue");

    messageQueueClass.method<&MessageQueue::getTopic>("getTopic");
    messageQueueClass.method<&MessageQueue::setTopic>("setTopic", { Php::ByVal("topic", Php::Type::String), });

    messageQueueClass.method<&MessageQueue::getBrokerName>("getBrokerName");
    messageQueueClass.method<&MessageQueue::setBrokerName>("setBrokerName", { Php::ByVal("brokerName", Php::Type::String), });

    messageQueueClass.method<&MessageQueue::getQueueId>("getQueueId");
    messageQueueClass.method<&MessageQueue::setQueueId>("setQueueId", { Php::ByVal("queueId", Php::Type::String), });

    messageQueueClass.method<&MessageQueue::__construct>("__construct", {
            Php::ByVal("topic", Php::Type::String),
            Php::ByVal("brokerName", Php::Type::String),
            Php::ByVal("queueId", Php::Type::Numeric),
            });

    rocketMQNamespace.add(messageQueueClass);
}