多端在线与多设备同步

// dual-session.mjs — 同一用户开两个 WS 会话，验证「多端副本 + 用户级游标」
// 运行：node dual-session.mjs（Node.js 22+，使用全局 WebSocket，无需安装依赖）
// 前置：服务端已启动；已注册 alice/bob；已取得 alice 的 Token。
const HOST = process.env.IM_HOST || 'http://127.0.0.1:8080';
const APPKEY = process.env.IM_APPKEY || 'demo';           // 变量：控制台创建应用后的 AppKey
const TOKEN = process.env.IM_TOKEN || 'YOUR_USER_TOKEN';   // 变量：alice 的 JWT（见下方 curl）

const wsUrl = HOST.replace(/^http/, 'ws') + '/ws?appkey=' + encodeURIComponent(APPKEY) +
  '&token=' + encodeURIComponent(TOKEN);

function open(label) {
  const ws = new WebSocket(wsUrl);
  ws.addEventListener('open', () => console.log('[' + label + '] open'));
  ws.addEventListener('message', (ev) => {
    const frame = JSON.parse(ev.data);
    if (frame.type === 'hello') {
      console.log('[' + label + '] hello sessionId=' + frame.data.sessionId);
      console.log('[' + label + '] syncState=' + JSON.stringify(frame.data.syncState));
    } else if (frame.type === 'message') {
      console.log('[' + label + '] message seq=' + frame.data.message.seq +
        ' direction=' + frame.data.message.direction + ' from=' + frame.data.message.senderId);
    } else if (frame.type === 'sync_done') {
      console.log('[' + label + '] sync_done count=' + frame.data.count);
    } else if (frame.type === 'send_ack') {
      console.log('[' + label + '] send_ack seq=' + frame.data.seq);
      // 客户端「持久化成功」后 ack：推进该用户此会话的 deliveredSeq。
      ws.send(JSON.stringify({ id: 'ack-' + frame.data.messageId, type: 'ack',
        data: { messageId: frame.data.messageId } }));
    } else if (frame.type === 'kick') {
      console.log('[' + label + '] KICK code=' + frame.data.code + ' reason=' + frame.data.reason);
    } else if (frame.type === 'error') {
      console.log('[' + label + '] error ' + JSON.stringify(frame.data));
    }
  });
  ws.addEventListener('close', (ev) => console.log('[' + label + '] close code=' + ev.code));
  return ws;
}

const a = open('A');
const b = open('B');

// 等两端都收到 hello/sync_done 后，由 A 发一条单聊消息给 bob；B 应收到 direction=1 的副本。
setTimeout(() => {
  a.send(JSON.stringify({ id: 'send-1', type: 'send', data: {
    conversationType: 1, targetId: 'bob',
    content: { type: 'text', text: 'hello from session A' },
    clientMsgId: 'c_' + Date.now()
  } }));
}, 1000);

setTimeout(() => { a.close(); b.close(); }, 4000);

// kick.mjs — 观察封禁后的 kick 帧与连接关闭
// 运行：node kick.mjs（Node.js 22+）
// 另一个终端执行封禁（把 <TOKEN> 换成被观察用户的 Token，<USER> 换成该用户 ID）：
//   curl -sS -X POST http://127.0.0.1:8080/api/admin/apps/demo/users/<USER>/ban \
//     -H 'X-Admin-Secret: dev-admin' -H 'content-type: application/json' \
//     -d '{"banned":true,"reason":"policy"}'
const HOST = process.env.IM_HOST || 'http://127.0.0.1:8080';
const APPKEY = process.env.IM_APPKEY || 'demo';
const TOKEN = process.env.IM_TOKEN || 'YOUR_USER_TOKEN';

const ws = new WebSocket(HOST.replace(/^http/, 'ws') + '/ws?appkey=' +
  encodeURIComponent(APPKEY) + '&token=' + encodeURIComponent(TOKEN));
ws.addEventListener('message', (ev) => {
  const frame = JSON.parse(ev.data);
  if (frame.type === 'kick') console.log('kick:', frame.data.code, frame.data.reason);
});
ws.addEventListener('close', (ev) => console.log('closed:', ev.code, ev.reason));

# 该用户的会话列表（每个在线端一行；device 当前恒为空）
curl -sS "http://127.0.0.1:8080/api/admin/apps/demo/connections?userId=alice" \
  -H 'X-Admin-Secret: dev-admin'

# 应用维度连接统计（在线用户数 / 会话数 / 今日峰值）
curl -sS "http://127.0.0.1:8080/api/admin/apps/demo/connections/stats" \
  -H 'X-Admin-Secret: dev-admin'