Mercurial > hg > orthanc-databases
annotate Framework/Plugins/DatabaseBackendAdapterV4.cpp @ 380:cb91096fef06 db-protobuf
implemented full protobuf api
| author | Sebastien Jodogne <s.jodogne@gmail.com> |
|---|---|
| date | Thu, 30 Mar 2023 17:08:00 +0200 |
| parents | 33b2aaffdd6c |
| children | 97f12bcd1826 |
| rev | line source |
|---|---|
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1 /** |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
2 * Orthanc - A Lightweight, RESTful DICOM Store |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
3 * Copyright (C) 2012-2016 Sebastien Jodogne, Medical Physics |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
4 * Department, University Hospital of Liege, Belgium |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
5 * Copyright (C) 2017-2022 Osimis S.A., Belgium |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
6 * Copyright (C) 2021-2022 Sebastien Jodogne, ICTEAM UCLouvain, Belgium |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
7 * |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
8 * This program is free software: you can redistribute it and/or |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
9 * modify it under the terms of the GNU Affero General Public License |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
10 * as published by the Free Software Foundation, either version 3 of |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
11 * the License, or (at your option) any later version. |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
12 * |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
13 * This program is distributed in the hope that it will be useful, but |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
14 * WITHOUT ANY WARRANTY; without even the implied warranty of |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
16 * Affero General Public License for more details. |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
17 * |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
18 * You should have received a copy of the GNU Affero General Public License |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
19 * along with this program. If not, see <http://www.gnu.org/licenses/>. |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
20 **/ |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
21 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
22 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
23 #include "DatabaseBackendAdapterV4.h" |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
24 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
25 #if defined(ORTHANC_PLUGINS_VERSION_IS_ABOVE) // Macro introduced in Orthanc 1.3.1 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
26 # if ORTHANC_PLUGINS_VERSION_IS_ABOVE(1, 12, 0) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
27 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
28 #include "IndexConnectionsPool.h" |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
29 |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
30 #include <OrthancDatabasePlugin.pb.h> // Include protobuf messages |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
31 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
32 #include <Logging.h> |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
33 #include <OrthancException.h> |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
34 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
35 #include <stdexcept> |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
36 #include <list> |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
37 #include <string> |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
38 #include <cassert> |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
39 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
40 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
41 #define ORTHANC_PLUGINS_DATABASE_CATCH(context) \ |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
42 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
43 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
44 namespace OrthancDatabases |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
45 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
46 static bool isBackendInUse_ = false; // Only for sanity checks |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
47 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
48 |
| 376 | 49 static Orthanc::DatabasePluginMessages::ResourceType Convert(OrthancPluginResourceType resourceType) |
| 50 { | |
| 51 switch (resourceType) | |
| 52 { | |
| 53 case OrthancPluginResourceType_Patient: | |
| 54 return Orthanc::DatabasePluginMessages::RESOURCE_PATIENT; | |
| 55 | |
| 56 case OrthancPluginResourceType_Study: | |
| 57 return Orthanc::DatabasePluginMessages::RESOURCE_STUDY; | |
| 58 | |
| 59 case OrthancPluginResourceType_Series: | |
| 60 return Orthanc::DatabasePluginMessages::RESOURCE_SERIES; | |
| 61 | |
| 62 case OrthancPluginResourceType_Instance: | |
| 63 return Orthanc::DatabasePluginMessages::RESOURCE_INSTANCE; | |
| 64 | |
| 65 default: | |
| 66 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); | |
| 67 } | |
| 68 } | |
| 69 | |
| 70 | |
| 71 static OrthancPluginResourceType Convert(Orthanc::DatabasePluginMessages::ResourceType resourceType) | |
| 72 { | |
| 73 switch (resourceType) | |
| 74 { | |
| 75 case Orthanc::DatabasePluginMessages::RESOURCE_PATIENT: | |
| 76 return OrthancPluginResourceType_Patient; | |
| 77 | |
| 78 case Orthanc::DatabasePluginMessages::RESOURCE_STUDY: | |
| 79 return OrthancPluginResourceType_Study; | |
| 80 | |
| 81 case Orthanc::DatabasePluginMessages::RESOURCE_SERIES: | |
| 82 return OrthancPluginResourceType_Series; | |
| 83 | |
| 84 case Orthanc::DatabasePluginMessages::RESOURCE_INSTANCE: | |
| 85 return OrthancPluginResourceType_Instance; | |
| 86 | |
| 87 default: | |
| 88 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); | |
| 89 } | |
| 90 } | |
| 91 | |
| 92 | |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
93 class Output : public IDatabaseBackendOutput |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
94 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
95 private: |
| 377 | 96 Orthanc::DatabasePluginMessages::DeleteAttachment::Response* deleteAttachment_; |
| 97 Orthanc::DatabasePluginMessages::DeleteResource::Response* deleteResource_; | |
| 98 Orthanc::DatabasePluginMessages::GetChanges::Response* getChanges_; | |
| 99 Orthanc::DatabasePluginMessages::GetExportedResources::Response* getExportedResources_; | |
| 100 Orthanc::DatabasePluginMessages::GetLastChange::Response* getLastChange_; | |
| 101 Orthanc::DatabasePluginMessages::GetLastExportedResource::Response* getLastExportedResource_; | |
| 102 Orthanc::DatabasePluginMessages::GetMainDicomTags::Response* getMainDicomTags_; | |
| 379 | 103 Orthanc::DatabasePluginMessages::LookupAttachment::Response* lookupAttachment_; |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
104 Orthanc::DatabasePluginMessages::LookupResources::Response* lookupResources_; |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
105 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
106 void Clear() |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
107 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
108 deleteAttachment_ = NULL; |
| 376 | 109 deleteResource_ = NULL; |
| 110 getChanges_ = NULL; | |
| 111 getExportedResources_ = NULL; | |
| 112 getLastChange_ = NULL; | |
| 377 | 113 getLastExportedResource_ = NULL; |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
114 getMainDicomTags_ = NULL; |
| 379 | 115 lookupAttachment_ = NULL; |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
116 lookupResources_ = NULL; |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
117 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
118 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
119 public: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
120 Output(Orthanc::DatabasePluginMessages::DeleteAttachment::Response& deleteAttachment) |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
121 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
122 Clear(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
123 deleteAttachment_ = &deleteAttachment; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
124 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
125 |
| 376 | 126 Output(Orthanc::DatabasePluginMessages::DeleteResource::Response& deleteResource) |
| 127 { | |
| 128 Clear(); | |
| 129 deleteResource_ = &deleteResource; | |
| 130 } | |
| 131 | |
| 132 Output(Orthanc::DatabasePluginMessages::GetChanges::Response& getChanges) | |
| 133 { | |
| 134 Clear(); | |
| 135 getChanges_ = &getChanges; | |
| 136 } | |
| 137 | |
| 138 Output(Orthanc::DatabasePluginMessages::GetExportedResources::Response& getExportedResources) | |
| 139 { | |
| 140 Clear(); | |
| 141 getExportedResources_ = &getExportedResources; | |
| 142 } | |
| 143 | |
| 144 Output(Orthanc::DatabasePluginMessages::GetLastChange::Response& getLastChange) | |
| 145 { | |
| 146 Clear(); | |
| 147 getLastChange_ = &getLastChange; | |
| 148 } | |
| 149 | |
| 377 | 150 Output(Orthanc::DatabasePluginMessages::GetLastExportedResource::Response& getLastExportedResource) |
| 151 { | |
| 152 Clear(); | |
| 153 getLastExportedResource_ = &getLastExportedResource; | |
| 154 } | |
| 155 | |
| 156 Output(Orthanc::DatabasePluginMessages::GetMainDicomTags::Response& getMainDicomTags) | |
| 157 { | |
| 158 Clear(); | |
| 159 getMainDicomTags_ = &getMainDicomTags; | |
| 160 } | |
| 161 | |
| 379 | 162 Output(Orthanc::DatabasePluginMessages::LookupAttachment::Response& lookupAttachment) |
| 163 { | |
| 164 Clear(); | |
| 165 lookupAttachment_ = &lookupAttachment; | |
| 166 } | |
| 167 | |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
168 Output(Orthanc::DatabasePluginMessages::LookupResources::Response& lookupResources) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
169 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
170 Clear(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
171 lookupResources_ = &lookupResources; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
172 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
173 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
174 virtual void SignalDeletedAttachment(const std::string& uuid, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
175 int32_t contentType, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
176 uint64_t uncompressedSize, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
177 const std::string& uncompressedHash, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
178 int32_t compressionType, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
179 uint64_t compressedSize, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
180 const std::string& compressedHash) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
181 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
182 Orthanc::DatabasePluginMessages::FileInfo* attachment; |
| 376 | 183 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
184 if (deleteAttachment_ != NULL) |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
185 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
186 if (deleteAttachment_->has_deleted_attachment()) |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
187 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
188 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
189 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
190 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
191 attachment = deleteAttachment_->mutable_deleted_attachment(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
192 } |
| 376 | 193 else if (deleteResource_ != NULL) |
| 194 { | |
| 195 attachment = deleteResource_->add_deleted_attachments(); | |
| 196 } | |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
197 else |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
198 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
199 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
200 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
201 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
202 attachment->set_uuid(uuid); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
203 attachment->set_content_type(contentType); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
204 attachment->set_uncompressed_size(uncompressedSize); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
205 attachment->set_uncompressed_hash(uncompressedHash); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
206 attachment->set_compression_type(compressionType); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
207 attachment->set_compressed_size(compressedSize); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
208 attachment->set_compressed_hash(compressedHash); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
209 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
210 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
211 virtual void SignalDeletedResource(const std::string& publicId, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
212 OrthancPluginResourceType resourceType) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
213 { |
| 376 | 214 if (deleteResource_ != NULL) |
| 215 { | |
| 216 Orthanc::DatabasePluginMessages::DeleteResource_Response_Resource* resource = deleteResource_->add_deleted_resources(); | |
| 217 resource->set_level(Convert(resourceType)); | |
| 218 resource->set_public_id(publicId); | |
| 219 } | |
| 220 else | |
| 221 { | |
| 222 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 223 } | |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
224 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
225 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
226 virtual void SignalRemainingAncestor(const std::string& ancestorId, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
227 OrthancPluginResourceType ancestorType) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
228 { |
| 376 | 229 if (deleteResource_ != NULL) |
| 230 { | |
| 231 if (deleteResource_->is_remaining_ancestor()) | |
| 232 { | |
| 233 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 234 } | |
| 235 else | |
| 236 { | |
| 237 deleteResource_->set_is_remaining_ancestor(true); | |
| 238 deleteResource_->mutable_remaining_ancestor()->set_level(Convert(ancestorType)); | |
| 239 deleteResource_->mutable_remaining_ancestor()->set_public_id(ancestorId); | |
| 240 } | |
| 241 } | |
| 242 else | |
| 243 { | |
| 244 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 245 } | |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
246 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
247 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
248 virtual void AnswerAttachment(const std::string& uuid, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
249 int32_t contentType, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
250 uint64_t uncompressedSize, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
251 const std::string& uncompressedHash, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
252 int32_t compressionType, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
253 uint64_t compressedSize, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
254 const std::string& compressedHash) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
255 { |
| 379 | 256 if (lookupAttachment_ != NULL) |
| 257 { | |
| 258 if (lookupAttachment_->found()) | |
| 259 { | |
| 260 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 261 } | |
| 262 | |
| 263 lookupAttachment_->set_found(true); | |
| 264 lookupAttachment_->mutable_attachment()->set_uuid(uuid); | |
| 265 lookupAttachment_->mutable_attachment()->set_content_type(contentType); | |
| 266 lookupAttachment_->mutable_attachment()->set_uncompressed_size(uncompressedSize); | |
| 267 lookupAttachment_->mutable_attachment()->set_uncompressed_hash(uncompressedHash); | |
| 268 lookupAttachment_->mutable_attachment()->set_compression_type(compressionType); | |
| 269 lookupAttachment_->mutable_attachment()->set_compressed_size(compressedSize); | |
| 270 lookupAttachment_->mutable_attachment()->set_compressed_hash(compressedHash); | |
| 271 } | |
| 272 else | |
| 273 { | |
| 274 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 275 } | |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
276 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
277 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
278 virtual void AnswerChange(int64_t seq, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
279 int32_t changeType, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
280 OrthancPluginResourceType resourceType, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
281 const std::string& publicId, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
282 const std::string& date) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
283 { |
| 376 | 284 Orthanc::DatabasePluginMessages::ServerIndexChange* change; |
| 285 | |
| 286 if (getChanges_ != NULL) | |
| 287 { | |
| 288 change = getChanges_->add_changes(); | |
| 289 } | |
| 290 else if (getLastChange_ != NULL) | |
| 291 { | |
| 379 | 292 if (getLastChange_->found()) |
| 376 | 293 { |
| 294 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 295 } | |
| 296 | |
| 379 | 297 getLastChange_->set_found(true); |
| 376 | 298 change = getLastChange_->mutable_change(); |
| 299 } | |
| 300 else | |
| 301 { | |
| 302 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 303 } | |
| 304 | |
| 305 change->set_seq(seq); | |
| 306 change->set_change_type(changeType); | |
| 307 change->set_resource_type(Convert(resourceType)); | |
| 308 change->set_public_id(publicId); | |
| 309 change->set_date(date); | |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
310 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
311 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
312 virtual void AnswerDicomTag(uint16_t group, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
313 uint16_t element, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
314 const std::string& value) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
315 { |
| 377 | 316 if (getMainDicomTags_ != NULL) |
| 317 { | |
| 318 Orthanc::DatabasePluginMessages::GetMainDicomTags_Response_Tag* tag = getMainDicomTags_->add_tags(); | |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
319 tag->set_group(group); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
320 tag->set_element(element); |
| 377 | 321 tag->set_value(value); |
| 322 } | |
| 323 else | |
| 324 { | |
| 325 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 326 } | |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
327 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
328 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
329 virtual void AnswerExportedResource(int64_t seq, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
330 OrthancPluginResourceType resourceType, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
331 const std::string& publicId, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
332 const std::string& modality, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
333 const std::string& date, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
334 const std::string& patientId, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
335 const std::string& studyInstanceUid, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
336 const std::string& seriesInstanceUid, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
337 const std::string& sopInstanceUid) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
338 { |
| 377 | 339 Orthanc::DatabasePluginMessages::ExportedResource* resource; |
| 340 | |
| 376 | 341 if (getExportedResources_ != NULL) |
| 342 { | |
| 377 | 343 resource = getExportedResources_->add_resources(); |
| 344 } | |
| 345 else if (getLastExportedResource_ != NULL) | |
| 346 { | |
| 379 | 347 if (getLastExportedResource_->found()) |
| 377 | 348 { |
| 349 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 350 } | |
| 351 | |
| 379 | 352 getLastExportedResource_->set_found(true); |
| 377 | 353 resource = getLastExportedResource_->mutable_resource(); |
| 376 | 354 } |
| 355 else | |
| 356 { | |
| 357 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
| 358 } | |
| 377 | 359 |
| 360 resource->set_seq(seq); | |
| 361 resource->set_resource_type(Convert(resourceType)); | |
| 362 resource->set_public_id(publicId); | |
| 363 resource->set_modality(modality); | |
| 364 resource->set_date(date); | |
| 365 resource->set_patient_id(patientId); | |
| 366 resource->set_study_instance_uid(studyInstanceUid); | |
| 367 resource->set_series_instance_uid(seriesInstanceUid); | |
| 368 resource->set_sop_instance_uid(sopInstanceUid); | |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
369 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
370 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
371 virtual void AnswerMatchingResource(const std::string& resourceId) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
372 { |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
373 if (lookupResources_ != NULL) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
374 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
375 lookupResources_->add_resources_ids(resourceId); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
376 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
377 else |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
378 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
379 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
380 } |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
381 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
382 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
383 virtual void AnswerMatchingResource(const std::string& resourceId, |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
384 const std::string& someInstanceId) ORTHANC_OVERRIDE |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
385 { |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
386 if (lookupResources_ != NULL) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
387 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
388 lookupResources_->add_resources_ids(resourceId); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
389 lookupResources_->add_instances_ids(someInstanceId); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
390 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
391 else |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
392 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
393 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
394 } |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
395 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
396 }; |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
397 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
398 |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
399 static void ProcessDatabaseOperation(Orthanc::DatabasePluginMessages::DatabaseResponse& response, |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
400 const Orthanc::DatabasePluginMessages::DatabaseRequest& request, |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
401 IndexConnectionsPool& pool) |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
402 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
403 switch (request.operation()) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
404 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
405 case Orthanc::DatabasePluginMessages::OPERATION_GET_SYSTEM_INFORMATION: |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
406 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
407 IndexConnectionsPool::Accessor accessor(pool); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
408 response.mutable_get_system_information()->set_database_version(accessor.GetBackend().GetDatabaseVersion(accessor.GetManager())); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
409 response.mutable_get_system_information()->set_supports_flush_to_disk(false); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
410 response.mutable_get_system_information()->set_supports_revisions(accessor.GetBackend().HasRevisionsSupport()); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
411 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
412 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
413 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
414 case Orthanc::DatabasePluginMessages::OPERATION_OPEN: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
415 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
416 pool.OpenConnections(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
417 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
418 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
419 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
420 case Orthanc::DatabasePluginMessages::OPERATION_CLOSE: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
421 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
422 pool.CloseConnections(); |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
423 break; |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
424 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
425 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
426 case Orthanc::DatabasePluginMessages::OPERATION_FLUSH_TO_DISK: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
427 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
428 // Raise an exception since "set_supports_flush_to_disk(false)" |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
429 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
430 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
431 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
432 case Orthanc::DatabasePluginMessages::OPERATION_START_TRANSACTION: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
433 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
434 std::unique_ptr<IndexConnectionsPool::Accessor> transaction(new IndexConnectionsPool::Accessor(pool)); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
435 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
436 switch (request.start_transaction().type()) |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
437 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
438 case Orthanc::DatabasePluginMessages::TRANSACTION_READ_ONLY: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
439 transaction->GetManager().StartTransaction(TransactionType_ReadOnly); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
440 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
441 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
442 case Orthanc::DatabasePluginMessages::TRANSACTION_READ_WRITE: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
443 transaction->GetManager().StartTransaction(TransactionType_ReadWrite); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
444 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
445 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
446 default: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
447 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
448 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
449 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
450 response.mutable_start_transaction()->set_transaction(reinterpret_cast<intptr_t>(transaction.release())); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
451 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
452 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
453 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
454 case Orthanc::DatabasePluginMessages::OPERATION_UPGRADE: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
455 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
456 IndexConnectionsPool::Accessor accessor(pool); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
457 OrthancPluginStorageArea* storageArea = reinterpret_cast<OrthancPluginStorageArea*>(request.upgrade().storage_area()); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
458 accessor.GetBackend().UpgradeDatabase(accessor.GetManager(), request.upgrade().target_version(), storageArea); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
459 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
460 } |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
461 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
462 default: |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
463 LOG(ERROR) << "Not implemented database operation from protobuf: " << request.operation(); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
464 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
465 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
466 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
467 |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
468 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
469 static void ApplyLookupResources(Orthanc::DatabasePluginMessages::LookupResources_Response& response, |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
470 const Orthanc::DatabasePluginMessages::LookupResources_Request& request, |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
471 IndexBackend& backend, |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
472 DatabaseManager& manager) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
473 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
474 std::vector<Orthanc::DatabaseConstraint> lookup; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
475 lookup.reserve(request.lookup().size()); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
476 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
477 size_t countValues = 0; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
478 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
479 for (int i = 0; i < request.lookup().size(); i++) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
480 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
481 const Orthanc::DatabasePluginMessages::DatabaseConstraint& constraint = request.lookup(i); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
482 countValues += constraint.values().size(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
483 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
484 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
485 std::vector<const char*> values; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
486 values.reserve(countValues); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
487 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
488 for (int i = 0; i < request.lookup().size(); i++) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
489 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
490 const Orthanc::DatabasePluginMessages::DatabaseConstraint& constraint = request.lookup(i); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
491 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
492 if (constraint.tag_group() > 0xffffu || |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
493 constraint.tag_element() > 0xffffu) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
494 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
495 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
496 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
497 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
498 OrthancPluginDatabaseConstraint c; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
499 c.level = Convert(constraint.level()); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
500 c.tagGroup = constraint.tag_group(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
501 c.tagElement = constraint.tag_element(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
502 c.isIdentifierTag = (constraint.is_identifier_tag() ? 1 : 0); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
503 c.isCaseSensitive = (constraint.is_case_sensitive() ? 1 : 0); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
504 c.isMandatory = (constraint.is_mandatory() ? 1 : 0); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
505 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
506 switch (constraint.type()) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
507 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
508 case Orthanc::DatabasePluginMessages::CONSTRAINT_EQUAL: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
509 c.type = OrthancPluginConstraintType_Equal; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
510 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
511 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
512 case Orthanc::DatabasePluginMessages::CONSTRAINT_SMALLER_OR_EQUAL: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
513 c.type = OrthancPluginConstraintType_SmallerOrEqual; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
514 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
515 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
516 case Orthanc::DatabasePluginMessages::CONSTRAINT_GREATER_OR_EQUAL: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
517 c.type = OrthancPluginConstraintType_GreaterOrEqual; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
518 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
519 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
520 case Orthanc::DatabasePluginMessages::CONSTRAINT_WILDCARD: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
521 c.type = OrthancPluginConstraintType_Wildcard; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
522 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
523 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
524 case Orthanc::DatabasePluginMessages::CONSTRAINT_LIST: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
525 c.type = OrthancPluginConstraintType_List; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
526 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
527 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
528 default: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
529 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
530 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
531 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
532 c.valuesCount = constraint.values().size(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
533 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
534 if (c.valuesCount == 0) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
535 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
536 c.values = NULL; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
537 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
538 else |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
539 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
540 c.values = &values[values.size()]; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
541 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
542 for (int j = 0; j < constraint.values().size(); j++) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
543 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
544 assert(values.size() < countValues); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
545 values.push_back(constraint.values(j).c_str()); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
546 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
547 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
548 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
549 lookup.push_back(Orthanc::DatabaseConstraint(c)); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
550 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
551 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
552 assert(values.size() == countValues); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
553 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
554 Output output(response); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
555 backend.LookupResources(output, manager, lookup, Convert(request.query_level()), |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
556 request.limit(), request.retrieve_instances_ids()); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
557 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
558 |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
559 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
560 static void ProcessTransactionOperation(Orthanc::DatabasePluginMessages::TransactionResponse& response, |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
561 const Orthanc::DatabasePluginMessages::TransactionRequest& request, |
| 377 | 562 IndexBackend& backend, |
| 563 DatabaseManager& manager) | |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
564 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
565 switch (request.operation()) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
566 { |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
567 case Orthanc::DatabasePluginMessages::OPERATION_ROLLBACK: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
568 { |
| 377 | 569 manager.RollbackTransaction(); |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
570 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
571 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
572 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
573 case Orthanc::DatabasePluginMessages::OPERATION_COMMIT: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
574 { |
| 377 | 575 manager.CommitTransaction(); |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
576 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
577 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
578 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
579 case Orthanc::DatabasePluginMessages::OPERATION_ADD_ATTACHMENT: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
580 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
581 OrthancPluginAttachment attachment; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
582 attachment.uuid = request.add_attachment().attachment().uuid().c_str(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
583 attachment.contentType = request.add_attachment().attachment().content_type(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
584 attachment.uncompressedSize = request.add_attachment().attachment().uncompressed_size(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
585 attachment.uncompressedHash = request.add_attachment().attachment().uncompressed_hash().c_str(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
586 attachment.compressionType = request.add_attachment().attachment().compression_type(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
587 attachment.compressedSize = request.add_attachment().attachment().compressed_size(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
588 attachment.compressedHash = request.add_attachment().attachment().compressed_hash().c_str(); |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
589 |
| 377 | 590 backend.AddAttachment(manager, request.add_attachment().id(), attachment, request.add_attachment().revision()); |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
591 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
592 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
593 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
594 case Orthanc::DatabasePluginMessages::OPERATION_CLEAR_CHANGES: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
595 { |
| 377 | 596 backend.ClearChanges(manager); |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
597 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
598 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
599 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
600 case Orthanc::DatabasePluginMessages::OPERATION_CLEAR_EXPORTED_RESOURCES: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
601 { |
| 377 | 602 backend.ClearExportedResources(manager); |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
603 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
604 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
605 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
606 case Orthanc::DatabasePluginMessages::OPERATION_DELETE_ATTACHMENT: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
607 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
608 Output output(*response.mutable_delete_attachment()); |
| 377 | 609 backend.DeleteAttachment(output, manager, request.delete_attachment().id(), request.delete_attachment().type()); |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
610 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
611 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
612 |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
613 case Orthanc::DatabasePluginMessages::OPERATION_DELETE_METADATA: |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
614 { |
| 377 | 615 backend.DeleteMetadata(manager, request.delete_metadata().id(), request.delete_metadata().type()); |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
616 break; |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
617 } |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
618 |
| 376 | 619 case Orthanc::DatabasePluginMessages::OPERATION_DELETE_RESOURCE: |
| 620 { | |
| 621 response.mutable_delete_resource()->set_is_remaining_ancestor(false); | |
| 622 | |
| 623 Output output(*response.mutable_delete_resource()); | |
| 377 | 624 backend.DeleteResource(output, manager, request.delete_resource().id()); |
| 376 | 625 break; |
| 626 } | |
| 627 | |
| 628 case Orthanc::DatabasePluginMessages::OPERATION_GET_ALL_METADATA: | |
| 629 { | |
| 630 typedef std::map<int32_t, std::string> Values; | |
| 631 | |
| 632 Values values; | |
| 377 | 633 backend.GetAllMetadata(values, manager, request.get_all_metadata().id()); |
| 376 | 634 |
| 635 for (Values::const_iterator it = values.begin(); it != values.end(); ++it) | |
| 636 { | |
| 377 | 637 Orthanc::DatabasePluginMessages::GetAllMetadata_Response_Metadata* metadata = |
| 638 response.mutable_get_all_metadata()->add_metadata(); | |
| 376 | 639 metadata->set_type(it->first); |
| 640 metadata->set_value(it->second); | |
| 641 } | |
| 642 | |
| 643 break; | |
| 644 } | |
| 645 | |
| 646 case Orthanc::DatabasePluginMessages::OPERATION_GET_ALL_PUBLIC_IDS: | |
| 647 { | |
| 648 std::list<std::string> values; | |
| 377 | 649 backend.GetAllPublicIds(values, manager, Convert(request.get_all_public_ids().resource_type())); |
| 376 | 650 |
| 651 for (std::list<std::string>::const_iterator it = values.begin(); it != values.end(); ++it) | |
| 652 { | |
| 653 response.mutable_get_all_public_ids()->add_ids(*it); | |
| 654 } | |
| 655 | |
| 656 break; | |
| 657 } | |
| 658 | |
| 659 case Orthanc::DatabasePluginMessages::OPERATION_GET_ALL_PUBLIC_IDS_WITH_LIMITS: | |
| 660 { | |
| 661 std::list<std::string> values; | |
| 377 | 662 backend.GetAllPublicIds(values, manager, Convert(request.get_all_public_ids_with_limits().resource_type()), |
| 663 request.get_all_public_ids_with_limits().since(), | |
| 664 request.get_all_public_ids_with_limits().limit()); | |
| 376 | 665 |
| 666 for (std::list<std::string>::const_iterator it = values.begin(); it != values.end(); ++it) | |
| 667 { | |
| 668 response.mutable_get_all_public_ids_with_limits()->add_ids(*it); | |
| 669 } | |
| 670 | |
| 671 break; | |
| 672 } | |
| 673 | |
| 674 case Orthanc::DatabasePluginMessages::OPERATION_GET_CHANGES: | |
| 675 { | |
| 676 Output output(*response.mutable_get_changes()); | |
| 677 | |
| 678 bool done; | |
| 377 | 679 backend.GetChanges(output, done, manager, request.get_changes().since(), request.get_changes().limit()); |
| 376 | 680 |
| 681 response.mutable_get_changes()->set_done(done); | |
| 682 break; | |
| 683 } | |
| 684 | |
| 685 case Orthanc::DatabasePluginMessages::OPERATION_GET_CHILDREN_INTERNAL_ID: | |
| 686 { | |
| 687 std::list<int64_t> values; | |
| 377 | 688 backend.GetChildrenInternalId(values, manager, request.get_children_internal_id().id()); |
| 376 | 689 |
| 690 for (std::list<int64_t>::const_iterator it = values.begin(); it != values.end(); ++it) | |
| 691 { | |
| 692 response.mutable_get_children_internal_id()->add_ids(*it); | |
| 693 } | |
| 694 | |
| 695 break; | |
| 696 } | |
| 697 | |
| 698 case Orthanc::DatabasePluginMessages::OPERATION_GET_CHILDREN_PUBLIC_ID: | |
| 699 { | |
| 700 std::list<std::string> values; | |
| 377 | 701 backend.GetChildrenPublicId(values, manager, request.get_children_public_id().id()); |
| 376 | 702 |
| 703 for (std::list<std::string>::const_iterator it = values.begin(); it != values.end(); ++it) | |
| 704 { | |
| 705 response.mutable_get_children_public_id()->add_ids(*it); | |
| 706 } | |
| 707 | |
| 708 break; | |
| 709 } | |
| 710 | |
| 711 case Orthanc::DatabasePluginMessages::OPERATION_GET_EXPORTED_RESOURCES: | |
| 712 { | |
| 713 Output output(*response.mutable_get_exported_resources()); | |
| 714 | |
| 715 bool done; | |
| 377 | 716 backend.GetExportedResources(output, done, manager, request.get_exported_resources().since(), |
| 717 request.get_exported_resources().limit()); | |
| 376 | 718 |
| 719 response.mutable_get_exported_resources()->set_done(done); | |
| 720 break; | |
| 721 } | |
| 722 | |
| 723 case Orthanc::DatabasePluginMessages::OPERATION_GET_LAST_CHANGE: | |
| 724 { | |
| 379 | 725 response.mutable_get_last_change()->set_found(false); |
| 376 | 726 |
| 727 Output output(*response.mutable_get_last_change()); | |
| 377 | 728 backend.GetLastChange(output, manager); |
| 729 break; | |
| 730 } | |
| 731 | |
| 732 case Orthanc::DatabasePluginMessages::OPERATION_GET_LAST_EXPORTED_RESOURCE: | |
| 733 { | |
| 379 | 734 response.mutable_get_last_exported_resource()->set_found(false); |
| 377 | 735 |
| 736 Output output(*response.mutable_get_last_exported_resource()); | |
| 737 backend.GetLastExportedResource(output, manager); | |
| 738 break; | |
| 739 } | |
| 740 | |
| 741 case Orthanc::DatabasePluginMessages::OPERATION_GET_MAIN_DICOM_TAGS: | |
| 742 { | |
| 743 Output output(*response.mutable_get_main_dicom_tags()); | |
| 744 backend.GetMainDicomTags(output, manager, request.get_main_dicom_tags().id()); | |
| 376 | 745 break; |
| 746 } | |
| 747 | |
| 377 | 748 case Orthanc::DatabasePluginMessages::OPERATION_GET_PUBLIC_ID: |
| 749 { | |
| 750 const std::string id = backend.GetPublicId(manager, request.get_public_id().id()); | |
| 751 response.mutable_get_public_id()->set_id(id); | |
| 752 break; | |
| 753 } | |
| 754 | |
| 755 case Orthanc::DatabasePluginMessages::OPERATION_GET_RESOURCES_COUNT: | |
| 756 { | |
| 757 OrthancPluginResourceType type = Convert(request.get_resources_count().type()); | |
| 758 uint64_t count = backend.GetResourcesCount(manager, type); | |
| 759 response.mutable_get_resources_count()->set_count(count); | |
| 760 break; | |
| 761 } | |
| 762 | |
| 763 case Orthanc::DatabasePluginMessages::OPERATION_GET_RESOURCE_TYPE: | |
| 764 { | |
| 765 OrthancPluginResourceType type = backend.GetResourceType(manager, request.get_public_id().id()); | |
| 766 response.mutable_get_resource_type()->set_type(Convert(type)); | |
| 767 break; | |
| 768 } | |
| 769 | |
| 770 case Orthanc::DatabasePluginMessages::OPERATION_GET_TOTAL_COMPRESSED_SIZE: | |
| 771 { | |
| 772 response.mutable_get_total_compressed_size()->set_size(backend.GetTotalCompressedSize(manager)); | |
| 773 break; | |
| 774 } | |
| 775 | |
| 776 case Orthanc::DatabasePluginMessages::OPERATION_GET_TOTAL_UNCOMPRESSED_SIZE: | |
| 777 { | |
| 778 response.mutable_get_total_uncompressed_size()->set_size(backend.GetTotalUncompressedSize(manager)); | |
| 779 break; | |
| 780 } | |
| 781 | |
|
378
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
782 case Orthanc::DatabasePluginMessages::OPERATION_IS_PROTECTED_PATIENT: |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
783 { |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
784 bool isProtected = backend.IsProtectedPatient(manager, request.is_protected_patient().patient_id()); |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
785 response.mutable_is_protected_patient()->set_protected_patient(isProtected); |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
786 break; |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
787 } |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
788 |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
789 case Orthanc::DatabasePluginMessages::OPERATION_LIST_AVAILABLE_ATTACHMENTS: |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
790 { |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
791 std::list<int32_t> values; |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
792 backend.ListAvailableAttachments(values, manager, request.list_available_attachments().id()); |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
793 |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
794 for (std::list<int32_t>::const_iterator it = values.begin(); it != values.end(); ++it) |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
795 { |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
796 response.mutable_list_available_attachments()->add_attachments(*it); |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
797 } |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
798 |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
799 break; |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
800 } |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
801 |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
802 case Orthanc::DatabasePluginMessages::OPERATION_LOG_CHANGE: |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
803 { |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
804 backend.LogChange(manager, request.log_change().change_type(), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
805 request.log_change().resource_id(), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
806 Convert(request.log_change().resource_type()), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
807 request.log_change().date().c_str()); |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
808 break; |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
809 } |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
810 |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
811 case Orthanc::DatabasePluginMessages::OPERATION_LOG_EXPORTED_RESOURCE: |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
812 { |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
813 backend.LogExportedResource(manager, |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
814 Convert(request.log_exported_resource().resource_type()), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
815 request.log_exported_resource().public_id().c_str(), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
816 request.log_exported_resource().modality().c_str(), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
817 request.log_exported_resource().date().c_str(), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
818 request.log_exported_resource().patient_id().c_str(), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
819 request.log_exported_resource().study_instance_uid().c_str(), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
820 request.log_exported_resource().series_instance_uid().c_str(), |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
821 request.log_exported_resource().sop_instance_uid().c_str()); |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
822 break; |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
823 } |
|
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
377
diff
changeset
|
824 |
| 379 | 825 case Orthanc::DatabasePluginMessages::OPERATION_LOOKUP_ATTACHMENT: |
| 826 { | |
| 827 Output output(*response.mutable_lookup_attachment()); | |
| 828 | |
| 829 int64_t revision = -1; | |
| 830 backend.LookupAttachment(output, revision, manager, request.lookup_attachment().id(), request.lookup_attachment().content_type()); | |
| 831 | |
| 832 if (response.lookup_attachment().found()) | |
| 833 { | |
| 834 response.mutable_lookup_attachment()->set_revision(revision); | |
| 835 } | |
| 836 | |
| 837 break; | |
| 838 } | |
| 839 | |
| 840 case Orthanc::DatabasePluginMessages::OPERATION_LOOKUP_GLOBAL_PROPERTY: | |
| 841 { | |
| 842 std::string value; | |
| 843 if (backend.LookupGlobalProperty(value, manager, request.lookup_global_property().server_id().c_str(), | |
| 844 request.lookup_global_property().property())) | |
| 845 { | |
| 846 response.mutable_lookup_global_property()->set_found(true); | |
| 847 response.mutable_lookup_global_property()->set_value(value); | |
| 848 } | |
| 849 else | |
| 850 { | |
| 851 response.mutable_lookup_global_property()->set_found(false); | |
| 852 } | |
| 853 | |
| 854 break; | |
| 855 } | |
| 856 | |
| 857 case Orthanc::DatabasePluginMessages::OPERATION_LOOKUP_METADATA: | |
| 858 { | |
| 859 std::string value; | |
| 860 int64_t revision = -1; | |
| 861 if (backend.LookupMetadata(value, revision, manager, request.lookup_metadata().id(), request.lookup_metadata().metadata_type())) | |
| 862 { | |
| 863 response.mutable_lookup_metadata()->set_found(true); | |
| 864 response.mutable_lookup_metadata()->set_value(value); | |
| 865 response.mutable_lookup_metadata()->set_revision(revision); | |
| 866 } | |
| 867 else | |
| 868 { | |
| 869 response.mutable_lookup_metadata()->set_found(false); | |
| 870 } | |
| 871 | |
| 872 break; | |
| 873 } | |
| 874 | |
| 875 case Orthanc::DatabasePluginMessages::OPERATION_LOOKUP_PARENT: | |
| 876 { | |
| 877 int64_t parent = -1; | |
| 878 if (backend.LookupParent(parent, manager, request.lookup_parent().id())) | |
| 879 { | |
| 880 response.mutable_lookup_parent()->set_found(true); | |
| 881 response.mutable_lookup_parent()->set_parent(parent); | |
| 882 } | |
| 883 else | |
| 884 { | |
| 885 response.mutable_lookup_parent()->set_found(false); | |
| 886 } | |
| 887 | |
| 888 break; | |
| 889 } | |
| 890 | |
| 891 case Orthanc::DatabasePluginMessages::OPERATION_LOOKUP_RESOURCE: | |
| 892 { | |
| 893 int64_t internalId = -1; | |
| 894 OrthancPluginResourceType type; | |
| 895 if (backend.LookupResource(internalId, type, manager, request.lookup_resource().public_id().c_str())) | |
| 896 { | |
| 897 response.mutable_lookup_resource()->set_found(true); | |
| 898 response.mutable_lookup_resource()->set_internal_id(internalId); | |
| 899 response.mutable_lookup_resource()->set_type(Convert(type)); | |
| 900 } | |
| 901 else | |
| 902 { | |
| 903 response.mutable_lookup_resource()->set_found(false); | |
| 904 } | |
| 905 | |
| 906 break; | |
| 907 } | |
| 908 | |
| 909 case Orthanc::DatabasePluginMessages::OPERATION_SELECT_PATIENT_TO_RECYCLE: | |
| 910 { | |
| 911 int64_t patientId = -1; | |
| 912 if (backend.SelectPatientToRecycle(patientId, manager)) | |
| 913 { | |
| 914 response.mutable_select_patient_to_recycle()->set_found(true); | |
| 915 response.mutable_select_patient_to_recycle()->set_patient_id(patientId); | |
| 916 } | |
| 917 else | |
| 918 { | |
| 919 response.mutable_select_patient_to_recycle()->set_found(false); | |
| 920 } | |
| 921 | |
| 922 break; | |
| 923 } | |
| 924 | |
| 925 case Orthanc::DatabasePluginMessages::OPERATION_SELECT_PATIENT_TO_RECYCLE_WITH_AVOID: | |
| 926 { | |
| 927 int64_t patientId = -1; | |
| 928 if (backend.SelectPatientToRecycle(patientId, manager, request.select_patient_to_recycle_with_avoid().patient_id_to_avoid())) | |
| 929 { | |
| 930 response.mutable_select_patient_to_recycle_with_avoid()->set_found(true); | |
| 931 response.mutable_select_patient_to_recycle_with_avoid()->set_patient_id(patientId); | |
| 932 } | |
| 933 else | |
| 934 { | |
| 935 response.mutable_select_patient_to_recycle_with_avoid()->set_found(false); | |
| 936 } | |
| 937 | |
| 938 break; | |
| 939 } | |
| 940 | |
| 941 case Orthanc::DatabasePluginMessages::OPERATION_SET_GLOBAL_PROPERTY: | |
| 942 { | |
| 943 backend.SetGlobalProperty(manager, request.set_global_property().server_id().c_str(), | |
| 944 request.set_global_property().property(), | |
| 945 request.set_global_property().value().c_str()); | |
| 946 break; | |
| 947 } | |
| 948 | |
| 949 case Orthanc::DatabasePluginMessages::OPERATION_CLEAR_MAIN_DICOM_TAGS: | |
| 950 { | |
| 951 backend.ClearMainDicomTags(manager, request.clear_main_dicom_tags().id()); | |
| 952 break; | |
| 953 } | |
| 954 | |
| 955 case Orthanc::DatabasePluginMessages::OPERATION_SET_METADATA: | |
| 956 { | |
| 957 backend.SetMetadata(manager, request.set_metadata().id(), | |
| 958 request.set_metadata().metadata_type(), | |
| 959 request.set_metadata().value().c_str(), | |
| 960 request.set_metadata().revision()); | |
| 961 break; | |
| 962 } | |
| 963 | |
| 964 case Orthanc::DatabasePluginMessages::OPERATION_SET_PROTECTED_PATIENT: | |
| 965 { | |
| 966 backend.SetProtectedPatient(manager, request.set_protected_patient().patient_id(), | |
| 967 request.set_protected_patient().protected_patient()); | |
| 968 break; | |
| 969 } | |
| 970 | |
| 971 case Orthanc::DatabasePluginMessages::OPERATION_IS_DISK_SIZE_ABOVE: | |
| 972 { | |
| 973 bool above = (backend.GetTotalCompressedSize(manager) >= request.is_disk_size_above().threshold()); | |
| 974 response.mutable_is_disk_size_above()->set_result(above); | |
| 975 break; | |
| 976 } | |
| 977 | |
|
380
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
978 case Orthanc::DatabasePluginMessages::OPERATION_LOOKUP_RESOURCES: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
979 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
980 ApplyLookupResources(*response.mutable_lookup_resources(), request.lookup_resources(), backend, manager); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
981 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
982 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
983 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
984 case Orthanc::DatabasePluginMessages::OPERATION_CREATE_INSTANCE: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
985 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
986 const char* hashPatient = request.create_instance().patient().c_str(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
987 const char* hashStudy = request.create_instance().study().c_str(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
988 const char* hashSeries = request.create_instance().series().c_str(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
989 const char* hashInstance = request.create_instance().instance().c_str(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
990 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
991 OrthancPluginCreateInstanceResult result; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
992 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
993 if (backend.HasCreateInstance()) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
994 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
995 backend.CreateInstance(result, manager, hashPatient, hashStudy, hashSeries, hashInstance); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
996 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
997 else |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
998 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
999 backend.CreateInstanceGeneric(result, manager, hashPatient, hashStudy, hashSeries, hashInstance); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1000 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1001 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1002 response.mutable_create_instance()->set_is_new_instance(result.isNewInstance); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1003 response.mutable_create_instance()->set_instance_id(result.instanceId); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1004 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1005 if (result.isNewInstance) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1006 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1007 response.mutable_create_instance()->set_is_new_patient(result.isNewPatient); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1008 response.mutable_create_instance()->set_is_new_study(result.isNewStudy); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1009 response.mutable_create_instance()->set_is_new_series(result.isNewSeries); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1010 response.mutable_create_instance()->set_patient_id(result.patientId); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1011 response.mutable_create_instance()->set_study_id(result.studyId); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1012 response.mutable_create_instance()->set_series_id(result.seriesId); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1013 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1014 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1015 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1016 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1017 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1018 case Orthanc::DatabasePluginMessages::OPERATION_SET_RESOURCES_CONTENT: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1019 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1020 std::vector<OrthancPluginResourcesContentTags> identifierTags; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1021 std::vector<OrthancPluginResourcesContentTags> mainDicomTags; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1022 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1023 identifierTags.reserve(request.set_resources_content().tags().size()); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1024 mainDicomTags.reserve(request.set_resources_content().tags().size()); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1025 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1026 for (int i = 0; i < request.set_resources_content().tags().size(); i++) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1027 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1028 if (request.set_resources_content().tags(i).group() > 0xffff || |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1029 request.set_resources_content().tags(i).element() > 0xffff) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1030 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1031 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1032 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1033 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1034 OrthancPluginResourcesContentTags tag; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1035 tag.resource = request.set_resources_content().tags(i).resource_id(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1036 tag.group = request.set_resources_content().tags(i).group(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1037 tag.element = request.set_resources_content().tags(i).element(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1038 tag.value = request.set_resources_content().tags(i).value().c_str(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1039 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1040 if (request.set_resources_content().tags(i).is_identifier()) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1041 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1042 identifierTags.push_back(tag); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1043 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1044 else |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1045 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1046 mainDicomTags.push_back(tag); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1047 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1048 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1049 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1050 std::vector<OrthancPluginResourcesContentMetadata> metadata(request.set_resources_content().metadata().size()); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1051 for (int i = 0; i < request.set_resources_content().metadata().size(); i++) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1052 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1053 OrthancPluginResourcesContentMetadata item; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1054 item.resource = request.set_resources_content().metadata(i).resource_id(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1055 item.metadata = request.set_resources_content().metadata(i).metadata(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1056 item.value = request.set_resources_content().metadata(i).value().c_str(); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1057 metadata.push_back(item); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1058 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1059 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1060 backend.SetResourcesContent(manager, |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1061 identifierTags.size(), (identifierTags.empty() ? NULL : &identifierTags[0]), |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1062 mainDicomTags.size(), (mainDicomTags.empty() ? NULL : &mainDicomTags[0]), |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1063 metadata.size(), (metadata.empty() ? NULL : &metadata[0])); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1064 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1065 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1066 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1067 case Orthanc::DatabasePluginMessages::OPERATION_GET_CHILDREN_METADATA: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1068 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1069 std::list<std::string> values; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1070 backend.GetChildrenMetadata(values, manager, request.get_children_metadata().id(), request.get_children_metadata().metadata()); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1071 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1072 for (std::list<std::string>::const_iterator it = values.begin(); it != values.end(); ++it) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1073 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1074 response.mutable_get_children_metadata()->add_values(*it); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1075 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1076 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1077 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1078 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1079 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1080 case Orthanc::DatabasePluginMessages::OPERATION_GET_LAST_CHANGE_INDEX: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1081 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1082 response.mutable_get_last_change_index()->set_result(backend.GetLastChangeIndex(manager)); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1083 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1084 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1085 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1086 case Orthanc::DatabasePluginMessages::OPERATION_LOOKUP_RESOURCE_AND_PARENT: |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1087 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1088 int64_t id; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1089 OrthancPluginResourceType type; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1090 std::string parent; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1091 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1092 if (backend.LookupResourceAndParent(id, type, parent, manager, request.lookup_resource_and_parent().public_id().c_str())) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1093 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1094 response.mutable_lookup_resource_and_parent()->set_found(true); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1095 response.mutable_lookup_resource_and_parent()->set_id(id); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1096 response.mutable_lookup_resource_and_parent()->set_type(Convert(type)); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1097 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1098 if (parent.empty()) |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1099 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1100 response.mutable_lookup_resource_and_parent()->set_has_parent(true); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1101 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1102 else |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1103 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1104 response.mutable_lookup_resource_and_parent()->set_has_parent(false); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1105 response.mutable_lookup_resource_and_parent()->set_parent_public_id(parent); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1106 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1107 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1108 else |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1109 { |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1110 response.mutable_lookup_resource_and_parent()->set_found(false); |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1111 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1112 |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1113 break; |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1114 } |
|
cb91096fef06
implemented full protobuf api
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
379
diff
changeset
|
1115 |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1116 default: |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1117 LOG(ERROR) << "Not implemented transaction operation from protobuf: " << request.operation(); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1118 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1119 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1120 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1121 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1122 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1123 static OrthancPluginErrorCode CallBackend(OrthancPluginMemoryBuffer64* serializedResponse, |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1124 void* rawPool, |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1125 const void* requestData, |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1126 uint64_t requestSize) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1127 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1128 Orthanc::DatabasePluginMessages::Request request; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1129 if (!request.ParseFromArray(requestData, requestSize)) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1130 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1131 LOG(ERROR) << "Cannot parse message from the Orthanc core using protobuf"; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1132 return OrthancPluginErrorCode_InternalError; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1133 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1134 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1135 if (rawPool == NULL) |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1136 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1137 LOG(ERROR) << "Received a NULL pointer from the database"; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1138 return OrthancPluginErrorCode_InternalError; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1139 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1140 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1141 IndexConnectionsPool& pool = *reinterpret_cast<IndexConnectionsPool*>(rawPool); |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1142 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1143 try |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1144 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1145 Orthanc::DatabasePluginMessages::Response response; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1146 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1147 switch (request.type()) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1148 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1149 case Orthanc::DatabasePluginMessages::REQUEST_DATABASE: |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1150 ProcessDatabaseOperation(*response.mutable_database_response(), request.database_request(), pool); |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1151 break; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1152 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1153 case Orthanc::DatabasePluginMessages::REQUEST_TRANSACTION: |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1154 { |
|
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1155 IndexConnectionsPool::Accessor& transaction = *reinterpret_cast<IndexConnectionsPool::Accessor*>(request.transaction_request().transaction()); |
| 377 | 1156 ProcessTransactionOperation(*response.mutable_transaction_response(), request.transaction_request(), |
| 1157 transaction.GetBackend(), transaction.GetManager()); | |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1158 break; |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1159 } |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1160 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1161 default: |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1162 LOG(ERROR) << "Not implemented request type from protobuf: " << request.type(); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1163 break; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1164 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1165 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1166 std::string s; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1167 if (!response.SerializeToString(&s)) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1168 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1169 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError, "Cannot serialize to protobuf"); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1170 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1171 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1172 if (OrthancPluginCreateMemoryBuffer64(pool.GetContext(), serializedResponse, s.size()) != OrthancPluginErrorCode_Success) |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1173 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1174 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotEnoughMemory, "Cannot allocate a memory buffer"); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1175 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1176 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1177 if (!s.empty()) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1178 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1179 assert(serializedResponse->size == s.size()); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1180 memcpy(serializedResponse->data, s.c_str(), s.size()); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1181 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1182 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1183 return OrthancPluginErrorCode_Success; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1184 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1185 catch (::Orthanc::OrthancException& e) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1186 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1187 LOG(ERROR) << "Exception in database back-end: " << e.What(); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1188 return static_cast<OrthancPluginErrorCode>(e.GetErrorCode()); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1189 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1190 catch (::std::runtime_error& e) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1191 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1192 LOG(ERROR) << "Exception in database back-end: " << e.what(); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1193 return OrthancPluginErrorCode_DatabasePlugin; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1194 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1195 catch (...) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1196 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1197 LOG(ERROR) << "Native exception"; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1198 return OrthancPluginErrorCode_DatabasePlugin; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1199 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1200 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1201 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1202 static void FinalizeBackend(void* rawPool) |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1203 { |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1204 if (rawPool != NULL) |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1205 { |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1206 IndexConnectionsPool* pool = reinterpret_cast<IndexConnectionsPool*>(rawPool); |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1207 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1208 if (isBackendInUse_) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1209 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1210 isBackendInUse_ = false; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1211 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1212 else |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1213 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1214 LOG(ERROR) << "More than one index backend was registered, internal error"; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1215 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1216 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1217 delete pool; |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1218 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1219 else |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1220 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1221 LOG(ERROR) << "Received a null pointer from the Orthanc core, internal error"; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1222 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1223 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1224 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1225 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1226 void DatabaseBackendAdapterV4::Register(IndexBackend* backend, |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1227 size_t countConnections, |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1228 unsigned int maxDatabaseRetries) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1229 { |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1230 std::unique_ptr<IndexConnectionsPool> pool(new IndexConnectionsPool(backend, countConnections)); |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1231 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1232 if (isBackendInUse_) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1233 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1234 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1235 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1236 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1237 OrthancPluginContext* context = backend->GetContext(); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1238 |
|
375
824d70ce85ff
implemented database operations
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1239 if (OrthancPluginRegisterDatabaseBackendV4(context, pool.release(), maxDatabaseRetries, |
|
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1240 CallBackend, FinalizeBackend) != OrthancPluginErrorCode_Success) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1241 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1242 delete backend; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1243 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError, "Unable to register the database backend"); |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1244 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1245 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1246 isBackendInUse_ = true; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1247 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1248 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1249 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1250 void DatabaseBackendAdapterV4::Finalize() |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1251 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1252 if (isBackendInUse_) |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1253 { |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1254 LOG(ERROR) << "The Orthanc core has not destructed the index backend, internal error"; |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1255 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1256 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1257 } |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1258 |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1259 # endif |
|
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
diff
changeset
|
1260 #endif |