/********************************************************************************
 * Copyright (C) 2014-2018 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
 *                                                                              *
 *              This software is distributed under the terms of the             *
 *              GNU Lesser General Public Licence (LGPL) version 3,             *
 *                  copied verbatim in the file "LICENSE"                       *
 ********************************************************************************/

#ifndef FAIR_MQ_TRANSPORTS_H
#define FAIR_MQ_TRANSPORTS_H

#include <fairmq/tools/Strings.h>

#include <memory>
#include <stdexcept>
#include <string>
#include <unordered_map>

namespace fair::mq
{

enum class Transport
{
    DEFAULT,
    ZMQ,
    SHM,
    OFI
};

struct TransportError : std::runtime_error { using std::runtime_error::runtime_error; };

} // namespace fair::mq

namespace fair::mq
{

static std::unordered_map<std::string, Transport> TransportTypes {
    { "default", Transport::DEFAULT },
    { "zeromq", Transport::ZMQ },
    { "shmem", Transport::SHM },
    { "ofi", Transport::OFI }
};

static std::unordered_map<Transport, std::string> TransportNames {
    { Transport::DEFAULT, "default" },
    { Transport::ZMQ, "zeromq" },
    { Transport::SHM, "shmem" },
    { Transport::OFI, "ofi" }
};

inline std::string TransportName(Transport transport)
{
    return TransportNames[transport];
}

inline Transport TransportType(const std::string& transport)
try {
    return TransportTypes.at(transport);
} catch (std::out_of_range&) {
    throw TransportError(tools::ToString("Unknown transport provided: ", transport));
}

} // namespace fair::mq

#endif /* FAIR_MQ_TRANSPORTS_H */