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 initializedscrape_error(с записью вfct_bitget_launchpool_quarantine)- SQL ingest ошибки
Callers
Observability
- Логи:
bitget_launchpool_mapping_coverage,bitget launchpool scrape failed