Smart Order Routing Execution Data

{
  "type": "subscribe",
  "channels": [
    {
      "type": "execution_data",
      "params": {
        "market": "BTCUSD"
      }
    }
  ]
}

{
  "type": "subscribe",
  "channels": [
    {
      "type": "execution_data",
      "params": { "market": "BTCUSD" },
      "success": true
    }
  ]
}

{
  "type": "subscribe",
  "channels": [
    {
      "type": "execution_data",
      "params": { "market": "BADBAD" },
      "success": false,
      "error": "UNKNOWN_CHANNEL_PARAMS_CONFIGURATION"
    }
  ]
}

{
  "channel": "execution_data",
  "payload": {
    "market": "BTCUSD",
    "price": "50000.00",
    "amount": "0.5",
    "executed_at": "2024-01-15T10:30:00.123456789Z"
  }
}

{
  "type": "subscribe",
  "channels": [
    {
      "type": "execution_data",
      "params": {
        "market": "BTCUSD"
      }
    },
    {
      "type": "execution_data",
      "params": {
        "market": "ETHUSD"
      }
    }
  ]
}

class ExecutionMonitor {
  constructor() {
    this.executions = [];
    this.volumeByMarket = new Map();
  }

  handleExecution(message) {
    const execution = message.payload;
    
    // Store execution
    this.executions.push(execution);
    
    // Update volume tracking
    const currentVolume = this.volumeByMarket.get(execution.market) || 0;
    const executionVolume = parseFloat(execution.price) * parseFloat(execution.amount);
    this.volumeByMarket.set(execution.market, currentVolume + executionVolume);
    
    // Process execution
    this.processExecution(execution);
  }

  processExecution(execution) {
    console.log(`Trade executed in ${execution.market}:`,
      `${execution.amount} @ ${execution.price}`,
      `at ${execution.executed_at}`);
    
    // Your custom logic here
    // - Update charts
    // - Trigger alerts
    // - Calculate metrics
  }

  getRecentExecutions(market, count = 10) {
    return this.executions
      .filter(e => e.market === market)
      .slice(-count);
  }

  getTotalVolume(market) {
    return this.volumeByMarket.get(market) || 0;
  }
}

{
  "type": "unsubscribe",
  "channels": [
    {
      "type": "execution_data",
      "params": {
        "market": "BTCUSD"
      }
    }
  ]
}

{
  "type": "subscription_list"
}

{
  "type": "subscription_list",
  "channels": [
    {
      "type": "execution_data",
      "params": {
        "market": "BTCUSD"
      }
    },
    {
      "type": "execution_data",
      "params": {
        "market": "ETHUSD"
      }
    }
  ]
}