Разработка Telegram-бота для P2P-обменника

Разработка API для управления торговым ботом

Торговый бот без API управления — монолит: чтобы изменить параметр, нужно лезть на сервер, редактировать конфиг, перезапускать. Management API решает это: бот управляется удалённо через HTTP или WebSocket, параметры меняются на лету без перезапуска.

Архитектура Management API

Основные эндпоинты

// Bot lifecycle
POST   /api/v1/bot/start                 - запустить бота
POST   /api/v1/bot/stop                  - остановить
POST   /api/v1/bot/pause                 - пауза (не открывает новые позиции)
GET    /api/v1/bot/status                - текущий статус

// Конфигурация
GET    /api/v1/bot/config                - текущие параметры
PUT    /api/v1/bot/config                - обновить параметры (hot reload)

// Мониторинг
GET    /api/v1/bot/stats                 - P&L, метрики
GET    /api/v1/bot/positions             - открытые позиции
GET    /api/v1/bot/trades?from=&to=      - история сделок
GET    /api/v1/bot/logs?level=&limit=    - логи в реальном времени

// Ручные операции
POST   /api/v1/bot/close-all             - принудительно закрыть все позиции
POST   /api/v1/bot/cancel-pending        - отменить pending ордера

Hot reload конфигурации

type BotConfig struct {
    mu              sync.RWMutex
    Symbol          string          `json:"symbol"`
    Timeframe       string          `json:"timeframe"`
    PositionSizePct float64         `json:"position_size_pct"`
    StopLossPct     float64         `json:"stop_loss_pct"`
    TakeProfitPct   float64         `json:"take_profit_pct"`
    MaxPositions    int             `json:"max_positions"`
    Enabled         bool            `json:"enabled"`
}

func (c *BotConfig) Update(newConfig map[string]interface{}) error {
    c.mu.Lock()
    defer c.mu.Unlock()
    
    // Валидация
    if sl, ok := newConfig["stop_loss_pct"].(float64); ok {
        if sl < 0.1 || sl > 50 {
            return errors.New("stop_loss_pct must be between 0.1 and 50")
        }
        c.StopLossPct = sl
    }
    
    if pct, ok := newConfig["position_size_pct"].(float64); ok {
        if pct < 1 || pct > 100 {
            return errors.New("position_size_pct must be between 1 and 100")
        }
        c.PositionSizePct = pct
    }
    
    // Бот подхватит новые параметры на следующем цикле
    return nil
}

// Handler для PUT /config
func (h *Handler) UpdateConfig(w http.ResponseWriter, r *http.Request) {
    var updates map[string]interface{}
    json.NewDecoder(r.Body).Decode(&updates)
    
    if err := h.bot.Config.Update(updates); err != nil {
        writeError(w, 400, err.Error())
        return
    }
    
    writeJSON(w, map[string]interface{}{
        "success": true,
        "config": h.bot.Config.Get(),
    })
}

WebSocket для real-time мониторинга

// Бот публикует события в канал, API транслирует через WebSocket
type BotEvent struct {
    Type      string      `json:"type"`   // trade, signal, error, status_change
    Timestamp int64       `json:"ts"`
    Data      interface{} `json:"data"`
}

func (api *ManagementAPI) StreamEvents(w http.ResponseWriter, r *http.Request) {
    conn, _ := upgrader.Upgrade(w, r, nil)
    defer conn.Close()
    
    subscription := api.bot.EventBus.Subscribe()
    defer api.bot.EventBus.Unsubscribe(subscription)
    
    for {
        select {
        case event := <-subscription:
            conn.WriteJSON(event)
        case <-r.Context().Done():
            return
        }
    }
}

Аутентификация Management API

Management API управляет реальными деньгами — доступ должен быть строго ограничен:

func authMiddleware(secret string) func(http.Handler) http.Handler {
    return func(next http.Handler) http.Handler {
        return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
            token := r.Header.Get("Authorization")
            if !strings.HasPrefix(token, "Bearer ") {
                writeError(w, 401, "Unauthorized")
                return
            }
            
            if token[7:] != secret {
                writeError(w, 401, "Invalid token")
                return
            }
            
            next.ServeHTTP(w, r)
        })
    }
}

Bind только на localhost или через VPN — Management API не должен быть открыт в интернет напрямую.

Dashboard (опциональный UI)

Простой веб-интерфейс для управления ботом:

// React компонент управления ботом
function BotDashboard() {
  const [status, setStatus] = useState<BotStatus | null>(null);
  
  // WebSocket для real-time обновлений
  useEffect(() => {
    const ws = new WebSocket(`ws://localhost:8080/ws/events`);
    ws.onmessage = (e) => {
      const event = JSON.parse(e.data);
      if (event.type === 'status_change') setStatus(event.data);
      if (event.type === 'trade') addTrade(event.data);
    };
    return () => ws.close();
  }, []);
  
  const toggleBot = async () => {
    await fetch(`/api/v1/bot/${status?.running ? 'stop' : 'start'}`, { method: 'POST' });
  };
  
  return (
    <div>
      <StatusCard status={status} onToggle={toggleBot} />
      <PnLChart />
      <OpenPositions />
      <ConfigEditor onSave={(config) => updateConfig(config)} />
    </div>
  );
}

Management API для торгового бота с hot reload конфига, WebSocket стримингом и базовым dashboard разрабатывается за 2–3 недели.