ZMQMessageHelper.h

/**************************************************************************
 * basf2 (Belle II Analysis Software Framework)                           *
 * Author: The Belle II Collaboration                                     *
 *                                                                        *
 * See git log for contributors and copyright holders.                    *
 * This file is licensed under LGPL-3.0, see LICENSE.md.                  *
 **************************************************************************/
#pragma once
 
#include <framework/dataobjects/EventMetaData.h>
#include <framework/pcore/zmq/messages/ZMQDefinitions.h>
#include <framework/pcore/zmq/utils/EventMetaDataSerialization.h>
#include <framework/pcore/EvtMessage.h>
#include <framework/datastore/StoreObjPtr.h>
#include <zmq.hpp>
#include <string>
#include <memory>
 
namespace Belle2 {
  class ZMQMessageHelper {
  public:
    static zmq::message_t createZMQMessage(zmq::message_t message)
    {
      return message;
    }
 
    static zmq::message_t createZMQMessage(const EMessageTypes& c)
    {
      return createZMQMessage(std::string(1, static_cast<char>(c)));
    }
 
    static zmq::message_t createZMQMessage(const std::string& s)
    {
      return zmq::message_t(s.c_str(), s.length());
    }
 
    static zmq::message_t createZMQMessage(const int i)
    {
      return createZMQMessage(std::to_string(i));
    }
 
    static zmq::message_t createZMQMessage(const StoreObjPtr<EventMetaData>& evtMetaData)
    {
      const auto& message = EventMetaDataSerialization::serialize(*evtMetaData);
      return zmq::message_t(message.c_str(), message.length());
    }
 
    static zmq::message_t createZMQMessage(const std::unique_ptr<EvtMessage>& evtMessage)
    {
      // TODO: here are the messages copied
      return zmq::message_t(evtMessage->buffer(), evtMessage->size());
    }
 
  };
}