das-bridge 1.0.0

Python client for DAS Trader Pro CMD API

DAS Trader Python API Client

English | Español

Complete Python client for the DAS Trader Pro CMD API that enables automated trading, real-time order management, position tracking, and market data streaming.

🚀 Key Features

Core Trading Capabilities

• Complete Trading: Send, modify, and cancel orders (Market, Limit, Stop, Peg, etc.)
• Real-Time Market Data: Level 1, Level 2, and Time & Sales streaming
• Position Management: Automatic position tracking and real-time P&L
• Historical Data: Access to daily and minute charts
• Specific Order Queries: Get pending orders and executed orders separately

Enhanced Features

• Production-Grade Logging: Structured logging with rotation and masking
• Connection Resilience: Circuit breaker pattern with exponential backoff
• Configuration Management: Environment variables and JSON config support
• Enhanced Error Handling: Categorized exceptions with recovery guidance
• Multi-Format Parsing: Handles various DAS response formats
• Automatic Reconnection: Robust connection handling with auto-reconnect
• Native Asyncio: High performance with concurrent operations
• Type Safety: Fully typed for better IDE support

📋 Requirements

• Python 3.8+
• DAS Trader Pro with CMD API enabled
• Valid DAS Trader account

⚡ Quick Installation

git clone https://github.com/jefrnc/das-bridge.git
cd das-bridge
pip install -e .

Optional Dependencies

# For notifications
pip install aiohttp

# For data analysis
pip install numpy pandas matplotlib

# For Windows desktop notifications
pip install win10toast  # Windows only

# For configuration management
pip install python-dotenv

🔧 Configuration

1. Environment Variables

cp .env.example .env
# Edit .env with your credentials

2. Basic Configuration

# .env
DAS_HOST=localhost
DAS_PORT=9910
DAS_USERNAME=your_das_username
DAS_PASSWORD=your_das_password
DAS_ACCOUNT=your_das_account

🎯 Basic Usage

import asyncio
from das_trader import DASTraderClient, OrderSide, OrderType, MarketDataLevel

async def main():
    # Create client
    client = DASTraderClient(host="localhost", port=9910)
    
    try:
        # Connect to DAS Trader
        await client.connect("your_username", "your_password", "your_account")
        
        # Get buying power
        bp = await client.get_buying_power()
        print(f"Buying Power: ${bp['buying_power']:,.2f}")
        
        # Subscribe to market data
        await client.subscribe_quote("AAPL", MarketDataLevel.LEVEL1)
        
        # Get quote
        quote = await client.get_quote("AAPL")
        print(f"AAPL: Bid ${quote.bid} | Ask ${quote.ask} | Last ${quote.last}")
        
        # Send order
        order_id = await client.send_order(
            symbol="AAPL",
            side=OrderSide.BUY,
            quantity=100,
            order_type=OrderType.LIMIT,
            price=150.00
        )
        print(f"Order sent: {order_id}")
        
        # Check positions
        positions = client.get_positions()
        for pos in positions:
            if not pos.is_flat():
                print(f"{pos.symbol}: {pos.quantity} shares, "
                      f"P&L: ${pos.unrealized_pnl:.2f}")
        
    finally:
        await client.disconnect()

if __name__ == "__main__":
    asyncio.run(main())

🔥 Enhanced Capabilities

Advanced Order Management

# Get specific order types
pending_orders = await client.get_pending_orders()
executed_orders = await client.get_executed_orders()

# Enhanced market data
level1_data = await client.get_level1_data("AAPL")
montage_data = await client.get_montage_data("AAPL")

# Robust buying power (handles multi-line responses)
bp_data = await client.get_buying_power()

Production-Ready Features

# Enhanced logging with rotation
from das_trader.enhanced_logger import EnhancedDASLogger

logger = EnhancedDASLogger(
    account_id="TRADER123",
    log_dir="logs/production",
    max_log_size=50*1024*1024  # 50MB rotation
)

# Connection resilience
from das_trader.connection_resilience import ConnectionResilientManager

resilient_mgr = ConnectionResilientManager(
    client.connection,
    max_reconnect_attempts=5,
    health_check_interval=60.0
)

# Configuration management
from das_trader.config_manager import load_das_config

config = load_das_config("config.json")
client = DASTraderClient(**config.get_client_config())

