房间管理（iOS）

import Foundation
import AtomicXCore

private let roomID = "webinar_123456"
private let roomType = .webinar

func createAndJoinRoom() {
    // 1. 配置房间创建参数
    // CreateRoomOptions 定义房间的基础属性和成员管理配置信息    
    var options = CreateRoomOptions()
    options.roomName = "团队会议室"           // 房间显示名称
    options.password = ""                   // 房间密码（可选）
    
    // 2. 房间权限预设
    options.isAllCameraDisabled = false     // 是否禁用所有成员摄像头
    options.isAllMessageDisabled = false    // 是否禁言所有成员
    options.isAllMicrophoneDisabled = false // 是否静音所有成员
    options.isAllScreenShareDisabled = false // 是否禁止所有成员屏幕分享

    // 3. 创建并加入房间
    // 该方法会自动处理房间创建（如果不存在）和加入逻辑
    RoomStore.shared.createAndJoinRoom(roomID: roomID, roomType: roomType, options: options) { result in
        switch result {
        case .success():
            print("成功创建并加入房间")
        case .failure(let error):
            print("创建并加入房间失败 [错误码: \\(error.code)]: \\(error.message)")
        }
    }
}

import Foundation
import AtomicXCore

private let roomID = "webinar_123456"
private let roomType = .webinar

func joinRoom() {
    // 1. 准备加入房间参数
    // joinRoom 适用于加入一个已知且正在进行的房间
    let roomPassword = "" // 房间密码，若房间未设置密码则传空字符串或 nil
    
    // 2. 调用 RoomStore 加入房间接口
    // 该操作会验证房间是否存在、用户是否被禁入以及密码是否正确
    RoomStore.shared.joinRoom(roomID: roomID, roomType: roomType, password: roomPassword) { result in
        switch result {
        case .success():
            print("加入房间成功")
        case .failure(let error):
            print("加入房间失败 [错误码: \\(error.code)]: \\(error.message)")
        }
    }
}

import Foundation
import AtomicXCore

func leaveRoom() {
    // 1. 业务逻辑说明
    // leaveRoom 接口用于普通成员或房主主动退出房间
    // 与 endRoom 不同，房主调用 leaveRoom 只会让自己离开，房间依然存在
    
    // 2. 调用 RoomStore 离开房间接口
    // 该操作会停止音视频流传输，并通知服务器将当前用户移出房间
    RoomStore.shared.leaveRoom { result in
        switch result {
        case .success():
            print("离开房间成功")
        case .failure(let error):
            print("离开房间失败 [错误码: \\(error.code)]: \\(error.message)")
        }
    }
}


import Foundation
import AtomicXCore

func endRoom() {
    // 1. 业务逻辑说明
    // endRoom 接口用于永久解散当前房间
    // 注意：该操作通常仅限房主（Owner）执行，解散后所有成员将被强制退出
    
    // 2. 调用 RoomStore 解散房间接口
    // 该方法会向服务器发送解散指令，并通知所有在线参与者房间已结束
    RoomStore.shared.endRoom { result in
        switch result {
        case .success():
            print("解散房间成功")
        case .failure(let error):
            print("解散房间失败 [错误码: \\(error.code)]: \\(error.message)")
        }
    }
}


import Foundation
import AtomicXCore

private let roomID = "webinar_123456"

func updateRoomInfo() {
    // 1. 配置房间更新参数
    // UpdateRoomOptions 用于定义需要更新的房间属性
    var options = UpdateRoomOptions()
    options.roomName = "新的会议室名称"  // 更新房间显示名称
    
    // 2. 设置修改标志位
    // ModifyFlag 用于指定具体要更新哪些字段
    var modifyFlag: UpdateRoomOptions.ModifyFlag = []
    modifyFlag.insert(.roomName)       // 标记需要更新房间名称
    
    // 3. 调用 RoomStore 更新房间信息接口
    // 该方法会向服务器提交更新请求，并同步给所有房间成员
    RoomStore.shared.updateRoomInfo(roomID: roomID, options: options, modifyFlag: modifyFlag) { result in
        switch result {
        case .success():
            print("更新房间信息成功")
        case .failure(let error):
            print("更新房间信息失败 [错误码: \\(error.code)]: \\(error.message)")
        }
    }
}

import Foundation
import AtomicXCore

private let roomID = "webinar_123456"

func getRoomInfo() {
    // 1. 业务逻辑说明
    // getRoomInfo 接口用于获取指定房间的详细信息
    // 可以获取房间名称、创建者、参与者数量、权限设置等完整信息
    
    // 2. 调用 RoomStore 获取房间信息接口
    // 该操作会从服务器获取最新的房间状态和配置信息
    RoomStore.shared.getRoomInfo(roomID: roomID) { result in
        switch result {
        case .success(let roomInfo):
            print("获取房间信息成功，roomInfo: \\(roomInfo)")
        case .failure(let error):
            print("获取房间信息失败 [错误码: \\(error.code)]: \\(error.message)")
        }
    }
}

import Foundation
import AtomicXCore
import Combine

private var cancellableSet = Set<AnyCancellable>()

/// 设置房间事件监听器
private func subscribeRoomEvent() {
    RoomStore.shared.roomEventPublisher
        .receive(on: DispatchQueue.main) // 确保在主线程处理 UI 逻辑
        .sink { event in
            switch event {
            case .onRoomEnded(let roomInfo):
                print("当前所在房间已结束")
            default: break
            }
        }
        .store(in: &cancellableSet)
}

import Foundation
import AtomicXCore
import Combine

private var cancellableSet = Set<AnyCancellable>()

private func subscribeRoomState() {
    /// 设置当前房间状态监听器
    RoomStore.shared.state
        .subscribe(StatePublisherSelector(keyPath: \\.currentRoom))
        .receive(on: DispatchQueue.main) // 确保在主线程处理 UI 逻辑
        .sink { roomInfo in
            if let newRoomInfo = roomInfo {
                print("房间信息更新 新的房间信息: \\(newRoomInfo)")
            }
        }
        .store(in: &cancellableSet)
}