gilles/go2rtc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update comments

Browse Source
This commit is contained in:
seydx
2025-10-26 22:21:56 +01:00
parent 80ab32379c
commit fb8c6e1b1b
1 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/tuya/mqtt.go
+13 -6
View File
@@ -79,12 +79,18 @@ type DisconnectFrame struct {
Mode string `json:"mode"` Mode string `json:"mode"`
} }
// {"protocol":4,"t":1761487814,"data":{"dps":{"152":"0","160":1,"170":false}}} type MqttLowPowerMessage struct {
type DPSMessage struct {
Protocol int `json:"protocol"` Protocol int `json:"protocol"`
T int `json:"t"` T int `json:"t"`
S int `json:"s,omitempty"`
Type string `json:"type,omitempty"`
Data struct { Data struct {
Dps map[string]interface{} `json:"dps"` DevID string `json:"devId,omitempty"`
Online bool `json:"online,omitempty"`
LastOnlineChangeTime int64 `json:"lastOnlineChangeTime,omitempty"`
GwID string `json:"gwId,omitempty"`
Cmd string `json:"cmd,omitempty"`
Dps map[string]interface{} `json:"dps,omitempty"`
} `json:"data"` } `json:"data"`
} }
@@ -277,12 +283,13 @@ func (c *TuyaMqttClient) onMessage(client mqtt.Client, msg mqtt.Message) {
} }
func (c *TuyaMqttClient) onLowPowerMessage(client mqtt.Client, msg mqtt.Message) { func (c *TuyaMqttClient) onLowPowerMessage(client mqtt.Client, msg mqtt.Message) {
var message DPSMessage var message MqttLowPowerMessage
if err := json.Unmarshal(msg.Payload(), &message); err != nil { if err := json.Unmarshal(msg.Payload(), &message); err != nil {
return return
} }
// Check if protocol is 4 and dps[149] is true (motion detection = camera ready) // Check if protocol is 4 and dps[149] is true
// https://developer.tuya.com/en/docs/iot-device-dev/doorbell_solution?id=Kayamyivh15ox#title-2-Battery
if message.Protocol == 4 { if message.Protocol == 4 {
if val, ok := message.Data.Dps["149"]; ok { if val, ok := message.Data.Dps["149"]; ok {
if ready, ok := val.(bool); ok && ready { if ready, ok := val.(bool); ok && ready {
@@ -290,7 +297,7 @@ func (c *TuyaMqttClient) onLowPowerMessage(client mqtt.Client, msg mqtt.Message)
// However, we don't wait for this signal (like ismartlife.me doesn't either). // However, we don't wait for this signal (like ismartlife.me doesn't either).
// The camera starts responding immediately after WakeUp() is called, // The camera starts responding immediately after WakeUp() is called,
// so we proceed with the connection without blocking. // so we proceed with the connection without blocking.
// This waiter is kept for potential future use or debugging. // This waiter is kept for potential future use.
c.wakeupWaiter.Done(nil) c.wakeupWaiter.Done(nil)
} }
} }