always multi-PM a stream source
parent
11968dd7ae
commit
b8723a94e3
|
@ -1,6 +1,7 @@
|
||||||
package controllers
|
package controllers
|
||||||
|
|
||||||
import play.api.mvc._
|
import play.api.mvc._
|
||||||
|
import akka.stream.scaladsl._
|
||||||
|
|
||||||
import lila.api.Context
|
import lila.api.Context
|
||||||
import lila.app._
|
import lila.app._
|
||||||
|
@ -149,7 +150,7 @@ final class Clas(
|
||||||
Reasonable(clas, students, "notify") {
|
Reasonable(clas, students, "notify") {
|
||||||
val url = routes.Clas.show(clas.id.value).url
|
val url = routes.Clas.show(clas.id.value).url
|
||||||
val full = if (text contains url) text else s"$text\n\n${env.net.baseUrl}$url"
|
val full = if (text contains url) text else s"$text\n\n${env.net.baseUrl}$url"
|
||||||
env.msg.api.multiPostBatch(me, students.map(_.user.id), full) inject
|
env.msg.api.multiPost(me, Source(students.map(_.user.id)), full) inject
|
||||||
Redirect(routes.Clas.show(clas.id.value)).flashSuccess
|
Redirect(routes.Clas.show(clas.id.value)).flashSuccess
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -127,13 +127,6 @@ final class MsgApi(
|
||||||
def systemPost(destId: User.ID, text: String) =
|
def systemPost(destId: User.ID, text: String) =
|
||||||
post(User.lichessId, destId, text, unlimited = true)
|
post(User.lichessId, destId, text, unlimited = true)
|
||||||
|
|
||||||
def multiPostBatch(orig: User, dests: Iterable[User.ID], text: String): Funit =
|
|
||||||
lila.common.Future
|
|
||||||
.linear(dests.filter(orig.id !=)) {
|
|
||||||
post(orig.id, _, text, unlimited = true).logFailure(logger).nevermind
|
|
||||||
}
|
|
||||||
.void
|
|
||||||
|
|
||||||
def multiPost(orig: User, destSource: Source[User.ID, _], text: String): Funit =
|
def multiPost(orig: User, destSource: Source[User.ID, _], text: String): Funit =
|
||||||
destSource
|
destSource
|
||||||
.filter(orig.id !=)
|
.filter(orig.id !=)
|
||||||
|
|
Loading…
Reference in New Issue