1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
|
/************************************************************************
*
* Copyright (C) 2009-2025 IRCAD France
* Copyright (C) 2012-2020 IHU Strasbourg
*
* This file is part of Sight.
*
* Sight is free software: you can redistribute it and/or modify it under
* the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Sight is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with Sight. If not, see <https://www.gnu.org/licenses/>.
*
***********************************************************************/
#pragma once
#include <core/progress/has_monitors.hpp>
#include <data/series_set.hpp>
#include <data/vector.hpp>
#include <io/__/service/reader.hpp>
#include <io/dimse/data/pacs_configuration.hpp>
#include <io/dimse/series_retriever.hpp>
#include <service/controller.hpp>
#include <service/has_services.hpp>
#include <service/notifier.hpp>
namespace sight::module::io::dimse
{
/**
* @brief This service is used to pull series from a PACS.
*
* @section Signals Signals
* - \b progress_started(std::string, float, std::string): sent when the process is updated (bar id,percentage,message).
* - \b progress_stopped(std::string): sent when the process ended (bar id).
*
* @section XML XML Configuration
* @code{.xml}
<service type="sight::module::io::dimse::series_puller">
<in key="pacsConfig" uid="..." />
<in key="selectedSeries" uid="..." />
<inout key="seriesSet" uid="..." />
</service>
@endcode
*
* @subsection Input Input:
* - \b pacsConfig [sight::io::dimse::data::pacs_configuration]: PACS configuration data.
* - \b selectedSeries [sight::data::vector]: list of DICOM series to pull from the PACS.
*
* @subsection In-Out In-Out:
* - \b seriesSet [sight::data::series_set]: series set where to put the retrieved dicom series.
*/
class series_puller final : public service::controller,
public service::has_services,
private service::notifier,
public core::progress::has_monitors
{
public:
/// Generates default methods as New, dynamicCast, ...
SIGHT_DECLARE_SERVICE(series_puller, sight::service::controller);
/// Creates the service and slots.
series_puller() noexcept;
/// Destroys the service.
~series_puller() noexcept override = default;
protected:
/// Configures the service.
void configuring() override;
/// Creates the DICOM reader.
void starting() override;
/// Stops the DICOM reader.
void stopping() override;
/// Pulls series.
void updating() override;
private:
/**
* @brief Proposals to connect service slots to associated object signals.
* @return A map of each proposed connection.
*
* Connects data::series_set::REMOVED_OBJECTS_SIG of s_SERIES_SET_INOUT to REMOVE_SERIES_SLOT (removeSeries)
*/
connections_t auto_connections() const override;
using dicom_series_container_t = data::series_set::container_t;
using read_dicom_slot_t = core::com::slot<void (dicom_series_container_t)>;
using progress_started_signal_t = core::com::signal<void ()>;
using progress_stopped_signal_t = core::com::signal<void ()>;
/// Pulls series from the PACS.
void pull_series();
/**
* @brief Reads local series.
* @param _selected_series DICOM series that must be read.
*/
void read_local_series(dicom_series_container_t _selected_series);
/**
* @brief Stores instance callback.
* @param _series_instance_uid series instance UID.
* @param _instance_number instance number.
* @param _file_path file path.
*/
void store_instance_callback(
const std::string& _series_instance_uid,
unsigned _instance_number,
const std::string& _file_path
);
///SLOT: removes series from m_localSeries, when deleted in a gui selector for instance.
void remove_series(data::series_set::container_t _removed_series);
/// Contains the series_set where the DICOM reader sets its output.
data::series_set::sptr m_series_set {nullptr};
/// Contains the signal emitted when the progress bar is started.
progress_started_signal_t::sptr m_sig_progress_started {nullptr};
/// Contains the signal emitted when the progress bar is stopped.
progress_stopped_signal_t::sptr m_sig_progress_stopped {nullptr};
/// Stores local series.
std::set<std::string> m_local_series;
/// Defines the total number of instances that must be downloaded.
std::size_t m_instance_count {0};
/// Stores a map of DICOM series being pulled.
std::map<std::string, data::series::wptr> m_pulling_dicom_series_map;
data::ptr<sight::io::dimse::data::pacs_configuration, data::access::in> m_config {this, "pacsConfig"};
data::ptr<sight::data::vector, data::access::in> m_selected_series {this, "selectedSeries"};
static constexpr std::string_view SERIES_SET_INOUT = "series_set";
data::ptr<sight::data::series_set, data::access::inout> m_dest_series_set {this, SERIES_SET_INOUT};
};
} // namespace sight::module::io::dimse.
|
