弹幕（iOS）

import Foundation
import AtomicXCore // 确保导入核心库
import Combine     // 用于处理响应式编程

class BarrageManager {
    
    private let liveId: String
    private let barrageStore: BarrageStore
    private var cancellables = Set<AnyCancellable>()
    
    // 对外暴露【全量】消息列表的发布者，方便UI层订阅
    let messagesPublisher = PassthroughSubject<[Barrage], Never>()
    
    init(liveId: String) {
        self.liveId = liveId
        // 1. 通过 liveId 获取 BarrageStore 的单例
        self.barrageStore = BarrageStore.create(liveID: liveId)
        
        // 2. 初始化后立即开始监听弹幕消息
        subscribeToBarrageUpdates()
    }
    
    private func subscribeToBarrageUpdates() {
        barrageStore.state
            .subscribe() // 订阅 BarrageState 的所有变化
            .receive(on: DispatchQueue.main) // 确保在主线程处理数据，保证UI安全
            .sink { [weak self] barrageState in
                // 3. 当 messageList 更新时，通过 publisher 将新列表传递给UI层
                // 关键点：这里接收到的是包含所有历史消息的【完整列表】
                self?.messagesPublisher.send(barrageState.messageList)
            }
            .store(in: &cancellables) // 管理订阅的生命周期
    }
}

extension BarrageManager {
    
    /// 发送一条文本弹幕
    func sendTextMessage(text: String) {
        // 建议：增加非空校验，避免发送无效消息
        guard !text.isEmpty else {
            print("弹幕内容不能为空")
            return
        }
        
        // 调用核心API发送消息
        barrageStore.sendTextMessage(text: text, extensionInfo: nil) { result in
            // 在回调中处理发送结果，例如给用户提示
            switch result {
            case .success:
                print("文本弹幕 '\\(text)' 发送成功")
            case .failure(let error):
                print("文本弹幕发送失败: \\(error.localizedDescription)")
            }
        }
    }
}

extension BarrageManager {

    /// 发送一条自定义弹幕，例如用于发送礼物
    func sendGiftMessage(giftId: String, giftCount: Int) {
        // 1. 定义一个能识别业务的ID
        let businessId = "live_gift" 
        
        // 2. 将业务数据编码为 JSON 字符串
        let giftData: [String: Any] = ["gift_id": giftId, "gift_count": giftCount]
        guard let jsonData = try? JSONSerialization.data(withJSONObject: giftData),
              let jsonString = String(data: jsonData, encoding: .utf8) else {
            print("无法将礼物数据编码为JSON")
            return
        }
        
        // 3. 调用核心API发送自定义消息
        barrageStore.sendCustomMessage(businessId: businessId, data: jsonString) { result in
            switch result {
            case .success:
                print("礼物消息（自定义弹幕）发送成功")
            case .failure(let error):
                print("礼物消息发送失败: \\(error.localizedDescription)")
            }
        }
    }
}

extension BarrageManager {
    
    /// 在本地消息列表中插入一条欢迎提示
    func showWelcomeMessage(for user: LiveUserInfo) {
        // 1. 创建一条 Barrage 消息
        var welcomeTip = Barrage()
        welcomeTip.messageType = .text // 可以复用 text 类型来显示
        welcomeTip.textContent = "欢迎 \\(user.userName) 进入直播间！"
        // sender 可以留空或设置为一个系统用户的标识
        
        // 2. 调用API将其插入本地列表
        barrageStore.appendLocalTip(message: welcomeTip)
    }
}

import AtomicXCore

// 1. 获取与当前直播间绑定的 LiveAudienceStore 实例
let audienceStore = LiveAudienceStore.create(liveID: "your_live_id")

// 2. 定义要操作的用户ID和禁言状态
let userIdToMute = "user_id_to_be_muted"
let shouldDisable = true // true为禁言, false为解禁

// 3. 调用接口执行操作
audienceStore.disableSendMessage(userId: userIdToMute, isDisable: shouldDisable) { result in
    switch result {
    case .success:
        print("\\(shouldDisable ? "禁言" : "解禁")用户 \\(userIdToMute) 成功")
    case .failure(let error):
        print("操作失败: \\(error.localizedDescription)")
    }
}

import AtomicXCore

// 1. 获取 LiveListStore 单例
let liveListStore = LiveListStore.shared

// 2. 获取当前直播间信息，并修改全体禁言状态
var currentLiveInfo = liveListStore.state.value.currentLive 
currentLiveInfo.isMessageDisable = true // true为全体禁言, false为关闭

// 3. 调用更新接口，并指定修改的标志位
liveListStore.updateLiveInfo(currentLiveInfo, modifyFlag: .isMessageDisable) { result in
    switch result {
    case .success:
        print("全体禁言状态更新成功")
    case .failure(let error):
        print("操作失败: \\(error.localizedDescription)")
    }
}

class BarrageUIManager {
    private var latestMessageList: [BarrageViewModel]?
    private var refreshTimer: Timer?
    private weak var tableView: UITableView?
    private var dataSource: [BarrageViewModel] = []

    init(tableView: UITableView) {
        self.tableView = tableView
        // 每 0.3 秒检查一次是否需要刷新
        self.refreshTimer = Timer.scheduledTimer(withTimeInterval: 0.3, repeats: true) { [weak self] _ in
            self?.refreshUIIfNeeded()
        }
    }

    /// 外部高频调用此方法，传入最新的全量列表
    func update(with fullList: [BarrageViewModel]) {
        self.latestMessageList = fullList
    }

    private func refreshUIIfNeeded() {
        // 检查是否有新的数据待刷新
        guard let newList = self.latestMessageList, let tableView = self.tableView else { return }

        self.latestMessageList = nil // 清空标志位，避免重复刷新

        // 更新数据源并刷新UI
        self.dataSource = newList
        tableView.reloadData()
    }

    deinit {
        refreshTimer?.invalidate()
    }
}

class BarrageUIManager {
    private let capacity: Int = 500 // 客户端只保留最新的500条消息
    // ...（其他代码同上）...

    private func refreshUIIfNeeded() {
        guard let fullList = self.latestMessageList, let tableView = self.tableView else { return }
        self.latestMessageList = nil 

        // 关键点：截取最新的N条消息
        let cappedList = Array(fullList.suffix(self.capacity))

        self.dataSource = cappedList
        tableView.reloadData()
    }
}

import UIKit

// 在你的自定义弹幕Cell中
class BarrageCell: UITableViewCell {

    // ... (UILabel, UIImageView等子视图的声明)

    override init(style: UITableViewCell.CellStyle, reuseIdentifier: String?) {
        super.init(style: style, reuseIdentifier: reuseIdentifier)

        // 开启异步绘制，这是最简单的实现方式
        // 系统会在合适的时机将这个Cell的绘制任务放到后台线程
        self.layer.drawsAsynchronously = true
    }

    required init?(coder: NSCoder) {
        fatalError("init(coder:) has not been implemented")
    }

    func configure(with viewModel: BarrageViewModel) {
        // 在这里设置你的Label文本、Image图片等
        // 由于开启了异步绘制，这些内容的最终渲染会尽量在后台完成
    }

    // 追求极致性能的进阶方案：完全手动绘制
    override func draw(_ rect: CGRect) {
        // 如果需要更精细的控制，可以在此使用Core Graphics手动绘制文本和图片
        // 结合后台线程生成UIImage，然后在主线程的draw方法中绘制它，可以实现完全的异步渲染
    }
}