refactoring: Masive refactor to build the V2

2026-07-28 23:46:52 +02:00 · 2026-07-26 17:51:58 +02:00
63 changed files with 871 additions and 1886 deletions
@@ -1,26 +0,0 @@
-# Version control
-.git
-.github
-
-# Gradle build outputs / caches (must always be rebuilt fresh inside the image)
-.gradle
-build/
-.kotlin
-!gradle/wrapper/gradle-wrapper.jar
-
-# IDE
-.idea
-.vscode
-.run
-*.iml
-*.iws
-*.ipr
-
-# Docker-only local files (secrets/env must never be baked into the image)
-docker/.env
-docker/*.env.docker
-docker/*.secret
-
-# Misc
-*.hprof
-.gradle-docker-cache/
@@ -1,7 +0,0 @@
-* text=auto
-* eol=lf
-*.sh text eol=lf
-*.png binary
-*.jar binary
-gradlew.bat eol=crlf
-gradlew text eol=lf
@@ -18,10 +18,10 @@ jobs:

    steps:
      - name: Checkout code
-        uses: actions/checkout@v6
+        uses: actions/checkout@v4

      - name: Set up JDK 21
-        uses: actions/setup-java@v5
+        uses: actions/setup-java@v4
        with:
          distribution: 'temurin'
          java-version: '21'
@@ -31,7 +31,7 @@ jobs:
        run: echo "key=gradle-${{ runner.os }}-${{ hashFiles('**/*.gradle*', '**/gradle-wrapper.properties') }}" >> $GITHUB_OUTPUT

      - name: Cache Gradle dependencies
-        uses: actions/cache@v6
+        uses: actions/cache@v3
        with:
          path: |
            ~/.gradle/caches
@@ -48,16 +48,16 @@ jobs:
    runs-on: ubuntu-latest
    steps:
      - name: Checkout code
-        uses: actions/checkout@v6
+        uses: actions/checkout@v4

      - name: Set up JDK 21
-        uses: actions/setup-java@v5
+        uses: actions/setup-java@v4
        with:
          distribution: 'temurin'
          java-version: '21'

      - name: Restore Gradle cache
-        uses: actions/cache@v6
+        uses: actions/cache@v3
        with:
          path: |
            ~/.gradle/caches
@@ -73,65 +73,53 @@ jobs:
        run: ./gradlew ktlintCheck

      - name: Publish ktlint report
-        uses: yutailang0119/action-ktlint@v5
+        uses: yutailang0119/action-ktlint@v4
        if: always()
        with:
          report-path: build/reports/ktlint/**/*.xml
        continue-on-error: false

  test:
+    needs: build
    runs-on: ubuntu-latest
-    env:
-      GRADLE_CACHE_DIR: ${{ github.workspace }}/.gradle-docker-cache
    steps:
      - name: Checkout code
-        uses: actions/checkout@v6
+        uses: actions/checkout@v4

-      - name: Install a pinned Docker Compose version
-        run: |
-          mkdir -p ~/.docker/cli-plugins
-          curl -fSL https://github.com/docker/compose/releases/download/v5.1.4/docker-compose-linux-x86_64 \
-            -o ~/.docker/cli-plugins/docker-compose
-          chmod +x ~/.docker/cli-plugins/docker-compose
-          docker compose version
-
-      - name: Prepare docker secrets
-        run: |
-          [ -f docker/postgresql.secret ] || echo -n "changeit" > docker/postgresql.secret
-
-      - name: Generate cache key
-        id: cache-key-generator
-        run: echo "key=gradle-docker-${{ runner.os }}-${{ hashFiles('**/*.gradle*', '**/gradle-wrapper.properties') }}" >> $GITHUB_OUTPUT
-
-      - name: Restore Gradle cache (Docker)
-        uses: actions/cache@v6
+      - name: Set up JDK 21
+        uses: actions/setup-java@v4
        with:
-          path: ${{ env.GRADLE_CACHE_DIR }}
-          key: ${{ steps.cache-key-generator.outputs.key }}
+          distribution: 'temurin'
+          java-version: '21'
+
+      - name: Restore Gradle cache
+        uses: actions/cache@v3
+        with:
+          path: |
+            ~/.gradle/caches
+            ~/.gradle/wrapper
+          key: ${{ needs.build.outputs.cache-key }}
          restore-keys: |
-            gradle-docker-${{ runner.os }}-
+            gradle-${{ runner.os }}-

-      - name: Prepare cache directory permissions
-        run: |
-          mkdir -p "$GRADLE_CACHE_DIR"
-          chmod -R 777 "$GRADLE_CACHE_DIR"
+      - name: Grant execute permission to Gradle wrapper
+        run: chmod +x gradlew

-      - name: Run tests in Docker
-        run: docker compose -f docker/docker-compose-test.yaml run tests
+      - name: Start CI Docker Compose services
+        run: ./gradlew composeUp -Pci

-      - name: Shut down Docker services
-        if: always()
-        run: docker compose -f docker/docker-compose-test.yaml down -v
+      - name: Run tests
+        run: ./gradlew test -x composeUp --no-daemon

      - name: Upload test reports
        if: always()
-        uses: actions/upload-artifact@v7
+        uses: actions/upload-artifact@v4
        with:
          name: test-results
          path: build/reports/tests/test

      - name: Publish Test Report
-        uses: dorny/test-reporter@v3
+        uses: dorny/test-reporter@v1
        if: always()
        with:
          name: JUnit Tests
