Skip to content

SyncBitgetLaunchpoolSnapshot

Purpose

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

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

Input / Output

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

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

External Dependencies

  • Scraping: ScrapeBitgetLaunchpoolActivity (Playwright + Chromium)
  • DB: SQL function ingest_bitget_launchpool_snapshot($1::jsonb) + fct_bitget_launchpool_*

Idempotency

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

Error Taxonomy

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

Callers

Observability

  • Логи: bitget_launchpool_mapping_coverage, bitget launchpool scrape failed