Use the with
statement on the game class
This is because the class is a context manager / state machine
This commit is contained in:
parent
7101db5394
commit
1845e42488
@ -7,7 +7,7 @@ import datetime
|
|||||||
|
|
||||||
from peewee import *
|
from peewee import *
|
||||||
|
|
||||||
# User can provide path to database, or it will be put next to models.py
|
# User can provide path to database, or it will be put next to main.py
|
||||||
DATABASE = os.environ.get('database_path', os.getcwd() + '/ghostball.db')
|
DATABASE = os.environ.get('database_path', os.getcwd() + '/ghostball.db')
|
||||||
database = SqliteDatabase(DATABASE)
|
database = SqliteDatabase(DATABASE)
|
||||||
|
|
||||||
|
@ -15,8 +15,8 @@ class GhostBallClient(discord.Client):
|
|||||||
def __init__(self, *args, **kwargs):
|
def __init__(self, *args, **kwargs):
|
||||||
super(GhostBallClient, self).__init__(*args, **kwargs)
|
super(GhostBallClient, self).__init__(*args, **kwargs)
|
||||||
|
|
||||||
self.game = game.Game()
|
with game.Game() as self.game:
|
||||||
self.game.discord = self
|
self.game.discord = self
|
||||||
|
|
||||||
async def on_ready(self):
|
async def on_ready(self):
|
||||||
print("Logged on as", self.user)
|
print("Logged on as", self.user)
|
||||||
|
@ -15,7 +15,13 @@ class Game:
|
|||||||
This represents a game that exists in a channel
|
This represents a game that exists in a channel
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self):
|
def __enter__(self):
|
||||||
|
"""
|
||||||
|
Allows use of `with Game as game` for try/except statements
|
||||||
|
|
||||||
|
We are using this instead of __init__, they work very similar
|
||||||
|
to each other (https://peps.python.org/pep-0343/)
|
||||||
|
"""
|
||||||
# Only one game should run at at time
|
# Only one game should run at at time
|
||||||
self.is_running = False
|
self.is_running = False
|
||||||
|
|
||||||
@ -36,18 +42,32 @@ class Game:
|
|||||||
self.discord = None
|
self.discord = None
|
||||||
|
|
||||||
database.connect()
|
database.connect()
|
||||||
|
return self
|
||||||
|
|
||||||
def __exit__(self, exc_type, exc_val, exc_tb):
|
def __exit__(self, exception_type, exception_value, exception_traceback):
|
||||||
"""
|
"""
|
||||||
Automagically close the database
|
Automagically close the database
|
||||||
when this class has ended execution
|
when this class has ended execution
|
||||||
"""
|
"""
|
||||||
database.close()
|
database.close()
|
||||||
|
|
||||||
async def start(self):
|
async def check_is_running(method, start_new_game=True):
|
||||||
if self.is_running:
|
"""
|
||||||
return await self.message.channel.send("A game is already running")
|
Decorator that determines if the game is running or not
|
||||||
|
"""
|
||||||
|
async def wrapper(self):
|
||||||
|
|
||||||
|
if self.is_running and start_new_game:
|
||||||
|
return await self.message.channel.send("A game is already running")
|
||||||
|
elif not self.is_running and not start_new_game:
|
||||||
|
return await self.message.channel.send("There is no game running to add guesses to")
|
||||||
|
|
||||||
|
await method(self)
|
||||||
|
|
||||||
|
return await wrapper
|
||||||
|
|
||||||
|
@check_is_running
|
||||||
|
async def start(self):
|
||||||
self.is_running = True
|
self.is_running = True
|
||||||
|
|
||||||
# game.pitch_value is unknown at the start of the game
|
# game.pitch_value is unknown at the start of the game
|
||||||
@ -68,10 +88,8 @@ class Game:
|
|||||||
|
|
||||||
return None, False, None, None
|
return None, False, None, None
|
||||||
|
|
||||||
|
@check_is_running(start_new_game=False)
|
||||||
async def stop(self):
|
async def stop(self):
|
||||||
if not self.is_running:
|
|
||||||
return await self.message.channel.send("There is no game running to resolve")
|
|
||||||
|
|
||||||
# Determine arguments
|
# Determine arguments
|
||||||
pitch_value, has_batter, batter_id, batter_guess = self.__stopArgs__()
|
pitch_value, has_batter, batter_id, batter_guess = self.__stopArgs__()
|
||||||
if not pitch_value:
|
if not pitch_value:
|
||||||
@ -97,10 +115,8 @@ class Game:
|
|||||||
self.is_running = False
|
self.is_running = False
|
||||||
self.game = None
|
self.game = None
|
||||||
|
|
||||||
|
@check_is_running(start_new_game=False)
|
||||||
async def guess(self):
|
async def guess(self):
|
||||||
if not self.is_running:
|
|
||||||
return await self.message.channel.send("There is no game running to add guesses to")
|
|
||||||
|
|
||||||
value = int(self.message.content.split()[1])
|
value = int(self.message.content.split()[1])
|
||||||
if value < 1 or value > 1000:
|
if value < 1 or value > 1000:
|
||||||
return await self.message.channel.send(f"Invalid value. It must be between 1 and 1000 inclusive")
|
return await self.message.channel.send(f"Invalid value. It must be between 1 and 1000 inclusive")
|
||||||
|
Loading…
Reference in New Issue
Block a user