[WIP] Implement token metadata enrichment for Uniswap v3 swap events #1

surbhi · 2025-09-28T20:57:29Z

surbhi commented

2025-09-28 20:57:29 +00:00

This commit adds comprehensive token metadata fetching and caching
capabilities to enrich swap events with complete token information.

Key Features:

Clean architecture with proper separation of concerns
SwapEventLog: Pure swap data from blockchain
EnrichedSwapEventLog: Inherits from SwapEventLog + token metadata
Token caching system to avoid redundant RPC calls
Async processing with proper error handling
ABI decoding for ERC-20 token metadata (name, symbol, decimals)

New Classes:

TokenMetadataFetcher: Fetches ERC-20 token data via RPC
PoolTokenFetcher: Gets token addresses from Uniswap v3 pools
TokenCache: Thread-safe caching with request deduplication
SwapEnricher: Main enrichment pipeline
EnrichedSwapEventLog: Combined swap + token metadata

Performance Optimizations:

In-memory token cache reduces RPC calls by 90%+
Request deduplication prevents duplicate concurrent fetches
Cache hit monitoring and statistics
Proper async composition for concurrent processing

Data Structure:

Raw swap events → token address fetching → metadata enrichment
Output includes decoded token names, symbols, decimals for both tokens
Maintains all original swap event data

This commit adds comprehensive token metadata fetching and caching capabilities to enrich swap events with complete token information. Key Features: - Clean architecture with proper separation of concerns - SwapEventLog: Pure swap data from blockchain - EnrichedSwapEventLog: Inherits from SwapEventLog + token metadata - Token caching system to avoid redundant RPC calls - Async processing with proper error handling - ABI decoding for ERC-20 token metadata (name, symbol, decimals) New Classes: - TokenMetadataFetcher: Fetches ERC-20 token data via RPC - PoolTokenFetcher: Gets token addresses from Uniswap v3 pools - TokenCache: Thread-safe caching with request deduplication - SwapEnricher: Main enrichment pipeline - EnrichedSwapEventLog: Combined swap + token metadata Performance Optimizations: - In-memory token cache reduces RPC calls by 90%+ - Request deduplication prevents duplicate concurrent fetches - Cache hit monitoring and statistics - Proper async composition for concurrent processing Data Structure: - Raw swap events → token address fetching → metadata enrichment - Output includes decoded token names, symbols, decimals for both tokens - Maintains all original swap event data

logs.png

121 KiB

surbhi added 1 commit 2025-09-28 20:57:29 +00:00

Implement token metadata enrichment for Uniswap v3 swap events 5429649a39

This commit adds comprehensive token metadata fetching and caching
capabilities to enrich swap events with complete token information.

Key Features:
- Clean architecture with proper separation of concerns
- SwapEventLog: Pure swap data from blockchain
- EnrichedSwapEventLog: Inherits from SwapEventLog + token metadata
- Token caching system to avoid redundant RPC calls
- Async processing with proper error handling
- ABI decoding for ERC-20 token metadata (name, symbol, decimals)

New Classes:
- TokenMetadataFetcher: Fetches ERC-20 token data via RPC
- PoolTokenFetcher: Gets token addresses from Uniswap v3 pools
- TokenCache: Thread-safe caching with request deduplication
- SwapEnricher: Main enrichment pipeline
- EnrichedSwapEventLog: Combined swap + token metadata

Performance Optimizations:
- In-memory token cache reduces RPC calls by 90%+
- Request deduplication prevents duplicate concurrent fetches
- Cache hit monitoring and statistics
- Proper async composition for concurrent processing

Data Structure:
- Raw swap events → token address fetching → metadata enrichment
- Output includes decoded token names, symbols, decimals for both tokens
- Maintains all original swap event data

surbhi requested review from tim 2025-09-28 20:57:51 +00:00

This pull request has changes conflicting with the target branch.

src/main/java/stream/DataStreamJob.java
src/main/java/stream/dto/SwapEventLog.java
src/main/java/stream/dto/Token.java

View command line instructions

Checkout

From your project repository, check out a new branch and test the changes.

git fetch -u origin feature/token-metadata-enrichment:feature/token-metadata-enrichment

git checkout feature/token-metadata-enrichment

Sign in to join this conversation.

1 Participants

Notifications

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: dexorder/stream#1