deepcrayon/lila
deepcrayon/lila
1
0
Fork 0
Code Releases Activity

code tweak

Browse source
This commit is contained in:
Thibault Duplessis 2019-12-22 19:52:43 -05:00
parent 958684faa7
commit 683a12c642
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
modules/relation/src/main/RelationActor.scala
View file

@ -153,15 +153,17 @@ final private[relation] class RelationActor(
.sequenceFu
.void
private def notifyFollowersGameStateChanged(userIds: Iterable[ID], message: String) =
private def notifyFollowersGameStateChanged(userIds: Iterable[ID], message: String) = {
val onlineIds = online.userIds()
userIds
.map { userId =>
api.fetchFollowersFromSecondary(userId) map online.userIds().intersect map { ids =>
api.fetchFollowersFromSecondary(userId) map onlineIds.intersect map { ids =>
if (ids.nonEmpty) Bus.publish(SendTos(ids, message, userId), "socketUsers")
}
}
.sequenceFu
.mon(_.relation.actor.gameStateChanged)
}
private def notifyFollowersFriendInStudyStateChanged(userId: ID, message: String) =
api