timer = Timer.scheduledTimer(withTimeInterval: MSConfig.wsHeartBeatTime, repeats: true) { [weak self] _ in
guard let self = self else {return}
if socket?.readyState == .open{
-// self.socket?.ping()
+ self.socket?.send(text: "")
}
else{
self.openWebSocket()
"status": 0,
],
"payload":[
-// "device_id": "test_device_id", // 设备ID/用户ID
"device_id": deviceId, // 设备ID/用户ID
"user_agent": "python", // 浏览器uset-gaent 自定义
"dialog_id":dialogId, // 继承上轮对话 空新建一个对话
/// 发送内容
/// - Parameter content: 内容
public func send(content:String){
+ MixSdk.shared.voiceChat.requestToSpeak()
+
let params:[String:Any] = [
"header": [
"trace_id": self.taskId,
/// 打断,请求说话
public func requestToSpeak(){
if socket?.readyState == .open{
- //self.socket?.ping()
sendSpeakCMD()
}
else{
+ //还没连接
+ Logger.log("还没连接!!!!!!!!!!!")
self.openWebSocket()
DispatchQueue.main.asyncAfter(deadline: .now() + 2) {
self.sendSpeakCMD()
currentEvent = model
}
-
-// if model.event == "RespondingEnded"{
-// let tmpModel = MSChatModel()
-// tmpModel.type = "end"
-// tmpModel.content = nil
-// lastChatModel = tmpModel
-// callBack?(tmpModel)
-// }
if model.event == "RespondingContent",let payload = model.payload,let text = payload.text{
if let finish = payload.finished,finish == false {
let tmpModel = MSChatModel()
}
func webSocketPong(){
- //Logger.log("MSVoiceChat Pong")
+ Logger.log("MSVoiceChat Pong")
}
func webSocketEnd(_ code: Int, reason: String, wasClean: Bool, error: NSError?){