Solved #195 and cleaned up code (#196)

Co-authored-by: Adam Bem <adam.bem@zoho.eu>
Reviewed-on: #196
Reviewed-by: Dariusz Augustyniak <augustyd@noreply.example.com>
This commit is contained in:
2023-05-18 13:36:51 +02:00
parent 1930cde695
commit e697a783ae
5 changed files with 133 additions and 120 deletions

View File

@@ -44,7 +44,7 @@ public class SparkApplication {
RestControllerRegistry registry = new RestControllerRegistry(); RestControllerRegistry registry = new RestControllerRegistry();
registry.registerController(new ProcessorInfoController(logger, saxon, xalan)); registry.registerController(new ProcessorInfoController(logger, saxon, xalan));
registry.registerController(new XsdController(gson, logger, saxon, xalan)); registry.registerController(new XsdController(gson, logger, xalan));
registry.registerController(new XPathController(gson, logger, saxon, xalan)); registry.registerController(new XPathController(gson, logger, saxon, xalan));
registry.registerController(new XsltController(gson, logger, saxon, xalan)); registry.registerController(new XsltController(gson, logger, saxon, xalan));
registry.registerController(new JsonController(gson, jsongson, logger)); registry.registerController(new JsonController(gson, jsongson, logger));

View File

@@ -3,8 +3,6 @@ package com.r11.tools.controller;
import com.google.gson.Gson; import com.google.gson.Gson;
import com.google.gson.JsonObject; import com.google.gson.JsonObject;
import com.r11.tools.controller.internal.*; import com.r11.tools.controller.internal.*;
import com.r11.tools.xml.Saxon;
import com.r11.tools.xml.Xalan;
import com.r11.tools.xml.XmlEngine; import com.r11.tools.xml.XmlEngine;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import spark.Request; import spark.Request;
@@ -50,10 +48,6 @@ public class XPathController implements RestController {
String processor = requestJson.get("processor").getAsString(); String processor = requestJson.get("processor").getAsString();
String version = requestJson.get("version").getAsString(); String version = requestJson.get("version").getAsString();
String tmp = "";
long timeStart;
long duration;
if (processor == null) { if (processor == null) {
response.body("saxon, xalan"); response.body("saxon, xalan");
return; return;
@@ -62,35 +56,19 @@ public class XPathController implements RestController {
JsonObject responseJson = new JsonObject(); JsonObject responseJson = new JsonObject();
switch (processor) { switch (processor) {
case "saxon": case "saxon":
response.header("processor", "Saxon " + saxon.getVersion() + " " + version + " over s9api"); processWithSaxon(response, data, query, version, responseJson);
timeStart = System.currentTimeMillis(); break;
case "xalan":
try { processWithXalan(response, data, query, responseJson);
tmp = saxon.processXPath(data, query, version).getData().trim(); break;
default:
response.status(200); response.body("saxon, xalan");
}
responseJson.addProperty("result", tmp);
responseJson.addProperty("status", "OK");
} catch (Exception ex) {
this.logger.error("Error on processing XPath using Saxon. " + ex);
response.status(400);
responseJson.addProperty("result", ex.getMessage());
responseJson.addProperty("status", "ERR");
} }
duration = System.currentTimeMillis() - timeStart; private void processWithXalan(Response response, String data, String query, JsonObject responseJson) {
this.logger.info("Request (XPath, Saxon) processed in " + duration + " ms."); long timeStart;
long duration;
responseJson.addProperty("processor", "Saxon " + saxon.getVersion() + " " + version + " over s9api");
responseJson.addProperty("time", duration);
response.body(this.gson.toJson(responseJson));
return;
case "xalan":
response.header("processor", xalan.getVersion()); response.header("processor", xalan.getVersion());
timeStart = System.currentTimeMillis(); timeStart = System.currentTimeMillis();
@@ -118,9 +96,37 @@ public class XPathController implements RestController {
responseJson.addProperty("time", duration); responseJson.addProperty("time", duration);
response.body(this.gson.toJson(responseJson)); response.body(this.gson.toJson(responseJson));
return; }
default:
response.body("saxon, xalan"); private void processWithSaxon(Response response, String data, String query, String version, JsonObject responseJson) {
} long timeStart;
String tmp;
long duration;
response.header("processor", "Saxon " + saxon.getVersion() + " " + version + " over s9api");
timeStart = System.currentTimeMillis();
try {
tmp = saxon.processXPath(data, query, version).getData().trim();
response.status(200);
responseJson.addProperty("result", tmp);
responseJson.addProperty("status", "OK");
} catch (Exception ex) {
this.logger.error("Error on processing XPath using Saxon. " + ex);
response.status(400);
responseJson.addProperty("result", ex.getMessage());
responseJson.addProperty("status", "ERR");
}
duration = System.currentTimeMillis() - timeStart;
this.logger.info("Request (XPath, Saxon) processed in " + duration + " ms.");
responseJson.addProperty("processor", "Saxon " + saxon.getVersion() + " " + version + " over s9api");
responseJson.addProperty("time", duration);
response.body(this.gson.toJson(responseJson));
} }
} }

View File

@@ -18,13 +18,11 @@ public class XsdController implements RestController {
private final Gson gson; private final Gson gson;
private final Logger logger; private final Logger logger;
private final XmlEngine saxon;
private final XmlEngine xalan; private final XmlEngine xalan;
public XsdController(Gson gson, Logger logger, XmlEngine saxon, XmlEngine xalan) { public XsdController(Gson gson, Logger logger, XmlEngine xalan) {
this.gson = gson; this.gson = gson;
this.logger = logger; this.logger = logger;
this.saxon = saxon;
this.xalan = xalan; this.xalan = xalan;
} }

View File

@@ -57,41 +57,25 @@ public class XsltController implements RestController {
response.body("saxon, xalan"); response.body("saxon, xalan");
return; return;
} }
String tmp;
long timeStart;
long duration;
JsonObject responseJson = new JsonObject(); JsonObject responseJson = new JsonObject();
switch (processor) { switch (processor) {
case "saxon": case "saxon":
timeStart = System.currentTimeMillis(); processWithSaxon(response, data, query, version, responseJson);
try {
tmp = saxon.processXSLT(data, query);
response.status(200);
responseJson.addProperty("result", tmp);
responseJson.addProperty("status", "OK");
} catch (Exception ex) {
this.logger.error("Error on processing XSLT using Saxon. " + ex);
response.status(400);
responseJson.addProperty("result", ex.getMessage());
responseJson.addProperty("status", "ERR");
}
duration = System.currentTimeMillis() - timeStart;
this.logger.info("Request (XSLT, Saxon) processed in " + duration + " ms.");
responseJson.addProperty("processor", "Saxon " + saxon.getVersion() + " " + version);
responseJson.addProperty("time", duration);
response.body(this.gson.toJson(responseJson));
return; return;
case "xalan": case "xalan":
processWithXalan(response, data, query, responseJson);
return;
default:
response.body("saxon, xalan");
}
}
private void processWithXalan(Response response, String data, String query, JsonObject responseJson) {
long duration;
long timeStart;
String tmp;
timeStart = System.currentTimeMillis(); timeStart = System.currentTimeMillis();
try { try {
tmp = xalan.processXSLT(data, query); tmp = xalan.processXSLT(data, query);
@@ -116,10 +100,35 @@ public class XsltController implements RestController {
responseJson.addProperty("time", duration); responseJson.addProperty("time", duration);
response.body(this.gson.toJson(responseJson)); response.body(this.gson.toJson(responseJson));
return; }
default: private void processWithSaxon(Response response, String data, String query, String version, JsonObject responseJson) {
response.body("saxon, xalan"); long duration;
} String tmp;
long timeStart;
timeStart = System.currentTimeMillis();
try {
tmp = saxon.processXSLT(data, query);
response.status(200);
responseJson.addProperty("result", tmp);
responseJson.addProperty("status", "OK");
} catch (Exception ex) {
this.logger.error("Error on processing XSLT using Saxon. " + ex);
response.status(400);
responseJson.addProperty("result", ex.getMessage());
responseJson.addProperty("status", "ERR");
}
duration = System.currentTimeMillis() - timeStart;
this.logger.info("Request (XSLT, Saxon) processed in " + duration + " ms.");
responseJson.addProperty("processor", "Saxon " + saxon.getVersion() + " " + version);
responseJson.addProperty("time", duration);
response.body(this.gson.toJson(responseJson));
} }
} }

View File

@@ -103,7 +103,7 @@ public class Xalan implements XmlEngine{
return new XPathQueryResult(resultString.toString(), "node"); return new XPathQueryResult(resultString.toString(), "node");
} catch (TransformerException e) { } catch (TransformerException e) {
String returnData = XPathAPI.eval(doc, transform).toString(); String returnData = XPathAPI.eval(doc, transform).toString();
return new XPathQueryResult(data, "string"); return new XPathQueryResult(returnData, "string");
} }
} }