tester_src.tar

tester/util/SterlingTester.java0000770000175000017260000005521413515355605016572 0ustar  omsdevvboxsfpackage util;
/**
 * This class runs Customer API class or OOB APi or Service from command line.
 * 
 * Command Line Parameters:
 * 			-u=Sterling login id
 * 			-p=password
 * 			-c=component name  	 (Can be custom api class name or oob api name or a service name
 * 								 eg: -c=com.xxx.smcfs.api.shipment.ProcessASNMessage  or  -c=scheduleOrder or -c=CustomProcessOrderService) 
 * 			-m=method to run     (Name of the method in custom api class.
 * 								 eg: -m=invoke 
 * 								 Required only when a custom api component is being run.
 *			-k=custom|oob|service (kind of component. can be a custom api or out-of-box sterling api or service)
 *								 eg: -k=custom  -k=oob  -k=service  default is custom.) 
 * 			-i=input xml file	 (eg: -i=order.xml)
 * 			-t=template xml file (eg: -t=order_template.xml) 
 *			-nodebug			 (by default, when a custom API is run, it will be run in verbose mode unless -nodebug parameter is passed
 *								 eg: -nodebug )
 *			-console             (display output xml on the screen. if -console option not used, the output is written to file in $HOME/tester/output folder)
 *
 * @author jaydeep.parikh
 *
 *
Windows Batch FIle to run this class:

cls
@REM define 'yfs.api.security.enabled=Y' in custom_overrides.properties
@REM define 'yfs.api.security.token.enabled=Y' in custom_overrides.properties

@ECHO OFF
setlocal


call C:\Users\IBM_ADMIN\opt\IBM\bin\tmp.cmd


set AGENT_JAVA_OPTS= -Dvendor=shell -DvendorFile=C:/Users/IBM_ADMIN/opt/IBM/properties/servers.properties -DCACHE_PS=true -DDISABLE_DS_EXTENSIONS=Y

%AGENT_JAVA% -classpath C:/Users/IBM_ADMIN/opt/IBM/jar/bootstrapper.jar %AGENT_JAVA_OPTS% com.sterlingcommerce.woodstock.noapp.NoAppLoader  -f C:/Users/IBM_ADMIN/opt/IBM/properties/APPDynamicclasspath.cfg -class SterlingTester %*


goto END

:END
endlocal
 *
 *
 */


import java.lang.reflect.Method;
import java.nio.file.Paths;
import java.nio.file.Files;
import java.util.Properties;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;

import java.io.StringWriter;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.io.FileOutputStream;
import java.io.FileDescriptor;

import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;
import org.apache.xml.serialize.OutputFormat;
import org.apache.xml.serialize.XMLSerializer;

import com.yantra.interop.japi.YIFApi;
import com.yantra.interop.japi.YIFClientCreationException;
import com.yantra.interop.japi.YIFClientFactory;
import com.yantra.yfs.japi.YFSEnvironment;

public class SterlingTester {

	public static String STERLING_TIMEOUT = "300000"; // 5 minutes
	private static boolean isDebug = true;
	private static boolean isDisplayOutput = false;
	private YIFApi api = null;
	private String token = null;
	
	private static String mode = ""; 
	private static String outputFolder = System.getProperty("user.home") +  "/tester/output";
	private static String logFolder = System.getProperty("user.home") +  "/tester/logs";

	private static Object lock = new Object();
	
	/**
	 * Read xml file to be used as input to Custom API.
	 * 
	 *  (Method used only for testing purposes)
	 * reads a file (xml file) for the purpose of unit testing from command prompt
	 */
	private String readFile(String fileName) throws Exception {
		   java.io.FileInputStream ifs = new java.io.FileInputStream(new java.io.File(fileName));
		   int bytesAvailable = ifs.available();
		   byte[] bt = new byte[bytesAvailable];
		   ifs.read(bt);
		   String data = new String(bt);
		   ifs.close();
		   return data;

	}

	/**
	 *  Create XML document from xml string.
	 *  
	 *  (Method used only for testing purposes)
	 * converts xml string to DOM
	 */
	public Document getDocument(String data) throws Exception {
			if (data != null && data.trim().length() != 0) {
			    org.xml.sax.InputSource inSource = new org.xml.sax.InputSource(new java.io.StringReader(data));
	
				javax.xml.parsers.DocumentBuilderFactory fac = javax.xml.parsers.DocumentBuilderFactory.newInstance();
	
				fac.setNamespaceAware(false);
				javax.xml.parsers.DocumentBuilder dbdr = fac.newDocumentBuilder();
	
				return dbdr.parse(inSource);
			}
			return null;
	}
	
	public Document createDocument(String docElementTag) throws ParserConfigurationException {
		DocumentBuilderFactory fac = DocumentBuilderFactory.newInstance();

		DocumentBuilder dbdr = fac.newDocumentBuilder();

		Document doc = dbdr.newDocument();
		Element ele = doc.createElement(docElementTag);
		doc.appendChild(ele);
		return doc;
	}	
	
	public String getXmlString(Document doc) throws Exception {
		//log("inside getXmlString");
		OutputFormat outFmt = new OutputFormat("xml", "iso-8859-1", true);
		outFmt.setOmitXMLDeclaration(true);
		StringWriter strWriter = new StringWriter();
		XMLSerializer xmlSerializer = new XMLSerializer(strWriter, outFmt);
		xmlSerializer.serialize(doc);
		//log("exiting getXmlString");
		return strWriter.toString();
	}		

