ci: bump version to v4.52.0

CHANGELOG.md

@@ -448,3 +448,8 @@
 ### Features
 
 * Update ID mapping in OpenIDUserInfo to use hashed value and remove name field ([daa072f](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/daa072f2bf260ed62402096b41ce85aa071efaf5))
+##  (2026-01-21)
+
+### Features
+
+* Implement OAuth session management with Redis caching for OpenID user data ([0430c7f](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/0430c7f4deb37661c697406a714e2693bf0c7307))

knockoutwhistweb/app/controllers/OpenIDController.scala

@@ -1,13 +1,15 @@
 package controllers
 
+import com.github.benmanes.caffeine.cache.{Cache, Caffeine}
 import logic.user.{SessionManager, UserManager}
 import model.users.User
 import play.api.{Configuration, Logger}
 import play.api.libs.json.Json
 import play.api.mvc.*
 import play.api.mvc.Cookie.SameSite.Lax
-import services.{OpenIDConnectService, OpenIDUserInfo}
+import services.{OpenIDConnectService, OpenIDUserInfo, OAuthCacheService}
 
+import java.util.concurrent.TimeUnit
 import javax.inject.*
 import scala.concurrent.{ExecutionContext, Future}
 
@@ -17,7 +19,8 @@ class OpenIDController @Inject()(
                                   val openIDService: OpenIDConnectService,
                                   val sessionManager: SessionManager,
                                   val userManager: UserManager,
-                                  val config: Configuration
+                                  val config: Configuration,
+                                  val oauthCache: OAuthCacheService
                                 )(implicit ec: ExecutionContext) extends BaseController {
 
   private val logger = Logger(this.getClass)
@@ -83,13 +86,11 @@ class OpenIDController @Inject()(
                         .removingFromSession("oauth_state", "oauth_nonce", "oauth_provider", "oauth_access_token"))
                     case None =>
                       logger.warn(s"User ${userInfo.name} (${userInfo.id}) not found, creating new user")
-                      // New user, redirect to username selection
+                      // Store OAuth data in cache and get session ID
+                      val oauthSessionId = oauthCache.storeOAuthData(userInfo, tokenResponse.accessToken, provider)
+                      // New user, redirect to username selection with only session ID
                       Future.successful(Redirect(config.get[String]("openid.selectUserRoute"))
-                        .withSession(
+                        .withSession("oauth_session_id" -> oauthSessionId))
-                          "oauth_user_info" -> Json.toJson(userInfo).toString(),
-                          "oauth_provider" -> provider,
-                          "oauth_access_token" -> tokenResponse.accessToken
-                        ))
                   }
                 case None =>
                   logger.error("Failed to retrieve user information")
