Extract akka/pekko dependencies to project

To minimize duplication:
 - Introduce neutral aliases for Akka actor dependencies
 - Pull in akka or pekko dependencies based on a build parameter
 - Publish pekko variants of all modules
 - Add pekko based permutations to integration test matrix

Author: SamTheisens

.circleci/config.yml

@@ -37,6 +37,9 @@ commands:
       scala_version:
         type: string
         default: "2.13.8"
+      actor_module:
+        type: string
+        default: "akka"
       shaded:
         type: boolean
         default: true
@@ -258,6 +261,9 @@ jobs:
       scala_version:
         type: string
         default: "2.13.8"
+      actor_module:
+        type: string
+        default: "akka"
       shaded:
         type: boolean
         default: true
@@ -276,6 +282,7 @@ jobs:
       - build_n_tests:
           jdk_version: << parameters.jdk_version >>
           scala_version: << parameters.scala_version >>
+          actor_module: << parameters.actor_module >>
           shaded: << parameters.shaded >>
           category: UNIT_TESTS
 
@@ -296,6 +303,9 @@ jobs:
       akka_version:
         type: string
         default: "2.5.23"
+      actor_module:
+        type: string
+        default: "akka"
       shaded:
         type: boolean
         default: true
@@ -316,6 +326,7 @@ jobs:
 
     environment:
       AKKA_VERSION: << parameters.akka_version >>
+      ACTOR_MODULE: << parameters.actor_module >>
       MONGO_PROFILE: << parameters.mongo_profile >>
       MONGO_VER: << parameters.mongo_version >>
       OS_NAME: linux
@@ -333,6 +344,7 @@ jobs:
                     echo "Shaded? << parameters.shaded >>"
                     echo "Compressor: << parameters.compressor>>"
                     echo "Akka: version=$AKKA_VERSION"
+                    echo "Actor module: $ACTOR_MODULE"
 
       - setup_integration:
           mongo_version: $MONGO_VER
@@ -345,6 +357,7 @@ jobs:
           jdk_version: openjdk<< parameters.openjdk_version >>
           scala_version: << parameters.scala_version >>
           shaded: << parameters.shaded >>
+          actor_module: << parameters.actor_module >>
           compressor: << parameters.compressor >>
 
       - collect_test_reports
@@ -414,6 +427,15 @@ workflows:
           jdk_version: openjdk10
           scala_version: 2.12.18
 
+      - unit_test_suite:
+          name: unit_linux_openjdk10_scala212_pekko
+          e:
+            name: openjdk
+            version: 10
+          jdk_version: openjdk10
+          scala_version: 2.12.18
+          actor_module: pekko
+
       - integration_test_suite:
           name: mongo3_openjdk8_scala211_akka23
           openjdk_version: 8
@@ -435,6 +457,12 @@ workflows:
           mongo_profile: x509
           scala_version: 2.13.8
 
+      - integration_test_suite:
+          name: mongo5_openjdk10_scala213_pekko_x509
+          mongo_version: 5
+          scala_version: 2.13.8
+          actor_module: pekko
+
       - integration_test_suite:
           name: mongo6_openjdk11_scala31_akka26
           scala_version: '3.2.2'
@@ -443,6 +471,14 @@ workflows:
           mongo_version: 6
           compressor: zstd
 
+      - integration_test_suite:
+          name: mongo6_openjdk11_scala31_pekko
+          scala_version: '3.2.2'
+          actor_module: pekko
+          openjdk_version: 11
+          mongo_version: 6
+          compressor: zstd
+
       - integration_test_suite:
           name: mongo5_openjdk10_scala212_akka25_invalidssl
           mongo_version: 5
@@ -512,6 +548,9 @@ workflows:
             - mongo4_openjdk10_scala211_akka25_mutualssl
             - mongo5_openjdk11_scala211_akka25_rs
             - mongo5_openjdk10_scala211_akka25_x509
+            - unit_linux_openjdk10_scala212_pekko
+            - mongo5_openjdk10_scala213_pekko_x509
+            - mongo6_openjdk11_scala31_pekko
 
       - trigger_dependent_builds:
           filters:

