SyncBingXLaunchpoolSnapshot

Purpose

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

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

Input / Output

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

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

External Dependencies

• Scraping: ScrapeBingXLaunchpoolActivity (Playwright + Chromium)
• DB: SQL function ingest_bingx_launchpool_snapshot($1::jsonb) + fct_bingx_launchpool_*

Idempotency

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

Error Taxonomy

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

Callers

• SyncBingXLaunchpoolWorkflow

Observability

• Логи: bingx_launchpool_mapping_coverage, bingx launchpool scrape failed