Update scalafmt-core to 3.9.7 (#409)

* Update scalafmt-core to 3.9.7

* Reformat with scalafmt 3.9.7

Executed command: scalafmt --non-interactive

* Add 'Reformat with scalafmt 3.9.7' to .git-blame-ignore-revs

Author: scala-steward

.git-blame-ignore-revs

@@ -6,3 +6,6 @@ b24ba10341261bd7f44e08fc26862d43b860f06a
 
 # Scala Steward: Reformat with scalafmt 3.8.4
 cbb28af43af57945f6096c40a0fb8ee1d11a4a68
+
+# Scala Steward: Reformat with scalafmt 3.9.7
+cb1c5d06835ed0d274bbea2ef90485d1cdf2f834

.scalafmt.conf

@@ -1,4 +1,4 @@
-version = "3.9.6"
+version = "3.9.7"
 runner.dialect = scala213
 maxColumn = 120
 project.git = true

modules/api/src/main/scala/com/github/andyglow/websocket/Platform.scala

@@ -155,7 +155,8 @@ trait Platform {
     /** We trigger this partial function in case of failures
       * @return
       */
-    def onFailure: PartialFunction[Throwable, Unit] = { case _: Throwable => /* ignore errors */
+    def onFailure: PartialFunction[Throwable, Unit] = {
+      case _: Throwable => /* ignore errors */
     }
 
     /** This function is going to be called when the socket is closed.

modules/api/src/main/scala/com/github/andyglow/websocket/ServerAddress.scala

@@ -40,17 +40,17 @@ object ServerAddress {
 
   def apply(uri: URI): ServerAddress = {
     require(uri.getScheme == "ws" || uri.getScheme == "wss")
-    val secure = uri.getScheme == "wss"
-    val host   = uri.getHost
-    val port   = uri.getPort
-    val path   = uri.getPath
+    val secure    = uri.getScheme == "wss"
+    val host      = uri.getHost
+    val port      = uri.getPort
+    val path      = uri.getPath
     val queryList =
       if (uri.getRawQuery == null) List.empty
       else
         (uri.getRawQuery split "&").toList map { token =>
           token split "=" match {
             case Array(k: String, v: String) => (k, URLDecoder.decode(v, "UTF-8"))
-            case arr =>
+            case arr                         =>
               throw new Exception(
                 s"Query Parameter Parse Exception. Invalid token [$token] lead to [${arr mkString ","}]. Expected 'k=v' form"
               )

modules/api/src/test/scala/com/github/andyglow/websocket/IntegrationSpecBase.scala

@@ -19,7 +19,7 @@ object IntegrationSpecBase {
   }
 
   protected class EmbeddedServer(ssl: Boolean) extends ServerHandle {
-    protected final lazy val server = WebsocketServer.newServer(ssl)
+    protected final lazy val server     = WebsocketServer.newServer(ssl)
     override def address: ServerAddress = {
       val scheme: String = if (ssl) "wss" else "ws"
       ServerAddress(s"$scheme://localhost:${server.port}${WebsocketServer.WebsocketPath}")
@@ -99,9 +99,9 @@ trait IntegrationSpecBase extends AnyWordSpec with BeforeAndAfterAll {
   protected def withState[T <: State](init: T): Builder0[T] = Builder0(init)
 
   protected case class CountingDownState(count: Int = 1) extends State {
-    val latch              = new CountDownLatch(count)
-    def countDown(): Unit  = latch.countDown()
-    def succeeded: Boolean = latch.getCount == 0
+    val latch                        = new CountDownLatch(count)
+    def countDown(): Unit            = latch.countDown()
+    def succeeded: Boolean           = latch.getCount == 0
     def whenFinished[T](fn: => T): T = {
       latch.await(2, TimeUnit.SECONDS)
       fn

modules/api/src/test/scala/com/github/andyglow/websocket/TestPlatform.scala

@@ -9,7 +9,7 @@ class TestPlatform extends Platform {
 
   trait Msg
   object Msg {
-    case class Text(value: String) extends Msg
+    case class Text(value: String)        extends Msg
     case class Binary(value: Array[Byte]) extends Msg {
       override def equals(obj: Any): Boolean = obj match {
         case Binary(other) => java.util.Arrays.equals(value, other)

modules/backend-akka/src/main/scala/com/github/andyglow/websocket/AkkaImplicits.scala

@@ -16,7 +16,7 @@ trait AkkaImplicits { this: AkkaPlatform =>
       fromString: String => T
     ) extends MessageAdapter[T] {
       override type F = Text
-      override def toMessage(msg: T)(implicit ic: InternalContext): F = ws.TextMessage(toString(msg))
+      override def toMessage(msg: T)(implicit ic: InternalContext): F   = ws.TextMessage(toString(msg))
       override def fromMessage(msg: F)(implicit ic: InternalContext): T = {
         import ic._
         import mat.executionContext
@@ -33,7 +33,7 @@ trait AkkaImplicits { this: AkkaPlatform =>
       fromByteString: ByteString => T
     ) extends MessageAdapter[T] {
       override type F = Binary
-      override def toMessage(msg: T)(implicit ic: InternalContext): F = ws.BinaryMessage(toByteString(msg))
+      override def toMessage(msg: T)(implicit ic: InternalContext): F   = ws.BinaryMessage(toByteString(msg))
       override def fromMessage(msg: F)(implicit ic: InternalContext): T = {
         import ic._
         import mat.executionContext

modules/backend-jdk-http-client/src/test/scala/com/github/andyglow/websocket/JdkPlatformSslSpec.scala

@@ -9,9 +9,9 @@ import org.scalatest.DoNotDiscover
 
 @DoNotDiscover
 final class JdkPlatformSslSpec extends IntegrationSpecBase {
-  override val platform: JdkPlatform = JdkPlatform
-  override val ssl                   = true
-  override val isPingSupported       = true
+  override val platform: JdkPlatform        = JdkPlatform
+  override val ssl                          = true
+  override val isPingSupported              = true
   override val options: platform.JdkOptions = {
 
     val trustAny = Array[TrustManager](new X509TrustManager() {

modules/backend-netty/src/main/scala/com/github/andyglow/websocket/AdaptNettyFuture.scala

@@ -11,7 +11,7 @@ private[websocket] object AdaptNettyFuture {
     if (f.isDone) {
       if (f.isSuccess) Future.successful(f.getNow) else Future.failed(f.cause())
     } else {
-      val promise = Promise[T]()
+      val promise        = Promise[T]()
       val futureListener = new GenericFutureListener[NFuture[T]]() {
         override def operationComplete(future: NFuture[T]): Unit = {
           if (future.isSuccess) promise.success(future.getNow) else promise.failure(future.cause())

modules/backend-netty/src/main/scala/com/github/andyglow/websocket/NettyClient.scala

@@ -68,7 +68,7 @@ trait NettyClient { this: NettyPlatform =>
     }
 
     override def channelRead0(ctx: ChannelHandlerContext, msg: ByteBufHolder): Unit = {
-      val ch = ctx.channel()
+      val ch                                                          = ctx.channel()
       val handleControlMessages: PartialFunction[ByteBufHolder, Unit] = {
         // handle Close initiated by Server
         case _: CloseWebSocketFrame =>
@@ -219,7 +219,7 @@ trait NettyClient { this: NettyPlatform =>
   ) extends Websocket
       with Websocket.AsyncImpl {
     override protected implicit val executionContext: ExecutionContext = ec
-    override protected def sendAsync(x: MessageType): Future[Unit] = {
+    override protected def sendAsync(x: MessageType): Future[Unit]     = {
       AdaptNettyFuture(ch.writeAndFlush(x)).map { _ => () }
     }
     override protected def pingAsync(): Future[Unit] = {