Fix Roborock support

dadav · Mar 21, 2023 · 3002d5f · 3002d5f
1 parent cca4f05
commit 3002d5f
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/pkg/roborock/client.go b/pkg/roborock/client.go
@@ -111,6 +111,9 @@ func (c *Client) Connect() error {
 				_ = c.SendICEtoRobot(msg.ToJSON().Candidate, "0")
 			}
 		case pion.PeerConnectionState:
+			if msg == pion.PeerConnectionStateConnecting {
+				return
+			}
 			// unblocking write to channel
 			select {
 			case connected <- msg == pion.PeerConnectionStateConnected:
@@ -131,8 +134,9 @@ func (c *Client) Connect() error {
 		return err
 	}
 
-	log.Printf("[roborock] offer\n%s", pc.LocalDescription().SDP)
-	if err = c.SendSDPtoRobot(pc.LocalDescription()); err != nil {
+	offer := pc.LocalDescription()
+	log.Printf("[roborock] offer\n%s", offer.SDP)
+	if err = c.SendSDPtoRobot(offer); err != nil {
 		return err
 	}