快速接入（iOS）

import AtomicXCore

//  AppDelegate.swift
func application(_ application: UIApplication, didFinishLaunchingWithOptions launchOptions: [UIApplication.LaunchOptionsKey: Any]?) -> Bool {
    LoginStore.shared.login(sdkAppID: 1400000001,                  // 替换为您的 SDKAppID
                            userID: "test_001",                    // 替换为您的 UserID
                            userSig: "xxxxxxxxxxx") { result in    // 替换为您的 UserSig
      switch result {
        case .success(let info):
        debugPrint("login success")
        case .failure(let error):
        debugPrint("login failed code:\\(error.code), message:\\(error.message)")
      }
    }
    return true
}

import UIKit
import AtomicXCore
import Combine // 导入 Combine 框架

// YourAnchorViewController 代表您的房主 ViewController
class YourAnchorViewController: UIViewController {

    private let liveListStore = LiveListStore.shared
    private let deviceStore = DeviceStore.shared

    // 使用 liveID 初始化 LiveSeatStore
    private let liveID = "test_voice_room_001"
    private lazy var liveSeatStore = LiveSeatStore.create(liveID: liveID)

    // 用于管理订阅生命周期
    private var cancellables = Set<AnyCancellable>()

    override func viewDidLoad() {
        super.viewDidLoad()
        // 假设您有自己的布局
        // setupUI() 

        // 2. 监听麦位列表变化
        observeSeatList()
    }

    private func observeSeatList() {
         // 监听 state.seatList 的变化，并更新您的麦位 UI
         liveSeatStore.state
            .subscribe(StatePublisherSelector(keyPath: \\LiveSeatState.seatList)) // 仅关心麦位列表
            .removeDuplicates()
            .receive(on: DispatchQueue.main) // 确保在主线程更新 UI
            .sink { [weak self] seatInfoList in
                // 在这里根据 seatInfoList 渲染您的麦位 UI
                // 例如：self?.updateMicSeatView(seatInfoList)
                print("Seat list updated: \\(seatInfoList.count) seats")
            }
            .store(in: &cancellables) // 管理订阅
    }
}

import UIKit
import AtomicXCore

class YourAnchorViewController: UIViewController {
    // ... 其他代码 ...

    private func openDevices() {
        // 1. 打开麦克风
        DeviceStore.shared.openLocalMicrophone(completion: nil)
    }
}

import UIKit
import AtomicXCore

class YourAnchorViewController: UIViewController {
    // ... 其他代码 ...
    private let liveID = "test_voice_room_001"
    
    override func viewDidLoad() {
        super.viewDidLoad()
        // ... 其他代码 ...

        // 开始语聊
        startLive()
    }

    private func startLive() {
        // 1. 准备 LiveInfo 对象
        var liveInfo = LiveInfo()

        // 2. 设置房间 id
        liveInfo.liveID = liveID
        // 3. 设置房间名称
        liveInfo.liveName = "test 语聊房"
        // 4. 配置为语聊房（启用麦位）
        liveInfo.isSeatEnabled = true
        // 5. 房主默认上麦
        liveInfo.keepOwnerOnSeat = true
        // 6. 设置麦位布局模板（例如 70 为 10 麦位模板）
        // 重要：请根据产品规范传入正确的 ID
        liveInfo.seatLayoutTemplateID = 70 
        // 7. 设置上麦模式，例如申请上麦
        liveInfo.seatMode = .apply
        // 8. 设置最大麦位数
        liveInfo.maxSeatCount = 10

        // 9. 调用 createLive 开始直播
        
        liveListStore.createLive(liveInfo) { [weak self] result in
            guard let self = self else { return }
            switch result {
            case .success(let liveInfo):
                print("Response startLive onSuccess")
                // 房主创建成功后，默认会上麦，此时您可以调用 unmuteMicrophone
                liveSeatStore.unmuteMicrophone(completion: nil)
            case .failure(let errorInfo):
                print("Response startLive onError: \\(errorInfo.message)")
            }
        }
    }
}

import UIKit
import AtomicXCore
import Combine

class YourAnchorViewController: UIViewController {
    // ... 其他代码 ...
    private var cancellables = Set<AnyCancellable>()
    private lazy var liveSeatStore = LiveSeatStore.create(liveID: "your_live_id")

    override func viewDidLoad() {
        super.viewDidLoad()
        // ... 其他代码 ...

        // 监听 seatList 变化
        observeSeatList()
    }

