package com.neolane;

import java.net.*;
import java.io.*;
import org.w3c.dom.*;
import javax.xml.parsers.*;

public class MyNeolaneAPIJavaApp {

	// Session token for authentication (login/password)
	static String strSessionToken = "api2/api2";
	
	// URL of Neolane server
	static String strUrl = "http://sandbox2.us.neolane.net/nl/jsp/soaprouter.jsp";
	
	// Build SOAP envelope message
	static String strQueryDefHeader = 
			
	 	"<?xml version='1.0' encoding='ISO-8859-1'?>" +
		"<SOAP-ENV:Envelope xmlns:xsd='http://www.w3.org/2001/XMLSchema' " + 
		" xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance' " +
		" xmlns:SOAP-ENV='http://schemas.xmlsoap.org/soap/envelope/'>" +
		"<SOAP-ENV:Body>"+
		"<ExecuteQuery xmlns:m='urn:xtk:queryDef' " +
		" SOAP-ENV:encodingStyle='http://xml.apache.org/xml-soap/literalxml'>"+
		"<sessiontoken xsi:type='xsd:string' " +
		"SOAP-ENV:encodingStyle='http://schemas.xmlsoap.org/soap/encoding/'>"+strSessionToken+"</sessiontoken>"+
		"<entity xsi:type='ns:Element'	SOAP-ENV:encodingStyle='http://xml.apache.org/xml-soap/literalxml'>";
	
	static String strQueryDefServiceBody =
		"<queryDef operation='select' schema='nms:service' xtkschema='xtk:queryDef'> " +
		"	<select>" +
		"		<node expr='@name' />" +
		"		<node expr='@created' />"+
		"		<node expr='desc' />"+
		"		<node expr='@id' />"+
		"		<node expr='@lastModified' />" +
		"		<node expr='@label' />" +
		"	</select>" +
		" 	<groupBy/> " +
		" 	<having/> " +
		" 	<orderBy> "+
		"		<node expr='@label' label='Label' sortDesc='0' /> "+
		" 	</orderBy> " + 
		" 	<where> " + 
		" 		<condition expr='@id != 0' /> " +  
		" 	</where> " +  
		"</queryDef>";
		
	static String strQueryDefRecipientBody =
	
		"<queryDef operation='select' schema='nms:recipient' xtkschema='xtk:queryDef' lineCount='50'> " +
		"	<select>" +
		"		<node expr='@firstName' />" +
		"		<node expr='@lastName' />"+
		"		<node expr='@email' />"+
		"		<node expr='@phone' />" +
		"		<node expr='[location/@stateCode]' alias='@myStateCode' />"+
		"		<node expr='[location/@countryCode]' alias='@myCountryCode' />"+
		"		<node expr='[folder/@fullName]' alias='@myFolderFullName' />" +
		"	</select>" +
		" 	<groupBy/> " +
		" 	<having/> " +
		" 	<orderBy> "+
		"		<node expr='@email'/> "+
		" 	</orderBy> "  
		+ "<where> "    
		+ "<condition boolOperator='AND' expr='@email LIKE &quot;john%&quot;'/> "
		+ "<condition expr='[folder/@name] = &quot;myCompanyRcp&quot;'/> "
		+ "</where> "
 	  	+ "</queryDef>";

	
	static String strQueryDefFooter =
		"</entity>" +
		"</ExecuteQuery>"+
		"</SOAP-ENV:Body>"+
		"</SOAP-ENV:Envelope>";

	static String strWriteHeader =
			
	"<?xml version='1.0' encoding='ISO-8859-1'?>" +
	"<soapenv:Envelope xmlns:soapenv='http://schemas.xmlsoap.org/soap/envelope/' xmlns:urn='urn:xtk:session'>"+
	"<soapenv:Header/>"+
	"<soapenv:Body>"+
	      "<urn:Write>"+
	        "<urn:sessiontoken>"+strSessionToken+"</urn:sessiontoken>"+
	        "<urn:domDoc>";
			
			
	static String strWriteFooter = 
		"</urn:domDoc>" +
		"</urn:Write>"+
		"</soapenv:Body>"+
		"</soapenv:Envelope>";
	
	public static void main(String s[]) 
	{
		 // Example One: Write to nms:recipient with insertOrUpdate with hierarchical XML objects
		WriteRecipientXMLObject(strSessionToken,strUrl);
		
		// Example Two: Write to nms:recipient with insertOrUpdate using a string converted to XML
		WriteRecipientXMLString(strSessionToken,strUrl);
		
		// Example Three: Query nms:service table in Neolane with a string converted to XML
		QueryService(strSessionToken,strUrl);
		
		// Example Four: Query nms:recipient for specific email and folder using XML hierarchical objects
		QueryRecipientXMLObject(strSessionToken,strUrl);
		
		// Example Five: Query nms:recipient for specific email and folder based on an XML string
		QueryRecipientXMLString(strSessionToken,strUrl);
		
	}

