StreamMessageParser.hpp

Go to the documentation of this file.

#pragma once
 
// standard
#include <memory>
 
// libraries
#include <XLink/XLinkPublicDefines.h>
 
// project
#include "depthai-shared/datatype/DatatypeEnum.hpp"
#include "depthai-shared/datatype/RawMessageGroup.hpp"
#include "depthai/pipeline/datatype/ADatatype.hpp"
 
// shared
#include "depthai-shared/datatype/RawBuffer.hpp"
 
// StreamPacket structure ->  || imgframepixels... , serialized_object, object_type, serialized_object_size ||
// object_type -> DataType(int), serialized_object_size -> int
 
namespace dai {
class StreamMessageParser {
   public:
    static std::shared_ptr<RawBuffer> parseMessage(streamPacketDesc_t* const packet);
    static std::shared_ptr<ADatatype> parseMessageToADatatype(streamPacketDesc_t* const packet);
    static std::shared_ptr<ADatatype> parseMessageToADatatype(streamPacketDesc_t* const packet, DatatypeEnum& type);
    static std::vector<std::uint8_t> serializeMessage(const std::shared_ptr<const RawBuffer>& data);
    static std::vector<std::uint8_t> serializeMessage(const RawBuffer& data);
    static std::vector<std::uint8_t> serializeMessage(const std::shared_ptr<const ADatatype>& data);
    static std::vector<std::uint8_t> serializeMessage(const ADatatype& data);
};
}  // namespace dai