Mercurial > hg > orthanc-stone
annotate Framework/Toolbox/OrthancApiClient.cpp @ 291:87376a645ee1 am-2
renaming
author | am@osimis.io |
---|---|
date | Thu, 30 Aug 2018 17:06:22 +0200 |
parents | 46c5296d867e |
children | 3897f9f28cfa |
rev | line source |
---|---|
270 | 1 /** |
2 * Stone of Orthanc | |
3 * Copyright (C) 2012-2016 Sebastien Jodogne, Medical Physics | |
4 * Department, University Hospital of Liege, Belgium | |
5 * Copyright (C) 2017-2018 Osimis S.A., Belgium | |
6 * | |
7 * This program is free software: you can redistribute it and/or | |
8 * modify it under the terms of the GNU Affero General Public License | |
9 * as published by the Free Software Foundation, either version 3 of | |
10 * the License, or (at your option) any later version. | |
11 * | |
12 * This program is distributed in the hope that it will be useful, but | |
13 * WITHOUT ANY WARRANTY; without even the implied warranty of | |
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | |
15 * Affero General Public License for more details. | |
16 * | |
17 * You should have received a copy of the GNU Affero General Public License | |
18 * along with this program. If not, see <http://www.gnu.org/licenses/>. | |
19 **/ | |
20 | |
21 #include "OrthancApiClient.h" | |
22 | |
23 #include "MessagingToolbox.h" | |
24 #include <Core/OrthancException.h> | |
25 | |
26 namespace OrthancStone { | |
27 | |
28 struct OrthancApiClient::InternalGetJsonResponseReadyMessage : | |
29 public IMessage | |
30 { | |
31 OrthancApiClient::BaseRequest* request_; | |
32 Json::Value response_; | |
33 | |
34 InternalGetJsonResponseReadyMessage(OrthancApiClient::BaseRequest* request, | |
35 const Json::Value& response) | |
36 : IMessage(MessageType_OrthancApi_InternalGetJsonResponseReady), | |
37 request_(request), | |
38 response_(response) | |
39 { | |
40 } | |
41 | |
42 }; | |
43 | |
44 struct OrthancApiClient::InternalGetJsonResponseErrorMessage : | |
45 public IMessage | |
46 { | |
47 OrthancApiClient::BaseRequest* request_; | |
48 | |
49 InternalGetJsonResponseErrorMessage(OrthancApiClient::BaseRequest* request) | |
50 : IMessage(MessageType_OrthancApi_InternalGetJsonResponseError), | |
51 request_(request) | |
52 { | |
53 } | |
54 }; | |
55 | |
56 | |
57 // this class handles a single request to the OrthancApiClient. | |
58 // Once the response is ready, it will emit a message to the responseObserver | |
59 // the responseObserver must handle only that message (and not all messages from the OrthancApiClient) | |
60 class OrthancApiClient::BaseRequest: | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
61 // public IObserver, |
270 | 62 public IObservable, |
63 public Orthanc::IDynamicObject | |
64 { | |
65 public: | |
66 std::string uri_; | |
67 OrthancApiClient& orthanc_; | |
68 MessageType messageToEmitWhenResponseReady_; | |
69 OrthancApiClient::Mode mode_; | |
70 | |
71 public: | |
72 BaseRequest( | |
73 OrthancApiClient& orthanc, | |
74 IObserver& responseObserver, | |
75 const std::string& uri, | |
76 MessageType messageToEmitWhenResponseReady, | |
77 OrthancApiClient::Mode mode) | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
78 : |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
79 //IObserver(orthanc.broker_), |
270 | 80 IObservable(orthanc.broker_), |
81 uri_(uri), | |
82 orthanc_(orthanc), | |
83 messageToEmitWhenResponseReady_(messageToEmitWhenResponseReady), | |
84 mode_(mode) | |
85 { | |
86 // this object will emit only a single message, the one the final responseObserver is expecting | |
87 DeclareEmittableMessage(messageToEmitWhenResponseReady); | |
88 | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
89 // // this object is observing the OrthancApi so it must handle all messages |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
90 // DeclareHandledMessage(MessageType_OrthancApi_InternalGetJsonResponseReady); |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
91 // DeclareIgnoredMessage(MessageType_OrthancApi_InternalGetJsonResponseError); |
270 | 92 |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
93 //orthanc_.RegisterObserver(*this); |
270 | 94 this->RegisterObserver(responseObserver); |
95 } | |
96 virtual ~BaseRequest() {} | |
97 | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
98 // // mainly maps OrthancApi internal messages to a message that is expected by the responseObserver |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
99 // virtual void HandleMessage(IObservable& from, const IMessage& message) |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
100 // { |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
101 // switch (message.GetType()) |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
102 // { |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
103 // case MessageType_OrthancApi_InternalGetJsonResponseReady: |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
104 // { |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
105 // const OrthancApiClient::InternalGetJsonResponseReadyMessage& messageReceived = dynamic_cast<const OrthancApiClient::InternalGetJsonResponseReadyMessage&>(message); |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
106 // EmitMessage(OrthancApiClient::GetJsonResponseReadyMessage(messageToEmitWhenResponseReady_, messageReceived.request_->uri_, messageReceived.response_)); |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
107 // orthanc_.ReleaseRequest(messageReceived.request_); |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
108 // }; break; |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
109 // default: |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
110 // throw MessageNotDeclaredException(message.GetType()); |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
111 // } |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
112 // } |
270 | 113 |
114 }; | |
115 | |
116 | |
117 class OrthancApiClient::WebCallback : public IWebService::ICallback | |
118 { | |
119 private: | |
120 OrthancApiClient& that_; | |
121 | |
122 public: | |
123 WebCallback(MessageBroker& broker, OrthancApiClient& that) : | |
124 IWebService::ICallback(broker), | |
125 that_(that) | |
126 { | |
127 } | |
128 | |
129 virtual void OnHttpRequestSuccess(const std::string& uri, | |
130 const void* answer, | |
131 size_t answerSize, | |
132 Orthanc::IDynamicObject* payload) | |
133 { | |
134 OrthancApiClient::BaseRequest* request = dynamic_cast<OrthancApiClient::BaseRequest*>(payload); // the BaseRequests objects belongs to the OrthancApiClient and is deleted in ReleaseRequest when it has been "consumed" | |
135 | |
136 switch (request->mode_) | |
137 { | |
138 case OrthancApiClient::Mode_GetJson: | |
139 { | |
140 Json::Value response; | |
141 if (MessagingToolbox::ParseJson(response, answer, answerSize)) | |
142 { | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
143 request->EmitMessage(OrthancApiClient::GetJsonResponseReadyMessage(request->messageToEmitWhenResponseReady_, request->uri_, response)); |
270 | 144 } |
145 else | |
146 { | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
147 // OrthancApiClient::InternalGetJsonResponseErrorMessage msg(request); |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
148 // that_.EmitMessage(msg); |
270 | 149 } |
150 }; break; | |
151 | |
152 default: | |
153 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
154 } | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
155 that_.ReleaseRequest(request); |
270 | 156 } |
157 | |
158 virtual void OnHttpRequestError(const std::string& uri, | |
159 Orthanc::IDynamicObject* payload) | |
160 { | |
161 OrthancApiClient::BaseRequest* request = dynamic_cast<OrthancApiClient::BaseRequest*>(payload); // the BaseRequests objects belongs to the OrthancApiClient and is deleted in ReleaseRequest when it has been "consumed" | |
162 | |
163 switch (request->mode_) | |
164 { | |
165 case OrthancApiClient::Mode_GetJson: | |
166 { | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
167 // OrthancApiClient::InternalGetJsonResponseErrorMessage msg(request); |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
168 // that_.EmitMessage(msg); |
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
169 // TODO: the request shall send an error message |
270 | 170 }; break; |
171 | |
172 default: | |
173 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
174 } | |
271
46c5296d867e
OracleWebService and BasicSdlApplicationContext using the same global mutex
am@osimis.io
parents:
270
diff
changeset
|
175 that_.ReleaseRequest(request); |
270 | 176 } |
177 }; | |
178 | |
179 OrthancApiClient::OrthancApiClient(MessageBroker &broker, IWebService &orthanc) | |
180 : IObservable(broker), | |
181 orthanc_(orthanc), | |
182 webCallback_(new OrthancApiClient::WebCallback(broker, *this)) | |
183 { | |
184 DeclareEmittableMessage(MessageType_OrthancApi_InternalGetJsonResponseReady); | |
185 DeclareEmittableMessage(MessageType_OrthancApi_InternalGetJsonResponseError); | |
186 } | |
187 | |
188 void OrthancApiClient::ScheduleGetJsonRequest(IObserver &responseObserver, const std::string &uri, MessageType messageToEmitWhenResponseReady) | |
189 { | |
190 OrthancApiClient::BaseRequest* request = new OrthancApiClient::BaseRequest(*this, | |
191 responseObserver, | |
192 uri, | |
193 messageToEmitWhenResponseReady, | |
194 OrthancApiClient::Mode_GetJson); | |
195 orthanc_.ScheduleGetRequest(*webCallback_, uri, IWebService::Headers(), request); | |
196 requestsInProgress_.insert(request); | |
197 } | |
198 | |
199 void OrthancApiClient::ReleaseRequest(BaseRequest* request) | |
200 { | |
201 requestsInProgress_.erase(request); | |
202 delete request; | |
203 } | |
204 | |
205 } |