|
|
|
@ -115,8 +115,16 @@ class PeerConnectionClientTest: XCTestCase {
|
|
|
|
func testDataChannelMessage() {
|
|
|
|
func testDataChannelMessage() {
|
|
|
|
XCTAssertEqual(0, clientDelegate.dataChannelMessages.count)
|
|
|
|
XCTAssertEqual(0, clientDelegate.dataChannelMessages.count)
|
|
|
|
|
|
|
|
|
|
|
|
let hangup = DataChannelMessage.forHangup(callId: 123)
|
|
|
|
var hangupData: Data
|
|
|
|
let hangupBuffer = RTCDataBuffer(data: hangup.asData(), isBinary: false)
|
|
|
|
do {
|
|
|
|
|
|
|
|
let hangupBuilder = WebRTCProtoHangup.WebRTCProtoHangupBuilder()
|
|
|
|
|
|
|
|
hangupBuilder.setId(123)
|
|
|
|
|
|
|
|
hangupData = try hangupBuilder.buildSerializedData()
|
|
|
|
|
|
|
|
} catch {
|
|
|
|
|
|
|
|
XCTFail("Couldn't build proto.")
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
let hangupBuffer = RTCDataBuffer(data: hangupData, isBinary: false)
|
|
|
|
client.dataChannel(dataChannel, didReceiveMessageWith: hangupBuffer)
|
|
|
|
client.dataChannel(dataChannel, didReceiveMessageWith: hangupBuffer)
|
|
|
|
|
|
|
|
|
|
|
|
waitForPeerConnectionClient()
|
|
|
|
waitForPeerConnectionClient()
|
|
|
|
@ -124,7 +132,7 @@ class PeerConnectionClientTest: XCTestCase {
|
|
|
|
XCTAssertEqual(1, clientDelegate.dataChannelMessages.count)
|
|
|
|
XCTAssertEqual(1, clientDelegate.dataChannelMessages.count)
|
|
|
|
|
|
|
|
|
|
|
|
let dataChannelMessageProto = clientDelegate.dataChannelMessages[0]
|
|
|
|
let dataChannelMessageProto = clientDelegate.dataChannelMessages[0]
|
|
|
|
XCTAssert(dataChannelMessageProto.hasHangup())
|
|
|
|
XCTAssert(dataChannelMessageProto.hasHangup)
|
|
|
|
|
|
|
|
|
|
|
|
let hangupProto = dataChannelMessageProto.hangup!
|
|
|
|
let hangupProto = dataChannelMessageProto.hangup!
|
|
|
|
XCTAssertEqual(123, hangupProto.id)
|
|
|
|
XCTAssertEqual(123, hangupProto.id)
|
|
|
|
|