/*
 * 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 "TopicConfig.h"
#include <stdlib.h>
#include <sstream>
#include "PermName.h"

namespace rocketmq {
//<!***************************************************************************
int TopicConfig::DefaultReadQueueNums = 16;
int TopicConfig::DefaultWriteQueueNums = 16;
string TopicConfig::SEPARATOR = " ";

TopicConfig::TopicConfig()
    : m_topicName(""),
      m_readQueueNums(DefaultReadQueueNums),
      m_writeQueueNums(DefaultWriteQueueNums),
      m_perm(PermName::PERM_READ | PermName::PERM_WRITE),
      m_topicFilterType(SINGLE_TAG) {}

TopicConfig::TopicConfig(const string& topicName)
    : m_topicName(topicName),
      m_readQueueNums(DefaultReadQueueNums),
      m_writeQueueNums(DefaultWriteQueueNums),
      m_perm(PermName::PERM_READ | PermName::PERM_WRITE),
      m_topicFilterType(SINGLE_TAG) {}

TopicConfig::TopicConfig(const string& topicName, int readQueueNums,
                         int writeQueueNums, int perm)
    : m_topicName(topicName),
      m_readQueueNums(readQueueNums),
      m_writeQueueNums(writeQueueNums),
      m_perm(perm),
      m_topicFilterType(SINGLE_TAG) {}

TopicConfig::~TopicConfig() {}

string TopicConfig::encode() {
  stringstream ss;
  ss << m_topicName << SEPARATOR << m_readQueueNums << SEPARATOR
     << m_writeQueueNums << SEPARATOR << m_perm << SEPARATOR
     << m_topicFilterType;

  return ss.str();
}

bool TopicConfig::decode(const string& in) {
  stringstream ss(in);

  ss >> m_topicName;
  ss >> m_readQueueNums;
  ss >> m_writeQueueNums;
  ss >> m_perm;

  int type;
  ss >> type;
  m_topicFilterType = (TopicFilterType)type;

  return true;
}

const string& TopicConfig::getTopicName() { return m_topicName; }

void TopicConfig::setTopicName(const string& topicName) {
  m_topicName = topicName;
}

int TopicConfig::getReadQueueNums() { return m_readQueueNums; }

void TopicConfig::setReadQueueNums(int readQueueNums) {
  m_readQueueNums = readQueueNums;
}

int TopicConfig::getWriteQueueNums() { return m_writeQueueNums; }

void TopicConfig::setWriteQueueNums(int writeQueueNums) {
  m_writeQueueNums = writeQueueNums;
}

int TopicConfig::getPerm() { return m_perm; }

void TopicConfig::setPerm(int perm) { m_perm = perm; }

TopicFilterType TopicConfig::getTopicFilterType() { return m_topicFilterType; }

void TopicConfig::setTopicFilterType(TopicFilterType topicFilterType) {
  m_topicFilterType = topicFilterType;
}
//<!***************************************************************************
}  //<!end namespace;