follow up with maintainers of externally maintained alpakka connectors

[pjfanning]

• see https://doc.akka.io/docs/alpakka/current/external/
• 3 of those are Akka maintained and we have Pekko equivalents (gRPC, TCP, HTTP)
• the others are not maintained by Lightbend and there is no Pekko team equivalent
• we could raise issues with the lib owners when Pekko snapshots are ready

[jtjeferreira]

I have used the following code to use source generators and search/replace on the imports to publish the same library for akka and pekko:

import sbt._

object PekkoMigration {
  def generatePekkoSourcesFromAkka(scalaSourceDirectory: File, sourceManagedDir: File): Seq[File] = {
    val scalaFiles: PathFinder = scalaSourceDirectory ** "*.scala"
    //collect the files
    val filesToBeCopied: Seq[(File, File)] = scalaFiles.get().map { f =>
      val Some(relative) = scalaSourceDirectory.relativize(f)
      val target: File = sourceManagedDir / relative.toPath.toString
      (f, target)
    }
    //copy the files
    val copiedFiles = IO.copy(filesToBeCopied).toSeq
    //rewrite imports
    copiedFiles.map { f =>
      val modifiedLines = IO.readLines(f).map {
        case l if l.startsWith("import akka.stream.alpakka") =>
          l.replaceFirst("import akka.stream.alpakka", "import org.apache.pekko.stream.connectors")
        case l if l.startsWith("import akka") =>
          l.replaceFirst("import akka", "import org.apache.pekko")
        case l => l
      }
      IO.writeLines(f, modifiedLines)
      f
    }
  }
}

and then you can use it like this

    Compile / sourceGenerators += Def.task {
      PekkoMigration.generatePekkoSourcesFromAkka((AKKA_PROJECT / Compile / scalaSource).value, (Compile / sourceManaged).value)
    }.taskValue

It is not very fancy (i.e it does not use scalafix) but gets the job done for small libs

[pjfanning]

with the Kinesis alternatives, I've logged issues in those projects

• Pekko implementation? 500px/kinesis-stream#15
• Pekko implementation? StreetContxt/kcl-akka-stream#191