Reformat with scalafmt 3.7.1

Executed command: scalafmt --non-interactive
softwaremill · Jan 24, 2023 · 5629d39 · 5629d39
1 parent 24bbe92
commit 5629d39
Show file tree

Hide file tree

Showing 27 changed files with 118 additions and 92 deletions.
diff --git a/build.sbt b/build.sbt
@@ -528,10 +528,10 @@ lazy val enumeratum: ProjectMatrix = (projectMatrix in file("integrations/enumer
       "com.beachape" %%% "enumeratum" % Versions.enumeratum,
       scalaTest.value % Test
     ),
-    Test/scalacOptions ++= {
+    Test / scalacOptions ++= {
       CrossVersion.partialVersion(scalaVersion.value) match {
         case Some((3, _)) => Seq("-Yretain-trees")
-        case _ => Seq()
+        case _            => Seq()
       }
     }
   )

diff --git a/core/src/main/scala-2.13-/sttp/tapir/CodecExtensions2.scala b/core/src/main/scala-2.13-/sttp/tapir/CodecExtensions2.scala
@@ -1,3 +1,3 @@
 package sttp.tapir
 
-trait CodecExtensions2
+trait CodecExtensions2
diff --git a/core/src/main/scala-2/sttp/tapir/internal/ValidatorEnumerationMacro.scala b/core/src/main/scala-2/sttp/tapir/internal/ValidatorEnumerationMacro.scala
@@ -42,13 +42,11 @@ private[tapir] object ValidatorEnumerationMacro {
       val enumNameComponents = weakTypeT.toString.split("\\.").dropRight(1)
       val enumeration = enumNameComponents.toList match {
         case head :: tail => tail.foldLeft[Tree](Ident(TermName(head))) { case (tree, nextName) => Select(tree, TermName(nextName)) }
-        case Nil => c.abort(c.enclosingPosition, s"Invalid enum name: ${weakTypeT.toString}")
+        case Nil          => c.abort(c.enclosingPosition, s"Invalid enum name: ${weakTypeT.toString}")
       }
 
-      q"_root_.sttp.tapir.Validator.enumeration($enumeration.values.toList, v => Option(v), Some(sttp.tapir.Schema.SName(${
-        enumNameComponents
-          .mkString(".")
-      })))"
+      q"_root_.sttp.tapir.Validator.enumeration($enumeration.values.toList, v => Option(v), Some(sttp.tapir.Schema.SName(${enumNameComponents
+          .mkString(".")})))"
     }
   }
 }
diff --git a/core/src/main/scala-2/sttp/tapir/macros/SchemaMacros.scala b/core/src/main/scala-2/sttp/tapir/macros/SchemaMacros.scala
@@ -83,5 +83,3 @@ trait SchemaCompanionMacros extends SchemaMagnoliaDerivation {
     */
   implicit def derivedEnumerationValue[T <: scala.Enumeration#Value]: Schema[T] = macro SchemaEnumerationMacro.derivedEnumerationValue[T]
 }
-
-
diff --git a/core/src/main/scala-3-2.13+/sttp/tapir/model/package.scala b/core/src/main/scala-3-2.13+/sttp/tapir/model/package.scala
@@ -1,6 +1,7 @@
 package sttp.tapir
 
 package object model {
+
   /** Used to lookup codecs which split/combine values using a comma. */
   type CommaSeparated[T] = Delimited[",", T]
 }
diff --git a/core/src/main/scala-3/sttp/tapir/macros/SchemaMacros.scala b/core/src/main/scala-3/sttp/tapir/macros/SchemaMacros.scala
@@ -254,11 +254,11 @@ private[tapir] object SchemaCompanionMacros {
         TypeIdent(subclass).tpe.asType match {
           case '[f] => {
             Expr.summon[Schema[f]] match {
-              case Some (subSchema) => '{${Expr (subclass.name)} -> Schema.wrapWithSingleFieldProduct (${subSchema}) ($conf)}
+              case Some(subSchema) => '{ ${ Expr(subclass.name) } -> Schema.wrapWithSingleFieldProduct(${ subSchema })($conf) }
               case None => {
                 val typeName = TypeRepr.of[f].typeSymbol.name
-                report.errorAndAbort (s"Cannot summon schema for `${typeName}`. Make sure schema derivation is properly configured.")
-             }
+                report.errorAndAbort(s"Cannot summon schema for `${typeName}`. Make sure schema derivation is properly configured.")
+              }
             }
           }
         }

