feat: added changes

Swasth-Digital-Health-Foundation · Feb 21, 2023 · 7c90804 · 7c90804
1 parent 9c8f0f4
commit 7c90804
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 7 deletions.
diff --git a/hcx-core/hcx-common/src/main/java/org/swasth/common/helpers/EventGenerator.java b/hcx-core/hcx-common/src/main/java/org/swasth/common/helpers/EventGenerator.java
@@ -129,7 +129,6 @@ public Map<String, Object> generateAuditEvent(Request request) {
         event.put(SENDER_PRIMARY_EMAIL, request.getSenderPrimaryEmail());
         event.put(RECIPIENT_PRIMARY_EMAIL, request.getRecipientPrimaryEmail());
         getTag(request,event);
-        System.out.println(event);
         return event;
     }
 

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
@@ -236,7 +236,6 @@ abstract class BaseDispatcherFunction(config: BaseJobConfig)
     audit.put(Constants.RECIPIENT_PRIMARY_EMAIL, getCDataStringValue(event, Constants.RECIPIENT, Constants.PRIMARY_EMAIL))
     audit.put(Constants.PAYLOAD, removeSensitiveData(payload))
     getTag(event,audit)
-    println(audit)
     audit
   }
 

diff --git a/...line-jobs/core/src/main/scala/org/swasth/dp/core/function/ContextEnrichmentFunction.scala b/...line-jobs/core/src/main/scala/org/swasth/dp/core/function/ContextEnrichmentFunction.scala
@@ -29,16 +29,13 @@ class ContextEnrichmentFunction(config: BaseJobConfig) (implicit val stringTypeI
 
     // Fetch the sender and receiver details from registry or cache
     val sender = fetchDetails(senderCode)
-    println(sender)
     if (!sender.isEmpty) {
       val enrichedSender = createSenderContext(sender, action)
       if (MapUtils.isNotEmpty(enrichedSender))
         result.put(Constants.SENDER, enrichedSender)
     }
 
     val recipient = fetchDetails(recipientCode)
-    println(recipient)
-    println(recipient.get(Constants.TAGS))
     if (!recipient.isEmpty) {
       val enrichedRecipient = createRecipientContext(recipient, action)
       if (MapUtils.isNotEmpty(enrichedRecipient))

diff --git a/hcx-pipeline-jobs/core/src/main/scala/org/swasth/dp/core/job/BaseProcessFunction.scala b/hcx-pipeline-jobs/core/src/main/scala/org/swasth/dp/core/job/BaseProcessFunction.scala
@@ -69,7 +69,7 @@ abstract class BaseProcessFunction[T, R](config: BaseJobConfig) extends ProcessF
   }
 
   def getCDataListValue(event: util.Map[String, AnyRef], participant: String, key: String): util.List[String] = {
-    event.getOrDefault(Constants.CDATA, new util.HashMap[String, AnyRef]()).asInstanceOf[util.Map[String, AnyRef]].getOrDefault(participant, new util.HashMap[String, AnyRef]()).asInstanceOf[util.Map[String, AnyRef]].getOrDefault(key, new util.ArrayList[String]).asInstanceOf[util.List[String]]  }
+    event.getOrDefault(Constants.CDATA, new util.HashMap[String, AnyRef]()).asInstanceOf[util.Map[String, AnyRef]].getOrDefault(participant, new util.HashMap[String, AnyRef]()).asInstanceOf[util.Map[String, AnyRef]].getOrDefault(key, new util.ArrayList[String]()).asInstanceOf[util.List[String]]  }
 
   def getCDataStringValue(event: util.Map[String, AnyRef], participant: String, key: String): String = {
     event.getOrDefault(Constants.CDATA, new util.HashMap[String, AnyRef]()).asInstanceOf[util.Map[String, AnyRef]].getOrDefault(participant, new util.HashMap[String, AnyRef]()).asInstanceOf[util.Map[String, AnyRef]].get(key).asInstanceOf[String]
@@ -143,7 +143,6 @@ abstract class BaseProcessFunction[T, R](config: BaseJobConfig) extends ProcessF
   def getDetails(code: String): util.Map[String, AnyRef] = {
     val key = Constants.PARTICIPANT_CODE
     val responseBody = registryService.getParticipantDetails(s"""{"$key":{"eq":"$code"}}""")
-    println(responseBody.get(0))
     if (!responseBody.isEmpty) {
       val collectionMap = responseBody.get(0)
       collectionMap