moha/moha.php

<?php
$title = "moha";
cli_set_process_title($title);
file_put_contents("/proc/".getmypid()."/comm",$title);
declare(ticks = 1);

$testMode = false;
$apiServerIsActive = true;

require "constants.php";

$listProperties = array("powerSource" => "batterie");
$listPropertiesKeys = array("expose");

//global variables

$notificationLevel = ALERT;
$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 friendly name
$indexTypes = array();
$indexProperties = array();		// index of properties
$hooksList = array();			// list of hooks to be included
$hooks = array();				// array of hooks
$topicsCallbacks = array();		// array of topics's callbacks
$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;
$devicesRequest = false;		//say to true when publishing device request to zigbee2mqtt

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, $device)
{
	global $notificationMethods;
	$result = false;

	//TODO destinataire selon fichier de config
	$destinataire = array("daniel");

	foreach($notificationMethods as $value)
	{
		foreach($destinataire as $dest)
		{
			$result =  $result | $value->send($message, $dest);
		}
	}
	return $result;
}

function logger($level, $log, $pos = "", $device=null, $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, $device) === false)
		{
			logger(INFO, _("Notification not sent"), __FILE__ . ":" . __LINE__, false);
			return true;
		}
	}
	return 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(ALERT, _("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";

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;
	}

}
// topics definition
listHooks("./topics_callbacks", $topicsCallbacks);
if (!empty($topicsCallbacks))
{
	foreach ($topicsCallbacks as $callback)
	{
		logger(INFO, _("Including ") . $callback, __FILE__ . ":" . __LINE__);
		include $callback;
	}
}

// making the list of hooks to include
listHooks("./hooks", $hooksList);
if (!empty($hooksList))		// 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;
		foreach($topics as $topicName => $topic )
		{
			$topic->notificationSent = false;
			logger(DEBUG, "topic: " . $topicName . " is " . bool2string($topic->notificationSent));
		}
	}

}

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();
	}
}



// Program start
logger(DEBUG, _("Program start"), __FILE__ . ":" . __LINE__, false);
$client = new Mosquitto\Client();


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;
logger(ALERT, _("Moha started"), __FILE__ . ":" . __LINE__);

while (true)
{
	$client->loop();			// mqtt server loop()

	if ($oneshot === false)		//	execute while the first loop :WARNING hooks can to be not initialized
	{
		logger(DEBUG, _("Oneshot part of loop"), __FILE__ . ":" . __LINE__, false);
		pws2mqttGetList();

		$oneshot = true;
	}
	$nn = 0;
	if($hooksInitialized == 0)			// all hooks are not initialized
	{
		$i = 1;
		foreach($hooks as $hookName => &$hook)
		{
			if ($hook->active === false)
			{
				$i = 1;
			}else
			{
				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();
	checkTopicsAvailability();
	if ($apiServerIsActive)		apiServer($read);
}

endMoha();

?>