    private func observeSeatList() {
        // 监听 state.seatList 变化，并更新您的麦位 UI
         liveSeatStore.state
            .subscribe(StatePublisherSelector(keyPath: \\LiveSeatState.seatList)) // 仅关心麦位列表
            .removeDuplicates()
            .receive(on: DispatchQueue.main) // 确保在主线程更新 UI
            .sink { [weak self] seatInfoList in
                // seatInfoList 即为最新的麦位列表 (List<SeatInfo>)
                // 在这里根据 seatInfoList 渲染您的麦位 UI
                print("Seat list updated: \\(seatInfoList.count) seats")
            }
            .store(in: &cancellables)
    }
}

import UIKit
import AtomicXCore
import RTCRoomEngine // 导入以获取 TUILiveStatisticsData

class YourAnchorViewController: UIViewController {
    // ... 其他代码 ...


    // 结束语聊
    private func stopLive() {
        liveListStore.endLive { result in
            switch result {
            case .success(let data):
                print("endLive success")
            case .failure(let errorInfo):
                print("endLive error: \\(errorInfo.message)")
            }
        }
    }
}

import UIKit
import AtomicXCore
import Combine

// YourAudienceViewController 代表您的观众 ViewController
class YourAudienceViewController: UIViewController {

    private let liveListStore = LiveListStore.shared

    // 确保 liveID 与房主一致
    private let liveID = "test_voice_room_001" 
    private lazy var liveSeatStore = LiveSeatStore.create(liveID: liveID)

    // 用于管理订阅生命周期
    private var cancellables = Set<AnyCancellable>()

    override func viewDidLoad() {
        super.viewDidLoad()
        // 假设您有自己的布局
        // setupUI()

        // 2. 监听麦位列表变化
        observeSeatList()
    }

    private func observeSeatList() {
         // 3. 监听 state.seatList 变化，并更新您的麦位 UI
         liveSeatStore.state
            .subscribe(StatePublisherSelector(keyPath: \\LiveSeatState.seatList)) // 仅关心麦位列表
            .removeDuplicates()
            .receive(on: DispatchQueue.main) // 确保在主线程更新 UI
            .sink { [weak self] seatInfoList in
                // 在这里根据 seatInfoList 渲染您的麦位 UI
                // 例如：self?.updateMicSeatView(seatInfoList)
                print("AudienceVC Seat list updated: \\(seatInfoList.count) seats")
            }
            .store(in: &cancellables)
    }
}

import UIKit
import AtomicXCore

// YourAudienceViewController 代表您的观众 ViewController
class YourAudienceViewController: UIViewController {

    // ... 其他代码 ...
    override func viewDidLoad() {
        super.viewDidLoad()
        // ... 其他代码 ...

        // 进入语聊房
        joinLive()
    }

    private func joinLive() {
        // 1. 调用 joinLive 进入语聊房
        liveListStore.joinLive(liveID: liveID) { result in
            DispatchQueue.main.async {
                switch result {
                case .success(let liveInfo):
                    print("joinLive success")
                case .failure(let errorInfo):
                    print("joinLive error: \\(errorInfo.message)")
                }
            }
        }
    }
}

import UIKit
import AtomicXCore

// YourAudienceViewController 代表您的观众 ViewController
class YourAudienceViewController: UIViewController {
    // ... 其他代码 ...
    
    private func leaveLive() {
        liveListStore.leaveLive { result in
              switch result {
              case .success:
                  print("leaveLive success")
              case .failure(let errorInfo):
                  print("leaveLive error: \\(errorInfo.message)")
              }
        }
    }
}

import UIKit
import AtomicXCore
import Combine

// 在 YourAnchorViewController 或 YourAudienceViewController 中
class YourAnchorViewController: UIViewController {
    // ... (省略其他代码) ...
    private var cancellables = Set<AnyCancellable>()

    override func viewDidLoad() {
        super.viewDidLoad()
        // ... (省略其他代码) ...

        // 监听 speakingUsers 变化
        observeSpeakingUsersState()
    }

    private func observeSpeakingUsersState() {
        // 监听 state.speakingUsers 变化，并更新“正在说话”状态
        liveSeatStore.state           
            .subscribe(StatePublisherSelector(keyPath: \\LiveSeatState.speakingUsers)) // 仅关心说话者 map
            .removeDuplicates()
            .receive(on: DispatchQueue.main) // 确保在主线程更新 UI
            .sink { [weak self] speakingUserMap in
                // 将 "正在说话" 的用户 ID 集合 传递给 UI , 更新 UI 状态
                print("Speaking users updated: \\(speakingUserMap.count) users")
            }
            .store(in: &cancellables)
    }
}