mqttdiscovery.php

<?php
include "include.php";
require("phpMQTT/phpMQTT.php");


/*
 *
 * TCP Ligthing Web UI 
 * 
 */


 if( TOKEN != "" ){
	if($ENABLE_MQTT == 0){
		echo "MQTT is not Enabled";
	} elseif($ENABLE_HA_DISCO == 0) {
		echo "Home Assistant Discovery is not Enabled";
	} else {


	$mqtt = new phpMQTT($MQTTserver, $MQTTport, $MQTTpub_id);
	
	//Get State of System Data
	$CMD = "cmd=GWRBatch&data=<gwrcmds><gwrcmd><gcmd>RoomGetCarousel</gcmd><gdata><gip><version>1</version><token>".TOKEN."</token><fields>name,image,imageurl,control,power,product,class,realtype,status</fields></gip></gdata></gwrcmd></gwrcmds>&fmt=xml";
	$result = getCurlReturn($CMD);
	
	$array = xmlToArray($result);
	
	//check if token is expired 
	if( !isset($array["gwrcmd"]) ){
		echo '<p>GWR Command not returned, this likely indicates your token is expired, or invalid.<p>';
		echo '<p>Remove token and try regenerating a new one.</p>';
		
		//unlink old token file
		if( file_exists("tcp.token") ){
			if( unlink("tcp.token") ){
				echo "<p>Successfully deleted expired token file</p>";
			}
		}
		
		if(USE_TOKEN_FILE){
			echo '<p>If you are continuously seeing this message, ensure the folder is writeable or that tcp.token is writeable</p>';
		}
		
		pageFooter();
		exit;
	}
	
	if( isset( $array["gwrcmd"]["gdata"]["gip"]["room"] ) ){
		$DATA = $array["gwrcmd"]["gdata"]["gip"]["room"];
	}else{
			echo "No Room Data";
			pa( $array );
			$DATA =  array();
			pageFooter();
			exit;
	}
	
	$deviceCount = 0;
	
	if( sizeof($DATA) > 0 ){
		if ( isset( $DATA["rid"] ) ){ $DATA = array( $DATA ); }
		
		foreach($DATA as $room){
			$RoomName = str_replace(' ', '_', $room['name']);			
			if( isset($room['rid'] ) ){
				$DEVICES = array();
			
				if( ! is_array($room["device"]) ){
					
				}else{
					$device = (array)$room["device"];
					if( isset($device["did"]) ){
						//item is singular device
						$DEVICES[] = $room["device"];
						$deviceCount++;
					}else{
					
						for( $x = 0; $x < sizeof($device); $x++ ){
							if( isset($device[$x]) && is_array($device[$x]) && ! empty($device[$x]) ){
								$DEVICES[] = $device[$x];
								$deviceCount++;
							}
						}
					}
				}
				if( sizeof($DEVICES) > 0 ){
						$unplugged = 0;
						$roomBrightness = 0;
						$roomDevices = 0;
						if ($mqtt->connect(true, retain, $MQTTusername, $MQTTpassword)) {
							foreach($DEVICES as $device){
								$DeviceName = str_replace(' ', '_', $device['name']);
                                $DeviceCommand = $RoomName."/".$DeviceName."/".$device['did'];
								$myObj->name = $device["name"];
                                $myObj->unique_id = $device['did'];
                                $myObj->command_topic = $MQTT_prefix."/".$DeviceCommand."/switch";
                                $myObj->state_topic = $MQTT_prefix."/".$DeviceCommand."/status";
                                $myObj->brightness_command_topic = $MQTT_prefix."/".$DeviceCommand."/brightness/set";
								$myObj->brightness_state_topic = $MQTT_prefix."/".$DeviceCommand."/brightness";
								$myObj->availability_topic = $MQTT_prefix."/".$DeviceCommand."/LWT";
                                $myObj->brightness_scale = 100;
                                $myObj->qos = 0;
                                $myObj->payload_on = "1";
                                $myObj->payload_off = "0";
                                $myObj->optimistic = "false";
                                
                                $myJSON = json_encode($myObj, JSON_UNESCAPED_SLASHES);
                                $Topic = $HASSTopic_id."/light/".$device['did']."/config";
                                //echo $myJSON.'<br/>';
                                //echo $Topic.'<br/>';

                                $mqtt->publishnoretain($Topic, $myJSON);
							}
							$mqtt->close();
						} else {
							echo "Time out!\n";
						}
				}else{
					echo 'No devices?';
					pa( $room );
				}
			}
		}
	}
	echo "Auto-Discovery Topics Published";

} 
}
?>