Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d809590f0e | |||
| 0d8e666a75 | |||
|
|
bd19b7d913 | ||
|
|
c49f91cc19 | ||
|
|
215085b326 | ||
| c063f5c4ef | |||
|
|
d92f571960 |
@ -379,14 +379,14 @@ def update_season_pitching_stats(player_ids, season, db_connection):
|
|||||||
|
|
||||||
-- RBI allowed (excluding HR) per runner opportunity
|
-- RBI allowed (excluding HR) per runner opportunity
|
||||||
CASE
|
CASE
|
||||||
WHEN (SUM(CASE WHEN sp.on_first IS NOT NULL THEN 1 ELSE 0 END) +
|
WHEN (SUM(CASE WHEN sp.on_first_id IS NOT NULL THEN 1 ELSE 0 END) +
|
||||||
SUM(CASE WHEN sp.on_second IS NOT NULL THEN 1 ELSE 0 END) +
|
SUM(CASE WHEN sp.on_second_id IS NOT NULL THEN 1 ELSE 0 END) +
|
||||||
SUM(CASE WHEN sp.on_third IS NOT NULL THEN 1 ELSE 0 END)) > 0
|
SUM(CASE WHEN sp.on_third_id IS NOT NULL THEN 1 ELSE 0 END)) > 0
|
||||||
THEN ROUND(
|
THEN ROUND(
|
||||||
(SUM(sp.rbi) - SUM(sp.homerun))::DECIMAL /
|
(SUM(sp.rbi) - SUM(sp.homerun))::DECIMAL /
|
||||||
(SUM(CASE WHEN sp.on_first IS NOT NULL THEN 1 ELSE 0 END) +
|
(SUM(CASE WHEN sp.on_first_id IS NOT NULL THEN 1 ELSE 0 END) +
|
||||||
SUM(CASE WHEN sp.on_second IS NOT NULL THEN 1 ELSE 0 END) +
|
SUM(CASE WHEN sp.on_second_id IS NOT NULL THEN 1 ELSE 0 END) +
|
||||||
SUM(CASE WHEN sp.on_third IS NOT NULL THEN 1 ELSE 0 END)),
|
SUM(CASE WHEN sp.on_third_id IS NOT NULL THEN 1 ELSE 0 END)),
|
||||||
3
|
3
|
||||||
)
|
)
|
||||||
ELSE 0.000
|
ELSE 0.000
|
||||||
@ -807,6 +807,10 @@ def handle_db_errors(func):
|
|||||||
|
|
||||||
return result
|
return result
|
||||||
|
|
||||||
|
except HTTPException:
|
||||||
|
# Let intentional HTTP errors (401, 404, etc.) pass through unchanged
|
||||||
|
raise
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
elapsed_time = time.time() - start_time
|
elapsed_time = time.time() - start_time
|
||||||
error_trace = traceback.format_exc()
|
error_trace = traceback.format_exc()
|
||||||
|
|||||||
@ -10,8 +10,6 @@ from ..dependencies import (
|
|||||||
oauth2_scheme,
|
oauth2_scheme,
|
||||||
cache_result,
|
cache_result,
|
||||||
handle_db_errors,
|
handle_db_errors,
|
||||||
MAX_LIMIT,
|
|
||||||
DEFAULT_LIMIT,
|
|
||||||
)
|
)
|
||||||
from ..services.base import BaseService
|
from ..services.base import BaseService
|
||||||
from ..services.player_service import PlayerService
|
from ..services.player_service import PlayerService
|
||||||
@ -30,7 +28,7 @@ async def get_players(
|
|||||||
strat_code: list = Query(default=None),
|
strat_code: list = Query(default=None),
|
||||||
is_injured: Optional[bool] = None,
|
is_injured: Optional[bool] = None,
|
||||||
sort: Optional[str] = None,
|
sort: Optional[str] = None,
|
||||||
limit: int = Query(default=DEFAULT_LIMIT, ge=1, le=MAX_LIMIT),
|
limit: Optional[int] = Query(default=None, ge=1),
|
||||||
offset: Optional[int] = Query(
|
offset: Optional[int] = Query(
|
||||||
default=None, ge=0, description="Number of results to skip for pagination"
|
default=None, ge=0, description="Number of results to skip for pagination"
|
||||||
),
|
),
|
||||||
|
|||||||
@ -81,9 +81,9 @@ class TestRouteRegistration:
|
|||||||
for route, methods in EXPECTED_PLAY_ROUTES.items():
|
for route, methods in EXPECTED_PLAY_ROUTES.items():
|
||||||
assert route in paths, f"Route {route} missing from OpenAPI schema"
|
assert route in paths, f"Route {route} missing from OpenAPI schema"
|
||||||
for method in methods:
|
for method in methods:
|
||||||
assert (
|
assert method in paths[route], (
|
||||||
method in paths[route]
|
f"Method {method.upper()} missing for {route}"
|
||||||
), f"Method {method.upper()} missing for {route}"
|
)
|
||||||
|
|
||||||
def test_play_routes_have_plays_tag(self, api):
|
def test_play_routes_have_plays_tag(self, api):
|
||||||
"""All play routes should be tagged with 'plays'."""
|
"""All play routes should be tagged with 'plays'."""
|
||||||
@ -96,9 +96,9 @@ class TestRouteRegistration:
|
|||||||
for method, spec in paths[route].items():
|
for method, spec in paths[route].items():
|
||||||
if method in ("get", "post", "patch", "delete"):
|
if method in ("get", "post", "patch", "delete"):
|
||||||
tags = spec.get("tags", [])
|
tags = spec.get("tags", [])
|
||||||
assert (
|
assert "plays" in tags, (
|
||||||
"plays" in tags
|
f"{method.upper()} {route} missing 'plays' tag, has {tags}"
|
||||||
), f"{method.upper()} {route} missing 'plays' tag, has {tags}"
|
)
|
||||||
|
|
||||||
@pytest.mark.post_deploy
|
@pytest.mark.post_deploy
|
||||||
@pytest.mark.skip(
|
@pytest.mark.skip(
|
||||||
@ -124,9 +124,9 @@ class TestRouteRegistration:
|
|||||||
]:
|
]:
|
||||||
params = paths[route]["get"].get("parameters", [])
|
params = paths[route]["get"].get("parameters", [])
|
||||||
param_names = [p["name"] for p in params]
|
param_names = [p["name"] for p in params]
|
||||||
assert (
|
assert "sbaplayer_id" in param_names, (
|
||||||
"sbaplayer_id" in param_names
|
f"sbaplayer_id parameter missing from {route}"
|
||||||
), f"sbaplayer_id parameter missing from {route}"
|
)
|
||||||
|
|
||||||
|
|
||||||
# ---------------------------------------------------------------------------
|
# ---------------------------------------------------------------------------
|
||||||
@ -493,10 +493,9 @@ class TestPlayCrud:
|
|||||||
assert result["id"] == play_id
|
assert result["id"] == play_id
|
||||||
|
|
||||||
def test_get_nonexistent_play(self, api):
|
def test_get_nonexistent_play(self, api):
|
||||||
"""GET /plays/999999999 returns an error (wrapped by handle_db_errors)."""
|
"""GET /plays/999999999 returns 404 Not Found."""
|
||||||
r = requests.get(f"{api}/api/v3/plays/999999999", timeout=10)
|
r = requests.get(f"{api}/api/v3/plays/999999999", timeout=10)
|
||||||
# handle_db_errors wraps HTTPException as 500 with detail message
|
assert r.status_code == 404
|
||||||
assert r.status_code == 500
|
|
||||||
assert "not found" in r.json().get("detail", "").lower()
|
assert "not found" in r.json().get("detail", "").lower()
|
||||||
|
|
||||||
|
|
||||||
@ -575,9 +574,9 @@ class TestGroupBySbaPlayer:
|
|||||||
)
|
)
|
||||||
assert r_seasons.status_code == 200
|
assert r_seasons.status_code == 200
|
||||||
season_pas = [s["pa"] for s in r_seasons.json()["stats"]]
|
season_pas = [s["pa"] for s in r_seasons.json()["stats"]]
|
||||||
assert career_pa >= max(
|
assert career_pa >= max(season_pas), (
|
||||||
season_pas
|
f"Career PA ({career_pa}) should be >= max season PA ({max(season_pas)})"
|
||||||
), f"Career PA ({career_pa}) should be >= max season PA ({max(season_pas)})"
|
)
|
||||||
|
|
||||||
@pytest.mark.post_deploy
|
@pytest.mark.post_deploy
|
||||||
def test_batting_sbaplayer_short_output(self, api):
|
def test_batting_sbaplayer_short_output(self, api):
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user