3 Commits

4 changed files with 22 additions and 20 deletions

1
.gitignore vendored
View File

@@ -1,2 +1,3 @@
/nhle_scoreboard_response.txt /nhle_scoreboard_response.txt
/nhle_standings_response.txt /nhle_standings_response.txt
/nhl_standings.db

12
app.py
View File

@@ -7,6 +7,7 @@ import threading
import time import time
import schedule import schedule
import json import json
from update_nhl_standings_db import update_nhl_standings
app = Flask(__name__) app = Flask(__name__)
@@ -39,8 +40,9 @@ def store_scoreboard_data():
global scoreboard_data global scoreboard_data
scoreboard_data = get_nhle_scoreboard() scoreboard_data = get_nhle_scoreboard()
# Schedule the task to run every 10 seconds # Schedule tasks
def schedule_task(): def schedule_tasks():
schedule.every(300).seconds.do(update_nhl_standings)
schedule.every(10).seconds.do(store_scoreboard_data) schedule.every(10).seconds.do(store_scoreboard_data)
while True: while True:
schedule.run_pending() schedule.run_pending()
@@ -157,9 +159,6 @@ def get_game_outcome(game_state, game):
return last_period_type return last_period_type
def calculate_game_priority(game): def calculate_game_priority(game):
if game["gameState"] in ["FINAL", "OFF", "PRE", "FUT"] or game["clock"]["inIntermission"]: if game["gameState"] in ["FINAL", "OFF", "PRE", "FUT"] or game["clock"]["inIntermission"]:
return 0 return 0
@@ -250,5 +249,6 @@ def get_scoreboard():
if __name__ == '__main__': if __name__ == '__main__':
store_scoreboard_data() store_scoreboard_data()
threading.Thread(target=schedule_task).start() update_nhl_standings()
threading.Thread(target=schedule_tasks).start()
serve(app, host="0.0.0.0", port=2897) serve(app, host="0.0.0.0", port=2897)

Binary file not shown.

View File

@@ -44,6 +44,7 @@ def extract_standings_info():
print("Error:", response.status_code) print("Error:", response.status_code)
return None return None
def update_nhl_standings():
# Connect to SQLite database # Connect to SQLite database
conn = sqlite3.connect("nhl_standings.db") conn = sqlite3.connect("nhl_standings.db")