added migration script and code changes for action and actionResultNa… (

#2069)

* added migration script and code changes for action and actionResultName changes

* added ActionName and ActionResultName to the builder method

* added unit test for 2 added fields

db-init/src/main/resources/database/migrations/V1.3__BIE_Contention_Event_Add_Additional_Columns.sql

@@ -0,0 +1,3 @@
+ALTER TABLE "bie_contention_event"
+ADD COLUMN "action_name" VARCHAR(255) DEFAULT NULL,
+ADD COLUMN "action_result_name" VARCHAR(255) DEFAULT NULL;

domain-xample/xample-workflows/src/test/java/gov/va/vro/routes/xample/BieXampleRoutesTest.java

@@ -70,6 +70,9 @@ void testSaveContentionEventRoute() {
     assertThat(response.getContentionId()).isEqualTo(testItem.getContentionId());
     assertThat(response.getContentionTypeCode()).isEqualTo(testItem.getContentionTypeCode());
     assertThat(response.getDiagnosticTypeCode()).isEqualTo(testItem.getDiagnosticTypeCode());
+    assertThat(response.getActionName()).isEqualTo(testItem.getActionName());
+    assertThat(response.getActionResultName()).isEqualTo(testItem.getActionResultName());
+
     assertMockEndpointsSatisfied();
   }
 

shared/lib-bie-kafka/src/main/java/gov/va/vro/model/biekafka/BieMessagePayload.java

@@ -18,6 +18,8 @@ public class BieMessagePayload {
   private String contentionTypeCode;
   private String contentionClassificationName;
   private String diagnosticTypeCode;
+  private String actionName;
+  private String actionResultName;
   private long notifiedAt;
   private long occurredAt;
 }

shared/lib-bie-kafka/src/main/java/gov/va/vro/model/biekafka/test/BieMessagePayloadFactory.java

@@ -20,6 +20,8 @@ public static BieMessagePayload create() {
         .diagnosticTypeCode(faker.lorem().characters(10))
         .occurredAt(faker.date().past(60, TimeUnit.DAYS).getTime())
         .notifiedAt(faker.date().past(60, TimeUnit.DAYS).getTime())
+        .actionName(faker.lorem().characters(10))
+        .actionResultName(faker.lorem().characters(10))
         .status(200)
         .build();
   }

svc-bie-kafka/src/main/java/gov/va/vro/services/bie/service/kafka/KafkaConsumer.java

@@ -62,6 +62,8 @@ private BieMessagePayload handleGenericRecord(ConsumerRecord<String, Object> rec
     String KEY_CONTENTION_ID = "ContentionId";
     String KEY_CONTENTION_TYPE_CODE = "ContentionTypeCode";
     String KEY_EVENT_TIME = "EventTime";
+    String ACTION_NAME = "ActionName";
+    String ACTION_RESULT_NAME = "ActionResultName";
 
     return BieMessagePayload.builder()
         .eventType(
@@ -73,6 +75,8 @@ private BieMessagePayload handleGenericRecord(ConsumerRecord<String, Object> rec
         .diagnosticTypeCode((String) messageValue.get(KEY_DIAGNOSTIC_TYPE_CODE))
         .occurredAt((Long) messageValue.get(KEY_EVENT_TIME))
         .notifiedAt(record.timestamp())
+        .actionName((String) messageValue.get(ACTION_NAME))
+        .actionResultName((String) messageValue.get(ACTION_RESULT_NAME))
         .status(200)
         .build();
   }

svc-bie-kafka/src/test/java/gov/va/vro/services/bie/service/BieRabbitServiceTest.java

@@ -50,6 +50,8 @@ void shouldConvertAndSendBiePayload() {
           .isEqualTo(payload.getContentionClassificationName());
       assertThat(value.getDiagnosticTypeCode()).isEqualTo(payload.getDiagnosticTypeCode());
       assertThat(value.getNotifiedAt()).isEqualTo(payload.getNotifiedAt());
+      assertThat(value.getActionName()).isEqualTo(payload.getActionName());
+      assertThat(value.getActionResultName()).isEqualTo(payload.getActionResultName());
     }
   }
 }