diff --git a/pkg/tuya/client.go b/pkg/tuya/client.go
index 586a8bbd..8a0cc221 100644
--- a/pkg/tuya/client.go
+++ b/pkg/tuya/client.go
@@ -71,7 +71,7 @@ func Dial(rawURL string) (core.Producer, error) {
 	}
 
 	// Initialize Tuya API client
-	tuyaAPI, err := NewTuyaClient(u.Hostname(), deviceID, uid, clientId, clientSecret, streamType)
+	tuyaAPI, err := NewTuyaClient(u.Hostname(), deviceID, uid, clientId, clientSecret, streamMode)
 	if err != nil {
 		return nil, err
 	}