public class org.apache.batchee.servlet.SimpleRestController extends java.lang.Object { public static final java.lang.String REST_CONTENT_TYPE; public static final java.lang.String NOT_FOUND_STRING; public static final char CSV_DELIMITER; public static final java.lang.String OP_START; public static final java.lang.String OP_STATUS; public static final java.lang.String OP_METRICS; public static final java.lang.String OP_STOP; public static final java.lang.String OP_RESTART; public static final long NO_JOB_ID; private final jakarta.batch.operations.JobOperator jobOperator; public void (jakarta.batch.operations.JobOperator) { jakarta.batch.operations.JobOperator v; org.apache.batchee.servlet.SimpleRestController v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: jakarta.batch.operations.JobOperator; specialinvoke v.()>(); v. = v; return; } public void dispatch(jakarta.servlet.http.HttpServletRequest, jakarta.servlet.http.HttpServletResponse, java.lang.String) { jakarta.servlet.http.HttpServletRequest v; int v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v; org.apache.batchee.servlet.SimpleRestController v; jakarta.servlet.http.HttpServletResponse v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: jakarta.servlet.http.HttpServletRequest; v := @parameter: jakarta.servlet.http.HttpServletResponse; v := @parameter: java.lang.String; interfaceinvoke v.("text/plain"); if v == null goto label; v = virtualinvoke v.("start/"); if v == 0 goto label; v = "start/"; v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(v, v, v); goto label; label: if v == null goto label; v = virtualinvoke v.("status/"); if v == 0 goto label; v = "status/"; v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(v, v, v); goto label; label: if v == null goto label; v = virtualinvoke v.("metrics/"); if v == 0 goto label; v = "metrics/"; v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(v, v, v); goto label; label: if v == null goto label; v = virtualinvoke v.("stop/"); if v == 0 goto label; v = "stop/"; v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(v, v, v); goto label; label: if v == null goto label; v = virtualinvoke v.("restart/"); if v == 0 goto label; v = "restart/"; v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(v, v, v); goto label; label: specialinvoke v.(v, v); label: return; } private void startBatch(java.lang.String, jakarta.servlet.http.HttpServletRequest, jakarta.servlet.http.HttpServletResponse) { java.lang.Throwable v; java.util.Properties v; jakarta.servlet.http.HttpServletRequest v; long v; org.apache.batchee.servlet.SimpleRestController v; jakarta.batch.operations.JobOperator v; java.lang.StringBuilder v, v; jakarta.servlet.http.HttpServletResponse v; java.lang.String v, v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.String; v := @parameter: jakarta.servlet.http.HttpServletRequest; v := @parameter: jakarta.servlet.http.HttpServletResponse; v = specialinvoke v.(v, v); if v != null goto label; return; label: v = v.; v = interfaceinvoke v.(v, v); specialinvoke v.(v, v, null); label: goto label; label: v := @caughtexception; v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("Error while starting job "); v = virtualinvoke v.(v); virtualinvoke v.(10); specialinvoke v.(v, v); v = virtualinvoke v.(); specialinvoke v.(-1L, v, v); label: return; catch jakarta.batch.operations.JobStartException from label to label with label; } private void batchStatus(java.lang.String, jakarta.servlet.http.HttpServletRequest, jakarta.servlet.http.HttpServletResponse) { java.lang.Throwable v; jakarta.batch.runtime.JobExecution v; jakarta.servlet.http.HttpServletRequest v; long v, v, v, v; jakarta.batch.runtime.BatchStatus v; java.lang.Long v; jakarta.batch.operations.JobOperator v; java.lang.String v, v, v; java.lang.Exception v; org.apache.batchee.servlet.SimpleRestController v; java.lang.StringBuilder v; jakarta.servlet.http.HttpServletResponse v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.String; v := @parameter: jakarta.servlet.http.HttpServletRequest; v := @parameter: jakarta.servlet.http.HttpServletResponse; v = specialinvoke v.(v, v); if v != null goto label; return; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); specialinvoke v.(v, v, "NoSuchJob"); goto label; label: v := @caughtexception; v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("Failure in BatchExecution"); specialinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v); label: return; catch jakarta.batch.operations.NoSuchJobExecutionException from label to label with label; catch java.lang.Exception from label to label with label; } private void batchMetrics(java.lang.String, jakarta.servlet.http.HttpServletRequest, jakarta.servlet.http.HttpServletResponse) { java.lang.Throwable v; jakarta.batch.runtime.JobExecution v; jakarta.servlet.http.HttpServletRequest v; long v, v, v, v, v; jakarta.batch.runtime.BatchStatus v; java.lang.Long v; jakarta.batch.operations.JobOperator v, v; java.lang.String v, v, v; java.lang.Exception v; java.util.List v; org.apache.batchee.servlet.SimpleRestController v; java.lang.StringBuilder v; jakarta.servlet.http.HttpServletResponse v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.String; v := @parameter: jakarta.servlet.http.HttpServletRequest; v := @parameter: jakarta.servlet.http.HttpServletResponse; v = specialinvoke v.(v, v); if v != null goto label; return; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v); specialinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); specialinvoke v.(v, v, "NoSuchJob"); goto label; label: v := @caughtexception; v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("Failure in BatchExecution"); specialinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v); label: return; catch jakarta.batch.operations.NoSuchJobExecutionException from label to label with label; catch java.lang.Exception from label to label with label; } private void batchStop(java.lang.String, jakarta.servlet.http.HttpServletRequest, jakarta.servlet.http.HttpServletResponse) { java.lang.Throwable v, v; jakarta.servlet.http.HttpServletRequest v; long v, v, v, v, v; jakarta.batch.runtime.BatchStatus v; java.lang.Long v; jakarta.batch.operations.JobOperator v; java.lang.String v, v, v; java.lang.Exception v; org.apache.batchee.servlet.SimpleRestController v; java.lang.StringBuilder v; jakarta.servlet.http.HttpServletResponse v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.String; v := @parameter: jakarta.servlet.http.HttpServletRequest; v := @parameter: jakarta.servlet.http.HttpServletResponse; v = specialinvoke v.(v, v); if v != null goto label; return; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); specialinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); specialinvoke v.(v, v, "NoSuchJob"); goto label; label: v := @caughtexception; v = virtualinvoke v.(); specialinvoke v.(v, v, "JobExecutionNotRunning"); goto label; label: v := @caughtexception; v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("Failure in BatchExecution"); specialinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v); label: return; catch jakarta.batch.operations.NoSuchJobExecutionException from label to label with label; catch jakarta.batch.operations.JobExecutionNotRunningException from label to label with label; catch java.lang.Exception from label to label with label; } private void batchRestart(java.lang.String, jakarta.servlet.http.HttpServletRequest, jakarta.servlet.http.HttpServletResponse) { java.lang.Throwable v, v; jakarta.servlet.http.HttpServletRequest v; long v, v, v, v; java.lang.Long v; jakarta.batch.operations.JobOperator v; java.lang.String v, v; java.util.Properties v; java.lang.Exception v; org.apache.batchee.servlet.SimpleRestController v; java.lang.StringBuilder v; jakarta.servlet.http.HttpServletResponse v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.String; v := @parameter: jakarta.servlet.http.HttpServletRequest; v := @parameter: jakarta.servlet.http.HttpServletResponse; v = specialinvoke v.(v, v); if v != null goto label; return; label: v = specialinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); specialinvoke v.(v, v, "NoSuchJob"); goto label; label: v := @caughtexception; v = virtualinvoke v.(); specialinvoke v.(v, v, "NoSuchJob"); goto label; label: v := @caughtexception; v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("Failure in BatchExecution"); specialinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v); label: return; catch jakarta.batch.operations.NoSuchJobExecutionException from label to label with label; catch jakarta.batch.operations.JobExecutionAlreadyCompleteException from label to label with label; catch java.lang.Exception from label to label with label; } private void unknownCommand(java.lang.String, jakarta.servlet.http.HttpServletResponse) { java.lang.String v, v; org.apache.batchee.servlet.SimpleRestController v; java.lang.StringBuilder v, v, v, v, v, v, v, v, v, v, v, v; jakarta.servlet.http.HttpServletResponse v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.String; v := @parameter: jakarta.servlet.http.HttpServletResponse; v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>("Unknown command:"); v = virtualinvoke v.(v); virtualinvoke v.(10); virtualinvoke v.("The returned response if of MIME type text/plain and contains the following information\n"); virtualinvoke v.(" {jobExecutionId} (or -1 if no executionId was detected)\\n\n"); virtualinvoke v.(" OK (or FAILURE)\\n\n"); virtualinvoke v.(" followed by command specific information\n"); virtualinvoke v.("\nKnown commands are:\n\n"); v = virtualinvoke v.("* "); v = virtualinvoke v.("start/"); virtualinvoke v.(" - start a new batch job\n"); virtualinvoke v.(" Sample: http://localhost:8080/myapp/jbatch/rest/start/myjobname?param1=x¶m2=y\n"); virtualinvoke v.(" BatchEE will start the job and immediately return\n\n"); v = virtualinvoke v.("* "); v = virtualinvoke v.("status/"); virtualinvoke v.(" - query the current status \n"); virtualinvoke v.(" Sample: http://localhost:8080/myapp/jbatch/rest/status/23\n"); virtualinvoke v.(" will return the state of executionId 23\n\n"); v = virtualinvoke v.("* "); v = virtualinvoke v.("metrics/"); virtualinvoke v.(" - query the current metrics \n"); virtualinvoke v.(" Sample: http://localhost:8080/myapp/jbatch/rest/metrics/23\n"); virtualinvoke v.(" will return the metrics of executionId 23\n\n"); v = virtualinvoke v.("* "); v = virtualinvoke v.("stop/"); virtualinvoke v.(" - stop the job with the given executionId \n"); virtualinvoke v.(" Sample: http://localhost:8080/myapp/jbatch/rest/stop/23\n"); virtualinvoke v.(" will stop the job with executionId 23\n\n"); v = virtualinvoke v.("* "); v = virtualinvoke v.("restart/"); virtualinvoke v.(" - restart the job with the given executionId \n"); virtualinvoke v.(" Sample: http://localhost:8080/myapp/jbatch/rest/restart/23\n"); virtualinvoke v.(" will restart the job with executionId 23\n\n"); v = virtualinvoke v.(); specialinvoke v.(-1L, v, v); return; } private java.util.Properties extractJobProperties(jakarta.servlet.http.HttpServletRequest, jakarta.servlet.http.HttpServletResponse) { java.util.Properties v; jakarta.servlet.http.HttpServletRequest v; java.util.Iterator v; java.util.Set v; org.apache.batchee.servlet.SimpleRestController v; java.util.Map v; int v, v; java.lang.Object v, v, v; jakarta.servlet.http.HttpServletResponse v; java.lang.String v, v; boolean v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: jakarta.servlet.http.HttpServletRequest; v := @parameter: jakarta.servlet.http.HttpServletResponse; v = new java.util.Properties; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; label: specialinvoke v.(-1L, v, "Parameter key must be set"); return null; label: v = interfaceinvoke v.(); if v == null goto label; v = lengthof v; if v == 1 goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("Exactly one value must be set for each parameter (parameter name=\u)"); specialinvoke v.(-1L, v, v); return null; label: v = v[0]; virtualinvoke v.(v, v); goto label; label: return v; } private java.lang.Long extractExecutionId(java.lang.String, jakarta.servlet.http.HttpServletResponse) { java.lang.Long v; org.apache.batchee.servlet.SimpleRestController v; java.lang.NumberFormatException v; jakarta.servlet.http.HttpServletResponse v; java.lang.String v, v; boolean v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.String; v := @parameter: jakarta.servlet.http.HttpServletResponse; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; label: specialinvoke v.(-1L, v, "no executionId given"); return null; label: v = staticinvoke (v); label: return v; label: v := @caughtexception; v = dynamicinvoke "makeConcatWithConstants" (v) ("executionId must be numeric, but is \u0001"); specialinvoke v.(-1L, v, v); return null; catch java.lang.NumberFormatException from label to label with label; } private void reportSuccess(long, jakarta.servlet.http.HttpServletResponse, java.lang.String) { org.apache.batchee.servlet.SimpleRestController v; long v; jakarta.servlet.http.HttpServletResponse v; java.lang.String v, v, v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: long; v := @parameter: jakarta.servlet.http.HttpServletResponse; v := @parameter: java.lang.String; interfaceinvoke v.(200); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001\n"); specialinvoke v.(v, v); specialinvoke v.(v, "OK\n"); if v == null goto label; specialinvoke v.(v, v); label: return; } private void reportFailure(long, jakarta.servlet.http.HttpServletResponse, java.lang.String) { org.apache.batchee.servlet.SimpleRestController v; long v; jakarta.servlet.http.HttpServletResponse v; java.lang.String v, v, v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: long; v := @parameter: jakarta.servlet.http.HttpServletResponse; v := @parameter: java.lang.String; interfaceinvoke v.(500); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001\n"); specialinvoke v.(v, v); specialinvoke v.(v, "FAILURE\n"); specialinvoke v.(v, v); return; } private void reportMetricsCsv(jakarta.servlet.http.HttpServletResponse, java.util.List) { java.lang.String[] v; java.util.HashMap v; long v, v; java.util.ArrayList v; jakarta.batch.runtime.Metric$MetricType[] v, v; int v, v, v, v; java.lang.String v, v, v; boolean v, v; jakarta.batch.runtime.Metric v; java.util.Iterator v; java.util.List v, v, v; jakarta.batch.runtime.Metric[] v; org.apache.batchee.servlet.SimpleRestController v; org.apache.batchee.servlet.SimpleRestController$1 v; jakarta.batch.runtime.Metric$MetricType v, v; java.lang.Object v, v; java.lang.StringBuilder v; jakarta.servlet.http.HttpServletResponse v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: jakarta.servlet.http.HttpServletResponse; v := @parameter: java.util.List; v = new java.lang.StringBuilder; specialinvoke v.(int)>(200); virtualinvoke v.("\n"); v = newarray (java.lang.String)[2]; v[0] = "STEP_EXECUTION_ID"; v[1] = "STEP_NAME"; v = staticinvoke (v); specialinvoke v.(v, v); virtualinvoke v.(59); v = staticinvoke (); v = staticinvoke (v); specialinvoke v.(v, v); virtualinvoke v.("\n"); v = new org.apache.batchee.servlet.SimpleRestController$1; specialinvoke v.(org.apache.batchee.servlet.SimpleRestController)>(v); staticinvoke (v, v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(59); v = interfaceinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(59); v = interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = v + 1; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = interfaceinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); goto label; label: v = "-"; label: interfaceinvoke v.(v); v = v + 1; goto label; label: specialinvoke v.(v, v); virtualinvoke v.("\n"); goto label; label: v = virtualinvoke v.(); specialinvoke v.(v, v); return; } private void joinCsv(java.lang.StringBuilder, java.util.List) { java.util.List v; java.util.ListIterator v; org.apache.batchee.servlet.SimpleRestController v; java.lang.Object v; java.lang.StringBuilder v; boolean v, v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.StringBuilder; v := @parameter: java.util.List; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(59); goto label; label: return; } private void writeContent(jakarta.servlet.http.HttpServletResponse, java.lang.String) { java.io.PrintWriter v; org.apache.batchee.servlet.SimpleRestController v; java.io.IOException v; jakarta.servlet.http.HttpServletResponse v; java.lang.RuntimeException v; java.lang.String v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: jakarta.servlet.http.HttpServletResponse; v := @parameter: java.lang.String; label: v = interfaceinvoke v.(); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return; catch java.io.IOException from label to label with label; } private void appendExceptionMsg(java.lang.StringBuilder, java.lang.Exception) { java.io.PrintWriter v; java.io.StringWriter v; java.lang.Exception v; org.apache.batchee.servlet.SimpleRestController v; java.lang.StringBuilder v, v; java.lang.String v, v; v := @this: org.apache.batchee.servlet.SimpleRestController; v := @parameter: java.lang.StringBuilder; v := @parameter: java.lang.Exception; v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(10); v = new java.io.StringWriter; specialinvoke v.()>(); v = new java.io.PrintWriter; specialinvoke v.(java.io.Writer)>(v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); return; } }