SeriesEnquirer.hpp

/* ***** BEGIN LICENSE BLOCK *****
 * FW4SPL - Copyright (C) IRCAD, 2009-2018.
 * Distributed under the terms of the GNU Lesser General Public License (LGPL) as
 * published by the Free Software Foundation.
 * ****** END LICENSE BLOCK ****** */

#pragma once

#include "fwPacsIO/config.hpp"

#include <fwCom/Slot.hpp>
#include <fwCom/Slots.hpp>

#include <fwCore/BaseObject.hpp>

#include <fwMemory/BufferObject.hpp>

#include <boost/filesystem/path.hpp>

#include <dcmtk/config/osconfig.h>
#include <dcmtk/dcmnet/scu.h>

namespace fwPacsIO
{

class FWPACSIO_CLASS_API SeriesEnquirer : public ::fwCore::BaseObject,
                                          protected DcmSCU
{

public:
    fwCoreClassDefinitionsWithFactoryMacro( (SeriesEnquirer)(::fwPacsIO::SeriesEnquirer),
                                            (()), new SeriesEnquirer);
    fwCoreAllowSharedFromThis();

    FWPACSIO_API static const ::fwCom::Slots::SlotKeyType s_PROGRESS_CALLBACK_SLOT;
    typedef ::fwCom::Slot<void (const std::string&, unsigned int, const std::string&)> ProgressCallbackSlotType;

    typedef std::vector< std::string > InstanceUIDContainer;

    typedef std::vector< ::boost::filesystem::path > InstancePathContainer;

    typedef std::vector< CSPTR(DcmDataset) > DatasetContainer;

    FWPACSIO_API SeriesEnquirer();

    FWPACSIO_API ~SeriesEnquirer();

    FWPACSIO_API void initialize(const std::string& applicationTitle,
                                 const std::string& peerHostName, unsigned short peerPort,
                                 const std::string& peerApplicationTitle,
                                 const std::string& moveApplicationTitle         = "",
                                 ProgressCallbackSlotType::sptr progressCallback = ProgressCallbackSlotType::sptr());

    FWPACSIO_API bool connect();

    FWPACSIO_API void disconnect();

    FWPACSIO_API bool pingPacs();

    FWPACSIO_API bool isConnectedToPacs() const;

    FWPACSIO_API OFList< QRResponse* > findSeriesByPatientName(const std::string& name);

    FWPACSIO_API OFList< QRResponse* > findSeriesByDate(const std::string& fromDate, const std::string& toDate);

    FWPACSIO_API OFList< QRResponse* > findSeriesByUID(const std::string& uid);

    FWPACSIO_API std::string findSOPInstanceUID(const std::string& seriesInstanceUID, unsigned int instanceNumber);

    FWPACSIO_API void pullSeriesUsingMoveRetrieveMethod(InstanceUIDContainer instanceUIDContainer);

    FWPACSIO_API void pullSeriesUsingGetRetrieveMethod(InstanceUIDContainer instanceUIDContainer);

    FWPACSIO_API void pullInstanceUsingMoveRetrieveMethod(const std::string& seriesInstanceUID,
                                                          const std::string& sopInstanceUID);

    FWPACSIO_API void pullInstanceUsingGetRetrieveMethod(const std::string& seriesInstanceUID,
                                                         const std::string& sopInstanceUID);

    FWPACSIO_API void pushSeries(const InstancePathContainer& pathContainer);

    FWPACSIO_API void pushSeries(const DatasetContainer& datasetContainer);

protected:

    FWPACSIO_API OFList< QRResponse* > sendFindRequest(DcmDataset dataset);

    FWPACSIO_API OFCondition sendMoveRequest(DcmDataset dataset);

    FWPACSIO_API OFCondition sendGetRequest(DcmDataset dataset);

    FWPACSIO_API OFCondition sendStoreRequest(const ::boost::filesystem::path& path);

    FWPACSIO_API OFCondition sendStoreRequest(const CSPTR(DcmDataset)& dataset);

    FWPACSIO_API virtual OFCondition handleMOVEResponse(
        const T_ASC_PresentationContextID presID, RetrieveResponse* response, OFBool& waitForNextResponse) override;

    FWPACSIO_API virtual OFCondition handleSTORERequest (
        const T_ASC_PresentationContextID presID, DcmDataset* incomingObject,
        OFBool& continueCGETSession, Uint16& cStoreReturnStatus) override;

    FWPACSIO_API Uint8 findUncompressedPC(const OFString& sopClass);

    std::string m_moveApplicationTitle;

    ::boost::filesystem::path m_path;

    ProgressCallbackSlotType::sptr m_progressCallback;

    unsigned int m_instanceIndex;
};

} // namespace fwPacsIO