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, NULL, $MQTTusername, $MQTTpassword)) {
							foreach($DEVICES as $device){
								$DeviceName = str_replace(' ', '', $device['name']);
                                $DeviceCommand = $RoomName."/".$DeviceName."/".$device['did'];
								$array = array(
									"name" => $device["name"],
									"unique_id" => $device['did'],
									"command_topic" => $MQTT_prefix."/".$DeviceCommand."/switch",
									"state_topic" => $MQTT_prefix."/".$DeviceCommand."/status",
									"brightness_command_topic" => $MQTT_prefix."/".$DeviceCommand."/brightness/set",
									"brightness_state_topic" => $MQTT_prefix."/".$DeviceCommand."/brightness",
									"availability_topic" => $MQTT_prefix."/".$DeviceCommand."/LWT",
									"brightness_scale" => 100,
									"qos" => 0,
									"payload_on" => "1",
									"payload_off" => "0",
									"optimistic" => "false",
									"device" => array(
										"ids" => $device['did'],
										"name" => $device["name"],
										"mf" => "TCP",
										"mdl" => "TCP Bulb"
									 )
								);
								$myJSON = json_encode($array, JSON_UNESCAPED_SLASHES);
                                $Topic = $HASSTopic_id."/light/".$device['did']."/config";
								//Uncomment the line below to see the formatted JSON being sent to the Home Assistant Discovery Topic
								//echo '<pre>'.json_encode($array, JSON_UNESCAPED_SLASHES | JSON_PRETTY_PRINT).'</pre>';

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

} 
}
?>