From cc4426335ee321d6a7f12c699f6989931beb398f Mon Sep 17 00:00:00 2001 From: int2001 Date: Wed, 2 Apr 2025 06:38:33 +0000 Subject: [PATCH] Added (optional) user/pass for mqtt --- application/libraries/Mh.php | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/application/libraries/Mh.php b/application/libraries/Mh.php index f4e3a5c84..b0edc806d 100644 --- a/application/libraries/Mh.php +++ b/application/libraries/Mh.php @@ -12,6 +12,8 @@ class Mh { $this->ci = & get_instance(); $this->mqsettings['server']=($this->ci->config->item('mqtt_server') ?? ''); $this->mqsettings['port']=($this->ci->config->item('mqtt_port') ?? 1883); + $this->mqsettings['user']=($this->ci->config->item('mqtt_username') ?? null); + $this->mqsettings['pass']=($this->ci->config->item('mqtt_password') ?? null); $this->mqsettings['prefix']=($this->ci->config->item('mqtt_prefix') ?? 'wavelog/'); } @@ -24,7 +26,7 @@ class Mh { try { $this->mqtt = @new Wavelog\phpMQTT($server, $port, $clientId); - if (!@$this->mqtt->connect(true, NULL)) { + if (!@$this->mqtt->connect(true, NULL, $this->mqsettings['user'],$this->mqsettings['pass'])) { throw new Exception('Failed to connect to MQTT broker'); } register_shutdown_function([$this, 'disconnect']);