Save point: Just added existing game logic and data from persistent rock paper scissors demo.

Author: mikeckennedy

days/97-99-online-game-api/demo_app/client/requirements.txt

@@ -0,0 +1,30 @@
+import flask
+
+app = flask.Flask(__name__)
+
+
+def main():
+    app.run(debug=True)
+
+
+@app.route('/')
+def index():
+    return "Hello world!!!"
+
+
+@app.route('/api/test', methods=['GET'])
+def api_test():
+    data = {
+        'name': 'Michael',
+        'day': 97
+    }
+    return flask.jsonify(data)
+
+
+@app.errorhandler(404)
+def not_found(_):
+    return "The page was not found."
+
+
+if __name__ == '__main__':
+    main()

days/97-99-online-game-api/demo_app/web/app.py

@@ -0,0 +1 @@
+Attacker,Rock,Gun,Lightning,Devil,Dragon,Water,Air,Paper,Sponge,Wolf,Tree,Human,Snake,Scissors,FireRock,draw,lose,lose,lose,lose,lose,lose,lose,win,win,win,win,win,win,winGun,win,draw,lose,lose,lose,lose,lose,lose,lose,win,win,win,win,win,winLightning,win,win,draw,lose,lose,lose,lose,lose,lose,lose,win,win,win,win,winDevil,win,win,win,draw,lose,lose,lose,lose,lose,lose,lose,win,win,win,winDragon,win,win,win,win,draw,lose,lose,lose,lose,lose,lose,lose,win,win,winWater,win,win,win,win,win,draw,lose,lose,lose,lose,lose,lose,lose,win,winAir,win,win,win,win,win,win,draw,lose,lose,lose,lose,lose,lose,lose,winPaper,win,win,win,win,win,win,win,draw,lose,lose,lose,lose,lose,lose,loseSponge,lose,win,win,win,win,win,win,win,draw,lose,lose,lose,lose,lose,loseWolf,lose,lose,win,win,win,win,win,win,win,draw,lose,lose,lose,lose,loseTree,lose,lose,lose,win,win,win,win,win,win,win,draw,win,win,win,winHuman,lose,lose,lose,lose,win,win,win,win,win,win,win,draw,win,win,winSnake,lose,lose,lose,lose,lose,win,win,win,win,win,win,win,draw,win,winScissors,lose,lose,lose,lose,lose,lose,win,win,win,win,win,win,win,draw,loseFire,lose,lose,lose,lose,lose,lose,lose,win,win,win,win,win,win,win,draw

days/97-99-online-game-api/demo_app/web/data/battle-table.csv

@@ -0,0 +1,6 @@
+import os
+
+
+def get_db_path(base_file):
+    base_folder = os.path.dirname(__file__)
+    return os.path.join(base_folder, base_file)

days/97-99-online-game-api/demo_app/web/data/db_folder.py

@@ -0,0 +1 @@
+# TODO: Game logic.

days/97-99-online-game-api/demo_app/web/game_logic/game.py

@@ -0,0 +1,76 @@
+import csv
+from enum import Enum
+
+from game_logic.models.roll import Roll
+from data import db_folder
+
+__winner_lookup = {}
+
+
+class Decision(Enum):
+    tie = 1
+    win = 2
+    lose = 3
+
+    def reversed(self):
+        if self == Decision.win:
+            return Decision.lose
+        if self == Decision.lose:
+            return Decision.win
+
+        return Decision.tie
+
+    def __str__(self):
+        if self == Decision.win:
+            return 'win'
+        if self == Decision.lose:
+            return 'lose'
+        if self == Decision.tie:
+            return 'tie'
+
+        return "UNKNOWN DECISION: {}".format(self)
+
+
+def decide(roll1: Roll, roll2: Roll) -> Decision:
+    __build_decisions()
+
+    if roll1.name == roll2.name:
+        return Decision.tie
+
+    roll1_wins = roll2.name in __winner_lookup[roll1.name]
+
+    if roll1_wins:
+        return Decision.win
+    else:
+        return Decision.lose
+
+
+def __build_decisions():
+    if __winner_lookup:
+        return
+
+    file = db_folder.get_db_path('battle-table.csv')
+
+    with open(file) as fin:
+        reader = csv.DictReader(fin)
+        for row in reader:
+            __build_roll(row)
+
+
+def __build_roll(row: dict):
+    row = dict(row)
+    name = row['Attacker']
+
+    del row['Attacker']
+    del row[name]
+
+    __winner_lookup[name] = set()
+    for k in row.keys():
+        can_defeat = row[k].strip().lower() == 'win'
+        if can_defeat:
+            __winner_lookup[name].add(k)
+
+
+def all_roll_names():
+    __build_decisions()
+    return [k for k, v in __winner_lookup.items()]

