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

save pool hook config in DB

Browse source
This commit is contained in:
Thibault Duplessis 2016-12-03 01:57:28 +01:00
parent 590ee17afd
commit cb8595b491
2 changed files with 17 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
app/controllers/Setup.scala
View file

@ -38,9 +38,8 @@ object Setup extends LilaController with TheftPrevention {
}
}
def ai = process(env.forms.ai) { config =>
implicit ctx =>
env.processor ai config
def ai = process(env.forms.ai) { config => implicit ctx =>
env.processor ai config
}
def friendForm(userId: Option[String]) = Open { implicit ctx =>
@ -78,10 +77,10 @@ object Setup extends LilaController with TheftPrevention {
variant = config.variant,
initialFen = config.fen,
timeControl = config.makeClock map { c =>
TimeControl.Clock(c.limit, c.increment)
} orElse config.makeDaysPerTurn.map {
TimeControl.Correspondence.apply
} getOrElse TimeControl.Unlimited,
TimeControl.Clock(c.limit, c.increment)
} orElse config.makeDaysPerTurn.map {
TimeControl.Correspondence.apply
} getOrElse TimeControl.Unlimited,
mode = config.mode,
color = config.color.name,
challenger = (ctx.me, HTTPRequest sid req) match {
@ -123,6 +122,8 @@ object Setup extends LilaController with TheftPrevention {
case HookResult.Refused => BadRequest(jsonError("Game was not created"))
}
private val hookSaveOnlyResponse = Ok(Json.obj("ok" -> true))
private val hookRefused = BadRequest(jsonError("Game was not created"))
def hook(uid: String) = OpenBody { implicit ctx =>
@ -133,10 +134,12 @@ object Setup extends LilaController with TheftPrevention {
err => negotiate(
html = BadRequest(errorsAsJson(err).toString).fuccess,
api = _ => BadRequest(errorsAsJson(err)).fuccess),
config => (ctx.userId ?? Env.relation.api.fetchBlocking) flatMap {
blocking =>
env.processor.hook(config, uid, HTTPRequest sid req, blocking) map hookResponse
}
config =>
if (getBool("pool")) env.processor.saveHookConfig(config) inject hookSaveOnlyResponse
else (ctx.userId ?? Env.relation.api.fetchBlocking) flatMap {
blocking =>
env.processor.hook(config, uid, HTTPRequest sid req, blocking) map hookResponse
}
)
}
}

3
modules/setup/src/main/Processor.scala
View file

@ -67,6 +67,9 @@ private[setup] final class Processor(
def saveFriendConfig(config: FriendConfig)(implicit ctx: UserContext) =
saveConfig(_ withFriend config)
def saveHookConfig(config: HookConfig)(implicit ctx: UserContext) =
saveConfig(_ withHook config)
private def saveConfig(map: UserConfig => UserConfig)(implicit ctx: UserContext): Funit =
ctx.me.fold(AnonConfigRepo.update(ctx.req) _)(user => UserConfigRepo.update(user) _)(map)
}