add debug
parent
77c10057fa
commit
30943f2a6b
|
@ -64,12 +64,28 @@ $mqtt->onMessage(function ($message) use (
|
|||
&$news,
|
||||
&$globalCounter,
|
||||
&$isRunning,
|
||||
$mqtt,
|
||||
$mqttTopic
|
||||
) {
|
||||
if ($mqttTopic . "/restart" === $message->topic) {
|
||||
$isRunning = false;
|
||||
return;
|
||||
}
|
||||
if ($mqttTopic . "/debug" === $message->topic) {
|
||||
$mqtt->publish(
|
||||
$mqttTopic . "/debug",
|
||||
strval(
|
||||
json_encode(
|
||||
$data,
|
||||
JSON_UNESCAPED_SLASHES +
|
||||
JSON_UNESCAPED_UNICODE +
|
||||
JSON_PRETTY_PRINT
|
||||
)
|
||||
),
|
||||
2
|
||||
);
|
||||
return;
|
||||
}
|
||||
$globalCounter++;
|
||||
$stats["messages"][] = time();
|
||||
|
||||
|
|
Loading…
Reference in New Issue