Skip to content

Commit

Permalink
Apply scalafix rules
Browse files Browse the repository at this point in the history
  • Loading branch information
lenguyenthanh committed Mar 4, 2024
1 parent cf01d8a commit 607467f
Show file tree
Hide file tree
Showing 37 changed files with 78 additions and 55 deletions.
5 changes: 3 additions & 2 deletions src/main/scala/Auth.scala
Original file line number Diff line number Diff line change
@@ -1,9 +1,10 @@
package lila.ws

import reactivemongo.api.bson.*
import util.RequestHeader
import com.roundeights.hasher.Algo
import com.typesafe.config.Config
import reactivemongo.api.bson.*

import util.RequestHeader

final class Auth(mongo: Mongo, seenAt: SeenAtUpdate, config: Config)(using Executor):

Expand Down
8 changes: 4 additions & 4 deletions src/main/scala/Chess.scala
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
package lila.ws

import play.api.libs.json.*
import chess.format.{ Fen, Uci, UciCharPair, UciPath }
import chess.opening.{ Opening, OpeningDb }
import cats.syntax.option.*
import chess.Square
import chess.bitboard.Bitboard
import chess.format.{ Fen, Uci, UciCharPair, UciPath }
import chess.opening.{ Opening, OpeningDb }
import chess.variant.{ Crazyhouse, Variant }
import cats.syntax.option.*
import play.api.libs.json.*

import ipc.*

Expand Down
3 changes: 2 additions & 1 deletion src/main/scala/Controller.scala
Original file line number Diff line number Diff line change
@@ -1,11 +1,12 @@
package lila.ws

import cats.syntax.all.*
import com.typesafe.config.Config
import com.typesafe.scalalogging.Logger
import io.netty.handler.codec.http.HttpResponseStatus

import util.RequestHeader
import ClientActor.{ Deps, Req }
import cats.syntax.all.*

