177 lines
3.6 KiB
PHP
177 lines
3.6 KiB
PHP
<?php
|
|
|
|
//Constants
|
|
define( "EOL", "\n");
|
|
define("Z2M", "zigbee2mqtt");
|
|
|
|
|
|
|
|
|
|
declare(ticks = 1);
|
|
|
|
$listProperties = array("powerSource" => "batterie");
|
|
$listPropertiesKeys = array("property");
|
|
|
|
include "class/main.php";
|
|
|
|
//global variables
|
|
$topics = array(); // list of topics
|
|
$mids = array(); // list of message IDs
|
|
$devices = array(); // array of device objetcs
|
|
$indexDevices = array(); // index devices by ieee_address
|
|
$hooks = array(); // array of hooks
|
|
$notificationMethods = array(); // array of notification methods objects
|
|
$events = array(); // list of event objects
|
|
$changed = array(); // list of changed devices
|
|
$dbInit = false; // flag to indicate that desvices db is initialized
|
|
$connected = false; // connected to MQTT server
|
|
$nSubscribed = 0; // Number of topics subsribed
|
|
$included = false; // flag indicate scripts are loaded
|
|
$logFh = null; // filehandle of log file
|
|
|
|
// topics definition
|
|
$topics["zigbee2mqtt"] = new topic;
|
|
|
|
// gettext
|
|
bindtextdomain("moha", "./locale");
|
|
textdomain("moha");
|
|
|
|
if (!init()) exit(1);
|
|
|
|
require "mqtt_functions.php";
|
|
require "utils.php";
|
|
require "events.php";
|
|
require "db_functions.php";
|
|
|
|
$client = new Mosquitto\Client();
|
|
|
|
// log levels
|
|
define( "DEBUG", $client->LOG_DEBUG);
|
|
define( "INFO", 1);
|
|
define( "WARNING", 3);
|
|
define( "ERROR", 4);
|
|
$logLevel = LOG_DEBUG;
|
|
|
|
// defining callback functions
|
|
$client->onConnect('connectResponse');
|
|
$client->onDisconnect('disconnectResponse');
|
|
$client->onSubscribe('subscribeResponse');
|
|
$client->onUnsubscribe('unsubscribeResponse');
|
|
$client->onMessage('message');
|
|
$client->onLog('logger');
|
|
$client->onPublish('publishResponse');
|
|
|
|
|
|
//signal handling
|
|
pcntl_signal(SIGTERM, 'signalHandler');// Termination ('kill' was called)
|
|
pcntl_signal(SIGHUP, 'signalHandler'); // Terminal log-out
|
|
pcntl_signal(SIGINT, 'signalHandler');
|
|
|
|
// Program start
|
|
$client->connect("192.168.1.253", 1883, 5);
|
|
foreach($topics as $name => $topic)
|
|
{
|
|
//echo $name;
|
|
$topic->mid = $client->subscribe($name . "/#", 2);
|
|
$mids[$topic->mid] = $name;
|
|
$topic->status = false;
|
|
}
|
|
|
|
while (true)
|
|
{
|
|
$client->loop();
|
|
if ($dbInit == 2 and ! $included)
|
|
{
|
|
$hooksList = array();
|
|
loadHooks("./hooks", $hooksList);
|
|
//print_r($hooksList);
|
|
if (!empty($hooksList))
|
|
{
|
|
foreach ($hooksList as $hook)
|
|
{
|
|
echo "Including $hook" . EOL;
|
|
include $hook;
|
|
}
|
|
}
|
|
}elseif($dbInit == 2 and $included)
|
|
{
|
|
checkEvents();
|
|
}
|
|
}
|
|
|
|
endMoha();
|
|
|
|
function init()
|
|
{
|
|
global $logFh, $client;
|
|
date_default_timezone_set('Europe/Paris');
|
|
|
|
if (! $logFh = fopen("moha.log", "w") )
|
|
{
|
|
echo _("error opening log file");
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function loadHooks($dir, &$hookList)
|
|
{
|
|
global $included;
|
|
$files = scandir($dir);
|
|
//print_r($files);
|
|
foreach ($files as $file)
|
|
{
|
|
//echo "=====> $file" . EOL;
|
|
|
|
if ($file != "." and $file != "..")
|
|
{
|
|
//echo "not . or .." . EOL;echo strpos($file, ".php", -4) . EOL;
|
|
if (is_dir($dir . "/" . $file))
|
|
{
|
|
//echo "directory : " . $dir . '/' . $file . EOL;
|
|
loadHooks($dir . '/' . $file, $hookList);
|
|
}elseif (strpos($file, ".php", -4) !== false)
|
|
{
|
|
//echo "file : " . $dir . "/" . $file . EOL;
|
|
$hookList[] = $dir . "/" . $file;
|
|
}
|
|
}
|
|
}
|
|
//print_r($hookList);
|
|
$included = true;
|
|
}
|
|
|
|
|
|
|
|
function endMoha()
|
|
{
|
|
global $topics, $nSubscribed ,$client, $logFh, $connected;
|
|
$x = 0;
|
|
/*foreach($topics as $topic => $object)
|
|
{
|
|
if ($object->status)
|
|
{*/
|
|
$mid = $client->unsubscribe("#");
|
|
/*$mids[$mid] = $topic;
|
|
}
|
|
}*/
|
|
|
|
while ($connected)
|
|
{
|
|
//echo $nSubscribed;0x00124b0022ebac5c
|
|
if ( $x++ > 60)
|
|
{
|
|
$client->disconnect();
|
|
fclose($logFh);
|
|
exit (1);
|
|
}
|
|
$client->loop();
|
|
}
|
|
fclose($logFh);
|
|
exit(0);
|
|
}
|
|
|
|
|
|
|
|
?>
|