QuaiWhale logo
QuaiWhale
Markets

Exchange Flows

Observes verified exchange movements, known DEX pool flows, and large unverified Base transfers.

Live
Runtime key
exchange_flow_feed
Railway process
exchange-flow-feed
Required production process
Last heartbeat
Jul 31, 2026, 12:42:00 a.m.
UTC
Last successful cycle
Jul 31, 2026, 12:42:00 a.m.
UTC
Runtime status
completed
Next scheduled run
Not available
No next_run_at exposed
Last cycle duration
160ms
Completed Jul 31, 2026, 12:42:00 a.m. UTC
Process started
Jul 31, 2026, 12:32:58 a.m.
UTC
Current runtime snapshot

Point-in-time operational summary

This worker exposes a current loop-state record in this view. No multi-run history is requested or inferred.

Live
Runtime status
completed
Next scheduled
Not available
Checkpoint fields
3
Metadata fields
4
Exact data chain

Input to product surface

required process
Step 1Input
Base QUAI transfer logs

Scans confirmed ERC-20 Transfer logs for the configured QUAI token contract on Base.

Step 2Normalization
Attach block time and parse transfers

Resolves canonical block timestamps, normalizes addresses and amounts, and repairs older ingestion-fallback timestamps.

Step 3Classification
Resolve counterparties

Matches active exchange wallets, identifies known DEX pools, and separates large unverified transfer candidates.

Step 4Persistence
Persist verified and candidate flows

Upserts verified exchange flows and candidate transfers with independent confidence and reasoning.

Step 5Product
Build market markers

Feeds QUAI Live markers, exchange-pressure context, and downstream signal views.

Required dependencies

The chain cannot produce its canonical output without these dependencies.

Base JSON-RPC

Block number, transfer logs, and block timestamp reads.

Supabase service role

Exchange wallet registry, checkpoints, and flow persistence.

Base QUAI token registry

Contract address, symbol, and decimals used to decode transfers.

Secondary and fallback paths

Recovery, enrichment, transport, or coordination paths that do not replace the canonical source of truth.

exchange_wallets registry

Promotes matched counterparties to verified exchange flows.

DEX pool registry

Recognizes known pool inflows and outflows before large-transfer candidate logic.

Configured QUAI/USD price

Adds USD amounts when a reliable configured price is available.

Storage contract

Tables read or written by this worker chain.

Swipe horizontally to inspect all columns

TablePurpose
exchange_walletsActive known exchange counterparties read by the worker.
exchange_flowsVerified exchange deposits and withdrawals.
exchange_flow_candidatesKnown DEX pool flows and large unverified candidates.

Product outputs

User-facing workspaces directly powered by this chain.

Runtime checkpoint

Base block scan range

To Block
49 334 580
From Block
49 334 256
Next Block
49 334 581

Cycle metadata

Transfer Log Count
0
Verified Inserted
0
Candidate Inserted
0
Block Timestamp Fallback Count
0

Implementation map

Primary repository files implementing this worker chain and its product read path.

workers/exchange-flow-feed/start.cjs
workers/market-feed/exchange-flow-feed.js
app/lib/market-feed/markers.js