EtpHdfProxy.h

/*-----------------------------------------------------------------------
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.  See the NOTICE file
distributed with this work for additional information
regarding copyright ownership.  The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"; you may not use this file except in compliance
with the License.  You may obtain a copy of the License at
 
  http://www.apache.org/licenses/LICENSE-2.0
 
Unless required by applicable law or agreed to in writing,
software distributed under the License is distributed on an
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express or implied.  See the License for the
specific language governing permissions and limitations
under the License.
-----------------------------------------------------------------------*/
#pragma once
 
#include "../common/HdfProxyFactory.h"
 
#include "DataArrayBlockingSession.h"
 
namespace ETP_NS
{
    class DLL_IMPORT_OR_EXPORT EtpHdfProxy : public EML2_NS::AbstractHdfProxy
    {
    private:
        std::shared_ptr<DataArrayBlockingSession> session;
        unsigned int compressionLevel;
 
        std::string getUri() const;
 
    public:
 
        EtpHdfProxy(COMMON_NS::DataObjectRepository * repo, const std::string & guid, const std::string & title, const std::string & packageDirAbsolutePath, const std::string & externalFilePath, COMMON_NS::DataObjectRepository::openingMode hdfPermissionAccess) :
            EML2_NS::AbstractHdfProxy(packageDirAbsolutePath, externalFilePath, hdfPermissionAccess) {
            initGsoapProxy(repo, guid, title, 20);
        }
 
        EtpHdfProxy(gsoap_resqml2_0_1::_eml20__EpcExternalPartReference* fromGsoap) :
            EML2_NS::AbstractHdfProxy(fromGsoap), session(nullptr), compressionLevel(0) {}
 
        EtpHdfProxy(gsoap_eml2_1::_eml21__EpcExternalPartReference* fromGsoap) :
            EML2_NS::AbstractHdfProxy(fromGsoap), session(nullptr), compressionLevel(0) {}
 
        EtpHdfProxy(gsoap_resqml2_0_1::eml20__DataObjectReference* partialObject) :
            EML2_NS::AbstractHdfProxy(partialObject), session(nullptr), compressionLevel(0) {}
 
        EtpHdfProxy(const COMMON_NS::DataObjectReference& dor) :
            EML2_NS::AbstractHdfProxy(dor), session(nullptr), compressionLevel(0) {}
 
 
        ~EtpHdfProxy() = default;
 
        std::shared_ptr<DataArrayBlockingSession> getSession() { return session; }
        void setSession(boost::asio::io_context& ioc, const std::string & host, const std::string & port, const std::string & target);
 
        void open();
 
        bool isOpened() const { return session != nullptr && !session->isWebSocketSessionClosed();  }
 
        void close() { session->close(); }
 
        /*
        * Get the used (native) datatype in a dataset
        */
        COMMON_NS::AbstractObject::hdfDatatypeEnum getHdfDatatypeInDataset(const std::string & groupName);
 
        int getHdfDatatypeClassInDataset(const std::string & datasetName);
 
        void writeItemizedListOfList(const std::string & groupName,
            const std::string & name,
            hdf5_hid_t cumulativeLengthDatatype,
            const void * cumulativeLength,
            unsigned long long cumulativeLengthSize,
            hdf5_hid_t elementsDatatype,
            const void * elements,
            unsigned long long elementsSize);
 
        unsigned int getDimensionCount(const std::string & datasetName);
 
        std::vector<unsigned long long> getElementCountPerDimension(const std::string & datasetName);
 
        signed long long getElementCount(const std::string & datasetName);
 
        void setCompressionLevel(unsigned int newCompressionLevel) { if (newCompressionLevel > 9) compressionLevel = 9; else compressionLevel = newCompressionLevel; }
 
        void writeArrayNdOfFloatValues(const std::string & groupName,
            const std::string & name,
            const float * floatValues,
            const unsigned long long * numValuesInEachDimension,
            unsigned int numDimensions);
 
        void writeArrayNdOfDoubleValues(const std::string & groupName,
            const std::string & name,
            const double * dblValues,
            const unsigned long long * numValuesInEachDimension,
            unsigned int numDimensions);
 
        void writeArrayNdOfCharValues(const std::string & groupName,
            const std::string & name,
            const char * intValues,
            const unsigned long long * numValuesInEachDimension,
            unsigned int numDimensions);
 
        void writeArrayNdOfIntValues(const std::string & groupName,
            const std::string & name,
            const int * intValues,
            const unsigned long long * numValuesInEachDimension,
            unsigned int numDimensions);
 
        void writeArrayNdOfInt64Values(const std::string & groupName,
            const std::string & name,
            const int64_t * values,
            const unsigned long long * numValuesInEachDimension,
            unsigned int numDimensions);
 
        void writeArrayNdOfUInt64Values(const std::string & groupName,
            const std::string & name,
            const uint64_t * values,
            const unsigned long long * numValuesInEachDimension,
            unsigned int numDimensions);
 
        void writeArrayNd(const std::string & groupName,
            const std::string & name,
            hdf5_hid_t datatype,
            const void * values,
            const unsigned long long * numValuesInEachDimension,
            unsigned int numDimensions);
 
        void createArrayNd(
            const std::string& groupName,
            const std::string& name,
            hdf5_hid_t datatype,
            const unsigned long long* numValuesInEachDimension,
            unsigned int numDimensions
        );
 
        void writeArrayNdSlab(
            const std::string& groupName,
            const std::string& name,
            hdf5_hid_t datatype,
            const void* values,
            const unsigned long long* numValuesInEachDimension,
            const unsigned long long* offsetValuesInEachDimension,
            unsigned int numDimensions
        );
 
        void writeGroupAttributes(const std::string & groupName,
            const std::vector<std::string> & attributeNames,
            const std::vector<std::string> & values);
 
