Formatting logs for /instances/deploy

Author: 24santoshr

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/Docker/DockerActor.scala

@@ -1,15 +1,13 @@
 package de.upb.cs.swt.delphi.instanceregistry.Docker
 
 import akka.actor.{Actor, ActorLogging, ActorSystem, Props, Status}
-import akka.http.scaladsl.model.ws.Message
 import akka.stream.ActorMaterializer
 import de.upb.cs.swt.delphi.instanceregistry.Docker.DockerActor._
 import de.upb.cs.swt.delphi.instanceregistry.Registry
 import de.upb.cs.swt.delphi.instanceregistry.io.swagger.client.model.InstanceEnums.ComponentType
-import org.reactivestreams.Publisher
 
 import scala.concurrent.duration._
-import scala.concurrent.{Await, ExecutionContext, Future}
+import scala.concurrent.{Await, ExecutionContext}
 import scala.util.{Failure, Success, Try}
 
 class DockerActor(connection: DockerConnection) extends Actor with ActorLogging {
@@ -45,7 +43,7 @@ class DockerActor(connection: DockerConnection) extends Actor with ActorLogging
         case Failure(ex) => sender ! Failure(ex)
         case Success(containerResult) =>
           Await.ready(container.start(containerResult.Id), Duration.Inf)
-          log.info(s"Docker Instance created and started")
+          log.debug(s"Docker Instance created and started")
           val containerInfo = Await.result(container.get(containerResult.Id), Duration.Inf)
 
           val instancePort = componentType match {
@@ -55,7 +53,7 @@ class DockerActor(connection: DockerConnection) extends Actor with ActorLogging
             case t => throw new RuntimeException(s"Invalid component type $t, cannot deploy container.")
           }
 
-          log.info("ip address is " + containerInfo.IPAddress)
+          log.debug("ip address is " + containerInfo.IPAddress)
           sender ! Success(containerResult.Id, containerInfo.IPAddress, instancePort)
       }
 

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/Registry.scala

@@ -32,9 +32,7 @@ object Registry extends AppLogging {
 
   def main(args: Array[String]): Unit = {
     requestHandler.initialize()
-    log.info("Starting server ...")
     server.startServer(configuration.bindHost, configuration.bindPort)
-    log.info("Shutting down ...")
     requestHandler.shutdown()
     system.terminate()
   }

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/RequestHandler.scala

@@ -247,7 +247,7 @@ class RequestHandler(configuration: Configuration, instanceDao: InstanceDAO, con
   }
 
   def handleDeploy(componentType: ComponentType, name: Option[String]): Try[Long] = {
-    log.info(s"Deploying container of type $componentType")
+    log.debug(s"Deploying container of type $componentType")
     val instance = Instance(None,
       "",
       -1L,
@@ -275,7 +275,7 @@ class RequestHandler(configuration: Configuration, instanceDao: InstanceDAO, con
             Failure(new RuntimeException(s"Failed to deploy container, docker host not reachable (${ex.getMessage})."))
           case Success((dockerId, host, port)) =>
             val normalizedHost = host.substring(1, host.length - 1)
-            log.info(s"Deployed new container with id $dockerId, host $normalizedHost and port $port.")
+            log.info(s"Deployed new '$componentType' container with id: $dockerId, host: $normalizedHost and port: $port.")
 
             val newInstance = Instance(Some(id),
               normalizedHost,
@@ -291,12 +291,12 @@ class RequestHandler(configuration: Configuration, instanceDao: InstanceDAO, con
 
             instanceDao.updateInstance(newInstance) match {
               case Success(_) =>
-                log.info("Successfully registered.")
+                log.info("Instance successfully registered.")
                 fireInstanceAddedEvent(newInstance)
                 fireNumbersChangedEvent(newInstance.componentType)
                 Success(id)
               case Failure(x) =>
-                log.info(s"Failed to register. Exception: $x")
+                log.warning(s"Failed to register. Exception: $x")
                 Failure(x)
             }
         }

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/connection/Server.scala

@@ -436,7 +436,7 @@ class Server(handler: RequestHandler) extends HttpApp
             val compType: ComponentType = ComponentType.values.find(v => v.toString == compTypeString).orNull
 
             if (compType != null) {
-              log.info(s"Trying to deploy container of type $compType" + (if (name.isDefined) {
+              log.debug(s"Trying to deploy container of type $compType" + (if (name.isDefined) {
                 s" with name ${name.get}..."
               } else {
                 "..."
@@ -453,7 +453,7 @@ class Server(handler: RequestHandler) extends HttpApp
               }
 
             } else {
-              log.error(s"Failed to deserialize parameter string $compTypeString to ComponentType.")
+              log.warning(s"Failed to deserialize parameter string $compTypeString to ComponentType.")
               complete(HttpResponse(StatusCodes.BadRequest, entity = s"Could not deserialize parameter string $compTypeString to ComponentType"))
             }
           case Failure(ex) =>