Merge pull request #1029 from aprilmaccydee/h200-child-devices
feat(tapo): Add support for H200 hub and child devices (for example battery/sub2G powered D230S1)
This commit is contained in:
+13
-2
@@ -75,6 +75,12 @@ func (c *Client) newConn() (net.Conn, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
query := u.Query()
|
||||||
|
|
||||||
|
if deviceId := query.Get("deviceId"); deviceId != "" {
|
||||||
|
req.URL.RawQuery = "deviceId=" + deviceId
|
||||||
|
}
|
||||||
|
|
||||||
req.URL.User = u.User
|
req.URL.User = u.User
|
||||||
req.Header.Set("Content-Type", "multipart/mixed; boundary=--client-stream-boundary--")
|
req.Header.Set("Content-Type", "multipart/mixed; boundary=--client-stream-boundary--")
|
||||||
|
|
||||||
@@ -91,7 +97,6 @@ func (c *Client) newConn() (net.Conn, error) {
|
|||||||
c.newDectypter(res)
|
c.newDectypter(res)
|
||||||
}
|
}
|
||||||
|
|
||||||
query := u.Query()
|
|
||||||
channel := query.Get("channel")
|
channel := query.Get("channel")
|
||||||
if channel == "" {
|
if channel == "" {
|
||||||
channel = "0"
|
channel = "0"
|
||||||
@@ -277,6 +282,7 @@ func dial(req *http.Request) (net.Conn, *http.Response, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, nil, err
|
return nil, nil, err
|
||||||
}
|
}
|
||||||
|
_ = res.Body.Close() // ignore response body
|
||||||
|
|
||||||
auth := res.Header.Get("WWW-Authenticate")
|
auth := res.Header.Get("WWW-Authenticate")
|
||||||
|
|
||||||
@@ -301,14 +307,19 @@ func dial(req *http.Request) (net.Conn, *http.Response, error) {
|
|||||||
ha1 := tcp.HexMD5(username, realm, password)
|
ha1 := tcp.HexMD5(username, realm, password)
|
||||||
ha2 := tcp.HexMD5(req.Method, uri)
|
ha2 := tcp.HexMD5(req.Method, uri)
|
||||||
nc := "00000001"
|
nc := "00000001"
|
||||||
cnonce := "00000001"
|
cnonce := core.RandString(32, 64)
|
||||||
response := tcp.HexMD5(ha1, nonce, nc, cnonce, qop, ha2)
|
response := tcp.HexMD5(ha1, nonce, nc, cnonce, qop, ha2)
|
||||||
|
|
||||||
|
// https://datatracker.ietf.org/doc/html/rfc7616
|
||||||
header := fmt.Sprintf(
|
header := fmt.Sprintf(
|
||||||
`Digest username="%s", realm="%s", nonce="%s", uri="%s", qop=%s, nc=%s, cnonce="%s", response="%s"`,
|
`Digest username="%s", realm="%s", nonce="%s", uri="%s", qop=%s, nc=%s, cnonce="%s", response="%s"`,
|
||||||
username, realm, nonce, uri, qop, nc, cnonce, response,
|
username, realm, nonce, uri, qop, nc, cnonce, response,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
if opaque := tcp.Between(auth, `opaque="`, `"`); opaque != "" {
|
||||||
|
header += fmt.Sprintf(`, opaque="%s", algorithm=MD5`, opaque)
|
||||||
|
}
|
||||||
|
|
||||||
req.Header.Set("Authorization", header)
|
req.Header.Set("Authorization", header)
|
||||||
|
|
||||||
if err = req.Write(conn); err != nil {
|
if err = req.Write(conn); err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user