meshtastic/Meshtastic-Apple
1
0
Fork 0
mirror of https://github.com/meshtastic/Meshtastic-Apple.git synced 2026-04-20 22:13:56 +00:00
Code Issues Projects Releases Packages Wiki Activity

Subscribe to client proxy topic

Browse source
This commit is contained in:
Garth Vander Houwen 2023-08-06 21:11:58 -07:00
parent af94d05f84
commit 81f824c79c
1 changed files with 4 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

11
Meshtastic/Helpers/Mqtt/MqttClientProxyManager.swift
View file

@ -51,12 +51,10 @@ class MqttClientProxyManager {
let password = config.password
var root = config.root?.count ?? 0 > 0 ? config.root : "msh"
var prefix = root! + "/" + metadata.firmwareVersion!
var prefix = root! + "/2" //+ metadata.firmwareVersion!
var topic = prefix + "/#"
let qos = CocoaMQTTQoS(rawValue :UInt8(2))!
connect(host: host, port: port, username: username, password: password, topic: topic, qos: qos, cleanSession: true)
}
}
@ -75,13 +73,13 @@ class MqttClientProxyManager {
mqttClient.logLevel = .debug
mqttClient.willMessage = CocoaMQTTMessage(topic: "/will", string: "dieout")
mqttClient.autoReconnect = true
mqttClient.delegate = self
let success = mqttClient.connect()
if !success {
status = .error
} else {
mqttClient.subscribe(topic!, qos: qos)
//mqttClient.subscribe(topic!, qos: qos)
subscribe(topic: topic!, qos: MqttQos.atLeastOnce)
}
} else {
status = .error
@ -91,6 +89,7 @@ class MqttClientProxyManager {
func subscribe(topic: String, qos: MqttQos) {
let qos = CocoaMQTTQoS(rawValue :UInt8(qos.rawValue))!
mqttClient?.subscribe(topic, qos: qos)
print("MQTT Client Proxy subscribed to: " + topic)
}
func unsubscribe(topic: String) {
@ -156,8 +155,6 @@ extension MqttClientProxyManager: CocoaMQTTDelegate {
}
self.status = ack == .accept ? ConnectionStatus.connected : ConnectionStatus.error // Set AFTER sending onMqttError (so the delegate can detect that was an error while stablishing connection)
}
func mqtt(_ mqtt: CocoaMQTT, didPublishMessage message: CocoaMQTTMessage, id: UInt16) {