Add batch ULI validation (json)

Author: jmarin

api-model/src/main/scala/hmda/api/model/public/ULIModel.scala

@@ -6,4 +6,6 @@ object ULIModel {
   case class ULI(loanId: String, checkDigit: Int, uli: String)
   case class ULICheck(uli: String)
   case class ULIValidated(isValid: Boolean)
+  case class ULIBatchValidated(uli: String, isValid: Boolean)
+  case class ULIBatchValidatedResponse(ulis: Seq[ULIBatchValidated])
 }

api-model/src/main/scala/hmda/api/protocol/public/ULIProtocol.scala

@@ -1,13 +1,15 @@
 package hmda.api.protocol.public
 
-import hmda.api.model.public.ULIModel.{ Loan, ULI, ULICheck, ULIValidated }
+import hmda.api.model.public.ULIModel._
 import spray.json.DefaultJsonProtocol
 
 trait ULIProtocol extends DefaultJsonProtocol {
 
   implicit val loanFormat = jsonFormat1(Loan.apply)
   implicit val uliFormat = jsonFormat3(ULI.apply)
   implicit val uliCheckFormat = jsonFormat1(ULICheck.apply)
-  implicit val uliValidated = jsonFormat1(ULIValidated.apply)
+  implicit val uliValidatedFormat = jsonFormat1(ULIValidated.apply)
+  implicit val uliBatchValidatedFormat = jsonFormat2(ULIBatchValidated.apply)
+  implicit val uliBatchValidatedResponseFormat = jsonFormat1(ULIBatchValidatedResponse.apply)
 
 }

api/src/main/scala/hmda/api/http/public/PublicHttpApi.scala

@@ -6,15 +6,20 @@ import akka.stream.ActorMaterializer
 import akka.util.Timeout
 import hmda.api.http.HmdaCustomDirectives
 import akka.http.scaladsl.server.Directives._
-import hmda.api.model.public.ULIModel.{ Loan, ULI, ULICheck, ULIValidated }
+import hmda.api.model.public.ULIModel._
 import hmda.validation.engine.lar.ULI._
 import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._
 import akka.http.scaladsl.marshalling.ToResponseMarshallable
+import akka.http.scaladsl.model.StatusCodes
+import akka.stream.scaladsl.Sink
+import hmda.api.protocol.processing.ApiErrorProtocol
 import hmda.api.protocol.public.ULIProtocol
+import hmda.api.util.FlowUtils
 
 import scala.concurrent.ExecutionContext
+import scala.util.{ Failure, Success }
 
-trait PublicHttpApi extends PublicLarHttpApi with HmdaCustomDirectives with ULIProtocol {
+trait PublicHttpApi extends PublicLarHttpApi with HmdaCustomDirectives with ApiErrorProtocol with ULIProtocol with FlowUtils {
   implicit val system: ActorSystem
   implicit val materializer: ActorMaterializer
   implicit val timeout: Timeout
@@ -46,7 +51,27 @@ trait PublicHttpApi extends PublicLarHttpApi with HmdaCustomDirectives with ULIP
                     val isValid = validateULI(uli)
                     val validated = ULIValidated(isValid)
                     complete(ToResponseMarshallable(validated))
-                  }
+                  } ~
+                    fileUpload("file") {
+                      case (_, byteSource) =>
+                        val validatedF = byteSource
+                          .via(framing)
+                          .map(_.utf8String)
+                          .map(uli => (uli, validateULI(uli)))
+                          .map(validated => ULIBatchValidated(validated._1, validated._2))
+                          .runWith(Sink.seq)
+
+                        onComplete(validatedF) {
+                          case Success(validated) =>
+                            complete(ToResponseMarshallable(ULIBatchValidatedResponse(validated)))
+                          case Failure(error) =>
+                            log.error(error.getLocalizedMessage)
+                            complete(ToResponseMarshallable(StatusCodes.InternalServerError))
+                        }
+
+                      case _ =>
+                        complete(ToResponseMarshallable(StatusCodes.BadRequest))
+                    }
                 }
               }
           }