聊天室进阶：KV、保活、优先级与禁言

import { AppClient } from '@ni-paas-im/server-sdk';

const app = new AppClient({
  appKey: process.env.IM_APP_KEY,
  appSecret: process.env.IM_APP_SECRET,
  baseUrl: 'http://127.0.0.1:8080',
});

// 1) 创建（chatroomId 可省略，服务端生成）
const room = await app.createChatroom({ chatroomId: 'live_1001', name: '新品发布会', owner: 'anchor_1' });

// 2) 定时销毁：创建后 2 小时销毁，活动不延长
await app.openApi('chatroom.destroy.policy.set', {
  chatroomId: room.chatroomId,
  destroyType: 'fixed',
  idleMs: 2 * 60 * 60 * 1000,
});

// 3) 恢复空闲销毁（默认 30 分钟）
await app.openApi('chatroom.destroy.policy.set', {
  chatroomId: room.chatroomId,
  destroyType: 'idle',
  idleMs: 1800000,
});

// 4) 主动销毁：踢人 + 广播 destroyed + 清理房间级状态
await app.destroyChatroom({ chatroomId: room.chatroomId });

// 公告写入：30 分钟后自动过期（房间销毁时一并清理）
await app.openApi('chatroom.kv.set', {
  chatroomId: 'live_1001',
  key: 'announcement',
  value: JSON.stringify({ text: '21:00 抽奖，请留在直播间', pinnedAt: Date.now() }),
  ttlMs: 30 * 60 * 1000,
});

// 读取单个键 + 读取全部
const one = await app.openApi('chatroom.kv.get', { chatroomId: 'live_1001', keys: ['announcement'] });
const all = await app.openApi('chatroom.kv.get', { chatroomId: 'live_1001' });

// 删除公告
await app.openApi('chatroom.kv.remove', { chatroomId: 'live_1001', key: 'announcement' });

// 长期活动房间：保活 3 个月，避免空闲销毁
await app.openApi('chatroom.keepalive', { chatroomId: 'live_1001' });

// 查询应用下当前处于保活状态的聊天室
const { chatroomIds } = await app.openApi('chatroom.keepalive.get', {});

// 释放保活：恢复空闲销毁计时（下次活动起重新计算）
await app.openApi('chatroom.keepalive.remove', { chatroomId: 'live_1001' });

// 高并发直播间：图片/文件/位置按低优先级渲染（配置全量覆盖）
await app.openApi('chatroom.message.priority.set', {
  chatroomId: 'live_1001',
  messageTypes: ['image', 'file', 'location'],
});

const { lowPriorityTypes } = await app.openApi('chatroom.message.priority.list', {
  chatroomId: 'live_1001',
});
console.log(lowPriorityTypes); // ['image','file','location']

// 房主/管理员：禁言 10 分钟 + 全员禁言 + 白名单豁免
const mutedUntil = Date.now() + 10 * 60 * 1000;
await app.openApi('chatroom.mute', { chatroomId: 'live_1001', userId: 'spammer_1', mutedUntil });

await app.openApi('chatroom.mute-all', { chatroomId: 'live_1001', muted: true, operatorId: 'anchor_1' });

// 运营号/管理员进白名单：不受禁言/封禁/全员禁言影响
await app.openApi('chatroom.whitelist.add', { chatroomId: 'live_1001', userIds: ['ops_1', 'anchor_1'] });

// 封禁恶意用户（立即踢出，不可再加入）
await app.openApi('chatroom.ban', { chatroomId: 'live_1001', userId: 'spammer_1', banned: true });

import { createClient, ConversationType, Events } from '@ni-paas/im-web';

const client = createClient({ appkey: 'YOUR_APP_KEY', serverUrl: 'http://127.0.0.1:8080' });
await client.connect(TOKEN);

client.addEventListener(Events.CHATROOM_EVENT, (event) => {
  // kind: joined | left | kicked | destroyed | member_changed
  console.log(event.chatroomId, event.kind, event.onlineCount);
});

const room = await client.createChatroom({ chatroomId: 'live_1001', name: '新品发布会', owner: 'anchor_1' });
await client.joinChatroom(room.chatroomId);

client.addEventListener(Events.MESSAGES, ({ messages }) => {
  for (const message of messages) {
    if (message.conversationType === ConversationType.CHATROOM) renderDanmaku(message);
  }
});

// 聊天室消息：仅广播在线成员，无 ack、无历史
await client.sendTextMessage(ConversationType.CHATROOM, 'live_1001', '主播好！');
const { onlineCount, members } = await client.getChatroomInfo('live_1001').then(async (info) => ({
  onlineCount: info.onlineCount,
  members: await client.getChatroomMembers('live_1001', { offset: 0, limit: 50 }),
}));
await client.leaveChatroom('live_1001');

val client = IMClient.init(applicationContext, IMClientOptions(appkey = "YOUR_APP_KEY", serverUrl = "http://127.0.0.1:8080"))
client.connect(token, object : ConnectCallback {
    override fun onSuccess(userId: String) {
        client.addEventListener(IMClientEvent.CHATROOM_EVENT) { event ->
            // event.kind: joined / left / kicked / destroyed / member_changed
            Log.d("chatroom", "${event.chatroomId} ${event.kind}")
        }
        client.createChatroom(CreateChatroomOptions(chatroomId = "live_1001", name = "新品发布会", owner = "anchor_1")) { created ->
            client.joinChatroom(created.chatroomId, object : ResultCallback<Chatroom> {
                override fun onSuccess(room: Chatroom) = Unit
                override fun onError(error: IMError) = Log.e("chatroom", "${error.code} ${error.message}")
            })
        }
    }
    override fun onError(error: IMError) = Log.e("chatroom", "${error.code} ${error.message}")
})

final engine = await RCIMIWEngine.create(
  'YOUR_APP_KEY',
  RCIMIWEngineOptions.create(naviServer: 'http://127.0.0.1:8080'),
);
await client.connect(token);

client.addEventListener('CHATROOM_EVENT', (event) {
  // event.kind: joined / left / kicked / destroyed / member_changed
  debugPrint('${event.chatroomId} ${event.kind}');
});

final room = await client.createChatroom(chatroomId: 'live_1001', name: '新品发布会', owner: 'anchor_1');
await client.joinChatroom(room.chatroomId);
await client.sendTextMessage(3, 'live_1001', '主播好！'); // 3 = ConversationType.CHATROOM
final info = await client.getChatroomInfo('live_1001');
final page = await client.getChatroomMembers('live_1001', offset: 0, limit: 50);
await client.leaveChatroom('live_1001');