# HG changeset patch # User Alain Mazy # Date 1727100413 -7200 # Node ID 77c8544bbd7df2374ea0bf28eff374ade0351d28 # Parent 22bbce1f88ff7f79ed1a16b7ab89243b21b6ed05# Parent a7f841fc4a9f00567430ef929c15f28913298f90 merge diff -r a7f841fc4a9f -r 77c8544bbd7d Framework/Plugins/DatabaseBackendAdapterV4.cpp --- a/Framework/Plugins/DatabaseBackendAdapterV4.cpp Sun Sep 22 10:06:51 2024 +0200 +++ b/Framework/Plugins/DatabaseBackendAdapterV4.cpp Mon Sep 23 16:06:53 2024 +0200 @@ -794,7 +794,13 @@ Output output(*response.mutable_get_changes_extended()); bool done; - backend.GetChangesExtended(output, done, manager, request.get_changes_extended().since(), request.get_changes_extended().to(), static_cast(request.get_changes_extended().change_type()), request.get_changes_extended().limit()); + std::set changeTypes; + for (int i = 0; i < request.get_changes_extended().change_type_size(); ++i) + { + changeTypes.insert(request.get_changes_extended().change_type(i)); + } + + backend.GetChangesExtended(output, done, manager, request.get_changes_extended().since(), request.get_changes_extended().to(), changeTypes, request.get_changes_extended().limit()); response.mutable_get_changes_extended()->set_done(done); break; diff -r a7f841fc4a9f -r 77c8544bbd7d Framework/Plugins/IDatabaseBackend.h --- a/Framework/Plugins/IDatabaseBackend.h Sun Sep 22 10:06:51 2024 +0200 +++ b/Framework/Plugins/IDatabaseBackend.h Mon Sep 23 16:06:53 2024 +0200 @@ -115,7 +115,7 @@ DatabaseManager& manager, int64_t since, int64_t to, - int32_t changeType, + const std::set& changeTypes, uint32_t limit) = 0; virtual void GetChildrenInternalId(std::list& target /*out*/, diff -r a7f841fc4a9f -r 77c8544bbd7d Framework/Plugins/IndexBackend.cpp --- a/Framework/Plugins/IndexBackend.cpp Sun Sep 22 10:06:51 2024 +0200 +++ b/Framework/Plugins/IndexBackend.cpp Mon Sep 23 16:06:53 2024 +0200 @@ -60,6 +60,19 @@ return s; } + static std::string JoinChanges(const std::set& changeTypes) + { + std::set changeTypesString; + for (std::set::const_iterator it = changeTypes.begin(); it != changeTypes.end(); ++it) + { + changeTypesString.insert(boost::lexical_cast(*it)); + } + + std::string joinedChangesTypes; + Orthanc::Toolbox::JoinStrings(joinedChangesTypes, changeTypesString, ", "); + + return joinedChangesTypes; + } template static void ReadListOfIntegers(std::list& target, @@ -601,11 +614,8 @@ int64_t since, uint32_t limit) { -#if ORTHANC_PLUGINS_VERSION_IS_ABOVE(1, 12, 5) - GetChangesExtended(output, done, manager, since, -1, _OrthancPluginChangeType_All, limit); -#else - GetChangesExtended(output, done, manager, since, -1, 65535, limit); -#endif + std::set changeTypes; + GetChangesExtended(output, done, manager, since, -1, changeTypes, limit); } /* Use GetOutput().AnswerChange() */ @@ -614,7 +624,7 @@ DatabaseManager& manager, int64_t since, int64_t to, - int32_t changeType, + const std::set& changeTypes, uint32_t limit) { std::string limitSuffix; @@ -630,7 +640,6 @@ std::vector filters; bool hasSince = false; bool hasTo = false; - bool hasFilterType = false; if (since > 0) { @@ -642,12 +651,10 @@ hasTo = true; filters.push_back("seq<=${to}"); } - #if ORTHANC_PLUGINS_HAS_CHANGES_EXTENDED == 1 - if (changeType != _OrthancPluginChangeType_All) + if (changeTypes.size() > 0) { - hasFilterType = true; - filters.push_back("changeType=${changeType}"); + filters.push_back("changeType IN (" + JoinChanges(changeTypes) + ") "); } #endif @@ -698,12 +705,6 @@ args.SetIntegerValue("to", to); } - if (hasFilterType) - { - statement.SetParameterType("changeType", ValueType_Integer64); - args.SetIntegerValue("changeType", changeType); - } - ReadChangesInternal(output, done, manager, statement, args, limit, returnFirstResults); } diff -r a7f841fc4a9f -r 77c8544bbd7d Framework/Plugins/IndexBackend.h --- a/Framework/Plugins/IndexBackend.h Sun Sep 22 10:06:51 2024 +0200 +++ b/Framework/Plugins/IndexBackend.h Mon Sep 23 16:06:53 2024 +0200 @@ -137,7 +137,7 @@ DatabaseManager& manager, int64_t since, int64_t to, - int32_t changeType, + const std::set& changeTypes, uint32_t limit) ORTHANC_OVERRIDE; virtual void GetChildrenInternalId(std::list& target /*out*/,