Compare commits
	
		
			2 Commits
		
	
	
		
			9f64b83844
			...
			6a70c3c9c9
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 6a70c3c9c9 | |||
| a0d759f58b | 
@@ -10,6 +10,8 @@ import org.apache.logging.log4j.Logger;
 | 
				
			|||||||
import spark.Request;
 | 
					import spark.Request;
 | 
				
			||||||
import spark.Response;
 | 
					import spark.Response;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import java.io.StringWriter;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
/**
 | 
					/**
 | 
				
			||||||
 * Controller used to handle XML tools: XPath, XSD validation, XQuery and XSLT
 | 
					 * Controller used to handle XML tools: XPath, XSD validation, XQuery and XSLT
 | 
				
			||||||
 * @author Adam Bem
 | 
					 * @author Adam Bem
 | 
				
			||||||
@@ -48,10 +50,12 @@ public class XmlController implements RestController {
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
    @ScopedControllerManifest(method = HandlerType.POST, path = "/xslt")
 | 
					    @ScopedControllerManifest(method = HandlerType.POST, path = "/xslt")
 | 
				
			||||||
    public void acceptRequestXslt(Request request, Response response) {
 | 
					    public void acceptRequestXslt(Request request, Response response) {
 | 
				
			||||||
 | 
					        System.out.println("received xslt");
 | 
				
			||||||
        acceptRequest(request, response, XmlJobType.XSLT);
 | 
					        acceptRequest(request, response, XmlJobType.XSLT);
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
    @ScopedControllerManifest(method = HandlerType.POST, path = "/xslt/addParam")
 | 
					    @ScopedControllerManifest(method = HandlerType.POST, path = "/xslt/param")
 | 
				
			||||||
    public void acceptRequestXsltAddParam(Request request, Response response) {
 | 
					    public void acceptRequestXsltAddParam(Request request, Response response) {
 | 
				
			||||||
 | 
					        System.out.println("received param");
 | 
				
			||||||
        acceptRequest(request, response, XmlJobType.XSLT_PARAM);
 | 
					        acceptRequest(request, response, XmlJobType.XSLT_PARAM);
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
    private void acceptRequest(Request request, Response response, XmlJobType xmlJobType) {
 | 
					    private void acceptRequest(Request request, Response response, XmlJobType xmlJobType) {
 | 
				
			||||||
@@ -63,7 +67,12 @@ public class XmlController implements RestController {
 | 
				
			|||||||
            return;
 | 
					            return;
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        if (requestBody.getProcessor() == null) {
 | 
					        if (requestBody.getProcessor() == null ) {
 | 
				
			||||||
 | 
					            if(requestBody.getProcessorData() != null){
 | 
				
			||||||
 | 
					                processRequest(new XmlJob(response, requestBody, xmlJobType));
 | 
				
			||||||
 | 
					                return;
 | 
				
			||||||
 | 
					            }
 | 
				
			||||||
 | 
					            System.out.println("getProcessor=null");
 | 
				
			||||||
            invalidEngineSelectedResponse(response);
 | 
					            invalidEngineSelectedResponse(response);
 | 
				
			||||||
            return;
 | 
					            return;
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
@@ -94,10 +103,9 @@ public class XmlController implements RestController {
 | 
				
			|||||||
            responseBody.setDuration(duration);
 | 
					            responseBody.setDuration(duration);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            xmlJob.getResponse().status(200);
 | 
					            xmlJob.getResponse().status(200);
 | 
				
			||||||
 | 
					           /* this.logger.info("Request (" + xmlJob.getXmlJobType() + ", " +
 | 
				
			||||||
            this.logger.info("Request (" + xmlJob.getXmlJobType() + ", " +
 | 
					 | 
				
			||||||
                    xmlJob.getEngine().getVersion() +
 | 
					                    xmlJob.getEngine().getVersion() +
 | 
				
			||||||
                    ") processed in " + duration + " ms.");
 | 
					                    ") processed in " + duration + " ms.");*/
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        } catch (Exception ex) {
 | 
					        } catch (Exception ex) {
 | 
				
			||||||
            responseBody = processingErrorResponse(ex, xmlJob);
 | 
					            responseBody = processingErrorResponse(ex, xmlJob);
 | 
				
			||||||
@@ -133,7 +141,12 @@ public class XmlController implements RestController {
 | 
				
			|||||||
        String result = null;
 | 
					        String result = null;
 | 
				
			||||||
        switch (xmlJob.getXmlJobType()) {
 | 
					        switch (xmlJob.getXmlJobType()) {
 | 
				
			||||||
            case XSLT_PARAM:
 | 
					            case XSLT_PARAM:
 | 
				
			||||||
                result = engine.addParam(requestBody.getData(), requestBody.getProcessorData());
 | 
					                System.out.println("xstl_param");
 | 
				
			||||||
 | 
					                System.out.println(requestBody.getProcessorData());
 | 
				
			||||||
 | 
					                System.out.println(requestBody.getParamName());
 | 
				
			||||||
 | 
					                System.out.println(requestBody.getParamValue());
 | 
				
			||||||
 | 
					                result = addParam(requestBody.getProcessorData(), requestBody.getParamName(), requestBody.getParamValue());
 | 
				
			||||||
 | 
					                break;
 | 
				
			||||||
            case XSLT:
 | 
					            case XSLT:
 | 
				
			||||||
                result = engine.processXSLT(requestBody.getData(), requestBody.getProcessorData());
 | 
					                result = engine.processXSLT(requestBody.getData(), requestBody.getProcessorData());
 | 
				
			||||||
                break;
 | 
					                break;
 | 
				
			||||||
@@ -146,7 +159,16 @@ public class XmlController implements RestController {
 | 
				
			|||||||
                        requestBody.getVersion());
 | 
					                        requestBody.getVersion());
 | 
				
			||||||
                break;
 | 
					                break;
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
        return new XMLResponseBody(result, "OK", requestBody.getVersion());
 | 
					        System.out.println("can we get here?");
 | 
				
			||||||
 | 
					        return new XMLResponseBody(result, "OK", requestBody.getProcessorData());
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    private String addParam(String processorData, String paramName, String paramValue) {
 | 
				
			||||||
 | 
					        System.out.println("addParamSaxon");
 | 
				
			||||||
 | 
					        processorData= processorData.replace("<xsl:template match=\"/\">", "<xsl:param name=\""+paramName+"\" select=\"'"+paramValue+"'\"/>\n\t\t<xsl:template match=\"/\">");
 | 
				
			||||||
 | 
					        StringWriter sw = new StringWriter();
 | 
				
			||||||
 | 
					        sw.write(processorData);
 | 
				
			||||||
 | 
					        return sw.toString();
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    private XMLResponseBody processingErrorResponse(Exception ex, XmlJob xmlJob) {
 | 
					    private XMLResponseBody processingErrorResponse(Exception ex, XmlJob xmlJob) {
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -7,7 +7,7 @@ import spark.Response;
 | 
				
			|||||||
public class XmlJob {
 | 
					public class XmlJob {
 | 
				
			||||||
    private final Response response;
 | 
					    private final Response response;
 | 
				
			||||||
    private final XMLRequestBody requestBody;
 | 
					    private final XMLRequestBody requestBody;
 | 
				
			||||||
    private final XmlEngine engine;
 | 
					    private XmlEngine engine;
 | 
				
			||||||
    private final XmlJobType xmlJobType;
 | 
					    private final XmlJobType xmlJobType;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    public XmlJob(Response response, XMLRequestBody requestBody, XmlEngine engine, XmlJobType xmlJobType) {
 | 
					    public XmlJob(Response response, XMLRequestBody requestBody, XmlEngine engine, XmlJobType xmlJobType) {
 | 
				
			||||||
@@ -16,7 +16,11 @@ public class XmlJob {
 | 
				
			|||||||
        this.engine = engine;
 | 
					        this.engine = engine;
 | 
				
			||||||
        this.xmlJobType = xmlJobType;
 | 
					        this.xmlJobType = xmlJobType;
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					    public XmlJob(Response response, XMLRequestBody requestBody, XmlJobType xmlJobType) {
 | 
				
			||||||
 | 
					        this.response = response;
 | 
				
			||||||
 | 
					        this.requestBody = requestBody;
 | 
				
			||||||
 | 
					        this.xmlJobType = xmlJobType;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
    public Response getResponse() {
 | 
					    public Response getResponse() {
 | 
				
			||||||
        return response;
 | 
					        return response;
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -1,7 +1,7 @@
 | 
				
			|||||||
package com.r11.tools.controller.internal;
 | 
					package com.r11.tools.controller.internal;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
public enum XmlJobType {
 | 
					public enum XmlJobType {
 | 
				
			||||||
    XPath("XPath"), XSD("XSD"), XQuery("XQuery"), XSLT("XSLT"), XSLT_PARAM("PARAM");
 | 
					    XPath("XPath"), XSD("XSD"), XQuery("XQuery"), XSLT("XSLT"), XSLT_PARAM("XSLT_PARAM");
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    XmlJobType(String type) {
 | 
					    XmlJobType(String type) {
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -15,19 +15,20 @@ public class XMLRequestBody {
 | 
				
			|||||||
    private String processor;
 | 
					    private String processor;
 | 
				
			||||||
    @SerializedName("version")
 | 
					    @SerializedName("version")
 | 
				
			||||||
    private String version;
 | 
					    private String version;
 | 
				
			||||||
 | 
					    @SerializedName("paramName")
 | 
				
			||||||
 | 
					    private String paramName;
 | 
				
			||||||
 | 
					    @SerializedName("paramValue")
 | 
				
			||||||
 | 
					    private String paramValue;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    public String getData() {
 | 
					    public String getData() {
 | 
				
			||||||
        return data;
 | 
					        return data;
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					    public String getProcessorData() {return processorData;}
 | 
				
			||||||
    public String getProcessorData() {
 | 
					    public String getParamName() {return paramName;}
 | 
				
			||||||
        return processorData;
 | 
					    public String getParamValue() {return paramValue;}
 | 
				
			||||||
    }
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
    public String getProcessor() {
 | 
					    public String getProcessor() {
 | 
				
			||||||
        return processor;
 | 
					        return processor;
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					 | 
				
			||||||
    public String getVersion() {
 | 
					    public String getVersion() {
 | 
				
			||||||
        return version;
 | 
					        return version;
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -11,5 +11,5 @@ public interface XmlEngine {
 | 
				
			|||||||
    String validate(String data, String xsd) throws Exception;
 | 
					    String validate(String data, String xsd) throws Exception;
 | 
				
			||||||
    String executeXQuery(String data, String xquery, String version) throws Exception;
 | 
					    String executeXQuery(String data, String xquery, String version) throws Exception;
 | 
				
			||||||
    public String getVersion();
 | 
					    public String getVersion();
 | 
				
			||||||
    String addParam(String data, String processorData) throws Exception;
 | 
					    String addParam(String processorData, String paramName, String paramValue) throws Exception;
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user