ioPacs/include/ioPacs/SSeriesPusher.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 "ioPacs/config.hpp"

#include <fwCom/Slot.hpp>

#include <fwMemory/BufferObject.hpp>

#include <fwPacsIO/data/PacsConfiguration.hpp>
#include <fwPacsIO/SeriesEnquirer.hpp>

#include <fwServices/IController.hpp>

#include <fwThread/Worker.hpp>

#include <vector>

namespace fwMedData
{
class Series;
}

namespace ioPacs
{

class IOPACS_CLASS_API SSeriesPusher : public ::fwServices::IController
{
public:

    fwCoreServiceClassDefinitionsMacro( (SSeriesPusher)( ::fwServices::IController ) );

    typedef std::vector< CSPTR(::fwMedData::Series) > DicomSeriesContainerType;

    IOPACS_API static const ::fwCom::Slots::SlotKeyType s_DISPLAY_SLOT;
    typedef ::fwCom::Slot<void (const std::string&, bool)> DisplayMessageSlotType;

    typedef ::fwCom::Signal< void ( std::string ) > StartedProgressSignalType;
    typedef ::fwCom::Signal< void ( std::string, float, std::string ) > ProgressedSignalType;
    typedef ::fwCom::Signal< void ( std::string ) > StoppedProgressSignalType;

    static const ::fwCom::Signals::SignalKeyType s_PROGRESSED_SIG;
    static const ::fwCom::Signals::SignalKeyType s_STARTED_PROGRESS_SIG;
    static const ::fwCom::Signals::SignalKeyType s_STOPPED_PROGRESS_SIG;

    IOPACS_API SSeriesPusher() noexcept;

    IOPACS_API virtual ~SSeriesPusher() noexcept;

protected:

    IOPACS_API virtual void configuring() override;

    IOPACS_API virtual void starting() override;

    IOPACS_API virtual void stopping() override;

    IOPACS_API void updating() override;

    IOPACS_API void info(std::ostream& _sstream) override;

protected:

    IOPACS_API bool checkSeriesOnPACS();

    IOPACS_API void pushSeries();

    IOPACS_API void displayMessage(const std::string& message, bool error) const;

    IOPACS_API void progressCallback(const std::string& seriesInstanceUID, unsigned int instanceNumber,
                                     const std::string& filePath);

    DisplayMessageSlotType::sptr m_slotDisplayMessage;

    ::fwPacsIO::SeriesEnquirer::ProgressCallbackSlotType::sptr m_slotProgressCallback;

    ProgressedSignalType::sptr m_sigProgressed;

    StartedProgressSignalType::sptr m_sigStartedProgress;

    StoppedProgressSignalType::sptr m_sigStoppedProgress;

    std::string m_progressbarId;

    ::fwPacsIO::SeriesEnquirer::sptr m_seriesEnquirer;

    ::fwPacsIO::data::PacsConfiguration::csptr m_pacsConfiguration;

    ::fwThread::Worker::sptr m_pushSeriesWorker;

    bool m_isPushing;

    long unsigned int m_instanceCount;

};

} // namespace ioPacs