Jupiter DEX Events Substream

A high-performance Substreams package for tracking Jupiter DEX aggregator events on Solana blockchain with 75% data reduction via foundational stores.

🌟 Overview

This substream provides complete visibility into Jupiter's DEX aggregation ecosystem, tracking:

• 🔄 Jupiter Swap Events (v1-v6): Token swap aggregations across multiple DEXs
• 📋 Jupiter Limit Orders: Advanced order management functionality
• 💰 Jupiter DCA: Dollar Cost Averaging automation
• 🧠 Aggregation Events: Cross-DEX routing decisions and arbitrage opportunities

🚀 Key Features

• ⚡ 75% Data Reduction: Uses solana-common foundational modules to exclude voting transactions
• 🎯 Block Filtering: Efficient filtering skips irrelevant blocks before processing
• 📊 Performance Stores: Track swap volumes and unique traders for analytics
• 🔄 Multi-Version Support: Tracks Jupiter v1-v6 simultaneously
• 🌐 Cross-DEX Analysis: Understands routing across Raydium, Orca, and other DEXs
• 📈 Real-time Events: Live tracking of Jupiter's aggregation decisions
• 💾 Shared Caching: Leverages foundational stores for reduced costs

📈 Performance Characteristics

• Data Reduction: 75% via vote transaction filtering
• Query Performance: 3-5x faster through foundational store caching
• Block Range: Optimized for blocks 31,310,775+
• Parallel Processing: Enabled for all map modules
• Infrastructure Cost: Significantly reduced via shared caching

📦 Installation

# Install Substreams CLI
curl -sSL https://substreams.dev/install.sh | bash

# Run Jupiter events (v0.3.2)
substreams run https://github.com/PaulieB14/Jupiter-Dex-Substreams/releases/download/v0.3.2/jupiter-dex-substreams-v0.3.2.spkg \
  map_jupiter_instructions \
  -e mainnet.sol.streamingfast.io:443 \
  -s 325766951 -t +1

🏗️ Module Architecture

jupiter_filtered_transactions (base module with foundational stores)
├── map_spl_initialized_account
├── map_jupiter_trading_data
│   ├── map_token_prices
│   ├── store_swap_volumes
│   └── store_unique_traders
├── map_jupiter_instructions
└── map_jupiter_analytics

🏗️ Development

Prerequisites

• Rust 1.70+
• Substreams CLI 1.7.0+
• Solana CLI (optional)

Build

# Clone the repository
git clone https://github.com/PaulieB14/Jupiter-Dex-Substreams.git
cd Jupiter-Dex-Substreams

# Build the WASM + package
substreams build

# (Optional) compile-check without packaging
cargo check --target wasm32-unknown-unknown

# Run with GUI for visualization
substreams gui substreams.yaml map_jupiter_instructions \
  -e mainnet.sol.streamingfast.io:443 \
  -s 325766951 -t +10

📊 Event Types

Swap Events

• Route discovery and execution
• Multi-hop swap tracking
• Slippage and price impact
• Cross-DEX routing decisions

Limit Order Events

• Order placement and management
• Order execution and fulfillment
• Order cancellation events

DCA Events

• Scheduled purchase events
• DCA execution status
• Position management

Aggregation Events

• Cross-DEX arbitrage opportunities
• Liquidity source selection
• Route optimization decisions

🔧 Jupiter Program IDs

📈 Usage Examples

Basic Usage

# Run with GUI
substreams gui substreams.yaml map_jupiter_analytics

# Run specific block range
substreams run substreams.yaml map_jupiter_instructions \
  -e mainnet.sol.streamingfast.io:443 \
  -s 325766951 -t +10

Advanced Usage

# Access swap volume store
substreams run substreams.yaml store_swap_volumes \
  -e mainnet.sol.streamingfast.io:443 \
  -s 325766951 -t +100

# Run with parallelization
substreams run substreams.yaml map_jupiter_analytics \
  -e mainnet.sol.streamingfast.io:443 \
  -H "X-Substreams-Parallel-Workers: 20" \
  -s 325766951 -t +1000

🏗️ Architecture

This substream is built using:

• Rust for the core logic
• Protocol Buffers for data serialization
• Substreams Solana for blockchain data access
• Solana Common v0.3.0 for foundational modules
• Block Filtering for efficient data processing

🆕 What's New in v0.3.2

Performance Improvements

• ✅ Integrated solana-common v0.3.0 foundational modules
• ✅ Added block-level filtering for Jupiter programs
• ✅ 75% data reduction by excluding voting transactions
• ✅ 3-5x query performance improvement

New Features

• ✅ store_swap_volumes - Track trading volumes by token pair
• ✅ store_unique_traders - Monitor unique wallet addresses
• ✅ Parameterized program ID filtering
• ✅ Enhanced module reusability

Technical Improvements

• ✅ Shared caching via foundational stores
• ✅ Reduced infrastructure costs
• ✅ Better error handling
• ✅ Improved parallel processing

📚 Documentation

• Substreams Documentation
• Foundational Stores Guide
• Jupiter Developer Docs
• Solana Documentation

🤝 Contributing

1. Fork the repository
2. Create a feature branch (git checkout -b feature/amazing-feature)
3. Commit your changes (git commit -m 'Add amazing feature')
4. Push to the branch (git push origin feature/amazing-feature)
5. Open a Pull Request

See CONTRIBUTING.md for detailed guidelines.

📄 License

This project is licensed under the MIT License - see the LICENSE file for details.

🔗 Links

• Substreams Package: https://substreams.dev/packages/jupiter-dex-substreams/v0.3.2
• GitHub Repository: https://github.com/PaulieB14/Jupiter-Dex-Substreams
• Jupiter Website: https://jup.ag
• Solana Website: https://solana.com

📞 Support

For support, please:

• Open an issue on GitHub
• Join the Substreams Discord
• Check the documentation

Built with ❤️ for the Jupiter and Solana ecosystem