Merge pull request #10 from muzzammilshahid/handle-remote-candidates

Handle remote candidates

client.go

@@ -6,6 +6,7 @@ import (
 
 	"github.com/google/uuid"
 	"github.com/pion/webrtc/v4"
+	log "github.com/sirupsen/logrus"
 
 	"github.com/xconnio/wampproto-go/auth"
 	"github.com/xconnio/xconn-go"
@@ -16,6 +17,7 @@ type ClientConfig struct {
 	Realm                    string
 	ProcedureWebRTCOffer     string
 	TopicAnswererOnCandidate string
+	TopicOffererOnCandidate  string
 	Serializer               xconn.WSSerializerSpec
 	Authenticator            auth.ClientAuthenticator
 }
@@ -33,6 +35,33 @@ func connectWebRTC(config *ClientConfig) (*WebRTCSession, error) {
 		Ordered:                  true,
 		TopicAnswererOnCandidate: config.TopicAnswererOnCandidate,
 	}
+
+	_, err = session.Subscribe(config.TopicOffererOnCandidate, func(event *xconn.Event) {
+		if len(event.Arguments) < 2 {
+			log.Errorf("invalid arguments length")
+			return
+		}
+
+		candidateJSON, ok := event.Arguments[1].(string)
+		if !ok {
+			log.Errorln("offer must be a string")
+			return
+		}
+
+		var candidate webrtc.ICECandidateInit
+		if err := json.Unmarshal([]byte(candidateJSON), &candidate); err != nil {
+			log.Errorln(err)
+			return
+		}
+
+		if err = offerer.AddICECandidate(candidate); err != nil {
+			log.Errorln(err)
+		}
+	}, nil)
+	if err != nil {
+		return nil, err
+	}
+
 	requestID := uuid.New().String()
 	offer, err := offerer.Offer(offerConfig, session, requestID)
 	if err != nil {

cmd/client/main.go

@@ -11,6 +11,7 @@ import (
 const (
 	procedureWebRTCOffer     = "io.xconn.webrtc.offer"
 	topicAnswererOnCandidate = "io.xconn.webrtc.answerer.on_candidate"
+	topicOffererOnCandidate  = "io.xconn.webrtc.offerer.on_candidate"
 )
 
 func main() {
@@ -19,6 +20,7 @@ func main() {
 		Realm:                    "realm1",
 		ProcedureWebRTCOffer:     procedureWebRTCOffer,
 		TopicAnswererOnCandidate: topicAnswererOnCandidate,
+		TopicOffererOnCandidate:  topicOffererOnCandidate,
 		Serializer:               xconn.CBORSerializerSpec,
 		Authenticator:            auth.NewCRAAuthenticator("john", map[string]any{}, "hello"),
 	}

offerer.go

@@ -98,6 +98,10 @@ func (o *Offerer) HandleAnswer(answer Answer) error {
 	return nil
 }
 
+func (o *Offerer) AddICECandidate(candidate webrtc.ICECandidateInit) error {
+	return o.connection.AddICECandidate(candidate)
+}
+
 func (o *Offerer) WaitReady() chan *webrtc.DataChannel {
 	return o.channel
 }