mna_port.cpp

Go to the documentation of this file.

//=============================================================================================================
 
//=============================================================================================================
// INCLUDES
//=============================================================================================================
 
#include "mna_port.h"
 
//=============================================================================================================
// USED NAMESPACES
//=============================================================================================================
 
using namespace MNALIB;
 
//=============================================================================================================
// STATIC HELPERS
//=============================================================================================================
 
static QString dataKindToString(MnaDataKind kind)
{
    switch (kind) {
        case MnaDataKind::FiffRaw:
            return QStringLiteral("fiff_raw");
        case MnaDataKind::Forward:
            return QStringLiteral("forward");
        case MnaDataKind::Inverse:
            return QStringLiteral("inverse");
        case MnaDataKind::Covariance:
            return QStringLiteral("covariance");
        case MnaDataKind::SourceEstimate:
            return QStringLiteral("source_estimate");
        case MnaDataKind::Epochs:
            return QStringLiteral("epochs");
        case MnaDataKind::Evoked:
            return QStringLiteral("evoked");
        case MnaDataKind::Matrix:
            return QStringLiteral("matrix");
        case MnaDataKind::Volume:
            return QStringLiteral("volume");
        case MnaDataKind::Surface:
            return QStringLiteral("surface");
        case MnaDataKind::Bem:
            return QStringLiteral("bem");
        case MnaDataKind::Annotation:
            return QStringLiteral("annotation");
        case MnaDataKind::Label:
            return QStringLiteral("label");
        case MnaDataKind::RealTimeStream:
            return QStringLiteral("real_time_stream");
        case MnaDataKind::Custom:
            return QStringLiteral("custom");
    }
    return QStringLiteral("custom");
}
 
//=============================================================================================================
 
static MnaDataKind dataKindFromString(const QString& str)
{
    if (str == QLatin1String("fiff_raw"))
        return MnaDataKind::FiffRaw;
    if (str == QLatin1String("forward"))
        return MnaDataKind::Forward;
    if (str == QLatin1String("inverse"))
        return MnaDataKind::Inverse;
    if (str == QLatin1String("covariance"))
        return MnaDataKind::Covariance;
    if (str == QLatin1String("source_estimate"))
        return MnaDataKind::SourceEstimate;
    if (str == QLatin1String("epochs"))
        return MnaDataKind::Epochs;
    if (str == QLatin1String("evoked"))
        return MnaDataKind::Evoked;
    if (str == QLatin1String("matrix"))
        return MnaDataKind::Matrix;
    if (str == QLatin1String("volume"))
        return MnaDataKind::Volume;
    if (str == QLatin1String("surface"))
        return MnaDataKind::Surface;
    if (str == QLatin1String("bem"))
        return MnaDataKind::Bem;
    if (str == QLatin1String("annotation"))
        return MnaDataKind::Annotation;
    if (str == QLatin1String("label"))
        return MnaDataKind::Label;
    if (str == QLatin1String("real_time_stream"))
        return MnaDataKind::RealTimeStream;
    return MnaDataKind::Custom;
}
 
//=============================================================================================================
 
static QString portDirToString(MnaPortDir dir)
{
    switch (dir) {
        case MnaPortDir::Input:
            return QStringLiteral("input");
        case MnaPortDir::Output:
            return QStringLiteral("output");
    }
    return QStringLiteral("input");
}
 
//=============================================================================================================
 
static MnaPortDir portDirFromString(const QString& str)
{
    if (str == QLatin1String("output"))
        return MnaPortDir::Output;
    return MnaPortDir::Input;
}
 
//=============================================================================================================
// DEFINE MEMBER METHODS
//=============================================================================================================
 
QJsonObject MnaPort::toJson() const
{
    QJsonObject json = extras;
    json[QLatin1String("name")] = name;
    json[QLatin1String("data_kind")] = dataKindToString(dataKind);
    json[QLatin1String("direction")] = portDirToString(direction);
 
    if (!sourceNodeId.isEmpty())
        json[QLatin1String("source_node")] = sourceNodeId;
    if (!sourcePortName.isEmpty())
        json[QLatin1String("source_port")] = sourcePortName;
 
    if (!streamProtocol.isEmpty()) {
        json[QLatin1String("stream_protocol")] = streamProtocol;
        json[QLatin1String("stream_endpoint")] = streamEndpoint;
        json[QLatin1String("stream_buffer_ms")] = streamBufferMs;
    }
 
    if (!cachedResultPath.isEmpty())
        json[QLatin1String("cached_result")] = cachedResultPath;
    if (!cachedResultHash.isEmpty())
        json[QLatin1String("cached_result_hash")] = cachedResultHash;
 
    return json;
}
 
