import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.MulticastSocket;
import android.os.Handler;
import android.util.Log;

public class STBMacId 
{
	
	DatagramPacket recPacket = null; 
	String responsemessage;
	public String discovery() throws IOException {
		// variable to store SSDP port
		final int SSDPPORT = 1900;
		//variable to store SSDPSEARCHPORT 
		final int SSDPSEARCHPORT = 1901;
		// Broadcast address to finding routers .
		final String SSDPIP = "239.255.255.250";
		// connection Time out .
		int TIME_OUT = 10000;
		// localhost_add address.
		final InetAddress localhost_add = InetAddress.getLocalHost();
		Log.d("localhost_add ", localhost_add.toString());		
		// Send from localhost:1901 address 		
		InetSocketAddress sourceAddress = new
		  InetSocketAddress(localhost_add, SSDPSEARCHPORT);
		Log.d("Port on Local host",sourceAddress.toString());
		// Send to  239.255.255.250:1900 address
		 InetSocketAddress destinationAddress = new InetSocketAddress(InetAddress.getByName(SSDPIP), SSDPPORT);
		 Log.d("Device ",destinationAddress.toString());
		  //  Generationg the request packet.
		  StringBuffer discoveryMsg = new StringBuffer();
		  discoveryMsg.append("M-SEARCH * HTTP/1.1\r\n");
		  discoveryMsg.append("HOST: " + SSDPIP + ":" + SSDPPORT +
		  "\r\n"); 
		  discoveryMsg.append("ST: urn:netgem:device:Netbox:1\r\n"); 	 
		  discoveryMsg.append("MAN: \"ssdp:discover\"\r\n");
		  discoveryMsg.append("MX: 3\r\n");
		  discoveryMsg.append("\r\n"); 
		  System.out.println("Request: " +	  discoveryMsg.toString() + "\n");
		  byte[] discoveryMsgBytes =
		  discoveryMsg.toString().getBytes(); 
		  
		  DatagramPacket discoveryPacket = new 							        DatagramPacket(discoveryMsgBytes,
		  discoveryMsgBytes.length, destinationAddress);
		 
		 
		 //Send multi-cast packet.
		 
		  
		 MulticastSocket multicastsocket = null; 
		 try {
	      multicastsocket = new MulticastSocket(null);
		  multicastsocket.bind(sourceAddress);
		  multicastsocket.setTimeToLive(4);
		  System.out.println("Send multicastsocket request."); 
		  // Sending multi-cast packet
		  multicastsocket.send(discoveryPacket); 
		  }
		  finally
		  { 
		System.out.println("multicastsocket ends. Close connection.");
		  multicastsocket.disconnect(); multicastsocket.close(); 
		  }
		  
		  // Listening  to response from the router in localarea. 
		 DatagramSocket wildDatagramSocket = null; 
		 
		 try {
		  wildDatagramSocket = new DatagramSocket(SSDPSEARCHPORT);
		  wildDatagramSocket.setSoTimeout(TIME_OUT);
		  // Sending datagram packet 
	        System.out.println("Send datagram packet.");
	        wildDatagramSocket.send(discoveryPacket);

	        while (true) {
	            try {
	                System.out.println("Receive ssdp response.");
	                receivePacket = new DatagramPacket(new byte[1536], 1536);
	                wildDatagramSocket.receive(receivePacket);
	               
	                System.out.println("Rec Packet "+receivePacket);
	                responsemessage = new String(receivePacket.getData());
	                System.out.println("Recieved messages:");
	                		//Message variable contains the response of STB
			    System.out.println(responsemessage);
	            } catch (Exception e) {
	                System.out.print("Time out."+e.getMessage());
	               }
	        }
	    } finally {
	        if (wildDatagramSocket != null) {
	            wildDatagramSocket.disconnect();
	            wildDatagramSocket.close();
	            
	        }
	        System.out.println("Message Value "+responsemessage);
	       
	    }
		 return responsemessage; 
	}
}

class STBMacIdChecking extends AsyncTask<String,Void,String> {

		@Override
		protected String doInBackground(String... params) {
			STBMacId stbid =new STBMacId();
			try {
				//message variable get the response of UPnP if connection is establish
				String message=stbid.discovery();
				
				//Extraction only url part from the complete request the response is in the format discuss above

				int httpindex=message.indexOf("http");
				
				int xmlindex=message.indexOf("xml");
				
				//Now STBUrl variable contain only the url on which the request is to be send for acessing STB MACID and IP
				String STBUrl= message.substring(httpindex, xmlindex);
				STBUrl=STBUrl+"xml";
				//XML Parsing to get macid and IP Address from xml response of STB
				XMLParserCls parser = new XMLParserCls();
				String xml = parser.getXmlFromUrl(STBUrl); // getting XML
				Document doc = parser.getXmlDomElement(xml); // getting DOM element

				NodeList nl = doc.getElementsByTagName("device");
				// getting root item nodes
					
					Element e = (Element) nl.item(0);
					 
					//UDN node of xml file contain the Macid  
					
					String macId= parser.getValue(e, "UDN");
					// presentationURL node of xml file contain the IP address of STB 
					stbip= parser.getValue(e, "presentationURL");
					
					//Extract only the stb ip part from the complete presentationURL value 
					stb_macid=  macId.substring( macId.lastIndexOf("-") +1,macId.length());
					
	}

		catch (Exception io) {
			Log.d("Error  is", io.getMessage());
			
		}
		return null;
		}


 

public class XMLParserCls {

	
	public XMLParserCls() {

	}

	
	 // Getting XML from URL making HTTP request param url string
	 
	public String getXmlFrom_Url(String url) {
		String xml = null;

		try {
			// defaultHttpClient
			DefaultHttpClient defaultHttpClient = new DefaultHttpClient();
			HttpPost httpPost = new HttpPost(url);

			HttpResponse httpResponse = defaultHttpClient.execute(httpPost);
			HttpEntity httpEntity = httpResponse.getEntity();
			xml = EntityUtils.toString(httpEntity);

		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		} catch (ClientProtocolException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		// return XML
		return xml;
	}
	
	
	 // Getting XML DOM element
	 
	public Document getXmlDomElement(String xml){
		Document doc = null;
		DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
		try {

			DocumentBuilder db = dbf.newDocumentBuilder();

			InputSource is = new InputSource();
		        is.setCharacterStream(new StringReader(xml));
		        doc = db.parse(is); 

			} catch (ParserConfigurationException e) {
				Log.e("Error: ", e.getMessage());
				return null;
			} catch (SAXException e) {
				Log.e("Error: ", e.getMessage());
	            return null;
			} catch (IOException e) {
				Log.e("Error: ", e.getMessage());
				return null;
			}

	        return doc;
	}
	
	/** Getting node value
	  * @param elem element
	  */
	 public final String getElementValue( Node elem ) {
	     Node child;
	     if( elem != null){
	         if (elem.hasChildNodes()){
	             for( child = elem.getFirstChild(); child != null; child = child.getNextSibling() ){
	                 if( child.getNodeType() == Node.TEXT_NODE  ){
	                     return child.getNodeValue();
	                 }
	             }
	         }
	     }
	     return "";
	 }
	 
	 /**
	  * Getting node value
	  * @param Element node
	  * @param key string
	  * */
	 public String getValue(Element item, String str) {		
			NodeList n = item.getElementsByTagName(str);		
			return this.getElementValue(n.item(0));
		}
}