Merge pull request #2 from noms-digital-studio/increase_entity_limit

Allow no limit to NOMIS data - to allow several days worth of data to…

build.sbt

@@ -2,7 +2,7 @@ name := "pollpush"
 
 organization := "gov.uk.justice.digital"
 
-version := "0.1.07"
+version := "0.1.08"
 
 scalaVersion := "2.12.2"
 

src/main/scala/gov/uk/justice/digital/pollpush/services/NomisSource.scala

@@ -51,7 +51,7 @@ class NomisSource @Inject() (@Named("sourceUrl") sourceUrl: String, @Named("note
 
         case HttpResponse(_, _, entity, _) =>
 
-          Unmarshal(entity).to[Seq[SourceCaseNote]].map(PullResult(_, Some(from), Some(until), None))
+          Unmarshal(entity.withoutSizeLimit()).to[Seq[SourceCaseNote]].map(PullResult(_, Some(from), Some(until), None))
 
       }.recover { case error: Throwable => PullResult(Seq(), Some(from), Some(until), Some(error)) }
   }

src/test/scala/NomisSpec.scala

@@ -36,7 +36,7 @@ class NomisSpec extends FunSpec with BeforeAndAfterAll with GivenWhenThen with M
       val minuteAgo = rightNow.minus(6000)
 
       When("Case Notes are pulled from the API")
-      val result = Await.result(source.pull(minuteAgo, rightNow), 5.seconds)
+      val result = Await.result(source.pull(minuteAgo, rightNow), 10.seconds)
 
       Then("the API receives a HTTP GET call with Authorization, from_datetime and returns the Case Notes")
       verify(
@@ -100,7 +100,7 @@ class NomisSpec extends FunSpec with BeforeAndAfterAll with GivenWhenThen with M
       val minuteAgo = rightNow.minus(6000)
 
       When("Case Notes are pulled from the API")
-      val result = Await.result(source.pull(minuteAgo, rightNow), 5.seconds)
+      val result = Await.result(source.pull(minuteAgo, rightNow), 10.seconds)
 
       Then("the API receives a HTTP GET call with Authorization, from_datetime, and noteType whitelist")
       verify(
@@ -124,7 +124,7 @@ class NomisSpec extends FunSpec with BeforeAndAfterAll with GivenWhenThen with M
       val minuteAgo = rightNow.minus(6000)
 
       When("Case Notes are pulled from the API")
-      val result = Await.result(source.pull(minuteAgo, rightNow), 5.seconds)
+      val result = Await.result(source.pull(minuteAgo, rightNow), 10.seconds)
 
       Then("the API receives a HTTP GET call with Authorization, from_datetime, and noteType whitelist")
       verify(
@@ -148,7 +148,7 @@ class NomisSpec extends FunSpec with BeforeAndAfterAll with GivenWhenThen with M
       val minuteAgo = rightNow.minus(6000)
 
       When("a Case Notes pull from the API is attempted")
-      val result = Await.result(source.pull(minuteAgo, rightNow), 5.seconds)
+      val result = Await.result(source.pull(minuteAgo, rightNow), 10.seconds)
 
       Then("the 500 error is reported")
       result.error.get.toString should include("500")