mirror of
https://github.com/wavelog/wavelog.git
synced 2026-03-22 10:24:14 +00:00
68 lines
2.0 KiB
PHP
68 lines
2.0 KiB
PHP
<?php
|
|
defined('BASEPATH') OR exit('No direct script access allowed');
|
|
|
|
require_once ('./src/phpMQTT.php');
|
|
|
|
class Mh {
|
|
private $ci;
|
|
private $mqsettings;
|
|
private $mqtt;
|
|
|
|
public function __construct() {
|
|
$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/');
|
|
}
|
|
|
|
public function connect() {
|
|
$server = $this->mqsettings['server'];
|
|
$port = $this->mqsettings['port'];
|
|
$clientId = uniqid('wl_');
|
|
|
|
if ($this->mqsettings['server'] != '') {
|
|
try {
|
|
$this->mqtt = @new Wavelog\phpMQTT($server, $port, $clientId);
|
|
|
|
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']);
|
|
return true;
|
|
} catch (Exception $e) {
|
|
log_message('error','Error while trying to connect to MQTT: '.$e->getMessage());
|
|
$this->mqtt=false;
|
|
}
|
|
}
|
|
}
|
|
|
|
public function disconnect() {
|
|
if ($this->mqtt) {
|
|
log_message('debug', 'disconnect from MQTT broker');
|
|
$this->mqtt->close();
|
|
}
|
|
}
|
|
|
|
public function wl_event($topic, $message) {
|
|
if ($this->mqsettings['server'] != '') {
|
|
if (!($this->mqtt)) {
|
|
$this->connect();
|
|
}
|
|
if ($this->mqtt) { // Failsafe. Check if REALLY connected before trying to puv
|
|
log_message('debug', 'published '.$this->mqsettings['prefix'].$topic.' -> '.$message.' to MQTT broker');
|
|
$this->publish($this->mqsettings['prefix'].$topic, $message);
|
|
}
|
|
}
|
|
}
|
|
|
|
private function publish($topic, $message) {
|
|
if ($this->mqtt) {
|
|
$this->mqtt->publish($topic, $message, 0);
|
|
} else {
|
|
log_message('error', 'Cannot publish message: MQTT connection not established');
|
|
}
|
|
}
|
|
}
|