Add tcp server stub

Author: jmarin

api/src/main/resources/application.conf

@@ -29,6 +29,14 @@ hmda {
   }
   isDemo = false
   isDemo = ${?HMDA_IS_DEMO}
+  panel {
+    tcp {
+      host = "127.0.0.1"
+      host = ${?HMDA_PANEL_LOADER_HOST}
+      port = "8888"
+      port = ${?HMDA_PANEL_LOADER_PORT}
+    }
+  }
 }
 
 api-dispatcher {

api/src/main/scala/hmda/api/tcp/TcpApi.scala

@@ -0,0 +1,39 @@
+package hmda.api.tcp
+
+import java.net.InetSocketAddress
+
+import akka.actor.{Actor, ActorSystem, Status}
+import akka.stream.ActorMaterializer
+import akka.stream.scaladsl.Tcp
+import akka.stream.scaladsl.Tcp.ServerBinding
+import hmda.persistence.model.HmdaActor
+
+import scala.concurrent.{ExecutionContext, Future}
+
+abstract class TcpApi extends HmdaActor {
+
+  val name: String
+  val host: String
+  val port: Int
+
+  implicit val system: ActorSystem
+  implicit val materializer: ActorMaterializer
+  implicit val ec: ExecutionContext
+
+  val tcp: Future[ServerBinding]
+
+  override def receive = {
+    case Tcp.ServerBinding(s) => handleServerBinding(s)
+    case Status.Failure(e) => handleBindFailure(e)
+  }
+
+  private def handleServerBinding(address: InetSocketAddress): Unit = {
+    log.info(s"$name started on {}", address)
+    context.become(Actor.emptyBehavior)
+  }
+
+  private def handleBindFailure(error: Throwable): Unit = {
+    log.error(error, s"Failed to bind to $host:$port")
+    context stop self
+  }
+}

api/src/main/scala/hmda/api/tcp/admin/InstitutionAdminTcpApi.scala

@@ -0,0 +1,37 @@
+package hmda.api.tcp.admin
+
+import akka.NotUsed
+import akka.pattern.pipe
+import akka.actor.{ActorRef, ActorSystem}
+import akka.stream.ActorMaterializer
+import akka.stream.scaladsl.{Flow, Tcp}
+import akka.util.ByteString
+import hmda.api.tcp.TcpApi
+import hmda.api.util.FlowUtils
+
+import scala.concurrent.{ExecutionContext, Future}
+
+class InstitutionAdminTcpApi(supervisor: ActorRef) extends TcpApi with FlowUtils {
+  override val name: String = "hmda-institutions-tcp-api"
+
+  override implicit val system: ActorSystem = context.system
+  override implicit val materializer: ActorMaterializer = ActorMaterializer()
+  override implicit val ec: ExecutionContext = context.dispatcher
+
+  override val host: String = config.getString("hmda.panel.tcp.host")
+  override val port: Int = config.getInt("hmda.panel.tcp.port")
+
+
+  val tcpHandler: Flow[ByteString, ByteString, NotUsed] =
+    Flow[ByteString]
+    .map{ e => println(e); e}
+
+
+  override val tcp: Future[Tcp.ServerBinding] = Tcp().bindAndHandle(
+    tcpHandler,
+    host,
+    port
+  )
+
+  tcp pipeTo self
+}