Add batch check digit

Author: jmarin

validation/src/main/scala/hmda/validation/engine/lar/ULI.scala

@@ -53,19 +53,24 @@ object ULI {
     98 - i
   }
 
-  def checkDigit(uli: String): BigInt = {
-    calculateCheckDigit(calculateMod(BigInt(convert(uli) ++ "00")))
+  def checkDigit(loanId: String): BigInt = {
+    calculateCheckDigit(calculateMod(BigInt(convert(loanId) ++ "00")))
   }
 
-  def generateULI(uli: String): String = {
-    uli + checkDigit(uli).toString()
+  def generateULI(loanId: String): String = {
+    loanId + checkDigit(loanId).toString()
+  }
+
+  def checkDigitBatch(loanIdSource: Source[String, NotUsed]): Source[(String, BigInt), NotUsed] = {
+    loanIdSource
+      .map(loanId => (loanId, checkDigit(loanId)))
   }
 
   def validateULI(uli: String): Boolean = {
     calculateMod(BigInt(convert(uli))) == 1
   }
 
-  def validateULISource(uliSource: Source[String, NotUsed]): Source[(String, Boolean), NotUsed] = {
+  def validateULIBatch(uliSource: Source[String, NotUsed]): Source[(String, Boolean), NotUsed] = {
     uliSource
       .map(uli => (uli, validateULI(uli)))
   }

validation/src/test/scala/hmda/validation/engine/lar/ULISpec.scala

@@ -34,10 +34,19 @@ class ULISpec extends AsyncWordSpec with MustMatchers with BeforeAndAfterAll {
       ULI.validateULI(validULI2) mustBe true
       ULI.validateULI(invalidULI) mustBe false
     }
+    "produce valid check digits in batch" in {
+      val loanIt = List(loan1, loan2).toIterator
+      val loanSource = Source.fromIterator(() => loanIt)
+      val checkDigitF = ULI.checkDigitBatch(loanSource).runWith(Sink.seq)
+      checkDigitF.map { checkDigit =>
+        checkDigit.head._2 mustBe 38
+        checkDigit.tail.head._2 mustBe 10
+      }
+    }
     "Validate a list of ULIs" in {
       val uliIt = List(validULI1, invalidULI).toIterator
       val uliSource = Source.fromIterator(() => uliIt)
-      val validatedF = ULI.validateULISource(uliSource).runWith(Sink.seq)
+      val validatedF = ULI.validateULIBatch(uliSource).runWith(Sink.seq)
       validatedF.map { validated =>
         validated.head._2 mustBe true
         validated.tail.head._2 mustBe false