bot4s · ex0ns · Dec 7, 2025 · Dec 6, 2025 · Dec 7, 2025 · Dec 7, 2025
diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
@@ -21,7 +21,7 @@ jobs:
       - name: Check code format
         uses: jrouly/scalafmt-native-action@v4
         with:
-          arguments: "-c .scalafmt.conf --test core akka examples"
+          arguments: "-c .scalafmt.conf --test core pekko examples"
       - name: Compile
         run: ./mill '_._[_].compile'
       - name: Test

diff --git a/akka/src/com/bot4s/telegram/models/AkkaInputFile.scala b/akka/src/com/bot4s/telegram/models/AkkaInputFile.scala
diff --git a/build.sc b/build.sc
@@ -22,22 +22,22 @@ object library {
     val scalaLogging       = "3.9.5"
     val logback            = "1.5.18"
     val scalajHttp         = "2.4.2"
-    val akkaVersion        = "2.6.20"
-    val akkaActor          = akkaVersion
-    val akkaStream         = akkaVersion
-    val akkaHttp           = "10.5.2"
-    val akkaTestkit        = akkaVersion
-    val akkaHttpCors       = "1.2.0"
+    val pekkoVersion       = "1.3.0"
+    val pekkoActor         = pekkoVersion
+    val pekkoStream        = pekkoVersion
+    val pekkoHttp          = "1.3.0"
+    val pekkoTestkit       = pekkoVersion
+    val pekkoHttpCors      = pekkoHttp
     val hammock            = "0.11.3"
     val monix              = "3.4.1"
     val sbtTesting         = "1.0"
   }
 
-  val akkaHttp        = mvn"com.typesafe.akka::akka-http::${Version.akkaHttp}"
-  val akkaHttpTestkit = mvn"com.typesafe.akka::akka-http-testkit::${Version.akkaHttp}"
-  val akkaTestkit     = mvn"com.typesafe.akka::akka-testkit::${Version.akkaTestkit}"
-  val akkaActor       = mvn"com.typesafe.akka::akka-actor::${Version.akkaActor}"
-  val akkaStream      = mvn"com.typesafe.akka::akka-stream::${Version.akkaStream}"
+  val pekkoHttp        = mvn"org.apache.pekko::pekko-http::${Version.pekkoHttp}"
+  val pekkoHttpTestkit = mvn"org.apache.pekko::pekko-http-testkit::${Version.pekkoHttp}"
+  val pekkoTestkit     = mvn"org.apache.pekko::pekko-testkit::${Version.pekkoTestkit}"
+  val pekkoActor       = mvn"org.apache.pekko::pekko-actor::${Version.pekkoActor}"
+  val pekkoStream      = mvn"org.apache.pekko::pekko-stream::${Version.pekkoStream}"
 
   val asyncHttpClientBackendCats =
     mvn"com.softwaremill.sttp.client4::fs2ce2::${Version.sttp}"
