173 lines
5.3 KiB
Scala
173 lines
5.3 KiB
Scala
package controllers
|
|
|
|
import play.api.mvc._
|
|
import views._
|
|
|
|
import lila.api.Context
|
|
import lila.app._
|
|
import lila.streamer.{ Streamer => StreamerModel, StreamerForm }
|
|
|
|
final class Streamer(
|
|
env: Env,
|
|
apiC: => Api
|
|
) extends LilaController(env) {
|
|
|
|
private def api = env.streamer.api
|
|
|
|
def index(page: Int) =
|
|
Open { implicit ctx =>
|
|
ctx.noKid ?? {
|
|
pageHit
|
|
val requests = getBool("requests") && isGranted(_.Streamers)
|
|
for {
|
|
liveStreams <- env.streamer.liveStreamApi.all
|
|
live <- api withUsers liveStreams
|
|
pager <- env.streamer.pager.notLive(page, liveStreams, requests)
|
|
} yield Ok(html.streamer.index(live, pager, requests))
|
|
}
|
|
}
|
|
|
|
def live =
|
|
apiC.ApiRequest { _ =>
|
|
env.user.lightUserApi asyncMany env.streamer.liveStreamApi.userIds.toList dmap (_.flatten) map {
|
|
users =>
|
|
apiC.toApiResult {
|
|
users.map { u =>
|
|
lila.common.LightUser.lightUserWrites.writes(u)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
def show(username: String) =
|
|
Open { implicit ctx =>
|
|
ctx.noKid ?? {
|
|
OptionFuResult(api find username) { s =>
|
|
WithVisibleStreamer(s) {
|
|
for {
|
|
sws <- env.streamer.liveStreamApi of s
|
|
activity <- env.activity.read.recent(sws.user, 10)
|
|
} yield Ok(html.streamer.show(sws, activity))
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
def create =
|
|
AuthBody { implicit ctx => me =>
|
|
ctx.noKid ?? {
|
|
NoLame {
|
|
NoShadowban {
|
|
api find me flatMap {
|
|
case None => api.create(me) inject Redirect(routes.Streamer.edit())
|
|
case _ => Redirect(routes.Streamer.edit()).fuccess
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private def modData(streamer: StreamerModel)(implicit ctx: Context) =
|
|
isGranted(_.ModLog) ?? {
|
|
env.mod.logApi.userHistory(streamer.userId) zip
|
|
env.user.noteApi.forMod(streamer.userId) zip
|
|
env.streamer.api.sameChannels(streamer) map some
|
|
}
|
|
|
|
def edit =
|
|
Auth { implicit ctx => _ =>
|
|
AsStreamer { s =>
|
|
env.streamer.liveStreamApi of s flatMap { sws =>
|
|
modData(s.streamer) map { forMod =>
|
|
NoCache(Ok(html.streamer.edit(sws, StreamerForm userForm sws.streamer, forMod)))
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
def editApply =
|
|
AuthBody { implicit ctx => me =>
|
|
AsStreamer { s =>
|
|
env.streamer.liveStreamApi of s flatMap { sws =>
|
|
implicit val req = ctx.body
|
|
StreamerForm
|
|
.userForm(sws.streamer)
|
|
.bindFromRequest()
|
|
.fold(
|
|
error =>
|
|
modData(s.streamer) map { forMod =>
|
|
BadRequest(html.streamer.edit(sws, error, forMod))
|
|
},
|
|
data =>
|
|
api.update(sws.streamer, data, isGranted(_.Streamers)) flatMap { change =>
|
|
change.list foreach { env.mod.logApi.streamerList(lila.report.Mod(me), s.user.id, _) }
|
|
change.tier foreach { env.mod.logApi.streamerTier(lila.report.Mod(me), s.user.id, _) }
|
|
if (data.approval.flatMap(_.quick).isDefined)
|
|
env.streamer.pager.nextRequestId map { nextId =>
|
|
Redirect {
|
|
nextId.fold(s"${routes.Streamer.index()}?requests=1") { id =>
|
|
s"${routes.Streamer.edit().url}?u=$id"
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
val next = if (sws.streamer is me) "" else s"?u=${sws.user.id}"
|
|
Redirect(s"${routes.Streamer.edit().url}$next").fuccess
|
|
}
|
|
}
|
|
)
|
|
}
|
|
}
|
|
}
|
|
|
|
def approvalRequest =
|
|
AuthBody { _ => me =>
|
|
api.approval.request(me) inject Redirect(routes.Streamer.edit())
|
|
}
|
|
|
|
def picture =
|
|
Auth { implicit ctx => _ =>
|
|
AsStreamer { s =>
|
|
NoCache(Ok(html.streamer.picture(s))).fuccess
|
|
}
|
|
}
|
|
|
|
def pictureApply =
|
|
AuthBody(parse.multipartFormData) { implicit ctx => _ =>
|
|
AsStreamer { s =>
|
|
ctx.body.body.file("picture") match {
|
|
case Some(pic) =>
|
|
api.uploadPicture(s.streamer, pic) recover { case e: Exception =>
|
|
BadRequest(html.streamer.picture(s, e.getMessage.some))
|
|
} inject Redirect(routes.Streamer.edit())
|
|
case None => fuccess(Redirect(routes.Streamer.edit()))
|
|
}
|
|
}
|
|
}
|
|
|
|
def pictureDelete =
|
|
Auth { implicit ctx => _ =>
|
|
AsStreamer { s =>
|
|
api.deletePicture(s.streamer) inject Redirect(routes.Streamer.edit())
|
|
}
|
|
}
|
|
|
|
private def AsStreamer(f: StreamerModel.WithUser => Fu[Result])(implicit ctx: Context) =
|
|
ctx.me.fold(notFound) { me =>
|
|
if (StreamerModel canApply me)
|
|
api.find(get("u").ifTrue(isGranted(_.Streamers)) | me.id) flatMap {
|
|
_.fold(Ok(html.streamer.bits.create).fuccess)(f)
|
|
}
|
|
else
|
|
Ok(
|
|
html.site.message("Too soon")(
|
|
scalatags.Text.all.raw("You are not yet allowed to create a streamer profile.")
|
|
)
|
|
).fuccess
|
|
}
|
|
|
|
private def WithVisibleStreamer(s: StreamerModel.WithUser)(f: Fu[Result])(implicit ctx: Context) =
|
|
if (s.streamer.isListed || ctx.me.??(s.streamer.is) || isGranted(_.Admin)) f
|
|
else notFound
|
|
}
|