📊 Supported Order Types

# Market Order
await client.send_order("AAPL", OrderSide.BUY, 100, OrderType.MARKET)

# Limit Order
await client.send_order("AAPL", OrderSide.BUY, 100, OrderType.LIMIT, price=150.00)

# Stop Loss
await client.send_order("AAPL", OrderSide.SELL, 100, OrderType.STOP, stop_price=145.00)

# Stop Limit
await client.send_order("AAPL", OrderSide.SELL, 100, OrderType.STOP_LIMIT,
                       price=148.00, stop_price=145.00)

# Trailing Stop
await client.send_order("AAPL", OrderSide.SELL, 100, OrderType.TRAILING_STOP,
                       trail_amount=2.00)

📈 Callbacks and Events

# Order callbacks
def on_order_filled(order):
    print(f"Order filled: {order.symbol}")

def on_order_rejected(order):
    print(f"Order rejected: {order.symbol}")

client.orders.register_callback("order_filled", on_order_filled)
client.orders.register_callback("order_rejected", on_order_rejected)

# Position callbacks
def on_position_update(position):
    print(f"Position updated: {position.symbol} P&L: ${position.unrealized_pnl:.2f}")

client.positions.register_callback("position_updated", on_position_update)

# Market data callbacks
def on_quote_update(quote):
    print(f"{quote.symbol}: ${quote.last}")

client.market_data.register_callback("quote_update", on_quote_update)

🤖 Advanced Examples

Basic Trading Bot

# See examples/trading_bot.py
python examples/trading_bot.py

Portfolio Monitor

# See examples/portfolio_monitor.py
python examples/portfolio_monitor.py

Market Data Streaming

# See examples/market_data_streaming.py
python examples/market_data_streaming.py

🛡️ Risk Management

# Configuration in config.example.py
MAX_POSITION_SIZE = 1000
MAX_ORDER_VALUE = 50000.0
STOP_LOSS_PERCENT = 0.02  # 2%
TAKE_PROFIT_PERCENT = 0.04  # 4%

# Paper Trading Mode
PAPER_TRADING_MODE = True
PAPER_TRADING_INITIAL_BALANCE = 100000.0

📚 API Documentation

Main Classes

• DASTraderClient: Main client for interacting with DAS Trader
• OrderManager: Order management and status tracking
• PositionManager: Position tracking and P&L
• MarketDataManager: Market data streaming and caching
• ConnectionManager: TCP connection handling and reconnection
• NotificationManager: Multi-platform notification system

Main Enums

• OrderType: MARKET, LIMIT, STOP, STOP_LIMIT, PEG, TRAILING_STOP
• OrderSide: BUY, SELL, SHORT, COVER
• OrderStatus: PENDING, NEW, PARTIALLY_FILLED, FILLED, CANCELLED, REJECTED
• TimeInForce: DAY, GTC, IOC, FOK, MOO, MOC
• MarketDataLevel: LEVEL1, LEVEL2, TIME_SALES

🧪 Testing

# Run tests
pytest tests/ -v

# With coverage
pytest tests/ --cov=das_trader --cov-report=html

🔐 Security

• Never commit credentials in code
• Use environment variables for sensitive configuration
• The .env file is in .gitignore
• Consider using paper trading mode for testing

📝 Logging

import logging
logging.basicConfig(level=logging.INFO)

# The client includes detailed logging:
# - Connections and authentication
# - Sent and received orders
# - Market data streaming
# - Errors and reconnections

🤝 Contributing

Contributions are welcome! Please:

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

📄 License

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

⚠️ Disclaimer

This software is for educational and development purposes. Automated trading carries significant financial risks. Use at your own risk and always consider:

• Thorough testing in paper trading mode
• Proper risk management
• Constant position monitoring
• Compliance with local regulations

🔗 Related Projects

• das-api-examples: Practical examples and tests for the DAS Trader Pro CMD API
  • Direct TCP connection tests
  • API feature verification
  • Configuration guides and troubleshooting

📚 Useful Links

• DAS Trader Pro Documentation
• CMD API Manual
• Usage Examples
• Tests

📞 Support

To report bugs or request features:

• Open an Issue
• Check the documentation
• Consult the examples

---

Developed with ❤️ for the algorithmic trading community