pyr0ball
ea78b9c2cd
- Parallel execution: search() and get_completed_sales() now run
concurrently via ThreadPoolExecutor — each gets its own Store/SQLite
connection for thread safety. First cold search time ~halved.
- Pagination: SearchFilters.pages (default 1) controls how many eBay
result pages are fetched. Both search and sold-comps support up to 3
parallel Playwright sessions per call (capped to avoid Xvfb overload).
UI: segmented 1/2/3/5 pages selector in filter sidebar with cost hint.
- True median: get_completed_sales() now averages the two middle values
for even-length price lists instead of always taking the lower bound.
- Fix suspicious_price false positive: aggregator now checks
signal_scores.get("price_vs_market") == 0 (pre-None-substitution)
so listings without market data are never flagged as suspicious.
- Fix title pollution: scraper strips eBay's hidden screen-reader span
("Opens in a new window or tab") from listing titles via regex.
Lazy-imports playwright/playwright_stealth inside _get() so pure
parsing functions are importable without the full browser stack.
- Tests: 48 pass on host (scraper tests now runnable without Docker),
new regression guards for all three bug fixes.
79 lines
2.1 KiB
Python
79 lines
2.1 KiB
Python
import pytest
|
|
from datetime import datetime, timedelta, timezone
|
|
from pathlib import Path
|
|
from app.db.store import Store
|
|
from app.db.models import Listing, Seller, TrustScore, MarketComp
|
|
|
|
|
|
@pytest.fixture
|
|
def store(tmp_path):
|
|
return Store(tmp_path / "test.db")
|
|
|
|
|
|
def test_store_creates_tables(store):
|
|
# If no exception on init, tables exist
|
|
pass
|
|
|
|
|
|
def test_save_and_get_seller(store):
|
|
seller = Seller(
|
|
platform="ebay",
|
|
platform_seller_id="user123",
|
|
username="techseller",
|
|
account_age_days=730,
|
|
feedback_count=450,
|
|
feedback_ratio=0.991,
|
|
category_history_json="{}",
|
|
)
|
|
store.save_seller(seller)
|
|
result = store.get_seller("ebay", "user123")
|
|
assert result is not None
|
|
assert result.username == "techseller"
|
|
assert result.feedback_count == 450
|
|
|
|
|
|
def test_save_and_get_listing(store):
|
|
listing = Listing(
|
|
platform="ebay",
|
|
platform_listing_id="ebay-123",
|
|
title="RTX 4090 FE",
|
|
price=950.00,
|
|
currency="USD",
|
|
condition="used",
|
|
seller_platform_id="user123",
|
|
url="https://ebay.com/itm/123",
|
|
photo_urls=["https://i.ebayimg.com/1.jpg"],
|
|
listing_age_days=3,
|
|
)
|
|
store.save_listing(listing)
|
|
result = store.get_listing("ebay", "ebay-123")
|
|
assert result is not None
|
|
assert result.title == "RTX 4090 FE"
|
|
assert result.price == 950.00
|
|
|
|
|
|
def test_save_and_get_market_comp(store):
|
|
comp = MarketComp(
|
|
platform="ebay",
|
|
query_hash="abc123",
|
|
median_price=1050.0,
|
|
sample_count=12,
|
|
expires_at=(datetime.now(timezone.utc) + timedelta(hours=6)).isoformat(),
|
|
)
|
|
store.save_market_comp(comp)
|
|
result = store.get_market_comp("ebay", "abc123")
|
|
assert result is not None
|
|
assert result.median_price == 1050.0
|
|
|
|
|
|
def test_get_market_comp_returns_none_for_expired(store):
|
|
comp = MarketComp(
|
|
platform="ebay",
|
|
query_hash="expired",
|
|
median_price=900.0,
|
|
sample_count=5,
|
|
expires_at="2020-01-01T00:00:00", # past
|
|
)
|
|
store.save_market_comp(comp)
|
|
result = store.get_market_comp("ebay", "expired")
|
|
assert result is None
|