//=============================================================================================================
 
MnaPort MnaPort::fromJson(const QJsonObject& json)
{
    MnaPort port;
    port.name = json[QLatin1String("name")].toString();
    port.dataKind = dataKindFromString(json[QLatin1String("data_kind")].toString());
    port.direction = portDirFromString(json[QLatin1String("direction")].toString());
    port.sourceNodeId = json[QLatin1String("source_node")].toString();
    port.sourcePortName = json[QLatin1String("source_port")].toString();
    port.streamProtocol = json[QLatin1String("stream_protocol")].toString();
    port.streamEndpoint = json[QLatin1String("stream_endpoint")].toString();
    port.streamBufferMs = json[QLatin1String("stream_buffer_ms")].toInt(0);
    port.cachedResultPath = json[QLatin1String("cached_result")].toString();
    port.cachedResultHash = json[QLatin1String("cached_result_hash")].toString();
 
    static const QSet<QString> knownKeys = {
        QStringLiteral("name"), QStringLiteral("data_kind"),
        QStringLiteral("direction"), QStringLiteral("source_node"),
        QStringLiteral("source_port"), QStringLiteral("stream_protocol"),
        QStringLiteral("stream_endpoint"), QStringLiteral("stream_buffer_ms"),
        QStringLiteral("cached_result"), QStringLiteral("cached_result_hash")};
    for (auto it = json.constBegin(); it != json.constEnd(); ++it) {
        if (!knownKeys.contains(it.key()))
            port.extras.insert(it.key(), it.value());
    }
 
    return port;
}
 
//=============================================================================================================
 
QCborMap MnaPort::toCbor() const
{
    QCborMap cbor = QCborMap::fromJsonObject(extras);
    cbor[QLatin1String("name")] = name;
    cbor[QLatin1String("data_kind")] = dataKindToString(dataKind);
    cbor[QLatin1String("direction")] = portDirToString(direction);
 
    if (!sourceNodeId.isEmpty())
        cbor[QLatin1String("source_node")] = sourceNodeId;
    if (!sourcePortName.isEmpty())
        cbor[QLatin1String("source_port")] = sourcePortName;
    if (!streamProtocol.isEmpty()) {
        cbor[QLatin1String("stream_protocol")] = streamProtocol;
        cbor[QLatin1String("stream_endpoint")] = streamEndpoint;
        cbor[QLatin1String("stream_buffer_ms")] = streamBufferMs;
    }
    if (!cachedResultPath.isEmpty())
        cbor[QLatin1String("cached_result")] = cachedResultPath;
    if (!cachedResultHash.isEmpty())
        cbor[QLatin1String("cached_result_hash")] = cachedResultHash;
 
    return cbor;
}
 
//=============================================================================================================
 
MnaPort MnaPort::fromCbor(const QCborMap& cbor)
{
    MnaPort port;
    port.name = cbor[QLatin1String("name")].toString();
    port.dataKind = dataKindFromString(cbor[QLatin1String("data_kind")].toString());
    port.direction = portDirFromString(cbor[QLatin1String("direction")].toString());
    port.sourceNodeId = cbor[QLatin1String("source_node")].toString();
    port.sourcePortName = cbor[QLatin1String("source_port")].toString();
    port.streamProtocol = cbor[QLatin1String("stream_protocol")].toString();
    port.streamEndpoint = cbor[QLatin1String("stream_endpoint")].toString();
    port.streamBufferMs = cbor[QLatin1String("stream_buffer_ms")].toInteger();
    port.cachedResultPath = cbor[QLatin1String("cached_result")].toString();
    port.cachedResultHash = cbor[QLatin1String("cached_result_hash")].toString();
 
    static const QSet<QString> knownKeys = {
        QStringLiteral("name"), QStringLiteral("data_kind"),
        QStringLiteral("direction"), QStringLiteral("source_node"),
        QStringLiteral("source_port"), QStringLiteral("stream_protocol"),
        QStringLiteral("stream_endpoint"), QStringLiteral("stream_buffer_ms"),
        QStringLiteral("cached_result"), QStringLiteral("cached_result_hash")};
    QJsonObject cborJson = cbor.toJsonObject();
    for (auto it = cborJson.constBegin(); it != cborJson.constEnd(); ++it) {
        if (!knownKeys.contains(it.key()))
            port.extras.insert(it.key(), it.value());
    }
 
    return port;
}