/*

* 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.

*/

#ifndef ROCKETMQ_MESSAGE_MESSAGEDECODER_H_

#define ROCKETMQ_MESSAGE_MESSAGEDECODER_H_

#ifndef WIN32

#include <sys/socket.h> // sockaddr

#else

#include <Winsock2.h>

#endif

#include "ByteBuffer.hpp"

#include "MQMessageExt.h"

#include "MessageId.h"

namespace rocketmq {

class MessageDecoder {

public:

static std::string createMessageId(const struct sockaddr* sa, int64_t offset);

static MessageId decodeMessageId(const std::string& msgId);

static MessageExtPtr clientDecode(ByteBuffer& byteBuffer, bool readBody);

static MessageExtPtr decode(ByteBuffer& byteBuffer);

static MessageExtPtr decode(ByteBuffer& byteBuffer, bool readBody);

static MessageExtPtr decode(ByteBuffer& byteBuffer, bool readBody, bool deCompressBody, bool isClient);

static std::vector<MessageExtPtr> decodes(ByteBuffer& byteBuffer);

static std::vector<MessageExtPtr> decodes(ByteBuffer& byteBuffer, bool readBody);

static std::string messageProperties2String(const std::map<std::string, std::string>& properties);

static std::map<std::string, std::string> string2messageProperties(const std::string& properties);

static std::string encodeMessage(Message& message);

static std::string encodeMessages(std::vector<MessagePtr>& messages);

};

} // namespace rocketmq

#endif // ROCKETMQ_MESSAGE_MESSAGEDECODER_H_