dlmw/julius_baer_onboarding
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/main'

Browse Source
This commit is contained in:
NoeBerdoz
2025-04-12 14:00:21 +02:00
parent 3f406f1417 1d1d542f59
commit 47675979d1
5 changed files with 17 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
services/julius_baer_api_client.py
View File

@ -29,7 +29,7 @@ class JuliusBaerApiClient:
"""
Start a new game session.
"""
logging.info("[+] Starting new game session")
logging.debug("[+] Starting new game session")
start_uri = f"{self.api_uri}/game/start"
payload = game_start_request.model_dump_json()
@ -39,7 +39,7 @@ class JuliusBaerApiClient:
response_json = response.json()
validated_response = GameStartResponseDTO.model_validate(response_json)
logging.info(f"Game started successfully. Session: {validated_response.session_id}, Client: {validated_response.client_id}")
logging.debug(f"Game started successfully. Session: {validated_response.session_id}, Client: {validated_response.client_id}")
return validated_response
except Exception as e:
@ -50,7 +50,7 @@ class JuliusBaerApiClient:
"""
Make a game decision (Accept or Reject).
"""
logging.info("[+] Sending decision")
logging.debug("[+] Sending decision")
decision_uri = f"{self.api_uri}/game/decision"
payload = game_decision_request.model_dump_json()
@ -61,7 +61,7 @@ class JuliusBaerApiClient:
response_json = response.json()
validated_response = GameDecisionResponseDTO.model_validate(response_json)
logging.info("[+] Decision sent successfully")
logging.debug("[+] Decision sent successfully")
return validated_response
except Exception as e:

10
services/player.py
View File

@ -7,6 +7,8 @@ from dto.requests import GameStartRequestDTO, GameDecisionRequestDTO
from services.julius_baer_api_client import JuliusBaerApiClient
from utils.storage.game_files_manager import store_game_round_data
log = logging.getLogger(__name__)
class Player:
@ -19,7 +21,7 @@ class Player:
def play_on_separate_thread(self):
if self._thread and self._thread.is_alive():
logging.warning('Game loop already running.')
log.warning('Game loop already running.')
return self._thread
self._thread = threading.Thread(target=self.play, daemon=True)
@ -27,10 +29,10 @@ class Player:
return self._thread
def play(self):
print('playing')
log.info('playing')
payload = GameStartRequestDTO(player_name=config.API_TEAM)
start_response = self.client.start_game(payload)
logging.info(start_response)
log.info('game started, session id: %s', start_response.session_id)
status = ''
decision = self.make_decision(start_response.client_data)
@ -45,7 +47,7 @@ class Player:
)
decision_response = self.client.send_decision(payload)
print(decision_response.status, decision_response.score)
log.info(f'decision: {decision}, response status: {decision_response.status}, score: {decision_response.score}')
status = decision_response.status
decision = self.make_decision(decision_response.client_data)