	/**
	 *  Generate YFSEnvironment xml document.
	 *  
	 *  (Method used only for testing purposes)
	 * Creates an instance of YFSEnvironment, for the purpose of unit testing from command prompt
	 */
	private YFSEnvironment getEnvironment(Object c, String userID, String password) throws Exception {

		String progid = "";
		if (c instanceof Class) {
			progid = ((Class) c).getClass().getName();
		} else  {
			progid = (String) c;
		}
		String envXmlString = "<YFSEnvironment progId='" + progid + "' userId='" + userID + "' password='" + password + "'/>" ;

		Document envXml = getDocument(envXmlString);

		api= getSterlingAPIInstance();
		YFSEnvironment env = api.createEnvironment(envXml);

		return env;
	}

	/**
	 * Generate Session Token using login api
	 *  
	 * @param env
	 * @param userID
	 * @param password
	 * @return
	 * @throws Exception
	 */
	private String getToken(YFSEnvironment env, String userID, String password) throws Exception {
		String tkn = "";
		if (token != null && (password == null || password.trim().length() == 0)) {
			tkn = token;
		} else {
			log("Generating new token...");
			api = getSterlingAPIInstance();
			Document input = getDocument("<Login LoginID='" + userID + "' Password='" +  password + "' Timeout='" + STERLING_TIMEOUT + "'/>");
			Document result = api.invoke(env, "login", input);
			if (result != null) {
				Element login = (Element) result.getElementsByTagName("Login").item(0);
				if (login != null) {
					tkn = login.getAttribute("UserToken");
				}
			}
		}
		return tkn;
	}
	
	private YIFApi getSterlingAPIInstance() throws YIFClientCreationException {
		if (api == null) {
			log("Generating new YIFApi...");
			synchronized(lock) {
				api = YIFClientFactory.getInstance().getApi("LOCAL");
			}
		} 
		return api;
	}		


