terrassumptions/server/app/api/game.py

from fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
from fastapi_camelcase import CamelModel
from pydantic import conint, constr

from sqlalchemy.orm import Session

from .. import scoring
from ..schemas import GameConfig, Guess, RuleSetEnum
from ..db import get_db, queries, models
from ..point_gen import generate_points, restock_source, ExhaustedSourceError

router = APIRouter()


class LinkedGame(CamelModel):
    linked_game: str


class JoinGame(CamelModel):
    player_name: constr(min_length=1)


class GuessResult(CamelModel):
    distance: int = None
    score: int = 0
    total_score: int


@router.put("")
def create_game(config: GameConfig, bg: BackgroundTasks, db: Session = Depends(get_db)):
    try:
        coords = generate_points(config)
    except ExhaustedSourceError:
        # TODO might be worth logging something useful here eventually
        raise HTTPException(status_code=501, detail="Sufficient points could not be generated quickly enough")
    game_id = queries.create_game(db, config, coords)
    bg.add_task(restock_source, config)
    return { "gameId": game_id }


def get_game(game_id: str, db: Session = Depends(get_db)) -> models.Game:
    game = queries.get_game(db, game_id)
    if game is None:
        raise HTTPException(status_code=404, detail="Game not found")
    return game


@router.get("/{game_id}/config", response_model=GameConfig)
def get_game_config(game: models.Game = Depends(get_game)):
    return game


@router.get("/{game_id}/coords")
def get_game_coords(game: models.Game = Depends(get_game)):
    return {
        str(coord.round_number): {
            "lat": coord.latitude,
            "lng": coord.longitude,
            "country": coord.country_code,
        }
        for coord in game.coordinates
    }


@router.post("/{game_id}/join")
def join_game(game_id: str, join: JoinGame, db: Session = Depends(get_db)):
    get_game(game_id, db) # confirm this game exists
    player_id = queries.join_game(db, game_id, join.player_name)
    if player_id is None:
        raise HTTPException(status_code=409, detail="Player name in use")
    return { "playerId": player_id }


@router.get("/{game_id}/players")
def get_players(game: models.Game = Depends(get_game)):
    return { "players": [
        {
            "name": p.player_name,
            "currentRound": queries.get_next_round_number(p),
            "totalScore": queries.get_total_score(p),
            "guesses": {
                str(g.round_number): {
                    "lat": g.latitude,
                    "lng": g.longitude,
                    "country": g.country_code,
                    "score": g.round_score,
                    "timeRemaining": g.time_remaining,
                } for g in p.guesses
            }
        } for p in game.players
    ] }


def get_player(game_id: str, player_id: str, db: Session = Depends(get_db)) -> models.Player:
    player = queries.get_player(db, player_id)
    if player is None:
        raise HTTPException(status_code=404, detail="Player not found")
    if player.game_id != game_id:
        raise HTTPException(status_code=404, detail="Player not in game")
    return player


@router.get("/{game_id}/players/{player_id}/current")
def get_current_round(db: Session = Depends(get_db), player: models.Player = Depends(get_player)):
    coord = queries.get_next_coordinate(db, player)
    if coord is None:
        return {
            "currentRound": None,
            "coord": None,
            "timer": None,
        }
    return {
        "currentRound": coord.round_number,
        "coord": {
            "lat": coord.latitude,
            "lng": coord.longitude,
            "country": coord.country_code,
        },
        "timer": queries.get_next_round_time(player),
    }


@router.put("/{game_id}/linked", status_code=204)
def set_linked_game(game_id: str, linked_game: LinkedGame, db: Session = Depends(get_db)):
    queries.link_game(db, game_id, linked_game.linked_game)


@router.get("/{game_id}/linked")
def get_linked_game(game: models.Game = Depends(get_game)):
    return { "linkedGame": game.linked_game }


@router.get("/{game_id}/round/{round_number}/first")
def get_first_submitter(game_id: str, round_number: conint(gt=0), db: Session = Depends(get_db)):
    return { "first": queries.get_first_submitter(db, game_id, round_number) }


@router.post("/{game_id}/round/{round_number}/guess/{player_id}", response_model=GuessResult)
def submit_guess(round_number: conint(gt=0), 
                 guess: Guess, 
                 db: Session = Depends(get_db), 
                 game: models.Game = Depends(get_game), 
                 player: models.Player = Depends(get_player)):
    target = queries.get_coordinate(db, player.game_id, round_number)
    if game.rule_set == RuleSetEnum.country_race:
        score = scoring.score_country_race(target.country_code, guess.country, guess.time_remaining, game.timer)
        distance = None
    else:
        score, distance = scoring.score((target.latitude, target.longitude), (guess.lat, guess.lng))
    added = queries.add_guess(db, guess, player, round_number, score)
    if not added:
        raise HTTPException(status_code=409, detail="Already submitted guess for this round")
    total_score = queries.get_total_score(player)
    return GuessResult(distance=distance, score=score, total_score=total_score)


@router.post("/{game_id}/round/{round_number}/timeout/{player_id}", response_model=GuessResult, response_model_include={"total_score"})
def submit_timeout(round_number: conint(gt=0), db: Session = Depends(get_db), player: models.Player = Depends(get_player)):
    added = queries.add_timeout(db, player, round_number)
    if not added:
        raise HTTPException(status_code=409, detail="Already submitted guess for this round")
    total_score = queries.get_total_score(player)
    return GuessResult(total_score=total_score)