Mercurial > hg > orthanc-stone

comparison OrthancStone/Resources/Graveyard/Deprecated/Platforms/Generic/OracleWebService.cpp @ 1512:244ad1e4e76a

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
reorganization of folders
author Sebastien Jodogne <s.jodogne@gmail.com>
date Tue, 07 Jul 2020 16:21:02 +0200
parents Resources/Graveyard/Deprecated/Platforms/Generic/OracleWebService.cpp@553084468225
children
comparison
equal deleted inserted replaced
1511:9dfeee74c1e6 1512:244ad1e4e76a
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-2020 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
22 #include "OracleWebService.h"
23 #include "../../Framework/Deprecated/Toolbox/IWebService.h"
24
25 namespace Deprecated
26 {
27
28
29 class OracleWebService::WebServiceCachedGetCommand : public IOracleCommand, OrthancStone::IObservable
30 {
31 protected:
32 std::unique_ptr<MessageHandler<IWebService::HttpRequestSuccessMessage> > successCallback_;
33 std::unique_ptr<Orthanc::IDynamicObject> payload_;
34 boost::shared_ptr<BaseWebService::CachedHttpRequestSuccessMessage> cachedMessage_;
35 OrthancStone::NativeStoneApplicationContext& context_;
36
37 public:
38 WebServiceCachedGetCommand(MessageHandler<IWebService::HttpRequestSuccessMessage>* successCallback, // takes ownership
39 boost::shared_ptr<BaseWebService::CachedHttpRequestSuccessMessage> cachedMessage,
40 Orthanc::IDynamicObject* payload /* takes ownership */,
41 OrthancStone::NativeStoneApplicationContext& context
42 ) :
43 successCallback_(successCallback),
44 payload_(payload),
45 cachedMessage_(cachedMessage),
46 context_(context)
47 {
48 }
49
50 virtual void Execute()
51 {
52 // nothing to do, everything is in the commit
53 }
54
55 virtual void Commit()
56 {
57 // We want to make sure that, i.e, the UpdateThread is not
58 // triggered while we are updating the "model" with the result of
59 // a WebServiceCommand
60 OrthancStone::NativeStoneApplicationContext::GlobalMutexLocker lock(context_);
61
62 IWebService::HttpRequestSuccessMessage successMessage(cachedMessage_->GetUri(),
63 cachedMessage_->GetAnswer(),
64 cachedMessage_->GetAnswerSize(),
65 cachedMessage_->GetAnswerHttpHeaders(),
66 payload_.get());
67
68 successCallback_->Apply(successMessage);
69 }
70 };
71
72 void OracleWebService::NotifyHttpSuccessLater(boost::shared_ptr<BaseWebService::CachedHttpRequestSuccessMessage> cachedMessage,
73 Orthanc::IDynamicObject* payload, // takes ownership
74 MessageHandler<IWebService::HttpRequestSuccessMessage>* successCallback)
75 {
76 oracle_.Submit(new WebServiceCachedGetCommand(successCallback, cachedMessage, payload, context_));
77 }
78
79
80 }