	/**
	 * To be used for the purpose of unit testing from command prompt.
	 * 
	 * Accepts parameters:
	 * 			-u=SterlingLoginId
	 * 			-p=Password
	 *			-k=custom|oob|service (kind of component. can be a custom api or out-of-box sterling api or service
	 *								 eg: -k=custom  -k=oob   -k=service  default is custom.) 
	 * 			-c=component name	(eg: com.custom.smcfs.api.shipment.CustomProcessASNMessage  or createOrder  or CustomProcessOrderService) 
	 * 			-m=method to run    (eg: invoke) 
	 * 			-i=input xml file	(eg: order.xml)
	 * 			-t=template xml file	(eg: order_template.xml)
	 *			-nodebug			 (by default, when a custom API is run, it will be run in verbose mode unless -nodebug parameter is passed)
	 *          -console             (display output xml on the screen. if -console option not used, the output is written to file in $HOME/tester/output folder)
	 * 
	 * 
	 */
	public static void main(String[] s) throws Exception {
		
		SterlingTester tester = new SterlingTester();
		tester.mode = "CLI";
		Document reply = tester.runTest(s);
		
		System.exit(0);	
	}
	
	
	public Document runTest(String[] s) throws Exception {

		Document reply = null;
		PrintStream logStream = null;
		
		
		try {
				Properties props = new Properties();
				String userID = "";
				String password = "";
				String codeToTest = null;
				String methodToRun = null;
				String inputXMLFile = null;
				String templateXMLFile = null;
				boolean isOOBApi = false;
				boolean isService = false;
				boolean isCustomApi = true; // if -k param not defined, default the component type as 'custom'
				String outputXMLFile = null;
				String xmlInput = null; // can have xml string when -ix param is used
				String xmlTemplate = null; // can have xml string when -tx param is used
				
				
				for (int i = 0; i < s.length; i++) {
					//log(s[i]);
					if (s[i].startsWith("-c=")) {
						// component name (ap or service name)
						codeToTest = s[i].replace("-c=", "");
					} else if (s[i].startsWith("-m=")) {
						// method name
						methodToRun = s[i].replace("-m=", "");
					} else if (s[i].startsWith("-i=")) {
						// input xml file name
						inputXMLFile = s[i].replace("-i=", "");
					} else if (s[i].startsWith("-u=")) {
						// user id - sterling login id
						userID = s[i].replace("-u=", "");
					} else if (s[i].startsWith("-p=")) {
						// password
						password = s[i].replace("-p=", "");
					} else if (s[i].startsWith("-a=")) {
						// optional arguments to be passed on to the custom api
						if (s[i].indexOf("=")+1 < s[i].lastIndexOf("=")) {
							String k = s[i].substring(s[i].indexOf("=")+1,s[i].lastIndexOf("="));
							String v = s[i].substring(s[i].lastIndexOf("=")+1);
							log(k + " : " + v);
							props.setProperty(k,v);
						}
					} else if (s[i].startsWith("-k=")) {
						// kind of component - custom, oob, service
						if (s[i].equals("-k=oob")) {
							isOOBApi = true;
							isService = false;
							isCustomApi = false;
						} else if (s[i].equals("-k=service")) {
							isService = true;
							isOOBApi = false;
							isCustomApi = false;
						} else {
							isCustomApi = true;
							isOOBApi = false;
							isService = false;
						}
					} else if (s[i].startsWith("-nodebug")) {
						// do not do verbose logging
						isDebug = false;
					} else if (s[i].startsWith("-t=")) {
						// template xml file name
						templateXMLFile = s[i].replace("-t=", "");
					} else if (s[i].startsWith("-console")) {
						// display ouput xml on screen instead of saving in output file
						isDisplayOutput = true;
					} else if (s[i].startsWith("-ix=")) { 
						// used to pass input xml string as input parameter (an alternative to -i param)
						xmlInput = s[i].substring(4);
					} else if (s[i].startsWith("-tx=")) { 
						// used to pass template xml string as input parameter (an alternative to -t param)
						xmlTemplate = s[i].substring(4);
					}
				}
				
				if (codeToTest == null || (methodToRun == null && isCustomApi) || (inputXMLFile == null && xmlInput == null)) {
					
					if (mode.equals("CLI")) {
						System.exit(1);
						parametersMissing();
					}
				}
		
				
				logStream = redirectToLogFile(inputXMLFile);			
				log("Started Test.");
		
		
				if (isOOBApi) {
					log("Running OOB API: " + codeToTest);
					
					if (api == null) {
						api = getSterlingAPIInstance();
					}
		
					YFSEnvironment env = getEnvironment(codeToTest, userID, password);
					token = getToken(env, userID, password);
					
					log("Got user token: " + token);
					
					env.setTokenID(token);
					
					Document templateDoc = null;
					if (xmlTemplate == null || xmlTemplate.trim().length() == 0) {
						if (templateXMLFile != null) {
							templateDoc = getDocument(readFile(templateXMLFile));
						}
					} else {
						templateDoc = getDocument(xmlTemplate);
					}
					if (templateDoc != null) {
						env.setApiTemplate(codeToTest, templateDoc);
					}
		
					Document indoc = null;
					if (xmlInput == null) {
						indoc = getDocument(readFile(inputXMLFile));
					} else {
						indoc = getDocument(xmlInput);
					}	
					
					reply = (Document) api.invoke(env, codeToTest, indoc);
		
					env.clearApiTemplate(codeToTest);
					
					log("Done Running OOB API: " + codeToTest);
					if (reply  == null) {
						log("API returned null.");
					} else {
						if (!isDisplayOutput) {
							outputXMLFile = saveOutput(inputXMLFile, getXmlString(reply));
						}
					}
				
				} else if (isService) {
					
					if (api == null) {
						api = getSterlingAPIInstance();
					}
		
					YFSEnvironment env = getEnvironment(codeToTest, userID, password);
					token = getToken(env, userID, password);
					
					log("Got user token: " + token);
					
					env.setTokenID(token);
					
					Document indoc = null;
					if (xmlInput == null) {
						indoc = getDocument(readFile(inputXMLFile));
					} else {
						indoc = getDocument(xmlInput);
					}			
		
					reply = (Document) api.executeFlow(env, codeToTest, indoc);
					log("Done Running Service: " + codeToTest);
					if (reply  == null || !(reply instanceof Document)) {
						log("Service returned null.");
					} else {
						if (!isDisplayOutput) {
							outputXMLFile = saveOutput(inputXMLFile, getXmlString(reply));
						}
					}
					
				} else {
					
					Class c =  Class.forName(codeToTest, true, getClass().getClassLoader());
					log("Class Loaded: " + c.getName());
				
					/*
					if (isDebug) {
						// print all logging statements while testing
						Field[] f = c.getDeclaredFields();
						for (int i = 0; i < f.length; i++) {
							log("Field in Class Loaded: " + f[i].getName() + " " + f[i].getGenericType().toString());
							if (f[i].getGenericType().toString().equals("class com.yantra.yfc.log.YFCLogCategory")) {
								log("Turning logging on.");
								f[i].setAccessible(true);
								com.yantra.yfc.log.YFCLogCategory log = (com.yantra.yfc.log.YFCLogCategory)  f[i].get(com.yantra.yfc.log.YFCLogCategory.instance("com.yantra"));
								log.setLogAll(true);
							}
						}
					}
					*/
					
					Object classObject = c.newInstance();
					
					if (props.size() > 0) {
					   Class[] propsParam = new Class[1];
					   propsParam[0] = java.util.Properties.class;
					   Method setProperties = c.getMethod("setProperties", propsParam);
						   setProperties.invoke(classObject, props);
					}
			
		
		
					Class[] params = new Class[2];
					params[0] = YFSEnvironment.class;
					params[1] = Document.class;
		
					Method m = c.getMethod(methodToRun, params);
					log("Method loaded: " + m.getName());
					
					YFSEnvironment env = getEnvironment(c, userID, password);
					token = getToken(env, userID, password);
					
					log("Got user token: " + token);
					
					env.setTokenID(token);
		
		
					log("Running method: " + m);
					Document indoc = null;
					if (xmlInput == null) {
						indoc = getDocument(readFile(inputXMLFile));
					} else {
						indoc = getDocument(xmlInput);
					}
					Object obj = m.invoke(classObject, env, indoc);
					log("Done Running " + m + " method in class " + c.getName());
					if (obj != null && obj instanceof Document) {
						reply = (Document) obj;
						if (!isDisplayOutput) {
							outputXMLFile = saveOutput(inputXMLFile, getXmlString(reply));
						}
					}
				}
		
				log("Exiting Test.");
				if (mode.equals("CLI")) {
					resetRedirection();
					if (!isDisplayOutput && outputXMLFile != null) {
						log("*****OUTPUT FILE NAME: " + outputXMLFile );
					} else {
						if (reply  != null && (reply instanceof Document)) {
							System.out.println("*****REPLY:\n" + getXmlString(reply));
						} else {
							System.out.println("*****NO REPLY XML.");
						}
					}
				}

		} catch (java.lang.NoClassDefFoundError e) {
			//System.out.println("Catching NoClassDefFoundError");
			reply = handleError(e);
			//System.out.println(this.getXmlString(reply));
		} catch (java.lang.ClassNotFoundException e) {
			//System.out.println("Catching ClassNotFoundException");
			reply = handleError(e);
			//System.out.println(this.getXmlString(reply));
		} catch (Exception e) {
			//System.out.println("Catching Exception");
			reply = handleError(e);
			//System.out.println(this.getXmlString(reply));
		} finally {
			try {
				if (logStream != null) {
					logStream.flush();
					logStream.close();
				}
			} catch(Exception ee) {}
		}

		return reply;
	}