final class Controller(
config: Config,
Expand Down
5 changes: 3 additions & 2 deletions src/main/scala/Fens.scala
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
package lila.ws

import org.apache.pekko.actor.typed.ActorRef
import chess.Color
import chess.format.{ Fen, Uci }
import java.util.concurrent.ConcurrentHashMap
import lila.ws.ipc.*
import org.apache.pekko.actor.typed.ActorRef

import java.util.concurrent.ConcurrentHashMap

/* Manages subscriptions to Fen updates */
object Fens:
Expand Down
1 change: 1 addition & 0 deletions src/main/scala/LightUser.scala
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package lila.ws

import com.github.blemale.scaffeine.{ AsyncLoadingCache, Scaffeine }
import reactivemongo.api.bson.*

import Mongo.given

final class LightUserApi(mongo: Mongo)(using Executor):
Expand Down
4 changes: 3 additions & 1 deletion src/main/scala/Lila.scala
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,12 @@ import com.typesafe.config.Config
import com.typesafe.scalalogging.Logger
import io.lettuce.core.*
import io.lettuce.core.pubsub.*
import ipc.*

import java.util.concurrent.ConcurrentLinkedQueue
import scala.concurrent.Await

import ipc.*

final class Lila(config: Config)(using Executor):

import Lila.*
Expand Down
5 changes: 3 additions & 2 deletions src/main/scala/LilaHandler.scala
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
package lila.ws

import org.apache.pekko.actor.typed.ActorRef
import com.typesafe.scalalogging.Logger
import ipc.*
import org.apache.pekko.actor.typed.ActorRef
import ornicar.scalalib.ThreadLocalRandom

import ipc.*

final class LilaHandler(
lila: Lila,
users: Users,
Expand Down
5 changes: 3 additions & 2 deletions src/main/scala/LilaRequest.scala
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
package lila.ws

import java.util.concurrent.atomic.AtomicInteger
import com.github.blemale.scaffeine.Scaffeine
import com.github.benmanes.caffeine.cache.RemovalCause
import com.github.blemale.scaffeine.Scaffeine
import com.typesafe.scalalogging.Logger

import java.util.concurrent.atomic.AtomicInteger

// send a request to lila and await a response
object LilaRequest:

Expand Down
2 changes: 1 addition & 1 deletion src/main/scala/LilaWs.scala
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package lila.ws

import org.apache.pekko.actor.typed.{ ActorSystem, Scheduler }
import com.softwaremill.macwire.*
import com.typesafe.config.{ Config, ConfigFactory }
import org.apache.pekko.actor.typed.{ ActorSystem, Scheduler }

object LilaWs extends App:

Expand Down
5 changes: 3 additions & 2 deletions src/main/scala/Mongo.scala
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,11 @@ import com.github.blemale.scaffeine.{ AsyncLoadingCache, Scaffeine }
import com.typesafe.config.Config
import reactivemongo.api.bson.*
import reactivemongo.api.bson.collection.BSONCollection
import reactivemongo.api.{ AsyncDriver, DB, MongoConnection, ReadConcern, ReadPreference, WriteConcern }
import reactivemongo.api.commands.WriteResult
import scala.util.{ Success, Try }
import reactivemongo.api.{ AsyncDriver, DB, MongoConnection, ReadConcern, ReadPreference, WriteConcern }

import java.time.LocalDateTime
import scala.util.{ Success, Try }

final class Mongo(config: Config)(using Executor) extends MongoHandlers:

Expand Down
3 changes: 2 additions & 1 deletion src/main/scala/Monitor.scala
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,10 @@ import com.typesafe.config.Config
import com.typesafe.scalalogging.Logger
import kamon.Kamon
import kamon.tag.TagSet
import java.util.concurrent.TimeUnit
import lila.ws.util.Domain

import java.util.concurrent.TimeUnit

final class Monitor(
config: Config,
services: Services
Expand Down
2 changes: 1 addition & 1 deletion src/main/scala/RelayCrowd.scala
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package lila.ws

import org.apache.pekko.actor.typed.Scheduler
import cats.syntax.all.*
import org.apache.pekko.actor.typed.Scheduler

final private class RelayCrowd(roomCrowd: RoomCrowd, mongo: Mongo)(using ex: Executor, scheduler: Scheduler):

Expand Down
1 change: 1 addition & 0 deletions src/main/scala/RoundCrowd.scala
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package lila.ws

import chess.{ ByColor, Color }

import java.util.concurrent.ConcurrentHashMap

import ipc.*
Expand Down
1 change: 1 addition & 0 deletions src/main/scala/SeenAtUpdate.scala
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import com.github.blemale.scaffeine.{ Cache, Scaffeine }
import reactivemongo.api.bson.*
import reactivemongo.api.bson.collection.BSONCollection
import reactivemongo.api.{ ReadConcern, WriteConcern }

import java.time.LocalDateTime

final class SeenAtUpdate(mongo: Mongo)(using
Expand Down
1 change: 1 addition & 0 deletions src/main/scala/SocialGraph.scala
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package lila.ws

import com.typesafe.config.Config

import java.util.concurrent.locks.ReentrantLock
import scala.jdk.CollectionConverters.*
import scala.util.{ boundary, Random }
Expand Down
1 change: 1 addition & 0 deletions src/main/scala/Users.scala
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package lila.ws

import org.apache.pekko.actor.typed.Scheduler

import java.util.concurrent.ConcurrentHashMap
import scala.jdk.CollectionConverters.*

Expand Down
2 changes: 1 addition & 1 deletion src/main/scala/actor/ApiActor.scala
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package lila.ws

import org.apache.pekko.actor.typed.{ Behavior, PostStop }
import org.apache.pekko.actor.typed.scaladsl.{ ActorContext, Behaviors }
import org.apache.pekko.actor.typed.{ Behavior, PostStop }

import ipc.*

Expand Down
5 changes: 3 additions & 2 deletions src/main/scala/actor/ClientActor.scala
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
package lila.ws

import com.typesafe.scalalogging.Logger
import lila.ws.util.SmallBoundedQueueSet
import org.apache.pekko.actor.typed.Behavior
import org.apache.pekko.actor.typed.scaladsl.{ ActorContext, Behaviors }
import com.typesafe.scalalogging.Logger

import ipc.*
import lila.ws.util.SmallBoundedQueueSet

object ClientActor:

Expand Down
3 changes: 2 additions & 1 deletion src/main/scala/actor/RoundClientActor.scala
Original file line number Diff line number Diff line change
@@ -1,9 +1,10 @@
package lila.ws

import chess.Centis
import org.apache.pekko.actor.typed.scaladsl.Behaviors
import org.apache.pekko.actor.typed.{ Behavior, PostStop }

import ipc.*
import chess.Centis

object RoundClientActor:

Expand Down
12 changes: 6 additions & 6 deletions src/main/scala/evalCache/EvalCacheApi.scala
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
package lila.ws
package evalCache

import cats.syntax.all.*
import chess.ErrorStr
import chess.format.Fen
import com.github.blemale.scaffeine.{ AsyncLoadingCache, Scaffeine }

import lila.ws.ipc.ClientOut.{ EvalGet, EvalGetMulti, EvalPut }
import com.typesafe.scalalogging.Logger
import lila.ws.ipc.ClientIn
import chess.format.Fen
import chess.ErrorStr
import lila.ws.ipc.ClientOut.{ EvalGet, EvalGetMulti, EvalPut }
import play.api.libs.json.JsString
import com.typesafe.scalalogging.Logger
import cats.syntax.all.*
import reactivemongo.api.bson.BSONDocument

import java.time.LocalDateTime

final class EvalCacheApi(mongo: Mongo)(using
Expand Down
7 changes: 4 additions & 3 deletions src/main/scala/evalCache/EvalCacheBsonHandlers.scala
Original file line number Diff line number Diff line change
@@ -1,12 +1,13 @@
package lila.ws
package evalCache

import reactivemongo.api.bson.*
import reactivemongo.api.bson.exceptions.TypeDoesNotMatchException
import scala.util.{ Failure, Success, Try }
import cats.data.NonEmptyList
import cats.syntax.all.*
import chess.format.Uci
import reactivemongo.api.bson.*
import reactivemongo.api.bson.exceptions.TypeDoesNotMatchException

import scala.util.{ Failure, Success, Try }

object EvalCacheBsonHandlers:

Expand Down
5 changes: 3 additions & 2 deletions src/main/scala/evalCache/EvalCacheEntry.scala
Original file line number Diff line number Diff line change
@@ -1,13 +1,14 @@
package lila.ws
package evalCache

import cats.data.NonEmptyList
import chess.format.{ Fen, Uci }
import chess.variant.Variant
import cats.data.NonEmptyList

import Eval.Score
import java.time.LocalDateTime

import Eval.Score

case class EvalCacheEntry(
_id: EvalCacheEntry.Id,
nbMoves: Int, // multipv cannot be greater than number of legal moves
Expand Down
2 changes: 1 addition & 1 deletion src/main/scala/evalCache/EvalCacheJsonHandlers.scala
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@ package evalCache

import cats.syntax.all.*
import chess.format.{ Fen, Uci, UciPath }
import play.api.libs.json.*
import chess.variant.Variant
import play.api.libs.json.*

import evalCache.EvalCacheEntry.*
import evalCache.Eval.*
Expand Down
4 changes: 2 additions & 2 deletions src/main/scala/evalCache/EvalCacheMulti.scala
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@ package evalCache

import chess.format.Fen
import chess.variant.Variant
import lila.ws.util.ExpireCallbackMemo
import lila.ws.ipc.ClientOut.EvalGetMulti
import lila.ws.ipc.ClientIn.EvalHitMulti
import lila.ws.ipc.ClientOut.EvalGetMulti
import lila.ws.util.ExpireCallbackMemo

import scala.collection.mutable

Expand Down
1 change: 1 addition & 0 deletions src/main/scala/evalCache/EvalCacheTruster.scala
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ package evalCache

import com.github.blemale.scaffeine.{ AsyncLoadingCache, Scaffeine }
import reactivemongo.api.bson.*

import java.time.LocalDateTime

final private class EvalCacheTruster(mongo: Mongo)(using Executor) extends MongoHandlers:
Expand Down
7 changes: 3 additions & 4 deletions src/main/scala/evalCache/EvalCacheUpgrade.scala
Original file line number Diff line number Diff line change
@@ -1,13 +1,12 @@
package lila.ws
package evalCache

import play.api.libs.json.JsString

import chess.format.{ Fen, UciPath }
import chess.variant.Variant
import lila.ws.util.ExpireCallbackMemo
import lila.ws.ipc.ClientOut.EvalGet
import lila.ws.ipc.ClientIn.EvalHit
import lila.ws.ipc.ClientOut.EvalGet
import lila.ws.util.ExpireCallbackMemo
import play.api.libs.json.JsString

import scala.collection.mutable

Expand Down
4 changes: 2 additions & 2 deletions src/main/scala/ipc/ClientIn.scala
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
package lila.ws
package ipc

import chess.{ Check, Color, Ply }
import chess.bitboard.Bitboard
import chess.format.{ EpdFen, Uci, UciCharPair, UciPath }
import chess.opening.Opening
import chess.variant.Crazyhouse
import chess.bitboard.Bitboard
import chess.{ Check, Color, Ply }
import play.api.libs.json.*

sealed trait ClientIn extends ClientMsg:
Expand Down
3 changes: 2 additions & 1 deletion src/main/scala/ipc/ClientOut.scala
Original file line number Diff line number Diff line change
@@ -1,12 +1,13 @@
package lila.ws
package ipc

import cats.data.NonEmptyList
import chess.format.{ Fen, Uci, UciPath }
import chess.variant.Variant
import chess.{ Centis, Color, Square }
import play.api.libs.json.*

import scala.util.{ Success, Try }
import cats.data.NonEmptyList

sealed trait ClientOut extends ClientMsg

Expand Down
3 changes: 1 addition & 2 deletions src/main/scala/ipc/types.scala
Original file line number Diff line number Diff line change
@@ -1,8 +1,7 @@
package lila.ws
package ipc

import chess.MoveMetrics
import chess.Centis
import chess.{ Centis, MoveMetrics }

trait ClientMsg

Expand Down
2 changes: 1 addition & 1 deletion src/main/scala/model.scala
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package lila.ws

import chess.{ ByColor, Color }
import chess.format.{ Fen, Uci }
import chess.{ ByColor, Color }
import ornicar.scalalib.SecureRandom

object User:
Expand Down
9 changes: 5 additions & 4 deletions src/main/scala/netty/ActorChannelConnector.scala
Original file line number Diff line number Diff line change
@@ -1,14 +1,15 @@
package lila.ws
package netty

import io.netty.buffer.Unpooled
import io.netty.channel.*
import io.netty.handler.codec.http.websocketx.*
import io.netty.util.concurrent.{ Future as NettyFuture, GenericFutureListener }
import lila.ws.Controller.Endpoint
import org.apache.pekko.actor.typed.ActorRef
import io.netty.channel.*

import ProtocolHandler.key
import io.netty.util.concurrent.{ Future as NettyFuture, GenericFutureListener }
import ipc.ClientIn
import io.netty.handler.codec.http.websocketx.*
import io.netty.buffer.Unpooled

final private class ActorChannelConnector(clients: ActorRef[Clients.Control])(using Executor):

Expand Down
1 change: 1 addition & 0 deletions src/main/scala/netty/FrameHandler.scala
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ import com.typesafe.scalalogging.Logger
import io.netty.channel.*
import io.netty.handler.codec.http.websocketx.*
import io.netty.util.concurrent.GenericFutureListener

import ipc.ClientOut

final private class FrameHandler(using Executor) extends SimpleChannelInboundHandler[WebSocketFrame]:
Expand Down
Loading

0 comments on commit 607467f

Please sign in to comment.