Mercurial > hg > orthanc-stone
annotate Framework/Toolbox/OrthancApiClient.cpp @ 275:58e23e0dd86a am-2
renaming
| author | am@osimis.io |
|---|---|
| date | Fri, 24 Aug 2018 13:58:06 +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 } |