	private static void log(String s) {
		if (isDebug) {
			System.out.println(new java.util.Date()  + " Tester: " + s);
		} 
	}
	
	private Document handleError(java.lang.Throwable e) {
		Document errDoc = null;
		boolean isStackTraceErrorsDoc = false;
		StringWriter sw = null;
		PrintWriter pw = null;		
		try {
			sw = new StringWriter();
			pw = new PrintWriter(sw);
			e.printStackTrace(pw);
			pw.flush();
			sw.flush();			
			try {
				errDoc = this.getDocument(sw.toString());
				if (errDoc.getDocumentElement().getNodeName().equals("Errors")) {
					isStackTraceErrorsDoc = true;
				}
			} catch (Exception ee) {}
			if (!isStackTraceErrorsDoc) {
				errDoc = createDocument("Errors");
				Element docEle = errDoc.getDocumentElement();
				docEle.appendChild(errDoc.createTextNode(sw.toString()));
			}
		} catch (Exception ee) {}
		finally {
			try {
				pw.close();
				sw.close();
			} catch (Exception xx) {}
		}
		e.printStackTrace();	
		return errDoc;
	}
	
	private String saveOutput(String inputXMLFile, String replyXML) throws Exception {
		String outputXMLFile = inputXMLFile;
		if (outputXMLFile != null && outputXMLFile.trim().length() != 0) {
			if (mode.equals("CLI")) {
				if (!isDisplayOutput) {
					if (!Files.exists(Paths.get(outputFolder))) {
						File dir = new File(outputFolder);
						dir.mkdirs();
					}
					if (inputXMLFile.contains(".")) {
						int startPos = inputXMLFile.lastIndexOf(File.separator) > -1 ? 
								inputXMLFile.lastIndexOf(File.separator) + 1 : 0;						
						outputXMLFile = inputXMLFile.substring(startPos, inputXMLFile.lastIndexOf("."));
					}
					outputXMLFile = outputFolder + File.separator + outputXMLFile.concat("_out.xml");
					PrintWriter wrt = new PrintWriter(outputXMLFile);
					wrt.write(replyXML);
					wrt.flush();
					wrt.close();
				} 
			}
		}
		return outputXMLFile;
	}
	
	private PrintStream redirectToLogFile(String inputXMLFile) throws FileNotFoundException {
		String logFile = inputXMLFile;
		if (logFile != null && logFile.trim().length() != 0) {
			if (!Files.exists(Paths.get(logFolder))) {
				File dir = new File(logFolder);
				dir.mkdirs();
			}
			if (inputXMLFile.contains(".")) {
				int startPos = inputXMLFile.lastIndexOf(File.separator) > -1 ? 
						inputXMLFile.lastIndexOf(File.separator) + 1 : 0;
				logFile = inputXMLFile.substring(startPos, inputXMLFile.lastIndexOf("."));
			}
			logFile = logFolder + File.separator + logFile.concat(".log");
			
			PrintStream log = new PrintStream(logFile);
			System.out.println("*****LOG FILE NAME: " + logFile );
			System.setErr(log);
			System.setOut(log);
			return log;
		}
		return null;
	}
	
	private void resetRedirection() throws Exception {
		PrintStream log = new PrintStream(new FileOutputStream(FileDescriptor.out));
		System.setOut(log);
		System.setErr(log);
	}

	public YIFApi getAPI() throws YIFClientCreationException {
		return api;
	}

	public String getToken() {
		return token;
	}

	public void setAPI(YIFApi theApi) {
		api = theApi;
	}

	public void setToken(String theToken) {
		token = theToken;
	}
	