@@ -37,4 +37,3 @@ out/
 /docker/.env
 /docker/*.secret
 *.hprof
-/.gradle-docker-cache/
@@ -1,27 +0,0 @@
-<component name="ProjectRunConfigurationManager">
-  <configuration default="false" name="docker composeUp" type="GradleRunConfiguration" factoryName="Gradle">
-    <ExternalSystemSettings>
-      <option name="executionName" />
-      <option name="externalProjectPath" value="$PROJECT_DIR$" />
-      <option name="externalSystemIdString" value="GRADLE" />
-      <option name="scriptParameters" value="" />
-      <option name="taskDescriptions">
-        <list />
-      </option>
-      <option name="taskNames">
-        <list>
-          <option value="composeUp" />
-        </list>
-      </option>
-      <option name="vmOptions" />
-    </ExternalSystemSettings>
-    <ExternalSystemDebugServerProcess>true</ExternalSystemDebugServerProcess>
-    <ExternalSystemReattachDebugProcess>true</ExternalSystemReattachDebugProcess>
-    <ExternalSystemDebugDisabled>false</ExternalSystemDebugDisabled>
-    <DebugAllEnabled>false</DebugAllEnabled>
-    <RunAsTest>false</RunAsTest>
-    <GradleProfilingDisabled>false</GradleProfilingDisabled>
-    <GradleCoverageDisabled>false</GradleCoverageDisabled>
-    <method v="2" />
-  </configuration>
-</component>
@@ -1,133 +0,0 @@
-# CLAUDE.md — event-demo
-
-Ce fichier donne le contexte du projet pour toute session Claude Code future sur ce dépôt.
-
-## Vue d'ensemble
-
-`event-demo` est un projet démo personnel (Fabrice Lecomte) qui illustre plusieurs patterns
-d'architecture backend :
-
- Event Sourcing
- Event-Driven (bus d'événements asynchrone)
- CQRS (séparation commandes / projections en lecture)
- Architecture Hexagonale (ports & adapters), un dossier par *bounded context*
-
-Le cas d'usage servant de support est un jeu de cartes façon UNO (créer une partie, rejoindre,
-jouer une carte, piocher, etc.), avec authentification des joueurs.
-
-Dépôts distants configurés : `gitea` (auto-hébergé, git.gogn.synology.me — remote historique)
-et `github` (`flecomte/event-demo`, miroir). Vérifier vers lequel pousser selon le contexte.
-
-## Stack technique
-
- **Langage** : Kotlin 2.1.21, JDK 21 (toolchain Gradle)
- **Framework serveur** : Ktor 3.5.1 (Netty), DI via Koin 4.2.1
- **Sérialisation** : kotlinx.serialization (JSON)
- **Persistance** :
-  - PostgreSQL (event store, via HikariCP) + migrations Flyway (`migrations/events/`)
-  - RabbitMQ (bus d'événements / bus de commandes, via amqp-client)
- **Auth** : JWT (ktor-server-auth-jwt), hash de mot de passe via password4j
- **Infra dev/prod** : Docker Compose (fichiers `docker/docker-compose-{dev,test,prod}.yaml`
-  incluant des « parts » réutilisables dans `docker/parts/`), reverse proxy Træfik
- **Tests** : Kotest (runner JUnit5), MockK, kotest-extensions-koin, ArchUnit (test d'architecture)
- **Qualité** : ktlint (`ktlint_official`, standard + experimental activés), reporting checkstyle
- **CI** : GitHub Actions (`.github/workflows/tests.yml`) — build/cache Gradle, `ktlintCheck`,
-  puis tests exécutés **dans Docker** (`docker compose -f docker/docker-compose-test.yaml run tests`)
- **API** : documentée en OpenAPI (`resources/openapi/documentation.yaml`)
-
-## Architecture
-
-Un dossier par *bounded context* sous `src/main/kotlin/eventDemo/contexts/<context>/`, chacun
-strictement découpé en 3 couches :
-
- `domain/` — aucune dépendance vers les autres couches
- `application/` — ne dépend que de `domain`
- `infrastructure/` — dépend de `domain` et `application`
-
-Contexts actuels :
-
- **`auth`** : `User`, création de compte, login JWT, event store dédié (Postgresql),
-  projection utilisateur.
- **`game`** : cœur du jeu — `Card`, `DrawPile`/`DiscardPile`, `Player`, `GameId`, commandes
-  (`JoinTheGameCommand`, `PlayCardCommand`, `ReadyToPlayCommand`, `TakeCartFromDrawPileCommand`),
-  state machine du jeu via `sealed interface Game` (`GameInit` → `GameCreated` → `GameStarted` →
-  `GameEnded`), notifications, projections (liste de parties), listeners/réactions.
-
-Libs transverses dans `libs/` (indépendantes de tout contexte) :
-
- `bus/` — abstraction `Bus<E>` avec implémentations in-memory et RabbitMQ (fanout exchange)
- `command/` — `Command`, `CommandUnicityChecker` (empêche la double exécution d'une commande,
-  cache glissant de 10 min par défaut)
- `eventSource/` — `Event`, `EventStream` (append/lecture par version, gestion de
-  `VersionConflictException`), `EventStore` in-memory / Postgresql
- `helpers/`, `serializer/` — utilitaires (conversion de frames WebSocket, sérialiseurs UUID, etc.)
-
-## Patterns notables dans le code
-
- **Event sourcing** : `Game.loadFromHistory(events)` reconstruit l'état en repliant
-  (`fold`) les événements sur une state machine scellée, en utilisant la syntaxe Kotlin 2.1
-  `when` avec garde `if` (ex. `is GameCreatedEvent if this is GameInit -> applyEvent(event)`).
- **CQRS** : écriture via les command handlers (`application/command/handlers`), lecture via des
-  projections dédiées (`application/projections`), propagées via le bus RabbitMQ, pas de couplage
-  direct avec l'écriture.
- **Event-driven** : réactions asynchrones (`ReactionListener`, `EventToNotificationSubscriber`)
-  déclenchées par le bus RabbitMQ (exchange fanout, une queue par abonné).
- **Exceptions métier** : hiérarchie `GameException` / `IllegalActionException` dans
-  `domain/game/errors`, une exception par règle métier violée (ex.
-  `NeedMorePlayersToStartGameException`, `ItsNotTheTurnException`).
-
-## Commandes utiles
-
-```shell
-./gradlew build            # build complet
-./gradlew test             # tests (JUnit5 via Kotest)
-./gradlew ktlintCheck      # lint
-./gradlew ktlintFormat     # auto-format
-./gradlew buildFatJar      # jar exécutable "all-in-one" (utilisé par le Dockerfile prod)
-
-# Dépendances seules (Postgres, RabbitMQ, Træfik, pgAdmin...) pour lancer l'app en local hors docker
-docker compose -f docker/docker-compose-dev.yaml up -d
-
-# Stack de test façon CI
-docker compose -f docker/docker-compose-test.yaml up -d
-# ou directement (comme en CI) :
-docker compose -f docker/docker-compose-test.yaml run tests
-
-# Stack complète en prod
-docker compose -f docker/docker-compose-prod.yaml -p event-demo up -d
-```
-
-URLs en dev (voir `doc/installation.md`, nécessite Træfik + résolution des `*.traefik.me`) :
-API sur `http://api.traefik.me/`, dashboard
-Træfik, pgAdmin et RabbitMQ management exposés via des sous-domaines `traefik.me`.
-
-## Conventions de code
-
- ktlint en mode `ktlint_official` + règles `standard` et `experimental` activées
-  (voir `.editorconfig`), indentation **2 espaces**, virgules finales (*trailing commas*)
-  systématiques, wrapping forcé des expressions/signatures multi-lignes.
- Fins de ligne forcées en **LF** (`.gitattributes`), sauf `gradlew.bat` en CRLF.
- Code et identifiants en anglais.
- Style Kotlin idiomatique/fonctionnel : `fold`, `let`, `apply`, `when` exhaustifs, classes/interfaces
-  scellées (`sealed class`/`sealed interface`) pour modéliser états et événements plutôt que des enums
-  avec des champs optionnels.
-
-## Pièges connus / choses à savoir avant de toucher au build ou à la CI
-
- **MockK/ByteBuddy en Docker** : l'auto-attach dynamique de MockK échoue dans les conteneurs
-  (le handshake SIGQUIT de l'AttachListener JVM time-out). Le `build.gradle.kts` charge donc
-  l'agent `byte-buddy-agent` de façon statique via `-javaagent` pour les tâches `Test`, afin
-  que MockK détecte l'instrumentation déjà présente et saute l'attach dynamique. Ne pas retirer
-  ce bloc sans repenser l'exécution des tests en Docker.
- **Secret Postgres en CI** : `docker/postgresql.secret` est généré à la volée par le workflow
-  GitHub Actions s'il n'existe pas (`echo -n "changeit" > docker/postgresql.secret`) — normal,
-  pas un fichier à committer.
- Les tests « officiels » de la CI tournent **dans Docker**, pas directement via `./gradlew test`
-  sur l'hôte — en cas de comportement différent entre local et CI, vérifier d'abord les
-  variables d'environnement/versions du `docker-compose-test.yaml`.
-
-## Historique récent (pour contexte)
-
-Le projet a connu un « Massive refactor to build the V2 » (commit `e2d7942`) : passage d'une
-architecture par couches techniques plates (`adapter/presenter/domain`) à l'organisation actuelle
-par bounded context (`auth`/`game`) avec 3 couches hexagonales chacune.
@@ -2,6 +2,7 @@ Event Demo
 ==========
 - [Installation](./doc/installation.md)
 - [What's the demo for ?](#whats-the-demo-for-)
+- [What's in this demo](#whats-in-this-demo)
 - [The stack](#the-stack)
 - [Architecture](./doc/architecture.md)

@@ -17,6 +18,31 @@ of different patterns and architectures.
 - The CQRS pattern.
 - With the Hexagonal architecture.

+
+What's in this demo
+-------------------
+
+- The **event sourcing** pattern.
+- The **event driven** pattern.
+- The **CQRS** pattern with **command** and **query**.
+- A fully **asynchronous** architecture.Concurently process.
+- A **pure Kotlin** implementation of **readmodel**/**projection**.
+- A **Redis** implementation of **readmodel**/**projection**.
+- A **pure Kotlin** implementation of **Event Store**.
+- A **Postgresql** implementation of **Event Store**.
+- A **pure Kotlin** implementation of **Event Bus**.
+- A **RabbitMQ** implementation of **Event Bus**.
+- A **Hexagonal** architecture.
+- Use of **Web Sockets**.
+- Use of the classic **Rest** route.
+- Simple usage of the **JWT**.
+- The **Ktor** framework.
+- The **Koin** Dependency Injection framework
+- Concurrently process.
+- Use of coroutines.
+- Using **docker compose** for the stack with **traefik**.
+- Use of **flyway** to migrate the postgresql schema.
+
 The stack
 ---------

@@ -25,11 +51,11 @@ Language

 Framework
 - Ktor
-  - with Koin for Dependency Injection

 Database
 - Postgresql
  - with Flyway
+- Redis
 - RabbitMQ

 Infra
@@ -14,6 +14,7 @@ plugins {
  id("io.ktor.plugin") version "3.5.1"
  id("org.jetbrains.kotlin.plugin.serialization") version "2.4.10"
  id("org.jlleitschuh.gradle.ktlint") version "14.2.0"
+  id("com.avast.gradle.docker-compose") version "0.17.12"
 }

 group = "io.github.flecomte"
@@ -46,17 +47,63 @@ java {

 tasks.withType<Test>().configureEach {
  useJUnitPlatform()
-  jvmArgs("-Djdk.attach.allowAttachSelf=true", "-XX:+EnableDynamicAgentLoading")
-  // Dynamic self-attach (used by MockK/ByteBuddy) times out in Docker containers because the
-  // SIGQUIT-triggered AttachListener handshake never completes there. Loading the byte-buddy
-  // agent jar statically via -javaagent avoids the attach handshake entirely: MockK detects the
-  // pre-installed Instrumentation instance and skips dynamic attach.
-  doFirst {
-    val agentJar =
-      classpath.files.firstOrNull { it.name.startsWith("byte-buddy-agent") }
-        ?: error("byte-buddy-agent jar not found on test classpath")
-    jvmArgs("-javaagent:$agentJar")
+}
+
+dockerCompose {
+  val composeFile =
+    if (project.hasProperty("ci")) {
+      // Use docker-compose-ci.yaml for the CI
+      "docker/docker-compose-ci.yaml"
+    } else {
+      // Use docker-compose-test.yaml for local tests
+      "docker/docker-compose-test.yaml"
+    }
+  useComposeFiles.set(listOf(composeFile))
+  setProjectName("event-demo-test")
+}
+
+tasks.test {
+  dependsOn("composeUp")
+  dockerCompose.useComposeFiles.set(listOf("docker/docker-compose-test.yaml"))
+  dockerCompose.setProjectName("event-demo-test")
+}
+
+tasks.named("run") {
+  dependsOn("composeUp")
+  dockerCompose.useComposeFiles.set(listOf("docker/docker-compose-test.yaml"))
+  dockerCompose.setProjectName("event-demo-dev")
+}
+
+tasks.register<Copy>("copyEnv") {
+  group = "docker"
+  description = "copy the default dotenv file"
+  from("docker")
+  into("docker")
+  rename {
+    it.removeSuffix(".template")
  }
+  include(".env.template")
+  eachFile {
+    if (File("docker/$name").exists()) {
+      exclude()
+    }
+  }
+  doLast {
+    val files =
+      listOf(
+        File("docker/pgadmin.secret"),
+        File("docker/postgresql.secret"),
+      )
+
+    files.forEach {
+      if (!it.exists()) {
+        it.writeText("changeit")
+      }
+    }
+  }
+}
+tasks.composeUp {
+  dependsOn("copyEnv")
 }

 dependencies {
@@ -81,6 +128,7 @@ dependencies {
  implementation("io.github.oshai:kotlin-logging-jvm:${kotlinLoggingVersion.get()}")
  implementation("org.jetbrains.kotlinx:kotlinx-serialization-json-jvm:${kotlinSerializationVersion.get()}")
  implementation("org.jetbrains.kotlinx:kotlinx-datetime:0.6.2")
+  implementation("redis.clients:jedis:5.2.0")
  implementation("org.postgresql:postgresql:42.7.13")
  implementation("com.zaxxer:HikariCP:6.3.0")
  implementation("com.rabbitmq:amqp-client:5.25.0")
@@ -93,6 +141,6 @@ dependencies {
  testImplementation("org.jetbrains.kotlin:kotlin-test-junit:${kotlinVersion.get()}")
  testImplementation("io.ktor:ktor-server-test-host-jvm:${ktorVersion.get()}")
  testImplementation("io.kotest:kotest-runner-junit5:${kotestVersion.get()}")
-  testImplementation("io.mockk:mockk:1.14.11")
+  testImplementation("io.mockk:mockk:1.13.17")
  testImplementation("com.tngtech.archunit:archunit-junit5:1.3.0")
 }
@@ -0,0 +1,11 @@
+Architecture
+============
+
+The Workflow
+------------
+![Workflow Diagram](./schemas/Workflow.svg)
+
+The business Entities
+---------------------
+
+![Entities and Projections Diagram](./schemas/Entities.svg)
@@ -0,0 +1,67 @@
+# Exemple de structure 
+
+Les couches, du plus interne au plus externe
+```
+Domain (le cœur, ne dépend de RIEN d'externe)
+↑
+Application (orchestre le Domain, ne connaît pas l'infra concrète)
+↑
+Infrastructure (WebSocket, DB, event store — dépend de tout le reste)
+```
+
+```
+src/
+└── contexts/
+    ├── auth/
+        └── ... 
+    └── game/
+        ├── domain/                              ← Le cœur métier, zéro dépendance externe
+        │   ├── game/
+        │   │   ├── Game.ts                      ← Aggregate Root
+        │   │   ├── Player.ts                    ← Entity interne
+        │   │   ├── Card.ts                      ← Entity
+        │   │   ├── Color.ts                     ← Value Object
+        │   │   ├── Deck.ts                      ← VO ou petite structure
+        │   │   └── errors/
+        │   │       ├── InvalidMoveError.ts
+        │   │       └── ColorChoiceRequiredError.ts
+        │   └── events/                          ← Events de DOMAINE (internes)
+        │       ├── CardPlayed.ts
+        │       ├── CardDrawn.ts
+        │       ├── TurnPassed.ts
+        │       └── DomainEvent.ts               ← interface/type de base
+        ├── application/                         ← Orchestration, cas d'usage
+        │   ├── commands/                        ← Les Commandes (intentions)
+        │   │   ├── PlayCardCommand.ts
+        │   │   └── DrawCardCommand.ts
+        │   ├── handlers/                        ← Un handler par commande
+        │   │   ├── PlayCardHandler.ts           ← charge l'aggregate, appelle game.playCard(), save
+        │   │   └── DrawCardHandler.ts
+        │   ├── projections/                     ← LA LOGIQUE de construction des projections
+        │   │   ├── GameSummaryProjector.kt      ← écoute les events, met à jour la vue
+        │   │   └── PlayerStatsProjector.kt
+        │   └── ports/                           ← INTERFACES seulement (le "hexagone")
+        │       ├── GameRepository.ts            ← interface, pas d'implémentation
+        │       ├── EventPublisher.ts            ← interface, pas d'implémentation
+        │       └── ProjectionStore.kt           ← interface, où lire/écrire la projection
+        ├── infrastructure/                      ← Tout ce qui est technique/externe
+        │   ├── persistence/
+        │   │   ├── EventStoreGameRepository.ts  ← implémente GameRepository
+        │   │   ├── EventStore.ts
+        │   │   ├── projections/
+        │   │   │   ├── GameSummaryProjectionStore.kt   ← implémentation concrète (DB, table dédiée)
+        │   │   │   └── models/
+        │   │   │       └── GameSummaryView.kt          ← structure de la vue elle-même 
+        │   ├── websocket/
+        │   │   ├── WebSocketServer.ts
+        │   │   ├── connectionManager.ts         ← Map<gameId, Map<playerId, WebSocket>>
+        │   │   └── commandRouter.ts             ← reçoit le message brut, dispatch vers le bon handler
+        │   └── eventPublisher/
+        │       └── WebSocketEventPublisher.ts   ← implémente EventPublisher, fait le broadcast
+        └── presentation/                        ← Traduction vers/depuis le client (le fameux DTO layer)
+            ├── clientEvents/
+            │   ├── ClientEvent.ts               ← types des events envoyés au front
+            │   └── toClientEvent.ts             ← fonction de traduction domain event → client event
+            └── clientCommands/
+                └── parseIncomingCommand.ts      ← valide/parse le message brut du client → Command
+```
@@ -1,33 +1,23 @@
 Installation
 ============

-To run the stack in production:
+To run the stack:

 ```shell
 docker compose -f docker\docker-compose-prod.yaml -p event-demo up -d
 ```

-To run only the app dependencies in development mode and run the app localy (not in docker):
-
-```shell
-docker compose -f docker\docker-compose-dev.yaml up -d
-```
-
-To run the tests in docker (it's designed for the CI):
-
-```shell
-docker compose -f docker\docker-compose-test.yaml up -d
-```
-
 Api url:
 - [Backend API](http://api.traefik.me/)
- [Frontend web site](http://app.traefik.me/)
+- [Frontend web site](http://app.traefik.me/) (WIP)

-Exposed url on dev env:
+Exposed url on test env:
 - [PostgreSql](http://localhost:5432/)
+- [Redis](http://localhost:6379/)
 - [RabbitMQ](http://localhost:15672/)

 Admin service URL:
 - [Træfik dashboard](http://traefik.traefik.me/)
+- [Redis insight](http://insight.redis.traefik.me/)
 - [pgAdmin](http://pgadmin.postgresql.traefik.me/)
 - [RabbitMQ management](http://management.rabbitmq.traefik.me/)
@@ -0,0 +1,93 @@
+@startuml
+'https://plantuml.com/class-diagram
+
+left to right direction
+
+class GameList <<Projection>> {
+  + status: Status
+}
+class GameState <<Projection>> {
+  + players: List<Player>
+  + currentPlayerTurn: Player
+  + lastCardPlayer: Player
+  + colorOnCurrentStack: Color
+  + direction: Direction
+  + readyPlayers: List<Player>
+  + deck: Deck
+  + isStarted: Boolean
+  + playerWins: List<Player>
+}
+interface Card {
+  + id: UUID
+}
+enum Color {
+  + Blue
+  + Red
+  + Yellow
+  + Green
+}
+class GameId {
+  + id: UUID
+}
+class Player {
+  + id: PlayerId
+  + name: String
+}
+class Deck {
+  + stack: Stack
+  + discard: Discard
+  + playersHands: PlayersHands
+}
+class Stack {
+  + cards: List<Card>
+  + shuffle()
+}
+class Discard {
+  + cards: List<Card>
+}
+class PlayerHands {
+  + map: Map<PlayerId, List<Card>>
+}
+
+class NumericCard {
+  + number: Int
+  + color: Color
+}
+class ReverseCard {
+  + color: Color
+}
+class PassCard {
+  + color: Color
+}
+class Plus2Card {
+  + color: Color
+}
+class Plus4Card
+class ChangeColorCard
+
+GameState *-- Deck
+GameState o-- "many" Player
+Deck *-- PlayerHands
+PlayerHands *-- "many" Card
+PlayerHands o-- "many" Player
+Stack *-- "many" Card
+Discard *-- "many" Card
+Deck *-- Stack
+Deck *-- Discard
+GameState *-- GameId
+Card <|--- NumericCard
+Card <|--- ReverseCard
+Card <|--- PassCard
+Card <|--- ChangeColorCard
+Card <|--- Plus2Card
+Card <|--- Plus4Card
+
+ReverseCard o-- Color
+NumericCard o-- Color
+PassCard o-- Color
+Plus2Card o-- Color
+
+GameList *-- GameId
+GameList o-- "many" Player
+
+@enduml
@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" contentStyleType="text/css" height="668px" preserveAspectRatio="none" style="width:1329px;height:668px;" version="1.1" viewBox="0 0 1329 668" width="1329px" zoomAndPan="magnify"><defs/><g><!--class GameList--><g id="elem_GameList"><rect codeLine="5" fill="#F1F1F1" height="79.2031" id="GameList" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="110.8203" x="50.5" y="7"/><ellipse cx="72.7501" cy="29.291" fill="#ADD1B2" rx="11" ry="11" style="stroke:#181818;stroke-width:1.0;"/><path d="M75.5157,25.166 Q75.672,24.9473 75.8595,24.8379 Q76.047,24.7285 76.2657,24.7285 Q76.6407,24.7285 76.8751,24.9941 Q77.1095,25.2441 77.1095,25.8535 L77.1095,27.3066 Q77.1095,27.916 76.8751,28.1816 Q76.6407,28.4473 76.2657,28.4473 Q75.922,28.4473 75.7188,28.2441 Q75.5157,28.0566 75.4063,27.541 Q75.3595,27.1816 75.172,26.9941 Q74.8438,26.6191 74.2345,26.4004 Q73.6251,26.1816 73.0001,26.1816 Q72.2345,26.1816 71.5938,26.5098 Q70.9688,26.8379 70.4688,27.5879 Q69.9845,28.3379 69.9845,29.3691 L69.9845,30.4629 Q69.9845,31.6973 70.8751,32.5254 Q71.7657,33.3379 73.3595,33.3379 Q74.297,33.3379 74.9532,33.0879 Q75.3438,32.9316 75.7657,32.4941 Q76.0313,32.2285 76.172,32.1504 Q76.3282,32.0723 76.5313,32.0723 Q76.8595,32.0723 77.1095,32.3379 Q77.3751,32.5879 77.3751,32.9316 Q77.3751,33.2754 77.0313,33.6816 Q76.5313,34.2598 75.7345,34.5879 Q74.6563,35.041 73.3595,35.041 Q71.8438,35.041 70.6407,34.416 Q69.6563,33.916 68.9688,32.8535 Q68.2813,31.7754 68.2813,30.4941 L68.2813,29.3379 Q68.2813,28.0098 68.8907,26.8691 Q69.5157,25.7129 70.6095,25.1035 Q71.7032,24.4785 72.9376,24.4785 Q73.672,24.4785 74.3126,24.6504 Q74.9688,24.8066 75.5157,25.166 Z " fill="#000000"/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacing" textLength="66.709" x="86.3612" y="24.9492">&#171;Projection&#187;</text><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="59.9102" x="89.7606" y="43.0684">GameList</text><line style="stroke:#181818;stroke-width:0.5;" x1="51.5" x2="160.3203" y1="51.582" y2="51.582"/><ellipse cx="61.5" cy="66.3926" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="84.8203" x="70.5" y="70.6895">status: Status</text><line style="stroke:#181818;stroke-width:0.5;" x1="51.5" x2="160.3203" y1="78.2031" y2="78.2031"/></g><!--class GameState--><g id="elem_GameState"><rect codeLine="8" fill="#F1F1F1" height="228.1719" id="GameState" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="197.9512" x="7" y="121.5"/><ellipse cx="66.3188" cy="143.791" fill="#ADD1B2" rx="11" ry="11" style="stroke:#181818;stroke-width:1.0;"/><path d="M69.0845,139.666 Q69.2407,139.4473 69.4282,139.3379 Q69.6157,139.2285 69.8345,139.2285 Q70.2095,139.2285 70.4438,139.4941 Q70.6782,139.7441 70.6782,140.3535 L70.6782,141.8066 Q70.6782,142.416 70.4438,142.6816 Q70.2095,142.9473 69.8345,142.9473 Q69.4907,142.9473 69.2876,142.7441 Q69.0845,142.5566 68.9751,142.041 Q68.9282,141.6816 68.7407,141.4941 Q68.4126,141.1191 67.8032,140.9004 Q67.1938,140.6816 66.5688,140.6816 Q65.8032,140.6816 65.1626,141.0098 Q64.5376,141.3379 64.0376,142.0879 Q63.5532,142.8379 63.5532,143.8691 L63.5532,144.9629 Q63.5532,146.1973 64.4438,147.0254 Q65.3345,147.8379 66.9282,147.8379 Q67.8657,147.8379 68.522,147.5879 Q68.9126,147.4316 69.3345,146.9941 Q69.6001,146.7285 69.7407,146.6504 Q69.897,146.5723 70.1001,146.5723 Q70.4282,146.5723 70.6782,146.8379 Q70.9438,147.0879 70.9438,147.4316 Q70.9438,147.7754 70.6001,148.1816 Q70.1001,148.7598 69.3032,149.0879 Q68.2251,149.541 66.9282,149.541 Q65.4126,149.541 64.2095,148.916 Q63.2251,148.416 62.5376,147.3535 Q61.8501,146.2754 61.8501,144.9941 L61.8501,143.8379 Q61.8501,142.5098 62.4595,141.3691 Q63.0845,140.2129 64.1782,139.6035 Q65.272,138.9785 66.5063,138.9785 Q67.2407,138.9785 67.8813,139.1504 Q68.5376,139.3066 69.0845,139.666 Z " fill="#000000"/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacing" textLength="66.709" x="88.8711" y="139.4492">&#171;Projection&#187;</text><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="70.8135" x="86.8188" y="157.5684">GameState</text><line style="stroke:#181818;stroke-width:0.5;" x1="8" x2="203.9512" y1="166.082" y2="166.082"/><ellipse cx="18" cy="180.8926" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="130.7305" x="27" y="185.1895">players: List&lt;Player&gt;</text><ellipse cx="18" cy="199.5137" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="159.5029" x="27" y="203.8105">currentPlayerTurn: PlayerLine truncated
@@ -0,0 +1,84 @@
+@startuml
+'https://plantuml.com/use-case-diagram
+
+package Legend {
+    usecase (Queries) #7693C4
+    usecase (Projections) #AB64C9
+    usecase (Events) #5FAD56
+}
+
+actor  User
+entity Query #7693C4
+
+entity Command #5FAD56
+entity Event #5FAD56
+entity Projection #AB64C9
+
+database  Postgresql
+database  Redis
+queue     RabbitMQ
+
+usecase  (Web socket adapter) #5FAD56
+usecase  (Command handler) #5FAD56
+usecase/ (Action) #5FAD56
+usecase  (Event handler) #5FAD56
+usecase  (Version builder) #5FAD56
+usecase  (Event store) #5FAD56
+usecase  (Event stream) #5FAD56
+usecase  (Event bus) #5FAD56
+usecase/ (Reaction listener) #5FAD56
+
+usecase/ (Projection builder) #AB64C9
+usecase  (Projection repository) #AB64C9
+usecase  (Projection bus) #AB64C9
+
+usecase  (Controller) #7693C4
+
+User -> Query : <<create>>
+Command <- User : <<create>>
+User ---> (Controller) : Get \nprojection
+User <-- (Controller) : Returns \nprojection
+
+(Controller) --------> (Projection repository) : Get \nprojection
+
+User -> (Web socket adapter) : Send \ncommand
+(Web socket adapter) --> (Command handler) : Send \ncommand
+(Web socket adapter) ...> User : Send notification \n(error or success)
+
+(Command handler) ..> (Web socket adapter) : Send \nnotification
+(Command handler) -> (Action) : Execute action
+(Command handler) <- (Action) : Returns \nevent builder
+(Command handler) ---> (Event handler) : Dispatch \nevent \n(send an event builder)
+(Command handler) --> Event : <<Create>>
+
+(Event handler) --> (Event store) : Publish \nevent
+(Event handler) <-- (Reaction listener) : Dispatch \n new event
+(Version builder) <- (Event handler) : build next version
+note "Acquire a lock, \nget the next event version, \nand then, build the event " as EventHandlerNote
+EventHandlerNote <-- (Event handler)
+
+(Event store) -left-> (Event stream)
+(Event store) ---> (Event bus) : Publish \nevent
+
+(Event stream) --> Postgresql : Persist \nevent
+(Event bus) -> RabbitMQ : Publish \nevent
+(Event bus) -> RabbitMQ : Subscribe \nto event
+(Event bus) <. RabbitMQ : Emit event
+
+(Reaction listener) ---> (Projection bus) : Subscribe
+(Reaction listener) <.. (Projection bus) : Emit projection
+
+(Projection bus) <- (Projection repository) : Publish \nprojection
+RabbitMQ <- (Projection bus) : Publish \nprojection
+RabbitMQ <- (Projection bus) : Subscribe \nto projection
+RabbitMQ .> (Projection bus) : Emit projection
+
+(Event bus) <---- (Projection repository) : Subscribe
+(Event bus) ..> (Projection repository) : Emit event
+
+(Projection repository) --> Redis : Persist \nprojection
+(Projection repository) <- Redis : Get \nprojection
+(Projection repository) -> (Projection builder) : Build \nprojection
+
+(Projection builder) --> Projection : <<create projection>>
+@enduml
@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" contentStyleType="text/css" height="1460px" preserveAspectRatio="none" style="width:1185px;height:1460px;" version="1.1" viewBox="0 0 1185 1460" width="1185px" zoomAndPan="magnify"><defs/><g><!--cluster Legend--><g id="cluster_Legend"><path d="M897,6.0137 L947.7793,6.0137 A3.75,3.75 0 0 1 950.2793,8.5137 L957.2793,30.6348 L1176,30.6348 A2.5,2.5 0 0 1 1178.5,33.1348 L1178.5,207.5137 A2.5,2.5 0 0 1 1176,210.0137 L897,210.0137 A2.5,2.5 0 0 1 894.5,207.5137 L894.5,8.5137 A2.5,2.5 0 0 1 897,6.0137 " fill="none" style="stroke:#000000;stroke-width:1.5;"/><line style="stroke:#000000;stroke-width:1.5;" x1="894.5" x2="957.2793" y1="30.6348" y2="30.6348"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacing" textLength="49.7793" x="898.5" y="23.1211">Legend</text></g><g id="elem_Queries"><ellipse cx="957.5879" cy="59.315" fill="#7693C4" rx="46.5879" ry="16.3013" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="49.0205" x="930.0776" y="64.1187">Queries</text></g><g id="elem_Projections"><ellipse cx="1100.6745" cy="59.4601" fill="#AB64C9" rx="61.6745" ry="16.4464" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="69.2549" x="1063.0471" y="64.2638">Projections</text></g><g id="elem_Events"><ellipse cx="957.4528" cy="178.2499" fill="#5FAD56" rx="41.9528" ry="16.2362" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="42.7998" x="933.2413" y="183.0022">Events</text></g><!--entity User--><g id="elem_User"><ellipse cx="605.2793" cy="28.5137" fill="#F1F1F1" rx="8" ry="8" style="stroke:#181818;stroke-width:0.5;"/><path d="M605.2793,36.5137 L605.2793,63.5137 M592.2793,44.5137 L618.2793,44.5137 M605.2793,63.5137 L592.2793,78.5137 M605.2793,63.5137 L618.2793,78.5137 " fill="none" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="29.5586" x="590.5" y="95.1211">User</text></g><!--entity Query--><g id="elem_Query"><ellipse cx="726.562" cy="50.0137" fill="#7693C4" rx="12" ry="12" style="stroke:#181818;stroke-width:0.5;"/><line style="stroke:#181818;stroke-width:0.5;" x1="714.562" x2="738.562" y1="64.0137" y2="64.0137"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="38.124" x="707.5" y="81.1211">Query</text></g><!--entity Command--><g id="elem_Command"><ellipse cx="471.2896" cy="50.0137" fill="#5FAD56" rx="12" ry="12" style="stroke:#181818;stroke-width:0.5;"/><line style="stroke:#181818;stroke-width:0.5;" x1="459.2896" x2="483.2896" y1="64.0137" y2="64.0137"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="64.5791" x="439" y="81.1211">Command</text></g><!--entity Event--><g id="elem_Event"><ellipse cx="243.3999" cy="530.5137" fill="#5FAD56" rx="12" ry="12" style="stroke:#181818;stroke-width:0.5;"/><line style="stroke:#181818;stroke-width:0.5;" x1="231.3999" x2="255.3999" y1="544.5137" y2="544.5137"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="35.7998" x="225.5" y="561.6211">Event</text></g><!--entity Projection--><g id="elem_Projection"><ellipse cx="750.6274" cy="1410.0137" fill="#AB64C9" rx="12" ry="12" style="stroke:#181818;stroke-width:0.5;"/><line style="stroke:#181818;stroke-width:0.5;" x1="738.6274" x2="762.6274" y1="1424.0137" y2="1424.0137"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="62.2549" x="719.5" y="1441.1211">Projection</text></g><!--entity Postgresql--><g id="elem_Postgresql"><path d="M83.5,905.0137 C83.5,895.0137 126.5723,895.0137 126.5723,895.0137 C126.5723,895.0137 169.6445,895.0137 169.6445,905.0137 L169.6445,932.6348 C169.6445,942.6348 126.5723,942.6348 126.5723,942.6348 C126.5723,942.6348 83.5,942.6348 83.5,932.6348 L83.5,905.0137 " fill="#F1F1F1" style="stroke:#181818;stroke-width:0.5;"/><path d="M83.5,905.0137 C83.5,915.0137 126.5723,915.0137 126.5723,915.0137 C126.5723,915.0137 169.6445,915.0137 169.6445,905.0137 " fill="none" style="stroke:#181818;stroke-width:0.5;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="66.1445" x="93.5" y="934.1211">Postgresql</text></g><!--entity Redis--><g id="elem_Redis"><path d="M462.5,1405.5137 C462.5,1395.5137 490.3965,1395.5137 490.3965,1395.5137 C490.3965,1395.5137 518.293,1395.5137 518.293,1405.5137 L518.293,1433.1348 C518.293,1443.1348 490.3965,1443.1348 490.3965,1443.1348 C490.3965,1443.1348 462.5,1443.1348 462.5,1433.1348 L462.5,1405.5137 " fill="#F1F1F1" style="stroke:#181818;stroke-width:0.5;"/><path d="M462.5,1405.5137 C462.5,1415.5137 490.3965,Line truncated
@@ -1,2 +0,0 @@
-POSTGRESQL_URL=jdbc:postgresql://postgresql/event-demo
-RABBITMQ_URL=rabbitmq
@@ -0,0 +1 @@
+PGADMIN_DEFAULT_EMAIL=
@@ -1,5 +1,5 @@
 # Stage 1: Cache Gradle dependencies
-FROM gradle:9.6.1-jdk21-alpine AS cache
+FROM gradle:latest AS cache
 RUN mkdir -p /home/gradle/cache_home
 ENV GRADLE_USER_HOME=/home/gradle/cache_home
 COPY build.gradle.* gradle.properties /home/gradle/app/
@@ -7,7 +7,7 @@ WORKDIR /home/gradle/app
 RUN gradle build -i -x check

 # Stage 2: Build Application
-FROM gradle:9.6.1-jdk21-alpine AS build
+FROM gradle:latest AS build
 COPY --from=cache /home/gradle/cache_home /home/gradle/.gradle
 COPY --chown=gradle:gradle . /home/gradle/src
 WORKDIR /home/gradle/src
@@ -16,8 +16,8 @@ WORKDIR /home/gradle/src
 RUN gradle buildFatJar --no-daemon

 # Stage 3: Create the Runtime Image
-FROM eclipse-temurin:21-jre-alpine AS runtime
+FROM amazoncorretto:21 AS runtime
 EXPOSE 8080
 RUN mkdir /app
-COPY --from=build /home/gradle/src/build/libs/*-all.jar /app/event-demo-all.jar
+COPY --from=build /home/gradle/src/build/libs/*.jar /app/event-demo-all.jar
 ENTRYPOINT ["java","-jar","/app/event-demo-all.jar"]
@@ -1,10 +0,0 @@
-# Image officielle Gradle avec JDK 21 déjà installé
-FROM gradle:9.6.1-jdk21
-
-WORKDIR /app
-
-# Copie du wrapper et des fichiers de config en premier pour profiter du cache Docker
-COPY build.gradle.kts settings.gradle.kts ./
-
-# Lance les tests Kotlin
-CMD ["gradle", "test", "--no-daemon"]
@@ -0,0 +1,6 @@
+name: event-demo-test
+include:
+  - path:
+    - parts/docker-compose-databases.yaml
+    - parts/docker-compose-databases-expose.yaml
+    - parts/docker-compose-traefik.yaml
@@ -1,17 +0,0 @@
-name: event-demo-dev
-include:
-  - path:
-      - parts/docker-compose-databases.yaml
-      - parts/docker-compose-databases-expose.yaml
-      - parts/docker-compose-tools.yaml
-      - parts/docker-compose-tools-local.yaml
-      - parts/docker-compose-traefik.yaml
-
-services:
-  postgresql:
-    environment:
-      POSTGRES_PASSWORD: "changeit"
-
-  pgadmin:
-    environment:
-      PGADMIN_DEFAULT_PASSWORD: "changeit"
@@ -5,16 +5,3 @@ include:
    - parts/docker-compose-app.yaml
    - parts/docker-compose-tools.yaml
    - parts/docker-compose-traefik.yaml
-
-services:
-  postgresql:
-    environment:
-      POSTGRES_PASSWORD_FILE: /run/secrets/postgresql_password
-    volumes:
-      - ./postgresql.secret:/run/secrets/postgresql_password:ro
-
-  pgadmin:
-    environment:
-      PGADMIN_DEFAULT_PASSWORD_FILE: /run/secrets/pgadmin_password
-    volumes:
-      - ./pgadmin.secret:/run/secrets/pgadmin_password:ro
@@ -2,10 +2,6 @@ name: event-demo-test
 include:
  - path:
    - parts/docker-compose-databases.yaml
-    - parts/docker-compose-test.yaml
+    - parts/docker-compose-databases-expose.yaml
+    - parts/docker-compose-tools.yaml
    - parts/docker-compose-traefik.yaml
-
-services:
-  postgresql:
-    environment:
-      POSTGRES_PASSWORD: "changeit"
@@ -10,8 +10,8 @@ services:
        condition: service_healthy
      rabbitmq:
        condition: service_healthy
-    env_file:
-      - ../.env.docker
+      redis:
+        condition: service_healthy
    labels:
      - "traefik.http.routers.api.rule=Host(`api.traefik.me`)"
      - "traefik.http.services.api.loadbalancer.server.port=8080"
@@ -1,4 +1,8 @@
 services:
+  redis:
+    ports:
+      - "6379:6379"
+
  postgresql:
    ports:
      - "5432:5432"
@@ -1,4 +1,12 @@
 services:
+  redis:
+    image: redis/redis-stack:7.4.0-v8
+    healthcheck:
+      test: [ "CMD", "redis-cli", "--raw", "incr", "ping" ]
+    volumes:
+      - redis_data:/data
+      - redisinsight_data:/redisinsight
+
  flyway:
    image: flyway/flyway
    command: migrate
@@ -14,7 +22,10 @@ services:
    image: postgres:18.4
    command: postgres -c 'max_connections=500'
    environment:
+      POSTGRES_PASSWORD_FILE: /run/secrets/postgresql_password
      POSTGRES_USER: event-demo
+    secrets:
+      - postgresql_password
    healthcheck:
      test: ["CMD-SHELL", "sh -c 'pg_isready -U event-demo'"]
      interval: 1s
@@ -36,6 +47,12 @@ services:
    volumes:
      - rabbitmq_data:/var/lib/rabbitmq/

+secrets:
+  postgresql_password:
+    file: ../postgresql.secret
+
 volumes:
+  redis_data:
+  redisinsight_data:
  postgresql_data:
  rabbitmq_data:
@@ -1,20 +0,0 @@
-services:
-  tests:
-    build:
-      context: ../..
-      dockerfile: docker/DockerfileTest
-    volumes:
-      - ${GRADLE_CACHE_DIR:-gradle-cache}:/home/gradle/.gradle
-      - ../..:/app
-    depends_on:
-      flyway:
-        condition: service_completed_successfully
-      postgresql:
-        condition: service_healthy
-      rabbitmq:
-        condition: service_healthy
-    env_file:
-      - ../.env.docker
-
-volumes:
-  gradle-cache:
@@ -1,18 +0,0 @@
-services:
-  pgadmin:
-    environment:
-      PGADMIN_CONFIG_SERVER_MODE: 'False'
-      PGADMIN_CONFIG_MASTER_PASSWORD_REQUIRED: 'False'
-    configs:
-      - source: pgpass
-        target: /pgpass
-        mode: 0600
-        uid: "5050"
-        gid: "5050"
-      - source: servers_json
-        target: /pgadmin4/servers.json
-
-configs:
-  pgpass:
-    content: |
-      *:*:*:event-demo:changeit
@@ -2,39 +2,31 @@ services:
  pgadmin:
    image: dpage/pgadmin4
    environment:
-      PGADMIN_DEFAULT_EMAIL: ${PGADMIN_DEFAULT_EMAIL:-admin@event-demo.dev}
+      PGADMIN_DEFAULT_EMAIL: $PGADMIN_DEFAULT_EMAIL
+      PGADMIN_DEFAULT_PASSWORD_FILE: /run/secrets/pgadmin_password
+    secrets:
+      - pgadmin_password
    volumes:
      - pgadmin_data:/var/lib/pgadmin
-    configs:
-      - source: servers_json
-        target: /pgadmin4/servers.json
    labels:
      - "traefik.http.routers.pgadmin.rule=Host(`pgadmin.postgresql.traefik.me`)"
      - "traefik.http.services.pgadmin.loadbalancer.server.port=80"

+  redis:
+    labels:
+      - "traefik.http.routers.redisinsight.rule=Host(`insight.redis.traefik.me`)"
+      - "traefik.http.routers.redisinsight.service=redisinsight"
+      - "traefik.http.services.redisinsight.loadbalancer.server.port=8001"
+
  rabbitmq:
    labels:
      - "traefik.http.routers.rabbitmq-management.rule=Host(`management.rabbitmq.traefik.me`)"
      - "traefik.http.routers.rabbitmq-management.service=rabbitmq-management"
      - "traefik.http.services.rabbitmq-management.loadbalancer.server.port=15672"

-configs:
-  servers_json:
-    content: |
-      {
-        "Servers": {
-          "1": {
-            "Name": "Event demo",
-            "Group": "Servers",
-            "Host": "postgresql",
-            "Port": 5432,
-            "MaintenanceDB": "event-demo",
-            "Username": "event-demo",
-            "PassFile": "/pgpass",
-            "SSLMode": "prefer"
-          }
-        }
-      }
+secrets:
+  pgadmin_password:
+    file: ../pgadmin.secret

 volumes:
  pgadmin_data:
@@ -1,264 +1,58 @@
 openapi: "3.0.3"
 info:
  title: "event_demo API"
-  description: |
-    API for the event_demo project: a small event-sourced Uno-like card game.
-
-    The API is split in two parts:
-    - a classic REST API used to authenticate, create users, list games and
-      replay a game's history.
-    - a WebSocket endpoint (`/games/{id}`) used to play a game in real time:
-      the client sends `GameCommand` messages and receives `Notification`
-      messages back. See the `x-websocket-channels` section below for details,
-      since WebSockets are not natively described by OpenAPI 3.0.
-
-    Authentication is done with a JWT bearer token obtained from `/login/{username}`.
-    Note that most polymorphic messages (`GameCommand`, `Notification`) are
-    discriminated by a `type` field whose value is the fully-qualified Kotlin
-    class name of the payload (since no custom serial name is declared for
-    these types), while `Card` uses short discriminator values
-    (`Simple`, `Reverse`, `Pass`, `Plus2`, `Plus4`, `ChangeColor`).
-  version: "2.0.0"
+  description: "event_demo API"
+  version: "1.0.0"
 servers:
 - url: "https://event_demo"
-
-tags:
- name: Auth
-  description: User registration and authentication
- name: Games
-  description: Listing games and reading/playing their state
-
-security:
- bearerAuth: []
-
 paths:
-  "/login/{username}":
-    post:
-      tags: [Auth]
-      summary: Log in and obtain a JWT
-      security: []
-      parameters:
-        - name: username
-          in: path
-          required: true
-          schema:
-            type: string
-        - name: password
-          in: query
-          description: The user's plain-text password.
-          required: true
-          schema:
-            type: string
-      responses:
-        200:
-          description: Successful login
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/LoginResponse"
-        400:
-          description: Unknown username or invalid password
-  "/users/create":
-    post:
-      tags: [Auth]
-      summary: Create a new user account
-      description: Requires a valid JWT (any authenticated user can create new users).
-      parameters:
-        - name: username
-          in: query
-          required: true
-          schema:
-            type: string
-        - name: password
-          in: query
-          description: The plain-text password, hashed server-side before being stored.
-          required: true
-          schema:
-            type: string
-      responses:
-        200:
-          description: The newly created user
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/CreateUserResponse"
-        401:
-          $ref: "#/components/responses/Unauthorized"
-  "/games":
+  "/game/{id}/card/last":
    get:
-      tags: [Games]
-      summary: List all known games
-      description: Returns up to the 100 most recent games (pagination is not yet exposed on this route).
+      description: get the last card played
      responses:
        200:
-          description: The list of games
+          description: The last card
          content:
            application/json:
              schema:
-                type: array
-                items:
-                  $ref: "#/components/schemas/GameList"
-        401:
-          $ref: "#/components/responses/Unauthorized"
-  "/games/{id}":
-    get:
-      tags: [Games]
-      summary: Replay a game's full notification history
-      description: |
-        Rebuilds every notification that would have been sent to the calling
-        player since the beginning of the game (from its event stream), so a
-        client reconnecting can catch up on the current game state.
-
-        This same path also accepts a WebSocket upgrade to play the game live,
-        see `x-websocket-channels` at the root of this document.
-      parameters:
-        - name: id
-          in: path
-          required: true
-          schema:
-            type: string
-            format: uuid
-      responses:
-        200:
-          description: The full list of notifications for this game, from this player's point of view
-          content:
-            application/json:
-              schema:
-                type: array
-                items:
-                  $ref: "#/components/schemas/Notification"
-        401:
-          $ref: "#/components/responses/Unauthorized"
-        404:
-          description: No game found for this id
-
-x-websocket-channels:
-  "/games/{id}":
-    description: |
-      WebSocket endpoint to join and play a game in real time. Requires the
-      same JWT bearer authentication as the REST routes (sent the same way,
-      e.g. via the `Authorization` header during the WebSocket handshake).
-    parameters:
-      - name: id
-        in: path
-        required: true
-        schema:
-          type: string
-          format: uuid
-    send:
-      description: Commands sent by the client to act on the game.
-      schema:
-        $ref: "#/components/schemas/GameCommand"
-    receive:
-      description: Notifications sent by the server as the game progresses.
-      schema:
-        $ref: "#/components/schemas/Notification"
+                $ref: "#/components/schemas/Card"

 components:
-  securitySchemes:
-    bearerAuth:
-      type: http
-      scheme: bearer
-      bearerFormat: JWT
-      description: >
-        JWT obtained from `POST /login/{username}`. It carries the `username`
-        and `userid` claims and currently expires 60 seconds after issuance.
-
-  responses:
-    Unauthorized:
-      description: Missing, invalid or expired JWT
-      content:
-        text/plain:
-          schema:
-            type: string
-            example: "Token is not valid or has expired"
-
  schemas:
-    LoginResponse:
-      type: object
-      required: [token]
+    Card:
+      oneOf:
+        - $ref: "#/components/schemas/SimpleCard"
+        - $ref: "#/components/schemas/ReverseCard"
+        - $ref: "#/components/schemas/PassCard"
+        - $ref: "#/components/schemas/Plus2Card"
+        - $ref: "#/components/schemas/Plus4Card"
+        - $ref: "#/components/schemas/ChangeColorCard"
+    SimpleCard:
      properties:
-        token:
-          type: string
-          description: JWT bearer token to use on subsequent requests.
-
-    CreateUserResponse:
-      type: object
-      required: [id]
-      properties:
-        id:
-          type: string
-          format: uuid
-
-    HttpErrorBadRequest:
-      type: object
-      description: Generic problem-details style error body used by some validation failures.
-      properties:
-        title:
-          type: string
-        statusCode:
+        number:
          type: integer
-        invalidParams:
-          type: array
-          items:
-            $ref: "#/components/schemas/InvalidParam"
-
-    InvalidParam:
-      type: object
-      required: [name, reason]
+        color:
+          $ref: "#/components/schemas/CardColor"
+    ReverseCard:
      properties:
-        name:
-          type: string
-        reason:
-          type: string
-
-    PlayerId:
-      type: string
-      format: uuid
-
-    Player:
-      type: object
-      required: [name, userId, hand, id]
+        color:
+          $ref: "#/components/schemas/CardColor"
+    PassCard:
      properties:
-        name:
-          type: string
-        userId:
-          type: string
-          format: uuid
-        id:
-          $ref: "#/components/schemas/PlayerId"
-        hand:
-          description: The set of cards currently held by the player.
-          type: array
-          items:
-            $ref: "#/components/schemas/Card"
-
-    GameList:
-      type: object
-      required: [aggregateId, status, players, winners]
+        color:
+          $ref: "#/components/schemas/CardColor"
+    Plus2Card:
      properties:
-        aggregateId:
-          type: string
-          format: uuid
-        status:
-          $ref: "#/components/schemas/GameStatus"
-        players:
-          type: array
-          items:
-            $ref: "#/components/schemas/Player"
-        winners:
-          type: array
-          items:
-            $ref: "#/components/schemas/PlayerId"
-
-    GameStatus:
-      type: string
-      enum:
-        - OPENING
-        - IS_STARTED
-        - FINISH
-        - CANCELED
-
+        color:
+          $ref: "#/components/schemas/CardColor"
+    Plus4Card:
+      properties:
+        nextColor:
+          $ref: "#/components/schemas/CardColor"
+    ChangeColorCard:
+      properties:
+        nextColor:
+          $ref: "#/components/schemas/CardColor"
    CardColor:
      type: string
      enum:
@@ -266,401 +60,3 @@ components:
        - Red
        - Yellow
        - Green
-
-    Card:
-      description: >
-        A playing card. Discriminated by the "type" field using the short
-        names declared on each Kotlin subtype (@SerialName), unlike
-        GameCommand/Notification below.
-      oneOf:
-        - $ref: "#/components/schemas/NumericCard"
-        - $ref: "#/components/schemas/ReverseCard"
-        - $ref: "#/components/schemas/PassCard"
-        - $ref: "#/components/schemas/Plus2Card"
-        - $ref: "#/components/schemas/Plus4Card"
-        - $ref: "#/components/schemas/ChangeColorCard"
-      discriminator:
-        propertyName: type
-        mapping:
-          Simple: "#/components/schemas/NumericCard"
-          Reverse: "#/components/schemas/ReverseCard"
-          Pass: "#/components/schemas/PassCard"
-          Plus2: "#/components/schemas/Plus2Card"
-          Plus4: "#/components/schemas/Plus4Card"
-          ChangeColor: "#/components/schemas/ChangeColorCard"
-
-    NumericCard:
-      description: A numbered card (0-9) of a given color.
-      type: object
-      required: [type, id, number, color]
-      properties:
-        type:
-          type: string
-          enum: [Simple]
-        id:
-          type: string
-          format: uuid
-        number:
-          type: integer
-          minimum: 0
-          maximum: 9
-        color:
-          $ref: "#/components/schemas/CardColor"
-
-    ReverseCard:
-      description: Reverses the turn order.
-      type: object
-      required: [type, id, color]
-      properties:
-        type:
-          type: string
-          enum: [Reverse]
-        id:
-          type: string
-          format: uuid
-        color:
-          $ref: "#/components/schemas/CardColor"
-
-    PassCard:
-      description: Skips the next player's turn.
-      type: object
-      required: [type, id, color]
-      properties:
-        type:
-          type: string
-          enum: [Pass]
-        id:
-          type: string
-          format: uuid
-        color:
-          $ref: "#/components/schemas/CardColor"
-
-    Plus2Card:
-      description: Forces the next player to draw 2 cards and skips their turn.
-      type: object
-      required: [type, id, color]
-      properties:
-        type:
-          type: string
-          enum: [Plus2]
-        id:
-          type: string
-          format: uuid
-        color:
-          $ref: "#/components/schemas/CardColor"
-
-    Plus4Card:
-      description: >
-        Forces the next player to draw 4 cards and skips their turn. The new
-        color is chosen separately, via the `chosenColor` field of
-        PlayCardCommand, and is not part of the card itself.
-      type: object
-      required: [type, id]
-      properties:
-        type:
-          type: string
-          enum: [Plus4]
-        id:
-          type: string
-          format: uuid
-
-    ChangeColorCard:
-      description: >
-        Changes the current color. The new color is chosen separately, via
-        the `chosenColor` field of PlayCardCommand, and is not part of the
-        card itself.
-      type: object
-      required: [type, id]
-      properties:
-        type:
-          type: string
-          enum: [ChangeColor]
-        id:
-          type: string
-          format: uuid
-
-    GameCommand:
-      description: >
-        A command sent by the client over the game WebSocket to act on a game.
-        Discriminated by "type", whose value is the fully-qualified Kotlin
-        class name of the command (no `@SerialName` is declared on these
-        types).
-      oneOf:
-        - $ref: "#/components/schemas/JoinTheGameCommand"
-        - $ref: "#/components/schemas/PlayCardCommand"
-        - $ref: "#/components/schemas/ReadyToPlayCommand"
-        - $ref: "#/components/schemas/TakeCartFromDrawPileCommand"
-      discriminator:
-        propertyName: type
-        mapping:
-          eventDemo.contexts.game.application.command.models.JoinTheGameCommand: "#/components/schemas/JoinTheGameCommand"
-          eventDemo.contexts.game.application.command.models.PlayCardCommand: "#/components/schemas/PlayCardCommand"
-          eventDemo.contexts.game.application.command.models.ReadyToPlayCommand: "#/components/schemas/ReadyToPlayCommand"
-          eventDemo.contexts.game.application.command.models.TakeCartFromDrawPileCommand: "#/components/schemas/TakeCartFromDrawPileCommand"
-
-    JoinTheGameCommand:
-      description: Join an existing (not yet started) game.
-      type: object
-      required: [type, userId, payload]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.command.models.JoinTheGameCommand]
-        userId:
-          type: string
-          format: uuid
-        payload:
-          type: object
-          required: [aggregateId]
-          properties:
-            aggregateId:
-              type: string
-              format: uuid
-              description: The id of the game to join.
-
-    ReadyToPlayCommand:
-      description: Mark the calling player as ready, so the game can start once everyone is ready.
-      type: object
-      required: [type, userId, payload]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.command.models.ReadyToPlayCommand]
-        userId:
-          type: string
-          format: uuid
-        payload:
-          type: object
-          required: [aggregateId, playerId]
-          properties:
-            aggregateId:
-              type: string
-              format: uuid
-            playerId:
-              $ref: "#/components/schemas/PlayerId"
-
-    TakeCartFromDrawPileCommand:
-      description: Draw a card from the draw pile.
-      type: object
-      required: [type, userId, payload]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.command.models.TakeCartFromDrawPileCommand]
-        userId:
-          type: string
-          format: uuid
-        payload:
-          type: object
-          required: [aggregateId, playerId]
-          properties:
-            aggregateId:
-              type: string
-              format: uuid
-            playerId:
-              $ref: "#/components/schemas/PlayerId"
-
-    PlayCardCommand:
-      description: Play a card from the calling player's hand.
-      type: object
-      required: [type, userId, payload]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.command.models.PlayCardCommand]
-        userId:
-          type: string
-          format: uuid
-        payload:
-          type: object
-          required: [aggregateId, playerId, card]
-          properties:
-            aggregateId:
-              type: string
-              format: uuid
-            playerId:
-              $ref: "#/components/schemas/PlayerId"
-            card:
-              $ref: "#/components/schemas/Card"
-            chosenColor:
-              description: The color to switch to, only required when playing a Plus4Card or ChangeColorCard.
-              nullable: true
-              allOf:
-                - $ref: "#/components/schemas/CardColor"
-
-    Notification:
-      description: >
-        A notification sent by the server, either replayed by `GET /games/{id}`
-        or streamed live over the game WebSocket. Discriminated by "type",
-        whose value is the fully-qualified Kotlin class name of the
-        notification (no `@SerialName` is declared on these types).
-      oneOf:
-        - $ref: "#/components/schemas/WelcomeToTheGameNotification"
-        - $ref: "#/components/schemas/PlayerAsJoinTheGameNotification"
-        - $ref: "#/components/schemas/PlayerWasReadyNotification"
-        - $ref: "#/components/schemas/TheGameWasStartedNotification"
-        - $ref: "#/components/schemas/ItsTheTurnOfNotification"
-        - $ref: "#/components/schemas/PlayerAsPlayACardNotification"
-        - $ref: "#/components/schemas/YourNewCardNotification"
-        - $ref: "#/components/schemas/PlayerHavePassNotification"
-        - $ref: "#/components/schemas/PilesShuffledNotification"
-        - $ref: "#/components/schemas/PlayerWinNotification"
-      discriminator:
-        propertyName: type
-        mapping:
-          eventDemo.contexts.game.application.notification.models.WelcomeToTheGameNotification: "#/components/schemas/WelcomeToTheGameNotification"
-          eventDemo.contexts.game.application.notification.models.PlayerAsJoinTheGameNotification: "#/components/schemas/PlayerAsJoinTheGameNotification"
-          eventDemo.contexts.game.application.notification.models.PlayerWasReadyNotification: "#/components/schemas/PlayerWasReadyNotification"
-          eventDemo.contexts.game.application.notification.models.TheGameWasStartedNotification: "#/components/schemas/TheGameWasStartedNotification"
-          eventDemo.contexts.game.application.notification.models.ItsTheTurnOfNotification: "#/components/schemas/ItsTheTurnOfNotification"
-          eventDemo.contexts.game.application.notification.models.PlayerAsPlayACardNotification: "#/components/schemas/PlayerAsPlayACardNotification"
-          eventDemo.contexts.game.application.notification.models.YourNewCardNotification: "#/components/schemas/YourNewCardNotification"
-          eventDemo.contexts.game.application.notification.models.PlayerHavePassNotification: "#/components/schemas/PlayerHavePassNotification"
-          eventDemo.contexts.game.application.notification.models.PilesShuffledNotification: "#/components/schemas/PilesShuffledNotification"
-          eventDemo.contexts.game.application.notification.models.PlayerWinNotification: "#/components/schemas/PlayerWinNotification"
-
-    WelcomeToTheGameNotification:
-      description: Sent to a player right after they join a game, listing all players currently in it.
-      type: object
-      required: [type, id, players]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.WelcomeToTheGameNotification]
-        id:
-          type: string
-          format: uuid
-        players:
-          type: array
-          items:
-            $ref: "#/components/schemas/Player"
-
-    PlayerAsJoinTheGameNotification:
-      description: Sent to the other players when a new player joins the game.
-      type: object
-      required: [type, id, player]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.PlayerAsJoinTheGameNotification]
-        id:
-          type: string
-          format: uuid
-        player:
-          $ref: "#/components/schemas/Player"
-
-    PlayerWasReadyNotification:
-      description: Sent to all players when a player marks themselves as ready.
-      type: object
-      required: [type, id, playerId]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.PlayerWasReadyNotification]
-        id:
-          type: string
-          format: uuid
-        playerId:
-          $ref: "#/components/schemas/PlayerId"
-
-    TheGameWasStartedNotification:
-      description: Sent to each player when the game starts, with their initial hand.
-      type: object
-      required: [type, id, hand]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.TheGameWasStartedNotification]
-        id:
-          type: string
-          format: uuid
-        hand:
-          type: array
-          items:
-            $ref: "#/components/schemas/Card"
-
-    ItsTheTurnOfNotification:
-      description: Sent to all players to indicate whose turn it now is.
-      type: object
-      required: [type, id, player]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.ItsTheTurnOfNotification]
-        id:
-          type: string
-          format: uuid
-        player:
-          $ref: "#/components/schemas/Player"
-
-    PlayerAsPlayACardNotification:
-      description: Sent to all players when a player plays a card.
-      type: object
-      required: [type, id, playerId, card]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.PlayerAsPlayACardNotification]
-        id:
-          type: string
-          format: uuid
-        playerId:
-          $ref: "#/components/schemas/PlayerId"
-        card:
-          $ref: "#/components/schemas/Card"
-
-    YourNewCardNotification:
-      description: Sent to a player with the cards they just drew from the draw pile.
-      type: object
-      required: [type, id, cards]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.YourNewCardNotification]
-        id:
-          type: string
-          format: uuid
-        cards:
-          type: array
-          items:
-            $ref: "#/components/schemas/Card"
-
-    PlayerHavePassNotification:
-      description: Sent to the other players when a player draws a card and passes their turn.
-      type: object
-      required: [type, id, playerId]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.PlayerHavePassNotification]
-        id:
-          type: string
-          format: uuid
-        playerId:
-          $ref: "#/components/schemas/PlayerId"
-
-    PilesShuffledNotification:
-      description: Sent to all players when the discard pile is reshuffled into the draw pile.
-      type: object
-      required: [type, id]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.PilesShuffledNotification]
-        id:
-          type: string
-          format: uuid
-
-    PlayerWinNotification:
-      description: Sent to all players when a player wins the game.
-      type: object
-      required: [type, id, playerId]
-      properties:
-        type:
-          type: string
-          enum: [eventDemo.contexts.game.application.notification.models.PlayerWinNotification]
-        id:
-          type: string
-          format: uuid
-        playerId:
-          $ref: "#/components/schemas/PlayerId"
@@ -3,6 +3,7 @@ package eventDemo.configuration
 import io.ktor.server.config.ApplicationConfig

 data class Configuration(
+  val redisUrl: String,
  val jwtSecret: String,
  val postgresql: Postgresql,
  val rabbitmq: RabbitMQ,
@@ -24,6 +25,7 @@ data class Configuration(
 val ApplicationConfig.configuration
  get() =
    Configuration(
+      redisUrl = getProperty("redis.url"),
      jwtSecret = getProperty("jwt.secret"),
      postgresql =
        Configuration.Postgresql(
@@ -7,6 +7,8 @@ import org.koin.core.module.Module
 import org.koin.core.scope.Scope
 import org.koin.core.scope.ScopeCallback
 import org.koin.dsl.bind
+import redis.clients.jedis.JedisPooled
+import redis.clients.jedis.UnifiedJedis
 import javax.sql.DataSource

 fun Module.configureDIDataSource(config: Configuration) {
@@ -24,6 +26,11 @@ fun Module.configureDIDataSource(config: Configuration) {
      }
  } bind DataSource::class

+  // Redis (for Projections)
+  single {
+    JedisPooled(config.redisUrl)
+  } bind UnifiedJedis::class
+
  // RabbitMQ (for EventBus)
  factory {
    ConnectionFactory().apply {
@@ -37,8 +37,16 @@ abstract class GameEventManager(
    return this
  }

-  protected inline fun <reified G : Game> Game.isStatusOrFail(message: String): G =
-    this as? G ?: throw CommandException(message)
+  protected fun <G : Game> Game.isStatusOrFail(
+    kClass: KClass<G>,
+    message: String,
+  ): G {
+    if (kClass.isInstance(this)) {
+      return this as G
+    } else {
+      throw CommandException(message)
+    }
+  }

  protected fun <T> retry(
    mapAttempts: Int = 5,
@@ -20,7 +20,7 @@ class JoinTheGameHandler(
    retry {
      command
        .getGame()
-        .isStatusOrFail<GameCreated>("The game is started")
+        .isStatusOrFail(GameCreated::class, "The game is started")
        .userJoinTheGame(
          userId = command.userId,
          name = user.username,
@@ -16,7 +16,7 @@ class PlayCardHandler(
  override fun handle(command: PlayCardCommand) {
    command
      .getGame()
-      .isStatusOrFail<GameStarted>("The game is not started")
+      .isStatusOrFail(GameStarted::class, "The game is not started")
      .playTheCard(
        card = command.payload.card,
        playerId = command.payload.playerId,
@@ -16,7 +16,7 @@ class ReadyToPlayHandler(
  override fun handle(command: ReadyToPlayCommand) {
    command
      .getGame()
-      .isStatusOrFail<GameCreated>("The game is started")
+      .isStatusOrFail(GameCreated::class, "The game is started")
      .setReadyPlayer(command.payload.playerId)
      .saveEvents()
      .publishEvents()
@@ -18,7 +18,7 @@ class TakeCartFromDrawPileHandler(
  override fun handle(command: TakeCartFromDrawPileCommand) {
    command
      .getGame()
-      .isStatusOrFail<GameStarted>("The game is not started")
+      .isStatusOrFail(GameStarted::class, "The game is not started")
      .playerTakeCartFromDrawPile(command.payload.playerId, 1)
      .saveEvents()
      .publishEvents()
@@ -24,10 +24,6 @@ import eventDemo.contexts.game.domain.events.PlayerWinEvent
 import eventDemo.contexts.game.domain.game.gameState.Game
 import eventDemo.contexts.game.domain.game.gameState.GameStarted
 import eventDemo.sharedKernel.UserId
-import io.github.oshai.kotlinlogging.KotlinLogging
-import io.github.oshai.kotlinlogging.withLoggingContext
-
-private val logger = KotlinLogging.logger {}

 fun GameEvent.toNotification(
  game: Game,
@@ -35,16 +31,15 @@ fun GameEvent.toNotification(
 ): Iterable<Notification> =
  Iterable {
    iterator {
+      val currentPlayerId = game.players.get(currentUserId).id
+
      context(iterator: SequenceScope<Notification>)
      suspend fun Notification.send() {
-        withLoggingContext("notification" to (this).toString()) {
-          logger.info { "Notification sent" }
-          iterator.yield(this)
-        }
+        iterator.yield(this)
      }

      fun PlayerActionEvent.isFromCurrentUser(): Boolean =
-        game.players.get(currentUserId).id == playerId
+        currentPlayerId != playerId

      when (this@toNotification) {
        is GameCreatedEvent -> {
@@ -56,7 +51,7 @@ fun GameEvent.toNotification(
        }

        is NewPlayerEvent -> {
-          if (this@toNotification.player.userId != currentUserId) {
+          if (this@toNotification.isFromCurrentUser()) {
            PlayerAsJoinTheGameNotification(
              player = this@toNotification.player,
            ).send()
@@ -90,7 +85,6 @@ fun GameEvent.toNotification(

          if (game is GameStarted) {
            ItsTheTurnOfNotification(player = game.nextPlayer)
-              .send()
          }
        }

@@ -107,20 +101,21 @@ fun GameEvent.toNotification(

          if (game is GameStarted) {
            ItsTheTurnOfNotification(player = game.nextPlayer)
-              .send()
          }
        }

        is PlayerReadyEvent -> {
-          PlayerWasReadyNotification(
-            playerId = this@toNotification.playerId,
-          ).send()
+          if (this@toNotification.isFromCurrentUser()) {
+            PlayerWasReadyNotification(
+              playerId = this@toNotification.playerId,
+            )
+          }
        }

        is PlayerWinEvent -> {
          PlayerWinNotification(
            playerId = this@toNotification.playerId,
-          ).send()
+          )
        }
      }
    }
@@ -48,7 +48,7 @@ class ReactionListener(
  }

  private fun sendWinnerEvent(game: Game) {
-    if (game is GameStarted && game.lastPlayerId != null) {
+    if (game is GameStarted) {
      val lastPlayerWin =
        game
          .players
@@ -4,7 +4,6 @@ import eventDemo.contexts.game.domain.game.DiscardPile
 import eventDemo.contexts.game.domain.game.DrawPile
 import eventDemo.contexts.game.domain.game.GameId
 import eventDemo.contexts.game.domain.game.Player
-import eventDemo.contexts.game.domain.game.PlayerHand
 import eventDemo.contexts.game.infrastructure.persistence.serializers.EventIdSerializer
 import eventDemo.contexts.game.infrastructure.persistence.serializers.PlayerIdSerializer
 import eventDemo.libs.eventSource.EventId
@@ -21,7 +20,6 @@ data class GameStartedEvent(
  override val aggregateId: GameId,
  @Serializable(with = PlayerIdSerializer::class)
  val firstPlayer: Player.PlayerId,
-  val playersHans: Map<Player.PlayerId, PlayerHand>,
  val drawPile: DrawPile,
  val discardPile: DiscardPile,
  override val version: Int,
@@ -30,3 +28,9 @@ data class GameStartedEvent(
  override val eventId: EventId = EventId(UUID.randomUUID())
  override val createdAt: Instant = Clock.System.now()
 }
+
+private var isDisabled = false
+
+internal fun disableShuffleDeck() {
+  isDisabled = true
+}
@@ -7,8 +7,6 @@ import kotlinx.serialization.Serializable
 value class DrawPile(
  val cards: Set<Card> = emptySet(),
 ) {
-  val size: Int get() = cards.size
-
  fun take(number: Int): Pair<DrawPile, Set<Card>> =
    cards.drop(number).toDrawPile() to cards.take(number).toSet()

@@ -25,7 +25,6 @@ data class Player(
  }
 }

-@Serializable
 class PlayerList(
  val players: Set<Player> = emptySet(),
 ) : Set<Player> by players {
@@ -39,36 +39,28 @@ sealed interface Game {

  companion object {
    fun loadFromHistory(events: Set<GameEvent>): Game =
-      events
-        .fold(GameInit(events.first().aggregateId)) { game: Game, event ->
-          game.run {
-            when (event) {
-              is GameCreatedEvent if this is GameInit -> applyEvent(event)
-              is GameCreatedEvent -> error("Game is already created")
-              is NewPlayerEvent if this is GameCreated -> applyEvent(event)
-              is NewPlayerEvent -> error("Game is already stared")
-              is PlayerReadyEvent if this is GameCreated -> applyEvent(event)
-              is PlayerReadyEvent -> error("Game is already stared")
-              is GameStartedEvent if this is GameCreated -> applyEvent(event)
-              is GameStartedEvent -> error("Game is already started")
-              is CardIsPlayedEvent if this is GameStarted -> applyEvent(event)
-              is CardIsPlayedEvent -> error("Game is end")
-              is PlayerHaveDrawCardEvent if this is GameStarted -> applyEvent(event)
-              is PlayerHaveDrawCardEvent -> error("Game is end")
-              is PlayerWinEvent if this is GameStarted -> applyEvent(event)
-              is PlayerWinEvent -> error("Game is end")
-              is DrawFilledWithDiscardEvent if this is GameStarted -> applyEvent(event)
-              is DrawFilledWithDiscardEvent -> error("Game is end")
-            }
-          }
-        }.let {
-          when (it) {
-            is GameInit -> it
-            is GameCreated -> it.copy(recordedEvents = emptySet())
-            is GameEnded -> it.copy(recordedEvents = emptySet())
-            is GameStarted -> it.copy(recordedEvents = emptySet())
+      events.fold(GameInit(events.first().aggregateId)) { game: Game, event ->
+        game.run {
+          when (event) {
+            is GameCreatedEvent if this is GameInit -> applyEvent(event)
+            is GameCreatedEvent -> error("Game is already created")
+            is NewPlayerEvent if this is GameCreated -> applyEvent(event)
+            is NewPlayerEvent -> error("Game is already stared")
+            is PlayerReadyEvent if this is GameCreated -> applyEvent(event)
+            is PlayerReadyEvent -> error("Game is already stared")
+            is GameStartedEvent if this is GameCreated -> applyEvent(event)
+            is GameStartedEvent -> error("Game is already started")
+            is CardIsPlayedEvent if this is GameStarted -> applyEvent(event)
+            is CardIsPlayedEvent -> error("Game is end")
+            is PlayerHaveDrawCardEvent if this is GameStarted -> applyEvent(event)
+            is PlayerHaveDrawCardEvent -> error("Game is end")
+            is PlayerWinEvent if this is GameStarted -> applyEvent(event)
+            is PlayerWinEvent -> error("Game is end")
+            is DrawFilledWithDiscardEvent if this is GameStarted -> applyEvent(event)
+            is DrawFilledWithDiscardEvent -> error("Game is end")
          }
        }
+      }
  }
 }

@@ -79,3 +71,18 @@ internal fun <T : GameEvent> T.checkState(
  if (!block(this)) throw exception(this)
  return this
 }
+
+/**
+ * recordedEvents versions must be ordered and incremental.
+ */
+internal fun Game.checkRecorderEventsConsistency() {
+  recordedEvents
+    .also { if (it.size != (it.lastOrNull()?.version ?: 0)) throw InconsistentEventVersionException(recordedEvents) }
+    .mapIndexed { index, event ->
+      (index + 1) == event.version
+    }.run {
+      if (any { !it }) {
+        throw InconsistentEventVersionException(recordedEvents)
+      }
+    }
+}
@@ -9,7 +9,6 @@ import eventDemo.contexts.game.domain.game.DiscardPile
 import eventDemo.contexts.game.domain.game.DrawPile
 import eventDemo.contexts.game.domain.game.GameId
 import eventDemo.contexts.game.domain.game.Player
