mirror/Meshtastic-Android
1
0
Fork 0
mirror of https://github.com/meshtastic/Meshtastic-Android.git synced 2026-04-01 20:53:04 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat: add MQTT client proxy PKI topic

Browse Source
This commit is contained in:
andrekir
2024-08-25 10:44:18 -03:00
parent 807ddf4fd6
commit f85bcac5aa
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/src/main/java/com/geeksville/mesh/repository/network/MQTTRepository.kt
View File

@@ -85,11 +85,12 @@ class MQTTRepository @Inject constructor(
val callback = object : MqttCallbackExtended {
override fun connectComplete(reconnect: Boolean, serverURI: String) {
info("MQTT connectComplete: $serverURI reconnect: $reconnect ")
channelSet.subscribeList.forEach { globalId ->
subscribe("$rootTopic$DEFAULT_TOPIC_LEVEL$globalId/#")
if (mqttConfig.jsonEnabled) subscribe("$rootTopic$JSON_TOPIC_LEVEL$globalId/#")
info("MQTT connectComplete: $serverURI reconnect: $reconnect")
channelSet.subscribeList.ifEmpty { return }.forEach { globalId ->
subscribe("$rootTopic$DEFAULT_TOPIC_LEVEL$globalId/+")
if (mqttConfig.jsonEnabled) subscribe("$rootTopic$JSON_TOPIC_LEVEL$globalId/+")
}
subscribe("$rootTopic${DEFAULT_TOPIC_LEVEL}PKI/+")
}
override fun connectionLost(cause: Throwable) {