();
- for (Command c : com) {
- command_ids.add(c.id);
- }
- response.setCommands(command_ids);
+ // ── Bipolar ──────────────────────────────────────────────────────────────
- // response.setSemantics(AbstractExtensionReasonerFactory.Semantics.values());
- return response;
- }
-
- /**
- * Handles HTTP POST requests for bipolar extension reasoner operations.
- *
- * This method processes requests with the endpoint "/bipolar" that have the specified content types
- * for both request and response. It takes a BipolarReasonerPost object as the request body and returns
- * a Response object as the response body.
- *
- * The method checks the command (cmd) from the BipolarReasonerPost object and performs different
- * operations based on the command. If the command is "info," it delegates the request to the getInfo
- * method. If the command is "get_models" or "get_model," it processes the request using the DungTheory,
- * AbstractExtensionReasoner, and other components. The result includes information about the execution
- * time, answer, and status, which is encapsulated in a BipolarReasonerResponse object.
- *
- * In case of a timeout during execution, the method sets the response status to "TIMEOUT" and includes
- * the specified timeout duration. If any other exception occurs, the response status is set to "Error,"
- * and the method provides a generic response with a time of 0.0 and a null answer.
- *
- * If the command is not recognized or not applicable, the method returns a default BipolarReasonerResponse.
- *
- * @param bipolarReasonerPost The BipolarReasonerPost object representing the request payload.
- * @return A Response object representing the response payload.
- */
@PostMapping(value = "/bipolar", produces = "application/json", consumes = "application/json")
@ResponseBody
- public Response handleRequest(
- @RequestBody BipolarReasonerPost bipolarReasonerPost) {
-
- if (bipolarReasonerPost.getCmd().equals("info"))
- return (Response) getBipolarInfo(bipolarReasonerPost.getEmail());
-
- if (bipolarReasonerPost.getCmd().equals("get_models") || bipolarReasonerPost.getCmd().equals("get_model") || bipolarReasonerPost.getCmd().equals("get_credulous") || bipolarReasonerPost.getCmd().equals("get_skeptical")) {
- BipolarArgumentationFramework bbase = AbstractBipolarFrameworkFactory.getArgumentationFramework(bipolarReasonerPost.getNr_of_arguments(),
- bipolarReasonerPost.getAttacks(),
- bipolarReasonerPost.getSupports());
- BipolarSemantics semantics = BipolarSemantics.getSemantics(bipolarReasonerPost.getSemantics());
- AbstractBipolarExtensionReasoner reasoner = AbstractBipolarExtensionReasonerFactory.getReasoner(semantics);
- ExecutorService executor = Executors.newSingleThreadExecutor();
- BipolarReasonerResponse reasonerResponse = new BipolarReasonerResponse(
- bipolarReasonerPost.getCmd(),
- bipolarReasonerPost.getEmail(),
- bipolarReasonerPost.getNr_of_arguments(),
- bipolarReasonerPost.getAttacks(),
- bipolarReasonerPost.getSupports(),
- bipolarReasonerPost.getSemantics(),
- bipolarReasonerPost.getSolver(),
- null,
- 0,
- bipolarReasonerPost.getUnit_timeout(),
- "ERRORs");
- TimeUnit unit = Utils.getTimeoutUnit(bipolarReasonerPost.getUnit_timeout());
- var command = BipolarReasonerCalleeFactory.Command.getCommand(bipolarReasonerPost.getCmd());
- Callee callee = BipolarReasonerCalleeFactory.getCallee(command, reasoner, bbase);
- int user_timeout = Utils.checkUserTimeout(bipolarReasonerPost.getTimeout(), SERVICES_TIMEOUT_DUNG, unit);
- try {
- // handle timeout
- Future>> future = executor.submit(callee);
- Pair>, Long> result = Utils.runServicesWithTimeout(future,
- user_timeout, unit);
- executor.shutdownNow();
- reasonerResponse.setTime(result.getValue());
- reasonerResponse.setAnswer(result.getKey().toString());
- reasonerResponse.setStatus("SUCCESS");
- } catch (TimeoutException e) {
- reasonerResponse.setTime(bipolarReasonerPost.getTimeout());
- reasonerResponse.setAnswer(null);
- reasonerResponse.setStatus("TIMEOUT");
- executor.shutdownNow();
- } catch (Exception e) {
- reasonerResponse.setTime(0.0);
- reasonerResponse.setAnswer(null);
- reasonerResponse.setStatus("Error");
+ public Response handleRequest(@RequestBody BipolarReasonerPost post) {
+ if (post.getCmd().equals("info"))
+ return getBipolarInfo(post.getEmail());
- executor.shutdownNow();
- }
- return reasonerResponse;
- } else {
+ BipolarReasonerCalleeFactory.Command cmd = BipolarReasonerCalleeFactory.Command.getCommand(post.getCmd());
+ if (cmd == null)
return new BipolarReasonerResponse();
- }
+
+ BipolarArgumentationFramework bbase = AbstractBipolarFrameworkFactory.getArgumentationFramework(
+ post.getNr_of_arguments(), post.getAttacks(), post.getSupports());
+ AbstractBipolarExtensionReasoner reasoner = AbstractBipolarExtensionReasonerFactory.getReasoner(
+ BipolarSemantics.getSemantics(post.getSemantics()));
+ Callee callee = BipolarReasonerCalleeFactory.getCallee(cmd, reasoner, bbase);
+ TimeUnit unit = Utils.getTimeoutUnit(post.getUnit_timeout());
+ int userTimeout = Utils.checkUserTimeout(post.getTimeout(), SERVICES_TIMEOUT_DUNG, unit);
+
+ BipolarReasonerResponse response = new BipolarReasonerResponse(post.getCmd(), post.getEmail(),
+ post.getNr_of_arguments(), post.getAttacks(), post.getSupports(), post.getSemantics(),
+ post.getSolver(), null, 0, post.getUnit_timeout(), "ERROR");
+ ExecutionResult r = runCallee(callee, userTimeout, post.getTimeout(), unit);
+ response.setAnswer(r.answer);
+ response.setTime(r.time);
+ response.setStatus(r.status);
+ return response;
}
private BipolarServicesInfoResponse getBipolarInfo(String email) {
@@ -809,172 +469,79 @@ private BipolarServicesInfoResponse getBipolarInfo(String email) {
response.setReply("info");
response.setEmail(email);
response.setBackend_timeout(SERVICES_TIMEOUT_DUNG);
- var sem = AbstractBipolarExtensionReasonerFactory.getSemantics();
- ArrayList semantics_ids = new ArrayList();
- for (var s : sem) {
+ ArrayList semantics_ids = new ArrayList<>();
+ for (var s : AbstractBipolarExtensionReasonerFactory.getSemantics())
semantics_ids.add(s.id);
- }
response.setSemantics(semantics_ids);
-
- BipolarReasonerCalleeFactory.Command[] com = BipolarReasonerCalleeFactory.getCommands();
- ArrayList command_ids = new ArrayList();
- for (var c : com) {
+ ArrayList command_ids = new ArrayList<>();
+ for (var c : BipolarReasonerCalleeFactory.getCommands())
command_ids.add(c.id);
- }
response.setCommands(command_ids);
-
return response;
}
+ // ── DeLP ─────────────────────────────────────────────────────────────────
- /**
- * Handles HTTP POST requests for Defeasible logic programming DeLP Reasoner operations.
- *
- * This method processes requests with the endpoint "/delp" that have the specified content types
- * for both request and response. It takes a DeLPPost object as the request body and returns a
- * DelpResponse object as the response body.
- *
- * The method prints the received DelpPost object to the console for debugging purposes. It then
- * constructs a DeLPResponse object with default values, prepares the DelpReasoner, and executes it
- * asynchronously using a separate thread. The result includes information about the execution time,
- * answer, and status, encapsulated in a DelpResponse object.
- *
- * If the execution times out, the method sets the response status to "TIMEOUT" and includes the
- * specified timeout duration. If a parsing exception occurs during knowledge base or query parsing,
- * the method throws a JSONException with an appropriate error message. If any other unexpected exception
- * occurs, the method prints the stack trace and throws a JSONException with a generic error message.
- *
- * @param delpPost The DelpPost object representing the request payload.
- * @return A Response object representing the response payload.
- * @throws JSONException If there is a parsing error or an unexpected error occurs during processing.
- */
@PostMapping(value = "/delp", produces = "application/json", consumes = "application/json")
@ResponseBody
- public Response handleRequest(
- @RequestBody DeLPPost delpPost) {
-
- System.out.println(delpPost.toString());
-
- DeLPResponse delpResponse = new DeLPResponse("query", delpPost.getEmail(), delpPost.getCompcriterion(),
- delpPost.getKb(), delpPost.getQuery(), delpPost.getTimeout(), null, 0.0, delpPost.getUnit_timeout(),
- null);
- TimeUnit unit = Utils.getTimeoutUnit(delpPost.getUnit_timeout());
- int user_timeout = Utils.checkUserTimeout(delpPost.getTimeout(), SERVICES_TIMEOUT_DELP, unit);
+ public Response handleRequest(@RequestBody DeLPPost post) {
+ DeLPResponse response = new DeLPResponse("query", post.getEmail(), post.getCompcriterion(),
+ post.getKb(), post.getQuery(), post.getTimeout(), null, 0.0, post.getUnit_timeout(), null);
+ TimeUnit unit = Utils.getTimeoutUnit(post.getUnit_timeout());
+ int userTimeout = Utils.checkUserTimeout(post.getTimeout(), SERVICES_TIMEOUT_DELP, unit);
ExecutorService executor = Executors.newSingleThreadExecutor();
try {
-
DelpParser parser = new DelpParser();
- DefeasibleLogicProgram delp = parser.parseBeliefBase(delpPost.getKb());
+ DefeasibleLogicProgram delp = parser.parseBeliefBase(post.getKb());
ComparisonCriterion comp = null;
- if (delpPost.getCompcriterion().equals("compcriterion"))
+ if (post.getCompcriterion().equals("compcriterion"))
comp = new EmptyCriterion();
- if (delpPost.getCompcriterion().equals("genspec"))
+ if (post.getCompcriterion().equals("genspec"))
comp = new GeneralizedSpecificity();
if (comp == null)
throw new JSONException("Malformed JSON: unknown value for attribute \"compcriterion\"");
DelpReasoner reasoner = new DelpReasoner(comp);
FolParser folParser = new FolParser();
folParser.setSignature(parser.getSignature());
- String qString = delpPost.getQuery().trim();
- Formula f = null;
- if (qString.startsWith("~"))
- f = new Negation((FolFormula) folParser.parseFormula(qString.substring(1)));
- else
- f = folParser.parseFormula(qString);
- Callee delpCallee = new DeLPCallee(delp, reasoner, f);
- Future future = executor.submit(delpCallee);
- Pair result = Utils.runServicesWithTimeout(future, user_timeout, unit);
-
- System.out.println(result.toString());
-
- delpResponse.setAnswer(result.getKey().toString());
- delpResponse.setTime(result.getValue());
- delpResponse.setStatus("SUCCESS");
- System.out.println(delpResponse.toString());
-
+ String qString = post.getQuery().trim();
+ Formula f = qString.startsWith("~")
+ ? new Negation((FolFormula) folParser.parseFormula(qString.substring(1)))
+ : folParser.parseFormula(qString);
+ Future future = executor.submit(new DeLPCallee(delp, reasoner, f));
+ Pair result = Utils.runServicesWithTimeout(future, userTimeout, unit);
+ response.setAnswer(result.getKey().toString());
+ response.setTime(result.getValue());
+ response.setStatus("SUCCESS");
} catch (TimeoutException e) {
- delpResponse.setTime(delpPost.getTimeout());
- delpResponse.setAnswer(null);
- delpResponse.setStatus("TIMEOUT");
- executor.shutdownNow();
- } catch (ParserException e) {
- executor.shutdownNow();
- throw new JSONException(
- "Malformed JSON: syntax of knowledge base and/or query does not conform to the given format.");
- } catch (IOException e) {
- executor.shutdownNow();
- throw new JSONException(
- "Malformed JSON: syntax of knowledge base and/or query does not conform to the given format.");
+ response.setTime(post.getTimeout());
+ response.setAnswer(null);
+ response.setStatus("TIMEOUT");
+ } catch (ParserException | IOException e) {
+ throw new JSONException("Malformed JSON: syntax of knowledge base and/or query does not conform to the given format.");
} catch (Exception e) {
- executor.shutdownNow();
- e.printStackTrace();
throw new JSONException("An unexpected error occured. Please contact an administrator.");
+ } finally {
+ executor.shutdownNow();
}
- return delpResponse;
+ return response;
}
- /**
- * Handles HTTP POST requests for Inconsistency Measures operations.
- *
- * This method processes requests with the endpoint "/incmes" that have the specified content type
- * for the request and response. It takes an InconsistencyPost object as the request body and returns a
- * Response object as the response body.
- *
- * The method initializes an InconsistencyValueResponse object for the response. It then checks the
- * command (cmd) from the InconsistencyPost object and delegates the request to specific methods based on
- * the command. If the command is "value," it calls the handleGetICMESValue method. If the command is
- * "measures," it calls the handleGetMeasures method. Any exceptions that occur during the processing are
- * caught, and a generic error message is printed to the console.
- *
- * If the command is not recognized or not applicable, the method returns a default InconsistencyValueResponse.
- *
- * @param incmesPost The InconsistencyPost object representing the request payload.
- * @return A Response object representing the response payload.
- */
+ // ── Inconsistency Measures ────────────────────────────────────────────────
@PostMapping(value = "/incmes", produces = "application/json")
@ResponseBody
- public Response handleRequest(
- @RequestBody InconsistencyPost incmesPost) {
- InconsistencyValueResponse icmesResponse = new InconsistencyValueResponse();
-
+ public Response handleRequest(@RequestBody InconsistencyPost post) {
try {
-
- if (incmesPost.getCmd().equals("value")) {
- return handleGetICMESValue(incmesPost);
- }
-
- if (incmesPost.getCmd().equals("measures")) {
-
- return handleGetMeasures(incmesPost);
- }
+ if (post.getCmd().equals("value"))
+ return handleGetICMESValue(post);
+ if (post.getCmd().equals("measures"))
+ return handleGetMeasures(post);
} catch (Exception e) {
- System.out.println(e.getMessage());
+ LoggerUtil.logger.log(Level.SEVERE, e.getMessage());
}
-
- return icmesResponse;
+ return new InconsistencyValueResponse();
}
- /**
- * Private inner class representing a Callable task for measuring inconsistency of a belief set.
- *
- * The MeasurementCallee class implements the Callable interface with a generic type of Double.
- * Instances of this class are used to perform asynchronous calculations of inconsistency measures
- * for a given BeliefSet using a specific InconsistencyMeasure.
- *
- * The class has two fields: "measure," representing the InconsistencyMeasure to be applied,
- * and "beliefSet," representing the BeliefSet for which the inconsistency measure is calculated.
- *
- * The constructor initializes the MeasurementCallee with a specific InconsistencyMeasure and
- * a BeliefSet.
- *
- * The call method, required by the Callable interface, invokes the inconsistencyMeasure method
- * of the provided InconsistencyMeasure on the given BeliefSet, returning the calculated inconsistency
- * measure value as a Double.
- *
- * @param The type of formulas in the belief set, e.g., PlFormula.
- * @param The type of signature associated with the belief set, e.g., PlSignature.
- */
private class MeasurementCallee implements Callable {
InconsistencyMeasure> measure;
BeliefSet beliefSet;
@@ -991,112 +558,64 @@ public Double call() throws Exception {
}
}
- /**
- *
- * Handles the computation of the inconsistency value for a given belief set and inconsistency measure.
- * This method takes an InconsistencyPost object representing the request payload and calculates
- * the inconsistency value based on the specified belief set, inconsistency measure, and other parameters.
- *
- * The method initializes an InconsistencyValueResponse object for the response and sets up the necessary
- * sub-solvers for the computation. It then retrieves the inconsistency measure and parser based on the request's
- * attributes. The belief set is parsed from the knowledge base using the selected parser, and an asynchronous
- * calculation of the inconsistency measure is performed using a separate thread. The execution time and result
- * are then encapsulated in the InconsistencyValueResponse object.
- *
- * If the calculation times out, the method sets the response status to "TIMEOUT" and includes the specified
- * timeout duration. If a parsing exception occurs during knowledge base parsing, the method throws a JSONException
- * with an appropriate error message. If any other unexpected exception occurs, the method logs the error and
- * throws a JSONException with a generic error message.
- *
- * The inconsistency value is set to specific sentinel values (-1 for timeout, -2 for general error, -3 for infinity),
- * and the response object includes information about the request and the computed inconsistency value.
- *
- * @param query The InconsistencyPost object representing the request payload.
- * @return An InconsistencyValueResponse object representing the response payload.
- * @throws JSONException If there is a parsing error or an unexpected error occurs during processing.
- */
-
private InconsistencyValueResponse handleGetICMESValue(InconsistencyPost query) throws JSONException {
- InconsistencyValueResponse icmesResponse = new InconsistencyValueResponse();
+ InconsistencyValueResponse response = new InconsistencyValueResponse();
TimeUnit unit = Utils.getTimeoutUnit(query.getUnit_timeout());
- int user_timeout = Utils.checkUserTimeout(query.getTimeout(), SERVICES_TIMEOUT_INCMES, unit);
- // set sub-solvers
+ int userTimeout = Utils.checkUserTimeout(query.getTimeout(), SERVICES_TIMEOUT_INCMES, unit);
SatSolver.setDefaultSolver(new Sat4jSolver());
PlMusEnumerator.setDefaultEnumerator(new NaiveMusEnumerator(new Sat4jSolver()));
Solver.setDefaultLinearSolver(new ApacheCommonsSimplex());
Solver.setDefaultIntegerLinearSolver(new GlpkSolver());
- // get measure
InconsistencyMeasure> measure = InconsistencyMeasureFactory.getInconsistencyMeasure(
Measure.getMeasure(query.getMeasure()));
if (measure == null)
throw new JSONException("Malformed JSON: unknown value for attribute \"measure\"");
- Parser parser = PlParserFactory.getParserForFormat(
- Format.getFormat(query.getFormat()));
+ Parser parser = PlParserFactory.getParserForFormat(Format.getFormat(query.getFormat()));
if (parser == null)
throw new JSONException("Malformed JSON: unknown value for attribute \"format\"");
double val = -3;
try {
PlBeliefSet beliefSet = parser.parseBeliefBase(query.getKb());
ExecutorService executor = Executors.newSingleThreadExecutor();
- long millis = System.currentTimeMillis();
try {
- // handle timeout
Future future = executor.submit(new MeasurementCallee(measure, beliefSet));
- Pair result = Utils.runServicesWithTimeout(future, user_timeout, unit);
+ Pair result = Utils.runServicesWithTimeout(future, userTimeout, unit);
val = result.getKey();
- icmesResponse.setTime(result.getValue());
- icmesResponse.setStatus("SUCCESS");
- // val = future.get(InconsistencyMeasurementService.timeout, TimeUnit.SECONDS);
+ response.setTime(result.getValue());
+ response.setStatus("SUCCESS");
executor.shutdownNow();
} catch (TimeoutException e) {
- // inconsistency value of -1 indicates that a timeout has occurred
- icmesResponse.setTime(query.getTimeout());
- icmesResponse.setStatus("TIMEOUT");
+ response.setTime(query.getTimeout());
+ response.setStatus("TIMEOUT");
executor.shutdownNow();
val = -1;
} catch (Exception e) {
- // inconsistency value of -2 indicates some general error
- icmesResponse.setStatus("ERROR");
+ response.setStatus("ERROR");
executor.shutdownNow();
val = -2;
}
- // inconsistency value of -3 indicates infinity
if (val == Double.POSITIVE_INFINITY)
val = -3;
- millis = System.currentTimeMillis() - millis;
-
- icmesResponse.setEmail(query.getEmail());
- icmesResponse.setFormat(query.getFormat());
- icmesResponse.setKb(query.getKb());
- icmesResponse.setMeasure(query.getMeasure());
- icmesResponse.setReply("value");
- icmesResponse.setValue(val);
-
- return icmesResponse;
- } catch (ParserException e) {
- throw new JSONException("Malformed JSON: syntax of knowledge base does not conform to the given format.");
- } catch (IOException e) {
+ response.setEmail(query.getEmail());
+ response.setFormat(query.getFormat());
+ response.setKb(query.getKb());
+ response.setMeasure(query.getMeasure());
+ response.setReply("value");
+ response.setValue(val);
+ return response;
+ } catch (ParserException | IOException e) {
throw new JSONException("Malformed JSON: syntax of knowledge base does not conform to the given format.");
} catch (Exception e) {
throw new JSONException("An unexpected error occured. Please contact an administrator.");
}
}
- /**
- * Handles the "List inconsistency measures" command
- *
- * @param query some query
- * @return the reply
- * @throws JSONException if some JSON issue occurs.
- * @throws org.codehaus.jettison.json.JSONException if some JSON issue occurs.
- */
private InconsistencyGetMeasuresResponse handleGetMeasures(InconsistencyPost query)
throws JSONException, org.codehaus.jettison.json.JSONException {
InconsistencyGetMeasuresResponse response = new InconsistencyGetMeasuresResponse();
- List> value = new LinkedList>();
- HashMap jsonMes;
+ List> value = new LinkedList<>();
for (Measure m : InconsistencyMeasureFactory.Measure.values()) {
- jsonMes = new HashMap();
+ HashMap jsonMes = new HashMap<>();
jsonMes.put("id", m.id);
jsonMes.put("label", m.label);
value.add(jsonMes);
@@ -1107,24 +626,13 @@ private InconsistencyGetMeasuresResponse handleGetMeasures(InconsistencyPost que
return response;
}
-
- /**
- * Handles the "List semanctics" command for aba
- *
- * @param query some query
- * @return the reply
- * @throws JSONException if some JSON issue occurs.
- * @throws org.codehaus.jettison.json.JSONException if some JSON issue occurs.
- */
private AbaGetSemanticsResponse handleGetSemantics(AbaReasonerPost query)
throws JSONException, org.codehaus.jettison.json.JSONException {
-
LoggerUtil.logger.info(String.format("User: %s Command: %s", query.getEmail(), query.getCmd()));
AbaGetSemanticsResponse response = new AbaGetSemanticsResponse();
- List> value = new LinkedList>();
- HashMap jsonMes;
- for (org.tweetyproject.web.services.aba.GeneralAbaReasonerFactory.Semantics m : GeneralAbaReasonerFactory.Semantics.values()) {
- jsonMes = new HashMap();
+ List> value = new LinkedList<>();
+ for (GeneralAbaReasonerFactory.Semantics m : GeneralAbaReasonerFactory.Semantics.values()) {
+ HashMap jsonMes = new HashMap<>();
jsonMes.put("id", m.id);
jsonMes.put("label", m.label);
value.add(jsonMes);
@@ -1135,307 +643,93 @@ private AbaGetSemanticsResponse handleGetSemantics(AbaReasonerPost query)
return response;
}
- /**
- * handler for the /sequence-explanation endpoint
- * @param request the sequence explanation request
- * @return the server response
- */
+ // ── Sequence Explanation ──────────────────────────────────────────────────
+
@PostMapping(value = "/sequence-explanation", produces = "application/json")
@ResponseBody
public SequenceExplanationResponse handleRequest(@Valid @RequestBody SequenceExplanationPost request) {
LoggerUtil.logger.info(String.format("Run sequence explanation command \"%s\" for user \"%s\" with timeout: %s %s",
- request.getCmd().getClass().getSimpleName(),
- request.getEmail(),
- request.getTimeout(),
- request.getUnit_timeout()));
+ request.getCmd().getClass().getSimpleName(), request.getEmail(),
+ request.getTimeout(), request.getUnit_timeout()));
TimeUnit timeoutUnit = Utils.getTimeoutUnit(request.getUnit_timeout());
int timeout = Utils.checkUserTimeout(request.getTimeout(), SERVICES_TIMEOUT_SEQUENCE_EXPLANATION, timeoutUnit);
-
ExecutorService executor = Executors.newSingleThreadExecutor();
- Pair resultAndExecutionTime;
+ Pair resultAndTime;
try {
var future = executor.submit(() -> processCommand(request.getCmd()));
- resultAndExecutionTime = Utils.runServicesWithTimeout(future, timeout, timeoutUnit);
+ resultAndTime = Utils.runServicesWithTimeout(future, timeout, timeoutUnit);
} catch (TimeoutException e) {
LoggerUtil.logger.info("Timeout while running sequence explanation.");
- return new SequenceExplanationResponse(
- null,
- request.getEmail(),
- timeout,
- request.getUnit_timeout(),
- SequenceExplanationResponse.Status.TIMEOUT
- );
+ return new SequenceExplanationResponse(null, request.getEmail(), timeout,
+ request.getUnit_timeout(), SequenceExplanationResponse.Status.TIMEOUT);
} catch (ExecutionException e) {
LoggerUtil.logger.warning(() -> "Error while running sequence explanation reasoner: " + e.getMessage());
e.printStackTrace();
throw new RuntimeException(e);
} catch (InterruptedException e) {
- LoggerUtil.logger.warning(() -> "Interrupt while running sequence explanation: " + e.getMessage());
+ LoggerUtil.logger.warning(() -> "Interrupt while running sequence explanation: " + e.getMessage());
e.printStackTrace();
Thread.currentThread().interrupt();
throw new RuntimeException("Thread was interrupted.");
} finally {
executor.shutdownNow();
}
-
- double executionTime = resultAndExecutionTime.getValue();
- var result = resultAndExecutionTime.getKey();
- return new SequenceExplanationResponse(
- result,
- request.getEmail(),
- executionTime,
- request.getUnit_timeout(),
- SequenceExplanationResponse.Status.SUCCESS
- );
+ return new SequenceExplanationResponse(resultAndTime.getKey(), request.getEmail(),
+ resultAndTime.getValue(), request.getUnit_timeout(), SequenceExplanationResponse.Status.SUCCESS);
}
private SequenceExplanationResult processCommand(SequenceExplanationCmd cmd) {
- if (cmd instanceof GetSequenceExplanationsCmd) {
+ if (cmd instanceof GetSequenceExplanationsCmd)
return processSequenceExplanationCmd((GetSequenceExplanationsCmd) cmd);
- } else {
- throw new IllegalStateException("Encountered invalid command:" + cmd.getClass().getSimpleName());
- }
+ throw new IllegalStateException("Encountered invalid command:" + cmd.getClass().getSimpleName());
}
private GetSequenceExplanationsResult processSequenceExplanationCmd(GetSequenceExplanationsCmd cmd) {
var theory = new DungTheory();
- for (AttackDTO attackDTO: cmd.getAttacks()) {
+ for (AttackDTO attackDTO : cmd.getAttacks()) {
var attacker = new Argument(attackDTO.getAttacker());
var attacked = new Argument(attackDTO.getAttacked());
theory.add(attacker);
theory.add(attacked);
- var attack = new Attack(attacker, attacked);
- theory.add(attack);
+ theory.add(new Attack(attacker, attacked));
}
Set argumentFilter = ArgumentFilterSerialization.deserialize(cmd.getArgumentFilter());
- if (argumentFilter != null) {
+ if (argumentFilter != null)
theory.addAll(argumentFilter);
- }
- var sequenceExplanation = sequenceExplanationService.querySequenceExplanations(theory, argumentFilter);
- return GetSequenceExplanationsResult.from(sequenceExplanation);
- }
-
- /**
- * Executes the causal reasoner as specified by the provided {@link CausalReasonerPost}
- *
- * @param request The request payload containing information for causal reasoning
- * @return A Response object containing the result of the ABA reasoning operation.
- */
- @PostMapping(value = "/causal", produces = "application/json")
- @ResponseBody
- public CausalReasonerResponse handleRequest(@Valid @RequestBody CausalReasonerPost request) {
- LoggerUtil.logger.info(String.format("Run causal reasoner command \"%s\" for user \"%s\" with timeout: %s %s",
- request.getCmd(),
- request.getEmail(),
- request.getTimeout(),
- request.getUnit_timeout()));
-
- TimeUnit timoutUnit = Utils.getTimeoutUnit(request.getUnit_timeout());
- int timout = Utils.checkUserTimeout(request.getTimeout(), SERVICES_TIMEOUT_CAUSAL, timoutUnit);
-
- ExecutorService executor = Executors.newSingleThreadExecutor();
- Pair resultAndExecutionTime;
- try {
- var future = executor.submit(() -> processCommand(request));
- resultAndExecutionTime = Utils.runServicesWithTimeout(future, timout, timoutUnit);
- } catch (TimeoutException e) {
- LoggerUtil.logger.info("Timeout while running causal reasoner.");
- return new CausalReasonerResponse(
- null,
- request.getEmail(),
- timout,
- request.getUnit_timeout(),
- TIMEOUT
- );
- } catch (ExecutionException e) {
- LoggerUtil.logger.warning(() -> "Error while running causal reasoner: " + e.getMessage());
- e.printStackTrace();
- throw new RuntimeException(e);
- } catch (InterruptedException e) {
- LoggerUtil.logger.warning(() -> "Interrupt while running causal reasoner: " + e.getMessage());
- e.printStackTrace();
- Thread.currentThread().interrupt();
- throw new RuntimeException("Thread was interrupted.");
- } finally {
- executor.shutdownNow();
- }
-
- double executionTime = resultAndExecutionTime.getValue();
- String result = resultAndExecutionTime.getKey();
- return new CausalReasonerResponse(
- result,
- request.getEmail(),
- executionTime,
- request.getUnit_timeout(),
- SUCCESS
- );
- }
-
- private String processCommand(CausalReasonerPost causalReasonerPost) {
- return switch (causalReasonerPost.getCmd()) {
- case GET_CONCLUSIONS -> processConclusionsCommand(causalReasonerPost);
- case GET_SIGNIFICANT_ATOMS -> processSignificantAtomsCommand(causalReasonerPost);
- case GET_ARGUMENTATION_FRAMEWORK -> processArgumentationFramework(causalReasonerPost);
- case GET_SEQUENCE_EXPLANATIONS -> processSequenceExplanations(causalReasonerPost);
- };
- }
-
- private String processConclusionsCommand(CausalReasonerPost causalReasonerPost) {
- CausalKnowledgeBase causalKnowledgeBase = parseCausalKnowledgeBase(causalReasonerPost);
- Collection observations = parseObservations(causalReasonerPost);
- var conclusionFilter = parseConclusionFilter(causalReasonerPost);
-
- Collection conclusions = causalReasonerService.queryConclusions(causalKnowledgeBase, observations, conclusionFilter);
- return conclusions.toString();
- }
-
- private String processSignificantAtomsCommand(CausalReasonerPost causalReasonerPost) {
- CausalKnowledgeBase causalKnowledgeBase = parseCausalKnowledgeBase(causalReasonerPost);
- Collection observations = parseObservations(causalReasonerPost);
- var conclusionFilter = parseConclusionFilter(causalReasonerPost);
-
- var perAtomSignificantAtoms = causalReasonerService.queryPerAtomSignificantAtoms(causalKnowledgeBase, observations, conclusionFilter);
-
- Map> jsonData = new HashMap<>();
- for (Map.Entry> entry : perAtomSignificantAtoms.entrySet()) {
- List list = new ArrayList<>();
- for (Proposition proposition : entry.getValue()) {
- String string = proposition.toString();
- list.add(string);
- }
- jsonData.put(entry.getKey().toString(), list);
- }
-
- try {
- return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(jsonData);
- } catch (JsonProcessingException e) {
- throw new RuntimeException(e);
- }
- }
-
- private String processSequenceExplanations(CausalReasonerPost causalReasonerPost) {
- CausalKnowledgeBase causalKnowledgeBase = parseCausalKnowledgeBase(causalReasonerPost);
- Collection observations = parseObservations(causalReasonerPost);
- var conclusionFilter = parseConclusionFilter(causalReasonerPost);
-
- var result = causalReasonerService.querySequenceExplanations(causalKnowledgeBase, observations, conclusionFilter);
- var reply = SequenceExplanationReply.from(result);
- try {
- return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(reply);
- } catch (JsonProcessingException e) {
- throw new RuntimeException(e);
- }
- }
-
- private String processArgumentationFramework(CausalReasonerPost causalReasonerPost) {
- CausalKnowledgeBase causalKnowledgeBase = parseCausalKnowledgeBase(causalReasonerPost);
- Collection observations = parseObservations(causalReasonerPost);
-
- var result = causalReasonerService.queryArgumentationFramework(causalKnowledgeBase, observations);
- var reply = ArgumentationFrameworkReply.from(result);
- try {
- return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(reply);
- } catch (JsonProcessingException e) {
- throw new RuntimeException(e);
- }
- }
-
- private static Collection parseObservations(CausalReasonerPost causalReasonerPost) {
- CausalParser causalParser = new CausalParser();
- Collection observations;
- try {
- observations = causalParser.parseListOfFormulae(causalReasonerPost.getObservations(), ",");
- } catch (ParserException e) {
- throw new ResponseStatusException(HttpStatus.BAD_REQUEST, null, e);
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
- return observations;
+ return GetSequenceExplanationsResult.from(sequenceExplanationService.querySequenceExplanations(theory, argumentFilter));
}
- private static @Nullable Set parseConclusionFilter(CausalReasonerPost causalReasonerPost) {
- return ConclusionsFilterSerialization.parse(causalReasonerPost.getConclusionsFilter());
- }
-
- private static CausalKnowledgeBase parseCausalKnowledgeBase(CausalReasonerPost causalReasonerPost) {
- CausalParser causalParser = new CausalParser();
- CausalKnowledgeBase causalKnowledgeBase;
- try {
- causalKnowledgeBase = causalParser.parseBeliefBase(causalReasonerPost.getKb());
- } catch (ParserException e) {
- throw new ResponseStatusException(HttpStatus.BAD_REQUEST, null, e);
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
- return causalKnowledgeBase;
- }
+ // ── PAF ──────────────────────────────────────────────────────────────────
- /**
- * Handles HTTP POST requests for Probabilistic Argumentation Framework (PAF) operations.
- *
- * Supported commands:
- *
- * - {@code info} – return supported semantics, commands, and solvers
- * - {@code get_credulous} – probability that the queried argument is credulously accepted
- * - {@code get_skeptical} – probability that the queried argument is skeptically accepted
- *
- *
- * Two solvers are available: {@code simple} (exact, enumerates all subgraphs) and
- * {@code montecarlo} (approximate sampling, configurable via {@code nr_of_trials}).
- *
- * @param pafPost the request payload
- * @return a {@link Response} containing the computed probability or service info
- */
@PostMapping(value = "/paf", produces = "application/json", consumes = "application/json")
@ResponseBody
- public Response handleRequest(@RequestBody PafReasonerPost pafPost) {
- if (pafPost.getCmd().equals("info"))
- return getPafInfo(pafPost.getEmail());
+ public Response handleRequest(@RequestBody PafReasonerPost post) {
+ if (post.getCmd().equals("info"))
+ return getPafInfo(post.getEmail());
- PafReasonerCalleeFactory.Command cmd = PafReasonerCalleeFactory.Command.getCommand(pafPost.getCmd());
+ PafReasonerCalleeFactory.Command cmd = PafReasonerCalleeFactory.Command.getCommand(post.getCmd());
if (cmd == null)
return new PafReasonerResponse();
ProbabilisticArgumentationFramework paf = AbstractPafReasonerFactory.getPaf(
- pafPost.getNr_of_arguments(),
- pafPost.getArgument_probabilities(),
- pafPost.getAttacks(),
- pafPost.getAttack_probabilities());
+ post.getNr_of_arguments(), post.getArgument_probabilities(),
+ post.getAttacks(), post.getAttack_probabilities());
AbstractPafReasoner reasoner = AbstractPafReasonerFactory.getReasoner(
- Semantics.getSemantics(pafPost.getSemantics()),
- pafPost.getSolver(),
- pafPost.getNr_of_trials());
+ Semantics.getSemantics(post.getSemantics()), post.getSolver(), post.getNr_of_trials());
Callee callee = PafReasonerCalleeFactory.getCallee(cmd, reasoner, paf);
-
- ExecutorService executor = Executors.newSingleThreadExecutor();
- PafReasonerResponse reasonerResponse = new PafReasonerResponse(
- pafPost.getCmd(), pafPost.getEmail(), pafPost.getNr_of_arguments(),
- pafPost.getArgument_probabilities(), pafPost.getAttacks(),
- pafPost.getAttack_probabilities(), pafPost.getSemantics(),
- pafPost.getSolver(), pafPost.getArgument(), null, 0,
- pafPost.getUnit_timeout(), "ERROR");
- TimeUnit unit = Utils.getTimeoutUnit(pafPost.getUnit_timeout());
- int user_timeout = Utils.checkUserTimeout(pafPost.getTimeout(), SERVICES_TIMEOUT_DUNG, unit);
- try {
- Future> future = executor.submit(callee);
- Pair, Long> result = Utils.runServicesWithTimeout(future, user_timeout, unit);
- executor.shutdownNow();
- reasonerResponse.setAnswer(result.getKey().toString());
- reasonerResponse.setTime(result.getValue());
- reasonerResponse.setStatus("SUCCESS");
- } catch (TimeoutException e) {
- reasonerResponse.setTime(pafPost.getTimeout());
- reasonerResponse.setAnswer(null);
- reasonerResponse.setStatus("TIMEOUT");
- executor.shutdownNow();
- } catch (Exception e) {
- reasonerResponse.setTime(0.0);
- reasonerResponse.setAnswer(null);
- reasonerResponse.setStatus("Error");
- executor.shutdownNow();
- }
- return reasonerResponse;
+ TimeUnit unit = Utils.getTimeoutUnit(post.getUnit_timeout());
+ int userTimeout = Utils.checkUserTimeout(post.getTimeout(), SERVICES_TIMEOUT_DUNG, unit);
+
+ PafReasonerResponse response = new PafReasonerResponse(post.getCmd(), post.getEmail(),
+ post.getNr_of_arguments(), post.getArgument_probabilities(), post.getAttacks(),
+ post.getAttack_probabilities(), post.getSemantics(), post.getSolver(),
+ post.getArgument(), null, 0, post.getUnit_timeout(), "ERROR");
+ ExecutionResult r = runCallee(callee, userTimeout, post.getTimeout(), unit);
+ response.setAnswer(r.answer);
+ response.setTime(r.time);
+ response.setStatus(r.status);
+ return response;
}
private PafServicesInfoResponse getPafInfo(String email) {
@@ -1443,102 +737,47 @@ private PafServicesInfoResponse getPafInfo(String email) {
response.setReply("info");
response.setEmail(email);
response.setBackend_timeout(SERVICES_TIMEOUT_DUNG);
- Semantics[] sem = AbstractPafReasonerFactory.getSemantics();
ArrayList semantics_ids = new ArrayList<>();
- for (Semantics s : sem)
+ for (Semantics s : AbstractPafReasonerFactory.getSemantics())
semantics_ids.add(s.abbreviation());
response.setSemantics(semantics_ids);
- PafReasonerCalleeFactory.Command[] com = PafReasonerCalleeFactory.getCommands();
ArrayList command_ids = new ArrayList<>();
- for (PafReasonerCalleeFactory.Command c : com)
+ for (PafReasonerCalleeFactory.Command c : PafReasonerCalleeFactory.getCommands())
command_ids.add(c.id);
response.setCommands(command_ids);
response.setSolvers(AbstractPafReasonerFactory.getSolvers());
return response;
}
- /**
- * Handles HTTP POST requests for Serialisation operations.
- *
- * Supported commands:
- *
- * - {@code info} – return supported commands and functions
- * - {@code get_reduct} – compute the reduct for the given AF and extension
- * - {@code get_selection} – get the selectable initial sets for the given AF and selection function
- * - {@code is_terminal} – determine whether the given AF and extension are a terminal state according to the termination function
- *
- *
- * @param serPost the request payload
- * @return a {@link Response} containing the computed result or service info
- */
+ // ── Serialisation ─────────────────────────────────────────────────────────
+
@PostMapping(value = "/serialisation", produces = "application/json", consumes = "application/json")
@ResponseBody
- public Response handleRequest(@RequestBody SerialisationPost serPost) {
- if (serPost.getCmd().equals("info"))
- return getSerInfo(serPost.getEmail());
+ public Response handleRequest(@RequestBody SerialisationPost post) {
+ if (post.getCmd().equals("info"))
+ return getSerInfo(post.getEmail());
- SerialisationCalleeFactory.Command cmd = SerialisationCalleeFactory.Command.getCommand(serPost.getCmd());
+ SerialisationCalleeFactory.Command cmd = SerialisationCalleeFactory.Command.getCommand(post.getCmd());
if (cmd == null)
return new SerialisationResponse();
- DungTheory theory = AbstractExtensionReasonerFactory.getDungTheory(
- serPost.getNr_of_arguments(),
- serPost.getAttacks());
- Extension extension = SerialisationFactory.getExtension(serPost.getExtension());
- SelectionFunction alpha = SerialisationFactory.getSelectionFunction(serPost.getSelectionFunction());
- TerminationFunction beta = SerialisationFactory.getTerminationFunction(serPost.getTerminationFunction());
+ DungTheory theory = AbstractExtensionReasonerFactory.getDungTheory(post.getNr_of_arguments(), post.getAttacks());
+ Extension extension = SerialisationFactory.getExtension(post.getExtension());
+ SelectionFunction alpha = SerialisationFactory.getSelectionFunction(post.getSelectionFunction());
+ TerminationFunction beta = SerialisationFactory.getTerminationFunction(post.getTerminationFunction());
Callee callee = SerialisationCalleeFactory.getCallee(cmd, alpha, beta, theory, extension);
-
- ExecutorService executor = Executors.newSingleThreadExecutor();
- SerialisationResponse reasonerResponse = new SerialisationResponse(
- serPost.getCmd(), serPost.getEmail(), serPost.getNr_of_arguments(), serPost.getAttacks(),
- serPost.getExtension(), serPost.getSelectionFunction(),
- serPost.getTerminationFunction(), null, 0,
- serPost.getUnit_timeout(), "ERROR");
- TimeUnit unit = Utils.getTimeoutUnit(serPost.getUnit_timeout());
- int user_timeout = Utils.checkUserTimeout(serPost.getTimeout(), SERVICES_TIMEOUT_DUNG, unit);
- try {
- String result_str;
- Long result_time;
- switch (cmd) {
- case GET_SEQUENCES -> {
- Future> future = executor.submit(callee);
- Pair, Long> result = Utils.runServicesWithTimeout(future, user_timeout, unit);
- result_str = result.getKey().toString();
- result_time = result.getValue();
- } case GET_REDUCT -> {
- Future future = executor.submit(callee);
- Pair result = Utils.runServicesWithTimeout(future, user_timeout, unit);
- result_str = result.getKey().toString();
- result_time = result.getValue();
- } case IS_TERMINAL -> {
- Future future = executor.submit(callee);
- Pair result = Utils.runServicesWithTimeout(future, user_timeout, unit);
- result_str = result.getKey().toString();
- result_time = result.getValue();
- } case GET_SELECTION,GET_MODELS -> {
- Future>> future = executor.submit(callee);
- Pair>, Long> result = Utils.runServicesWithTimeout(future, user_timeout, unit);
- result_str = result.getKey().toString();
- result_time = result.getValue();
- } default -> throw new IllegalArgumentException("unknown command " + cmd);
- }
- executor.shutdownNow();
- reasonerResponse.setAnswer(result_str);
- reasonerResponse.setTime(result_time);
- reasonerResponse.setStatus("SUCCESS");
- } catch (TimeoutException e) {
- reasonerResponse.setTime(serPost.getTimeout());
- reasonerResponse.setAnswer(null);
- reasonerResponse.setStatus("TIMEOUT");
- executor.shutdownNow();
- } catch (Exception e) {
- reasonerResponse.setTime(0.0);
- reasonerResponse.setAnswer(null);
- reasonerResponse.setStatus("Error");
- executor.shutdownNow();
- }
- return reasonerResponse;
+ TimeUnit unit = Utils.getTimeoutUnit(post.getUnit_timeout());
+ int userTimeout = Utils.checkUserTimeout(post.getTimeout(), SERVICES_TIMEOUT_DUNG, unit);
+
+ SerialisationResponse response = new SerialisationResponse(post.getCmd(), post.getEmail(),
+ post.getNr_of_arguments(), post.getAttacks(), post.getExtension(),
+ post.getSelectionFunction(), post.getTerminationFunction(), null, 0,
+ post.getUnit_timeout(), "ERROR");
+ ExecutionResult r = runCallee(callee, userTimeout, post.getTimeout(), unit);
+ response.setAnswer(r.answer);
+ response.setTime(r.time);
+ response.setStatus(r.status);
+ return response;
}
private SerialisationInfoResponse getSerInfo(String email) {
@@ -1548,11 +787,18 @@ private SerialisationInfoResponse getSerInfo(String email) {
response.setBackend_timeout(SERVICES_TIMEOUT_DUNG);
response.setSelectionFunctions(SerialisationFactory.getSelectionFunctions());
response.setTerminationFunctions(SerialisationFactory.getTerminationFunction());
- SerialisationCalleeFactory.Command[] com = SerialisationCalleeFactory.getCommands();
ArrayList command_ids = new ArrayList<>();
- for (SerialisationCalleeFactory.Command c : com)
+ for (SerialisationCalleeFactory.Command c : SerialisationCalleeFactory.getCommands())
command_ids.add(c.id);
response.setCommands(command_ids);
return response;
}
+
+ // ── Ping ─────────────────────────────────────────────────────────────────
+
+ @PostMapping(value = "/ping", produces = "application/json")
+ @ResponseBody
+ public Ping ping(@RequestBody Ping ping_Greeting) {
+ return ping_Greeting;
+ }
}
diff --git a/org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/causal/CausalController.java b/org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/causal/CausalController.java
new file mode 100644
index 000000000..cf7241599
--- /dev/null
+++ b/org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/causal/CausalController.java
@@ -0,0 +1,186 @@
+/*
+ * This file is part of "TweetyProject", a collection of Java libraries for
+ * logical aspects of artificial intelligence and knowledge representation.
+ *
+ * TweetyProject is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License version 3 as
+ * published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program. If not, see .
+ *
+ * Copyright 2016 The TweetyProject Team
+ */
+package org.tweetyproject.web.services.causal;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.lang.Nullable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.server.ResponseStatusException;
+import org.tweetyproject.causal.parser.CausalParser;
+import org.tweetyproject.causal.syntax.CausalKnowledgeBase;
+import org.tweetyproject.commons.ParserException;
+import org.tweetyproject.logics.pl.syntax.PlFormula;
+import org.tweetyproject.logics.pl.syntax.Proposition;
+import org.tweetyproject.web.services.LoggerUtil;
+import org.tweetyproject.web.services.Utils;
+
+import javafx.util.Pair;
+
+import javax.validation.Valid;
+
+import static org.tweetyproject.web.services.causal.CausalReasonerResponse.Status.SUCCESS;
+import static org.tweetyproject.web.services.causal.CausalReasonerResponse.Status.TIMEOUT;
+
+/**
+ * Handles HTTP POST requests for the {@code /causal} endpoint.
+ */
+@RestController
+public class CausalController {
+
+ private static final int TIMEOUT_SECONDS = 300;
+
+ private final ObjectMapper objectMapper;
+ private final CausalReasonerService causalReasonerService;
+
+ @Autowired
+ public CausalController(ObjectMapper objectMapper, CausalReasonerService causalReasonerService) {
+ this.objectMapper = objectMapper;
+ this.causalReasonerService = causalReasonerService;
+ }
+
+ @PostMapping(value = "/causal", produces = "application/json")
+ @ResponseBody
+ public CausalReasonerResponse handleRequest(@Valid @RequestBody CausalReasonerPost request) {
+ LoggerUtil.logger.info(String.format("Run causal reasoner command \"%s\" for user \"%s\" with timeout: %s %s",
+ request.getCmd(), request.getEmail(), request.getTimeout(), request.getUnit_timeout()));
+
+ TimeUnit timeoutUnit = Utils.getTimeoutUnit(request.getUnit_timeout());
+ int timeout = Utils.checkUserTimeout(request.getTimeout(), TIMEOUT_SECONDS, timeoutUnit);
+ ExecutorService executor = Executors.newSingleThreadExecutor();
+ Pair resultAndTime;
+ try {
+ var future = executor.submit(() -> processCommand(request));
+ resultAndTime = Utils.runServicesWithTimeout(future, timeout, timeoutUnit);
+ } catch (TimeoutException e) {
+ LoggerUtil.logger.info("Timeout while running causal reasoner.");
+ return new CausalReasonerResponse(null, request.getEmail(), timeout, request.getUnit_timeout(), TIMEOUT);
+ } catch (ExecutionException e) {
+ LoggerUtil.logger.warning(() -> "Error while running causal reasoner: " + e.getMessage());
+ e.printStackTrace();
+ throw new RuntimeException(e);
+ } catch (InterruptedException e) {
+ LoggerUtil.logger.warning(() -> "Interrupt while running causal reasoner: " + e.getMessage());
+ e.printStackTrace();
+ Thread.currentThread().interrupt();
+ throw new RuntimeException("Thread was interrupted.");
+ } finally {
+ executor.shutdownNow();
+ }
+ return new CausalReasonerResponse(resultAndTime.getKey(), request.getEmail(),
+ resultAndTime.getValue(), request.getUnit_timeout(), SUCCESS);
+ }
+
+ private String processCommand(CausalReasonerPost post) {
+ return switch (post.getCmd()) {
+ case GET_CONCLUSIONS -> processConclusionsCommand(post);
+ case GET_SIGNIFICANT_ATOMS -> processSignificantAtomsCommand(post);
+ case GET_ARGUMENTATION_FRAMEWORK -> processArgumentationFramework(post);
+ case GET_SEQUENCE_EXPLANATIONS -> processSequenceExplanations(post);
+ };
+ }
+
+ private String processConclusionsCommand(CausalReasonerPost post) {
+ CausalKnowledgeBase kb = parseKnowledgeBase(post);
+ Collection observations = parseObservations(post);
+ return causalReasonerService.queryConclusions(kb, observations, parseConclusionFilter(post)).toString();
+ }
+
+ private String processSignificantAtomsCommand(CausalReasonerPost post) {
+ CausalKnowledgeBase kb = parseKnowledgeBase(post);
+ Collection observations = parseObservations(post);
+ var perAtomSignificantAtoms = causalReasonerService.queryPerAtomSignificantAtoms(kb, observations, parseConclusionFilter(post));
+ Map> jsonData = new HashMap<>();
+ for (Map.Entry> entry : perAtomSignificantAtoms.entrySet()) {
+ List list = new ArrayList<>();
+ for (Proposition p : entry.getValue())
+ list.add(p.toString());
+ jsonData.put(entry.getKey().toString(), list);
+ }
+ try {
+ return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(jsonData);
+ } catch (JsonProcessingException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ private String processSequenceExplanations(CausalReasonerPost post) {
+ CausalKnowledgeBase kb = parseKnowledgeBase(post);
+ Collection observations = parseObservations(post);
+ var reply = SequenceExplanationReply.from(causalReasonerService.querySequenceExplanations(kb, observations, parseConclusionFilter(post)));
+ try {
+ return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(reply);
+ } catch (JsonProcessingException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ private String processArgumentationFramework(CausalReasonerPost post) {
+ CausalKnowledgeBase kb = parseKnowledgeBase(post);
+ Collection observations = parseObservations(post);
+ var reply = ArgumentationFrameworkReply.from(causalReasonerService.queryArgumentationFramework(kb, observations));
+ try {
+ return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(reply);
+ } catch (JsonProcessingException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ private static Collection parseObservations(CausalReasonerPost post) {
+ try {
+ return new CausalParser().parseListOfFormulae(post.getObservations(), ",");
+ } catch (ParserException e) {
+ throw new ResponseStatusException(HttpStatus.BAD_REQUEST, null, e);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ private static @Nullable Set parseConclusionFilter(CausalReasonerPost post) {
+ return ConclusionsFilterSerialization.parse(post.getConclusionsFilter());
+ }
+
+ private static CausalKnowledgeBase parseKnowledgeBase(CausalReasonerPost post) {
+ try {
+ return new CausalParser().parseBeliefBase(post.getKb());
+ } catch (ParserException e) {
+ throw new ResponseStatusException(HttpStatus.BAD_REQUEST, null, e);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+}
From 0feb55959ca3218181f566b915c766bed6c2dff5 Mon Sep 17 00:00:00 2001
From: Lars Bengel
Date: Thu, 18 Jun 2026 16:19:55 +0200
Subject: [PATCH 05/14] added webservice for setAFs
---
...va => AbstractSetAfExtensionReasoner.java} | 34 +-
.../SimpleAdmissibleSetAfReasoner.java | 2 +-
.../SimpleCompleteSetAfReasoner.java | 2 +-
.../SimpleConflictFreeSetAfReasoner.java | 2 +-
.../reasoners/SimpleEagerSetAfReasoner.java | 2 +-
.../SimpleGroundedSetAfReasoner.java | 2 +-
.../reasoners/SimpleIdealSetAfReasoner.java | 2 +-
.../SimplePreferredSetAfReasoner.java | 2 +-
.../SimpleSemiStableSetAfReasoner.java | 2 +-
.../reasoners/SimpleStableSetAfReasoner.java | 2 +-
.../reasoners/SimpleStageSetAfReasoner.java | 2 +-
.../tweetyproject/arg/setaf/syntax/SetAf.java | 10 +
org-tweetyproject-web/pom.xml | 7 +-
.../web/services/RequestController.java | 47 ++
.../services/setaf/AbstractSetAfFactory.java | 83 ++++
.../setaf/SetAfReasonerCalleeFactory.java | 106 +++++
.../setaf/SetAfReasonerGetModelsCallee.java | 65 +++
.../web/services/setaf/SetAfReasonerPost.java | 196 +++++++++
.../setaf/SetAfReasonerQueryAllCallee.java | 73 ++++
.../services/setaf/SetAfReasonerResponse.java | 411 ++++++++++++++++++
.../setaf/SetAfServicesInfoResponse.java | 244 +++++++++++
.../services/RequestControllerSetAfTest.java | 231 ++++++++++
22 files changed, 1509 insertions(+), 18 deletions(-)
rename org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/{AbstractExtensionSetAfReasoner.java => AbstractSetAfExtensionReasoner.java} (76%)
create mode 100644 org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/setaf/AbstractSetAfFactory.java
create mode 100644 org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/setaf/SetAfReasonerCalleeFactory.java
create mode 100644 org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/setaf/SetAfReasonerGetModelsCallee.java
create mode 100644 org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/setaf/SetAfReasonerPost.java
create mode 100644 org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/setaf/SetAfReasonerQueryAllCallee.java
create mode 100644 org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/setaf/SetAfReasonerResponse.java
create mode 100644 org-tweetyproject-web/src/main/java/org/tweetyproject/web/services/setaf/SetAfServicesInfoResponse.java
create mode 100644 org-tweetyproject-web/src/test/java/org/tweetyproject/web/services/RequestControllerSetAfTest.java
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/AbstractExtensionSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/AbstractSetAfExtensionReasoner.java
similarity index 76%
rename from org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/AbstractExtensionSetAfReasoner.java
rename to org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/AbstractSetAfExtensionReasoner.java
index 4f864de23..99aef0adb 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/AbstractExtensionSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/AbstractSetAfExtensionReasoner.java
@@ -19,6 +19,7 @@
package org.tweetyproject.arg.setaf.reasoners;
import java.util.Collection;
+import java.util.HashSet;
import org.tweetyproject.arg.dung.semantics.Extension;
import org.tweetyproject.arg.dung.semantics.Semantics;
@@ -29,17 +30,17 @@
import org.tweetyproject.commons.postulates.PostulateEvaluatable;
/**
- * Ancestor class for all SetAf-extension-based reasoners.
+ * Ancestor class for all SetAF-extension-based reasoners.
*
* @author Sebastian Franke
*/
-public abstract class AbstractExtensionSetAfReasoner extends AbstractSetAfReasoner
+public abstract class AbstractSetAfExtensionReasoner extends AbstractSetAfReasoner
implements ModelProvider>, PostulateEvaluatable {
/**
* Default constructor for {@code AbstractExtensionSetAfReasoner}.
*/
- public AbstractExtensionSetAfReasoner() {
+ public AbstractSetAfExtensionReasoner() {
// No specific initialization required
}
@@ -56,10 +57,29 @@ public Boolean query(SetAf beliefbase, Argument formula) {
}
/**
- * Queries the given AAF for the given argument using the given
+ * Determine the set of acceptable arguments wrt. the given inference mode
+ * @param bbase some SetAF
+ * @param inferenceMode the inference mode
+ * @return the set of acceptable arguments
+ */
+ public Collection queryAll(SetAf bbase, InferenceMode inferenceMode) {
+ Collection result = new HashSet<>();
+ if(inferenceMode.equals(InferenceMode.CREDULOUS))
+ for(Collection extension: this.getModels(bbase))
+ result.addAll(extension);
+ else {
+ result.addAll(bbase);
+ for(Collection extension: this.getModels(bbase))
+ result.retainAll(extension);
+ }
+ return result;
+ }
+
+ /**
+ * Queries the given SetAf for the given argument using the given
* inference type.
*
- * @param beliefbase an AAF
+ * @param beliefbase an SetAF
* @param formula a single argument
* @param inferenceMode either InferenceMode.SKEPTICAL or
* InferenceMode.CREDULOUS
@@ -85,9 +105,9 @@ public Boolean query(SetAf beliefbase, Argument formula, InferenceMode inference
* Creates a reasoner for the given semantics.
*
* @param semantics a semantics
- * @return a reasoner for the given Dung theory, inference type, and semantics
+ * @return a reasoner for the given SetAF, inference type, and semantics
*/
- public static AbstractExtensionSetAfReasoner getSimpleReasonerForSemantics(Semantics semantics) {
+ public static AbstractSetAfExtensionReasoner getSimpleReasonerForSemantics(Semantics semantics) {
switch (semantics) {
case CO:
return new SimpleCompleteSetAfReasoner();
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleAdmissibleSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleAdmissibleSetAfReasoner.java
index d9c794f71..6da8f33cd 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleAdmissibleSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleAdmissibleSetAfReasoner.java
@@ -33,7 +33,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimpleAdmissibleSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleAdmissibleSetAfReasoner extends AbstractSetAfExtensionReasoner {
/** Default */
public SimpleAdmissibleSetAfReasoner(){
// Default
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleCompleteSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleCompleteSetAfReasoner.java
index 7641197df..39e07532c 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleCompleteSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleCompleteSetAfReasoner.java
@@ -31,7 +31,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimpleCompleteSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleCompleteSetAfReasoner extends AbstractSetAfExtensionReasoner {
/** Default */
public SimpleCompleteSetAfReasoner(){
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleConflictFreeSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleConflictFreeSetAfReasoner.java
index b208f9ef8..a1e23ace8 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleConflictFreeSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleConflictFreeSetAfReasoner.java
@@ -32,7 +32,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimpleConflictFreeSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleConflictFreeSetAfReasoner extends AbstractSetAfExtensionReasoner {
/** Default */
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleEagerSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleEagerSetAfReasoner.java
index 5abd94b36..8b8d43e3e 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleEagerSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleEagerSetAfReasoner.java
@@ -33,7 +33,7 @@
*
* @author Lars Bengel, Sebastian Franke
*/
-public class SimpleEagerSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleEagerSetAfReasoner extends AbstractSetAfExtensionReasoner {
/** Default */
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleGroundedSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleGroundedSetAfReasoner.java
index ab6f4a5ff..b5b1b59fb 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleGroundedSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleGroundedSetAfReasoner.java
@@ -32,7 +32,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimpleGroundedSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleGroundedSetAfReasoner extends AbstractSetAfExtensionReasoner {
/** Default */
public SimpleGroundedSetAfReasoner(){
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleIdealSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleIdealSetAfReasoner.java
index bd5c08dd4..f0ac32508 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleIdealSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleIdealSetAfReasoner.java
@@ -32,7 +32,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimpleIdealSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleIdealSetAfReasoner extends AbstractSetAfExtensionReasoner {
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimplePreferredSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimplePreferredSetAfReasoner.java
index 0eb12b846..359d98175 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimplePreferredSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimplePreferredSetAfReasoner.java
@@ -33,7 +33,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimplePreferredSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimplePreferredSetAfReasoner extends AbstractSetAfExtensionReasoner {
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleSemiStableSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleSemiStableSetAfReasoner.java
index f0b475c08..c4a695134 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleSemiStableSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleSemiStableSetAfReasoner.java
@@ -33,7 +33,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimpleSemiStableSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleSemiStableSetAfReasoner extends AbstractSetAfExtensionReasoner {
/** Default */
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleStableSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleStableSetAfReasoner.java
index 8e8cb9cd9..2d7abee48 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleStableSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleStableSetAfReasoner.java
@@ -31,7 +31,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimpleStableSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleStableSetAfReasoner extends AbstractSetAfExtensionReasoner {
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleStageSetAfReasoner.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleStageSetAfReasoner.java
index d82b1a6cf..584accedc 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleStageSetAfReasoner.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/reasoners/SimpleStageSetAfReasoner.java
@@ -32,7 +32,7 @@
* @author Matthias Thimm, Sebastian Franke
*
*/
-public class SimpleStageSetAfReasoner extends AbstractExtensionSetAfReasoner {
+public class SimpleStageSetAfReasoner extends AbstractSetAfExtensionReasoner {
diff --git a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/syntax/SetAf.java b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/syntax/SetAf.java
index f90509927..965f3b76a 100644
--- a/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/syntax/SetAf.java
+++ b/org-tweetyproject-arg-setaf/src/main/java/org/tweetyproject/arg/setaf/syntax/SetAf.java
@@ -432,6 +432,16 @@ public boolean add(SetAttack edge) {
return true;
}
+ /**
+ * Add a new set-attack so the theory
+ * @param attackers the set of attacking arguments
+ * @param attacked the attacked argument
+ * @return "true" if the set-attack has been added
+ */
+ public boolean addSetAttack(Set attackers, Argument attacked) {
+ return this.add(new SetAttack(attackers, attacked));
+ }
+
@Override
public Collection getNodes() {
return this.nodes;
diff --git a/org-tweetyproject-web/pom.xml b/org-tweetyproject-web/pom.xml
index 342822e12..7964bea55 100644
--- a/org-tweetyproject-web/pom.xml
+++ b/org-tweetyproject-web/pom.xml
@@ -159,8 +159,13 @@
prob
1.30-SNAPSHOT
+
+ org.tweetyproject.arg
+ setaf
+ 1.30-SNAPSHOT
+
-