Интеграция бота с API Coinbase

Интеграция бота с API Coinbase

Coinbase Advanced Trade API (бывший Coinbase Pro) — профессиональный API для алгоритмической торговли. Отличается от Coinbase Simple: поддерживает limit/market/stop ордера, WebSocket feed, детальную историю. Ключевая особенность — переход на JWT аутентификацию в 2024 году.

Аутентификация через JWT

Coinbase Advanced Trade API использует JWT (JSON Web Token) с ES256 алгоритмом:

import jwt
import time
from cryptography.hazmat.primitives.asymmetric import ec

def generate_jwt(api_key: str, private_key_pem: str) -> str:
    """
    api_key: строка вида "organizations/{org_id}/apiKeys/{key_id}"
    private_key_pem: EC private key в PEM формате
    """
    private_key = serialization.load_pem_private_key(
        private_key_pem.encode(), password=None
    )
    
    payload = {
        'sub': api_key,
        'iss': 'coinbase-cloud',
        'nbf': int(time.time()),
        'exp': int(time.time()) + 120,  # JWT действителен 2 минуты
    }
    
    return jwt.encode(payload, private_key, algorithm='ES256',
                      headers={'kid': api_key, 'nonce': secrets.token_hex(16)})

# Каждый запрос требует свежего JWT
async def api_request(method: str, path: str, body: dict = None):
    token = generate_jwt(API_KEY, PRIVATE_KEY)
    headers = {
        'Authorization': f'Bearer {token}',
        'Content-Type': 'application/json',
    }
    async with aiohttp.ClientSession() as session:
        async with session.request(method, BASE_URL + path, 
                                    headers=headers, json=body) as resp:
            return await resp.json()

Основные торговые операции

# Размещение ордера
async def place_order(product_id: str, side: str, order_type: str, 
                       size: str, price: str = None) -> dict:
    body = {
        'client_order_id': str(uuid.uuid4()),
        'product_id': product_id,  # 'BTC-USD'
        'side': side,               # 'BUY' или 'SELL'
        'order_configuration': {}
    }
    
    if order_type == 'market':
        if side == 'BUY':
            body['order_configuration']['market_market_ioc'] = {'quote_size': size}
        else:
            body['order_configuration']['market_market_ioc'] = {'base_size': size}
    elif order_type == 'limit':
        body['order_configuration']['limit_limit_gtc'] = {
            'base_size': size,
            'limit_price': price,
            'post_only': False,
        }
    
    return await api_request('POST', '/api/v3/brokerage/orders', body)

# Отмена ордера
async def cancel_orders(order_ids: list[str]) -> dict:
    return await api_request('POST', '/api/v3/brokerage/orders/batch_cancel',
                              {'order_ids': order_ids})

WebSocket feed

import websockets

async def subscribe_market_data():
    async with websockets.connect('wss://advanced-trade-ws.coinbase.com') as ws:
        # Подписка с JWT аутентификацией
        token = generate_jwt(API_KEY, PRIVATE_KEY)
        await ws.send(json.dumps({
            'type': 'subscribe',
            'product_ids': ['BTC-USD', 'ETH-USD'],
            'channel': 'ticker',
            'jwt': token,
        }))
        
        async for message in ws:
            data = json.loads(message)
            if data['channel'] == 'ticker':
                for event in data['events']:
                    process_ticker(event)

Coinbase также поддерживает CCXT для унифицированного доступа, но прямое API даёт больше возможностей (batch cancel, advanced order types).

Интеграция с Coinbase Advanced Trade API: 1–2 недели с учётом JWT аутентификации и тестирования на sandbox среде.