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}`]);

ws.onopen = () => {
  ws.send(JSON.stringify({ type: 'device_info', payload: { country: 'US' } }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === 'proxy_request') {
    const { requestId, method, url, headers, body } = msg.payload;
    fetch(url, { method, headers, body: body ? atob(body) : undefined })
      .then(async (res) => {
        const buf = await res.arrayBuffer();
        ws.send(JSON.stringify({
          type: 'proxy_response',
          payload: {
            requestId,
            statusCode: res.status,
            headers: Object.fromEntries(res.headers),
            body: btoa(String.fromCharCode(...new Uint8Array(buf))),
          },
        }));
      });
  }
  if (msg.type === 'heartbeat') ws.send(JSON.stringify({ type: 'heartbeat_ack' }));
};

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"}'

# Сначала зарегистрируйтесь, потом запускайте:
docker run -d --name proxies-peer \
  -e DEVICE_ID=agent_abc123 \
  -e JWT=eyJ... \
  -e RELAY_URL=wss://relay.proxies.sx \
  --restart unless-stopped \
  ghcr.io/proxies-sx/peer:latest

curl -s -X POST https://api.proxies.sx/v1/peer-auth/register \
  -H "Content-Type: application/json" \
  -d '{
    "email": "newpeer@example.com",
    "password": "SecurePass123!",
    "name": "New Peer",
    "referralCode": "PEER_ABC123"
  }'

curl -s https://api.proxies.sx/v1/peer-account/referrals \
  -H "Authorization: Bearer $JWT"

# Ответ:
# {
#   "referralCode": "PEER_ABC123",
#   "referralCount": 5,
#   "referralEarningsCents": 1250,
#   "referredUsers": [...]
# }

// 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.0")

// Permissions: INTERNET, ACCESS_NETWORK_STATE, FOREGROUND_SERVICE,
// FOREGROUND_SERVICE_DATA_SYNC, WAKE_LOCK, POST_NOTIFICATIONS (Android 13+)

ProxiesPeerSDK.init(
  context  = applicationContext,
  apiKey   = "psx_YOUR_KEY",
  config   = Config(
    walletAddress         = "YOUR_SOLANA",
    mobileDataOnly        = false,
    onlyWhenCharging      = false,
    maxBandwidthMBPerHour = null,
    onStatusChange        = { status -> /* online | offline | error */ },
    onEarningsUpdate      = { earnings -> /* копейки, GB */ },
  )
)

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()