Search/replace akka-http to pekko-http

Author: blast-hardcheese

modules/scala-pekko-http/src/main/resources/META-INF/services/dev.guardrail.generators.spi.ClientGeneratorLoader

@@ -1 +1 @@
-dev.guardrail.generators.scala.akkaHttp.AkkaHttpClientGeneratorLoader
+dev.guardrail.generators.scala.pekkoHttp.PekkoHttpClientGeneratorLoader

modules/scala-pekko-http/src/main/resources/META-INF/services/dev.guardrail.generators.spi.FrameworkGeneratorLoader

@@ -1 +1 @@
-dev.guardrail.generators.scala.akkaHttp.AkkaHttpGeneratorLoader
+dev.guardrail.generators.scala.pekkoHttp.PekkoHttpGeneratorLoader

modules/scala-pekko-http/src/main/resources/META-INF/services/dev.guardrail.generators.spi.ServerGeneratorLoader

@@ -1 +1 @@
-dev.guardrail.generators.scala.akkaHttp.AkkaHttpServerGeneratorLoader
+dev.guardrail.generators.scala.pekkoHttp.PekkoHttpServerGeneratorLoader

modules/scala-pekko-http/src/main/scala/dev/guardrail/generators/scala/akkaHttp/AkkaHttpVersion.scala

@@ -1,4 +1,4 @@
-package dev.guardrail.generators.scala.akkaHttp
+package dev.guardrail.generators.scala.pekkoHttp
 
 import _root_.io.swagger.v3.oas.models.Components
 import _root_.io.swagger.v3.oas.models.PathItem.HttpMethod
@@ -35,27 +35,27 @@ import java.net.URI
 import scala.meta._
 import scala.reflect.runtime.universe.typeTag
 
