refactor: call mqtt::mqtt_init() from connection orchestration
This commit is contained in:
@@ -745,12 +745,7 @@ async fn try_connect_wifi_sntp_mqtt(
|
|||||||
let mqtt_connected = if board.board_hal.get_config().network.mqtt_url.is_some() {
|
let mqtt_connected = if board.board_hal.get_config().network.mqtt_url.is_some() {
|
||||||
let nw_config = board.board_hal.get_config().network.clone();
|
let nw_config = board.board_hal.get_config().network.clone();
|
||||||
let nw_config = mk_static!(NetworkConfig, nw_config);
|
let nw_config = mk_static!(NetworkConfig, nw_config);
|
||||||
match board
|
match mqtt::mqtt_init(nw_config, stack, spawner).await {
|
||||||
.board_hal
|
|
||||||
.get_esp()
|
|
||||||
.mqtt(nw_config, stack, spawner)
|
|
||||||
.await
|
|
||||||
{
|
|
||||||
Ok(_) => {
|
Ok(_) => {
|
||||||
info!("Mqtt connection ready");
|
info!("Mqtt connection ready");
|
||||||
true
|
true
|
||||||
|
|||||||
Reference in New Issue
Block a user