days/97-99-online-game-api/demo_app/web/game_logic/game_decider.py

@@ -0,0 +1,179 @@
+from collections import defaultdict
+from typing import List, Optional
+
+# noinspection PyPackageRequirements
+from game_logic import session_factory, game_decider
+# noinspection PyPackageRequirements
+from game_logic.game_decider import Decision
+from game_logic.models.move import Move
+# noinspection PyPackageRequirements
+from game_logic.models.player import Player
+# noinspection PyPackageRequirements
+from game_logic.models.roll import Roll
+
+
+def get_game_history(game_id: str) -> List[Move]:
+    session = session_factory.create_session()
+
+    query = session.query(Move) \
+        .filter(Move.game_id == game_id) \
+        .order_by(Move.roll_number) \
+        .all()
+
+    moves = list(query)
+
+    session.close()
+
+    return moves
+
+
+def is_game_over(game_id: str) -> bool:
+    history = get_game_history(game_id)
+    return any([h.is_winning_play for h in history])
+
+
+def get_win_count(player: Player) -> int:
+    session = session_factory.create_session()
+
+    wins = session.query(Move) \
+        .filter(Move.player_id == player.id). \
+        filter(Move.is_winning_play) \
+        .count()
+
+    session.close()
+
+    return wins
+
+
+def find_player(name: str) -> Player:
+    session = session_factory.create_session()
+
+    player = session.query(Player).filter(Player.name == name).first()
+    session.close()
+
+    return player
+
+
+def create_player(name: str) -> Player:
+    session = session_factory.create_session()
+
+    player = session.query(Player).filter(Player.name == name).first()
+    if player:
+        raise Exception("Player already exists")
+
+    player = Player()
+    player.name = name
+    session.add(player)
+    session.commit()
+    session.close()
+
+    player = session.query(Player).filter(Player.name == name).first()
+    return player
+
+
+def all_players() -> List[Player]:
+    session = session_factory.create_session()
+
+    players = list(session.query(Player).all())
+    session.close()
+    return players
+
+
+def record_roll(player, roll: 'Roll', game_id: str, is_winning_play: bool, roll_num: int):
+    session = session_factory.create_session()
+
+    move = Move()
+    move.player_id = player.id
+    move.roll_id = roll.id
+    move.game_id = game_id
+    move.is_winning_play = is_winning_play
+    move.roll_number = roll_num
+    session.add(move)
+
+    session.commit()
+    session.close()
+
+
+def all_rolls() -> List[Roll]:
+    session = session_factory.create_session()
+
+    query = session.query(Roll).order_by(Roll.name).all()
+    rolls = list(query)
+
+    session.close()
+
+    return rolls
+
+
+def init_rolls(rolls: List[str]):
+    session = session_factory.create_session()
+    roll_count = session.query(Roll).count()
+    session.close()
+
+    if roll_count:
+        return
+
+    for roll_name in rolls:
+        create_roll(roll_name)
+
+
+def find_roll(name: str) -> Optional['Roll']:
+    session = session_factory.create_session()
+
+    roll = session.query(Roll).filter(Roll.name == name).first()
+
+    session.close()
+    return roll
+
+
+def create_roll(name: str) -> 'Roll':
+    session = session_factory.create_session()
+
+    roll = Roll()
+    roll.name = name
+    session.add(roll)
+
+    session.commit()
+    session.close()
+
+    roll = session.query(Roll).filter(Roll.id == roll.id).first()
+    return roll
+
+
+def find_roll_by_id(roll_id):
+    session = session_factory.create_session()
+    roll = session.query(Roll).filter(Roll.id == roll_id).first()
+    session.close()
+
+    return roll
+
+
+def find_player_by_id(player_id: int) -> Player:
+    session = session_factory.create_session()
+    player = session.query(Player).filter(Player.id == player_id).first()
+    session.close()
+
+    return player
+
+
+def count_round_wins(player_id: int, game_id: str) -> int:
+    history = get_game_history(game_id)
+    wins = 0
+    grouped_moves = defaultdict(list)
+
+    for h in history:
+        grouped_moves[h.roll_number].append(h)
+
+    for rnd_num, moves in grouped_moves.items():
+        player_move = [m for m in moves if m.player_id == player_id][0]
+        opponent_move = [m for m in moves if m.player_id != player_id][0]
+
+        player_roll = find_roll_by_id(player_move.roll_id)
+        opponent_roll = find_roll_by_id(opponent_move.roll_id)
+
+        outcome = game_decider.decide(player_roll, opponent_roll)
+        if outcome == Decision.win:
+            wins += 1
+
+    return wins
+