        void writeGroupAttribute(const std::string & groupName,
            const std::string & attributeName,
            const std::vector<std::string> & values);
 
        void writeGroupAttributes(const std::string & groupName,
            const std::vector<std::string> & attributeNames,
            const std::vector<double> & values);
 
        void writeGroupAttributes(const std::string & groupName,
            const std::vector<std::string> & attributeNames,
            const std::vector<int> & values);
 
        void writeDatasetAttributes(const std::string & datasetName,
            const std::vector<std::string> & attributeNames,
            const std::vector<std::string> & values);
 
        void writeDatasetAttribute(const std::string & datasetName,
            const std::string & attributeName,
            const std::vector<std::string> & values);
 
        void writeDatasetAttributes(const std::string & datasetName,
            const std::vector<std::string> & attributeNames,
            const std::vector<double> & values);
 
        void writeDatasetAttributes(const std::string & datasetName,
            const std::vector<std::string> & attributeNames,
            const std::vector<int> & values);
 
        std::string readStringAttribute(const std::string & obj_name,
            const std::string & attr_name) const;
 
        std::vector<std::string> readStringArrayAttribute(const std::string & obj_name,
            const std::string & attr_name) const;
 
        double readDoubleAttribute(const std::string & obj_name,
            const std::string & attr_name) const;
 
        int64_t readLongAttribute(const std::string & obj_name,
            const std::string & attr_name) const;
 
        void readArrayNdOfDoubleValues(const std::string & datasetName, double* values);
 
        void readArrayNdOfDoubleValues(
            const std::string & datasetName,
            double* values,
            unsigned long long const * numValuesInEachDimension,
            unsigned long long const * offsetInEachDimension,
            unsigned int numDimensions
          );
 
        void readArrayNdOfDoubleValues(
            const std::string & datasetName, double* values,
            unsigned long long const * blockCountPerDimension,
            unsigned long long const * offsetInEachDimension,
            unsigned long long const * strideInEachDimension,
            unsigned long long const * blockSizeInEachDimension,
            unsigned int numDimensions);
 
        void selectArrayNdOfValues(
            const std::string & datasetName,
            unsigned long long const * blockCountPerDimension,
            unsigned long long const * offsetInEachDimension,
            unsigned long long const * strideInEachDimension,
            unsigned long long const * blockSizeInEachDimension,
            unsigned int numDimensions,
            bool newSelection,
            hdf5_hid_t & dataset,
            hdf5_hid_t & filespace);
 
        void readArrayNdOfDoubleValues(
            hdf5_hid_t dataset,
            hdf5_hid_t filespace,
            void* values,
            unsigned long long slabSize);
 
        void readArrayNdOfFloatValues(const std::string & datasetName, float* values);
 
        void readArrayNdOfFloatValues(
            const std::string & datasetName,
            float* values,
            unsigned long long const * numValuesInEachDimension,
            unsigned long long const * offsetInEachDimension,
            unsigned int numDimensions
        );
 
        void readArrayNdOfInt64Values(const std::string & datasetName, int64_t* values);
 
        void readArrayNdOfInt64Values(
            const std::string & datasetName,
            int64_t* values,
            unsigned long long const * numValuesInEachDimension,
            unsigned long long const * offsetInEachDimension,
            unsigned int numDimensions
        );
 
        void readArrayNdOfUInt64Values(const std::string & datasetName, uint64_t* values);
 
        void readArrayNdOfIntValues(const std::string & datasetName, int* values);
 
        void readArrayNdOfIntValues(
            const std::string & datasetName,
            int* values,
            unsigned long long const * numValuesInEachDimension,
            unsigned long long const * offsetInEachDimension,
            unsigned int numDimensions
        );
 
        void readArrayNdOfUIntValues(const std::string & datasetName, unsigned int* values);
 
        void readArrayNdOfShortValues(const std::string & datasetName, short* values);
 
        void readArrayNdOfUShortValues(const std::string & datasetName, unsigned short* values);
 
        void readArrayNdOfCharValues(const std::string & datasetName, char* values);
 
        void readArrayNdOfUCharValues(const std::string & datasetName, unsigned char* values);
 
        std::vector<unsigned long long> readArrayDimensions(const std::string & datasetName);
 
        bool exist(const std::string & absolutePathInHdfFile) const;
 
        bool isCompressed(const std::string & datasetName);
 
        static const char* XML_NS;
 
        std::string getXmlNamespace() const { return XML_NS; }
    };
 
    class DLL_IMPORT_OR_EXPORT EtpHdfProxyFactory : public COMMON_NS::HdfProxyFactory
    {
    public:
        EML2_NS::AbstractHdfProxy* make(gsoap_resqml2_0_1::eml20__DataObjectReference* partialObject) {
            return new EtpHdfProxy(partialObject);
        }
        EML2_NS::AbstractHdfProxy* make(const COMMON_NS::DataObjectReference& dor) {
            return new EtpHdfProxy(dor);
        }
 
        EML2_NS::AbstractHdfProxy* make(gsoap_resqml2_0_1::_eml20__EpcExternalPartReference* fromGsoap) {
            return new EtpHdfProxy(fromGsoap);
        }
 
        EML2_NS::AbstractHdfProxy* make(COMMON_NS::DataObjectRepository * repo, const std::string & guid, const std::string & title,
            const std::string & packageDirAbsolutePath, const std::string & externalFilePath,
            COMMON_NS::DataObjectRepository::openingMode hdfPermissionAccess = COMMON_NS::DataObjectRepository::openingMode::READ_ONLY) {
            return new EtpHdfProxy(repo, guid, title, packageDirAbsolutePath, externalFilePath, hdfPermissionAccess);
        }
    };
}