in app/models/ServerTokenDAORedis.scala [22:37]
override def get(tokenValue: String): Future[Option[ServerTokenEntry]] =
redisClient.get(s"vaultdoor:servertoken:$tokenValue")
.map(_.map(io.circe.parser.parse)).flatMap({
case None=>Future(None)
case Some(Left(parseError))=>
logger.error(s"Could not parse content for server token '$tokenValue' from redis: ${parseError.toString}, deleting it")
redisClient.del(s"vaultdoor:servertoken:$tokenValue").map(_=>None)
case Some(Right(json))=>
json.as[ServerTokenEntry] match {
case Left(marshalErr)=>
logger.error(s"Could not marshal content for server token '$tokenValue from redis: ${marshalErr.toString}, deleting it")
redisClient.del(s"vaultdoor:servertoken:$tokenValue").map(_=>None)
case Right(tok)=>
Future(Some(tok))
}
})