omflinkeddata.h

#ifndef OMFLINKEDDATA_H
#define OMFLINKEDDATA_H
/*
 * Fledge OSIsoft OMF interface to PI Server.
 *
 * Copyright (c) 2022-2025 Dianomic Systems
 *
 * Released under the Apache 2.0 Licence
 *
 * Author: Mark Riddoch
 */
 
#include <map>
#include <set>
#include <reading.h>
#include <OMFHint.h>
#include <omfbuffer.h>
#include <linkedlookup.h>
#include <omferror.h>
 
class OMFLinkedData
{
    public:
        OMFLinkedData(  std::unordered_map<std::string, LALookup> *linkedAssetState,
                const OMF_ENDPOINT PIServerEndpoint = ENDPOINT_CR) :
                    m_linkedAssetState(linkedAssetState),
                    m_endpoint(PIServerEndpoint),
                        m_doubleFormat("float64"),
                    m_integerFormat("int64")
                    {};
        bool        processReading(OMFBuffer& payload, bool needDelim, const Reading& reading,
                const std::string& DefaultAFLocation = std::string(),
                OMFHints *hints = NULL);
        void        buildLookup(const std::vector<Reading *>& reading);
        void        setSendFullStructure(const bool sendFullStructure) {m_sendFullStructure = sendFullStructure;};
        bool        flushContainers(HttpSender& sender, const std::string& path, std::vector<std::pair<std::string, std::string> >& header, OMFError& error, bool *isConnected);
        std::size_t clearLALookup(const std::vector<Reading *>& reading, std::size_t startIndex, std::size_t numReadings, std::string &delimiter);
        void        setDelimiter(const std::string &delimiter) {m_delimiter = delimiter;};
        void        setFormats(const std::string& doubleFormat, const std::string& integerFormat)
                {
                    m_doubleFormat = doubleFormat;
                    m_integerFormat = integerFormat;
                };
        void        setStaticData(std::vector<std::pair<std::string, std::string>> *staticData)
                {
                    m_staticData = staticData;
                };
 
    private:
        std::string getBaseType(Datapoint *dp, const std::string& format);
        void        sendContainer(std::string& link, Datapoint *dp, OMFHints * hints, const std::string& baseType);
        bool        isTypeSupported(DatapointValue& dataPoint)
                {
                    switch (dataPoint.getType())
                    {
                        case DatapointValue::DatapointTag::T_FLOAT:
                        case DatapointValue::DatapointTag::T_INTEGER:
                        case DatapointValue::DatapointTag::T_STRING:
                            return true;
                        default:
                            return false;
                    }
                };
 
    private:
        bool m_sendFullStructure;
        std::string m_delimiter;
 
        std::unordered_map<std::string, LALookup>   *m_linkedAssetState;
 
        OMF_ENDPOINT                m_endpoint;
 
        std::vector<std::pair<std::string, std::string>> *m_staticData;
 
 
        std::string             m_containers;
        std::set<std::string>   m_containerNames;
        std::string             m_doubleFormat;
        std::string             m_integerFormat;
 
};
#endif