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

A bit more integration (Still debug in it)

Browse Source
This commit is contained in:
int2001
2025-04-02 05:35:45 +00:00
parent a421d6fe24
commit e2d09632ea
2 changed files with 64 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
application/controllers/Dashboard.php
View File

@@ -172,7 +172,8 @@ class Dashboard extends CI_Controller {
}
$data['total_countries_needed'] = count($dxcc->result()) - $current;
$this->load->library('Mh');
$this->mh->wl_event('web/dashboard/'.$this->session->userdata('user_id'), json_encode($data));
$this->load->view('interface_assets/header', $data);
$this->load->view('dashboard/index');
$this->load->view('interface_assets/footer', $footerData);

62
application/libraries/Mh.php Normal file
View File

@@ -0,0 +1,62 @@
<?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['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)) {
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('error', 'disconnect from MQTT broker');
$this->mqtt->close();
}
}
public function wl_event($topic, $message) {
if ($this->mqsettings['server'] != '') {
if (!($this->mqtt)) {
$this->connect();
}
$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');
}
}
}