Merge pull request #61 from shreelakshmijoshi/updating-build-pg-write…

…-query Updating build pg write query
datakaveri · May 8, 2024 · bb7b8a3 · bb7b8a3
2 parents c918714 + cf231a5
commit bb7b8a3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/main/java/iudx/auditing/server/querystrategy/DmpApdAuditingStrategy.java b/src/main/java/iudx/auditing/server/querystrategy/DmpApdAuditingStrategy.java
@@ -26,7 +26,7 @@ public String buildPostgresWriteQuery(JsonObject request) {
     String userId = request.getString(USER_ID);
     String api = request.getString(API);
     String method = request.getString(HTTP_METHOD);
-    String information = request.getString(INFORMATION);
+    JsonObject information = request.getJsonObject(INFORMATION);
     String isoTime = request.getString(ISO_TIME);
     String databaseTableName = config.getString(DMP_APD_PG_TABLE_NAME);
 
@@ -40,7 +40,7 @@ public String buildPostgresWriteQuery(JsonObject request) {
         .replace("$2", userId)
         .replace("$3", api)
         .replace("$4", method)
-        .replace("$5", information)
+        .replace("$5", information.encode())
         .replace("$6", utcTime.toString());
   }
 

diff --git a/src/test/java/iudx/auditing/server/processor/MessageProcessorImplTest.java b/src/test/java/iudx/auditing/server/processor/MessageProcessorImplTest.java
@@ -151,7 +151,7 @@ public void testForDmpSuccess(VertxTestContext vertxTestContext) {
 
         String primaryKey = UUID.randomUUID().toString().replace("-", "");
         String userId = UUID.randomUUID().toString();
-        String information = new JsonObject().put("policyId", UUID.randomUUID().toString()).put("createdAt", isoTime).put("policyStatus", "ACTIVE").encode();
+        JsonObject information = new JsonObject().put("policyId", UUID.randomUUID().toString()).put("createdAt", isoTime).put("policyStatus", "ACTIVE");
         LOGGER.info("primary key is : {}", primaryKey);
         when(config.getString(DMP_APD_PG_TABLE_NAME)).thenReturn("DMP_APD_PG_TABLE_NAME");
         when(config.getString(DMP_APD_IMMUDB_TABLE_NAME)).thenReturn("DMP_APD_IMMUDB_TABLE_NAME");
@@ -198,7 +198,7 @@ public void testForDmpFailure(VertxTestContext vertxTestContext) {
 
         String primaryKey = UUID.randomUUID().toString().replace("-", "");
         String userId = UUID.randomUUID().toString();
-        String information = new JsonObject().put("policyId", UUID.randomUUID().toString()).put("createdAt", isoTime).put("policyStatus", "ACTIVE").encode();
+        JsonObject information = new JsonObject().put("policyId", UUID.randomUUID().toString()).put("createdAt", isoTime).put("policyStatus", "ACTIVE");
         LOGGER.info("primary key is : {}", primaryKey);
         when(config.getString(DMP_APD_PG_TABLE_NAME)).thenReturn("DMP_APD_PG_TABLE_NAME");
         when(config.getString(DMP_APD_IMMUDB_TABLE_NAME)).thenReturn("DMP_APD_IMMUDB_TABLE_NAME");