request room versions for tour, simul and study
parent
085488d4b0
commit
2fb42fa9c5
|
@ -76,7 +76,7 @@ object RoomSocket {
|
|||
}
|
||||
case P.In.WsBoot =>
|
||||
logger.warn("Remote socket boot")
|
||||
rooms.killAll
|
||||
// rooms.killAll // apparently not
|
||||
case Protocol.In.SetVersions(versions) => versions foreach {
|
||||
case (roomId, version) => rooms.tell(roomId, SetVersion(version))
|
||||
}
|
||||
|
|
|
@ -55,5 +55,7 @@ private final class SimulSocket(
|
|||
|
||||
private lazy val send: String => Unit = remoteSocketApi.makeSender("simul-out").apply _
|
||||
|
||||
remoteSocketApi.subscribe("simul-in", RP.In.reader)(handler orElse remoteSocketApi.baseHandler)
|
||||
remoteSocketApi.subscribe("simul-in", RP.In.reader)(
|
||||
handler orElse remoteSocketApi.baseHandler
|
||||
) >>- send(P.Out.boot)
|
||||
}
|
||||
|
|
|
@ -208,7 +208,7 @@ private final class StudySocket(
|
|||
|
||||
remoteSocketApi.subscribe("study-in", Protocol.In.reader)(
|
||||
studyHandler orElse rHandler orElse remoteSocketApi.baseHandler
|
||||
)
|
||||
) >>- send(P.Out.boot)
|
||||
|
||||
// send API
|
||||
|
||||
|
|
|
@ -83,7 +83,7 @@ private final class TournamentSocket(
|
|||
|
||||
remoteSocketApi.subscribe("tour-in", Protocol.In.reader)(
|
||||
tourHandler orElse handler orElse remoteSocketApi.baseHandler
|
||||
)
|
||||
) >>- send(P.Out.boot)
|
||||
|
||||
object Protocol {
|
||||
|
||||
|
|
Loading…
Reference in New Issue