forked from c0de/BaseballBot
Zed
3525ea42e1
First merge after adding branch Co-authored-by: c0de <c0de@c0de.dev> Reviewed-on: c0de/BaseballBot#1 Co-authored-by: Zed <benolken5@gmail.com> Co-committed-by: Zed <benolken5@gmail.com>
90 lines
2.7 KiB
Python
90 lines
2.7 KiB
Python
#!/usr/bin/env python3
|
|
# Copyright 2022 - c0de <c0de@c0de.dev>
|
|
# Licensed under the MIT License (https://opensource.org/licenses/MIT)
|
|
|
|
# pylint: disable=missing-module-docstring
|
|
|
|
import datetime
|
|
|
|
from database.models import GameModel as Game, GuessModel as Guess
|
|
from game.base import BaseGameManager
|
|
from game.process_guess import ProcessGuess
|
|
|
|
|
|
class EndGameManager(BaseGameManager):
|
|
"""Commands that run at the end of a play"""
|
|
|
|
def __init__(self):
|
|
super().__init__()
|
|
self.commands.append(("resolve", self.stop))
|
|
|
|
async def update_pitch_value(self):
|
|
"""Update game state database for closing arguments"""
|
|
pitch_value = self.message.content.split()[1]
|
|
if not pitch_value:
|
|
return await self.message.channel.send(
|
|
f"Invalid command <@{ str(self.message.author.id) }>!"
|
|
)
|
|
|
|
# Save the pitch value
|
|
Game.update(
|
|
{
|
|
Game.pitch_value: pitch_value,
|
|
Game.date_ended: datetime.datetime.now(),
|
|
}
|
|
).where(Game.game_id == self.game.game_id).execute()
|
|
|
|
return int(pitch_value)
|
|
|
|
async def stop(self):
|
|
"""
|
|
Stop command - Stops the game if it is currently running,
|
|
saves the pitch value, and displays differences
|
|
"""
|
|
|
|
if not self.is_running:
|
|
return await self.message.channel.send("There is no game running")
|
|
|
|
# How many valid guesses got placed?
|
|
guess_count = (
|
|
Guess.select()
|
|
.join(Game)
|
|
.where((Guess.game.game_id == self.game.game_id) & (Guess.guess > 0))
|
|
.count()
|
|
)
|
|
|
|
# Discard the game if there weren't enough players
|
|
if guess_count < 2:
|
|
self.game = None
|
|
self.is_running = False
|
|
return await self.message.channel.send(
|
|
("Play closed!\n" + "However, there were not enough participants.")
|
|
)
|
|
|
|
message = (
|
|
"Closed this play! Here are the results\n"
|
|
+ "__PLAYER | GUESS | DIFFERENCE | POINTS GAINED | TOTAL POINTS__\n"
|
|
)
|
|
|
|
pitch_value = await self.update_pitch_value()
|
|
guess_processor = ProcessGuess(
|
|
game=self, pitch_value=pitch_value, message=message
|
|
)
|
|
|
|
(
|
|
message,
|
|
closest_player_id,
|
|
furthest_player_id,
|
|
) = guess_processor.process_guesses()
|
|
|
|
message += (
|
|
f"\nCongrats <@{closest_player_id}>! You were the closest!\n"
|
|
+ f"Sorry <@{furthest_player_id}>, you were way off"
|
|
)
|
|
|
|
await self.message.channel.send(message)
|
|
|
|
# stop and discard game
|
|
self.is_running = False
|
|
self.game = None
|