first commit

src/main/java/fr/natan/akkastreamfileprocessingapi/controller/MovieController.java

@@ -61,8 +61,8 @@ public class MovieController {
     }
 
     @RequestMapping(value = "/tvseries/title/{tvseriePrimaryTitle}", method = RequestMethod.GET)
-    private ResponseEntity<List<Models.TvSerie>> getTvserieByPrimaryTitle(@PathVariable(name = "tvseriePrimaryTitle") String tvseriePrimaryTitle) {
-       List<Models.TvSerie> listFuture = akkaStreamFilesProcessing.getTvSerieByPrimaryTitle(tvseriePrimaryTitle);
+    private ResponseEntity<Future<List<Models.TvSerie>>> getTvserieByPrimaryTitle(@PathVariable(name = "tvseriePrimaryTitle") String tvseriePrimaryTitle) {
+       Future<List<Models.TvSerie>> listFuture = akkaStreamFilesProcessing.getTvSerieByPrimaryTitle(tvseriePrimaryTitle);
 
        return new ResponseEntity<>(listFuture, HttpStatus.OK);
     }

src/main/scala/fr/natan/akkastreamfileprocessingapi/service/AkkaStreamFileProcessing.scala

@@ -10,7 +10,7 @@ trait AkkaStreamFileProcessing {
   def getPersonByName(primaryName: String): Future[Person]
 
   def getTvSerieById(tvSerieID: String): Future[TvSerie]
-  def getTvSerieByPrimaryTitle(tvSerieTitle: String):List[TvSerie]
+  def getTvSerieByPrimaryTitle(tvSerieTitle: String):Future[List[TvSerie]]
 
   def getTeamOfPersonsForTvSerie(tvSeriePrimaryTitle: String): Future[IndexedSeq[Person]]
   def getAllTvSeries(): Unit

src/main/scala/fr/natan/akkastreamfileprocessingapi/service/AkkaStreamFileProcessingImpl.scala

@@ -1,8 +1,8 @@
 package fr.natan.akkastreamfileprocessingapi.service
 
-import akka.Done
 import akka.actor.ActorSystem
-import akka.stream.scaladsl.{Sink, Source}
+import akka.stream.scaladsl.{Flow, Sink, Source}
+import akka.{Done, NotUsed}
 import com.typesafe.scalalogging.slf4j.Logger
 import fr.natan.akkastreamfileprocessingapi.datasource.Datasource.{nameBasics, titleBasics, titlePrincipalsBasics}
 import fr.natan.akkastreamfileprocessingapi.models.Models.{Person, TvSerie}
@@ -65,7 +65,7 @@ class AkkaStreamFileProcessingImpl extends AkkaStreamFileProcessing {
     })
     res
   }
-  override def getTvSerieByPrimaryTitle(tvSeriePrimaryTitle: String): List[TvSerie] = {
+  override def getTvSerieByPrimaryTitle(tvSeriePrimaryTitle: String): Future[List[TvSerie]] = {
 
     val tvSeriesSource: Source[Map[String, String], _] = buildAndValidateSource(inputFile = titleBasics)
 
@@ -79,9 +79,8 @@ class AkkaStreamFileProcessingImpl extends AkkaStreamFileProcessing {
         value.foreach((tvSrie: TvSerie) => logger.info(s"$tvSrie"))
         logger.info("SUCCESS")
     })
-    Await.result(tvSries,2 minutes)
-    val tvSriesList : List[TvSerie] = tvSries.value.get.get
-    tvSriesList
+
+    tvSries
   }