FIX speciality EntityChange altType into different subtypes

telefonicaid · Sep 11, 2024 · 0b4627c · 0b4627c
1 parent 651d740
commit 0b4627c
Show file tree

Hide file tree

Showing 4 changed files with 58 additions and 16 deletions.
diff --git a/src/lib/apiTypesV2/Subscription.cpp b/src/lib/apiTypesV2/Subscription.cpp
@@ -42,7 +42,7 @@ ngsiv2::SubAltType parseAlterationType(const std::string& altType)
 {
   if (altType == "entityChange")
   {
-    return ngsiv2::SubAltType::EntityChange;
+    return ngsiv2::SubAltType::EntityChangeBothValueAndMetadata;
   }
   else if (altType == "entityUpdate")
   {
@@ -64,13 +64,26 @@ ngsiv2::SubAltType parseAlterationType(const std::string& altType)
 
 
 
+/* ****************************************************************************
+*
+* isChangeAltType -
+*/
+bool isChangeAltType(ngsiv2::SubAltType altType)
+{
+  return (altType == ngsiv2::SubAltType::EntityChangeBothValueAndMetadata) ||
+         (altType == ngsiv2::SubAltType::EntityChangeOnlyMetadata)         ||
+         (altType == ngsiv2::SubAltType::EntityChangeOnlyValue);
+}
+
+
+
 /* ****************************************************************************
 *
 * subAltType2string -
 */
 std::string subAltType2string(ngsiv2::SubAltType altType)
 {
-  if (altType == ngsiv2::SubAltType::EntityChange)
+  if (isChangeAltType(altType))
   {
     return "entityChange";
   }

diff --git a/src/lib/apiTypesV2/Subscription.h b/src/lib/apiTypesV2/Subscription.h
@@ -57,7 +57,9 @@ typedef enum NotificationType
 */
 typedef enum SubAltType
 {
-  EntityChange,
+  EntityChangeBothValueAndMetadata,  // this is the reference one used by parsing/rendering logic
+  EntityChangeOnlyValue,
+  EntityChangeOnlyMetadata,
   EntityUpdate,
   EntityCreate,
   EntityDelete,
@@ -192,4 +194,12 @@ extern std::string subAltType2string(ngsiv2::SubAltType altType);
 
 
 
+/* ****************************************************************************
+*
+* isChangeAltType -
+*/
+extern bool isChangeAltType(ngsiv2::SubAltType altType);
+
+
+
 #endif  // SRC_LIB_APITYPESV2_SUBSCRIPTION_H_
diff --git a/src/lib/cache/subCache.cpp b/src/lib/cache/subCache.cpp
@@ -403,7 +403,7 @@ static bool matchAltType(CachedSubscription* cSubP, ngsiv2::SubAltType targetAlt
   // If subAltTypeV size == 0 default alteration types are update with change and create
   if (cSubP->subAltTypeV.size() == 0)
   {
-    if ((targetAltType == ngsiv2::SubAltType::EntityChange) || (targetAltType == ngsiv2::SubAltType::EntityCreate))
+    if ((isChangeAltType(targetAltType)) || (targetAltType == ngsiv2::SubAltType::EntityCreate))
     {
       return true;
     }
@@ -417,9 +417,9 @@ static bool matchAltType(CachedSubscription* cSubP, ngsiv2::SubAltType targetAlt
     ngsiv2::SubAltType altType = cSubP->subAltTypeV[ix];
 
     // EntityUpdate is special, it is a "sub-type" of EntityChange
-    if (targetAltType == ngsiv2::SubAltType::EntityChange)
+    if (isChangeAltType(targetAltType))
     {
-      if ((altType == ngsiv2::SubAltType::EntityUpdate) || (altType == ngsiv2::SubAltType::EntityChange))
+      if ((altType == ngsiv2::SubAltType::EntityUpdate) || (isChangeAltType(altType)))
       {
         return true;
       }
@@ -507,7 +507,7 @@ static bool subMatch
       return false;
     }
   }
-  else if ((targetAltType == ngsiv2::EntityChange) || (targetAltType == ngsiv2::EntityCreate))
+  else if ((isChangeAltType(targetAltType)) || (targetAltType == ngsiv2::EntityCreate))
   {
     if (!attributeMatch(cSubP, attrsWithModifiedValue) &&
         !(cSubP->notifyOnMetadataChange && attributeMatch(cSubP, attrsWithModifiedMd)))

diff --git a/src/lib/mongoBackend/MongoCommonUpdate.cpp b/src/lib/mongoBackend/MongoCommonUpdate.cpp
@@ -1493,7 +1493,7 @@ static bool matchAltType(orion::BSONObj sub, ngsiv2::SubAltType targetAltType)
   // change and create. Maybe this could be check at MongoDB query stage, but seems be more complex
   if (altTypeStrings.size() == 0)
   {
-    if ((targetAltType == ngsiv2::SubAltType::EntityChange) || (targetAltType == ngsiv2::SubAltType::EntityCreate))
+    if ((isChangeAltType(targetAltType)) || (targetAltType == ngsiv2::SubAltType::EntityCreate))
     {
       return true;
     }
@@ -1513,9 +1513,9 @@ static bool matchAltType(orion::BSONObj sub, ngsiv2::SubAltType targetAltType)
     else
     {
       // EntityUpdate is special, it is a "sub-type" of EntityChange
-      if (targetAltType == ngsiv2::SubAltType::EntityChange)
+      if (isChangeAltType(targetAltType))
       {
-        if ((altType == ngsiv2::SubAltType::EntityUpdate) || (altType == ngsiv2::SubAltType::EntityChange))
+        if ((altType == ngsiv2::SubAltType::EntityUpdate) || (isChangeAltType(targetAltType)))
         {
           return true;
         }
@@ -1659,11 +1659,13 @@ static bool addTriggeredSubscriptions_noCache
           continue;
         }
       }
-      else if ((targetAltType == ngsiv2::EntityChange) || (targetAltType == ngsiv2::EntityCreate))
+      else if ((isChangeAltType(targetAltType)) || (targetAltType == ngsiv2::EntityCreate))
       {
         // Skip if: 1) there is no change in the *value* of attributes listed in conditions.attrs and 2) there is no change
         // in the *metadata* of the attributes listed in conditions.attrs (the 2) only if notifyOnMetadtaChange is true)
-        if (!condValueAttrMatch(sub, attrsWithModifiedValue) && !(notifyOnMetadataChange && condValueAttrMatch(sub, attrsWithModifiedMd)))
+        bool b1 = condValueAttrMatch(sub, attrsWithModifiedValue);
+        bool b2 = condValueAttrMatch(sub, attrsWithModifiedMd);
+        if (!b1 && !(notifyOnMetadataChange && b2))
         {
           continue;
         }
@@ -2766,24 +2768,41 @@ static bool processContextAttributeVector
     {
       attrsWithModifiedValue.push_back(ca->name);
       attrsWithModifiedMd.push_back(ca->name);
+      targetAltType = ngsiv2::SubAltType::EntityChangeBothValueAndMetadata;
     }
     else if (changeType == CHANGE_ONLY_VALUE)
     {
       attrsWithModifiedValue.push_back(ca->name);
+      if ((targetAltType == ngsiv2::SubAltType::EntityChangeBothValueAndMetadata) || (targetAltType == ngsiv2::SubAltType::EntityChangeOnlyMetadata))
+      {
+        targetAltType = ngsiv2::SubAltType::EntityChangeBothValueAndMetadata;
+      }
+      else
+      {
+        targetAltType = ngsiv2::SubAltType::EntityChangeOnlyValue;
+      }
     }
     else if (changeType == CHANGE_ONLY_MD)
     {
       attrsWithModifiedMd.push_back(ca->name);
+      if ((targetAltType == ngsiv2::SubAltType::EntityChangeBothValueAndMetadata) || (targetAltType == ngsiv2::SubAltType::EntityChangeOnlyValue))
+      {
+        targetAltType = ngsiv2::SubAltType::EntityChangeBothValueAndMetadata;
+      }
+      else
+      {
+        targetAltType = ngsiv2::SubAltType::EntityChangeOnlyMetadata;
+      }
     }
 
-    attributes.push_back(ca->name);
+    attributes.push_back(ca->name); 
 
     /* If actual update then targetAltType changes from EntityUpdate (the value used to initialize
      * the variable) to EntityChange */
-    if (changeType != NO_CHANGE)
+    /*if (changeType != NO_CHANGE)
     {
       targetAltType = ngsiv2::SubAltType::EntityChange;
-    }
+    }*/
   }
 
   /* Add triggered subscriptions */
@@ -3948,7 +3967,7 @@ static unsigned int updateEntity
    * previous addTriggeredSubscriptions() invocations. Before that, we add
    * builtin attributes and metadata (both NGSIv1 and NGSIv2 as this is
    * for notifications and NGSIv2 builtins can be used in NGSIv1 notifications) */
-  addBuiltins(notifyCerP, subAltType2string(ngsiv2::SubAltType::EntityChange));
+  addBuiltins(notifyCerP, subAltType2string(ngsiv2::SubAltType::EntityChangeBothValueAndMetadata));
   unsigned int notifSent = processSubscriptions(subsToNotify,
                                                 notifyCerP,
                                                 tenant,