    public boolean isUserAuthorized(Document doc) {

    	try {
    		//System.out.println("isUserAuthorized input: " + this.getXmlString(doc));
    	} catch (Exception e)  {}
    	
    	
    	boolean isUserAuthorized = true;
    	Element rootEle = doc.getDocumentElement();
    	
    	
    	NodeList errorsList = rootEle.getElementsByTagName("Error");
    	
    	    	
    	for (int e = 0; errorsList != null && e < errorsList.getLength(); e++ ) {
    		Element errors = (Element) errorsList.item(e);
    		String errorCode = errors.getAttribute("ErrorCode");
    		log(errorCode);
    		if (errorCode.equals("YCP0427")) {
    			isUserAuthorized = false;
    			log("User is not authorized.");
    		}
    	}
    	//System.out.println("Exiting isUserAuthorized with: " + isUserAuthorized);
    	return isUserAuthorized;
    }
    
	private void parametersMissing() {
		System.err.println("\nMissing one or more paramaters: -u=<loginid> -p=<password> -c=<component> -m=<method> -i=<inputXmlFile> [-t=templateXmlFile] [-k=custom|api|service] [-nodebug] [-a=<ArgumentName>=<ArgumentValue> ...]\n");
		System.err.println("	 * Accepts parameters:\r\n" + 
				"	 * 	-u=SterlingLoginId   (A valid Sterling login id)\r\n" + 
				"	 * 	-p=Password          (Sterling user's password)\r\n" + 
				"	 * 	-c=component name    (name of API or Service. eg: -c=com.custom.smcfs.api.shipment.CustomProcessASNMessage  or -c=createOrder  or -c=CustomProcessOrderService) \r\n" + 
				"	 * 	-m=method to run     (method to invoke in custom api. only needed when running a custom api. eg: -m=invoke) \r\n" + 
				"	 * 	-i=input xml file    (input xml file name. eg: -i=order.xml)\r\n" + 
				"	 * 	-t=template xml file (optional parameter for template xml file name. eg: -t=order_template.xml)\r\n" + 
				"    *  -k=custom|oob|service (kind of component. can be a custom api or out-of-box sterling api or service). eg: -k=custom  -k=oob  -k=service default is custom.)\r\n" +  
				"	 *	-nodebug             (optional parameter, without this flag the API/Service runs in verbose mode. eg: -nodebug)\r\n" +
				"	 *	-console             (display output xml on the screen. if -console option not specified, the output is written to a file in " + outputFolder + " folder)\r\n");
		System.err.println("Examples:\n");
		System.err.println("Parameters for running custom API:\n -u=jaydeep.parikh -p=thepassword -c=com.xyz.order.api.CustomProcessOrder -m=invoke -i=process_order.xml");
		System.err.println("Parameters for running OOB API:\n -c=getOrderDetails -k=oob -i=/tmp/go.xml -t=/tmp/t.xml -console -nolog");
		System.err.println("Parameters for running Service:\n -u=jaydeep.parikh -p=thepassword -c=ConfirmShipmentService -k=service -i=order.xml");
		System.err.println("Parameters for running custom API with attributes:\n -u=jaydeep.parikh -p=thepassword -c=com.xyz.order.api.CustomProcessShipment -m=invoke -i=process_order.xml -a=LINE_TYPE=GC -a=ORDER_TYPE=WEB");
		System.err.println("\nOutput xml is saved in the " + outputFolder + " folder.");
		System.err.println("Output File Name: <InputFileName>_out.xml\n");
	}
}
tester/util/SterlingTestServer.java0000770000175000017260000001775513515355605017442 0ustar  omsdevvboxsfpackage util;
/**
 * Open firewll on the linux VM (centos) to allow incoming connection on port 9876.
 * sudo firewall-cmd --zone=public --add-port=9876/tcp 		[--permanent]
 */
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.URLDecoder;
import java.util.Date;
import java.util.HashMap;
import java.util.UUID;

import org.w3c.dom.Document;

import com.yantra.interop.japi.YIFApi;

public class SterlingTestServer {

	
	ServerSocket serverSocket = null;
	int serverPort = 9876;
	boolean isStopped = false;
	boolean isDebug = true;
	String sterlingTimeout = "300000"; // 5 minutes
	//private static HashMap<String, YIFApi> apiMap = new HashMap<String, YIFApi>();
	private static HashMap<String, String> tokenMap = new HashMap<String, String>();
	private static YIFApi api = null;
	
	public static void main(String[] s) throws IOException {
		
		SterlingTestServer sterlingTestServer = new SterlingTestServer();
		if (s != null && s.length > 0) {
			for (int i = 0 ; i < s.length; i++) {
				if (s[i].equals("-port")) {
					try {
						sterlingTestServer.serverPort = Integer.parseInt(s[i].replaceAll("-port=", ""));
					} catch (java.lang.Throwable e) {
						throw new IOException("Invalid Port# " + s[0]);
					}
				} else if (s[i].equals("-nodebug")) {
					sterlingTestServer.isDebug = false;
				} else 	if (s[i].equals("-timeout")) {
					sterlingTestServer.sterlingTimeout = s[i];
				}
			}
			sterlingTestServer.openServerSocket();
			sterlingTestServer.listen();
		} else {
			sterlingTestServer.printUsage();
		}
	}
	
    private void openServerSocket() {
        try {
            serverSocket = new ServerSocket(this.serverPort, 0, InetAddress.getByAddress(new byte[] {0x00,0x00,0x00,0x00}));
		   log("Socket Opened.");
        } catch (IOException e) {
            throw new RuntimeException("Cannot open port ", e);
        }
    }	
	
