Peer-to-peer сеть трафика для ИИ-агентов и парков устройств.

curl -s -X POST https://api.proxies.sx/v1/peer/agents/register \
  -H "Content-Type: application/json" \
  -d '{
    "name":"my-agent",
    "type":"claude",
    "walletAddress":"YOUR_SOLANA_ADDRESS",
    "apiKey":"psx_YOUR_API_KEY"
  }'

# Ответ:
# {
#   "deviceId": "agent_abc123",
#   "jwt": "eyJ...",
#   "refreshToken": "a1b2...",
#   "relay": "wss://relay.proxies.sx",
#   "earningsPerGB": { "mobile": "...", "residential": "...", "datacenter": "..." }
# }

// Используйте relay из ответа регистрации — НЕ хардкодьте.
// Платформа гео-привязывает к ближайшему relay (US/LATAM пиры идут на
// wss://relay-us.proxies.sx). Удалённый relay режет одиночный TCP-стрим
// латентностью. Уважайте сообщение relay_redirect для рантайм-миграции.
const ws = new WebSocket(registerResponse.relay, [`token.${JWT}`]);
const tunnels = new Map();
const MSG_TUNNEL_DATA = 0x01, MSG_TUNNEL_CLOSE = 0x03;
const encode = (type, sid, data) => {
  const s = Buffer.from(sid, 'utf-8');
  return Buffer.concat([Buffer.from([type, s.length]), s, data || Buffer.alloc(0)]);
};

ws.on('open', () => {
  ws.send(JSON.stringify({ type: 'device_info', payload: { country: 'US', protocol: 'binary-v1' } }));
  // Heartbeat шлёт ПИР каждые 30 с; relay отвечает heartbeat_ack
  setInterval(() => ws.send(JSON.stringify({ type: 'heartbeat', payload: {} })), 30000);
});

ws.on('message', (raw, isBinary) => {
  if (isBinary && raw[0] !== 0x7B) {             // binary-v1 фрейм
    const sid = raw.slice(2, 2 + raw[1]).toString('utf-8');
    const sock = tunnels.get(sid);
    if (raw[0] === MSG_TUNNEL_DATA && sock) sock.write(raw.slice(2 + raw[1]));
    if (raw[0] === MSG_TUNNEL_CLOSE && sock) sock.destroy();
    return;
  }
  const msg = JSON.parse(raw.toString());
  if (msg.type === 'tunnel_connect') {           // HTTP и HTTPS
    const { sessionId, host, port } = msg.payload;
    const sock = net.connect(port, host);
    tunnels.set(sessionId, sock);
    sock.on('connect', () => ws.send(JSON.stringify({ type: 'tunnel_connected', payload: { sessionId } })));
    sock.on('data', (d) => ws.send(encode(MSG_TUNNEL_DATA, sessionId, d)));  // сырые байты
    sock.on('close', () => {
      tunnels.delete(sessionId);
      ws.send(JSON.stringify({ type: 'tunnel_closed', payload: { sessionId } }));
    });
  }
});

curl -s "https://api.proxies.sx/v1/peer/agents/${DEVICE_ID}/earnings" \
  -H "Authorization: Bearer $JWT" | jq

curl -s -X POST "https://api.proxies.sx/v1/peer/agents/${DEVICE_ID}/withdraw" \
  -H "Authorization: Bearer $JWT" \
  -H "Content-Type: application/json" \
  -d '{"walletAddress":"YOUR_SOLANA_ADDRESS"}'

# Референсный Node-клиент сам регистрируется и держит туннели
curl -O https://agents.proxies.sx/peer/reference-sdk.js
docker run -d --name proxies-peer --restart unless-stopped \
  -e API_KEY=psx_YOUR_KEY \
  -v "$PWD/reference-sdk.js:/app/reference-sdk.js:ro" -w /app \
  node:20-alpine node reference-sdk.js

// settings.gradle — добавьте JitPack
dependencyResolutionManagement {
  repositories {
    mavenCentral()
    maven { url 'https://jitpack.io' }
  }
}

// build.gradle (app-level)
implementation("com.github.bolivian-peru:android-peer-sdk:1.3.2")

// Permissions (manifest merge): INTERNET, ACCESS_NETWORK_STATE, ACCESS_WIFI_STATE,
// FOREGROUND_SERVICE, FOREGROUND_SERVICE_DATA_SYNC, WAKE_LOCK, READ_PHONE_STATE
// POST_NOTIFICATIONS — запрашивайте в рантайме на Android 13+

ProxiesPeerSDK.init(
  context = applicationContext,
  apiKey  = "psx_YOUR_KEY",
  config  = ProxiesPeerSDK.Config(
    userId           = "optional-user-id",
    onStatusChange   = { status -> /* CONNECTING | CONNECTED | ... */ },
    onEarningsUpdate = { earnings -> /* earnings.totalEarnedCents */ },
  )
)

ProxiesPeerSDK.getInstance().start()  // foreground-сервис запускается
ProxiesPeerSDK.getInstance().stop()

if (sdk.isIPRotationAvailable()) {
  sdk.rotateIP(object : IPRotationListener {
    override fun onRotationComplete(result: IPRotationResult) {
      println("New IP: ${result.newIp}")
    }
  })
} else {
  sdk.openIPRotationSettings()
}

// Coroutine-версия
val result = sdk.rotateIPAsync()