package net.ihe.xcpd.init.action;
import java.io.IOException;
import java.io.StringWriter;
import java.util.Date;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerException;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import net.ihe.gazelle.simulator.common.model.ApplicationConfiguration;
import net.ihe.xcpd.init.assertion.AssertionGenerator;
import net.ihe.xcpd.init.model.Assertion;
import net.ihe.xcpd.init.transport.Client2Server;
import net.ihe.xcpd.init.transport.SOAPSender2;
import org.w3c.dom.Element;
/**
* @author abderrazek boufahja
*/
public class HL7V3Responder {
public static String generateResponse(String requestV3, String wsURL, boolean isXUA) throws Exception{
if (wsURL == null) return null;
if (wsURL.equals("")) return null;
String requestSOAP = generateRequestSOAP(requestV3, isXUA, wsURL);
String res = SOAPSender2.sendToUrlAndGetResponse(wsURL, requestSOAP);
return res;
/*
if (!isXUA){
if (requestV3 != null && wsURL != null){
if ((!requestV3.equals(""))&&(!wsURL.equals(""))){
Client2Server c2s = new Client2Server();
responseV3 = c2s.getSOAPResponse(null, requestV3, wsURL);
//XUser xu = new XUser();
//Element e = xu.getServerResponse(null, requestV3, wsURL);
//responseV3 = formatDocument(e);
responseV3 = XmlFormatter.prettyFormat(responseV3,3);
}
}
}
else{
if (requestV3 != null && wsURL != null){
if ((!requestV3.equals(""))&&(!wsURL.equals(""))){
String STSurl = ApplicationConfiguration.getValueOfVariable("sts_url");
String serviceName = ApplicationConfiguration.getValueOfVariable("sts_service_name");
String port = ApplicationConfiguration.getValueOfVariable("sts_port");
String asser = AssertionGenerator.generateToken(STSurl, serviceName, port);
Assertion.mergeAssertion(new Assertion(asser, STSurl, serviceName, port, new Date()));
System.out.println("HL7V3Gen.asser = " + asser);
System.out.println("HL7V3Gen.requestV3 = " + requestV3);
Client2Server c2s = new Client2Server();
responseV3 = c2s.getSOAPResponse(asser, requestV3, wsURL);
//XUser xu = new XUser();
//Element e = xu.getServerResponse(asser, requestV3, wsURL);
if (responseV3 != null){
responseV3 = XmlFormatter.prettyFormat(responseV3,3);
}
}
}
}
return responseV3;
//*/
}
public static String generateRequestSOAP(String requestV3, boolean isXUA, String endPoint) throws Exception{
String requestSOAP = new String();
Client2Server c2s = new Client2Server();
if (!isXUA){
if (requestV3 != null){
if (!requestV3.equals("")){
requestSOAP = c2s.createMessageSoap(null, requestV3, endPoint);
}
}
}
else{
if (requestV3 != null){
if (!requestV3.equals("")){
String STSurl = ApplicationConfiguration.getValueOfVariable("sts_url");
String serviceName = ApplicationConfiguration.getValueOfVariable("sts_service_name");
String port = ApplicationConfiguration.getValueOfVariable("sts_port");
String nameID = ApplicationConfiguration.getValueOfVariable("nameID");
String patientID = ApplicationConfiguration.getValueOfVariable("patientID");
String asser = AssertionGenerator.generateToken(nameID,patientID);
Assertion.mergeAssertion(new Assertion(asser, new Date()));
System.out.println("HL7V3Gen.asser = " + asser);
System.out.println("HL7V3Gen.requestV3 = " + requestV3);
requestSOAP = c2s.createMessageSoap(asser, requestV3, endPoint);
}
}
}
return requestSOAP;
}
public static String formatDocument(Element document) throws IOException, TransformerException
{
TransformerFactory tf = TransformerFactory.newInstance();
Transformer trans = tf.newTransformer();
StringWriter sw = new StringWriter();
trans.transform(new DOMSource(document), new StreamResult(sw));
String theAnswer = sw.toString();
return theAnswer;
}
public static void main(String[] args) {
String init = "" +
"urn:idp:demozL9zR7P4yfNYaJs/WqLmx+EefCE=muDYOLU3Qu/GHRgwmTzWW85m05ch2UwrvUHY458fAhMIZx/uqX5RtZg0jGVSdemLfv0pvyh79yTycMKK9+1lsCDGO+uFuh4eM92CvaprwLEHx51beignvgmTh0meKdwv9RgNqUr3Vvu/OB1o2Lj2jPo0tTvkX4DAs1aU2dcmeXc=MIICUDCCAbkCBEn1/6gwDQYJKoZIhvcNAQEEBQAwbzELMAkGA1UEBhMCVVMxCzAJBgNVBAgTAk5DMRAwDgYDVQQHEwdSYWxlaWdoMRQwEgYDVQQKEwtSZWQgSGF0IEluYzEXMBUGA1UECxMOSkJvc3MgRGl2aXNpb24xEjAQBgNVBAMTCUpCb3NzIFNUUzAeFw0wOTA0MjcxODU1MzZaFw0wOTA3MjYxODU1MzZaMG8xCzAJBgNVBAYTAlVTMQswCQYDVQQIEwJOQzEQMA4GA1UEBxMHUmFsZWlnaDEUMBIGA1UEChMLUmVkIEhhdCBJbmMxFzAVBgNVBAsTDkpCb3NzIERpdmlzaW9uMRIwEAYDVQQDEwlKQm9zcyBTVFMwgZ8wDQYJKoZIhvcNAQEBBQADgY0AMIGJAoGBALLhiMoVU2xbw8GXcfAL+ts5j/mhjpbATfFlBN3hBHA7TiGYDu/EiJjEBsAdgtHiFTIYi0c1T6qFtXQjwL3k5uud8xzprm2qbNX2NJSyQ0mW024Y3mIaEJpmga6P7Q6VcOZSiZ7NqlZzLkStfY7tncaSsJWBhraz+VUL9NHXzT27AgMBAAEwDQYJKoZIhvcNAQEEBQADgYEArEeh+zEX7ibbf9qgDqOHyKV+7bnTy4IrWL5sbdOVWTuVoOYmxL5/bWqaWvNxnglKeWX+Nb9EOqEw1eyiNiDcFbBd/liIefq6yZTzdUhqDRitpFy/OyuF6p5NX4jRvyiPh4ifAn5SLGqfUNvi1m1K/JhVtG6leFZYvIYDv833coE=ihelocalurn:oasis:names:tc:SAML:2.0:ac:classes:X509" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"A*" +
"" +
"LivingSubject.name" +
"" +
"" +
"" +
"" +
"" +
"" +
"";
String rr = "" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"NOVAK" +
"JAN" +
"" +
"LivingSubject.name" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"" +
"";
try {
//String r = SOAPSender.sendMessageSoap("http://office.tiani-spirit.com:6102/SpiritProxy/XCPD", init);
//String r = SOAPSender.sendMessageSoap("http://jumbo-2.irisa.fr:8080/XCPDRESPSimulator-XCPDRESPSimulator/RespondingGatewayPortTypeImpl?wsdl", init);
// String r = SOAPSender2.sendToUrlAndGetResponse( "http://jumbo-2.irisa.fr:8080/XCPDRESPSimulator-XCPDRESPSimulator/RespondingGatewayPortTypeImpl?wsdl", rr);
String r = SOAPSender2.sendToUrlAndGetResponse( "http://office.tiani-spirit.com:6102/SpiritProxy/XCPD", init);
System.out.println("r = " + r);
} catch (Exception e) {
e.printStackTrace();
}
}
}