Remove DB projections

Author: jmarin

api/src/main/scala/hmda/api/http/institutions/submissions/SubmissionIrsPaths.scala

@@ -12,7 +12,6 @@ import hmda.api.model.{ Irs, IrsResponse }
 import hmda.api.protocol.processing.MsaProtocol
 import hmda.census.model.Msa
 import hmda.model.fi.SubmissionId
-import hmda.query.repository.filing.FilingComponent
 import hmda.validation.ValidationStats.FindIrsStats
 
 import scala.concurrent.{ ExecutionContext, Future }
@@ -21,8 +20,7 @@ import scala.util.{ Failure, Success }
 trait SubmissionIrsPaths
     extends HmdaCustomDirectives
     with RequestVerificationUtils
-    with MsaProtocol
-    with FilingComponent {
+    with MsaProtocol {
 
   implicit val system: ActorSystem
   implicit val materializer: ActorMaterializer

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

@@ -2,30 +2,28 @@ package hmda.api.http.public
 
 import akka.actor.ActorSystem
 import akka.event.LoggingAdapter
-import akka.http.scaladsl.model.HttpEntity.ChunkStreamPart
-import akka.http.scaladsl.model.{ ContentTypes, HttpEntity, HttpResponse }
 import akka.http.scaladsl.server.Directives._
 import akka.stream.ActorMaterializer
 import hmda.api.EC
 import hmda.api.http.HmdaCustomDirectives
-import hmda.query.DbConfiguration._
-import hmda.query.repository.filing.FilingComponent
 
-trait PublicLarHttpApi extends HmdaCustomDirectives with FilingComponent {
+trait PublicLarHttpApi extends HmdaCustomDirectives {
 
   implicit val system: ActorSystem
   implicit val materializer: ActorMaterializer
   val log: LoggingAdapter
 
-  val modifiedLarRepository = new ModifiedLarRepository(config)
+  //val modifiedLarRepository = new ModifiedLarRepository(config)
 
   def modifiedLar[_: EC](institutionId: String) =
     path("filings" / Segment / "lar") { period =>
       timedGet { _ =>
-        val data = modifiedLarRepository.findByInstitutionIdSource(institutionId, period)
-          .map(x => ChunkStreamPart(x.toCSV + "\n"))
-        val response = HttpResponse(entity = HttpEntity.Chunked(ContentTypes.`text/csv(UTF-8)`, data))
-        complete(response)
+        //TODO: reimplement modified lar endpoint when Cassandra backend implementation is done
+        //val data = modifiedLarRepository.findByInstitutionIdSource(institutionId, period)
+        //  .map(x => ChunkStreamPart(x.toCSV + "\n"))
+        //val response = HttpResponse(entity = HttpEntity.Chunked(ContentTypes.`text/csv(UTF-8)`, data))
+        //complete(response)
+        complete("OK")
       }
     }
 

query/src/main/scala/hmda/query/HmdaQuerySupervisor.scala

@@ -1,16 +1,12 @@
 package hmda.query
 
 import akka.actor.{ ActorRef, ActorSystem, Props }
-import akka.pattern.ask
 import akka.util.Timeout
 import hmda.persistence.model.HmdaSupervisorActor
-import hmda.query.projections.filing.HmdaFilingDBProjection.CreateSchema
 import hmda.query.view.filing.HmdaFilingView
 import hmda.query.view.institutions.InstitutionView
-import hmda.query.view.messages.CommonViewMessages.GetProjectionActorRef
 import hmda.persistence.PersistenceConfig._
 import hmda.persistence.messages.CommonMessages._
-import scala.concurrent.ExecutionContext
 import scala.concurrent.duration._
 
 object HmdaQuerySupervisor {
@@ -49,14 +45,9 @@ class HmdaQuerySupervisor extends HmdaSupervisorActor {
     actors.getOrElse(s"HmdaFilingView-$period", createHmdaFilingView(period))
   }
 
-  private def createHmdaFilingView(period: String)(implicit ec: ExecutionContext): ActorRef = {
+  private def createHmdaFilingView(period: String): ActorRef = {
     val id = s"${HmdaFilingView.name}-$period"
     val actor = context.actorOf(HmdaFilingView.props(period).withDispatcher("query-dispatcher"), id)
-    for {
-      p <- (actor ? GetProjectionActorRef).mapTo[ActorRef]
-    } yield {
-      p ! CreateSchema
-    }
     supervise(actor, id)
   }