orthanc-databases: Framework/Plugins/DatabaseBackendAdapterV4.cpp annotate

annotate Framework/Plugins/DatabaseBackendAdapterV4.cpp @ 520:e1d3da372805 OrthancMySQL-5.2 tip

mainline -> MySQL 5.2

author	Alain Mazy <am@orthanc.team>
date	Thu, 06 Jun 2024 15:12:01 +0200
parents	54d518dcd74a
children

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

Mercurial > hg > orthanc-databases

annotate Framework/Plugins/DatabaseBackendAdapterV4.cpp @ 520:e1d3da372805 OrthancMySQL-5.2 tip