┌─────────────────── MAIN LOOP (async, 30s) ───────────────────┐
│  main_async.py — главный цикл (asyncio)                      │
│                                                               │
│  Каждый цикл:                                                 │
|    • state_db.py        — SQLite SSOT (WAL, 11 таблиц)       |
|    • unified_sl.py      — Unified SL (5 механизмов → 1)      |
│    • auto_tp.py         — ATR-based TP (1.0×/2.0×/3.0× ATR)  │
│    • time_exit.py       — Time exit (6ч/48ч)                  │
│    • риск-менеджмент     — Circuit breaker, BlackSwan 3-tier  │
│                                                               │
│  Каждые 10 циклов (HEAVY, ~5 мин):                            │
│    • auto_entry.py      — авто-LONG (MTF+OB+Volume+Judge)    │
│    • auto_short.py      — авто-SHORT + Dry Spell Throttle     │
│    • pump_detect.py     — детект пампов (24ч/нед)            │
│    • correlation.py     — корреляционная матрица              │
│    • dca.py             — DCA-докупки                         │
│                                                               │
│  Раз в сутки (2880 циклов):                                   │
│    • post_trade.py      — кластерный анализ (WR<40% → блок)  │
│    • journal/self_learn.py — self-learning + canary v3       │
│                                                               │
│  Импорт истории (каждый цикл):                                │
│    • Bybit closed-pnl → trades.jsonl                          │
│    • → post_trade_features.jsonl (с 30.06)                    │
│                                                               │
└───────────────────────────────────────────────────────────────┘
         │
         ▼ RPC (порт 8766) + WS push (порт 8768)
    • rpc.py              — JSON-RPC, /metrics Prometheus
    • push_notifier.py    — ntfy + Telegram алерты

1. pump_detect.py → памп +80% за 24ч
2. auto_short.py → лимитка Sell +2%, TP Middle BB, DCA +100%/+120%
3. check_junk_dca() → проверка max_loss/max_hold/DCA-уровней
4. junk_trail.py → профит >15%: TP подтянут (фиксация 70%)
5. junk_trail.py → профит >30%: TP затянут (фиксация 85%)
6. TP срабатывает → позиция закрыта с прибылью

🔴 SHORT JUNK HMSTR: вход $0.000373 лимит $0.000380 ×664190 (3x) | памп +120% | TP $0.000112 | DCA: +100% @ $0.000746, +120% @ $0.000821

🔴 SHORT MOVE: вход $0.0143 лимит $0.0146 ×700 (3x) | BB=92% | SL $0.0150 (+5%) | TP $0.0120

🔴 DCA JUNK HMSTR: +100% @ $0.000746 ×664190 | вход $0.000373 → сейчас $0.000750

🔒 JUNK Trail TP HMSTR: фиксация 70% при +22.5% | вход $0.000373 → TP $0.000210 (был $0.000112)

🛑 STOP JUNK HMSTR: убыток -16.2% > лимит 15% | вход $0.000373 → выход $0.000433 | PnL $-12.40

⏰ TIMEOUT JUNK HMSTR: 49ч > 48ч лимит | выход $0.000380 | PnL $-1.20

curl http://localhost:8766/health          # статус
curl http://localhost:8766/positions       # позиции (read)
curl http://localhost:8766/scan?mode=short # сканирование рынка
curl -H "Authorization: Bearer $TOKEN" \
     -X POST http://localhost:8766/enter   # вход (write, требует auth)

# AI-агенты (Claude Code, Codex, Cursor, Hermes) подключаются напрямую
mcp_bybit_ws_get_positions()   # позиции + PnL + SL
mcp_bybit_ws_scan_market()     # BB-сигналы LONG/SHORT
mcp_bybit_ws_get_metrics()     # дневная статистика
mcp_bybit_ws_vpn_status()      # VPN + трафик

from bybit_ws_sdk import Monitor
m = Monitor("http://localhost:8766", token="your-token")

# Сканирование рынка
signals = m.scan(mode="short", limit=5)
for s in signals["signals"]:
    preview = m.enter(s["symbol"], "Sell", s["qty"], confirm=False)
    print(f"Preview {s['symbol']}: sell {preview['qty']} @ market")
    m.enter(s["symbol"], "Sell", s["qty"], confirm=True)

# Позиции и метрики
positions = m.positions()          # все позиции + PnL + SL
metrics = m.metrics()              # дневная статистика (SL/TP/entries)
pnl = sum(p["upnl"] for p in positions["positions"])  # общий PnL

# Управление
m.set_sl("DOGEUSDT", 0.075)        # set stop-loss
m.close("APTUSDT")                 # закрыть позицию по рынку
m.cancel_all()                     # отменить все ордера

git clone https://github.com/poliakarmai/bybit-ws.git
cd bybit-ws
python3 -m venv .venv && source .venv/bin/activate
pip install -r requirements.txt
cp config.example.yaml ~/.config/bybit-ws/config.yaml
cp .env.example ~/.config/bybit-ws/.env
nano ~/.config/bybit-ws/.env    # BYBIT_API_KEY, BYBIT_API_SECRET
python3 -m bybit_ws              # запуск

mkdir -p ~/.config/systemd/user
cp bybit-ws.service ~/.config/systemd/user/
# Убедись что путь в ExecStart ведёт к bybit-ws:
which bybit-ws                    # должно быть ~/.local/bin/bybit-ws
systemctl --user daemon-reload
systemctl --user enable --now bybit-ws
systemctl --user status bybit-ws  # проверка
journalctl --user -u bybit-ws -f  # логи

docker compose up -d

api:
  key: "${BYBIT_API_KEY}"
  secret: "${BYBIT_API_SECRET}"
  base_url: "https://api-testnet.bybit.com"

strategy:
  long:
    leverage: 3
    max_positions: 12           # макс одновременных LONG-позиций (hard limit)
    sl_offset: 0.07
  short:
    leverage: 3
    max_positions: 3            # макс одновременных SHORT (включая JUNK)
    bb_threshold: 85
  junk:                          # 🆕 JUNK-шорты
    daily_pump_threshold: 0.80   # 80% рост за 24ч
    weekly_pump_threshold: 2.30  # 230% за неделю
    dca_levels: [1.0, 1.2]     # DCA на +100% и +120%
    max_loss_pct: 15            # hard stop при −15% маржи
    max_hold_hours: 48          # авто-закрытие через 48ч

risk:
  max_drawdown_pct: 15
  max_daily_loss: 50
  emergency_close_all: true

position_sizing:
  long_risk_pct: 0.20           # 20% депозита в риске
  max_positions: 5              # база для расчёта маржи: депозит × risk% / N позиций
  max_position_share: 0.40      # не более 40% бюджета на позицию

rpc:
  port: 8766
  auth_token: "${RPC_TOKEN}"

Команды:
  /scan              Топ-5 LONG-сигналов
  /scan short        Топ-5 SHORT
  /scan scalp        BB Scalping x10
  /scan mean         Mean Reversion x10
  /pro               GridSignal Pro (безлимит)