import Foundation
import LinksoulAgentSDK

// 遥操：enter → startAudio → appendAudioDelta → doneAudio → exit

let url = "wss://open.agibot.com/api/V1/open-portal/app/wss/agent-sdk"
let appId = "您通过灵心开放平台创建的应用获取的appId"
let appKey = "您通过灵心开放平台创建的应用获取的appKey"
let appSecret = "您通过灵心开放平台创建的应用获取的appSecret"
let agentId = "您通过灵心平台创建的二开智能体获取的agentId"

let agentSdk = AgentSdk.create(url: url, appId: appId, appKey: appKey, appSecret: appSecret)

final class AuthCallback: AgentAuthCallback {
    func onAuthState(appId: String, code: Int, msg: String) {
        print("onAuthState => appId: \(appId), code: \(code), msg: \(msg)")
    }
}
agentSdk.registerAuth(AuthCallback())
agentSdk.initialize()

Thread.sleep(forTimeInterval: 2.0)

// 注册遥操请求
let teleopId = IdGenerator.generateTeleopId()
let teleopRequest = TeleopRequest(agentSdk: agentSdk, agentId: agentId, teleopId: teleopId)
agentSdk.registerTeleop(teleopRequest)

// 进入遥操
final class EnterCallback: TeleopEnterCallback {
    override func onEnterAck(teleopId: String, eventId: String, code: Int, msg: String?) {
        print("onEnterAck => teleopId \(teleopId), eventId \(eventId), code \(code), msg \(msg ?? "")")
    }
}
let enterParam = AgentParam.create()
teleopRequest.enter(param: enterParam, enterCallback: EnterCallback(), timeout: 2000)

// 开始说话
let startParam = AgentParam.create()
    .setString("role", "male")   // male/female
    .setInt("threshold", 0)     // -14 - 14
let eventId = teleopRequest.startAudio(param: startParam)

// 持续说话（audio delta 为 base64 编码字符串）
teleopRequest.appendAudioDelta(eventId: eventId, audioDelta: "")

// 结束说话
teleopRequest.doneAudio(eventId: eventId)

// 检查机器人是否在线（详见「定时探活」小节，遥操期间应每 10s 探活一次）
final class KeepaliveCallback: TeleopKeepaliveCallback {
    override func onKeepaliveAck(teleopId: String, eventId: String, code: Int, msg: String?) {
        print("onKeepaliveAck => teleopId \(teleopId), eventId \(eventId), code \(code), msg \(msg ?? "")")
    }
}
teleopRequest.keepalive(keepaliveCallback: KeepaliveCallback(), timeout: 2000)

// 退出遥操
final class ExitCallback: TeleopExitCallback {
    override func onExitAck(teleopId: String, eventId: String, code: Int, msg: String?) {
        print("onExitAck => teleopId \(teleopId), eventId \(eventId), code \(code), msg \(msg ?? "")")
    }
}
teleopRequest.exit(exitCallback: ExitCallback(), timeout: 2000)

RunLoop.main.run()

import Foundation
import LinksoulAgentSDK

final class KeepaliveWatcher {
    private let teleopRequest: TeleopRequest
    private let agentSdk: AgentSdk
    private let queue = DispatchQueue(label: "teleop.keepalive")
    private var timer: DispatchSourceTimer?
    private var online = true
    private let lock = NSLock()

    init(teleopRequest: TeleopRequest, agentSdk: AgentSdk) {
        self.teleopRequest = teleopRequest
        self.agentSdk = agentSdk
    }

    /// enter 成功后调用；每 10 秒探活一次。
    func start(intervalSec: Int = 10) {
        let t = DispatchSource.makeTimerSource(queue: queue)
        t.schedule(deadline: .now() + .seconds(intervalSec), repeating: .seconds(intervalSec))
        t.setEventHandler { [weak self] in self?.tick() }
        t.resume()
        self.timer = t
    }

    func stop() {
        timer?.cancel()
        timer = nil
    }

    private func tick() {
        lock.lock(); let stillOnline = online; lock.unlock()
        guard stillOnline else { return }
        teleopRequest.keepalive(keepaliveCallback: Callback(owner: self), timeout: 2000)
    }

    private final class Callback: TeleopKeepaliveCallback {
        weak var owner: KeepaliveWatcher?
        init(owner: KeepaliveWatcher) { self.owner = owner; super.init() }
        override func onKeepaliveAck(teleopId: String, eventId: String, code: Int, msg: String?) {
            guard let self = owner else { return }
            if code == 0 { return }
            self.lock.lock()
            if !self.online { self.lock.unlock(); return }
            self.online = false
            self.lock.unlock()
            print("robot offline => code=\(code), msg=\(msg ?? "")")
            self.stop()
            self.teleopRequest.exit(exitCallback: ExitCb(owner: self), timeout: 2000)
        }
    }

    private final class ExitCb: TeleopExitCallback {
        weak var owner: KeepaliveWatcher?
        init(owner: KeepaliveWatcher) { self.owner = owner; super.init() }
        override func onExitAck(teleopId: String, eventId: String, code: Int, msg: String?) {
            owner?.agentSdk.unregisterTeleop(teleopId: teleopId)
        }
    }
}