Public_Tools/wavelog
2
0
Fork 0
mirror of https://github.com/wavelog/wavelog.git synced 2026-03-22 10:24:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added (optional) user/pass for mqtt

Browse Source
This commit is contained in:
int2001
2025-04-02 06:38:33 +00:00
parent 9cb4c04ce5
commit cc4426335e
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
application/libraries/Mh.php
View File

@@ -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']);