-import eventDemo.contexts.game.domain.game.PlayerHand
 import eventDemo.contexts.game.domain.game.PlayerList
 import eventDemo.contexts.game.domain.game.errors.AllPlayerNotReadyException
 import eventDemo.contexts.game.domain.game.errors.DeckMissingCardsException
@@ -24,28 +23,24 @@ data class GameCreated(
  override val recordedEvents: Set<GameEvent>,
  override val version: Int,
 ) : Game {
+  init {
+    checkRecorderEventsConsistency()
+  }
+
  val allPlayerIsReady: Boolean
    get() {
-      return playersStatus.isNotEmpty() && playersStatus.values.all { it == PlayerStatus.Ready }
+      return playersStatus.values.all { it == PlayerStatus.Ready }
    }

  fun startGame(deck: Deck = newDeck().shuffleDeck()): GameStarted {
-    val (drawPile, discardPile, playersHands) =
-      initPiles(deck)
-        .let { (drawPile, discardPile) ->
-          createHandsFromDrawPile(drawPile)
-            .let { (drawPile, playersHands) ->
-              Triple(drawPile, discardPile, playersHands)
-            }
-        }
+    val (drawPile, discardPile) = initPiles(deck)

    return GameStartedEvent(
      aggregateId = aggregateId,
-      firstPlayer = players.randomPlayer().id,
+      firstPlayer = players.random().id,
      version = version + 1,
      drawPile = drawPile,
      discardPile = discardPile,
-      playersHans = playersHands,
    ).checkState(
      { players.size > 1 },
      { NeedMorePlayersToStartGameException(players) },
@@ -55,8 +50,7 @@ data class GameCreated(
    ).checkState(
      { deck.size == 108 },
      { DeckMissingCardsException(players, deck) },
-    ).also { if (it.drawPile.size + it.discardPile.size + playersHands.values.sumOf { it.size } != 108) error("missing cards!") }
-      .run(::applyEvent)
+    ).run(::applyEvent)
  }

  private fun initPiles(deck: Set<Card>): Pair<DrawPile, DiscardPile> =
@@ -67,20 +61,6 @@ data class GameCreated(
        draw to DiscardPile(cards)
      }

-  private fun createHandsFromDrawPile(drawPile: DrawPile) =
-    players
-      .map { it.id }
-      .fold(Pair(drawPile, emptyMap<Player.PlayerId, PlayerHand>())) { (drawAcc, handsAcc), playerId ->
-        drawAcc
-          .take(7)
-          .let { (draw, hand) ->
-            Pair(
-              draw,
-              handsAcc + (playerId to PlayerHand(hand)),
-            )
-          }
-      }
-
  fun userJoinTheGame(
    userId: UserId,
    name: String,
@@ -127,13 +107,8 @@ data class GameCreated(
  internal fun applyEvent(event: GameStartedEvent): GameStarted =
    GameStarted(
      aggregateId = event.aggregateId,
-      players =
-        players
-          .map {
-            it.copy(hand = event.playersHans[it.id] ?: error("Player ${it.id} not found"))
-          }.let { PlayerList(it.toSet()) },
-      lastPlayerId = null,
-      nextPlayerId = event.firstPlayer,
+      players = players,
+      lastPlayerId = event.firstPlayer,
      drawPile = event.drawPile,
      discardPile = event.discardPile,
      version = event.version + 1,
@@ -158,22 +133,7 @@ fun newDeck(): Deck =
        (1..2).map { Card.PassCard(color) }
    }.let {
      it + (1..4).map { Card.Plus4Card() }
-    }.let {
-      it + (1..4).map { Card.ChangeColorCard() }
    }.toSet()

-fun Set<Card>.shuffleDeck(): Set<Card> {
-  if (isDisabled) return this
-  return shuffled().toSet()
-}
-
-private fun PlayerList.randomPlayer(): Player {
-  if (isDisabled) return first()
-  return random()
-}
-
-private var isDisabled = false
-
-fun disableRandomForTest() {
-  isDisabled = true
-}
+fun Set<Card>.shuffleDeck() =
+  shuffled().toSet()
@@ -16,5 +16,6 @@ data class GameEnded(
    if (!players.map { it.id }.containsAll(playerWins)) {
      throw IllegalArgumentException("Player ${players.map { it.id }} were not in players")
    }
+    checkRecorderEventsConsistency()
  }
 }
@@ -23,39 +23,12 @@ import eventDemo.contexts.game.domain.game.errors.ThePlayerIsNotInTheGameExcepti
 import eventDemo.contexts.game.domain.game.errors.ThePlayerMustPlayACardException
 import eventDemo.contexts.game.domain.game.gameState.Game.Direction

-fun PlayerList.nextPlayerTurn(
-  lastPlayerId: Player.PlayerId,
-  direction: Direction,
-): Player.PlayerId {
-  val lastPlayer = get(lastPlayerId)
-  val playersLastTurn = filter { it.hand.cards.isNotEmpty() || it == lastPlayer }
-
-  return playersLastTurn
-    .indexOf(lastPlayer)
-    .let { lastPlayerIndex ->
-      if (direction == Direction.CLOCKWISE) {
-        if (lastPlayerIndex == playersLastTurn.size - 1) {
-          0
-        } else {
-          lastPlayerIndex + 1
-        }
-      } else {
-        if (lastPlayerIndex == 0) {
-          playersLastTurn.size - 1
-        } else {
-          lastPlayerIndex - 1
-        }
-      }
-    }.let { nextPlayerIndex -> elementAt(nextPlayerIndex).id }
-}
-
 data class GameStarted(
  override val aggregateId: GameId,
  override val players: PlayerList,
  val drawPile: DrawPile,
  val discardPile: DiscardPile,
-  val lastPlayerId: Player.PlayerId?,
-  val nextPlayerId: Player.PlayerId,
+  val lastPlayerId: Player.PlayerId,
  val currentColor: Color,
  val playedTurnHistory: List<History> = emptyList(),
  val direction: Direction = Direction.CLOCKWISE,
@@ -67,15 +40,41 @@ data class GameStarted(

  val lastPlayedCard: Card? by lazy { discardPile.topCard }

+  val lastPlayed: Player by lazy { players.get(lastPlayerId) }
+
+  init {
+    checkRecorderEventsConsistency()
+  }
+
  data class History(
    val playerId: Player.PlayerId,
    val event: GameEvent,
    val direction: Direction,
  )

-  val lastPlayer: Player? by lazy { lastPlayerId?.let { players.get(it) } }
+  val lastPlayer by lazy { players.get(lastPlayerId) }

-  val nextPlayer: Player by lazy { players.get(nextPlayerId) }
+  val nextPlayer: Player by lazy {
+    val playersLastTurn = players.filter { it.hand.cards.isNotEmpty() || it == lastPlayer }
+
+    playersLastTurn
+      .indexOf(lastPlayer)
+      .let { lastPlayerIndex ->
+        if (direction == Direction.CLOCKWISE) {
+          if (lastPlayerIndex == playersLastTurn.size - 1) {
+            0
+          } else {
+            lastPlayerIndex + 1
+          }
+        } else {
+          if (lastPlayerIndex == 0) {
+            playersLastTurn.size - 1
+          } else {
+            lastPlayerIndex - 1
+          }
+        }
+      }.let { nextPlayerIndex -> players.elementAt(nextPlayerIndex) }
+  }

  fun canBePlayThisCard(card: Card): Boolean {
    val cardOnBoard = discardPile.topCard ?: return false
@@ -145,12 +144,8 @@ data class GameStarted(
  ): GameStarted =
    CardIsPlayedEvent(aggregateId, card, playerId, chosenColor, version + 1)
      .checkPlayerTurn()
-      .checkState({
-        (card is Card.CardWithColor && chosenColor == null) || card is Card.CardWith4Color
-      }, { TheCardIsAColorCardException(playerId) })
-      .checkState({
-        (card is Card.CardWith4Color && chosenColor != null) || card is Card.CardWithColor
-      }, { TheCardHasNoColorException(playerId) })
+      .checkState({ card is Card.CardWithColor && chosenColor != null }, { TheCardIsAColorCardException(playerId) })
+      .checkState({ card is Card.CardWith4Color && chosenColor == null }, { TheCardHasNoColorException(playerId) })
      .run(::applyEvent)

  internal fun applyEvent(event: CardIsPlayedEvent): GameStarted =
@@ -172,7 +167,6 @@ data class GameStarted(
        discardPile = discardPile.withNewCard(card = event.card),
        currentColor = color,
        lastPlayerId = event.playerId,
-        nextPlayerId = players.nextPlayerTurn(event.playerId, nextDirectionAfterPlay),
        playedTurnHistory = playedTurnHistory - History(event.playerId, event, direction),
        direction = nextDirectionAfterPlay,
        version = event.version,
@@ -208,8 +202,6 @@ data class GameStarted(
    copy(
      players = players.withNewCardOnPlayerHand(event.playerId, event.takenCards),
      drawPile = drawPile.take(event.takenCards.size).first,
-      lastPlayerId = event.playerId,
-      nextPlayerId = players.nextPlayerTurn(event.playerId, direction),
      version = event.version,
      recordedEvents = recordedEvents + event,
    )
@@ -16,7 +16,7 @@ fun Route.gameWebSocket(channelSubscriber: GameChannelsSubscriber) {
  authenticate {
    webSocket("/games/{id}") {
      channelSubscriber.subscribePlayerToGameChannels(
-        gameId = GameId(UUID.fromString(call.parameters["id"]!!)),
+        gameId = GameId(UUID.nameUUIDFromBytes(call.parameters["id"]?.encodeToByteArray()!!)),
        userId = call.currentUserId,
        incomingCommandChannel = toObjectChannel(incoming),
        sendNotificationChannel = fromFrameChannel(outgoing),
@@ -78,11 +78,7 @@ class BusInRabbitMQ<E>(
                body: ByteArray,
              ) {
                runBlocking {
-                  val obj = stringToObject(body.toString(Charsets.UTF_8))
-                  withLoggingContext("item" to obj.toString()) {
-                    logger.info { "Received delivery of $exchangeName" }
-                  }
-                  block(obj)
+                  block(stringToObject(body.toString(Charsets.UTF_8)))
                }
                channel.basicAck(envelope.deliveryTag, false)
              }
@@ -12,6 +12,11 @@ jwt {
    secret = ${?JWT_SECRET}
 }

+redis {
+    url = "redis://localhost:6379"
+    url = ${?REDIS_URL}
+}
+
 postgresql {
    url = "jdbc:postgresql://localhost:5432/event-demo"
    url = ${?POSTGRESQL_URL}
@@ -7,5 +7,7 @@ object Tag {

  object RabbitMQ : Tag()

+  object Redis : Tag()
+
  object Concurrence : Tag()
 }
@@ -6,18 +6,12 @@ import com.tngtech.archunit.library.Architectures.layeredArchitecture
 import org.junit.jupiter.api.Test

 /**
- * Vérifie le respect des frontières de l'architecture hexagonale (ports & adapters),
- * pour chaque bounded context sous `eventDemo.contexts`.
+ * Vérifie le respect des frontières de l'architecture hexagonale (ports & adapters).
 *
- * Les contexts ne sont pas listés en dur : ils sont déduits des classes réellement
- * présentes sous `eventDemo.contexts.*`, de sorte que l'ajout d'un nouveau context
- * (nouveau dossier `eventDemo.contexts.<xxx>`) soit automatiquement couvert par ce test,
- * sans modification de ce fichier.
- *
- * Convention attendue, pour un contexte donné :
- *   eventDemo.contexts.<context>.domain
- *   eventDemo.contexts.<context>.application
- *   eventDemo.contexts.<context>.infrastructure
+ * Convention attendue :
+ *   eventDemo.contexts.uno.domain
+ *   eventDemo.contexts.uno.application
+ *   eventDemo.contexts.uno.infrastructure
 *
 * Règles imposées :
 *   – domain         → ne dépend d'aucune autre couche (ni application, ni infrastructure)
@@ -25,42 +19,24 @@ import org.junit.jupiter.api.Test
 *   – infrastructure → ne dépend que de domain et application
 */
 class HexagonalArchitectureTest {
-  private val rootPackage = "eventDemo.contexts"
+  private val basePackage = "eventDemo.contexts.uno"

  private val classes =
    ClassFileImporter()
      .withImportOption(ImportOption.Predefined.DO_NOT_INCLUDE_TESTS)
-      .importPackages(rootPackage)
-
-  // Premier segment de package après "eventDemo.contexts." (ex. "auth", "game", ...),
-  // recalculé à chaque exécution à partir des classes importées.
-  private val contexts: Set<String> =
-    classes
-      .map { it.packageName }
-      .filter { it.startsWith("$rootPackage.") }
-      .map { it.removePrefix("$rootPackage.").substringBefore('.') }
-      .toSet()
+      .importPackages(basePackage)

  @Test
  fun `respecte les couches de l'architecture hexagonale`() {
-    check(contexts.isNotEmpty()) {
-      "Aucun context trouvé sous `$rootPackage` : le test ne vérifie rien, " +
-        "vérifiez que le package racine est correct."
-    }
-
-    contexts.forEach { context ->
-      val basePackage = "$rootPackage.$context"
-
-      @Suppress("ktlint:standard:chain-method-continuation")
-      layeredArchitecture()
-        .consideringAllDependencies()
-        .layer("Domain").definedBy("$basePackage.domain..")
-        .layer("Application").definedBy("$basePackage.application..")
-        .layer("Infrastructure").definedBy("$basePackage.infrastructure..")
-        .whereLayer("Domain").mayNotAccessAnyLayer()
-        .whereLayer("Application").mayOnlyAccessLayers("Domain")
-        .whereLayer("Infrastructure").mayOnlyAccessLayers("Domain", "Application")
-        .check(classes)
-    }
+    @Suppress("ktlint:standard:chain-method-continuation")
+    layeredArchitecture()
+      .consideringAllDependencies()
+      .layer("Domain").definedBy("$basePackage.domain..")
+      .layer("Application").definedBy("$basePackage.application..")
+      .layer("Infrastructure").definedBy("$basePackage.infrastructure..")
+      .whereLayer("Domain").mayNotAccessAnyLayer()
+      .whereLayer("Application").mayOnlyAccessLayers("Domain")
+      .whereLayer("Infrastructure").mayOnlyAccessLayers("Domain", "Application")
+      .check(classes)
  }
 }
@@ -1,8 +1,6 @@
 package eventDemo.contexts.game.application

 import eventDemo.Tag
-import eventDemo.contexts.auth.application.eventStores.UserRepository
-import eventDemo.contexts.auth.domain.User
 import eventDemo.contexts.game.application.channels.GameChannelsSubscriber
 import eventDemo.contexts.game.application.command.models.GameCommand
 import eventDemo.contexts.game.application.eventStores.GameRepository
@@ -13,11 +11,11 @@ import eventDemo.contexts.game.application.notification.models.PlayerAsPlayACard
 import eventDemo.contexts.game.application.notification.models.PlayerWasReadyNotification
 import eventDemo.contexts.game.application.notification.models.TheGameWasStartedNotification
 import eventDemo.contexts.game.application.notification.models.WelcomeToTheGameNotification
+import eventDemo.contexts.game.domain.events.disableShuffleDeck
 import eventDemo.contexts.game.domain.game.Card
 import eventDemo.contexts.game.domain.game.GameId
 import eventDemo.contexts.game.domain.game.gameState.Game
 import eventDemo.contexts.game.domain.game.gameState.GameStarted
-import eventDemo.contexts.game.domain.game.gameState.disableRandomForTest
 import eventDemo.testHelpers.CreateGameWithCommandsInChannelsHelpers.createGameWithCommandsInChannels
 import eventDemo.testHelpers.CreateGameWithCommandsInChannelsHelpers.joinTheGame
 import eventDemo.testHelpers.CreateGameWithCommandsInChannelsHelpers.playCard
@@ -26,14 +24,8 @@ import eventDemo.testHelpers.createNewUser
 import eventDemo.testHelpers.testKoinApplicationWithConfig
 import io.kotest.assertions.nondeterministic.eventually
 import io.kotest.assertions.nondeterministic.until
-import io.kotest.assertions.retry
 import io.kotest.core.spec.style.FunSpec
-import io.kotest.matchers.collections.shouldContainExactly
 import io.kotest.matchers.equals.shouldBeEqual
-import io.kotest.matchers.equals.shouldEqual
-import io.kotest.matchers.nulls.shouldNotBeNull
-import io.kotest.matchers.should
-import io.kotest.matchers.types.shouldBeInstanceOf
 import kotlinx.coroutines.DelicateCoroutinesApi
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.GlobalScope
@@ -51,236 +43,177 @@ class GameSimulationTest :
    tags(Tag.Postgresql)

    test("Simulation of a game") {
-      should {
-        retry(maxRetry = 3, timeout = 20.seconds) {
-          disableRandomForTest()
-          val gameId = GameId()
-          val user1 = createNewUser("user1")
-          val user2 = createNewUser("user2")
+      withTimeout(10.seconds) {
+        disableShuffleDeck()
+        val gameId = GameId()
+        val user1 = createNewUser("user1")
+        val user2 = createNewUser("user2")

-          val channelCommand1 = Channel<GameCommand>(Channel.BUFFERED)
-          val channelCommand2 = Channel<GameCommand>(Channel.BUFFERED)
-          val channelNotification1 = Channel<Notification>(Channel.BUFFERED)
-          val channelNotification2 = Channel<Notification>(Channel.BUFFERED)
+        val channelCommand1 = Channel<GameCommand>(Channel.BUFFERED)
+        val channelCommand2 = Channel<GameCommand>(Channel.BUFFERED)
+        val channelNotification1 = Channel<Notification>(Channel.BUFFERED)
+        val channelNotification2 = Channel<Notification>(Channel.BUFFERED)

-          var playedCard1: Card? = null
-          var playedCard2: Card? = null
+        var playedCard1: Card? = null
+        var playedCard2: Card? = null

-          var player1HasJoin = false
+        var player1HasJoin = false

-          testKoinApplicationWithConfig {
-            val gameRepository = get<GameRepository>()
-            val userRepository = get<UserRepository>()
-            userRepository.run {
-              save(user1)
-              save(user2)
-            }
+        testKoinApplicationWithConfig {
+          val gameRepository = get<GameRepository>()

-            gameRepository.create(gameId)
+          gameRepository.create(gameId)

-            // Run command/notification subscriber
-            // In the normal process, these subscriber is invoque on players connect to the websocket
-            GlobalScope.launch(Dispatchers.IO) {
-              get<GameChannelsSubscriber>().subscribePlayerToGameChannels(
-                gameId,
-                user1.id,
-                channelCommand1,
-                channelNotification1,
-              )
-            }
-            GlobalScope.launch(Dispatchers.IO) {
-              get<GameChannelsSubscriber>().subscribePlayerToGameChannels(
-                gameId,
-                user2.id,
-                channelCommand2,
-                channelNotification2,
-              )
-            }
-
-            // Consume etch notification of players, and put theses in a list.
-            // Is used later to control when other players can execute the next action
-            val player1Notifications = mutableListOf<Notification>()
-            val player2Notifications = mutableListOf<Notification>()
-            run {
-              GlobalScope.launch {
-                for (notification in channelNotification1) {
-                  player1Notifications.add(notification)
-                }
-              }
-
-              GlobalScope.launch {
-                for (notification in channelNotification2) {
-                  player2Notifications.add(notification)
-                }
-              }
-            }
-
-            // Player 1 actions
-            val player1Job =
-              launch {
-                createGameWithCommandsInChannels(channelCommand1, gameId, user1) {
-
-                  joinTheGame()
-                  player1Notifications.waitNotification<WelcomeToTheGameNotification> {
-                    players.map { it.userId }.contains(user1.id)
-                  }
-
-                  player1HasJoin = true
-
-                  player1Notifications.waitNotification<PlayerAsJoinTheGameNotification> {
-                    player.userId == user2.id
-                  }
-
-                  readyToPlay()
-                  player1Notifications.waitNotification<PlayerWasReadyNotification> {
-                    playerId == getPlayer(user2).id
-                  }
-
-                  playedCard1 =
-                    player1Notifications
-                      .waitNotification<TheGameWasStartedNotification> { hand.size == 7 }
-                      .hand
-                      .first()
-                      .apply {
-                        this.shouldBeInstanceOf<Card.NumericCard>()
-                        number shouldEqual 1
-                        color shouldEqual Card.Color.Red
-                      }
-
-                  player1Notifications.waitNotification<ItsTheTurnOfNotification> {
-                    if (player.userId == user2.id) error("WRONG PLAYER TURN")
-                    player.userId == user1.id
-                  }
-
-                  game
-                    .shouldBeInstanceOf<GameStarted>()
-                    .discardPile
-                    .topCard
-                    .shouldNotBeNull()
-                    .shouldBeInstanceOf<Card.NumericCard> {
-                      it.number shouldEqual 0
-                      it.color shouldEqual Card.Color.Red
-                    }
-
-                  playCard(playedCard1!!)
-
-                  player1Notifications.waitNotification<ItsTheTurnOfNotification> {
-                    player == getPlayer(user2)
-                  }
-
-                  player1Notifications.waitNotification<PlayerAsPlayACardNotification> {
-                    playerId == getPlayer(user2).id && card == playedCard2
-                  }
-
-                  playedCard1 =
-                    assertInstanceOf<GameStarted>(game)
-                      .playableCards(currentPlayer.id)
-                      .first()
-
-                  playedCard1.run {
-                    this.shouldBeInstanceOf<Card.NumericCard>()
-                    number shouldEqual 2
-                    color shouldEqual Card.Color.Red
-                  }
-
-                  playCard(playedCard1)
-
-                  player1Notifications.waitNotification<ItsTheTurnOfNotification> {
-                    player == getPlayer(user2)
-                  }
-                }
-              }
-
-            // Player 2 actions
-            val player2Job =
-              launch {
-                createGameWithCommandsInChannels(channelCommand2, gameId, user2) {
-                  // wait player 1 has joined the game
-                  until(3.seconds) { player1HasJoin }
-
-                  joinTheGame()
-
-                  player2Notifications.waitNotification<WelcomeToTheGameNotification> {
-                    players.map { it.userId }.contains(user1.id) &&
-                      players.map { it.userId }.contains(user2.id)
-                  }
-                  player2Notifications.waitNotification<PlayerWasReadyNotification> { playerId == getPlayer(user1).id }
-
-                  readyToPlay()
-
-                  playedCard2 =
-                    player2Notifications
-                      .waitNotification<TheGameWasStartedNotification> { hand.size == 7 }
-                      .hand
-                      .first()
-                      .apply {
-                        this.shouldBeInstanceOf<Card.NumericCard>()
-                        number shouldEqual 8
-                        color shouldEqual Card.Color.Red
-                      }
-
-                  player2Notifications.waitNotification<ItsTheTurnOfNotification> {
-                    if (player.userId == user2.id) error("WRONG PLAYER TURN")
-                    player.userId == user1.id
-                  }
-                  player2Notifications.waitNotification<PlayerAsPlayACardNotification> {
-                    playerId == getPlayer(user1).id && card == playedCard1
-                  }
-
-                  player2Notifications.waitNotification<ItsTheTurnOfNotification> {
-                    player == currentPlayer
-                  }
-
-                  game
-                    .shouldBeInstanceOf<GameStarted>()
-                    .discardPile
-                    .topCard
-                    .shouldNotBeNull()
-                    .shouldBeInstanceOf<Card.NumericCard> {
-                      it.number shouldEqual 1
-                      it.color shouldEqual Card.Color.Red
-                    }
-
-                  playCard(playedCard2)
-
-                  player2Notifications.waitNotification<ItsTheTurnOfNotification> {
-                    player.userId == user1.id
-                  }
-                  player2Notifications.waitNotification<PlayerAsPlayACardNotification> {
-                    playerId == currentPlayer.id && card == playedCard2
-                  }
-                }
-              }
-
-            // Wait the end of the game
-            joinAll(player1Job, player2Job)
-
-            // Build the last state from the event store
-            val game = gameRepository.get(gameId)
-            assertInstanceOf<GameStarted>(game)
-
-            // Check if the state is correct
-            game.aggregateId shouldBeEqual gameId
-            game.players.map { it.userId } shouldContainExactly setOf(user1.id, user2.id)
-            assertNotNull(game.players.find { it.userId == user1.id })
-              .hand.size shouldBeEqual 5
-            assertNotNull(game.players.find { it.userId == user2.id })
-              .hand.size shouldBeEqual 6
-            game.direction shouldBeEqual Game.Direction.CLOCKWISE
-            assertNotNull(game.lastPlayer?.userId) shouldBeEqual user1.id
-            assertNotNull(game.discardPile.topCard) shouldBeEqual assertNotNull(playedCard1)
+          // Run command/notification subscriber
+          // In the normal process, these subscriber is invoque on players connect to the websocket
+          GlobalScope.launch(Dispatchers.IO) {
+            get<GameChannelsSubscriber>().subscribePlayerToGameChannels(
+              gameId,
+              user1.id,
+              channelCommand1,
+              channelNotification1,
+            )
          }
+          GlobalScope.launch(Dispatchers.IO) {
+            get<GameChannelsSubscriber>().subscribePlayerToGameChannels(
+              gameId,
+              user2.id,
+              channelCommand2,
+              channelNotification2,
+            )
+          }
+
+          // Consume etch notification of players, and put theses in a list.
+          // Is used later to control when other players can execute the next action
+          val player1Notifications = mutableListOf<Notification>()
+          val player2Notifications = mutableListOf<Notification>()
+          run {
+            GlobalScope.launch {
+              for (notification in channelNotification1) {
+                player1Notifications.add(notification)
+              }
+            }
+
+            GlobalScope.launch {
+              for (notification in channelNotification2) {
+                player2Notifications.add(notification)
+              }
+            }
+          }
+
+          // Player 1 actions
+          val player1Job =
+            launch {
+              createGameWithCommandsInChannels(channelCommand1) { getPlayer ->
+                user1.joinTheGame()
+                player1Notifications.waitNotification<WelcomeToTheGameNotification> {
+                  players.map { it.userId }.contains(user1.id)
+                }
+
+                player1HasJoin = true
+
+                player1Notifications.waitNotification<PlayerAsJoinTheGameNotification> {
+                  player.userId == user2.id
+                }
+
+                getPlayer(user1).readyToPlay()
+                player1Notifications.waitNotification<PlayerWasReadyNotification> {
+                  playerId == getPlayer(user2).id
+                }
+
+                val player1Hand =
+                  player1Notifications.waitNotification<TheGameWasStartedNotification> { hand.size == 7 }.hand
+
+                playedCard1 = player1Hand.first()
+                player1Notifications.waitNotification<ItsTheTurnOfNotification> {
+                  player.userId == user1.id
+                }
+
+                getPlayer(user1).playCard(playedCard1!!, null)
+
+                player1Notifications.waitNotification<ItsTheTurnOfNotification> {
+                  player == getPlayer(user2)
+                }
+
+                player1Notifications.waitNotification<PlayerAsPlayACardNotification> {
+                  playerId == getPlayer(user2).id && card == playedCard2
+                }
+
+                playedCard1 = player1Hand.elementAt(1)
+                getPlayer(user1).playCard(playedCard1)
+
+                player1Notifications.waitNotification<ItsTheTurnOfNotification> {
+                  player == getPlayer(user2)
+                }
+              }
+            }
+
+          // Player 2 actions
+          val player2Job =
+            launch {
+              createGameWithCommandsInChannels(channelCommand2) { getPlayer ->
+                // wait player 1 has joined the game
+                until(3.seconds) { player1HasJoin }
+
+                user2.joinTheGame()
+
+                player2Notifications.waitNotification<WelcomeToTheGameNotification> {
+                  players.map { it.userId }.contains(user1.id) &&
+                    players.map { it.userId }.contains(user2.id)
+                }
+                player2Notifications.waitNotification<PlayerWasReadyNotification> { playerId == getPlayer(user1).id }
+
+                getPlayer(user2).readyToPlay()
+
+                val player2Hand =
+                  player2Notifications.waitNotification<TheGameWasStartedNotification> { hand.size == 7 }.hand
+
+                player2Notifications.waitNotification<ItsTheTurnOfNotification> {
+                  player.userId == user1.id
+                }
+                player2Notifications.waitNotification<PlayerAsPlayACardNotification> {
+                  playerId == getPlayer(user1).id && card == playedCard1
+                }
+                playedCard2 = player2Hand.first()
+
+                player2Notifications.waitNotification<ItsTheTurnOfNotification> {
+                  player == getPlayer(user2)
+                }
+
+                getPlayer(user2).playCard(playedCard2)
+
+                player2Notifications.waitNotification<ItsTheTurnOfNotification> {
+                  player.userId == user1.id
+                }
+                player2Notifications.waitNotification<PlayerAsPlayACardNotification> {
+                  playerId == getPlayer(user2).id && card == playedCard2
+                }
+              }
+            }
+
+          // Wait the end of the game
+          joinAll(player1Job, player2Job)
+
+          // Build the last state from the event store
+          val game = gameRepository.get(gameId)
+          assertInstanceOf<GameStarted>(game)
+
+          // Check if the state is correct
+          game.aggregateId shouldBeEqual gameId
+          game.players.map { it.id } shouldBeEqual setOf(user1.id, user2.id)
+          assertNotNull(game.players.find { it.userId == user1.id })
+            .hand.size shouldBeEqual 5
+          assertNotNull(game.players.find { it.userId == user2.id })
+            .hand.size shouldBeEqual 6
+          game.direction shouldBeEqual Game.Direction.CLOCKWISE
+          assertNotNull(game.lastPlayed.userId) shouldBeEqual user1
+          assertNotNull(game.discardPile.topCard) shouldBeEqual assertNotNull(playedCard1)
        }
      }
    }
  })

-context(user: User)
-private suspend inline fun <reified T : Notification> MutableList<Notification>.waitNotification(crossinline block: T.() -> Boolean): T {
-  println("NOTIFICATION WAITING: ${T::class.simpleName} for user: ${user.username}")
-  return eventually(5.seconds) {
-    filterIsInstance<T>()
-      .first { block(it) }
-      .also { remove(it) }
-  }.also { println("NOTIFICATION RECEIVED: ${T::class.simpleName} for user: ${user.username}") }
-}
+private suspend inline fun <reified T : Notification> MutableList<Notification>.waitNotification(crossinline block: T.() -> Boolean): T =
+  eventually(3.seconds) {
+    filterIsInstance<T>().first { block(it) }
+  }
@@ -1,7 +1,6 @@
 package eventDemo.contexts.game.application.notification

 import eventDemo.contexts.auth.application.eventStores.UserEventStoreRepository
-import eventDemo.contexts.auth.application.eventStores.UserRepository
 import eventDemo.contexts.auth.infrastructure.persistence.eventStore.UserEventStoreInMemory
 import eventDemo.contexts.game.application.command.handlers.GameCommandHandlerDispatcher
 import eventDemo.contexts.game.application.command.handlers.JoinTheGameHandler
@@ -15,8 +14,6 @@ import eventDemo.contexts.game.application.notification.models.WelcomeToTheGameN
 import eventDemo.contexts.game.infrastructure.persistence.eventBus.GameEventBusInMemory
 import eventDemo.contexts.game.infrastructure.persistence.eventStore.GameEventStoreInMemory
 import eventDemo.sharedKernel.UserId
-import eventDemo.testHelpers.createNewUser
-import io.kotest.assertions.nondeterministic.eventually
 import io.kotest.core.spec.style.FunSpec
 import io.kotest.matchers.collections.shouldContain
 import io.kotest.matchers.equals.shouldEqual
@@ -24,7 +21,6 @@ import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.launch
 import org.junit.jupiter.api.assertInstanceOf
-import kotlin.time.Duration.Companion.seconds

 class EventToNotificationSubscriberTest :
  FunSpec({
@@ -50,12 +46,8 @@ class EventToNotificationSubscriberTest :

      val game = gameRepository.create()

-      val user1 = createNewUser("user1")
-      val user2 = createNewUser("user2")
-      userRepository.run {
-        save(user1)
-        save(user2)
-      }
+      val user1 = UserId()
+      val user2 = UserId()

      val player1Notifications = mutableListOf<Notification>()
      GlobalScope.launch {
@@ -64,22 +56,20 @@ class EventToNotificationSubscriberTest :
        }
      }

-      commentDispatcher.dispatch(JoinTheGameCommand(user1.id, JoinTheGameCommand.Payload(game.aggregateId)))
+      commentDispatcher.dispatch(JoinTheGameCommand(user1, JoinTheGameCommand.Payload(game.aggregateId)))
      subscriber
        .subscribeToEventsAndSendNotification(
          game.aggregateId,
-          user2.id,
+          user1,
          notificationChannel,
        ).use {
-          commentDispatcher.dispatch(JoinTheGameCommand(user2.id, JoinTheGameCommand.Payload(game.aggregateId)))
+          commentDispatcher.dispatch(JoinTheGameCommand(user2, JoinTheGameCommand.Payload(game.aggregateId)))
        }

-      eventually(duration = 1.seconds) {
-        player1Notifications.size shouldEqual 1
-      }
+      player1Notifications.size shouldEqual 2
      player1Notifications.first().let { notification ->
        assertInstanceOf<WelcomeToTheGameNotification>(notification)
-        notification.players.map { it.userId } shouldContain user2.id
+        notification.players.map { it.userId } shouldContain user1
      }
    }
  })
@@ -1,301 +0,0 @@
-package eventDemo.contexts.game.application.notification
-
-import eventDemo.contexts.game.application.notification.models.ItsTheTurnOfNotification
-import eventDemo.contexts.game.application.notification.models.PilesShuffledNotification
-import eventDemo.contexts.game.application.notification.models.PlayerAsPlayACardNotification
-import eventDemo.contexts.game.application.notification.models.PlayerHavePassNotification
-import eventDemo.contexts.game.application.notification.models.PlayerWasReadyNotification
-import eventDemo.contexts.game.application.notification.models.TheGameWasStartedNotification
-import eventDemo.contexts.game.application.notification.models.WelcomeToTheGameNotification
-import eventDemo.contexts.game.application.notification.models.YourNewCardNotification
-import eventDemo.contexts.game.domain.events.CardIsPlayedEvent
-import eventDemo.contexts.game.domain.events.DrawFilledWithDiscardEvent
-import eventDemo.contexts.game.domain.events.GameStartedEvent
-import eventDemo.contexts.game.domain.events.NewPlayerEvent
-import eventDemo.contexts.game.domain.events.PlayerHaveDrawCardEvent
-import eventDemo.contexts.game.domain.events.PlayerReadyEvent
-import eventDemo.contexts.game.domain.game.Card
-import eventDemo.contexts.game.domain.game.DiscardPile
-import eventDemo.contexts.game.domain.game.DrawPile
-import eventDemo.contexts.game.domain.game.GameId
-import eventDemo.contexts.game.domain.game.Player
-import eventDemo.contexts.game.domain.game.PlayerHand
-import eventDemo.contexts.game.domain.game.PlayerList
-import eventDemo.contexts.game.domain.game.gameState.GameCreated
-import eventDemo.contexts.game.domain.game.gameState.GameStarted
-import eventDemo.sharedKernel.UserId
-import io.kotest.core.spec.style.FunSpec
-import io.kotest.matchers.shouldBe
-import org.junit.jupiter.api.assertInstanceOf
-
-class ToNotificationTest :
-  FunSpec({
-    val player1 =
-      Player(
-        name = "Bob",
-        userId = UserId(),
-        hand = PlayerHand(setOf(Card.NumericCard(1, Card.Color.Red))),
-        id = Player.PlayerId(),
-      )
-    val player2 =
-      Player(
-        name = "John",
-        userId = UserId(),
-        hand = PlayerHand(setOf(Card.NumericCard(1, Card.Color.Red))),
-        id = Player.PlayerId(),
-      )
-
-    test("NewPlayerEvent") {
-      val game =
-        GameCreated(
-          aggregateId = GameId(),
-          version = 1,
-          players = PlayerList(setOf(player1)),
-          recordedEvents = setOf(),
-        )
-      NewPlayerEvent(
-        game.aggregateId,
-        version = 2,
-        player = player1,
-      ).toNotification(
-        game = game,
-        currentUserId = player1.userId,
-      ).let {
-        it.toList().size shouldBe 1
-        // Check if the user is
-        assertInstanceOf<WelcomeToTheGameNotification>(it.first()).run {
-          players.size shouldBe 1
-          players.first().name shouldBe "Bob"
-        }
-      }
-    }
-
-    test("PlayerReadyEvent") {
-      val game =
-        GameCreated(
-          aggregateId = GameId(),
-          version = 1,
-          players = PlayerList(setOf(player1)),
-          recordedEvents = setOf(),
-        )
-      PlayerReadyEvent(
-        game.aggregateId,
-        version = 2,
-        playerId = player1.id,
-      ).toNotification(
-        game = game,
-        currentUserId = player1.userId,
-      ).let {
-        it.toList().size shouldBe 1
-        assertInstanceOf<PlayerWasReadyNotification>(it.first()).let {
-          it.playerId shouldBe player1.id
-        }
-      }
-    }
-
-    test("PlayerHaveDrawCardEvent on current player") {
-      val game =
-        GameStarted(
-          aggregateId = GameId(),
-          players = PlayerList(setOf(player1, player2)),
-          drawPile = DrawPile(),
-          discardPile = DiscardPile(),
-          lastPlayerId = player1.id,
-          nextPlayerId = player2.id,
-          currentColor = Card.Color.Red,
-          version = 1,
-          recordedEvents = setOf(),
-        )
-      val card = Card.NumericCard(1, Card.Color.Blue)
-      PlayerHaveDrawCardEvent(
-        game.aggregateId,
-        version = 2,
-        playerId = player1.id,
-        takenCards = setOf(card),
-      ).toNotification(
-        game = game,
-        currentUserId = player1.userId,
-      ).let {
-        it.toList().size shouldBe 2
-        it.toList().let { notifications ->
-          assertInstanceOf<YourNewCardNotification>(notifications.first()).let {
-            it.cards.first() shouldBe card
-          }
-          assertInstanceOf<ItsTheTurnOfNotification>(notifications[1]).let {
-            it.player.id shouldBe player2.id
-          }
-        }
-      }
-    }
-    test("PlayerHaveDrawCardEvent on other player") {
-      val game =
-        GameStarted(
-          aggregateId = GameId(),
-          players = PlayerList(setOf(player1, player2)),
-          drawPile = DrawPile(),
-          discardPile = DiscardPile(),
-          lastPlayerId = player1.id,
-          nextPlayerId = player2.id,
-          currentColor = Card.Color.Red,
-          version = 1,
-          recordedEvents = setOf(),
-        )
-      val card = Card.NumericCard(1, Card.Color.Blue)
-      PlayerHaveDrawCardEvent(
-        game.aggregateId,
-        version = 2,
-        playerId = player1.id,
-        takenCards = setOf(card),
-      ).toNotification(
-        game = game,
-        currentUserId = player2.userId,
-      ).let {
-        it.toList().size shouldBe 2
-        it.toList().let { notifications ->
-          assertInstanceOf<PlayerHavePassNotification>(notifications.first()).let {
-            it.playerId shouldBe player1.id
-          }
-          assertInstanceOf<ItsTheTurnOfNotification>(notifications[1]).let {
-            it.player.id shouldBe player2.id
-          }
-        }
-      }
-    }
-
-    test("CardIsPlayedEvent on current player") {
-      val game =
-        GameStarted(
-          aggregateId = GameId(),
-          players = PlayerList(setOf(player1, player2)),
-          drawPile = DrawPile(),
-          discardPile = DiscardPile(),
-          lastPlayerId = player2.id,
-          nextPlayerId = player1.id,
-          currentColor = Card.Color.Red,
-          version = 1,
-          recordedEvents = setOf(),
-        )
-      val card = Card.NumericCard(1, Card.Color.Blue)
-      CardIsPlayedEvent(
-        game.aggregateId,
-        version = 2,
-        playerId = player1.id,
-        card = card,
-      ).toNotification(
-        game = game,
-        currentUserId = player1.userId,
-      ).toList()
-        .let { notifications ->
-          notifications.size shouldBe 2
-          assertInstanceOf<PlayerAsPlayACardNotification>(notifications.first()).let {
-            it.playerId shouldBe player1.id
-            it.card shouldBe card
-          }
-          assertInstanceOf<ItsTheTurnOfNotification>(notifications[1]).let {
-            it.player.id shouldBe player1.id
-          }
-        }
-    }
-    test("CardIsPlayedEvent on other player") {
-      val game =
-        GameStarted(
-          aggregateId = GameId(),
-          players = PlayerList(setOf(player1, player2)),
-          drawPile = DrawPile(),
-          discardPile = DiscardPile(),
-          lastPlayerId = player1.id,
-          nextPlayerId = player2.id,
-          currentColor = Card.Color.Red,
-          version = 1,
-          recordedEvents = setOf(),
-        )
-      val card = Card.NumericCard(1, Card.Color.Blue)
-      CardIsPlayedEvent(
-        game.aggregateId,
-        version = 2,
-        playerId = player2.id,
-        card = card,
-      ).toNotification(
-        game = game,
-        currentUserId = player1.userId,
-      ).let {
-        it.toList().size shouldBe 2
-        it.toList().let { notifications ->
-          assertInstanceOf<PlayerAsPlayACardNotification>(notifications.first()).let {
-            it.playerId shouldBe player2.id
-            it.card shouldBe card
-          }
-          assertInstanceOf<ItsTheTurnOfNotification>(notifications[1]).let {
-            it.player.id shouldBe player2.id
-          }
-        }
-      }
-    }
-
-    test("DrawFilledWithDiscardEvent") {
-      val game =
-        GameStarted(
-          aggregateId = GameId(),
-          players = PlayerList(setOf(player1, player2)),
-          drawPile = DrawPile(),
-          discardPile = DiscardPile(),
-          lastPlayerId = player1.id,
-          nextPlayerId = player2.id,
-          currentColor = Card.Color.Red,
-          version = 1,
-          recordedEvents = setOf(),
-        )
-      DrawFilledWithDiscardEvent(
-        game.aggregateId,
-        version = 2,
-        newDrawPile = DrawPile(),
-        newDiscardPile = DiscardPile(),
-      ).toNotification(
-        game = game,
-        currentUserId = player1.userId,
-      ).let {
-        it.toList().size shouldBe 1
-        assertInstanceOf<PilesShuffledNotification>(it.first())
-      }
-    }
-
-    test("GameStartedEvent") {
-      val game =
-        GameStarted(
-          aggregateId = GameId(),
-          players = PlayerList(setOf(player1, player2)),
-          drawPile = DrawPile(),
-          discardPile = DiscardPile(),
-          lastPlayerId = player1.id,
-          nextPlayerId = player2.id,
-          currentColor = Card.Color.Red,
-          version = 1,
-          recordedEvents = setOf(),
-        )
-      GameStartedEvent(
-        game.aggregateId,
-        version = 2,
-        firstPlayer = player1.id,
-        playersHans =
-          mapOf(
-            player1.id to player1.hand,
-            player2.id to player2.hand,
-          ),
-        drawPile = DrawPile(),
-        discardPile = DiscardPile(),
-      ).toNotification(
-        game = game,
-        currentUserId = player1.userId,
-      ).toList()
-        .let { notifications ->
-          notifications.size shouldBe 2
-          assertInstanceOf<TheGameWasStartedNotification>(notifications.first()).let {
-            it.hand.size shouldBe 1
-            it.hand.first() shouldBe player1.hand.cards.first()
-          }
-          assertInstanceOf<ItsTheTurnOfNotification>(notifications[1]).let {
-            it.player.id shouldBe player2.id
-          }
-        }
-    }
-  })
@@ -11,7 +11,6 @@ import eventDemo.contexts.game.domain.game.GameId
 import eventDemo.contexts.game.domain.game.Player
 import eventDemo.contexts.game.domain.game.PlayerHand
 import eventDemo.contexts.game.domain.game.PlayerList
-import eventDemo.contexts.game.domain.game.gameState.Game.Direction
 import eventDemo.sharedKernel.UserId
 import eventDemo.testHelpers.act
 import eventDemo.testHelpers.assert
@@ -196,12 +195,10 @@ class GameStartedTest :
        val card3 = Card.NumericCard(3, Card.Color.Red)
        assert {
          val player1 = Player("Player 1", UserId())
-          val player2 = Player("Player 2", UserId())
          GameStarted(
            aggregateId = GameId(),
            players = PlayerList(setOf(player1)),
            lastPlayerId = player1.id,
-            nextPlayerId = player2.id,
            drawPile = DrawPile(),
            discardPile =
              DiscardPile(
@@ -247,14 +244,17 @@ class GameStartedTest :
        val card3 = Card.NumericCard(3, Card.Color.Red)
        val card4 = Card.NumericCard(4, Card.Color.Red)

-        val player1 = Player("Jo", UserId())
-        val player2 = Player("Bob", UserId())
+        val player1 =
+          Player(
+            "Jo",
+            UserId(),
+            hand = PlayerHand(cards = setOf()),
+          )
        assert {
          GameStarted(
            aggregateId = GameId(),
            players = PlayerList(setOf(player1)),
            lastPlayerId = player1.id,
-            nextPlayerId = player2.id,
            drawPile =
              DrawPile(
                setOf(
@@ -303,7 +303,6 @@ class GameStartedTest :
            aggregateId = GameId(),
            players = PlayerList(setOf(player1, player2)),
            lastPlayerId = player1.id,
-            nextPlayerId = player2.id,
            drawPile = DrawPile(),
            discardPile = DiscardPile(),
            currentColor = Card.Color.Yellow,
@@ -374,12 +373,10 @@ private fun gameWithCard(
  val player1 = Player("Tesla", UserId(), hand = played1Hand)
  val player2 = Player("Einstein", UserId(), hand = played2Hand)
  val player3 = Player("Curie", UserId(), hand = PlayerHand(setOf(Card.NumericCard(8, Card.Color.Yellow))))
-  val players = PlayerList(setOf(player1, player2, player3))
  return GameStarted(
    aggregateId = GameId(),
-    players = players,
+    players = PlayerList(setOf(player1, player2, player3)),
    lastPlayerId = player3.id,
-    nextPlayerId = players.nextPlayerTurn(player3.id, Direction.CLOCKWISE),
    discardPile = DiscardPile(setOf(onTheDiscardPile)),
    drawPile = DrawPile(),
    currentColor = (onTheDiscardPile as? Card.CardWithColor)?.color ?: chosenColor ?: error("no color"),
@@ -1,41 +0,0 @@
-package eventDemo.contexts.game.domain.game.gameState
-
-import eventDemo.contexts.game.domain.game.Card
-import io.kotest.assertions.retry
-import io.kotest.core.spec.style.FunSpec
-import io.kotest.matchers.collections.shouldHaveSize
-import io.kotest.matchers.should
-import io.kotest.matchers.shouldBe
-import io.kotest.matchers.shouldNotBe
-import kotlin.time.Duration.Companion.seconds
-
-class NewDeckTest :
-  FunSpec({
-
-    test("newDeck") {
-      newDeck().let {
-        it shouldNotBe null
-        it.filterIsInstance<Card.NumericCard>() shouldHaveSize 76
-        it.filterIsInstance<Card.Plus2Card>() shouldHaveSize 8
-        it.filterIsInstance<Card.ReverseCard>() shouldHaveSize 8
-        it.filterIsInstance<Card.PassCard>() shouldHaveSize 8
-        it.filterIsInstance<Card.Plus4Card>() shouldHaveSize 4
-        it.filterIsInstance<Card.ChangeColorCard>() shouldHaveSize 4
-        it shouldHaveSize 108
-      }
-    }
-
-    test("shuffleDeck") {
-      val deck = (0..9).map { Card.NumericCard(it, Card.Color.Red) }
-      deck.run {
-        this[3].number shouldBe 3
-      }
-      should {
-        retry(maxRetry = 4, timeout = 1.seconds) {
-          deck.shuffled().run {
-            this[3].number shouldNotBe 3
-          }
-        }
-      }
-    }
-  })
@@ -0,0 +1,21 @@
+package eventDemo.contexts.game.intrastructure.persistence.connectors
+
+import eventDemo.Tag
+import eventDemo.testHelpers.testKoinApplicationWithConfig
+import io.kotest.core.spec.style.FunSpec
+import io.kotest.matchers.equals.shouldBeEqual
+import redis.clients.jedis.UnifiedJedis
+
+class RedisTest :
+  FunSpec({
+    tags(Tag.Redis)
+
+    test("test connection with jedis") {
+      testKoinApplicationWithConfig {
+        get<UnifiedJedis>().also {
+          it.set("test", "test")
+          it.get("test") shouldBeEqual "test"
+        }
+      }
+    }
+  })
@@ -117,8 +117,8 @@ class GameListRouteTest :
              call.body<List<GameList>>().first().let {
                it.status shouldBeEqual GameList.Status.IS_STARTED
                it.players shouldHaveSize 2
-                it.players.map { it.userId } shouldContain user1.id
-                it.players.map { it.userId } shouldContain user2.id
+                it.players.map { it.userId } shouldContain user1
+                it.players.map { it.userId } shouldContain user2
                it.winners shouldHaveSize 0
              }
            }
@@ -2,7 +2,6 @@ package eventDemo.libs.bus

 import com.rabbitmq.client.ConnectionFactory
 import eventDemo.testHelpers.spyPing
-import eventDemo.testHelpers.testKoinApplicationWithConfig
 import io.kotest.core.spec.style.FunSpec
 import io.kotest.datatest.withData
 import io.kotest.matchers.string.shouldStartWith
@@ -16,28 +15,33 @@ private data class ObjTest(
 class BusTest :
  FunSpec({
    context("Pub/sub") {
-      testKoinApplicationWithConfig {
-        val list: Map<String, Bus<ObjTest>> =
-          mapOf(
-            BusInMemory::class.java.simpleName to BusInMemory(),
-            BusInRabbitMQ::class.java.simpleName to
-              BusInRabbitMQ(
-                get<ConnectionFactory>(),
-                "testExchange",
-                { it.value },
-                { ObjTest(it) },
-              ),
-          )
+      val factory =
+        ConnectionFactory().apply {
+          host = "localhost"
+          port = 5672
+          username = "event-demo"
+          password = "changeit"
+        }
+      val list: Map<String, Bus<ObjTest>> =
+        mapOf(
+          BusInMemory::class.java.simpleName to BusInMemory(),
+          BusInRabbitMQ::class.java.simpleName to
+            BusInRabbitMQ(
+              factory,
+              "testExchange",
+              { it.value },
+              { ObjTest(it) },
+            ),
+        )

-        withData(list) { bus ->
-          spyPing(exactly = 2, duration = 1.seconds) { ping ->
-            bus.subscribe { obj ->
-              ping()
-              obj.value shouldStartWith "testMessage"
-            }
-            bus.publish(ObjTest("testMessage${Random.nextInt()}"))
-            bus.publish(ObjTest("testMessage${Random.nextInt()}"))
+      withData(list) { bus ->
+        spyPing(exactly = 2, duration = 1.seconds) { ping ->
+          bus.subscribe { obj ->
+            ping()
+            obj.value shouldStartWith "testMessage"
          }
+          bus.publish(ObjTest("testMessage${Random.nextInt()}"))
+          bus.publish(ObjTest("testMessage${Random.nextInt()}"))
        }
      }
    }
@@ -33,17 +33,16 @@ class EventStreamTest :
        block(aggregateId)
      }

-    fun Koin.eventStreams(): Map<String, EventStream<EventXTest, IdTest>> =
-      mapOf(
-        EventStreamInMemory::class.simpleName.toString() to EventStreamInMemory(IdTest()),
-        EventStreamInPostgresql::class.simpleName.toString() to
-          EventStreamInPostgresql(
-            IdTest(),
-            dataSource = get(),
-            objectToString = { Json.encodeToString(it) },
-            stringToObject = { Json.decodeFromString(it) },
-            "game.game_event_stream",
-          ),
+    fun Koin.eventStreams(): List<EventStream<EventXTest, IdTest>> =
+      listOf(
+        EventStreamInMemory(IdTest()),
+        EventStreamInPostgresql(
+          IdTest(),
+          dataSource = get(),
+          objectToString = { Json.encodeToString(it) },
+          stringToObject = { Json.decodeFromString(it) },
+          "game.game_event_stream",
+        ),
      )

    context("readVersionBetween should only return the event of aggregate") {
@@ -9,70 +9,51 @@ import eventDemo.contexts.game.application.eventStores.GameRepository
 import eventDemo.contexts.game.domain.game.Card
 import eventDemo.contexts.game.domain.game.GameId
 import eventDemo.contexts.game.domain.game.Player
-import eventDemo.contexts.game.domain.game.gameState.Game
 import kotlinx.coroutines.channels.Channel
 import org.koin.core.Koin
+import java.util.UUID

 object CreateGameWithCommandsInChannelsHelpers {
-  class Data(
-    private val repo: GameRepository,
-    val gameId: GameId,
-    val currentUser: User,
-  ) {
-    fun getPlayer(user: User): Player =
-      game.players.get(user.id)
-
-    val currentPlayer: Player get() = getPlayer(currentUser)
-
-    val game: Game
-      get() = repo.get(gameId)!!
-  }
-
  context(koin: Koin)
  suspend fun <T> createGameWithCommandsInChannels(
    channelCommand: Channel<GameCommand>,
-    gameId: GameId,
-    user: User,
-    block:
-      suspend context(
-        CreateGameWithCommandsInChannelsHelpers,
-        Channel<GameCommand>,
-        User,
-      ) Data.() -> T,
+    gameName: String = "testGame${UUID.randomUUID()}",
+    block: suspend context(Channel<GameCommand>, GameId) ((User) -> Player) -> T,
  ): T {
+    val gameId = GameId(UUID.nameUUIDFromBytes(gameName.encodeToByteArray()))
    val repo = koin.get<GameRepository>()
    repo.getOrCreate(gameId)

-    return with(channelCommand) {
-      with(user) {
+    return with(gameId) {
+      with(channelCommand) {
        with(CreateGameWithCommandsInChannelsHelpers) {
-          Data(repo, gameId, user).block()
+          block { user -> repo.get(gameId)!!.players.get(user.id) }
        }
      }
    }
  }

-  context(channelCommand: Channel<GameCommand>, data: Data)
-  suspend fun joinTheGame(): JoinTheGameCommand =
+  context(channelCommand: Channel<GameCommand>, gameId: GameId)
+  suspend fun User.joinTheGame(): JoinTheGameCommand =
    JoinTheGameCommand(
-      data.currentUser.id,
-      JoinTheGameCommand.Payload(data.gameId),
+      id,
+      JoinTheGameCommand.Payload(gameId),
    ).also { channelCommand.send(it) }

-  context(channelCommand: Channel<GameCommand>, data: Data)
-  suspend fun readyToPlay(): ReadyToPlayCommand =
+  context(channelCommand: Channel<GameCommand>, gameId: GameId)
+  suspend fun Player.readyToPlay(): ReadyToPlayCommand =
    ReadyToPlayCommand(
-      data.currentUser.id,
-      ReadyToPlayCommand.Payload(data.gameId, data.currentPlayer.id),
+      userId,
+      ReadyToPlayCommand.Payload(gameId, id),
    ).also { channelCommand.send(it) }

-  context(channelCommand: Channel<GameCommand>, data: Data)
-  suspend fun playCard(
+  context(channelCommand: Channel<GameCommand>, gameId: GameId)
+  suspend fun Player.playCard(
    card: Card,
    chosenColor: Card.Color? = null,
  ): PlayCardCommand =
    PlayCardCommand(
-      data.currentUser.id,
-      PlayCardCommand.Payload(data.gameId, data.currentPlayer.id, card, chosenColor),
+      userId,
+      PlayCardCommand.Payload(gameId, id, card, chosenColor),
    ).also { channelCommand.send(it) }
 }
@@ -15,13 +15,10 @@ import org.koin.core.module.KoinApplicationDslMarker
 import org.koin.dsl.koinApplication
 import org.koin.ktor.ext.getKoin

-const val CONFIG_FILE_NAME = "application.conf"
-
@KoinApplicationDslMarker
 suspend fun <T> testKoinApplicationWithConfig(block: suspend Koin.() -> T): T =
-  koinApplication {
-    modules(appKoinModule(ApplicationConfig(CONFIG_FILE_NAME).configuration))
-  }.koin
+  koinApplication { modules(appKoinModule(ApplicationConfig("application.conf").configuration)) }
+    .koin
    .run {
      cleanDataTest()
      configureProjectionListener()
@@ -37,7 +34,7 @@ fun testApplicationWithConfig(
 ) {
  val logger = KotlinLogging.logger {}
  testApplication {
-    val conf = ApplicationConfig(CONFIG_FILE_NAME)
+    val conf = ApplicationConfig("application.conf")
    environment {
      config = conf
    }
@@ -1,6 +1,7 @@
 package eventDemo.testHelpers

 import org.koin.core.Koin
+import redis.clients.jedis.UnifiedJedis
 import javax.sql.DataSource

 fun DataSource.cleanEventSource() {
@@ -16,6 +17,11 @@ fun DataSource.cleanEventSource() {
  }
 }

+fun UnifiedJedis.cleanProjections() {
+  flushAll()
+}
+
 fun Koin.cleanDataTest() {
  get<DataSource>().cleanEventSource()
+  get<UnifiedJedis>().cleanProjections()
 }
Author	SHA1	Message	Date
flecomte	9c9d057f0a	refactoring: Masive refactor to build the V2 Tests / lint (push) Has been skipped Details Tests / test (push) Has been skipped Details Tests / build (push) Failing after 14m50s Details	2026-07-28 23:46:52 +02:00
flecomte	f3b848ea93	refactoring: Masive refactor to build the V2	2026-07-26 17:51:58 +02:00
				`@@ -0,0 +1 @@`
				<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" contentStyleType="text/css" height="668px" preserveAspectRatio="none" style="width:1329px;height:668px;" version="1.1" viewBox="0 0 1329 668" width="1329px" zoomAndPan="magnify"><defs/><g><!--class GameList--><g id="elem_GameList"><rect codeLine="5" fill="#F1F1F1" height="79.2031" id="GameList" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="110.8203" x="50.5" y="7"/><ellipse cx="72.7501" cy="29.291" fill="#ADD1B2" rx="11" ry="11" style="stroke:#181818;stroke-width:1.0;"/><path d="M75.5157,25.166 Q75.672,24.9473 75.8595,24.8379 Q76.047,24.7285 76.2657,24.7285 Q76.6407,24.7285 76.8751,24.9941 Q77.1095,25.2441 77.1095,25.8535 L77.1095,27.3066 Q77.1095,27.916 76.8751,28.1816 Q76.6407,28.4473 76.2657,28.4473 Q75.922,28.4473 75.7188,28.2441 Q75.5157,28.0566 75.4063,27.541 Q75.3595,27.1816 75.172,26.9941 Q74.8438,26.6191 74.2345,26.4004 Q73.6251,26.1816 73.0001,26.1816 Q72.2345,26.1816 71.5938,26.5098 Q70.9688,26.8379 70.4688,27.5879 Q69.9845,28.3379 69.9845,29.3691 L69.9845,30.4629 Q69.9845,31.6973 70.8751,32.5254 Q71.7657,33.3379 73.3595,33.3379 Q74.297,33.3379 74.9532,33.0879 Q75.3438,32.9316 75.7657,32.4941 Q76.0313,32.2285 76.172,32.1504 Q76.3282,32.0723 76.5313,32.0723 Q76.8595,32.0723 77.1095,32.3379 Q77.3751,32.5879 77.3751,32.9316 Q77.3751,33.2754 77.0313,33.6816 Q76.5313,34.2598 75.7345,34.5879 Q74.6563,35.041 73.3595,35.041 Q71.8438,35.041 70.6407,34.416 Q69.6563,33.916 68.9688,32.8535 Q68.2813,31.7754 68.2813,30.4941 L68.2813,29.3379 Q68.2813,28.0098 68.8907,26.8691 Q69.5157,25.7129 70.6095,25.1035 Q71.7032,24.4785 72.9376,24.4785 Q73.672,24.4785 74.3126,24.6504 Q74.9688,24.8066 75.5157,25.166 Z " fill="#000000"/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacing" textLength="66.709" x="86.3612" y="24.9492">«Projection»</text><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="59.9102" x="89.7606" y="43.0684">GameList</text><line style="stroke:#181818;stroke-width:0.5;" x1="51.5" x2="160.3203" y1="51.582" y2="51.582"/><ellipse cx="61.5" cy="66.3926" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="84.8203" x="70.5" y="70.6895">status: Status</text><line style="stroke:#181818;stroke-width:0.5;" x1="51.5" x2="160.3203" y1="78.2031" y2="78.2031"/></g><!--class GameState--><g id="elem_GameState"><rect codeLine="8" fill="#F1F1F1" height="228.1719" id="GameState" rx="2.5" ry="2.5" style="stroke:#181818;stroke-width:0.5;" width="197.9512" x="7" y="121.5"/><ellipse cx="66.3188" cy="143.791" fill="#ADD1B2" rx="11" ry="11" style="stroke:#181818;stroke-width:1.0;"/><path d="M69.0845,139.666 Q69.2407,139.4473 69.4282,139.3379 Q69.6157,139.2285 69.8345,139.2285 Q70.2095,139.2285 70.4438,139.4941 Q70.6782,139.7441 70.6782,140.3535 L70.6782,141.8066 Q70.6782,142.416 70.4438,142.6816 Q70.2095,142.9473 69.8345,142.9473 Q69.4907,142.9473 69.2876,142.7441 Q69.0845,142.5566 68.9751,142.041 Q68.9282,141.6816 68.7407,141.4941 Q68.4126,141.1191 67.8032,140.9004 Q67.1938,140.6816 66.5688,140.6816 Q65.8032,140.6816 65.1626,141.0098 Q64.5376,141.3379 64.0376,142.0879 Q63.5532,142.8379 63.5532,143.8691 L63.5532,144.9629 Q63.5532,146.1973 64.4438,147.0254 Q65.3345,147.8379 66.9282,147.8379 Q67.8657,147.8379 68.522,147.5879 Q68.9126,147.4316 69.3345,146.9941 Q69.6001,146.7285 69.7407,146.6504 Q69.897,146.5723 70.1001,146.5723 Q70.4282,146.5723 70.6782,146.8379 Q70.9438,147.0879 70.9438,147.4316 Q70.9438,147.7754 70.6001,148.1816 Q70.1001,148.7598 69.3032,149.0879 Q68.2251,149.541 66.9282,149.541 Q65.4126,149.541 64.2095,148.916 Q63.2251,148.416 62.5376,147.3535 Q61.8501,146.2754 61.8501,144.9941 L61.8501,143.8379 Q61.8501,142.5098 62.4595,141.3691 Q63.0845,140.2129 64.1782,139.6035 Q65.272,138.9785 66.5063,138.9785 Q67.2407,138.9785 67.8813,139.1504 Q68.5376,139.3066 69.0845,139.666 Z " fill="#000000"/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacing" textLength="66.709" x="88.8711" y="139.4492">«Projection»</text><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="70.8135" x="86.8188" y="157.5684">GameState</text><line style="stroke:#181818;stroke-width:0.5;" x1="8" x2="203.9512" y1="166.082" y2="166.082"/><ellipse cx="18" cy="180.8926" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="130.7305" x="27" y="185.1895">players: List<Player></text><ellipse cx="18" cy="199.5137" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="14" lengthAdjust="spacing" textLength="159.5029" x="27" y="203.8105">currentPlayerTurn: PlayerLine truncated