Mercurial > hg > orthanc-stone

comparison Platforms/Generic/OracleWebService.cpp @ 434:3a8bcc45c221 am-vsol-upgrade

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
moved the HTTP cache from OrthancApiClient to BaseWebService (not implemented yet in WASM)
author am@osimis.io
date Mon, 03 Dec 2018 18:03:30 +0100
parents
children 4f2416d519b4
comparison
equal deleted inserted replaced
433:8999823db8b8 434:3a8bcc45c221
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
22 #include "OracleWebService.h"
23 #include "../../Framework/Toolbox/IWebService.h"
24
25 namespace OrthancStone
26 {
27
28
29 class OracleWebService::WebServiceCachedGetCommand : public IOracleCommand, IObservable
30 {
31 protected:
32 std::auto_ptr<MessageHandler<IWebService::HttpRequestSuccessMessage> > successCallback_;
33 std::auto_ptr<Orthanc::IDynamicObject> payload_;
34 boost::shared_ptr<BaseWebService::CachedHttpRequestSuccessMessage> cachedMessage_;
35 NativeStoneApplicationContext& context_;
36
37 public:
38 WebServiceCachedGetCommand(MessageBroker& broker,
39 MessageHandler<IWebService::HttpRequestSuccessMessage>* successCallback, // takes ownership
40 boost::shared_ptr<BaseWebService::CachedHttpRequestSuccessMessage> cachedMessage,
41 Orthanc::IDynamicObject* payload /* takes ownership */,
42 NativeStoneApplicationContext& context
43 ) :
44 IObservable(broker),
45 successCallback_(successCallback),
46 payload_(payload),
47 cachedMessage_(cachedMessage),
48 context_(context)
49 {
50 }
51
52 virtual void Execute()
53 {
54 // nothing to do, everything is in the commit
55 }
56
57 virtual void Commit()
58 {
59 // We want to make sure that, i.e, the UpdateThread is not
60 // triggered while we are updating the "model" with the result of
61 // a WebServiceCommand
62 NativeStoneApplicationContext::GlobalMutexLocker lock(context_);
63
64 IWebService::HttpRequestSuccessMessage successMessage(cachedMessage_->GetUri(),
65 cachedMessage_->GetAnswer(),
66 cachedMessage_->GetAnswerSize(),
67 cachedMessage_->GetAnswerHttpHeaders(),
68 payload_.get());
69
70 successCallback_->Apply(successMessage);
71 }
72 };
73
74 void OracleWebService::NotifyHttpSuccessLater(boost::shared_ptr<BaseWebService::CachedHttpRequestSuccessMessage> cachedMessage,
75 Orthanc::IDynamicObject* payload, // takes ownership
76 MessageHandler<IWebService::HttpRequestSuccessMessage>* successCallback)
77 {
78 oracle_.Submit(new WebServiceCachedGetCommand(GetBroker(), successCallback, cachedMessage, payload, context_));
79 }
80
81
82 }