import AtomicXCore
import Foundation

// Cancel scheduled room
func cancelScheduledRoom(roomID: String) {
    RoomStore.shared.cancelScheduledRoom(roomID: roomID) { result in
        switch result {
        case .success:
            print("Room reservation cancelled successfully")
        case .failure(let error):
            print("Failed to cancel room reservation: [Error Code: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation

// Update scheduled room
func updateScheduledRoom() {
    let newStartTime = Int(Date().timeIntervalSince1970) + 60 * 30 // New start: 30 min from now
    let newEndTime = newStartTime + 60 * 45 // New end: 45 min after start

    var options = ScheduleRoomOptions()
    options.roomName = "Room Name"
    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("Scheduled room updated successfully")
        case .failure(let error):
            print("Failed to update scheduled room: [Error Code: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation

// Add participants
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("Scheduled participants added successfully")
        case .failure(let error):
            print("Failed to add scheduled participants: [Error Code: \\(error.code)] \\(error.message)")
        }
    }
}

// Remove participants
func removeScheduledAttendees(roomID: String, userIDList: [String]) {
    RoomStore.shared.removeScheduledAttendees(roomID: roomID, userIDList: userIDList) { result in
        switch result {
        case .success:
            print("Scheduled participants removed successfully")
        case .failure(let error):
            print("Failed to remove scheduled participants: [Error Code: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation

// Retrieve scheduled room list
func getScheduledRoomList(cursor: String? = nil) {
    // 'cursor' is a pagination cursor. Pass nil for the first call; use the previous nextCursor for subsequent pages.
    RoomStore.shared.getScheduledRoomList(cursor: cursor) { result in
        switch result {
        case .success(let (roomList, nextCursor)):
            print("Scheduled room list retrieved successfully")
        case .failure(let error):
            print("Failed to retrieve scheduled room list: [Error Code: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation

// Retrieve participant list for a scheduled room
func getScheduledAttendees(roomID: String, cursor: String? = nil) {
    // 'cursor' is a pagination cursor. Pass nil for the first call; use the previous nextCursor for subsequent pages.
    RoomStore.shared.getScheduledAttendees(roomID: roomID, cursor: cursor) { result in
        switch result {
        case .success(let (attendees, nextCursor)):
            print("Scheduled room participants retrieved successfully")
        case .failure(let error):
            print("Failed to retrieve scheduled room participants: [Error Code: \\(error.code)] \\(error.message)")
        }
    }
}

import AtomicXCore
import Foundation
import Combine

private var cancellableSet = Set<AnyCancellable>()

/// Subscribe to scheduled room events
private func subscribeScheduledRoomEvents() {
    RoomStore.shared.roomEventPublisher
        .receive(on: DispatchQueue.main)
        .sink { event in
            switch event {
            case .onAddedToScheduledRoom(let roomInfo):
                print("Added to scheduled room. Room info: \\(roomInfo)")
            case .onRemovedFromScheduledRoom(let roomInfo, let operatorUser):
                print("Removed from scheduled room. Room info: \\(roomInfo), removed by: \\(operatorUser)")
            case .onScheduledRoomCancelled(let roomInfo, let operatorUser):
                print("Scheduled room cancelled. Room info: \\(roomInfo), cancelled by: \\(operatorUser)")
            case .onScheduledRoomStartingSoon(let roomInfo):
                print("Scheduled room starting soon. Room info: \\(roomInfo)")
            default:
                // Handle other non-scheduled room events
                break
            }
        }
        .store(in: &cancellableSet)
}

import AtomicXCore
import Foundation
import Combine

private var cancellableSet = Set<AnyCancellable>()

/// Subscribe to scheduled room list state changes
private func subscribeScheduledRoomListState() {
    RoomStore.shared.state.subscribe(StatePublisherSelector(keyPath: \\.scheduledRoomList))
        .receive(on: DispatchQueue.main)
        .sink { scheduledRoomList in
            print("Scheduled room list changed. Room list info: \\(scheduledRoomList)")
        }
        .store(in: &cancellableSet)
}