deepcrayon
/
lila
1
0
Fork 0
Code Releases Activity

remote socket redis ping

pull/7901/head
Thibault Duplessis 2021-01-12 20:20:06 +01:00
parent 7c5b63e495
commit 1f354aceff
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
modules/round/src/main/RoundSocket.scala
View File

@ -146,6 +146,7 @@ final class RoundSocket(
versions foreach { case (roomId, version) =>
rounds.tell(roomId, SetVersion(version))
}
case P.In.Ping(id) => send(P.Out.pong(id))
case P.In.WsBoot =>
logger.warn("Remote socket boot")
// schedule termination for all game ducts

10
modules/socket/src/main/RemoteSocket.scala
View File

@ -61,9 +61,6 @@ final class RemoteSocket(
Bus.publish(TellSriIn(sri.value, userId, msg), s"remoteSocketIn:$typ")
case In.TellUser(userId, typ, msg) =>
Bus.publish(TellUserIn(userId, msg), s"remoteSocketIn:$typ")
case In.WsBoot =>
logger.warn("Remote socket boot")
onlineUserIds set Set("lichess")
case In.ReqResponse(reqId, response) =>
requests
.computeIfPresent(
@ -74,6 +71,10 @@ final class RemoteSocket(
}
)
.unit
case In.Ping(id) => send(Out.pong(id))
case In.WsBoot =>
logger.warn("Remote socket boot")
onlineUserIds set Set("lichess")
}
Bus.subscribeFun(
@ -193,6 +194,7 @@ object RemoteSocket {
case class TellSri(sri: Sri, userId: Option[String], typ: String, msg: JsObject) extends In
case class TellUser(userId: String, typ: String, msg: JsObject) extends In
case class ReqResponse(reqId: Int, response: String) extends In
case class Ping(id: String) extends In
val baseReader: Reader = raw =>
raw.path match {
@ -232,6 +234,7 @@ object RemoteSocket {
raw.get(2) { case Array(reqId, response) =>
reqId.toIntOption map { ReqResponse(_, response) }
}
case "ping" => Ping(raw.args).some
case "boot" => WsBoot.some
case _ => none
}
@ -273,6 +276,7 @@ object RemoteSocket {
def unfollow(u1: String, u2: String) = s"rel/unfollow $u1 $u2"
def apiUserOnline(u: String, v: Boolean) = s"api/online $u ${boolean(v)}"
def boot = "boot"
def pong(id: String) = s"pong $id"
def stop(reqId: Int) = s"lila/stop $reqId"
def commas(strs: Iterable[Any]): String = if (strs.isEmpty) "-" else strs mkString ","