Compare commits
29 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5f8afbf236 | ||
| 3b7a1e3c64 | |||
|
|
5af5785fa0 | ||
|
|
9510147806 | ||
| e17f59e614 | |||
| 8126b46a0a | |||
| 25dd9264b5 | |||
| 5f9ef2beb0 | |||
| ccf993bff2 | |||
| 1d05bd43b4 | |||
| 3e067346ff | |||
| b2527ed041 | |||
|
|
06d150b8c5 | ||
| 0cbac61b4a | |||
| 088dda8d52 | |||
|
|
c3d10f31ac | ||
| e4384ee894 | |||
|
|
d667a2f68c | ||
| 35f608513d | |||
|
|
13038b0cb9 | ||
| b17aae5795 | |||
|
|
421f769cb6 | ||
| bd7a055a09 | |||
|
|
e2a2b56174 | ||
| 2a29ca8cdd | |||
|
|
266cbe7509 | ||
| e8b31b1748 | |||
|
|
8812b0fad4 | ||
| dd5e8e65e5 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -134,6 +134,7 @@ target
|
|||||||
/.project
|
/.project
|
||||||
/.settings
|
/.settings
|
||||||
/RUNNING_PID
|
/RUNNING_PID
|
||||||
|
/knockoutwhistwebfrontend/
|
||||||
/knockoutwhist/
|
/knockoutwhist/
|
||||||
/knockoutwhistweb/.g8/
|
/knockoutwhistweb/.g8/
|
||||||
/knockoutwhistweb/.bsp/
|
/knockoutwhistweb/.bsp/
|
||||||
|
|||||||
58
CHANGELOG.md
58
CHANGELOG.md
@@ -224,3 +224,61 @@
|
|||||||
### Bug Fixes
|
### Bug Fixes
|
||||||
|
|
||||||
* FRO-29 Websocket Communication ([#104](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/104)) ([fa3d21e](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/fa3d21e3038eb07369764850a9ad9badd269ac57))
|
* FRO-29 Websocket Communication ([#104](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/104)) ([fa3d21e](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/fa3d21e3038eb07369764850a9ad9badd269ac57))
|
||||||
|
## (2025-12-10)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* BAC-27 Implemented endpoint which returns information about the current state ([#103](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/103)) ([dd5e8e6](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/dd5e8e65e55f02a7618b3c60e8fc7087774e5106))
|
||||||
|
## (2025-12-10)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* FRO-2 Implement Login Component ([#105](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/105)) ([e8b31b1](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/e8b31b174819b5f033034501856c4b1189c4c4ee))
|
||||||
|
## (2025-12-10)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* FRO-20 Create scoreboard component ([#106](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/106)) ([2a29ca8](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/2a29ca8cdd3ef55f6f66f00b5e7727e1b1af1458))
|
||||||
|
## (2025-12-10)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* **api:** FRO-14 Create Game ([#107](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/107)) ([bd7a055](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/bd7a055a0944a1c5219f21bb080bf658229f49e9))
|
||||||
|
## (2025-12-11)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* FRO-31 Small backend changes ([#108](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/108)) ([b17aae5](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/b17aae5795b35ce3805db87c9bf741a5a96cd5ac))
|
||||||
|
## (2025-12-14)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* Update routing and websocket configuration for game state management ([#109](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/109)) ([35f6085](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/35f608513dd80eece46d49b40ecf31c8e915d307))
|
||||||
|
## (2025-12-18)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* **ui:** FRO-36 PWA ([#110](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/issues/110)) ([e4384ee](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/e4384ee8945ac462fe1f3580215117e0a438f71a))
|
||||||
|
## (2026-01-06)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* Enhance win effects and animations in OfflineView component ([088dda8](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/088dda8d528edb9f3fd420e7e69eb44144d39eff))
|
||||||
|
## (2026-01-07)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* Add GatewayModule for enhanced module configuration ([1d05bd4](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/1d05bd43b482564636345322a2cecf58f7d229d0))
|
||||||
|
* Enhance Dockerfile with secret management for GitHub credentials ([5f9ef2b](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/5f9ef2beb0a6e7d5e8caf436f545bbd78a6b242e))
|
||||||
|
* Simplify Dockerfile by removing multi-stage build and adjusting file copy paths ([e17f59e](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/e17f59e614a0060b70514c2337ac6fd84688546e))
|
||||||
|
* Update build.sbt and Dockerfile for improved GitHub credentials handling ([8126b46](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/8126b46a0a1649d2b20b31975603f7610fafd18b))
|
||||||
|
* Update build.sbt and Dockerfile for improved GitHub credentials handling ([25dd926](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/25dd9264b57ffafc5b01587ff5dda2e2188b5fbd))
|
||||||
|
* Update Dockerfile for multi-platform support and add nginx configuration ([ccf993b](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/ccf993bff25b4551a70c1f0263695f828df15a02))
|
||||||
|
* Update Dockerfile for multi-platform support and add nginx configuration ([3e06734](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/3e067346ffe3bdc62dc936ea8e79ae9293d86351))
|
||||||
|
* Update Dockerfile for multi-platform support and add nginx configuration ([b2527ed](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/b2527ed041568d20f880515b406fe0b0e10c12c1))
|
||||||
|
## (2026-01-07)
|
||||||
|
## (2026-01-07)
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* Update configuration files for CORS settings and add production environment ([3b7a1e3](https://git.janis-eccarius.de/KnockOutWhist/KnockOutWhist-Web/commit/3b7a1e3c646d870134d8d06b4962498b0e282cbd))
|
||||||
|
|||||||
26
Dockerfile
26
Dockerfile
@@ -1,26 +1,4 @@
|
|||||||
# === Stage 1: Build the Play application ===
|
FROM --platform=$TARGETPLATFORM eclipse-temurin:22-jre-alpine
|
||||||
FROM sbtscala/scala-sbt:eclipse-temurin-alpine-22_36_1.10.3_3.5.1 AS builder
|
|
||||||
|
|
||||||
WORKDIR /app
|
|
||||||
|
|
||||||
# Install Node.js and Less CSS preprocessor
|
|
||||||
USER root
|
|
||||||
RUN apk add --no-cache nodejs npm && \
|
|
||||||
npm install -g less
|
|
||||||
|
|
||||||
# Cache dependencies first
|
|
||||||
COPY project ./project
|
|
||||||
COPY build.sbt ./
|
|
||||||
RUN sbt -Dscoverage.skip=true update
|
|
||||||
|
|
||||||
# Copy the rest of the code
|
|
||||||
COPY . .
|
|
||||||
|
|
||||||
# Build the app and stage it
|
|
||||||
RUN sbt -Dscoverage.skip=true clean stage
|
|
||||||
|
|
||||||
# === Stage 2: Runtime image ===
|
|
||||||
FROM eclipse-temurin:21-jre-alpine
|
|
||||||
|
|
||||||
# Install Argon2 CLI and libraries
|
# Install Argon2 CLI and libraries
|
||||||
RUN apk add --no-cache bash argon2 argon2-libs
|
RUN apk add --no-cache bash argon2 argon2-libs
|
||||||
@@ -28,7 +6,7 @@ RUN apk add --no-cache bash argon2 argon2-libs
|
|||||||
WORKDIR /opt/playapp
|
WORKDIR /opt/playapp
|
||||||
|
|
||||||
# Copy staged Play build
|
# Copy staged Play build
|
||||||
COPY --from=builder /app/knockoutwhistweb/target/universal/stage /opt/playapp
|
COPY ./knockoutwhistweb/target/universal/stage /opt/playapp
|
||||||
|
|
||||||
# Expose the default Play port
|
# Expose the default Play port
|
||||||
EXPOSE 9000
|
EXPOSE 9000
|
||||||
|
|||||||
11
build.sbt
11
build.sbt
@@ -1,5 +1,12 @@
|
|||||||
ThisBuild / scalaVersion := "3.5.1"
|
ThisBuild / scalaVersion := "3.5.1"
|
||||||
|
|
||||||
|
credentials += Credentials(
|
||||||
|
"GitHub Package Registry",
|
||||||
|
"maven.pkg.github.com",
|
||||||
|
sys.env.getOrElse("GITHUB_USER", sys.error("GITHUB_USER not set")),
|
||||||
|
sys.env.getOrElse("GITHUB_TOKEN", sys.error("GITHUB_TOKEN not set"))
|
||||||
|
)
|
||||||
|
|
||||||
lazy val commonSettings = Seq(
|
lazy val commonSettings = Seq(
|
||||||
libraryDependencies += "org.scalactic" %% "scalactic" % "3.2.19",
|
libraryDependencies += "org.scalactic" %% "scalactic" % "3.2.19",
|
||||||
libraryDependencies += "org.scalatest" %% "scalatest" % "3.2.19" % "test",
|
libraryDependencies += "org.scalatest" %% "scalatest" % "3.2.19" % "test",
|
||||||
@@ -35,12 +42,16 @@ lazy val knockoutwhistweb = project.in(file("knockoutwhistweb"))
|
|||||||
.enablePlugins(PlayScala)
|
.enablePlugins(PlayScala)
|
||||||
.dependsOn(knockoutwhist % "compile->compile;test->test")
|
.dependsOn(knockoutwhist % "compile->compile;test->test")
|
||||||
.settings(
|
.settings(
|
||||||
|
|
||||||
|
resolvers += "GitHub Packages" at "https://maven.pkg.github.com/16Janis12/KnockOutWhist-Web",
|
||||||
|
|
||||||
commonSettings,
|
commonSettings,
|
||||||
libraryDependencies += "org.scalatestplus.play" %% "scalatestplus-play" % "7.0.2" % Test,
|
libraryDependencies += "org.scalatestplus.play" %% "scalatestplus-play" % "7.0.2" % Test,
|
||||||
libraryDependencies += "de.mkammerer" % "argon2-jvm" % "2.12",
|
libraryDependencies += "de.mkammerer" % "argon2-jvm" % "2.12",
|
||||||
libraryDependencies += "com.auth0" % "java-jwt" % "4.5.0",
|
libraryDependencies += "com.auth0" % "java-jwt" % "4.5.0",
|
||||||
libraryDependencies += "com.github.ben-manes.caffeine" % "caffeine" % "3.2.3",
|
libraryDependencies += "com.github.ben-manes.caffeine" % "caffeine" % "3.2.3",
|
||||||
libraryDependencies += "tools.jackson.module" %% "jackson-module-scala" % "3.0.2",
|
libraryDependencies += "tools.jackson.module" %% "jackson-module-scala" % "3.0.2",
|
||||||
|
libraryDependencies += "de.janis" % "knockoutwhist-data" % "1.0-SNAPSHOT",
|
||||||
JsEngineKeys.engineType := JsEngineKeys.EngineType.Node
|
JsEngineKeys.engineType := JsEngineKeys.EngineType.Node
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
Submodule knockoutwhistfrontend updated: 5d080bba47...e972f1c432
@@ -23,12 +23,12 @@ class AuthAction @Inject()(val sessionManager: SessionManager, val parser: BodyP
|
|||||||
case Some(user) =>
|
case Some(user) =>
|
||||||
block(new AuthenticatedRequest(user, request))
|
block(new AuthenticatedRequest(user, request))
|
||||||
case None =>
|
case None =>
|
||||||
Future.successful(Results.Redirect(routes.UserController.login()))
|
Future.successful(Results.Unauthorized)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
protected def getUserFromSession(request: RequestHeader): Option[User] = {
|
protected def getUserFromSession(request: RequestHeader): Option[User] = {
|
||||||
val session = request.cookies.get("sessionId")
|
val session = request.cookies.get("accessToken")
|
||||||
if (session.isDefined)
|
if (session.isDefined)
|
||||||
return sessionManager.getUserBySession(session.get.value)
|
return sessionManager.getUserBySession(session.get.value)
|
||||||
None
|
None
|
||||||
|
|||||||
@@ -44,8 +44,7 @@ class MainMenuController @Inject()(
|
|||||||
)
|
)
|
||||||
Ok(Json.obj(
|
Ok(Json.obj(
|
||||||
"status" -> "success",
|
"status" -> "success",
|
||||||
"redirectUrl" -> routes.IngameController.game(gameLobby.id).url,
|
"gameId" -> gameLobby.id,
|
||||||
"content" -> IngameController.returnInnerHTML(gameLobby, gameLobby.logic.getCurrentState, request.user).toString
|
|
||||||
))
|
))
|
||||||
} else {
|
} else {
|
||||||
BadRequest(Json.obj(
|
BadRequest(Json.obj(
|
||||||
|
|||||||
94
knockoutwhistweb/app/controllers/StatusController.scala
Normal file
94
knockoutwhistweb/app/controllers/StatusController.scala
Normal file
@@ -0,0 +1,94 @@
|
|||||||
|
package controllers
|
||||||
|
|
||||||
|
import auth.AuthAction
|
||||||
|
import logic.PodManager
|
||||||
|
import logic.game.GameLobby
|
||||||
|
import logic.user.SessionManager
|
||||||
|
import model.users.User
|
||||||
|
import play.api.libs.json.{JsValue, Json}
|
||||||
|
import play.api.mvc.*
|
||||||
|
import util.WebsocketEventMapper
|
||||||
|
|
||||||
|
import javax.inject.Inject
|
||||||
|
|
||||||
|
class StatusController @Inject()(
|
||||||
|
val controllerComponents: ControllerComponents,
|
||||||
|
val sessionManager: SessionManager,
|
||||||
|
val authAction: AuthAction
|
||||||
|
) extends BaseController {
|
||||||
|
|
||||||
|
def requestStatus(): Action[AnyContent] = {
|
||||||
|
Action { implicit request =>
|
||||||
|
val userOpt = getUserFromSession(request)
|
||||||
|
if (userOpt.isEmpty) {
|
||||||
|
Ok(
|
||||||
|
Json.obj(
|
||||||
|
"status" -> "unauthenticated"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
} else {
|
||||||
|
val user = userOpt.get
|
||||||
|
val gameOpt = PodManager.identifyGameOfUser(user)
|
||||||
|
if (gameOpt.isEmpty) {
|
||||||
|
Ok(
|
||||||
|
Json.obj(
|
||||||
|
"status" -> "authenticated",
|
||||||
|
"username" -> user.name,
|
||||||
|
"inGame" -> false
|
||||||
|
)
|
||||||
|
)
|
||||||
|
} else {
|
||||||
|
val game = gameOpt.get
|
||||||
|
Ok(
|
||||||
|
Json.obj(
|
||||||
|
"status" -> "authenticated",
|
||||||
|
"username" -> user.name,
|
||||||
|
"inGame" -> true,
|
||||||
|
"gameId" -> game.id
|
||||||
|
)
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def game(gameId: String): Action[AnyContent] = {
|
||||||
|
Action { implicit request =>
|
||||||
|
val userOpt = getUserFromSession(request)
|
||||||
|
if (userOpt.isEmpty) {
|
||||||
|
Unauthorized("User not authenticated")
|
||||||
|
} else {
|
||||||
|
val user = userOpt.get
|
||||||
|
val gameOpt = PodManager.getGame(gameId)
|
||||||
|
if (gameOpt.isEmpty) {
|
||||||
|
NotFound("Game not found")
|
||||||
|
} else {
|
||||||
|
val game = gameOpt.get
|
||||||
|
if (!game.getPlayers.contains(user.id)) {
|
||||||
|
Forbidden("User not part of this game")
|
||||||
|
} else {
|
||||||
|
Ok(
|
||||||
|
Json.obj(
|
||||||
|
"gameId" -> game.id,
|
||||||
|
"state" -> game.logic.getCurrentState.toString,
|
||||||
|
"data" -> mapGameState(game, user)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}}
|
||||||
|
|
||||||
|
private def getUserFromSession(request: RequestHeader): Option[User] = {
|
||||||
|
val session = request.cookies.get("accessToken")
|
||||||
|
if (session.isDefined)
|
||||||
|
return sessionManager.getUserBySession(session.get.value)
|
||||||
|
None
|
||||||
|
}
|
||||||
|
|
||||||
|
private def mapGameState(gameLobby: GameLobby, user: User): JsValue = {
|
||||||
|
val userSession = gameLobby.getUserSession(user.id)
|
||||||
|
WebsocketEventMapper.stateToJson(userSession)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@@ -1,10 +1,13 @@
|
|||||||
package controllers
|
package controllers
|
||||||
|
|
||||||
import auth.{AuthAction, AuthenticatedRequest}
|
import auth.{AuthAction, AuthenticatedRequest}
|
||||||
|
import dto.subDTO.UserDTO
|
||||||
import logic.user.{SessionManager, UserManager}
|
import logic.user.{SessionManager, UserManager}
|
||||||
|
import model.users.User
|
||||||
import play.api.*
|
import play.api.*
|
||||||
import play.api.libs.json.Json
|
import play.api.libs.json.Json
|
||||||
import play.api.mvc.*
|
import play.api.mvc.*
|
||||||
|
import play.api.mvc.Cookie.SameSite.{Lax, None, Strict}
|
||||||
|
|
||||||
import javax.inject.*
|
import javax.inject.*
|
||||||
|
|
||||||
@@ -21,22 +24,6 @@ class UserController @Inject()(
|
|||||||
val authAction: AuthAction
|
val authAction: AuthAction
|
||||||
) extends BaseController {
|
) extends BaseController {
|
||||||
|
|
||||||
def login(): Action[AnyContent] = {
|
|
||||||
Action { implicit request =>
|
|
||||||
val session = request.cookies.get("sessionId")
|
|
||||||
if (session.isDefined) {
|
|
||||||
val possibleUser = sessionManager.getUserBySession(session.get.value)
|
|
||||||
if (possibleUser.isDefined) {
|
|
||||||
Redirect(routes.MainMenuController.mainMenu())
|
|
||||||
} else {
|
|
||||||
Ok(views.html.main("Login")(views.html.login.login()))
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
Ok(views.html.main("Login")(views.html.login.login()))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
def login_Post(): Action[AnyContent] = {
|
def login_Post(): Action[AnyContent] = {
|
||||||
Action { implicit request =>
|
Action { implicit request =>
|
||||||
val jsonBody = request.body.asJson
|
val jsonBody = request.body.asJson
|
||||||
@@ -51,12 +38,17 @@ class UserController @Inject()(
|
|||||||
val possibleUser = userManager.authenticate(username.get, password.get)
|
val possibleUser = userManager.authenticate(username.get, password.get)
|
||||||
if (possibleUser.isDefined) {
|
if (possibleUser.isDefined) {
|
||||||
Ok(Json.obj(
|
Ok(Json.obj(
|
||||||
"status" -> "success",
|
"user" -> Json.obj(
|
||||||
"redirectUrl" -> routes.MainMenuController.mainMenu().url,
|
"id" -> possibleUser.get.id,
|
||||||
"content" -> views.html.mainmenu.creategame(possibleUser).toString
|
"username" -> possibleUser.get.name
|
||||||
)).withCookies(
|
|
||||||
Cookie("sessionId", sessionManager.createSession(possibleUser.get))
|
|
||||||
)
|
)
|
||||||
|
)).withCookies(Cookie(
|
||||||
|
name = "accessToken",
|
||||||
|
value = sessionManager.createSession(possibleUser.get),
|
||||||
|
httpOnly = true,
|
||||||
|
secure = false,
|
||||||
|
sameSite = Some(Lax)
|
||||||
|
))
|
||||||
} else {
|
} else {
|
||||||
Unauthorized("Invalid username or password")
|
Unauthorized("Invalid username or password")
|
||||||
}
|
}
|
||||||
@@ -66,13 +58,20 @@ class UserController @Inject()(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Pass the request-handling function directly to authAction (no nested Action)
|
def getUserInfo(): Action[AnyContent] = authAction { implicit request: AuthenticatedRequest[AnyContent] =>
|
||||||
def logout(): Action[AnyContent] = authAction { implicit request: AuthenticatedRequest[AnyContent] =>
|
val user: User = request.user
|
||||||
val sessionCookie = request.cookies.get("sessionId")
|
Ok(Json.obj(
|
||||||
|
"id" -> user.id,
|
||||||
|
"username" -> user.name
|
||||||
|
))
|
||||||
|
}
|
||||||
|
|
||||||
|
def logoutPost(): Action[AnyContent] = authAction { implicit request: AuthenticatedRequest[AnyContent] =>
|
||||||
|
val sessionCookie = request.cookies.get("accessToken")
|
||||||
if (sessionCookie.isDefined) {
|
if (sessionCookie.isDefined) {
|
||||||
sessionManager.invalidateSession(sessionCookie.get.value)
|
sessionManager.invalidateSession(sessionCookie.get.value)
|
||||||
}
|
}
|
||||||
Redirect(routes.UserController.login()).discardingCookies(DiscardingCookie("sessionId"))
|
NoContent.discardingCookies(DiscardingCookie("accessToken"))
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -21,7 +21,7 @@ class WebsocketController @Inject()(
|
|||||||
)(implicit system: ActorSystem, mat: Materializer) extends AbstractController(cc) {
|
)(implicit system: ActorSystem, mat: Materializer) extends AbstractController(cc) {
|
||||||
|
|
||||||
def socket(): WebSocket = WebSocket.accept[String, String] { request =>
|
def socket(): WebSocket = WebSocket.accept[String, String] { request =>
|
||||||
val session = request.cookies.get("sessionId")
|
val session = request.cookies.get("accessToken")
|
||||||
if (session.isEmpty) throw new Exception("No session cookie found")
|
if (session.isEmpty) throw new Exception("No session cookie found")
|
||||||
val userOpt = sessionManger.getUserBySession(session.get.value)
|
val userOpt = sessionManger.getUserBySession(session.get.value)
|
||||||
if (userOpt.isEmpty) throw new Exception("Invalid session")
|
if (userOpt.isEmpty) throw new Exception("Invalid session")
|
||||||
|
|||||||
@@ -28,7 +28,7 @@ object GameInfoDTO {
|
|||||||
hand = selfPlayer.flatMap(_.currentHand()).map(HandDTO(_)),
|
hand = selfPlayer.flatMap(_.currentHand()).map(HandDTO(_)),
|
||||||
playerQueue = PlayerQueueDTO(lobby.logic),
|
playerQueue = PlayerQueueDTO(lobby.logic),
|
||||||
currentTrick = lobby.logic.getCurrentTrick.map(TrickDTO(_)),
|
currentTrick = lobby.logic.getCurrentTrick.map(TrickDTO(_)),
|
||||||
currentRound = lobby.logic.getCurrentRound.map(RoundDTO(_))
|
currentRound = lobby.logic.getCurrentRound.map(r => RoundDTO(r, lobby.logic.getCurrentMatch))
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -2,13 +2,13 @@ package dto.subDTO
|
|||||||
|
|
||||||
import de.knockoutwhist.cards.Hand
|
import de.knockoutwhist.cards.Hand
|
||||||
|
|
||||||
case class HandDTO(card: List[CardDTO])
|
case class HandDTO(cards: List[CardDTO])
|
||||||
|
|
||||||
object HandDTO {
|
object HandDTO {
|
||||||
|
|
||||||
def apply(hand: Hand): HandDTO = {
|
def apply(hand: Hand): HandDTO = {
|
||||||
HandDTO(
|
HandDTO(
|
||||||
card = hand.cards.zipWithIndex.map { case (card, idx) => CardDTO(card, idx) }
|
cards = hand.cards.zipWithIndex.map { case (card, idx) => CardDTO(card, idx) }
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -2,14 +2,16 @@ package dto.subDTO
|
|||||||
|
|
||||||
import de.knockoutwhist.cards.Card
|
import de.knockoutwhist.cards.Card
|
||||||
import de.knockoutwhist.cards.CardValue.Ace
|
import de.knockoutwhist.cards.CardValue.Ace
|
||||||
|
import de.knockoutwhist.rounds.{Match, Round}
|
||||||
|
|
||||||
case class RoundDTO(trumpSuit: CardDTO, firstRound: Boolean, trickList: List[TrickDTO])
|
case class RoundDTO(trumpSuit: CardDTO, playersIn: Seq[PlayerDTO], firstRound: Boolean, trickList: List[TrickDTO])
|
||||||
|
|
||||||
object RoundDTO {
|
object RoundDTO {
|
||||||
|
|
||||||
def apply(round: de.knockoutwhist.rounds.Round): RoundDTO = {
|
def apply(round: Round, matchImpl: Option[Match]): RoundDTO = {
|
||||||
RoundDTO(
|
RoundDTO(
|
||||||
trumpSuit = CardDTO(Card(Ace, round.trumpSuit)),
|
trumpSuit = CardDTO(Card(Ace, round.trumpSuit)),
|
||||||
|
playersIn = matchImpl.map(_.playersIn.map(PlayerDTO(_))).getOrElse(Seq.empty),
|
||||||
firstRound = round.firstRound,
|
firstRound = round.firstRound,
|
||||||
trickList = round.tricklist.map(trick => TrickDTO(trick))
|
trickList = round.tricklist.map(trick => TrickDTO(trick))
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ object TrickDTO {
|
|||||||
|
|
||||||
def apply(trick: Trick): TrickDTO = {
|
def apply(trick: Trick): TrickDTO = {
|
||||||
TrickDTO(
|
TrickDTO(
|
||||||
cards = trick.cards.map { case (card, player) => player.id.toString -> CardDTO(card) },
|
cards = trick.cards.map { case (card, player) => player.name -> CardDTO(card) },
|
||||||
firstCard = trick.firstCard.map(card => CardDTO(card)),
|
firstCard = trick.firstCard.map(card => CardDTO(card)),
|
||||||
winner = trick.winner.map(player => PlayerDTO(player))
|
winner = trick.winner.map(player => PlayerDTO(player))
|
||||||
)
|
)
|
||||||
|
|||||||
45
knockoutwhistweb/app/logic/Gateway.scala
Normal file
45
knockoutwhistweb/app/logic/Gateway.scala
Normal file
@@ -0,0 +1,45 @@
|
|||||||
|
package logic
|
||||||
|
|
||||||
|
import de.knockoutwhist.data.Pod
|
||||||
|
import de.knockoutwhist.data.redis.RedisManager
|
||||||
|
import org.apache.pekko.actor.ActorSystem
|
||||||
|
import org.redisson.config.Config
|
||||||
|
import play.api.inject.ApplicationLifecycle
|
||||||
|
|
||||||
|
import java.util.UUID
|
||||||
|
import javax.inject.*
|
||||||
|
import scala.concurrent.ExecutionContext
|
||||||
|
import scala.jdk.CollectionConverters.*
|
||||||
|
|
||||||
|
@Singleton
|
||||||
|
class Gateway @Inject()(
|
||||||
|
lifecycle: ApplicationLifecycle,
|
||||||
|
actorSystem: ActorSystem
|
||||||
|
)(implicit ec: ExecutionContext) {
|
||||||
|
|
||||||
|
val redis: RedisManager = {
|
||||||
|
val config: Config = Config()
|
||||||
|
config.useSingleServer.setAddress("valkey://" + sys.env.getOrElse("VALKEY_HOST", "localhost") + ":" + sys.env.getOrElse("VALKEY_PORT", "6379"))
|
||||||
|
RedisManager(config)
|
||||||
|
}
|
||||||
|
|
||||||
|
redis.continuousSyncPod(() => {
|
||||||
|
createPod()
|
||||||
|
})
|
||||||
|
|
||||||
|
def syncPod(): Unit = {
|
||||||
|
redis.syncPod(createPod())
|
||||||
|
}
|
||||||
|
|
||||||
|
private def createPod(): Pod = {
|
||||||
|
Pod(
|
||||||
|
UUID.randomUUID().toString,
|
||||||
|
PodManager.podName,
|
||||||
|
PodManager.podIp,
|
||||||
|
9000,
|
||||||
|
PodManager.getAllGameIds().asJava,
|
||||||
|
PodManager.allBoundUsers().asJava
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@@ -21,6 +21,8 @@ object PodManager {
|
|||||||
private val userSession: mutable.Map[User, String] = mutable.Map()
|
private val userSession: mutable.Map[User, String] = mutable.Map()
|
||||||
private val injector: Injector = Guice.createInjector(KnockOutWebConfigurationModule())
|
private val injector: Injector = Guice.createInjector(KnockOutWebConfigurationModule())
|
||||||
|
|
||||||
|
private[logic] var redis: Option[Gateway] = None
|
||||||
|
|
||||||
def createGame(
|
def createGame(
|
||||||
host: User,
|
host: User,
|
||||||
name: String,
|
name: String,
|
||||||
@@ -35,7 +37,8 @@ object PodManager {
|
|||||||
host = host
|
host = host
|
||||||
)
|
)
|
||||||
sessions += (gameLobby.id -> gameLobby)
|
sessions += (gameLobby.id -> gameLobby)
|
||||||
userSession += (host -> gameLobby.id)
|
registerUserToGame(host, gameLobby.id)
|
||||||
|
redis.foreach(gateway => gateway.syncPod())
|
||||||
gameLobby
|
gameLobby
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -46,6 +49,7 @@ object PodManager {
|
|||||||
def registerUserToGame(user: User, gameId: String): Boolean = {
|
def registerUserToGame(user: User, gameId: String): Boolean = {
|
||||||
if (sessions.contains(gameId)) {
|
if (sessions.contains(gameId)) {
|
||||||
userSession += (user -> gameId)
|
userSession += (user -> gameId)
|
||||||
|
redis.foreach(gateway => gateway.syncPod())
|
||||||
true
|
true
|
||||||
} else {
|
} else {
|
||||||
false
|
false
|
||||||
@@ -54,6 +58,7 @@ object PodManager {
|
|||||||
|
|
||||||
def unregisterUserFromGame(user: User): Unit = {
|
def unregisterUserFromGame(user: User): Unit = {
|
||||||
userSession.remove(user)
|
userSession.remove(user)
|
||||||
|
redis.foreach(gateway => gateway.redis.invalidateUser(user.id.toString))
|
||||||
}
|
}
|
||||||
|
|
||||||
def identifyGameOfUser(user: User): Option[GameLobby] = {
|
def identifyGameOfUser(user: User): Option[GameLobby] = {
|
||||||
@@ -65,9 +70,12 @@ object PodManager {
|
|||||||
|
|
||||||
private[logic] def removeGame(gameId: String): Unit = {
|
private[logic] def removeGame(gameId: String): Unit = {
|
||||||
sessions.remove(gameId)
|
sessions.remove(gameId)
|
||||||
|
redis.foreach(gateway => gateway.redis.invalidateGame(gameId))
|
||||||
// Also remove all user sessions associated with this game
|
// Also remove all user sessions associated with this game
|
||||||
userSession.filterInPlace((_, v) => v != gameId)
|
userSession.filterInPlace((_, v) => v != gameId)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private[logic] def getAllGameIds(): List[String] = sessions.keys.toList
|
||||||
|
private[logic] def allBoundUsers(): List[String] = userSession.keys.map(_.id.toString).toList
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -106,6 +106,9 @@ class GameLobby private(
|
|||||||
}
|
}
|
||||||
if (sessionOpt.get.host) {
|
if (sessionOpt.get.host) {
|
||||||
logic.invoke(SessionClosed())
|
logic.invoke(SessionClosed())
|
||||||
|
for (session <- users.values) {
|
||||||
|
PodManager.unregisterUserFromGame(session.user)
|
||||||
|
}
|
||||||
users.clear()
|
users.clear()
|
||||||
PodManager.removeGame(id)
|
PodManager.removeGame(id)
|
||||||
return
|
return
|
||||||
|
|||||||
@@ -9,6 +9,7 @@ trait SessionManager {
|
|||||||
|
|
||||||
def createSession(user: User): String
|
def createSession(user: User): String
|
||||||
|
|
||||||
|
|
||||||
def getUserBySession(sessionId: String): Option[User]
|
def getUserBySession(sessionId: String): Option[User]
|
||||||
|
|
||||||
def invalidateSession(sessionId: String): Unit
|
def invalidateSession(sessionId: String): Unit
|
||||||
|
|||||||
@@ -46,13 +46,13 @@ class UserSession(val user: User, val host: Boolean, val gameLobby: GameLobby) e
|
|||||||
case "StartGame" =>
|
case "StartGame" =>
|
||||||
gameLobby.startGame(user)
|
gameLobby.startGame(user)
|
||||||
case "PlayCard" =>
|
case "PlayCard" =>
|
||||||
val maybeCardIndex: Option[String] = (data \ "cardindex").asOpt[String]
|
val maybeCardIndex: Option[Int] = (data \ "cardindex").asOpt[Int]
|
||||||
maybeCardIndex match {
|
maybeCardIndex match {
|
||||||
case Some(index) =>
|
case Some(index) =>
|
||||||
val session = gameLobby.getUserSession(user.id)
|
val session = gameLobby.getUserSession(user.id)
|
||||||
gameLobby.playCard(session, index.toInt)
|
gameLobby.playCard(session, index)
|
||||||
case None =>
|
case None =>
|
||||||
println("Card Index not found or is not a number.")
|
println("Card Index not found or is not a number." + data)
|
||||||
}
|
}
|
||||||
case "PickTrumpsuit" =>
|
case "PickTrumpsuit" =>
|
||||||
val maybeSuitIndex: Option[Int] = (data \ "suitIndex").asOpt[Int]
|
val maybeSuitIndex: Option[Int] = (data \ "suitIndex").asOpt[Int]
|
||||||
@@ -74,6 +74,10 @@ class UserSession(val user: User, val host: Boolean, val gameLobby: GameLobby) e
|
|||||||
}
|
}
|
||||||
case "ReturnToLobby" =>
|
case "ReturnToLobby" =>
|
||||||
gameLobby.returnToLobby(this)
|
gameLobby.returnToLobby(this)
|
||||||
|
case "LeaveGame" =>
|
||||||
|
gameLobby.leaveGame(user.id, false)
|
||||||
|
case _ =>
|
||||||
|
println("Unknown event type: " + eventType + " with data: " + data)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
9
knockoutwhistweb/app/modules/GatewayModule.scala
Normal file
9
knockoutwhistweb/app/modules/GatewayModule.scala
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
package modules
|
||||||
|
|
||||||
|
import com.google.inject.AbstractModule
|
||||||
|
|
||||||
|
class GatewayModule extends AbstractModule {
|
||||||
|
override def configure(): Unit = {
|
||||||
|
bind(classOf[GatewayModule]).asEagerSingleton()
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -57,12 +57,13 @@ object WebsocketEventMapper {
|
|||||||
Json.obj(
|
Json.obj(
|
||||||
"id" -> ("request-" + java.util.UUID.randomUUID().toString),
|
"id" -> ("request-" + java.util.UUID.randomUUID().toString),
|
||||||
"event" -> obj.id,
|
"event" -> obj.id,
|
||||||
"state" -> toJson(session),
|
"state" -> session.gameLobby.getLogic.getCurrentState.toString,
|
||||||
|
"stateData" -> stateToJson(session),
|
||||||
"data" -> data
|
"data" -> data
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
def toJson(session: UserSession): JsValue = {
|
def stateToJson(session: UserSession): JsValue = {
|
||||||
session.gameLobby.getLogic.getCurrentState match {
|
session.gameLobby.getLogic.getCurrentState match {
|
||||||
case Lobby => Json.toJson(LobbyInfoDTO(session.gameLobby, session.user))
|
case Lobby => Json.toJson(LobbyInfoDTO(session.gameLobby, session.user))
|
||||||
case InGame => Json.toJson(GameInfoDTO(session.gameLobby, session.user))
|
case InGame => Json.toJson(GameInfoDTO(session.gameLobby, session.user))
|
||||||
|
|||||||
@@ -45,15 +45,9 @@
|
|||||||
<li><a class="dropdown-item disabled" href="#" tabindex="-1" aria-disabled="true">
|
<li><a class="dropdown-item disabled" href="#" tabindex="-1" aria-disabled="true">
|
||||||
Settings</a></li>
|
Settings</a></li>
|
||||||
<li><hr class="dropdown-divider"></li>
|
<li><hr class="dropdown-divider"></li>
|
||||||
<li><a class="dropdown-item" href="@routes.UserController.logout()">Logout</a></li>
|
|
||||||
</ul>
|
</ul>
|
||||||
</li>
|
</li>
|
||||||
</ul>
|
</ul>
|
||||||
} else {
|
|
||||||
<div class="d-flex ms-auto">
|
|
||||||
<a class="btn btn-outline-primary me-2" href="@routes.UserController.login()">Login</a>
|
|
||||||
<a class="btn btn-primary" href="@routes.UserController.login()">Sign Up</a>
|
|
||||||
</div>
|
|
||||||
}
|
}
|
||||||
|
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -13,3 +13,12 @@ auth {
|
|||||||
publicKeyFile = ${?PUBLIC_KEY_FILE}
|
publicKeyFile = ${?PUBLIC_KEY_FILE}
|
||||||
publicKeyPem = ${?PUBLIC_KEY_PEM}
|
publicKeyPem = ${?PUBLIC_KEY_PEM}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
play.filters.enabled += "play.filters.cors.CORSFilter"
|
||||||
|
|
||||||
|
play.filters.cors {
|
||||||
|
allowedOrigins = ["http://localhost:5173"]
|
||||||
|
allowedCredentials = true
|
||||||
|
allowedHttpMethods = ["GET", "POST", "PUT", "DELETE", "OPTIONS"]
|
||||||
|
allowedHttpHeaders = ["Accept", "Content-Type", "Origin", "X-Requested-With"]
|
||||||
|
}
|
||||||
|
|||||||
14
knockoutwhistweb/conf/prod.conf
Normal file
14
knockoutwhistweb/conf/prod.conf
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
include "application.conf"
|
||||||
|
|
||||||
|
play.http.secret.key="zg8^v0R*:7-m.>^8T2B1q)sE3MV_9=M{K9zx8,<3}"
|
||||||
|
|
||||||
|
play.http.context="/api"
|
||||||
|
|
||||||
|
play.modules.enabled += "modules.GatewayModule"
|
||||||
|
|
||||||
|
play.filters.cors {
|
||||||
|
allowedOrigins = ["https://knockout.janis-eccarius.de"]
|
||||||
|
allowedCredentials = true
|
||||||
|
allowedHttpMethods = ["GET", "POST", "PUT", "DELETE", "OPTIONS"]
|
||||||
|
allowedHttpHeaders = ["Accept", "Content-Type", "Origin", "X-Requested-With"]
|
||||||
|
}
|
||||||
@@ -18,13 +18,16 @@ POST /createGame controllers.MainMenuController.createGame()
|
|||||||
POST /joinGame controllers.MainMenuController.joinGame()
|
POST /joinGame controllers.MainMenuController.joinGame()
|
||||||
|
|
||||||
# User authentication routes
|
# User authentication routes
|
||||||
GET /login controllers.UserController.login()
|
|
||||||
POST /login controllers.UserController.login_Post()
|
POST /login controllers.UserController.login_Post()
|
||||||
|
POST /logout controllers.UserController.logoutPost()
|
||||||
GET /logout controllers.UserController.logout()
|
GET /userInfo controllers.UserController.getUserInfo()
|
||||||
|
|
||||||
# In-game routes
|
# In-game routes
|
||||||
GET /game/:id controllers.IngameController.game(id: String)
|
GET /game/:id controllers.IngameController.game(id: String)
|
||||||
|
|
||||||
# Websocket
|
# Websocket
|
||||||
GET /websocket controllers.WebsocketController.socket()
|
GET /websocket controllers.WebsocketController.socket()
|
||||||
|
|
||||||
|
# Status
|
||||||
|
GET /status controllers.StatusController.requestStatus()
|
||||||
|
GET /status/:gameId controllers.StatusController.game(gameId: String)
|
||||||
@@ -1,11 +1,9 @@
|
|||||||
// javascript
|
let ws = null;
|
||||||
let ws = null; // will be created by connectWebSocket()
|
const pending = new Map();
|
||||||
const pending = new Map(); // id -> { resolve, reject, timer }
|
const handlers = new Map();
|
||||||
const handlers = new Map(); // eventType -> handler(data) -> (value|Promise)
|
|
||||||
|
|
||||||
let timer = null;
|
let timer = null;
|
||||||
|
|
||||||
// helper to attach message/error/close handlers to a socket
|
|
||||||
function setupSocketHandlers(socket) {
|
function setupSocketHandlers(socket) {
|
||||||
socket.onmessage = (event) => {
|
socket.onmessage = (event) => {
|
||||||
console.debug("SERVER MESSAGE:", event.data);
|
console.debug("SERVER MESSAGE:", event.data);
|
||||||
@@ -48,7 +46,6 @@ function setupSocketHandlers(socket) {
|
|||||||
};
|
};
|
||||||
|
|
||||||
if (!handler) {
|
if (!handler) {
|
||||||
// no handler: respond with an error object in data so server can fail it
|
|
||||||
console.warn("No handler for event:", eventType);
|
console.warn("No handler for event:", eventType);
|
||||||
sendResponse({error: "No handler for event: " + eventType});
|
sendResponse({error: "No handler for event: " + eventType});
|
||||||
return;
|
return;
|
||||||
@@ -91,7 +88,6 @@ function setupSocketHandlers(socket) {
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
// connect/disconnect helpers
|
|
||||||
function connectWebSocket(url = null) {
|
function connectWebSocket(url = null) {
|
||||||
if (!url) {
|
if (!url) {
|
||||||
const loc = window.location;
|
const loc = window.location;
|
||||||
@@ -100,7 +96,6 @@ function connectWebSocket(url = null) {
|
|||||||
}
|
}
|
||||||
if (ws && ws.readyState === WebSocket.OPEN) return Promise.resolve();
|
if (ws && ws.readyState === WebSocket.OPEN) return Promise.resolve();
|
||||||
if (ws && ws.readyState === WebSocket.CONNECTING) {
|
if (ws && ws.readyState === WebSocket.CONNECTING) {
|
||||||
// already connecting - return a promise that resolves on open
|
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const prevOnOpen = ws.onopen;
|
const prevOnOpen = ws.onopen;
|
||||||
const prevOnError = ws.onerror;
|
const prevOnError = ws.onerror;
|
||||||
@@ -121,7 +116,6 @@ function connectWebSocket(url = null) {
|
|||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
ws.onopen = () => {
|
ws.onopen = () => {
|
||||||
console.log("WebSocket connection established!");
|
console.log("WebSocket connection established!");
|
||||||
// start heartbeat
|
|
||||||
timer = setInterval(() => {
|
timer = setInterval(() => {
|
||||||
if (ws && ws.readyState === WebSocket.OPEN) {
|
if (ws && ws.readyState === WebSocket.OPEN) {
|
||||||
sendEventAndWait("ping", {}).then(
|
sendEventAndWait("ping", {}).then(
|
||||||
|
|||||||
@@ -1,3 +1,3 @@
|
|||||||
MAJOR=4
|
MAJOR=4
|
||||||
MINOR=9
|
MINOR=19
|
||||||
PATCH=1
|
PATCH=0
|
||||||
|
|||||||
Reference in New Issue
Block a user