From 7c2371766b940742f3986d7904d4c20a4127ea70 Mon Sep 17 00:00:00 2001
From: joffrey-bion <joffrey.bion@gmail.com>
Date: Wed, 3 Feb 2021 02:37:38 +0100
Subject: Add auto-game with bots only

Resolves:
https://github.com/joffrey-bion/seven-wonders/issues/82
---
 .../sevenwonders/client/SevenWondersClient.kt      | 30 +++++++++++++++++++---
 1 file changed, 27 insertions(+), 3 deletions(-)

(limited to 'sw-client/src')

diff --git a/sw-client/src/commonMain/kotlin/org/luxons/sevenwonders/client/SevenWondersClient.kt b/sw-client/src/commonMain/kotlin/org/luxons/sevenwonders/client/SevenWondersClient.kt
index 68026888..fc097d86 100644
--- a/sw-client/src/commonMain/kotlin/org/luxons/sevenwonders/client/SevenWondersClient.kt
+++ b/sw-client/src/commonMain/kotlin/org/luxons/sevenwonders/client/SevenWondersClient.kt
@@ -1,5 +1,7 @@
 package org.luxons.sevenwonders.client
 
+import kotlinx.coroutines.async
+import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.flow.map
@@ -148,8 +150,30 @@ class SevenWondersSession(private val stompSession: StompSessionWithKxSerializat
     }
 }
 
-suspend fun SevenWondersSession.joinGameAndWaitLobby(gameId: Long): LobbyDTO {
-    val joinedLobbies = watchLobbyJoined()
+suspend fun SevenWondersSession.createGameAndWaitLobby(gameName: String): LobbyDTO = coroutineScope {
+    val lobbies = watchLobbyJoined()
+    val joinedLobby = async { lobbies.first() }
+    createGame(gameName)
+    joinedLobby.await()
+}
+
+suspend fun SevenWondersSession.joinGameAndWaitLobby(gameId: Long): LobbyDTO = coroutineScope {
+    val lobbies = watchLobbyJoined()
+    val joinedLobby = async { lobbies.first() }
+    joinGame(gameId)
+    joinedLobby.await()
+}
+
+suspend fun SevenWondersSession.startGameAndAwaitFirstTurn(): PlayerTurnInfo = coroutineScope {
+    val gameStartedEvents = watchGameStarted()
+    val deferredFirstTurn = async { gameStartedEvents.first() }
+    startGame()
+    deferredFirstTurn.await()
+}
+
+suspend fun SevenWondersSession.joinGameAndWaitFirstTurn(gameId: Long): PlayerTurnInfo = coroutineScope {
+    val gameStartedEvents = watchGameStarted()
+    val deferredFirstTurn = async { gameStartedEvents.first() }
     joinGame(gameId)
-    return joinedLobbies.first()
+    deferredFirstTurn.await()
 }
-- 
cgit