diff --git a/core/src/main/scala/sttp/tapir/Codec.scala b/core/src/main/scala/sttp/tapir/Codec.scala
@@ -569,9 +569,9 @@ object Codec extends CodecExtensions with CodecExtensions2 with FormCodecMacros
     }
   }(_.toString)
 
-   implicit val contentRange: Codec[String, ContentRange, CodecFormat.TextPlain] = Codec.string.mapDecode { v => 
-    DecodeResult.fromEitherString(v, ContentRange.parse(v)) 
-   }(_.toString)
+  implicit val contentRange: Codec[String, ContentRange, CodecFormat.TextPlain] = Codec.string.mapDecode { v =>
+    DecodeResult.fromEitherString(v, ContentRange.parse(v))
+  }(_.toString)
 
   implicit val cacheDirective: Codec[String, List[CacheDirective], CodecFormat.TextPlain] = Codec.string.mapDecode { v =>
     @tailrec

diff --git a/examples/src/main/scala/sttp/tapir/examples/HelloWorldZioHttpServer.scala b/examples/src/main/scala/sttp/tapir/examples/HelloWorldZioHttpServer.scala
@@ -38,8 +38,11 @@ object HelloWorldZioHttpServer extends ZIOAppDefault {
 
   // starting the server
   override def run =
-    Server.serve(app).provide(
-      ServerConfig.live(ServerConfig.default.port(8090)),
-      Server.live,
-    ).exitCode
+    Server
+      .serve(app)
+      .provide(
+        ServerConfig.live(ServerConfig.default.port(8090)),
+        Server.live
+      )
+      .exitCode
 }
diff --git a/examples/src/main/scala/sttp/tapir/examples/ZioExampleZioHttpServer.scala b/examples/src/main/scala/sttp/tapir/examples/ZioExampleZioHttpServer.scala
@@ -46,7 +46,7 @@ object ZioExampleZioHttpServer extends ZIOAppDefault {
       .serve(routes)
       .provide(
         ServerConfig.live(ServerConfig.default.port(8080)),
-        Server.live,
+        Server.live
       )
       .exitCode
 }
diff --git a/examples/src/main/scala/sttp/tapir/examples/observability/ZioMetricsExample.scala b/examples/src/main/scala/sttp/tapir/examples/observability/ZioMetricsExample.scala
@@ -40,7 +40,7 @@ object ZioMetricsExample extends ZIOAppDefault {
     } yield serverPort)
       .provide(
         ServerConfig.live(ServerConfig.default.port(port)),
-        Server.live,
+        Server.live
       )
       .exitCode
   }

