Better test framework for IBM IIB/ACE 11

Idea / RFE Review. This capability has now been provided in ACE 12.0.1.0 ... Status is updated to Delivered.

Thank you for raising this RFE. ACEv11 has moved the product's capabilities in this area further forward, but it is acknowledged that there is much more we could do. In fact we have plans for this area which have been shared under Non-Disclosure Agreement as part of our Early Experience Program. Status of the RFE is updated to Planned for Future Release. Meanwhile we also intend to publish more collateral advertising the art of what is possible already in ACEv11. In the interim, until a more suitable publication location is exploited, the code snippet below may also be helpful to some users:

package com.ibm.dev;

import java.io.*;
import java.text.DateFormat;
import java.util.Base64;
import java.util.Date;
import java.util.Iterator;
import java.util.Locale;
import java.util.Map;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.xpath.XPath;
import javax.xml.xpath.XPathConstants;
import javax.xml.xpath.XPathExpressionException;
import javax.xml.xpath.XPathFactory;

import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;
import org.xml.sax.SAXException;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.ibm.integration.admin.http.HttpClient;
import com.ibm.integration.admin.http.HttpResponse;
import com.ibm.broker.config.common.XMLHelper;

public class UnitTestingACE {

public static void main(String[] args) {
log("=============================================================================================");
log("This v11 admin program uses the REST API across local comms to a local integration node");
log("=============================================================================================");

try {
String nodeName = "NODEFP7";
HttpClient httpClient = new HttpClient(nodeName);
// Start injection mode
HttpResponse httpResponse1 = httpClient.postMethod("/apiv2/servers/default/applications/ExampleApplication/messageflows/ExampleFlow/start-recording", "");
log("URL: "+ httpResponse1.getUrlPath());
log("StatusCode: "+ httpResponse1.getStatusCode());
log("ReasonCode: "+ httpResponse1.getReason());
HttpResponse httpResponse2 = httpClient.postMethod("/apiv2/servers/default/applications/ExampleApplication/messageflows/ExampleFlow/start-injection", "");
log("URL: "+ httpResponse2.getUrlPath());
log("StatusCode: "+ httpResponse2.getStatusCode());
log("ReasonCode: "+ httpResponse2.getReason());
String testData = "{\"testData\":{\"message\":\"PG1lc3NhZ2UgeG1sbnM6aWliPSJodHRwOi8vY29tLmlibS5paWIvbHQvMS4wIiBpaWI6cGFyc2VyPSJXU1Jvb3QiIGlpYjppbmplY3RhYmxlPSJ0cnVlIj48UHJvcGVydGllcyBpaWI6cGFyc2VyPSJXU1BST1BFUlRZUEFSU0VSIj48TWVzc2FnZVNldCBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCI+PC9NZXNzYWdlU2V0PjxNZXNzYWdlVHlwZSBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCI+PC9NZXNzYWdlVHlwZT48TWVzc2FnZUZvcm1hdCBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCI+PC9NZXNzYWdlRm9ybWF0PjxFbmNvZGluZyBpaWI6dmFsdWVUeXBlPSJJTlRFR0VSIj41NDY8L0VuY29kaW5nPjxDb2RlZENoYXJTZXRJZCBpaWI6dmFsdWVUeXBlPSJJTlRFR0VSIj4xMjA4PC9Db2RlZENoYXJTZXRJZD48VHJhbnNhY3Rpb25hbCBpaWI6dmFsdWVUeXBlPSJCT09MRUFOIj5GQUxTRTwvVHJhbnNhY3Rpb25hbD48UGVyc2lzdGVuY2UgaWliOnZhbHVlVHlwZT0iQk9PTEVBTiI+RkFMU0U8L1BlcnNpc3RlbmNlPjxDcmVhdGlvblRpbWUgaWliOnZhbHVlVHlwZT0iR01UVElNRVNUQU1QIj4yMDE5LTExLTI5IDIzOjA2OjIwLjc5OTwvQ3JlYXRpb25UaW1lPjxFeHBpcmF0aW9uVGltZSBpaWI6dmFsdWVUeXBlPSJJTlRFR0VSIj4tMTwvRXhwaXJhdGlvblRpbWU+PFByaW9yaXR5IGlpYjp2YWx1ZVR5cGU9IklOVEVHRVIiPjA8L1ByaW9yaXR5PjxSZXBseUlkZW50aWZpZXIgaWliOnZhbHVlVHlwZT0iQkxPQiI+MDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwPC9SZXBseUlkZW50aWZpZXI+PFJlcGx5UHJvdG9jb2wgaWliOnZhbHVlVHlwZT0iQ0hBUkFDVEVSIj5TT0FQLUhUVFA8L1JlcGx5UHJvdG9jb2w+PFRvcGljIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCIvPjxDb250ZW50VHlwZSBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiPmFwcGxpY2F0aW9uL3gtd3d3LWZvcm0tdXJsZW5jb2RlZDwvQ29udGVudFR5cGU+PElkZW50aXR5U291cmNlVHlwZSBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCI+PC9JZGVudGl0eVNvdXJjZVR5cGU+PElkZW50aXR5U291cmNlVG9rZW4gaWliOnZhbHVlVHlwZT0iQ0hBUkFDVEVSIiBpaWI6ZWxlbWVudFR5cGU9IjB4MDMwMDAwMDAiPjwvSWRlbnRpdHlTb3VyY2VUb2tlbj48SWRlbnRpdHlTb3VyY2VQYXNzd29yZCBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCI+PC9JZGVudGl0eVNvdXJjZVBhc3N3b3JkPjxJZGVudGl0eVNvdXJjZUlzc3VlZEJ5IGlpYjp2YWx1ZVR5cGU9IkNIQVJBQ1RFUiIgaWliOmVsZW1lbnRUeXBlPSIweDAzMDAwMDAwIj48L0lkZW50aXR5U291cmNlSXNzdWVkQnk+PElkZW50aXR5TWFwcGVkVHlwZSBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCI+PC9JZGVudGl0eU1hcHBlZFR5cGU+PElkZW50aXR5TWFwcGVkVG9rZW4gaWliOnZhbHVlVHlwZT0iQ0hBUkFDVEVSIiBpaWI6ZWxlbWVudFR5cGU9IjB4MDMwMDAwMDAiPjwvSWRlbnRpdHlNYXBwZWRUb2tlbj48SWRlbnRpdHlNYXBwZWRQYXNzd29yZCBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCI+PC9JZGVudGl0eU1hcHBlZFBhc3N3b3JkPjxJZGVudGl0eU1hcHBlZElzc3VlZEJ5IGlpYjp2YWx1ZVR5cGU9IkNIQVJBQ1RFUiIgaWliOmVsZW1lbnRUeXBlPSIweDAzMDAwMDAwIj48L0lkZW50aXR5TWFwcGVkSXNzdWVkQnk+PC9Qcm9wZXJ0aWVzPjxIVFRQSW5wdXRIZWFkZXIgaWliOnBhcnNlcj0iV1NJTlBIRFIiPjxIb3N0IGlpYjp2YWx1ZVR5cGU9IkNIQVJBQ1RFUiI+bG9jYWxob3N0Ojc4MDA8L0hvc3Q+PFVzZXItQWdlbnQgaWliOnZhbHVlVHlwZT0iQ0hBUkFDVEVSIj5jdXJsLzcuNTUuMTwvVXNlci1BZ2VudD48QWNjZXB0IGlpYjp2YWx1ZVR5cGU9IkNIQVJBQ1RFUiI+Ki8qPC9BY2NlcHQ+PENvbnRlbnQtTGVuZ3RoIGlpYjp2YWx1ZVR5cGU9IkNIQVJBQ1RFUiI+MjwvQ29udGVudC1MZW5ndGg+PENvbnRlbnQtVHlwZSBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiPmFwcGxpY2F0aW9uL3gtd3d3LWZvcm0tdXJsZW5jb2RlZDwvQ29udGVudC1UeXBlPjxYLU9yaWdpbmFsLUhUVFAtQ29tbWFuZCBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiPlBPU1QgaHR0cDovL2xvY2FsaG9zdDo3ODAwL0V4YW1wbGVGbG93IEhUVFAvMS4xPC9YLU9yaWdpbmFsLUhUVFAtQ29tbWFuZD48WC1RdWVyeS1TdHJpbmcgaWliOnZhbHVlVHlwZT0iQ0hBUkFDVEVSIj57fTwvWC1RdWVyeS1TdHJpbmc+PFgtU2VydmVyLU5hbWUgaWliOnZhbHVlVHlwZT0iQ0hBUkFDVEVSIj5sb2NhbGhvc3Q8L1gtU2VydmVyLU5hbWU+PFgtU2VydmVyLVBvcnQgaWliOnZhbHVlVHlwZT0iQ0hBUkFDVEVSIj43ODAwPC9YLVNlcnZlci1Qb3J0PjxYLVJlbW90ZS1BZGRyIGlpYjp2YWx1ZVR5cGU9IkNIQVJBQ1RFUiI+MTI3LjAuMC4xPC9YLVJlbW90ZS1BZGRyPjxYLVJlbW90ZS1Ib3N0IGlpYjp2YWx1ZVR5cGU9IkNIQVJBQ1RFUiI+bG9jYWxob3N0PC9YLVJlbW90ZS1Ib3N0PjxYLVNjaGVtZSBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiPmh0dHA8L1gtU2NoZW1lPjwvSFRUUElucHV0SGVhZGVyPjxCTE9CIGlpYjpwYXJzZXI9Im5vbmUiPjxVbmtub3duUGFyc2VyTmFtZSBpaWI6dmFsdWVUeXBlPSJDSEFSQUNURVIiIGlpYjplbGVtZW50VHlwZT0iMHgwMzAwMDAwMCI+PC9Vbmtub3duUGFyc2VyTmFtZT48QkxPQiBpaWI6dmFsdWVUeXBlPSJCTE9CIj43YjdkPC9CTE9CPjwvQkxPQj48L21lc3NhZ2U+\",\"localEnvironment\":\"PGxvY2FsRW52aXJvbm1lbnQgeG1sbnM6aWliPSJodHRwOi8vY29tLmlibS5paWIvbHQvMS4wIiBpaWI6cGFyc2VyPSJNUVJPT1QiIGlpYjppbmplY3RhYmxlPSJ0cnVlIj48RGVzdGluYXRpb24+PEhUVFA+PFJlcXVlc3RJZGVudGlmaWVyIGlpYjp2YWx1ZVR5cGU9IkJMT0IiPjQ1NTY0ODU0MDAwMDAwMDAwMDAwMDAwMGZkNDg2YWI5ZjA1YTAwMDAwMDAwMDAwMDwvUmVxdWVzdElkZW50aWZpZXI+PC9IVFRQPjwvRGVzdGluYXRpb24+PC9sb2NhbEVudmlyb25tZW50Pg==\",\"environment\":\"\",\"exceptionList\":\"\"}}";
HttpResponse httpResponse3 = httpClient.postMethod("/apiv2/servers/default/applications/ExampleApplication/messageflows/ExampleFlow/nodes/HTTPInput/inject", testData);
log("URL: "+ httpResponse3.getUrlPath());
log("StatusCode: "+ httpResponse3.getStatusCode());
log("ReasonCode: "+ httpResponse3.getReason());
HttpResponse httpResponse4 = httpClient.getMethod("/apiv2/servers/default/data/recorded-test-data?messageFlow=ExampleFlow");
log("URL: "+ httpResponse4.getUrlPath());
log("StatusCode: "+ httpResponse4.getStatusCode());
log("ReasonCode: "+ httpResponse4.getReason());
// ======================================================================================================
// === This section shows a simple way of checking the recorded test data ...
JsonFactory factory = new JsonFactory();
ObjectMapper mapper = new ObjectMapper(factory);
JsonNode node = mapper.readValue(httpResponse4.getBody().toString(), JsonNode.class);
JsonNode array = node.get("recordedTestData");
log("Number of objects in the array of recordedTestData is "+Integer.toString(array.size()));
JsonNode testData1 = array.get(1).get("testData");
JsonNode message = testData1.get("message");
byte[] decodedBytes = Base64.getDecoder().decode(message.asText());
String decodedString = new String(decodedBytes);
log("Decoded message is "+decodedString);
DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory.newInstance();
DocumentBuilder builder = docBuilderFactory.newDocumentBuilder();
StringBuilder xmlStringBuilder = new StringBuilder();
xmlStringBuilder.append(decodedString);
ByteArrayInputStream input = new ByteArrayInputStream(xmlStringBuilder.toString().getBytes("UTF-8"));
Document logicalTree = builder.parse(input);
Element logicalTreeRoot = logicalTree.getDocumentElement();
// This is the message injected into the map node ...
// String xPathAssertion = "/message/BLOB/BLOB[.='7b7d']";
// This is the message expected to come out of the map node ...
String xPathAssertion = "/message/BLOB/BLOB[.='5468697320697320616e206578616d706c65206f6620612068617264636f646564206f7574707574206d657373616765']";
XPath xPath = XPathFactory.newInstance().newXPath();
NodeList nodes = (NodeList)xPath.evaluate(xPathAssertion, logicalTreeRoot, XPathConstants.NODESET);
if (nodes.getLength() > 0) {
log("PASSED ASSERTION! Value of node was "+nodes.item(0).getTextContent()+" which matched the assertion "+xPathAssertion);
} else {
log("ASSERTION FAILED! Assertion was "+xPathAssertion);
}
// ======================================================================================================
HttpResponse httpResponse5 = httpClient.deleteMethod("/apiv2/servers/default/data/recorded-test-data");
log("URL: "+ httpResponse5.getUrlPath());
log("StatusCode: "+ httpResponse5.getStatusCode());
log("ReasonCode: "+ httpResponse5.getReason());
// ^^ Get clear injection working!
HttpResponse httpResponse6 = httpClient.postMethod("/apiv2/servers/default/applications/ExampleApplication/messageflows/ExampleFlow/stop-injection", "");
log("URL: "+ httpResponse6.getUrlPath());
log("StatusCode: "+ httpResponse6.getStatusCode());
log("ReasonCode: "+ httpResponse6.getReason());
HttpResponse httpResponse7 = httpClient.postMethod("/apiv2/servers/default/applications/ExampleApplication/messageflows/ExampleFlow/stop-recording", "");
log("URL: "+ httpResponse7.getUrlPath());
log("StatusCode: "+ httpResponse7.getStatusCode());
log("ReasonCode: "+ httpResponse7.getReason());

} catch (IOException | InterruptedException | XPathExpressionException e) {
e.printStackTrace();
} catch (SAXException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ParserConfigurationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

private static void log(String string) {
DateFormat df = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.MEDIUM, Locale.getDefault());
String formattedDate = df.format(new Date());
System.out.println("("+formattedDate+") "+string);
}

}