stopped using println and using logger instead

Author: janniclas

app/actors/ClientSocketActor.scala

@@ -3,6 +3,7 @@ import akka.actor._
 import actors.PublishSocketMessageActor.{AddOutActor, PublishMessage, StopMessage}
 import models.EventEnums.EventType
 import models.{EventJsonSupport, SocketMessage}
+import play.api.Logger
 import spray.json._
 
 import scala.collection.mutable.HashSet
@@ -22,12 +23,12 @@ class ClientSocketActor(out: ActorRef, publisher: ActorRef) extends Actor with E
   implicit val messageWrites: Writes[SocketMessage] = Json.writes[SocketMessage]
 
   override def preStart() {
-    println("pre start called in client", self)
+    Logger.debug("pre start called in client" + self)
     out ! "successfully registered"
   }
 
   override def postStop() {
-    println("post stop called in client", self)
+    Logger.debug("post stop called in client" + self)
     publisher ! StopMessage(self)
   }
 
@@ -36,9 +37,9 @@ class ClientSocketActor(out: ActorRef, publisher: ActorRef) extends Actor with E
       val json = Json.parse(msg)
       val result = json.validate[SocketMessage]
       result.fold(
-        errors => {println("error parsing message to json", msg)},
+        errors => {Logger.error("error parsing message to json" + msg + " with error " + errors)},
         socketMsg => {
-          println("successfully parsed socket message", socketMsg)
+          Logger.debug("successfully parsed socket message" + socketMsg)
           if (socketMsg.event == EventType.Heartbeat) {
             out ! "Heartbeat"
           } else {
@@ -48,14 +49,14 @@ class ClientSocketActor(out: ActorRef, publisher: ActorRef) extends Actor with E
       )
 
     case SocketMessage(event, payload) =>
-      println("received socket message in client", SocketMessage)
+      Logger.debug("received socket message in client" + SocketMessage)
       if (!myEvents.contains(event)) {
         myEvents += event
         publisher ! AddOutActor(self, event)
       }
 
     case PublishMessage(msg) =>
-      println("received publish message in client", self)
+      Logger.debug("received publish message in client" + self)
       out ! msg.toJson(eventFormat).toString()
   }
 

app/actors/PublishSocketMessageActor.scala

@@ -7,6 +7,7 @@ import akka.stream.Materializer
 import akka.stream.scaladsl.{Flow, Keep, Sink, Source}
 import models.EventEnums.EventType
 import models.{EventJsonSupport, RegistryEvent}
+import play.api.Logger
 import spray.json._
 
 import scala.collection.mutable
@@ -25,15 +26,16 @@ class PublishSocketMessageActor(irBasePath: String, mat: Materializer, actorSys:
   val eventActorMap: mutable.HashMap[EventType, ListBuffer[ActorRef]] = new mutable.HashMap[EventType, ListBuffer[ActorRef]]()
 
   override def preStart() {
-    println("pre start called in publisher", self)
+
+    Logger.debug("pre start called in publisher" + self)
     val flow: Flow[Message, Message, Promise[Option[Message]]] =
       Flow.fromSinkAndSourceMat(
         Sink.foreach[Message]{ msg =>
           self ! msg},
         Source(List(TextMessage("one"), TextMessage("two")))
           .concatMat(Source.maybe[Message])(Keep.right))(Keep.right)
 
-    val (upgradeResponse, promise) =
+
       Http()(actorSys).singleWebSocketRequest(
         WebSocketRequest("ws://" + irBasePath + "/events"),
         flow)(mat)
@@ -42,36 +44,35 @@ class PublishSocketMessageActor(irBasePath: String, mat: Materializer, actorSys:
   }
 
   override def postStop() {
-    println("post stop called in publisher", self)
+    Logger.debug("post stop called in publisher" + self)
   }
 
   def receive: PartialFunction[Any, Unit] = {
 
     case StopMessage(toStop) =>
-      println("stop received", toStop)
+      Logger.debug("stop received" + toStop)
       for ((k, v) <- eventActorMap) v -= toStop
 
     case AddOutActor(out, event) =>
-      println("received add out actor", out)
+      Logger.debug("received add out actor" + out)
       if (!eventActorMap.contains(event)){
         eventActorMap += (event -> new ListBuffer[ActorRef]())
       }
       eventActorMap(event) += out
 
 
     case TextMessage.Strict(msg) =>
-      println("received something ", msg)
+      Logger.debug("received something " + msg)
       val registryEvent = msg.parseJson.convertTo[RegistryEvent](eventFormat)
       self ! PublishMessage(registryEvent)
 
     case PublishMessage(msg) =>
-      println("publish message called with message", msg)
+      Logger.debug("publish message called with message" + msg)
       if(eventActorMap.contains(msg.eventType)){
 
         val list = eventActorMap(msg.eventType)
-        println("found list in actor map for msg", list)
-        list.foreach((actor) => {
-          println("sending message to actor", actor)
+        list.foreach(actor => {
+          Logger.debug("sending message to actor" + actor)
           actor ! PublishMessage(msg)
         })
       }

app/controllers/InstanceRegistryController.scala

@@ -19,21 +19,16 @@
 package controllers
 
 import akka.actor.{ActorRef, ActorSystem}
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model.ws.{Message, TextMessage, WebSocketRequest}
 import javax.inject.Inject
 import play.api.Configuration
 
-import scala.concurrent.{ExecutionContext, Promise}
+import scala.concurrent.ExecutionContext
 import play.api.libs.concurrent.CustomExecutionContext
 import play.api.libs.ws.WSClient
-import play.api.mvc._
 import akka.stream.Materializer
-import akka.stream.scaladsl.{Flow, Keep, Sink, Source}
 import play.api.libs.streams.ActorFlow
 import actors.{ClientSocketActor, PublishSocketMessageActor}
-
-import play.api.mvc.{Action, AnyContent, BaseController, ControllerComponents}
+import play.api.mvc._
 
 
 trait MyExecutionContext extends ExecutionContext