面向 AI 代理与设备群的 P2P 带宽网络。

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

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

// 使用注册响应返回的 relay（按地域分配），不要硬编码。
const net = require('net');
const WebSocket = require('ws');
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' } }));
  // 必需：节点每 30 秒发送一次 heartbeat，中继回复 heartbeat_ack
  setInterval(() => ws.send(JSON.stringify({ type: 'heartbeat', payload: {} })), 30000);
});

ws.on('message', (raw, isBinary) => {
  if (isBinary && raw[0] !== 0x7B) {              // binary-v1 数据帧
    const len = raw[1], sid = raw.slice(2, 2 + len).toString('utf-8');
    const sock = tunnels.get(sid);
    if (raw[0] === MSG_TUNNEL_DATA && sock) sock.write(raw.slice(2 + len));
    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"}'

# 参考客户端会自行注册、刷新令牌并处理隧道协议
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")

// SDK 声明的权限：INTERNET, ACCESS_NETWORK_STATE, ACCESS_WIFI_STATE,
// FOREGROUND_SERVICE, FOREGROUND_SERVICE_DATA_SYNC, WAKE_LOCK, READ_PHONE_STATE
// Android 13+ 需在运行时请求 POST_NOTIFICATIONS

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

ProxiesPeerSDK.getInstance().start()  // 前台服务启动
ProxiesPeerSDK.getInstance().stop()

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

// 协程版本
val result = sdk.rotateIPAsync()