"batterie"); $listPropertiesKeys = array("expose"); //global variables $notificationLevel = ALERT | ERROR; $topics = array(); // list of topics $mids = array(); // list of message IDs $devices = array(); // array of device objetcs $indexDevices = array(); // index of devices by ieee_address $indexFriendlyNames = array(); // index of devices by freindly name $indexTypes = array(); // index of devices by type $hooksList = array(); // list of hooks to be included $hooks = array(); // array of hooks $notificationMethods = array(); // array of notification methods objects $events = array(); // list of event objects $monitored = array(); // list of device to watch $changed = array(); // list of changed devices $dbInit = 0; // flag to indicate that devices db is initializedl $connected = false; // connected to MQTT server $included = false; // flag indicate scripts are loaded $nSubscribed = 0; // Number of topics subsribed $logFh = null; // filehandle of log file $curlErr = 0; // Number of errors returned by curl $configDir = "./config"; // default config dir (production value is /etc/moha/) $hooksInitialized = 0; // are all hooks initialized ? false/true $flagHooks = false; if ($testMode) { $logLevel = ALL; // INFO | NOTICE | WARNING | ERROR | ALERT; //ALL; $mqttServerIp = "192.168.1.253"; // IP address of mqttserver in test mode $dataPath = "./"; $logFile = "./moha.log"; // Path of log file $configDir = "./config"; // default config dir (production value is /etc/moha/) $httpServerIp = "192.168.1.253"; }else { $logLevel = DEBUG | INFO | NOTICE | WARNING | ERROR | ALERT; $mqttServerIp = "127.0.0.1"; // IP address of mqttserver in production mode $dataPath = "/usr/share/moha/"; $logFile = "/var/log/moha.log"; // Path of log file $configDir = "/etc/moha"; // default config dir (production value is /etc/moha/) $httpServerIp = "127.0.0.1"; } if (!init()) exit(1); // gettext bindtextdomain("moha", "./locale"); textdomain("moha"); function notify($message) { global $notificationMethods; $result = false; foreach($notificationMethods as $value) { $result = $result | $value->send($message); } return $result; } function logger($level, $log, $pos = "", $notif = true) { global $logFh, $logLevel, $notificationLevel, $logLevels; $logString = $logLevels[$level] . " " ; if ($pos !== false) { $logString .= $pos; } $logString .= " - " . $log; if ($level & $logLevel) { fwrite($logFh, date("c") . ' ' . $logString . EOL); print ("MOHA-" . $logString . EOL); } $test = $level & $notificationLevel; if (($test != 0) and ($notif === true)) { if(notify("Moha\n" . $logString) === false) { logger(INFO, _("Notification not sent"), __FILE__ . ":" . __LINE__, false); } } } function init() { global $logFile, $logFh, $client; date_default_timezone_set('Europe/Paris'); if (! $logFh = fopen($logFile, "w") ) { echo _("error opening log file in ") . getcwd(); return false; } return true; } function listHooks($dir, &$hookList) { $files = scandir($dir); foreach ($files as $file) { if ($file != "." and $file != "..") { if (is_dir($dir . "/" . $file)) { listHooks($dir . '/' . $file, $hookList); }elseif (strpos($file, ".php", -4) !== false) { if (substr($file, -4) == ".php") { $hookList[] = $dir . "/" . $file; } } } } } function endMoha() { global $testMode, $devices, $topics, $events, $nSubscribed ,$client, $logFh, $connected, $dataPath; $x = 0; logger(WARNING, _("moha is ending"), __FILE__ . ":" . __LINE__); if (storeDB($devices, $dataPath . "devices.db") === false) { logger(ERROR, _("Can not store devices db" ), __FILE__ . ":" . __LINE__); } if (storeDB($topics, $dataPath . "topics.db") === false) { logger(ERROR, _("Can not store topics db" ), __FILE__ . ":" . __LINE__); } if (storeDB($events, $dataPath . "events.db") === false) { logger(ERROR, _("Can not store events db" ), __FILE__ . ":" . __LINE__); } if($testMode) file_put_contents($dataPath . "moha.devices", var_export($devices, true)); if ($connected) { $mid = $client->unsubscribe("#"); $client->disconnect(); while ($connected) { if ( $x++ >= 60) { fclose($logFh); exit (1); } $client->loop(); } } fclose($logFh); exit(0); } function connect2mqttServer() { global $client; $client->onConnect('connectResponse'); } logger(WARNING, _("starting moha"), __FILE__ . ":" . __LINE__); logger(DEBUG, _("requiring config files -> devices_constants.php"), __FILE__ . ":" . __LINE__); //include predefined file witch define constants for devices if (is_readable($configDir . "/devices_constants.php")) { include $configDir . "/devices_constants.php"; //echo "hooklist"; print_r($hooksList); echo EOL; logger(INFO, sprintf(_("%s/devices_constants.php found, so it has been included :-)"), $configDir), __FILE__ . ":" . __LINE__, false); }else { logger(WARNING, sprintf(_("%s/devices_constants.php not found, so not included :-)"), $configDir), __FILE__ . ":" . __LINE__, false); } logger(DEBUG, _("requiring php modules"), __FILE__ . ":" . __LINE__); require "class/main.php"; require "class/db.php"; require "class/hook_class.php"; require "utils.php"; require $configDir . "/properties2log.php"; require "mqtt_functions.php"; require "events.php"; require "db_functions.php"; require "apiserver/apiserver.php"; // topics definition listHooks("./topics_callbacks", $hooksList); if (!empty($hooksList)) { foreach ($hooksList as $callback) { logger(INFO, _("Including ") . $callback, __FILE__ . ":" . __LINE__); include $callback; } } // making the list of hooks to include listHooks("./hooks", $hooksList); if (!empty($hooksList)) // some hooks to include if hooklist is not empty { foreach ($hooksList as $hookFile) // loop to include hooks in hookslist { logger(INFO, _("Including ") . $hookFile, __FILE__ . ":" . __LINE__, false); include_once $hookFile; } if ($logLevel & DEBUG) { file_put_contents($dataPath . "moha.devices", var_export($devices, true)); // debugging : save device list } $included = true; } logger(DEBUG, _("Loading stored topics datas from ") . $dataPath . "topics.db", __FILE__ . ":" . __LINE__); if (file_exists($dataPath . "topics.db")) { if (($db = loadDB($dataPath . "topics.db")) === false) { logger(ERROR, _("Can not load topics db"), __FILE__ . ":" . __LINE__); }else { $topics = $db; } } logger(DEBUG, _("Loading stored devices datas from ") . $dataPath . "devices.db", __FILE__ . ":" . __LINE__); if (file_exists($dataPath . "devices.db")) { if (($db = loadDB($dataPath . "devices.db")) === false) { logger(ERROR, _("Can not load devices db"), __FILE__ . ":" . __LINE__); }else { $devices = $db; mkIndexes(); } } logger(DEBUG, _("Loading stored events datas from ") . $dataPath . "events.db", __FILE__ . ":" . __LINE__); if (file_exists($dataPath . "events.db")) { if (($db = loadDB($dataPath . "events.db")) === false) { logger(ERROR, _("Can not load events db"), __FILE__ . ":" . __LINE__); }else { $events = $db; } } // Program start logger(DEBUG, _("Program start"), __FILE__ . ":" . __LINE__, false); $client = new Mosquitto\Client(); // defining callback functions try { connect2mqttServer(); }catch ( Mosquitto\Exception $err) { logger(ALERT, sprintf(_("Error connecting to mosquitto server, retrying in 10 seconds:"), $err), __FILE__ . ":" . __LINE__, false); sleep (10); exit(1); } $client->onDisconnect('disconnectResponse'); $client->onSubscribe('subscribeResponse'); $client->onUnsubscribe('unsubscribeResponse'); $client->onMessage('messageReceived'); $client->onLog('logger'); $client->onPublish('publishResponse'); // connectong to mqtt server $client->connect($mqttServerIp, 1883, 5); logger(INFO, _("Subscribing to bridge"), __FILE__ . ":" . __LINE__, false); foreach($topics as $name => &$topic) { $topic->mid = $client->subscribe($name . "/#", 2); $mids[$topic->mid] = $name; $topic->status = false; } // starting main loop logger(INFO, _("Starting loop"), __FILE__ . ":" . __LINE__, false); $oneshot = false; while (true) { $client->loop(); // mqtt server loop() /*if (! $included) // hooks not already included { logger(DEBUG, _("Loading hooks list"), __FILE__ . ":" . __LINE__, false); if (!empty($hooksList)) // some hooks to include if hooklist is not empty { foreach ($hooksList as $hookFile) // loop to include hooks in hookslist { logger(INFO, _("Including ") . $hookFile, __FILE__ . ":" . __LINE__, false); include_once $hookFile; } if ($logLevel & DEBUG) { file_put_contents($dataPath . "moha.devices", var_export($devices, true)); // debugging : save device list } $included = true; } }else {*/ if ($oneshot === false) // execute while the first loop :WARNING hooks can to be not initialized { logger(DEBUG, _("Oneshot part of loop"), __FILE__ . ":" . __LINE__, false); $oneshot = true; } $nn = 0; if($hooksInitialized == 0) // all hooks are not initialized { $i = 1; foreach($hooks as $hookName => &$hook) { if ($hook->initialized === false and $hook->active === true) { logger(WARNING, _("Initializing Hook not completely initialized :") . $hookName, __FILE__ . ":" . __LINE__); $i &= $hook->installHooks($indexDevices); } } $hooksInitialized = $i; }elseif($flagHooks === false) { logger(DEBUG, _("All hooks initialized"), __FILE__ . ":" . __LINE__); $flagHooks = true; }else // executed when hooks initialization finished but database init not finished { //logger(DEBUG, _("looping"), __FILE__ . ":" . __LINE__); } checkEvents(); apiServer($read); //} } endMoha(); ?>