added logging

Author: Nick Grippin

persistence/src/main/scala/hmda/persistence/processing/HmdaFileValidator.scala

@@ -256,9 +256,13 @@ class HmdaFileValidator(submissionId: SubmissionId) extends HmdaPersistentActor
 
     case CompleteValidation(replyTo, originalSender) =>
       if (state.readyToSign) {
+        log.info("Ready to persist IRS")
         for {
           stat <- statRef
-        } yield stat ! PersistIrs
+        } yield {
+          log.info("Sending IRS persistence message")
+          stat ! PersistIrs
+        }
         log.debug(s"Validation completed for $submissionId")
         replyTo ! ValidationCompleted(originalSender)
       } else {

validation/src/main/scala/hmda/validation/SubmissionLarStats.scala

@@ -94,6 +94,7 @@ class SubmissionLarStats(submissionId: SubmissionId) extends HmdaPersistentActor
       tallyQ075Lar(lar)
       tallyQ076Lar(lar)
       msaMap = msaMap + lar
+      log.info("Msa Map: " + msaMap)
 
     case CountSubmittedLarsInSubmission =>
       persist(SubmittedLarsUpdated(totalSubmittedLars)) { e =>
@@ -129,8 +130,9 @@ class SubmissionLarStats(submissionId: SubmissionId) extends HmdaPersistentActor
 
     case PersistIrs =>
       val msaSeq = msaMap.msas.values.toSeq
+      log.info("SubmissionLarStats PersistIrs message received, about to persist IRS")
       persist(IrsStatsUpdated(msaSeq)) { e =>
-        log.debug(s"Persisted: $msaSeq")
+        log.info(s"Persisted: $msaSeq")
         updateState(e)
         val validationStats = context.actorSelection("/user/validation-stats")
         validationStats ! AddIrsStats(msaSeq, submissionId)

validation/src/main/scala/hmda/validation/ValidationStats.scala

@@ -111,6 +111,7 @@ class ValidationStats extends HmdaPersistentActor {
   var state = ValidationStatsState()
 
   override def updateState(event: Event): Unit = {
+    log.info("ValidationStats event " + event)
     state = state.updated(event)
   }
 
@@ -134,8 +135,9 @@ class ValidationStats extends HmdaPersistentActor {
       }
 
     case AddIrsStats(map, id) =>
+      log.info("ValidationStats AddIrsStats message received")
       persist(IrsStatsAdded(map, id)) { e =>
-        log.debug(s"Persisted: $e")
+        log.info(s"Persisted: $e")
         updateState(e)
       }