Skip to content

SyncBingXXPoolSnapshot

Purpose

Запускает Playwright scraping BingX XPool и ingests snapshot через SQL-контракт.

Код: internal/worker/activities/sync_bingx_xpool.go

Input / Output

Input (models.SyncBingXXPoolInput): - include_details (optional, default true)

Output (models.SyncBingXXPoolResult): - snapshot_at - projects_seen, projects_upserted - subpools_seen, subpools_upserted - quarantine_rows

External Dependencies

  • Scraping: ScrapeBingXXPoolActivity (Playwright + Chromium)
  • DB: SQL function ingest_bingx_xpool_snapshot($1::jsonb) + fct_bingx_xpool_*

Idempotency

  • Ingestion SQL использует upsert-модель по ключам snapshot таблиц.

Error Taxonomy

  • database pool is not initialized
  • scrape_error (с записью в fct_bingx_xpool_quarantine)
  • SQL ingest ошибки

Callers

Observability

  • Логи: bingx_xpool_mapping_coverage, bingx xpool scrape failed