import AtomicXCore
import Foundation

// 预定房间
func scheduleRoom() {
    let startTime = Int(Date().timeIntervalSince1970) + 60 * 15 // 计算预定时间：当前时间 + 15分钟后开始
    let endTime = startTime + 60 * 30 // 计算结束时间：开始时间 + 30分钟（房间持续30分钟）
    let reminderSeconds = 60 * 5 // 设置提醒时间：房间开始前5分钟提醒
    
    // 创建预定房间选项配置
    var options = ScheduleRoomOptions()
    options.roomName = "房间名称"
    options.scheduleStartTime = startTime
    options.scheduleEndTime = endTime
    options.reminderSecondsBeforeStart = reminderSeconds
    options.scheduleAttendees = ["user01", "user02", "user03"] // 设置预定参与者列表（用户ID数组）
    options.password = "房间密码" // 设置房间密码（可选，空字符串表示无密码）
    options.isAllMicrophoneDisabled = false // 设置是否默认禁用所有参与者的麦克风（false = 允许开启麦克风）
    options.isAllCameraDisabled = false // 设置是否默认禁用所有参与者的摄像头（false = 允许开启摄像头）
    options.isAllScreenShareDisabled = false // 设置是否默认禁用所有参与者的屏幕共享（false = 允许屏幕共享）
    options.isAllMessageDisabled = false // 设置是否默认禁用所有参与者的消息功能（false = 允许发送消息）
    
    RoomStore.shared.scheduleRoom(roomID: "roomID", options: options) { result in
        switch result {
        case .success:
            print("预定房间成功")
        case .failure(let error):
            print("预定房间失败: [错误码: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation

// 取消房间预定
func cancelScheduledRoom(roomID: String) {
    RoomStore.shared.cancelScheduledRoom(roomID: roomID) { result in
        switch result {
        case .success:
            print("取消预定房间成功")
        case .failure(let error):
            print("取消预定房间失败: [错误码: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation

// 更新预定房间
func updateScheduledRoom() {
    let newStartTime = Int(Date().timeIntervalSince1970) + 60 * 30 // 计算预定时间：当前时间 + 30分钟后开始
    let newEndTime = newStartTime + 60 * 45 // 计算结束时间：开始时间 + 45分钟（房间持续30分钟）
    
    var options = ScheduleRoomOptions()
    options.roomName = "房间名称"
    options.scheduleStartTime = newStartTime
    options.scheduleEndTime = newEndTime
    
    var modifyFlag: ScheduleRoomOptions.ModifyFlag = []
    modifyFlag.insert(.roomName)
    modifyFlag.insert(.scheduleStartTime)
    modifyFlag.insert(.scheduleEndTime)
    
    RoomStore.shared.updateScheduledRoom(roomID: "roomID", options: options, modifyFlag: modifyFlag) { result in
        switch result {
        case .success:
            print("更新预定房间成功")
        case .failure(let error):
            print("更新预定房间失败: [错误码: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation

// 添加参与成员
func addScheduledAttendees(roomID: String, userIDList: [String]) {
    RoomStore.shared.addScheduledAttendees(roomID: roomID, userIDList: userIDList) { result in
        guard let self = self else { return }
        switch result {
        case .success:
            print("添加预定参与者成功")
        case .failure(let error):
            print("添加预定参与者失败: [错误码: \\(error.code)] \\(error.message)")
        }
    }
}

// 移除参与成员
func removeScheduledAttendees(roomID: String, userIDList: [String]) {
    RoomStore.shared.removeScheduledAttendees(roomID: roomID, userIDList: userIDList) { result in
        switch result {
        case .success:
            print("移除预定参与者成功")
        case .failure(let error):
            print("移除预定参与者失败: [错误码: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation

// 获取预定房间列表
func getScheduledRoomList(cursor: String? = nil) {
    // cursor 为分页游标，首次调用时传入 null，获取第一页数据， 后续调用时传入上次返回的 nextCursor 值
    RoomStore.shared.getScheduledRoomList(cursor: cursor) { result in
        switch result {
        case .success(let (roomList, nextCursor)):
            print("获取预定房间列表成功")
        case .failure(let error):
            print("获取预定房间列表失败: [错误码: \\(error.code)] \\(error.message)")
        }
    }
}


import AtomicXCore
import Foundation

// 获取预定房间的参与者列表
func getScheduledAttendees(roomID: String, cursor: String? = nil) {
    // cursor 为分页游标，首次调用时传入 null，获取第一页数据， 后续调用时传入上次返回的 nextCursor 值
    RoomStore.shared.getScheduledAttendees(roomID: roomID, cursor: cursor) { result in
        switch result {
        case .success(let (attendees, nextCursor)):
            print("获取预定房间参与者列表成功")
        case .failure(let error):
            print("获取预定房间参与者列表失败: [错误码: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation
import Combine

private var cancellableSet = Set<AnyCancellable>()

/// 订阅预定房间相关事件
private func subscribeScheduledRoomEvents() {
    RoomStore.shared.roomEventPublisher
        .receive(on: DispatchQueue.main)
        .sink { event in
            switch event {
            case .onAddedToScheduledRoom(let roomInfo):
                print("已被添加到预定房间 房间信息: \\(roomInfo)")
            case .onRemovedFromScheduledRoom(let roomInfo, let operatorUser):
                print("已被移除预定房间 房间信息: \\(roomInfo), 移除者: \\(operatorUser)")
            case .onScheduledRoomCancelled(let roomInfo, let operatorUser):
                print("预定房间被取消 房间信息: \\(roomInfo), 取消者: \\(operatorUser)")
            case .onScheduledRoomStartingSoon(let roomInfo):
                print("预定房间即将开始 房间信息: \\(roomInfo)")
            default:
                // 处理其他非预定房间相关事件
                break
            }
        }
        .store(in: &cancellableSet)
}

import AtomicXCore
import Foundation
import Combine

private var cancellableSet = Set<AnyCancellable>()

/// 订阅预定房间列表状态变化
private func subscribeScheduledRoomListState() {
    RoomStore.shared.state.subscribe(StatePublisherSelector(keyPath: \\.scheduledRoomList))
        .receive(on: DispatchQueue.main)
        .sink { scheduledRoomList in
            print("预定房间列表变化 房间列表信息: \\(scheduledRoomList)")
        }
        .store(in: &cancellableSet)
}