Replaced akka with pekko

Author: phearnot

build.sbt

@@ -185,7 +185,7 @@ inScope(Global)(
     testOptions += Tests.Setup(_ => sys.props("sbt-testing") = "true"),
     network         := Network.default(),
     instrumentation := false,
-    resolvers ++= Resolver.sonatypeOssRepos("releases") ++ Resolver.sonatypeOssRepos("snapshots") ++ Seq(Resolver.mavenLocal, "Akka library repository".at("https://repo.akka.io/maven")),
+    resolvers ++= Resolver.sonatypeOssRepos("releases") ++ Resolver.sonatypeOssRepos("snapshots") ++ Seq(Resolver.mavenLocal),
     Compile / packageDoc / publishArtifact := false,
     concurrentRestrictions                 := Seq(Tags.limit(Tags.Test, math.min(EvaluateTask.SystemProcessors, 8))),
     excludeLintKeys ++= Set(

grpc-server/src/main/scala/com/wavesplatform/events/BlockchainUpdates.scala

@@ -28,7 +28,7 @@ class BlockchainUpdates(private val context: Context) extends Extension with Sco
     "blockchain-updates",
     UncaughtExceptionReporter(err => log.error("Uncaught exception in BlockchainUpdates scheduler", err)),
     ExecutionModel.Default,
-    rejectedExecutionHandler = new akka.dispatch.SaneRejectedExecutionHandler
+    rejectedExecutionHandler = new org.apache.pekko.dispatch.SaneRejectedExecutionHandler
   )
   private val rdb  = RocksDB.open(context.settings.directory + "/blockchain-updates")
   private val repo = new Repo(rdb, context.blocksApi)

node-generator/src/main/scala/com/wavesplatform/generator/Worker.scala

@@ -17,7 +17,7 @@ import monix.execution.Scheduler
 import org.asynchttpclient.AsyncHttpClient
 import play.api.libs.json.Json
 
-import scala.compat.java8.FutureConverters
+import scala.jdk.javaapi.FutureConverters
 import scala.concurrent.duration.FiniteDuration
 import scala.concurrent.{ExecutionContext, Future}
 
@@ -56,7 +56,7 @@ class Worker(
     import org.asynchttpclient.Dsl.*
     val request = get(s"$nodeRestAddress/transactions/unconfirmed/size").build()
     Task
-      .fromFuture(FutureConverters.toScala(httpClient.executeRequest(request).toCompletableFuture))
+      .fromFuture(FutureConverters.asScala(httpClient.executeRequest(request).toCompletableFuture))
       .map(r => math.max(settings.utxLimit - (Json.parse(r.getResponseBody) \ "size").as[Int], 0))
   }
 
@@ -67,7 +67,7 @@ class Worker(
         val results = richAccountAddresses.map { address =>
           val request = get(s"$nodeRestAddress/addresses/balance/$address").build()
           Task
-            .fromFuture(FutureConverters.toScala(httpClient.executeRequest(request).toCompletableFuture))
+            .fromFuture(FutureConverters.asScala(httpClient.executeRequest(request).toCompletableFuture))
             .map(r => address -> (Json.parse(r.getResponseBody) \ "balance").as[Long])
         }
         Task.parSequence(results).map(_.toMap)

node-it/src/test/resources/template.conf

@@ -109,7 +109,7 @@ waves {
   }
 }
 
-akka.actor.debug {
+pekko.actor.debug {
   lifecycle = on
   unhandled = on
 }

node-it/src/test/scala/com/wavesplatform/it/api/SyncHttpApi.scala

@@ -1,8 +1,8 @@
 package com.wavesplatform.it.api
 
 import java.net.InetSocketAddress
-import akka.http.scaladsl.model.StatusCodes.BadRequest
-import akka.http.scaladsl.model.{StatusCode, StatusCodes}
+import org.apache.pekko.http.scaladsl.model.StatusCodes.BadRequest
+import org.apache.pekko.http.scaladsl.model.{StatusCode, StatusCodes}
 import com.wavesplatform.account.{AddressOrAlias, KeyPair, SeedKeyPair}
 import com.wavesplatform.api.http.RewardApiRoute.RewardStatus
 import com.wavesplatform.api.http.requests.IssueRequest

node-it/src/test/scala/com/wavesplatform/it/async/BlockSizeConstraintsSuite.scala

@@ -43,7 +43,7 @@ object BlockSizeConstraintsSuite {
   private val maxTxsGroup     = 500 // More, than 1mb of block
   private val maxGroups       = 9
   private val txsInMicroBlock = 500
-  private val ConfigOverrides = ConfigFactory.parseString(s"""akka.http.server {
+  private val ConfigOverrides = ConfigFactory.parseString(s"""pekko.http.server {
                                                              |  parsing.max-content-length = 3737439
                                                              |  request-timeout = 60s
                                                              |}

node-it/src/test/scala/com/wavesplatform/it/async/WideStateGenerationSuite.scala

@@ -15,7 +15,7 @@ class WideStateGenerationSuite extends BaseFreeSpec with WaitForHeight2 with Tra
 
   override protected def createDocker: Docker = new Docker(
     suiteConfig = ConfigFactory.parseString(
-      """akka.http.server {
+      """pekko.http.server {
         |  parsing.max-content-length = 3737439
         |  request-timeout = 60s
         |}

node-it/src/test/scala/com/wavesplatform/it/sync/transactions/SetAssetScriptTransactionSuite.scala

@@ -1,6 +1,6 @@
 package com.wavesplatform.it.sync.transactions
 
-import akka.http.scaladsl.model.StatusCodes
+import org.apache.pekko.http.scaladsl.model.StatusCodes
 import com.wavesplatform.account.KeyPair
 import com.wavesplatform.api.http.ApiError.{Mistiming, StateCheckFailed, WrongJson}
 import com.wavesplatform.common.state.ByteStr

node/src/main/resources/application.conf

@@ -379,11 +379,11 @@ waves {
 
 # WARNING: No user-configurable settings below this line.
 
-akka {
+pekko {
   daemonic = on
   loglevel = "INFO"
-  loggers = ["akka.event.slf4j.Slf4jLogger"]
-  logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
+  loggers = ["org.apache.pekko.event.slf4j.Slf4jLogger"]
+  logging-filter = "org.apache.pekko.event.slf4j.Slf4jLoggingFilter"
   log-dead-letters-during-shutdown = false
 
   http.server {

node/src/main/resources/network-defaults.conf

@@ -114,7 +114,7 @@ waves.defaults {
       enable = yes
       metric.tick-interval = 5s
       util.filters {
-        "akka.tracked-dispatcher" {
+        "pekko.tracked-dispatcher" {
           includes = [
             "wavesplatform/**"
           ]