@@ -107,18 +108,24 @@ class OpenIDController @Inject()(
   }
 
   def selectUsername(): Action[AnyContent] = Action.async { implicit request =>
-    request.session.get("oauth_user_info") match {
+    request.session.get("oauth_session_id") match {
-      case Some(userInfoJson) =>
+      case Some(sessionId) =>
-        val userInfo = Json.parse(userInfoJson).as[OpenIDUserInfo]
+        oauthCache.getOAuthData(sessionId) match {
-        Future.successful(Ok(Json.obj(
+          case Some((userInfo, _, _)) =>
-          "id" -> userInfo.id,
+            Future.successful(Ok(Json.obj(
-          "email" -> userInfo.email,
+              "id" -> userInfo.id,
-          "name" -> userInfo.name,
+              "email" -> userInfo.email,
-          "picture" -> userInfo.picture,
+              "name" -> userInfo.name,
-          "provider" -> userInfo.provider,
+              "picture" -> userInfo.picture,
-          "providerName" -> userInfo.providerName
+              "provider" -> userInfo.provider,
-        )))
+              "providerName" -> userInfo.providerName
+            )))
+          case None =>
+            logger.error(s"OAuth session data not found for session ID: $sessionId")
+            Future.successful(Redirect("/login").flashing("error" -> "Session expired"))
+        }
       case None =>
+        logger.error("No OAuth session ID found")
         Future.successful(Redirect("/login").flashing("error" -> "No authentication information found"))
     }
   }
@@ -126,48 +133,53 @@ class OpenIDController @Inject()(
   def submitUsername(): Action[AnyContent] = Action.async { implicit request =>
     val username = request.body.asJson.flatMap(json => (json \ "username").asOpt[String])
       .orElse(request.body.asFormUrlEncoded.flatMap(_.get("username").flatMap(_.headOption)))
-    val userInfoJson = request.session.get("oauth_user_info")
+    val sessionId = request.session.get("oauth_session_id")
-    val provider = request.session.get("oauth_provider").getOrElse("unknown")
     
-    (username, userInfoJson) match {
+    (username, sessionId) match {
-      case (Some(uname), Some(userInfoJson)) =>
+      case (Some(uname), Some(sid)) =>
-        val userInfo = Json.parse(userInfoJson).as[OpenIDUserInfo]
+        oauthCache.getOAuthData(sid) match {
-        
+          case Some((userInfo, accessToken, provider)) =>
-        // Check if username already exists
+            // Check if username already exists
-        val trimmedUsername = uname.trim
+            val trimmedUsername = uname.trim
-        userManager.userExists(trimmedUsername) match {
+            userManager.userExists(trimmedUsername) match {
-          case Some(_) =>
+              case Some(_) =>
-            Future.successful(Conflict(Json.obj("error" -> "Username already taken")))
+                Future.successful(Conflict(Json.obj("error" -> "Username already taken")))
-          case None =>
+              case None =>
-            // Create new user with OpenID info (no password needed)
+                // Create new user with OpenID info (no password needed)
-            val success = userManager.addOpenIDUser(trimmedUsername, userInfo)
+                val success = userManager.addOpenIDUser(trimmedUsername, userInfo)
-            if (success) {
+                if (success) {
-              // Get the created user and create session
+                  // Get created user and create session
-              userManager.userExists(trimmedUsername) match {
+                  userManager.userExists(trimmedUsername) match {
-                case Some(user) =>
+                    case Some(user) =>
-                  val sessionToken = sessionManager.createSession(user)
+                      val sessionToken = sessionManager.createSession(user)
-                  Future.successful(Ok(Json.obj(
+                      // Clean up cache after successful user creation
-                    "message" -> "User created successfully",
+                      oauthCache.removeOAuthData(sid)
-                    "user" -> Json.obj(
+                      Future.successful(Ok(Json.obj(
-                      "id" -> user.id,
+                        "message" -> "User created successfully",
-                      "username" -> user.name
+                        "user" -> Json.obj(
-                    )
+                          "id" -> user.id,
-                  )).withCookies(Cookie(
+                          "username" -> user.name
-                    name = "accessToken",
+                        )
-                    value = sessionToken,
+                      )).withCookies(Cookie(
-                    httpOnly = true,
+                        name = "accessToken",
-                    secure = false,
+                        value = sessionToken,
-                    sameSite = Some(Lax)
+                        httpOnly = true,
-                  )).removingFromSession("oauth_user_info", "oauth_provider", "oauth_access_token"))
+                        secure = false,
-                case None =>
+                        sameSite = Some(Lax)
-                  Future.successful(InternalServerError(Json.obj("error" -> "Failed to create user session")))
+                      )).removingFromSession("oauth_session_id"))
-              }
+                    case None =>
-            } else {
+                      Future.successful(InternalServerError(Json.obj("error" -> "Failed to create user session")))
-              Future.successful(InternalServerError(Json.obj("error" -> "Failed to create user")))
+                  }
+                } else {
+                  Future.successful(InternalServerError(Json.obj("error" -> "Failed to create user")))
+                }
             }
+          case None =>
+            logger.error(s"OAuth session data not found for session ID: $sid")
+            Future.successful(Redirect("/login").flashing("error" -> "Session expired"))
         }
       case _ =>
-        Future.successful(BadRequest(Json.obj("error" -> "Username is required")))
+        Future.successful(BadRequest(Json.obj("error" -> "Username and valid session required")))
     }
   }
 }

knockoutwhistweb/app/services/OAuthCacheService.scala

@@ -0,0 +1,89 @@
+package services
+
+import org.redisson.Redisson
+import org.redisson.api.RMapCache
+import org.redisson.config.Config
+import play.api.Logger
+import play.api.libs.json.Json
+
+import java.util.concurrent.TimeUnit
+import javax.inject.*
+
+@Singleton
+class OAuthCacheService @Inject()() {
+  
+  private val logger = Logger(this.getClass)
+  
+  // Initialize Redis connection similar to Gateway
+  private val redis = {
+    val config: Config = Config()
+    val url = "redis://" + sys.env.getOrElse("REDIS_HOST", "localhost") + ":" + sys.env.getOrElse("REDIS_PORT", "6379")
+    logger.info(s"OAuthCacheService connecting to Redis at $url")
+    config.useSingleServer.setAddress(url)
+    Redisson.create(config)
+  }
+  
+  // Cache for OAuth data with 30 minute TTL
+  private val oauthCache: RMapCache[String, String] = redis.getMapCache("oauth_cache")
+  
+  /**
+   * Store OAuth data with random ID and return the ID
+   */
+  def storeOAuthData(userInfo: OpenIDUserInfo, accessToken: String, provider: String): String = {
+    val sessionId = java.util.UUID.randomUUID().toString
+    
+    val oauthData = Json.obj(
+      "userInfo" -> Json.toJson(userInfo),
+      "accessToken" -> accessToken,
+      "provider" -> provider,
+      "timestamp" -> System.currentTimeMillis()
+    ).toString()
+    
+    // Store with 30 minute TTL
+    oauthCache.put(sessionId, oauthData, 30, TimeUnit.MINUTES)
+    logger.info(s"Stored OAuth data for session $sessionId")
+    
+    sessionId
+  }
+  
+  /**
+   * Retrieve OAuth data by session ID
+   */
+  def getOAuthData(sessionId: String): Option[(OpenIDUserInfo, String, String)] = {
+    Option(oauthCache.get(sessionId)) match {
+      case Some(dataJson) =>
+        try {
+          val json = Json.parse(dataJson)
+          val userInfo = (json \ "userInfo").as[OpenIDUserInfo]
+          val accessToken = (json \ "accessToken").as[String]
+          val provider = (json \ "provider").as[String]
+          
+          logger.info(s"Retrieved OAuth data for session $sessionId")
+          Some((userInfo, accessToken, provider))
+        } catch {
+          case e: Exception =>
+            logger.error(s"Failed to parse OAuth data for session $sessionId: ${e.getMessage}")
+            None
+        }
+      case None =>
+        logger.warn(s"No OAuth data found for session $sessionId")
+        None
+    }
+  }
+  
+  /**
+   * Remove OAuth data after use
+   */
+  def removeOAuthData(sessionId: String): Unit = {
+    oauthCache.remove(sessionId)
+    logger.info(s"Removed OAuth data for session $sessionId")
+  }
+  
+  /**
+   * Clean up expired sessions (optional maintenance)
+   */
+  def cleanupExpiredSessions(): Unit = {
+    oauthCache.clear()
+    logger.info("Cleaned up expired OAuth sessions")
+  }
+}

knockoutwhistweb/app/services/OpenIDConnectService.scala

@@ -138,9 +138,9 @@ class OpenIDConnectService@Inject(ws: WSClient, config: Configuration)(implicit
             if (response.status == 200) {
               val json = response.json
               Some(OpenIDUserInfo(
-                id = (json \ provider.idClaimName).as[String].hashCode.toString,
+                id = (json \ provider.idClaimName).as[String],
                 email = (json \ "email").asOpt[String],
-                name = None,
+                name = (json \ "name").asOpt[String].orElse((json \ "login").asOpt[String]),
                 picture = (json \ "picture").asOpt[String].orElse((json \ "avatar_url").asOpt[String]),
                 provider = providerName,
                 providerName = provider.name

versions.env

@@ -1,3 +1,3 @@
 MAJOR=4
-MINOR=51
+MINOR=52
 PATCH=0