subscribe with Berry

[timtimsson]

Hi,
i can subscribe the „local“ sensor, not the far? - whats wrong?
TasmoCompiler v12.4.0 —> options?

Welcome to the Berry Scripting console. Check the documentation.
import mqtt
import lv
import json

mqtt.subscribe("/ESP32C6/tele/SENSOR", /topic, idx, payload, bindata -> print(topic, payload))
mqtt.subscribe("/ESP32_A8T_04/tele/SENSOR", /topic, idx, payload, bindata -> print(topic, payload))

/ESP32C6/tele/SENSOR {"Time":"2025-02-04T22:49:39","ESP32":{"Temperature":21.0},"TempUnit":"C"}
/ESP32C6/tele/SENSOR {"Time":"2025-02-04T22:50:09","ESP32":{"Temperature":21.0},"TempUnit":"C"}
/ESP32C6/tele/SENSOR {"Time":"2025-02-04T22:50:39","ESP32":{"Temperature":21.0},"TempUnit":"C"}
/ESP32C6/tele/SENSOR {"Time":"2025-02-04T22:51:09","ESP32":{"Temperature":21.0},"TempUnit":"C"}
/ESP32C6/tele/SENSOR {"Time":"2025-02-04T22:51:39","ESP32":{"Temperature":21.0},"TempUnit":"C"}

[sfromis]

Try using the specific topic, instead of arbitrarily inserting a / at the start of the string.

[timtimsson]

This is a very good example for me - thank you very much!!!

If i put the hole code in the autoexec.be - nothings to see?
But if I use a separate file, its load correctly …, why?

autoexec.be

import haspmota
haspmota.start()
load("mqtt.be")

[sfromis]

Do check the log for messages right after restart, and you'll likely see something like

BRY: failed to load '/autoexec.be' (syntax_error - /autoexec.be:12: 'p1b2' undeclared (first use in this function))

When compiling the code of autoexec.be, it will process all code before starting executing, and p1b2 is not defined before pages.jsonl has been processed during the haspmota.start. But when having the subscribe in a separate file, the lines from that file will only be compiled when it got to the point of executing the load, hence p1b2 is available.

One way around it would be to make it explicit that p1b2 is a global variable, by prefixing it like global.p1b2. That will work when compiling as global is defined, without requiring members of global to already exist at compile time.

[timtimsson]

Great, everything is as you reported.
I have another question about querying the button.state. I subscribe to the channel, but the script is probably loading too slowly - at the beginning I don't get any stat value... although it is output in the console.
Can I somehow trigger the stat output again?

• restart 1:
  print("POWER3:", p1b22.text, "| Wert:", p1b22.val)
  POWER3: nil | Wert: false

• press button3 the first time:
  print("POWER3:", p1b22.text, "| Wert:", p1b22.val)
  POWER3: POWER3 OFF | Wert: false
  POWER3: POWER3 ON | Wert: true
  …

mqtt.subscribe('ESP32_M5_01/stat/RESULT',
def (topic, idx, payload, bin)
import json
var data = json.load(payload)
var power3 = data ? data.find('POWER3', "OFF") : "OFF"
p1b22.text = f'POWER3 {power3}'
p1b22.val = (power3 == "ON")
end)

ESP32_M5_01/stat/RESULT = {"POWER3":"OFF"}
ESP32_M5_01/stat/POWER3 = ON
ESP32_M5_01/stat/RESULT = {"POWER3":"ON"}
ESP32_M5_01/stat/POWER3 = OFF

mqtt.subscribe('ESP32_M5_01/stat/RESULT',
  def (topic, idx, payload, bin)
    import json
    var data = json.load(payload)
    var power3 = data ? data.find('POWER3', "OFF") : "OFF"
    p1b22.text = f'POWER3 {power3}'
    p1b22.val = (power3 == "ON") 
  end)

ESP32_M5_01/stat/RESULT = {"POWER3":"OFF"}
ESP32_M5_01/stat/POWER3 = ON
ESP32_M5_01/stat/RESULT = {"POWER3":"ON"}
ESP32_M5_01/stat/POWER3 = OFF

[timtimsson]

omg in works with retain and without json

mqtt.subscribe('ESP32_M5_01/stat/POWER3',
  def (topic, idx, payload, bin)
    var power3 = payload
    p1b22.text = f'POWER3 {power3}' 
    p1b22.val = (power3 == "ON") 
  end)

[sfromis]

In general, commands able to change something will report the current status if issuing the command (like Power3) without arguments. Or Power0 for all power channels.

Note that relying on retained payloads may be a "questionable" workaround, as you can get very old (and outdated) values, if it was not replaced, and missing if the broker was restarted without persistent retain database.

Using retain without fully dealing with the many pitfalls has led to much tearing out of hairs. 👨‍🦲