Add batch ULI validation

Author: jmarin

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

@@ -1,5 +1,8 @@
 package hmda.validation.engine.lar
 
+import akka.NotUsed
+import akka.stream.scaladsl.Source
+
 //See https://www.consumerfinance.gov/eregulations/1003-C/2015-26607_20180101#1003-C-1
 
 object ULI {
@@ -62,4 +65,9 @@ object ULI {
     calculateMod(BigInt(convert(uli))) == 1
   }
 
+  def validateULISource(uliSource: Source[String, NotUsed]): Source[(String, Boolean), NotUsed] = {
+    uliSource
+      .map(uli => (uli, validateULI(uli)))
+  }
+
 }

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

@@ -1,20 +1,47 @@
 package hmda.validation.engine.lar
 
-import org.scalatest.{ MustMatchers, WordSpec }
+import akka.actor.ActorSystem
+import akka.stream.ActorMaterializer
+import akka.stream.scaladsl.{ Sink, Source }
+import org.scalatest.{ AsyncWordSpec, BeforeAndAfterAll, MustMatchers }
 
-class ULISpec extends WordSpec with MustMatchers {
+class ULISpec extends AsyncWordSpec with MustMatchers with BeforeAndAfterAll {
 
-  val validULI = "10Bx939c5543TqA1144M999143X"
+  implicit val system = ActorSystem()
+  implicit val materializer = ActorMaterializer()
+  implicit val ec = system.dispatcher
+
+  val loan1 = "10Bx939c5543TqA1144M999143X"
+  val loan2 = "10Cx939c5543TqA1144M999143X"
+  val validULI1 = "10Bx939c5543TqA1144M999143X38"
+  val validULI2 = "10Cx939c5543TqA1144M999143X10"
   val invalidULI = "10Bx939c5543TqA1144M999133X38"
 
+  override def afterAll(): Unit = {
+    super.afterAll()
+    system.terminate()
+  }
+
   "A ULI Validation" must {
     "Produce valid check digit" in {
-      ULI.checkDigit(validULI) mustBe 38
-      ULI.generateULI(validULI) mustBe "10Bx939c5543TqA1144M999143X38"
+      ULI.checkDigit(loan1) mustBe 38
+      ULI.checkDigit(loan2) mustBe 10
+      ULI.generateULI(loan1) mustBe validULI1
+      ULI.generateULI(loan2) mustBe validULI2
     }
     "Validate ULI" in {
-      ULI.validateULI(validULI + "38") mustBe true
+      ULI.validateULI(validULI1) mustBe true
+      ULI.validateULI(validULI2) mustBe true
       ULI.validateULI(invalidULI) mustBe false
     }
+    "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)
+      validatedF.map { validated =>
+        validated.head._2 mustBe true
+        validated.tail.head._2 mustBe false
+      }
+    }
   }
 }