@@ -50,7 +50,7 @@ object library {
   val scalajHttp                  = mvn"org.scalaj::scalaj-http::${Version.scalajHttp}"
   val scalaLogging                = mvn"com.typesafe.scala-logging::scala-logging::${Version.scalaLogging}"
   val scalaMockScalaTest          = mvn"org.scalamock::scalamock::${Version.scalaMockScalaTest}"
-  val akkaHttpCors                = mvn"ch.megard::akka-http-cors::${Version.akkaHttpCors}"
+  val pekkoHttpCors               = mvn"org.apache.pekko::pekko-http-cors::${Version.pekkoHttpCors}"
   val scalaTest                   = mvn"org.scalatest::scalatest::${Version.scalaTest}"
   val sbtTesting                  = mvn"org.scala-sbt:test-interface:${Version.sbtTesting}"
 
@@ -166,19 +166,19 @@ object core extends Module {
 
 }
 
-object akka extends Module {
+object pekko extends Module {
 
-  object jvm extends Cross[AkkaModule](ScalaVersions)
-  trait AkkaModule extends Bot4sTelegramCrossPlatform with Publishable {
+  object jvm extends Cross[pekkoModule](ScalaVersions)
+  trait pekkoModule extends Bot4sTelegramCrossPlatform with Publishable {
     override val platformSegment: String = "jvm"
-    override val location: String        = "akka"
-    override def artifactName            = "telegram-akka"
+    override val location: String        = "pekko"
+    override def artifactName            = "telegram-pekko"
 
     override def mvnDeps = Task {
       super.mvnDeps() ++ Seq(
-        library.akkaActor,
-        library.akkaHttp,
-        library.akkaStream
+        library.pekkoActor,
+        library.pekkoHttp,
+        library.pekkoStream
       )
     }
 
@@ -189,8 +189,8 @@ object akka extends Module {
 
       override def mvnDeps = Task {
         super.mvnDeps() ++ Seq(
-          library.akkaTestkit,
-          library.akkaHttpTestkit
+          library.pekkoTestkit,
+          library.pekkoHttpTestkit
         )
       }
     }
@@ -216,12 +216,12 @@ object examples extends Module {
 
     override def mvnDeps = Task {
       super.mvnDeps() ++ Seq(
-        library.akkaHttpCors,
+        library.pekkoHttpCors,
         library.sttpOkHttp
       ) ++ versionDependencies()
     }
 
-    override def moduleDeps = super.moduleDeps ++ Seq(core.jvm(), akka.jvm())
+    override def moduleDeps = super.moduleDeps ++ Seq(core.jvm(), pekko.jvm())
   }
 
   object catsjvm extends Cross[ExamplesCatsModule](ScalaVersions)

diff --git a/examples/src-jvm-2/AkkaExampleBot.scala b/examples/src-jvm-2/AkkaExampleBot.scala
diff --git a/examples/src-jvm-2/GitHubHosted2048Bot.scala b/examples/src-jvm-2/GitHubHosted2048Bot.scala
@@ -1,15 +1,14 @@
-import akka.http.scaladsl.model.Uri
-import akka.http.scaladsl.model.Uri.{ Path, Query }
-import akka.http.scaladsl.model.headers.HttpOrigin
-import akka.http.scaladsl.server.RouteConcatenation._
-import akka.http.scaladsl.server.Route
-
-import ch.megard.akka.http.cors.scaladsl.model.HttpOriginMatcher
+import org.apache.pekko.http.scaladsl.model.Uri
+import org.apache.pekko.http.scaladsl.model.Uri.{ Path, Query }
+import org.apache.pekko.http.scaladsl.model.headers.HttpOrigin
+import org.apache.pekko.http.scaladsl.server.RouteConcatenation._
+import org.apache.pekko.http.scaladsl.server.Route
+import org.apache.pekko.http.cors.scaladsl.settings.CorsSettings
+import org.apache.pekko.http.cors.scaladsl.model.HttpOriginMatcher
+import org.apache.pekko.http.cors.scaladsl.CorsDirectives._
 
 import cats.instances.future._
 import cats.syntax.functor._
-import ch.megard.akka.http.cors.scaladsl.CorsDirectives.cors
-import ch.megard.akka.http.cors.scaladsl.settings.CorsSettings
 import com.bot4s.telegram.api.declarative.{ Callbacks, Commands }
 import com.bot4s.telegram.api.{ GameManager, Payload }
 import com.bot4s.telegram.future.Polling
@@ -48,7 +47,7 @@ import scala.concurrent.Future
  * @param gameManagerHost Base URL of the game manager.
  */
 class GitHubHosted2048Bot(token: String, gameManagerHost: String)
-    extends AkkaExampleBot(token)
+    extends PekkoExampleBot(token)
     with Polling
     with Commands[Future]
     with Callbacks[Future]

diff --git a/examples/src-jvm-2/LmgtfyBot.scala b/examples/src-jvm-2/LmgtfyBot.scala
@@ -1,5 +1,5 @@
-import akka.http.scaladsl.model.Uri
-import akka.http.scaladsl.model.Uri.Query
+import org.apache.pekko.http.scaladsl.model.Uri
+import org.apache.pekko.http.scaladsl.model.Uri.Query
 import cats.instances.future._
 import cats.syntax.functor._
 import com.bot4s.telegram.Implicits._

diff --git a/examples/src-jvm-2/PekkoExampleBot.scala b/examples/src-jvm-2/PekkoExampleBot.scala
@@ -0,0 +1,6 @@
+import com.bot4s.telegram.api.PekkoTelegramBot
+import com.bot4s.telegram.clients.PekkoHttpClient
+
+abstract class PekkoExampleBot(val token: String) extends PekkoTelegramBot {
+  override val client = new PekkoHttpClient(token)
+}
diff --git a/examples/src-jvm-2/PerChatRequestsBot.scala b/examples/src-jvm-2/PerChatRequestsBot.scala
@@ -1,15 +1,15 @@
-import akka.actor.{ Actor, ActorRef, Props, Terminated }
+import org.apache.pekko.actor.{ Actor, ActorRef, Props, Terminated }
 import cats.syntax.functor._
 import cats.instances.future._
 import com.bot4s.telegram.api.declarative.Commands
-import com.bot4s.telegram.api.{ ActorBroker, AkkaDefaults }
+import com.bot4s.telegram.api.{ ActorBroker, PekkoDefaults }
 import com.bot4s.telegram.future.Polling
 import com.bot4s.telegram.methods.SendMessage
 import com.bot4s.telegram.models.{ Message, Update }
 
 import scala.concurrent.Future
 
-trait PerChatRequests extends ActorBroker with AkkaDefaults {
+trait PerChatRequests extends ActorBroker with PekkoDefaults {
 
   override val broker = Some(system.actorOf(Props(new Broker), "broker"))
 

diff --git a/examples/src-jvm-2/PollingWithWebRoutes.scala b/examples/src-jvm-2/PollingWithWebRoutes.scala
@@ -13,7 +13,7 @@ import scala.concurrent.Future
  * and even serving entire websites.
  */
 class PollingWithWebRoutes(token: String)
-    extends AkkaExampleBot(token)
+    extends PekkoExampleBot(token)
     with Polling
     with WebRoutes
     with Commands[Future] {
@@ -24,7 +24,7 @@ class PollingWithWebRoutes(token: String)
     reply("Hello").void
   }
 
-  import akka.http.scaladsl.server.Directives._
+  import org.apache.pekko.http.scaladsl.server.Directives._
 
   override def routes = pathEndOrSingleSlash {
     complete("I'm running...")

diff --git a/examples/src-jvm-2/QrCodesBot.scala b/examples/src-jvm-2/QrCodesBot.scala
@@ -1,22 +1,22 @@
 import java.net.URLEncoder
 
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model.{ HttpRequest, Uri }
-import akka.http.scaladsl.unmarshalling.Unmarshal
-import akka.util.ByteString
+import org.apache.pekko.http.scaladsl.Http
+import org.apache.pekko.http.scaladsl.model.{ HttpRequest, Uri }
+import org.apache.pekko.http.scaladsl.unmarshalling.Unmarshal
+import org.apache.pekko.util.ByteString
 import com.bot4s.telegram.api.declarative.Commands
 import com.bot4s.telegram.api._
 import com.bot4s.telegram.future.Polling
 import com.bot4s.telegram.methods._
-import com.bot4s.telegram.models.AkkaInputFile
+import com.bot4s.telegram.models.PekkoInputFile
 
 import scala.concurrent.Future
 
 /**
  * Generates QR codes from text/url.
  */
 class QrCodesBot(token: String)
-    extends AkkaExampleBot(token)
+    extends PekkoExampleBot(token)
     with Polling
     with Commands[Future]
     with ChatActions[Future] {
@@ -31,7 +31,7 @@ class QrCodesBot(token: String)
         response <- Http().singleRequest(HttpRequest(uri = Uri(url)))
         if response.status.isSuccess()
         bytes <- Unmarshal(response).to[ByteString]
-        photo  = AkkaInputFile("qrcode.png", bytes)
+        photo  = PekkoInputFile("qrcode.png", bytes)
         _     <- uploadingPhoto // Hint the user
         _     <- request(SendPhoto(msg.source, photo))
       } yield ()

diff --git a/examples/src-jvm-2/SelfHosted2048Bot.scala b/examples/src-jvm-2/SelfHosted2048Bot.scala
@@ -1,12 +1,12 @@
-import akka.http.scaladsl.model.Uri
-import akka.http.scaladsl.model.Uri.{ Path, Query }
-import akka.http.scaladsl.server.Directives.{ getFromResourceDirectory, pathPrefix }
-import akka.http.scaladsl.server.Route
-import akka.http.scaladsl.server.RouteConcatenation._
+import org.apache.pekko.http.scaladsl.model.Uri
+import org.apache.pekko.http.scaladsl.model.Uri.{ Path, Query }
+import org.apache.pekko.http.scaladsl.server.Directives.{ getFromResourceDirectory, pathPrefix }
+import org.apache.pekko.http.scaladsl.server.Route
+import org.apache.pekko.http.scaladsl.server.RouteConcatenation._
 import cats.instances.future._
 import cats.syntax.functor._
 import com.bot4s.telegram.api.declarative.{ Callbacks, Commands }
-import com.bot4s.telegram.api.{ AkkaDefaults, GameManager, Payload }
+import com.bot4s.telegram.api.{ GameManager, Payload, PekkoDefaults }
 import com.bot4s.telegram.future.Polling
 import com.bot4s.telegram.methods.SendGame
 
@@ -35,7 +35,7 @@ import scala.concurrent.Future
 class SelfHosted2048Bot(token: String, gameManagerHost: String)
     extends ExampleBot(token)
     with Polling
-    with AkkaDefaults
+    with PekkoDefaults
     with Callbacks[Future]
     with GameManager
     with Commands[Future] {

diff --git a/examples/src-jvm-2/SpotifyBot.scala b/examples/src-jvm-2/SpotifyBot.scala
@@ -1,9 +1,9 @@
 import java.net.URLEncoder
 
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model._
-import akka.http.scaladsl.model.headers.{ Authorization, BasicHttpCredentials }
-import akka.http.scaladsl.unmarshalling.Unmarshal
+import org.apache.pekko.http.scaladsl.Http
+import org.apache.pekko.http.scaladsl.model._
+import org.apache.pekko.http.scaladsl.model.headers.{ Authorization, BasicHttpCredentials }
+import org.apache.pekko.http.scaladsl.unmarshalling.Unmarshal
 import cats.instances.future._
 import cats.syntax.functor._
 import com.bot4s.telegram.future.Polling
@@ -22,7 +22,7 @@ import scala.concurrent.Future
  * The provided clientId/secret are not guaranteed to work forever.
  * See [[https://developer.spotify.com/web-api/authorization-guide/]]
  */
-class SpotifyBot(token: String) extends AkkaExampleBot(token) with Polling {
+class SpotifyBot(token: String) extends PekkoExampleBot(token) with Polling {
 
   val limit = 10
 

diff --git a/examples/src-jvm-2/VoiceFileBot.scala b/examples/src-jvm-2/VoiceFileBot.scala
@@ -1,7 +1,7 @@
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model.{ HttpRequest, Uri }
-import akka.http.scaladsl.unmarshalling.Unmarshal
-import akka.util.ByteString
+import org.apache.pekko.http.scaladsl.Http
+import org.apache.pekko.http.scaladsl.model.{ HttpRequest, Uri }
+import org.apache.pekko.http.scaladsl.unmarshalling.Unmarshal
+import org.apache.pekko.util.ByteString
 import cats.instances.future._
 import cats.syntax.functor._
 import com.bot4s.telegram.api.declarative.Commands
@@ -14,7 +14,7 @@ import scala.util.{ Failure, Success }
 /**
  * This bot receives voice recordings and outputs the file size.
  */
-class VoiceFileBot(token: String) extends AkkaExampleBot(token) with Polling with Commands[Future] {
+class VoiceFileBot(token: String) extends PekkoExampleBot(token) with Polling with Commands[Future] {
 
   onMessage { implicit msg =>
     using(_.voice) { voice =>

diff --git a/examples/src-jvm-2/WebhookBot.scala b/examples/src-jvm-2/WebhookBot.scala
@@ -1,8 +1,8 @@
 import java.net.URLEncoder
 
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model.{ HttpRequest, Uri }
-import akka.http.scaladsl.unmarshalling.Unmarshal
+import org.apache.pekko.http.scaladsl.Http
+import org.apache.pekko.http.scaladsl.model.{ HttpRequest, Uri }
+import org.apache.pekko.http.scaladsl.unmarshalling.Unmarshal
 import com.bot4s.telegram.api.Webhook
 import com.bot4s.telegram.methods._
 import com.bot4s.telegram.models.Message
@@ -13,7 +13,7 @@ import scala.concurrent.Future
  * Webhook-backed JS calculator.
  * To test Webhooks locally, use an SSH tunnel or ngrok.
  */
-class WebhookBot(token: String) extends AkkaExampleBot(token) with Webhook {
+class WebhookBot(token: String) extends PekkoExampleBot(token) with Webhook {
 
   val port       = 8080
   val webhookUrl = "https://88c444ab.ngrok.io"

diff --git a/examples/src-jvm-2/WebhookSSLBot.scala b/examples/src-jvm-2/WebhookSSLBot.scala
@@ -1,21 +1,21 @@
 import java.net.URLEncoder
 
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model.{ HttpRequest, Uri }
-import akka.http.scaladsl.unmarshalling.Unmarshal
+import org.apache.pekko.http.scaladsl.Http
+import org.apache.pekko.http.scaladsl.model.{ HttpRequest, Uri }
+import org.apache.pekko.http.scaladsl.unmarshalling.Unmarshal
 import com.bot4s.telegram.api.Webhook
 import com.bot4s.telegram.methods._
 import com.bot4s.telegram.models.Message
 
 import scala.concurrent.Future
 import com.bot4s.telegram.models.InputFile
 import java.io.File
-import akka.http.scaladsl.HttpsConnectionContext
+import org.apache.pekko.http.scaladsl.HttpsConnectionContext
 import java.security.KeyStore
 import javax.net.ssl.KeyManagerFactory
 import javax.net.ssl.TrustManagerFactory
 import javax.net.ssl.SSLContext
-import akka.http.scaladsl.ConnectionContext
+import org.apache.pekko.http.scaladsl.ConnectionContext
 import java.security.SecureRandom
 
 /**
@@ -34,7 +34,7 @@ import java.security.SecureRandom
  *
  * Replace XXXX with your bot's key
  */
-class WebhookSSLBot(token: String) extends AkkaExampleBot(token) with Webhook {
+class WebhookSSLBot(token: String) extends PekkoExampleBot(token) with Webhook {
 
   val port       = 8080
   val webhookUrl = "https://domain.extension:8443"

diff --git a/.../com/bot4s/telegram/api/ActorBroker.scala → .../com/bot4s/telegram/api/ActorBroker.scala b/.../com/bot4s/telegram/api/ActorBroker.scala → .../com/bot4s/telegram/api/ActorBroker.scala
@@ -1,6 +1,6 @@
 package com.bot4s.telegram.api
 
-import akka.actor.ActorRef
+import org.apache.pekko.actor.ActorRef
 import com.bot4s.telegram.models.{ Update, User }
 
 import scala.concurrent.Future