Python Script Documentation

@on_message decorator

Long-running scripts can listen for real-time messages from webhooks. Webhooks send messages using the script_listener parameter.

from traydar import on_message, run_forever, place_order, send_message

@on_message
def handle_webhook_alert(payload):
    """
    Receives messages from webhooks with script_listener parameter.
    Payload contains the entire webhook data.
    """
    print(f"Received alert: {payload}")

    alert_type = payload.get('alert_type')
    price = payload.get('price')

    if alert_type == 'resistance_break' and price > 98000:
        place_order(
            symbol="BTC/USDT",
            side="buy",
            amount=0.1,
            order_type="market"
        )
        send_message(f"🚀 Resistance broken at ${price}! Bought 0.1 BTC")

    elif alert_type == 'stop_loss':
        # Close all positions
        positions = get_positions()
        for pos in positions:
            place_order(
                symbol=pos.symbol,
                side='sell' if pos.side == 'long' else 'buy',
                amount=pos.size,
                order_type='market'
            )
        send_message("🛑 Stop loss triggered. All positions closed.")

# Start the script and keep it running
run_forever()

Webhook Configuration

Send a webhook with the script_listener parameter to deliver messages to your running script:

{
  "script_listener": "btc_monitor",
  "alert_type": "resistance_break",
  "price": 98500.50,
  "volume_spike": true,
  "custom_data": "any data you want"
}

Important Notes

• The script must be running before webhooks can send messages to it
• Only long-running scripts support message listeners
• Messages are delivered instantly via Redis pub/sub (< 10ms latency)
• If no @on_message handler is defined, messages are silently dropped
• The script name in the webhook must exactly match the script's name in Traydar
• Multiple @on_message handlers can be registered in the same script

Complete Example: Monitoring Bot

A long-running monitoring script that reacts to both price changes and webhook commands:

from traydar import on_price, on_message, run_forever, place_order, send_message, get_positions

# Listen for price updates
@on_price("BTC/USDT")
def check_price(price, timestamp):
    # Basic monitoring
    if price > 100000:
        send_message(f"📈 BTC crossed $100k: ${price}")

# Listen for webhook messages
@on_message
def handle_webhook_command(payload):
    """
    Webhook sends:
    {"script_listener": "btc_bot", "command": "close_all"}
    """
    command = payload.get('command')

    if command == 'close_all':
        positions = get_positions()
        for pos in positions:
            place_order(
                symbol=pos.symbol,
                side='sell' if pos.side == 'long' else 'buy',
                amount=pos.size
            )
        send_message("✅ Closed all positions via webhook command")

    elif command == 'pause':
        # Set internal state to pause trading
        global paused
        paused = True
        send_message("⏸️ Trading paused via webhook")

    elif command == 'resume':
        global paused
        paused = False
        send_message("▶️ Trading resumed via webhook")

run_forever()