days/97-99-online-game-api/demo_app/web/game_logic/game_service.py

@@ -0,0 +1,3 @@
+from sqlalchemy.ext.declarative import declarative_base
+
+ModelBase = declarative_base()

days/97-99-online-game-api/demo_app/web/game_logic/models/model_base.py

@@ -0,0 +1,34 @@
+import datetime
+import sqlalchemy
+
+# noinspection PyPackageRequirements
+from game_logic.models.model_base import ModelBase
+
+
+class Move(ModelBase):
+    __tablename__ = 'moves'
+
+    id = sqlalchemy.Column(sqlalchemy.Integer, primary_key=True, autoincrement=True)
+    created = sqlalchemy.Column(sqlalchemy.DateTime, default=datetime.datetime.now, index=True)
+    roll_id = sqlalchemy.Column(sqlalchemy.Integer, index=True)
+    game_id = sqlalchemy.Column(sqlalchemy.String, index=True)
+    roll_number = sqlalchemy.Column(sqlalchemy.Integer, index=True)
+    player_id = sqlalchemy.Column(sqlalchemy.Integer, index=True)
+    is_winning_play = sqlalchemy.Column(sqlalchemy.Boolean, index=True, default=False)
+
+    def to_json(self, roll: 'Roll', player: 'Player'):
+        if self.roll_id != roll.id:
+            raise Exception("Mismatched roll values")
+        if self.player_id != player.id:
+            raise Exception("Mismatched player values")
+
+        return {
+            'id': self.id,
+            'created': self.created.isoformat(),
+            'roll_id': self.roll_id,
+            'roll': roll.name,
+            'player_id': self.player_id,
+            'player': player.name,
+            'roll_number': self.roll_number,
+            'is_winning_play': self.is_winning_play,
+        }

days/97-99-online-game-api/demo_app/web/game_logic/models/move.py

@@ -0,0 +1,21 @@
+import datetime
+
+import sqlalchemy
+
+# noinspection PyPackageRequirements
+from game_logic.models.model_base import ModelBase
+
+
+class Player(ModelBase):
+    __tablename__ = 'players'
+
+    id = sqlalchemy.Column(sqlalchemy.Integer, primary_key=True, autoincrement=True)
+    created = sqlalchemy.Column(sqlalchemy.DateTime, default=datetime.datetime.now)
+    name = sqlalchemy.Column(sqlalchemy.String, nullable=False)
+
+    def to_json(self):
+        return {
+            'id': self.id,
+            'created': self.created.isoformat(),
+            'name': self.name,
+        }