feat: added event map

Swasth-Digital-Health-Foundation · Feb 21, 2023 · 9c8f0f4 · 9c8f0f4
1 parent b2d76d5
commit 9c8f0f4
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/...ipeline-jobs/core/src/main/scala/org/swasth/dp/core/function/BaseDispatcherFunction.scala b/...ipeline-jobs/core/src/main/scala/org/swasth/dp/core/function/BaseDispatcherFunction.scala
@@ -234,8 +234,8 @@ abstract class BaseDispatcherFunction(config: BaseJobConfig)
     audit.put(Constants.RECIPIENT_NAME, getCDataStringValue(event, Constants.RECIPIENT, Constants.PARTICIPANT_NAME))
     audit.put(Constants.SENDER_PRIMARY_EMAIL, getCDataStringValue(event, Constants.SENDER, Constants.PRIMARY_EMAIL))
     audit.put(Constants.RECIPIENT_PRIMARY_EMAIL, getCDataStringValue(event, Constants.RECIPIENT, Constants.PRIMARY_EMAIL))
-    getTag(audit)
     audit.put(Constants.PAYLOAD, removeSensitiveData(payload))
+    getTag(event,audit)
     println(audit)
     audit
   }
@@ -299,13 +299,10 @@ abstract class BaseDispatcherFunction(config: BaseJobConfig)
   }
 
 
-  def getTag(audit: util.HashMap[String, AnyRef]): Unit = {
+  def getTag(event : util.Map[String, AnyRef],audit: util.HashMap[String, AnyRef]): Unit = {
     var tagSet: Set[String] = Set()
-    print(getCDataListValue(audit,Constants.SENDER,Constants.TAGS))
-    print(getCDataListValue(audit,Constants.RECIPIENT,Constants.TAGS))
-    tagSet += getCDataListValue(audit, Constants.SENDER, Constants.TAGS).toString
-    tagSet += getCDataListValue(audit, Constants.RECIPIENT, Constants.TAGS).toString
-    println(tagSet)
+    tagSet += getCDataListValue(event, Constants.SENDER, Constants.TAGS).toString
+    tagSet += getCDataListValue(event, Constants.RECIPIENT, Constants.TAGS).toString
     if (!StringUtils.isEmpty(config.tag)) {
       tagSet += config.tag
     }