	 // Example One: Write to nms:recipient with insertOrUpdate with hierarchical XML objects
	public static void WriteRecipientXMLObject(String strSessionToken, String strUrl)
	{
		// TBD
	}
	
	// Example Two: Write to nms:recipient with insertOrUpdate using a string converted to XML
	public static void WriteRecipientXMLString(String strSessionToken, String strUrl)
	{
		try {
			URL url = new URL(strUrl);
			String strSoapAction = "xtk:persist#Write"; 
			HttpURLConnection connection = (HttpURLConnection) url.openConnection();
			System.out.println("connection = "+connection.toString());
					
			connection.setRequestProperty("Content-Type", "text/xml;charset=UTF-8");
			connection.setRequestProperty("SOAPAction", strSoapAction);
			connection.setDoOutput(true);
			connection.setDoInput(true);
			connection.setRequestMethod("POST");

			// be sure to insert trailing space at end of each line
            String strWriteRecipientBody =
            		
                "<recipient "
                    + "_operation='insertOrUpdate' "
                    + "_key='@email,@firstName,@lastName' "
                    + "xtkschema='nms:recipient' "
                    + "lastName='Mathis' "
                    + "firstName='Samantha K.' "
                    + "blackListEmail='0' "
                    + "email='samantha.k.mathis@yahoo.com' "
                    + "origin='WEBSITE' "
                    + "phone='+1 617-777-1234' "
                    + "birthDate='1985-01-01'> "
                    + "<location address1='1000 Washington Street' "
                        + "address2='3rd Floor' "
                        + "address3='' "
                        + "address4='' "
                        + "city='New York' "
                        + "stateCode='NY' "
                        + "countryCode='US' "
                        + "zipCode='10021'/> "
                    + "<folder name='myCompanyRcp'/> "
                + "</recipient> ";
					
			String strRequest = strWriteHeader + strWriteRecipientBody + strWriteFooter;
					
			PrintStream p = new PrintStream(connection.getOutputStream());
			p.println(strRequest);
			
			int iResponseCode = connection.getResponseCode();
			
			if( iResponseCode == HttpURLConnection.HTTP_OK ) 
			{
				// 	Parse XML result document
				InputStream inXml = connection.getInputStream();
				System.out.println("XML="+inXml.toString());
				
				System.out.println("Insert completed");
				
			}
			else
			{
				throw new Exception("Execution Error, response code="+iResponseCode);
			}
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
	}
	// ExampleThree: Query nms:service table in Neolane with a string converted to XML
	public static void QueryService(String strSessionToken, String strUrl)
	{
	 	try {
			URL url = new URL(strUrl);
			String strSoapAction = "xtk:queryDef#ExecuteQuery"; 
			HttpURLConnection connection = (HttpURLConnection) url.openConnection();
			
			System.out.println("connection = "+connection.toString());
					
			connection.setRequestProperty("Content-Type", "text/xml;charset=UTF-8");
			connection.setRequestProperty("SOAPAction", strSoapAction);
			connection.setDoOutput(true);
			connection.setDoInput(true);
			connection.setRequestMethod("POST");
			
			String strRequest = strQueryDefHeader + strQueryDefServiceBody + strQueryDefFooter;
			
			PrintStream p = new PrintStream(connection.getOutputStream());
			p.println(strRequest);
			
			int iResponseCode = connection.getResponseCode();
			
			if( iResponseCode == HttpURLConnection.HTTP_OK ) 
			{
				// 	Parse XML result document
				InputStream inXml = connection.getInputStream();
				System.out.println("XML="+inXml.toString());
				
				/*
				// Write the inputStream to a FileOutputStream
				OutputStream outputStream = new FileOutputStream(new File("C:\\temp\\output.xml"));
				int read = 0;
				byte[] bytes = new byte[1024];

				while ((read = inXml.read(bytes)) != -1) {
					outputStream.write(bytes, 0, read);
				}
				outputStream.close();
				*/
				
				DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory.newInstance();
				DocumentBuilder docBuilder = docBuilderFactory.newDocumentBuilder();
				Document doc = docBuilder.parse (inXml);  
	
	            // normalize text representation
	            doc.getDocumentElement().normalize();
	            System.out.println ("Root element of the doc is " + 
	                 doc.getDocumentElement().getNodeName());
		            
	            NodeList objects = doc.getElementsByTagName("service");
	            int count = objects.getLength();
	            System.out.println("Count of objects: " + count);
	
	            int objectLength = objects.getLength();
	            
	            for(int i=0; i<objectLength; i++)
	            {
	            	Node object = objects.item(i);
	                if(object.getNodeType() == Node.ELEMENT_NODE)
	                {
		        	   Element objElement = (Element)object;
		        	   String strName = objElement.getAttribute("name");
		        	   String strId = objElement.getAttribute("id");
		        	   String strLabel = objElement.getAttribute("label");
		        	   String dateCreated = objElement.getAttribute("created");
		        	   String dateModified = objElement.getAttribute("lastModified");
		        	   
		        	   System.out.println("name="+strName+" id="+strId+" label="+strLabel+
		        			   " created="+dateCreated+" lastModified="+dateModified);
	                }
	            }
			}
			else
				throw new Exception("Execution error !");
			
			}
			catch (Exception e)
			{
				e.printStackTrace();
			}

	}
	
	// Example Four; query nms:recipient for specific email and folder using XML hierarchical objects
	public static void QueryRecipientXMLObject(String strSessionToken, String strUrl)
	{
		// TBD
	}
	
	// Example Five; query nms:recipient for specific email and folder based on XML string
	public static void QueryRecipientXMLString(String strSessionToken, String strUrl)
	{
	 	try {
			
			URL url = new URL(strUrl);
			String strSoapAction = "xtk:queryDef#ExecuteQuery"; 
			HttpURLConnection connection = (HttpURLConnection) url.openConnection();
			
			System.out.println("connection = "+connection.toString());
					
			connection.setRequestProperty("Content-Type", "text/xml;charset=UTF-8");
			connection.setRequestProperty("SOAPAction", strSoapAction);
			connection.setDoOutput(true);
			connection.setDoInput(true);
			connection.setRequestMethod("POST");
			
			String strRequest = strQueryDefHeader + strQueryDefRecipientBody + strQueryDefFooter;
			
			PrintStream p = new PrintStream(connection.getOutputStream());
			p.println(strRequest);
			
			int iResponseCode = connection.getResponseCode();
			
			if( iResponseCode == HttpURLConnection.HTTP_OK ) 
			{
				// 	Parse XML result document
				InputStream inXml = connection.getInputStream();
				System.out.println("XML="+inXml.toString());
				
				/*
				// Write the inputStream to a FileOutputStream
				OutputStream outputStream = new FileOutputStream(new File("C:\\temp\\output.xml"));
				 			
				int read = 0;
				byte[] bytes = new byte[1024];
		 
				while ((read = inXml.read(bytes)) != -1) {
					outputStream.write(bytes, 0, read);
				}
		
				outputStream.close();
				*/
				
				DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory.newInstance();
				DocumentBuilder docBuilder = docBuilderFactory.newDocumentBuilder();
				Document doc = docBuilder.parse (inXml);  
	
	            // normalize text representation
	            doc.getDocumentElement().normalize();
	            System.out.println ("Root element of the doc is " + 
	                 doc.getDocumentElement().getNodeName());
		            
	            NodeList objects = doc.getElementsByTagName("recipient");
	            int count = objects.getLength();
	            System.out.println("Count of objects: " + count);
	
	            int objectLength = objects.getLength();
	            
	            for(int i=0; i<objectLength; i++)
	            {
	            	Node object = objects.item(i);
	                if(object.getNodeType() == Node.ELEMENT_NODE)
	                {
		        	   Element objElement = (Element)object;
		        	   String strFirstName = objElement.getAttribute("firstName");
		        	   String strLastName = objElement.getAttribute("lastName");
		        	   String strEmail = objElement.getAttribute("email");
		        	   String strMyStateCode = objElement.getAttribute("myStateCode");
		        	   String strMyCountryCode = objElement.getAttribute("myCountryCode");
		        	   String strMyFolderFullName = objElement.getAttribute("myFolderFullName");
		        	   
		        	   System.out.println("firstName="+strFirstName+" lastName="+strLastName+" email="+strEmail+
		        			   " stateCode="+strMyStateCode+" countryCode="+strMyCountryCode 
		        			   + " folderFullName="+strMyFolderFullName);
	                }
	            }
			}
			else
				throw new Exception("Execution error !");
			
			}
			catch (Exception e)
			{
				e.printStackTrace();
			}
		
		} // ExampleFive
} // MyNeolaneAPIJavaApp