	private void listen() {
		   log("listening.");
	    while(! isStopped()){
	        Socket clientSocket = null;
	        try {
		   log("Waiting.");
	            clientSocket = serverSocket.accept();
	        } catch (IOException e) {
	            if(isStopped()) {
	                log("Server Stopped.") ;
	                return;
	            }
	            throw new RuntimeException(
	                "Error accepting client connection", e);
	        }
	        
	            new Thread(
	            new WorkerThread(
	            clientSocket)
	            ).start();
	        
	    }			
	}
	
    private synchronized boolean isStopped() {
        return this.isStopped;
    }
    
    public synchronized void stop(){
        this.isStopped = true;
        try {
            this.serverSocket.close();
        } catch (IOException e) {
            throw new RuntimeException("Error closing server", e);
        }
    }
    
    private void log(String s) {
    	if (isDebug) {
    		System.out.println(new Date() + ": " + s);
    	}
    }
    
    private void printUsage() {
    	System.err.println("Usage: java SterlingTestServer [-port=<port#>] [-nodebug] [-timeout=milliseconds]");
    	System.err.println("Defaults:\n port: " + this.serverPort);
    	System.err.println("logging: verbose logging.");
    	System.err.println("timeout: " + this.sterlingTimeout + " millis.");
    }
	
	class WorkerThread implements Runnable{

	    protected Socket clientSocket = null;
	    
	    
	    public WorkerThread(Socket clientSocket) {
	        this.clientSocket = clientSocket;
	    }

	    public void run() {
	    	log("*****New Worker");
	    	String sessionId = null;
	        try {
	            InputStreamReader input  = new InputStreamReader(clientSocket.getInputStream());
	            BufferedReader reader = new BufferedReader(input);
	            String line = reader.readLine(); 
	            StringBuffer sbf = new StringBuffer("");
	            while (line != null && !line.isEmpty()) {
	                line = reader.readLine();
	                sbf.append(line + "\n");
	                if (line.contains("Cookie") &&
	                	line.contains(" sessionid")) {
	                	sessionId = getCookie(line);
	                }
	            }
	            //log(sbf.toString());
	            StringBuffer payload = new StringBuffer("");
	            while (reader.ready()) {
	                payload.append((char) reader.read());
	                payload.append(line);
	            }
	            if (payload.toString().length() == 0 ) {
	            	log(".");
	            	return;
	            }	            
	            if (!isDebug) {
	            	payload.append("&-nodebug");
	            }
	            //log(payload.toString());
	            
	            String[] params = payload.toString().split("&");
	            for (int p = 0 ; p < params.length; p++) {
	            	params[p] = URLDecoder.decode(params[p], "UTF-8");
	            	//log(params[p]);
	            }
	            
	            SterlingTester tester = new SterlingTester();
	            tester.STERLING_TIMEOUT = sterlingTimeout;
	            Document doc = null;
	            
	            String token = null;
	            YIFApi api = null;
	            if (sessionId != null) {
		            token = tokenMap.get(sessionId);
		            //api = apiMap.get(sessionId);
	            }
	            
		        String outXml = "<NoReply/>";
		        log("Sending Request to Sterling OMS: " + new Date());
	            try {
	            	tester.setAPI(api);
	            	tester.setToken(token);
	            	doc = tester.runTest(params);
	            	if (doc != null) {
	            		outXml = tester.getXmlString(doc);
	            		token = tester.getToken();
	            		api = tester.getAPI();
	            		if (!tester.isUserAuthorized(doc)) {
	            			invalidateSession(sessionId);
	            		} else {
	                        createSession(sessionId, api, token);
	            		}
	            	}
	            } catch(Exception e) {
	            	e.printStackTrace();
	            }
	            log("Got Response from Sterling OMS: " + new Date());
	            if (sessionId == null) {
	            	sessionId = getUUID();
	            }
	            
	            OutputStream output = clientSocket.getOutputStream();

	            PrintWriter writer = new PrintWriter(output);
	            writeHeaders(writer, sessionId, api, token);
	            writer.println(outXml);
	            writer.flush();
	            writer.close();
	            output.close();
	            input.close();

	        } catch (IOException e) {
	            //report exception somewhere.
	            e.printStackTrace();
	        }
	    }
	    
	    private String getUUID() {
	    	UUID uuid = UUID.randomUUID();
	    	return uuid.toString();
	    }
	    private String getCookie(String line) {
	    	log("getCookie :" + line);
	    	String sid = null;
	    	String[] s = line.split("=");
	    	if (s != null && s.length > 0) {
	    		sid = s[s.length - 1];
	    		log(sid);
	    	}
	    	return sid;
	    }
	    private void writeHeaders(PrintWriter writer, String sessionId, YIFApi api, String token) {
            writer.println("HTTP/1.0 200 OK");
            writer.println("Server: SterlingTestServer/1.0");
            writer.println("Content-Type: application/xml");
            writer.println("Set-Cookie: sessionid=" + sessionId);
            writer.println(); // must have this blank line after all headers 
	    }
	    
	    private void createSession(String sessionId, YIFApi api, String token) {
            tokenMap.put(sessionId, token);
           // apiMap.put(sessionId, api);
	    }
	    
