Handling Signaling Messages

handling_signaling_messages.kt

// Copyright 2023 Stream.IO, Inc. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

init {
  sessionManagerScope.launch {
    signalingClient.signalingCommandFlow
      .collect { commandToValue ->
        when (commandToValue.first) {
          SignalingCommand.OFFER -> handleOffer(commandToValue.second)
          SignalingCommand.ANSWER -> handleAnswer(commandToValue.second)
          SignalingCommand.ICE -> handleIce(commandToValue.second)
          else -> Unit
        }
      }
  }
}

private fun handleOffer(sdp: String) {
  logger.d { "[SDP] handle offer: $sdp" }
  offer = sdp
}

private suspend fun handleAnswer(sdp: String) {
  logger.d { "[SDP] handle answer: $sdp" }
  peerConnection.setRemoteDescription(
    SessionDescription(SessionDescription.Type.ANSWER, sdp)
  )
}

private suspend fun handleIce(iceMessage: String) {
  val iceArray = iceMessage.split(ICE_SEPARATOR)
  peerConnection.addIceCandidate(
    IceCandidate(
      iceArray[0],
      iceArray[1].toInt(),
      iceArray[2]
    )
  )
}