Merge pull request #721 from ie3-institute/ms/#666-convert-GridAgent-…

…and-DBFSAlgorithm-to-pekko-typed

Convert `GridAgent` & `DBFSAlgorithm` to pekko typed

CHANGELOG.md

@@ -39,6 +39,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Unified consideration of scaling factor when simulating system participants [#81](https://github.com/ie3-institute/simona/issues/81)
 - Small improvements in `ResultEventListener` [#738](https://github.com/ie3-institute/simona/issues/738)
 - Converting `SimonaSim` to pekko typed/terminating SimonSim when initialization fails [#210](https://github.com/ie3-institute/simona/issues/210)
+- Converting the `GridAgent` and the `DBFSAlgorithm` to `pekko typed` [#666](https://github.com/ie3-institute/simona/issues/666)
 
 ### Fixed
 - Removed a repeated line in the documentation of vn_simona config [#658](https://github.com/ie3-institute/simona/issues/658)

src/main/scala/edu/ie3/simona/actor/SimonaActorNaming.scala

@@ -6,7 +6,9 @@
 
 package edu.ie3.simona.actor
 
-import org.apache.pekko.actor.{ActorRef, ActorRefFactory, Props}
+import org.apache.pekko.actor.typed.ActorRef
+import org.apache.pekko.actor.typed.scaladsl.adapter.TypedActorRefOps
+import org.apache.pekko.actor.{ActorRefFactory, Props, ActorRef => ClassicRef}
 
 import java.util.UUID
 
@@ -15,10 +17,10 @@ object SimonaActorNaming {
   implicit class RichActorRefFactory(private val refFactory: ActorRefFactory)
       extends AnyVal {
 
-    def simonaActorOf(props: Props, actorId: String): ActorRef =
+    def simonaActorOf(props: Props, actorId: String): ClassicRef =
       refFactory.actorOf(props, actorName(props, actorId))
 
-    def simonaActorOf(props: Props): ActorRef =
+    def simonaActorOf(props: Props): ClassicRef =
       refFactory.actorOf(props, actorName(props, simonaActorUuid))
   }
 
@@ -62,13 +64,13 @@ object SimonaActorNaming {
   def actorName(typeName: String, actorId: String): String =
     s"${typeName}_${cleanActorIdForPekko(actorId)}"
 
-  /** Extracts the actor name from given [[ActorRef]]. Cluster singletons are
+  /** Extracts the actor name from given [[ClassicRef]]. Cluster singletons are
     * taken care of separately.
     *
     * @return
     *   the actor name extract from the ActorRef
     */
-  def actorName(actorRef: ActorRef): String =
+  def actorName(actorRef: ClassicRef): String =
     actorRef.path.name match {
       case "singleton" =>
         // singletons end in /${actorName}/singleton
@@ -77,6 +79,14 @@ object SimonaActorNaming {
         other
     }
 
+  /** Extracts the actor name from given [[ActorRef]]. Cluster singletons are
+    * taken care of separately.
+    *
+    * @return
+    *   the actor name extract from the ActorRef
+    */
+  def actorName(actorRef: ActorRef[_]): String = actorName(actorRef.toClassic)
+
   /** Constructs the type name from given props.
     *
     * @return

src/main/scala/edu/ie3/simona/agent/EnvironmentRefs.scala

@@ -6,6 +6,7 @@
 
 package edu.ie3.simona.agent
 
+import edu.ie3.simona.event.RuntimeEvent
 import edu.ie3.simona.ontology.messages.SchedulerMessage
 import org.apache.pekko.actor.typed.ActorRef
 import org.apache.pekko.actor.{ActorRef => ClassicRef}
@@ -26,7 +27,7 @@ import org.apache.pekko.actor.{ActorRef => ClassicRef}
   */
 final case class EnvironmentRefs(
     scheduler: ActorRef[SchedulerMessage],
-    runtimeEventListener: ClassicRef,
+    runtimeEventListener: ActorRef[RuntimeEvent],
     primaryServiceProxy: ClassicRef,
     weather: ClassicRef,
     evDataService: Option[ClassicRef],