-class AkkaHttpClientGeneratorLoader extends ClientGeneratorLoader {
+class PekkoHttpClientGeneratorLoader extends ClientGeneratorLoader {
   type L = ScalaLanguage
   def reified = typeTag[Target[ScalaLanguage]]
   val apply = ModuleLoadResult.forProduct2(
-    ClientGeneratorLoader.label -> Seq(AkkaHttpVersion.mapping),
+    ClientGeneratorLoader.label -> Seq(PekkoHttpVersion.mapping),
     ProtocolGeneratorLoader.label -> Seq(
       CirceModelGenerator.mapping,
       CirceRefinedModelGenerator.mapping.view.mapValues(_.toCirce).toMap,
       JacksonModelGenerator.mapping
     )
   ) { (_, collectionVersion) =>
-    AkkaHttpClientGenerator(collectionVersion)
+    PekkoHttpClientGenerator(collectionVersion)
   }
 }
 
-object AkkaHttpClientGenerator {
+object PekkoHttpClientGenerator {
   def apply(modelGeneratorType: ModelGeneratorType): ClientTerms[ScalaLanguage, Target] =
-    new AkkaHttpClientGenerator(modelGeneratorType)
+    new PekkoHttpClientGenerator(modelGeneratorType)
 }
 
-class AkkaHttpClientGenerator private (modelGeneratorType: ModelGeneratorType) extends ClientTerms[ScalaLanguage, Target] {
+class PekkoHttpClientGenerator private (modelGeneratorType: ModelGeneratorType) extends ClientTerms[ScalaLanguage, Target] {
   private def splitOperationParts(operationId: String): (List[String], String) = {
     val parts = operationId.split('.')
     (parts.drop(1).toList, parts.last)
@@ -500,7 +500,7 @@ class AkkaHttpClientGenerator private (modelGeneratorType: ModelGeneratorType) e
       param"mat: Materializer"
     )
     for {
-      protocolImplicits <- AkkaHttpHelper.protocolImplicits(modelGeneratorType)
+      protocolImplicits <- PekkoHttpHelper.protocolImplicits(modelGeneratorType)
     } yield List(
       Term.ParamClause(
         List(formatHost(serverUrls)) ++ (if (tracing)
@@ -547,7 +547,7 @@ class AkkaHttpClientGenerator private (modelGeneratorType: ModelGeneratorType) e
       }
 
       for {
-        protocolImplicits <- AkkaHttpHelper.protocolImplicits(modelGeneratorType)
+        protocolImplicits <- PekkoHttpHelper.protocolImplicits(modelGeneratorType)
         args = List(
           Term.ParamClause(
             List(param"httpClient: HttpRequest => Future[HttpResponse]", formatHost(serverUrls)) ++ tracingParams,
@@ -635,7 +635,7 @@ class AkkaHttpClientGenerator private (modelGeneratorType: ModelGeneratorType) e
     responses.value.flatTraverse { resp =>
       resp.value.map(_._2).toList.traverse { tpe =>
         for {
-          (decoder, baseType) <- AkkaHttpHelper.generateDecoder(tpe, produces, modelGeneratorType)
+          (decoder, baseType) <- PekkoHttpHelper.generateDecoder(tpe, produces, modelGeneratorType)
         } yield q"val ${Pat.Var(Term.Name(s"$methodName${resp.statusCodeName}Decoder"))} = ${decoder}"
       }
     }

modules/scala-pekko-http/src/main/scala/dev/guardrail/generators/scala/akkaHttp/AkkaHttpClientGenerator.scala renamed to modules/scala-pekko-http/src/main/scala/dev/guardrail/generators/scala/pekkoHttp/PekkoHttpClientGenerator.scala

@@ -1,4 +1,4 @@
-package dev.guardrail.generators.scala.akkaHttp
+package dev.guardrail.generators.scala.pekkoHttp
 
 import scala.meta._
 import scala.reflect.runtime.universe.typeTag
@@ -8,28 +8,28 @@ import dev.guardrail.generators.scala.{ CirceModelGenerator, CirceRefinedModelGe
 import dev.guardrail.generators.spi.{ FrameworkGeneratorLoader, ModuleLoadResult, ProtocolGeneratorLoader }
 import dev.guardrail.terms.framework._
 
-class AkkaHttpGeneratorLoader extends FrameworkGeneratorLoader {
+class PekkoHttpGeneratorLoader extends FrameworkGeneratorLoader {
   type L = ScalaLanguage
   def reified = typeTag[Target[ScalaLanguage]]
   val apply =
     ModuleLoadResult.forProduct2(
-      FrameworkGeneratorLoader.label -> Seq(AkkaHttpVersion.mapping),
+      FrameworkGeneratorLoader.label -> Seq(PekkoHttpVersion.mapping),
       ProtocolGeneratorLoader.label -> Seq(
         CirceModelGenerator.mapping,
         CirceRefinedModelGenerator.mapping.view.mapValues(_.toCirce).toMap,
         JacksonModelGenerator.mapping
       )
-    ) { (akkaHttpVersion, collectionVersion) =>
-      AkkaHttpGenerator(akkaHttpVersion, collectionVersion)
+    ) { (pekkoHttpVersion, collectionVersion) =>
+      PekkoHttpGenerator(pekkoHttpVersion, collectionVersion)
     }
 }
 
-object AkkaHttpGenerator {
-  def apply(akkaHttpVersion: AkkaHttpVersion, modelGeneratorType: ModelGeneratorType): FrameworkTerms[ScalaLanguage, Target] =
-    new AkkaHttpGenerator(akkaHttpVersion, modelGeneratorType)
+object PekkoHttpGenerator {
+  def apply(pekkoHttpVersion: PekkoHttpVersion, modelGeneratorType: ModelGeneratorType): FrameworkTerms[ScalaLanguage, Target] =
+    new PekkoHttpGenerator(pekkoHttpVersion, modelGeneratorType)
 }
 
-class AkkaHttpGenerator private (akkaHttpVersion: AkkaHttpVersion, modelGeneratorType: ModelGeneratorType) extends FrameworkTerms[ScalaLanguage, Target] {
+class PekkoHttpGenerator private (pekkoHttpVersion: PekkoHttpVersion, modelGeneratorType: ModelGeneratorType) extends FrameworkTerms[ScalaLanguage, Target] {
   override def fileType(format: Option[String]) = Target.pure(format.fold[Type](t"BodyPartEntity")(Type.Name(_)))
   override def objectType(format: Option[String]) =
     modelGeneratorType match {
@@ -46,16 +46,16 @@ class AkkaHttpGenerator private (akkaHttpVersion: AkkaHttpVersion, modelGenerato
         case _                        => Target.raiseError(RuntimeFailure(s"Unknown modelGeneratorType: ${modelGeneratorType}"))
       }
     } yield List(
-      q"import akka.http.scaladsl.model._",
-      q"import akka.http.scaladsl.model.headers.RawHeader",
-      q"import akka.http.scaladsl.unmarshalling.{Unmarshal, Unmarshaller, FromEntityUnmarshaller, FromRequestUnmarshaller, FromStringUnmarshaller}",
-      q"import akka.http.scaladsl.marshalling.{Marshal, Marshaller, Marshalling, ToEntityMarshaller, ToResponseMarshaller}",
-      q"import akka.http.scaladsl.server.Directives._",
-      q"import akka.http.scaladsl.server.{Directive, Directive0, Directive1, ExceptionHandler, MalformedFormFieldRejection, MalformedHeaderRejection, MissingFormFieldRejection, MalformedRequestContentRejection, Rejection, RejectionError, Route}",
-      q"import akka.http.scaladsl.util.FastFuture",
-      q"import akka.stream.{IOResult, Materializer}",
-      q"import akka.stream.scaladsl.{FileIO, Keep, Sink, Source}",
-      q"import akka.util.ByteString",
+      q"import org.apache.pekko.http.scaladsl.model._",
+      q"import org.apache.pekko.http.scaladsl.model.headers.RawHeader",
+      q"import org.apache.pekko.http.scaladsl.unmarshalling.{Unmarshal, Unmarshaller, FromEntityUnmarshaller, FromRequestUnmarshaller, FromStringUnmarshaller}",
+      q"import org.apache.pekko.http.scaladsl.marshalling.{Marshal, Marshaller, Marshalling, ToEntityMarshaller, ToResponseMarshaller}",
+      q"import org.apache.pekko.http.scaladsl.server.Directives._",
+      q"import org.apache.pekko.http.scaladsl.server.{Directive, Directive0, Directive1, ExceptionHandler, MalformedFormFieldRejection, MalformedHeaderRejection, MissingFormFieldRejection, MalformedRequestContentRejection, Rejection, RejectionError, Route}",
+      q"import org.apache.pekko.http.scaladsl.util.FastFuture",
+      q"import org.apache.pekko.stream.{IOResult, Materializer}",
+      q"import org.apache.pekko.stream.scaladsl.{FileIO, Keep, Sink, Source}",
+      q"import org.apache.pekko.util.ByteString",
       q"import cats.{Functor, Id}",
       q"import cats.data.EitherT",
       q"import cats.implicits._",
@@ -76,7 +76,7 @@ class AkkaHttpGenerator private (akkaHttpVersion: AkkaHttpVersion, modelGenerato
         case _                          => Target.raiseError(RuntimeFailure(s"Unknown modelGeneratorType: ${modelGeneratorType}"))
       }
       defn = q"""
-        object AkkaHttpImplicits {
+        object PekkoHttpImplicits {
           private[this] def pathEscape(s: String): String = Uri.Path.Segment.apply(s, Uri.Path.Empty).toString
           implicit def addShowablePath[T](implicit ev: Show[T]): AddPath[T] = AddPath.build[T](v => pathEscape(ev.show(v)))
 
@@ -149,7 +149,7 @@ class AkkaHttpGenerator private (akkaHttpVersion: AkkaHttpVersion, modelGenerato
           ..$protocolImplicits
         }
       """
-    } yield Some((q"AkkaHttpImplicits", defn))
+    } yield Some((q"PekkoHttpImplicits", defn))
 
   private def circeImplicits(circeVersion: CirceModelGenerator): List[Defn] = {
     val jsonEncoderTypeclass: Type = t"io.circe.Encoder"
@@ -426,9 +426,9 @@ class AkkaHttpGenerator private (akkaHttpVersion: AkkaHttpVersion, modelGenerato
         Target.pure(
           (
             413,
-            akkaHttpVersion match {
-              case AkkaHttpVersion.V10_1 => q"RequestEntityTooLarge"
-              case AkkaHttpVersion.V10_2 => q"PayloadTooLarge"
+            pekkoHttpVersion match {
+              case PekkoHttpVersion.V10_1 => q"RequestEntityTooLarge"
+              case PekkoHttpVersion.V10_2 => q"PayloadTooLarge"
             }
           )
         )

modules/scala-pekko-http/src/main/scala/dev/guardrail/generators/scala/akkaHttp/AkkaHttpGenerator.scala renamed to modules/scala-pekko-http/src/main/scala/dev/guardrail/generators/scala/pekkoHttp/PekkoHttpGenerator.scala

@@ -1,4 +1,4 @@
-package dev.guardrail.generators.scala.akkaHttp
+package dev.guardrail.generators.scala.pekkoHttp
 
 import cats.data.NonEmptyList
 import cats.syntax.all._
@@ -8,7 +8,7 @@ import dev.guardrail.generators.scala.{ CirceModelGenerator, JacksonModelGenerat
 import dev.guardrail.terms.{ ApplicationJson, ContentType, TextPlain }
 import scala.meta._
 
-object AkkaHttpHelper {
+object PekkoHttpHelper {
   def generateDecoder(tpe: Type, consumes: Tracker[NonEmptyList[ContentType]], modelGeneratorType: ModelGeneratorType): Target[(Term, Type)] = {
     val baseType = tpe match {
       case t"Option[$x]" => x

modules/scala-pekko-http/src/main/scala/dev/guardrail/generators/scala/akkaHttp/AkkaHttpHelper.scala renamed to modules/scala-pekko-http/src/main/scala/dev/guardrail/generators/scala/pekkoHttp/PekkoHttpHelper.scala

@@ -1,12 +1,12 @@
-package dev.guardrail.generators.scala.akkaHttp
+package dev.guardrail.generators.scala.pekkoHttp
 
 import scala.meta._
 
 import dev.guardrail.core.PathExtractor
 import dev.guardrail.generators.scala.{ ModelGeneratorType, ScalaLanguage }
 import dev.guardrail.generators.LanguageParameter
 
-object AkkaHttpPathExtractor
+object PekkoHttpPathExtractor
     extends PathExtractor[ScalaLanguage, Term, Term.Name, ModelGeneratorType](
       pathSegmentConverter = { case (LanguageParameter(_, param, _, argName, argType), base, modelGeneratorType) =>
         base.fold {
@@ -19,7 +19,7 @@ object AkkaHttpPathExtractor
             case t"Long"   => Right(q"LongNumber")
             case t"BigInt" => Right(q"Segment.map(BigInt.apply _)")
             case tpe =>
-              AkkaHttpHelper
+              PekkoHttpHelper
                 .fromStringConverter(tpe, modelGeneratorType)
                 .map(tpe => q"Segment.flatMap(str => ${tpe})")
           }
@@ -30,7 +30,7 @@ object AkkaHttpPathExtractor
               Right(q"${segment}.map(BigDecimal.apply _)")
             case t"BigInt" => Right(q"${segment}.map(BigInt.apply _)")
             case tpe =>
-              AkkaHttpHelper
+              PekkoHttpHelper
                 .fromStringConverter(tpe, modelGeneratorType)
                 .map(tpe => q"${segment}.flatMap(str => ${tpe})")
           }