	    private void invalidateSession(String sessionId) {
    			//apiMap.remove(sessionId);
    			tokenMap.remove(sessionId);
	    }
	}	
	
	
}
tester/compile.sh0000700000175000017500000001407413514522401013720 0ustar  omsdevomsdevexport rt='/home/omsdev/devtoolkit/devtoolkit_docker/runtime'
export v1='9.5'
export v2='9_5'
export CLASSPATH=${CLASSPATH}:${rt}/jar/smcfs/${v1}/backport-util-concurrent.jar:${rt}/jar/smcfs/${v1}/cmgt-ariesPorting.jar:${rt}/jar/smcfs/${v1}/cmgt-base64.jar:${rt}/jar/smcfs/${v1}/cmgt-configurator.jar:${rt}/jar/smcfs/${v1}/cmgt-configuredItem.jar:${rt}/jar/smcfs/${v1}/cmgt-rulesEngine.jar:${rt}/jar/smcfs/${v1}/sivbe.jar:${rt}/jar/smcfs/${v1}/sjibe.jar:${rt}/jar/smcfs/${v1}/smcfsicons.jar:${rt}/jar/smcfs/${v1}/smcfsiconsbe.jar:${rt}/jar/smcfs/${v1}/smcfsshared.jar:${rt}/jar/smcfs/${v1}/ubxbe.jar:${rt}/jar/smcfs/${v1}/vasbe.jar:${rt}/jar/smcfs/${v1}/ycmbe.jar:${rt}/jar/smcfs/${v1}/ycsbe.jar:${rt}/jar/smcfs/${v1}/ydmbe.jar:${rt}/jar/smcfs/${v1}/yicbe.jar:${rt}/jar/smcfs/${v1}/yimbe.jar:${rt}/jar/smcfs/${v1}/yompbe.jar:${rt}/jar/smcfs/${v1}/ypmbe.jar:${rt}/jar/smcfs/${v1}/yscpbe.jar:${rt}/jar/smcfs/${v1}/yscwbe.jar:${rt}/jar/smcfs/${v1}/yswcbe.jar:${rt}/jar/sbc/${v1}/sbc_be.jar:${rt}/jar/sbc/${v1}/uishared.jar:${rt}/jar/COM_Add-in/${v1}_${v1}/saauishared.jar:${rt}/jar/COM_Add-in/${v1}_${v1}/ycdbe.jar:${rt}/jar/COM_Add-in/${v1}_${v1}/ycdbridge.jar:${rt}/jar/COM_Add-in/${v1}_${v1}/ycdclientbe.jar:${rt}/jar/COM_Add-in/${v1}_${v1}/ycdfop.jar:${rt}/jar/COM_Add-in/${v1}_${v1}/ycdjasper.jar:${rt}/jar/COM_Add-in/${v1}_${v1}/ycdshared.jar:${rt}/jar/sic_app/${v1}/sic_appbe.jar:${rt}/jar/scecore/${v1}/scecoreicons.jar:${rt}/jar/scecore/${v1}/scecoreshared.jar:${rt}/jar/scecore/${v1}/wmsbe.jar:${rt}/jar/com.ibm.sterling.afc.jsonutil/${v2}/com.ibm.sterling.afc.jsonutil.jar:${rt}/jar/json4j/1_1_0_0/JSON4J_Apache.jar:${rt}/jar/platform_afc/${v2}/platform_activity.jar:${rt}/jar/platform_afc/${v2}/platform_dv.jar:${rt}/jar/jakarta_oro/2_0_8/jakarta-oro-2.0.8.jar:${rt}/jar/dom4j/1_5_2/dom4j.jar:${rt}/jar/log4j/1_2_17/log4j-1.2.17.jar:${rt}/jar/slf4j/1_7_21/slf4j-api-1.7.21.jar:${rt}/jar/jose4j/0_6_4/jose4j-0.6.4.jar:${rt}/jar/icu4j/55_1/icu4j-55_1.jar:${rt}/jar/icu4j/55_1/icu4j-charset-55_1.jar:${rt}/jar/icu4j/55_1/icu4j-localespi-55_1.jar:${rt}/jar/javamail/1_4/mail.jar:${rt}/jar/commons_pool/1_4/commons-pool-1.4.jar:${rt}/jar/commons_net/1_4_1/commons-net-1.4.1.jar:${rt}/jar/commons_fileupload/1_3_3/commons-fileupload-1.3.3.jar:${rt}/jar/commons_io/2_2/commons-io-2.2.jar:${rt}/jar/ehcache/2_0_1/ehcache-core-2.0.1.jar:${rt}/jar/commons_lang/3_2/commons-lang3-3.2.jar:${rt}/jar/comm/2_0/comm.jar:${rt}/jar/soap/2_3_1/soap.jar:${rt}/jar/concurrent/1_3_4/concurrent.jar:${rt}/jar/commons_collections/3_2_2/commons-collections-3.2.2.jar:${rt}/jar/xslt4j/2_7_19/serializer.jar:${rt}/jar/xslt4j/2_7_19/xalan.jar:${rt}/jar/xml4j/4_5_16/xercesImpl.jar:${rt}/jar/xml4j/4_5_16/xml-apis.jar:${rt}/jar/geronimo/2_2/geronimo-jms_1.1_spec-1.1.1.jar:${rt}/jar/geronimo/2_2/geronimo-jsp_2.1_spec-1.0.1.jar:${rt}/jar/geronimo/2_2/geronimo-jta_1.1_spec-1.1.1.jar:${rt}/jar/geronimo/2_2/geronimo-servlet_2.5_spec-1.2.jar:${rt}/jar/lucene/4_10_4/lucene-analyzers-common-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-core-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-expressions-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-grouping-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-highlighter-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-join-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-memory-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-queries-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-queryparser-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-sandbox-4.10.4.jar:${rt}/jar/lucene/4_10_4/lucene-suggest-4.10.4.jar:${rt}/jar/httpcomponents_client/4_5/httpclient-4.5.jar:${rt}/jar/httpcomponents_core/4_4_1/httpcore-4.4.1.jar:${rt}/jar/httpcomponents_core/4_4_1/httpcore-nio-4.4.1.jar:${rt}/jar/httpcomponents_asyncclient/4_1/httpasyncclient-4.1.jar:${rt}/jar/jest/0_1_7/jest-0.1.7.jar:${rt}/jar/jest/0_1_7/jest-common-0.1.7.jar:${rt}/jar/datastax/3_0_0/cassandra-driver-core-3.0.0.jar:${rt}/jar/datastax/3_0_0/cassandra-driver-mapping-3.0.0.jar:${rt}/jar/gson/2_2_4/gson-2.2.4.jar:${rt}/jar/guava/17_0/guava-17.0.jar:${rt}/jar/metrics/3_0_2/metrics-core-3.0.2.jar:${rt}/jar/netty/4_0_33/netty-all-4.0.33.Final.jar:${rt}/jar/lz4/1_3_0/lz4-1.3.0.jar:${rt}/jar/jsch/0_1_52/jsch-0.1.52.jar:${rt}/jar/quartz/2_2_3/quartz-2.2.3.jar:${rt}/jar/platform_afc/${v2}/platform_afc.jar:${rt}/jar/platform/${v2}/entities.jar:${rt}/jar/platform_baseutils.jar:${rt}/jar/platform/${v2}/resources.jar:${rt}/jar/platform/${v2}/xapi.jar:${rt}/jar/install_foundation.jar:${rt}/jdk/lib/tools.jar:DB_JAR=${rt}/dbjar/jdbc/DB2/db2jcc4.jar:PROPERTIES=${rt}/properties:${rt}/jar/platform_uifwk/${v2}/platform_uifwk_be.jar:${rt}/jar/platform_uifwk/${v2}/platform_uifwk_ui.jar:${rt}/jar/commons_logging/1_0_4/commons-logging-1.0.4.jar:${rt}/jar/platform_afc_ui_impl/${v2}/platform_afc_ui_impl_be.jar:${rt}/jar/platform_sma_app/${v2}/platform_sma_app_be.jar:${rt}/jar/com.ibm.sterling.afc.cassandra/${v2}/com.ibm.sterling.afc.cassandra.jar:${rt}/jar/com.ibm.sterling.afc.jmx/${v2}/com.ibm.sterling.afc.jmx.jar:${rt}/jar/elasticsearch/1_7_1/elasticsearch-1.7.1.jar:${rt}/jar/platform_cuf_generator/${v2}/platform_cuf_generator.jar:${rt}/jar/sfs/${v1}/sfs_be.jar:${rt}/jar/ifs/${v1}/ifs_be.jar:${rt}/jar/wsc/${v1}/wsc_be.jar:${rt}/jar/isccs/${v1}/isccs_be.jar:${rt}/jar/mq/8_0/com.ibm.mq.headers.jar:${rt}/jar/mq/8_0/com.ibm.mq.jar:${rt}/jar/mq/8_0/com.ibm.mq.jmqi.jar:${rt}/jar/mq/8_0/com.ibm.mqjms.jar:${rt}/jar/mq/8_0/fscontext.jar:${rt}/jar/mq/8_0/jms.jar:${rt}/jar/mq/8_0/providerutil.jar:${rt}/jar/yfsextn/1_0/CYBSWsdd.jar:${rt}/jar/yfsextn/1_0/avalon-framework-4.2.0.jar:${rt}/jar/yfsextn/1_0/axis.jar:${rt}/jar/yfsextn/1_0/com.ibm.ffdc.jar:${rt}/jar/yfsextn/1_0/com.ibm.websphere.javaee.jaxrs.2.0_1.0.21.jar:${rt}/jar/yfsextn/1_0/com.ibm.websphere.javaee.servlet.3.1_1.0.21.jar:${rt}/jar/yfsextn/1_0/com.ibm.ws.security.crypto.jar:${rt}/jar/yfsextn/1_0/commons-discovery-0.2.jar:${rt}/jar/yfsextn/1_0/cybsclients15.jar:${rt}/jar/yfsextn/1_0/fop.jar:${rt}/jar/yfsextn/1_0/jackson-all-1.9.0.jar:${rt}/jar/yfsextn/1_0/jaxrpc.jar:${rt}/jar/yfsextn/1_0/wsdl4j-1.6.3.jar:${rt}/jar/yfsextn/1_0/wss4j-1.5.11.jar:${rt}/jar/yfsextn/1_0/xmlgraphics-commons-1.4.jar:${rt}/jar/yfsextn/1_0/xmlsec-1.4.3.jar:${rt}/jar/yfsextn/1_0/yfsextn.jar:.:

#echo $CLASSPATH
javac  $*