in src/datachannel/streaming.go [495:518]
func (dataChannel *DataChannel) handleHandshakeComplete(log log.T, clientMessage message.ClientMessage) error {
var err error
var handshakeComplete message.HandshakeCompletePayload
handshakeComplete, err = clientMessage.DeserializeHandshakeComplete(log)
if err != nil {
return err
}
// SessionType would be set when handshake request is received
if dataChannel.sessionType != "" {
dataChannel.isSessionTypeSet <- true
} else {
dataChannel.isSessionTypeSet <- false
}
log.Debugf("Handshake Complete. Handshake time to complete is: %s seconds",
handshakeComplete.HandshakeTimeToComplete.Seconds())
if handshakeComplete.CustomerMessage != "" {
fmt.Fprintln(os.Stdout, handshakeComplete.CustomerMessage)
}
return err
}