apps/go2rtc
1
0
Fork 0
mirror of https://github.com/AlexxIT/go2rtc.git synced 2025-10-07 01:03:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix panic from roborock source (iot.Dial error) #601

Browse Source
This commit is contained in:
Alex X
2023-10-11 14:26:02 +03:00
parent 6c07c59454
commit acec8a76aa
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
pkg/roborock/client.go
View File

@@ -6,16 +6,17 @@ import (
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" "fmt"
"github.com/AlexxIT/go2rtc/pkg/core"
"github.com/AlexxIT/go2rtc/pkg/roborock/iot"
"github.com/AlexxIT/go2rtc/pkg/webrtc"
pion "github.com/pion/webrtc/v3"
"log" "log"
"net/rpc" "net/rpc"
"net/url" "net/url"
"strconv" "strconv"
"sync" "sync"
"time" "time"
"github.com/AlexxIT/go2rtc/pkg/core"
"github.com/AlexxIT/go2rtc/pkg/roborock/iot"
"github.com/AlexxIT/go2rtc/pkg/webrtc"
pion "github.com/pion/webrtc/v3"
) )
type Client struct { type Client struct {
@@ -38,13 +39,15 @@ func NewClient(url string) *Client {
return &Client{url: url} return &Client{url: url}
} }
func (c *Client) Dial() (err error) { func (c *Client) Dial() error {
u, err := url.Parse(c.url) u, err := url.Parse(c.url)
if err != nil { if err != nil {
return return err
} }
c.iot, err = iot.Dial(c.url) if c.iot, err = iot.Dial(c.url); err != nil {
return err
}
c.pin = u.Query().Get("pin") c.pin = u.Query().Get("pin")
if c.pin != "" { if c.pin != "" {