b7fc327779
**낡은 테스트**: test_handler_skips_record_on_negative_cache_hit 는 '캐시 히트면 이력을 남기지 않는다'를 검증했는데, 그 동작은 실측 버그였다 — 잡은 DONE 인데 price_history 에 새 행이 없어 이를 폴링하는 소비자(negodata 최저가 모달)가 결과를 영영 못 받고 로딩만 돌았다. 코드는 이미 '캐시 히트도 이 잡의 결과이므로 기록한다'로 고쳐져 있었고 테스트만 남아 있었다. → 현재 계약(not_found 스냅샷 1건 기록, 가격은 null)을 검증하도록 다시 씀. 전체 220 passed·0 failed. **오픈API 어댑터 제거**: shop.json 이 2026-07-31 종료돼 404 SE05 만 반환하고, 파이프라인은 naver_shop(크롤)로 옮겨 갔다. 되살릴 수 없는 코드를 남겨두면 다음 사람이 "키를 넣으면 되나" 하고 시간을 쓴다. - services/search/naver/ (adapter·transform) 삭제 - NaverConfig 모델·로더·설정 섹션 3개 파일에서 제거(죽은 키) - test_naver_transform 삭제, test_alerts 는 NaverAdapter 대신 스텁 사용 (검증 대상인 recent_stats/_note_result 는 베이스 SearchAdapter 계약이라 무관) **문서 정합화**: architecture(네이버 안티봇=WTM, 통과 3조건) · api(배송비가 이제 채워짐, 가격은 즉시판매가·쿠폰가 제외) · operations(kr_host·naver_ip_request_budget) · README 트리. source 이름 "naver" 는 그대로다 — price_history·by_mall·프론트 계약은 구현 교체와 무관하다.
103 lines
4.7 KiB
Python
103 lines
4.7 KiB
Python
"""최저가 이력 — 소스별 min 스냅샷 계산 + 기록/조회 CRUD + 핸들러 기록 규칙."""
|
|
|
|
import pytest_asyncio
|
|
from sqlalchemy import text
|
|
|
|
from common.enums import JobType
|
|
from crud.price_history import PriceHistory
|
|
from services.search.contract import NormalizedProduct
|
|
from worker.handlers import _price_snapshot, build_search_handler
|
|
|
|
|
|
def _np(source, price, name=None):
|
|
return NormalizedProduct(source=source, name=name or f"{source}-{price}", price=price, detail_url=f"http://{source}/{price}")
|
|
|
|
|
|
# ── 스냅샷 계산 (순수) ─────────────────────────────────────────────
|
|
def test_snapshot_source_lowest_and_final():
|
|
matched = [_np("naver", 3000), _np("naver", 2000), _np("coupang", 2500)]
|
|
s = _price_snapshot(matched)
|
|
assert s["naver_lowest"] == 2000 and s["coupang_lowest"] == 2500
|
|
assert s["final_lowest"] == 2000 and s["final_source"] == "naver"
|
|
assert s["matched_count"] == 3
|
|
|
|
|
|
def test_snapshot_single_source_only():
|
|
s = _price_snapshot([_np("coupang", 1500)])
|
|
assert s["naver_lowest"] is None and s["coupang_lowest"] == 1500
|
|
assert s["final_lowest"] == 1500 and s["final_source"] == "coupang"
|
|
|
|
|
|
def test_snapshot_empty_is_all_null():
|
|
s = _price_snapshot([])
|
|
assert s["final_lowest"] is None and s["naver_lowest"] is None and s["matched_count"] == 0
|
|
|
|
|
|
# ── CRUD (실 DB) ───────────────────────────────────────────────────
|
|
@pytest_asyncio.fixture
|
|
async def ph(db_engine):
|
|
async with db_engine.begin() as conn:
|
|
await conn.execute(text("TRUNCATE price_history"))
|
|
return PriceHistory()
|
|
|
|
|
|
async def test_record_and_list_time_ordered(ph):
|
|
await ph.record({"product_code": "P1", "outcome": "found", "final_lowest": 2000, "final_source": "naver",
|
|
"naver_lowest": 2000, "coupang_lowest": 2500, "matched_count": 3})
|
|
await ph.record({"product_code": "P1", "outcome": "found", "final_lowest": 1900, "final_source": "coupang",
|
|
"naver_lowest": 2100, "coupang_lowest": 1900, "matched_count": 2})
|
|
await ph.record({"product_code": "P2", "outcome": "found", "final_lowest": 999}) # 다른 상품
|
|
|
|
points = await ph.list_by_product("P1")
|
|
assert len(points) == 2 # P2 제외
|
|
assert [p["final_lowest"] for p in points] == [2000, 1900] # 시각 오름차순
|
|
assert points[0]["triggered_at"] <= points[1]["triggered_at"]
|
|
|
|
|
|
# ── 핸들러 기록 규칙 ───────────────────────────────────────────────
|
|
class _Rec:
|
|
def __init__(self): self.events = []
|
|
async def record(self, e): self.events.append(e)
|
|
|
|
|
|
class _FakeAdapter:
|
|
def __init__(self, source, products): self.source = source; self._p = products
|
|
async def search(self, q, limit=40): return self._p
|
|
|
|
|
|
class _Neg:
|
|
def __init__(self, neg): self._neg = neg
|
|
async def is_negative(self, k): return self._neg
|
|
async def put(self, *a, **k): pass
|
|
|
|
|
|
def _job(**p):
|
|
p.setdefault("product_name", "x"); p.setdefault("product_code", "PC1")
|
|
return {"job_type": JobType.SEARCH.value, "attempts": 1, "job_id": "j1", "payload": p}
|
|
|
|
|
|
async def test_handler_records_found_snapshot():
|
|
rec = _Rec()
|
|
adapters = {"naver": _FakeAdapter("naver", [_np("naver", 2000)]), "coupang": _FakeAdapter("coupang", [_np("coupang", 1800)])}
|
|
await build_search_handler(adapters, history=rec)(_job())
|
|
assert len(rec.events) == 1
|
|
e = rec.events[0]
|
|
assert e["product_code"] == "PC1" and e["outcome"] == "found"
|
|
assert e["final_lowest"] == 1800 and e["final_source"] == "coupang"
|
|
|
|
|
|
async def test_handler_records_on_negative_cache_hit():
|
|
"""캐시 히트도 '이 잡의 결과'라 이력을 남겨야 한다.
|
|
|
|
예전엔 남기지 않았는데, 그러면 잡은 DONE 인데 price_history 에 새 행이 없어
|
|
이걸 폴링하는 소비자(negodata 최저가 모달)가 결과를 영영 못 받고 로딩만 돌았다(실측 버그).
|
|
검색을 생략했을 뿐 결과는 not_found 로 확정된 것이므로 기록이 맞다."""
|
|
rec = _Rec()
|
|
adapters = {"naver": _FakeAdapter("naver", [_np("naver", 100)])}
|
|
out = await build_search_handler(adapters, neg_cache=_Neg(True), history=rec)(_job())
|
|
assert out["outcome"] == "not_found" and out["cached"] is True
|
|
assert len(rec.events) == 1
|
|
e = rec.events[0]
|
|
assert e["product_code"] == "PC1" and e["outcome"] == "not_found"
|
|
assert e["final_lowest"] is None and e["matched_count"] == 0 # 검색을 안 했으니 가격도 없다
|