diff --git a/examples/src/main/scala/sttp/tapir/examples/openapi/RedocZioHttpServer.scala b/examples/src/main/scala/sttp/tapir/examples/openapi/RedocZioHttpServer.scala
@@ -32,7 +32,7 @@ object RedocZioHttpServer extends ZIOAppDefault {
         .serve(petRoutes ++ redocRoutes)
         .provide(
           ServerConfig.live(ServerConfig.default.port(8080)),
-          Server.live,
+          Server.live
         )
         .fork
         .flatMap { fiber =>

diff --git a/examples/src/main/scala/sttp/tapir/examples/streaming/StreamingZioHttpServer.scala b/examples/src/main/scala/sttp/tapir/examples/streaming/StreamingZioHttpServer.scala
@@ -45,7 +45,7 @@ object StreamingZioHttpServer extends ZIOAppDefault {
       .serve(routes)
       .provide(
         ServerConfig.live(ServerConfig.default.port(8080)),
-        Server.live,
+        Server.live
       )
       .exitCode
 }
diff --git a/grpc/protobuf/src/main/scala/sttp/tapir/grpc/protobuf/EndpointToProtobufMessage.scala b/grpc/protobuf/src/main/scala/sttp/tapir/grpc/protobuf/EndpointToProtobufMessage.scala
@@ -77,7 +77,6 @@ class EndpointToProtobufMessage {
           }
           List(ProtobufProductMessage(toMessageName(name), protoFields))
         case SCoproduct(subtypes, discriminator) =>
-
           List(
             ProtobufCoproductMessage(
               toMessageName(name),

diff --git a/grpc/protobuf/src/main/scala/sttp/tapir/grpc/protobuf/model/ProtobufMessage.scala b/grpc/protobuf/src/main/scala/sttp/tapir/grpc/protobuf/model/ProtobufMessage.scala
@@ -7,4 +7,4 @@ sealed trait ProtobufMessage {
 }
 
 case class ProtobufProductMessage(name: MessageName, fields: Iterable[ProtobufMessageField]) extends ProtobufMessage
-case class ProtobufCoproductMessage(name: MessageName, alternatives: Iterable[ProtobufMessageField]) extends ProtobufMessage
+case class ProtobufCoproductMessage(name: MessageName, alternatives: Iterable[ProtobufMessageField]) extends ProtobufMessage
diff --git a/grpc/protobuf/src/test/scala/sttp/tapir/grpc/protobuf/ProtoRendererTest.scala b/grpc/protobuf/src/test/scala/sttp/tapir/grpc/protobuf/ProtoRendererTest.scala
@@ -211,7 +211,7 @@ class ProtoRendererTest extends AnyFlatSpec with ProtobufMatchers {
           "Format",
           List(
             ProtobufMessageField(ProtobufMessageRef(SName("Epub")), "epub", None),
-            ProtobufMessageField(ProtobufMessageRef(SName("Paper")), "paper", None),
+            ProtobufMessageField(ProtobufMessageRef(SName("Paper")), "paper", None)
           )
         ),
         ProtobufProductMessage(

diff --git a/...grations/enumeratum/src/main/scala/sttp/tapir/codec/enumeratum/TapirCodecEnumeratum.scala b/...grations/enumeratum/src/main/scala/sttp/tapir/codec/enumeratum/TapirCodecEnumeratum.scala
@@ -14,7 +14,9 @@ trait TapirCodecEnumeratum {
   implicit def schemaForEnumEntry[E <: EnumEntry](implicit annotations: SchemaAnnotations[E], `enum`: Enum[E]): Schema[E] =
     annotations.enrich(Schema[E](SchemaType.SString()).validate(validatorEnumEntry))
 
-  def plainCodecEnumEntryUsing[E <: EnumEntry](f: String => Option[E])(implicit `enum`: Enum[E]): Codec[String, E, CodecFormat.TextPlain] = {
+  def plainCodecEnumEntryUsing[E <: EnumEntry](
+      f: String => Option[E]
+  )(implicit `enum`: Enum[E]): Codec[String, E, CodecFormat.TextPlain] = {
     val validator = validatorEnumEntry
     Codec.string
       .mapDecode { s =>
@@ -47,7 +49,10 @@ trait TapirCodecEnumeratum {
   implicit def schemaForShortEnumEntry[E <: ShortEnumEntry](implicit annotations: SchemaAnnotations[E], `enum`: ShortEnum[E]): Schema[E] =
     annotations.enrich(Schema[E](SchemaType.SInteger()).validate(validatorValueEnumEntry[Short, E]))
 
-  implicit def schemaForStringEnumEntry[E <: StringEnumEntry](implicit annotations: SchemaAnnotations[E], `enum`: StringEnum[E]): Schema[E] =
+  implicit def schemaForStringEnumEntry[E <: StringEnumEntry](implicit
+      annotations: SchemaAnnotations[E],
+      `enum`: StringEnum[E]
+  ): Schema[E] =
     annotations.enrich(Schema[E](SchemaType.SString()).validate(validatorValueEnumEntry[String, E]))
 
   implicit def schemaForByteEnumEntry[E <: ByteEnumEntry](implicit annotations: SchemaAnnotations[E], `enum`: ByteEnum[E]): Schema[E] =

diff --git a/...ions/enumeratum/src/test/scala/sttp/tapir/codec/enumeratum/TapirCodecEnumeratumTest.scala b/...ions/enumeratum/src/test/scala/sttp/tapir/codec/enumeratum/TapirCodecEnumeratumTest.scala
@@ -95,7 +95,9 @@ class TapirCodecEnumeratumTest extends AnyFlatSpec with Matchers {
     }
   }
 
-  private def testValueEnumPlainCodec[T, EE <: ValueEnumEntry[T], E <: ValueEnum[T, EE]](codec: PlainCodec[EE])(implicit `enum`: E): Unit = {
+  private def testValueEnumPlainCodec[T, EE <: ValueEnumEntry[T], E <: ValueEnum[T, EE]](
+      codec: PlainCodec[EE]
+  )(implicit `enum`: E): Unit = {
     `enum`.values.foreach { v =>
       codec.encode(v) shouldBe v.value.toString
       codec.decode(v.value.toString) shouldBe DecodeResult.Value(v)

diff --git a/metrics/zio-metrics/src/main/scala/sttp/tapir/server/metrics/zio/ZioMetrics.scala b/metrics/zio-metrics/src/main/scala/sttp/tapir/server/metrics/zio/ZioMetrics.scala
@@ -45,14 +45,14 @@ object ZioMetrics {
     Boundaries.fromChunk(Chunk(.005, .01, .025, .05, .075, .1, .25, .5, .75, 1, 2.5, 5, 7.5, 10, 15, 30, 45, 60))
 
   /** Using the default namespace and labels, registers the following metrics:
-   *
-   *   - `tapir_request_active{path, method}` (gauge)
-   *   - `tapir_request_total{path, method, status}` (counter)
-   *   - `tapir_request_duration_seconds{path, method, status, phase}` (histogram)
-   *
-   * Status is by default the status code class (1xx, 2xx, etc.), and phase can be either `headers` or `body` - request duration is
-   * measured separately up to the point where the headers are determined, and then once again when the whole response body is complete.
-   */
+    *
+    *   - `tapir_request_active{path, method}` (gauge)
+    *   - `tapir_request_total{path, method, status}` (counter)
+    *   - `tapir_request_duration_seconds{path, method, status, phase}` (histogram)
+    *
+    * Status is by default the status code class (1xx, 2xx, etc.), and phase can be either `headers` or `body` - request duration is
+    * measured separately up to the point where the headers are determined, and then once again when the whole response body is complete.
+    */
   def default[F[_]](namespace: String = DefaultNamespace, labels: MetricLabels = MetricLabels.Default): ZioMetrics[F] = ZioMetrics(
     namespace,
     List(
@@ -75,7 +75,6 @@ object ZioMetrics {
   def getRequestDurationHistogram(namespace: String): zio.metrics.Metric.Histogram[Double] =
     zio.metrics.Metric.histogram(s"${namespace}_request_duration_seconds", DurationBoundaries)
 
-
   /** ZIO Unsafe Run Wrapper */
   private def unsafeRun[T](task: Task[T]): T = Unsafe.unsafe { implicit u =>
     runtime.unsafe.run(task.orDie).getOrThrowFiberFailure()

diff --git a/metrics/zio-metrics/src/test/scala/sttp/tapir/server/metrics/zio/ZioMetricsTest.scala b/metrics/zio-metrics/src/test/scala/sttp/tapir/server/metrics/zio/ZioMetricsTest.scala
@@ -32,14 +32,18 @@ object ZioMetricsTest extends ZIOSpecDefault {
           )
 
         // when
-        val active: Counter[Long] = ZioMetrics.getActiveRequestCounter("tapir").tagged(
-          Set(MetricLabel("path", "/person"), MetricLabel("method", "GET"))
-        )
+        val active: Counter[Long] = ZioMetrics
+          .getActiveRequestCounter("tapir")
+          .tagged(
+            Set(MetricLabel("path", "/person"), MetricLabel("method", "GET"))
+          )
 
         for {
-          _ <- ZIO.succeed({
-            interpreter.apply(PersonsApi.request("Jacob"))
-          }).fork
+          _ <- ZIO
+            .succeed({
+              interpreter.apply(PersonsApi.request("Jacob"))
+            })
+            .fork
           _ <- ZIO.succeed(Thread.sleep(100))
           state <- active.value
           _ <- ZIO.succeed(Thread.sleep(150))
@@ -63,13 +67,17 @@ object ZioMetricsTest extends ZIOSpecDefault {
           )
 
         // when
-        val counter: Counter[Long] = ZioMetrics.getRequestsTotalCounter("tapir").tagged(
-          Set(MetricLabel("path", "/person"), MetricLabel("method", "GET"),MetricLabel("status", "2xx"))
-        )
+        val counter: Counter[Long] = ZioMetrics
+          .getRequestsTotalCounter("tapir")
+          .tagged(
+            Set(MetricLabel("path", "/person"), MetricLabel("method", "GET"), MetricLabel("status", "2xx"))
+          )
 
-        val missedCounter: Counter[Long] = ZioMetrics.getRequestsTotalCounter("tapir").tagged(
-          Set(MetricLabel("path", "/person"), MetricLabel("method", "GET"), MetricLabel("status", "4xx"))
-        )
+        val missedCounter: Counter[Long] = ZioMetrics
+          .getRequestsTotalCounter("tapir")
+          .tagged(
+            Set(MetricLabel("path", "/person"), MetricLabel("method", "GET"), MetricLabel("status", "4xx"))
+          )
         for {
           _ <- ZIO.succeed({
             interpreter.apply(PersonsApi.request("Jacob"))
@@ -80,10 +88,10 @@ object ZioMetricsTest extends ZIOSpecDefault {
           })
           state <- counter.value
           stateMissed <- missedCounter.value
-        } yield assertTrue(state == MetricState.Counter(3D)) &&
-          assertTrue(stateMissed == MetricState.Counter(2D))
+        } yield assertTrue(state == MetricState.Counter(3d)) &&
+          assertTrue(stateMissed == MetricState.Counter(2d))
       },
-      test ("can collect requests duration") {
+      test("can collect requests duration") {
         val serverEp = PersonsApi { name =>
           PersonsApi.defaultLogic(name)
         }.serverEp
@@ -98,9 +106,11 @@ object ZioMetricsTest extends ZIOSpecDefault {
           )
 
         // when
-        val histogram: Metric[MetricKeyType.Histogram, Double, MetricState.Histogram] = ZioMetrics.getRequestDurationHistogram("tapir").tagged(
-          Set(MetricLabel("path", "/person"), MetricLabel("method", "GET"), MetricLabel("status", "2xx"), MetricLabel("phase", "headers"))
-        )
+        val histogram: Metric[MetricKeyType.Histogram, Double, MetricState.Histogram] = ZioMetrics
+          .getRequestDurationHistogram("tapir")
+          .tagged(
+            Set(MetricLabel("path", "/person"), MetricLabel("method", "GET"), MetricLabel("status", "2xx"), MetricLabel("phase", "headers"))
+          )
 
         for {
           _ <- ZIO.succeed({
@@ -109,8 +119,8 @@ object ZioMetricsTest extends ZIOSpecDefault {
           state <- histogram.value
         } yield assertTrue(state.buckets.exists(_._2 > 0L)) &&
           assertTrue(state.count == 1L) &&
-          assertTrue(state.min > 0D) &&
-          assertTrue(state.max > 0D)
+          assertTrue(state.min > 0d) &&
+          assertTrue(state.max > 0d)
       }
     )
   }

diff --git a/...er/finatra-server/src/main/scala/sttp/tapir/server/finatra/FinatraServerInterpreter.scala b/...er/finatra-server/src/main/scala/sttp/tapir/server/finatra/FinatraServerInterpreter.scala
@@ -26,34 +26,35 @@ trait FinatraServerInterpreter extends Logging {
       finatraServerOptions.deleteFile
     )(FutureMonadError, new FinatraBodyListener[Future]())
 
-    val handler = { request: Request =>
-      val serverRequest = new FinatraServerRequest(request)
+    val handler = {
+      request: Request =>
+        val serverRequest = new FinatraServerRequest(request)
 
-      serverInterpreter(serverRequest).map {
-        case RequestResult.Failure(_) => Response(Status.NotFound)
-        case RequestResult.Response(response) =>
-          val status = Status(response.code.code)
-          val responseWithContent = response.body match {
-            case Some(fContent) =>
-              val response = fContent match {
-                case FinatraContentBuf(buf) =>
-                  val r = Response(Version.Http11, status)
-                  r.content = buf
-                  r
-                case FinatraContentReader(reader) => Response(Version.Http11, status, reader)
-              }
-              response
-            case None =>
-              Response(Version.Http11, status)
-          }
+        serverInterpreter(serverRequest).map {
+          case RequestResult.Failure(_) => Response(Status.NotFound)
+          case RequestResult.Response(response) =>
+            val status = Status(response.code.code)
+            val responseWithContent = response.body match {
+              case Some(fContent) =>
+                val response = fContent match {
+                  case FinatraContentBuf(buf) =>
+                    val r = Response(Version.Http11, status)
+                    r.content = buf
+                    r
+                  case FinatraContentReader(reader) => Response(Version.Http11, status, reader)
+                }
+                response
+              case None =>
+                Response(Version.Http11, status)
+            }
 
-          response.headers.foreach(header => responseWithContent.headerMap.add(header.name, header.value))
+            response.headers.foreach(header => responseWithContent.headerMap.add(header.name, header.value))
 
-          // If there's a content-type header in headers, override the content-type.
-          response.contentType.foreach(ct => responseWithContent.contentType = ct)
+            // If there's a content-type header in headers, override the content-type.
+            response.contentType.foreach(ct => responseWithContent.contentType = ct)
 
-          responseWithContent
-      }
+            responseWithContent
+        }
     }
 
     FinatraRoute(handler, httpMethod(se.endpoint), path(se.securityInput.and(se.input)))

diff --git a/server/netty-server/src/main/scala/sttp/tapir/server/netty/NettyResponseContent.scala b/server/netty-server/src/main/scala/sttp/tapir/server/netty/NettyResponseContent.scala
@@ -8,8 +8,9 @@ sealed trait NettyResponseContent {
   def channelPromise: ChannelPromise
 }
 
-object  NettyResponseContent{
+object NettyResponseContent {
   final case class ByteBufNettyResponseContent(channelPromise: ChannelPromise, byteBuf: ByteBuf) extends NettyResponseContent
-  final case class ChunkedStreamNettyResponseContent(channelPromise: ChannelPromise, chunkedStream: ChunkedStream) extends NettyResponseContent
+  final case class ChunkedStreamNettyResponseContent(channelPromise: ChannelPromise, chunkedStream: ChunkedStream)
+      extends NettyResponseContent
   final case class ChunkedFileNettyResponseContent(channelPromise: ChannelPromise, chunkedFile: ChunkedFile) extends NettyResponseContent
 }
diff --git a/...er/netty-server/src/main/scala/sttp/tapir/server/netty/internal/NettyToResponseBody.scala b/...er/netty-server/src/main/scala/sttp/tapir/server/netty/internal/NettyToResponseBody.scala
@@ -8,7 +8,11 @@ import sttp.model.HasHeaders
 import sttp.tapir.capabilities.NoStreams
 import sttp.tapir.server.interpreter.ToResponseBody
 import sttp.tapir.server.netty.NettyResponse
-import sttp.tapir.server.netty.NettyResponseContent.{ByteBufNettyResponseContent, ChunkedFileNettyResponseContent, ChunkedStreamNettyResponseContent}
+import sttp.tapir.server.netty.NettyResponseContent.{
+  ByteBufNettyResponseContent,
+  ChunkedFileNettyResponseContent,
+  ChunkedStreamNettyResponseContent
+}
 import sttp.tapir.{CodecFormat, FileRange, RawBodyType, WebSocketBodyOutput}
 
 import java.io.{InputStream, RandomAccessFile}

diff --git a/...r/netty-server/zio/src/main/scala/sttp/tapir/server/netty/zio/NettyZioServerOptions.scala b/...r/netty-server/zio/src/main/scala/sttp/tapir/server/netty/zio/NettyZioServerOptions.scala
@@ -57,5 +57,4 @@ object NettyZioServerOptions {
   private def debugLog[R](msg: String, exOpt: Option[Throwable]): RIO[R, Unit] =
     ZIO.succeed(NettyDefaults.debugLog(log, msg, exOpt))
 
-
 }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -83,5 +83,3 @@ trait SchemaCompanionMacros extends SchemaMagnoliaDerivation {
		*/
		implicit def derivedEnumerationValue[T <: scala.Enumeration#Value]: Schema[T] = macro SchemaEnumerationMacro.derivedEnumerationValue[T]
		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -57,5 +57,4 @@ object NettyZioServerOptions {
		private def debugLog[R](msg: String, exOpt: Option[Throwable]): RIO[R, Unit] =
		ZIO.succeed(NettyDefaults.debugLog(log, msg, exOpt))


		}