README.md

@@ -31,7 +31,7 @@ Then go to the `ReactiveMongo` directory and launch the SBT build console:
 ```
 $ cd ReactiveMongo
 $ sbt
-> +publish-local
+> +publishLocal
 ```
 
 *Running tests:*

actors-akka/src/main/scala/reactivemongo/actors/actor/package.scala

@@ -0,0 +1,16 @@
+package reactivemongo.actors
+
+package object actor {
+  type ActorSystem = akka.actor.ActorSystem
+  val ActorSystem = akka.actor.ActorSystem
+
+  type ActorRef = akka.actor.ActorRef
+  type Actor = akka.actor.Actor
+  val Actor = akka.actor.Actor
+
+  type Props = akka.actor.Props
+  val Props = akka.actor.Props
+  type Terminated = akka.actor.Terminated
+  type Cancellable = akka.actor.Cancellable
+
+}

actors-akka/src/main/scala/reactivemongo/actors/pattern/ask/package.scala

@@ -0,0 +1,16 @@
+package reactivemongo.actors.pattern
+
+import akka.pattern.{
+  AskSupport,
+  FutureTimeoutSupport,
+  GracefulStopSupport,
+  PipeToSupport,
+  RetrySupport
+}
+
+package object ask
+    extends PipeToSupport
+    with AskSupport
+    with GracefulStopSupport
+    with FutureTimeoutSupport
+    with RetrySupport

actors-akka/src/main/scala/reactivemongo/actors/pattern/package.scala

@@ -0,0 +1,5 @@
+package reactivemongo.actors
+
+import akka.pattern.FutureTimeoutSupport
+
+package object pattern extends FutureTimeoutSupport

actors-akka/src/main/scala/reactivemongo/actors/util/package.scala

@@ -0,0 +1,15 @@
+package reactivemongo.actors
+
+import akka.util.{
+  ByteString => PekkoByteString,
+  Timeout => PekkoTimeout
+}
+
+package object util {
+  type Timeout = PekkoTimeout
+  val Timeout = PekkoTimeout
+
+  type ByteString = PekkoByteString
+  val ByteString = PekkoByteString
+
+}

actors-akka/src/test/scala/reactivemongo/actors/testkit/package.scala

@@ -0,0 +1,9 @@
+package reactivemongo.actors
+
+import akka.actor.Actor
+import akka.testkit.{ TestActorRef => PekkoTestActorRef }
+
+package object testkit {
+  type TestActorRef[T <: Actor] = PekkoTestActorRef[T]
+  val TestActorRef = PekkoTestActorRef
+}

actors-pekko/src/main/scala/reactivemongo/actors/actor/package.scala

@@ -0,0 +1,16 @@
+package reactivemongo.actors
+
+package object actor {
+  type ActorSystem = org.apache.pekko.actor.ActorSystem
+  val ActorSystem = org.apache.pekko.actor.ActorSystem
+
+  type ActorRef = org.apache.pekko.actor.ActorRef
+  type Actor = org.apache.pekko.actor.Actor
+  val Actor = org.apache.pekko.actor.Actor
+
+  type Props = org.apache.pekko.actor.Props
+  val Props = org.apache.pekko.actor.Props
+  type Terminated = org.apache.pekko.actor.Terminated
+  type Cancellable = org.apache.pekko.actor.Cancellable
+
+}

actors-pekko/src/main/scala/reactivemongo/actors/pattern/ask/package.scala

@@ -0,0 +1,10 @@
+package reactivemongo.actors.pattern
+
+import org.apache.pekko.pattern.{AskSupport, FutureTimeoutSupport, GracefulStopSupport, PipeToSupport, RetrySupport}
+
+package object ask
+    extends PipeToSupport
+    with AskSupport
+    with GracefulStopSupport
+    with FutureTimeoutSupport
+    with RetrySupport

actors-pekko/src/main/scala/reactivemongo/actors/pattern/package.scala

@@ -0,0 +1,5 @@
+package reactivemongo.actors
+
+import org.apache.pekko.pattern.FutureTimeoutSupport
+
+package object pattern extends FutureTimeoutSupport