Adjust code

Signed-off-by: Matheus Cruz <matheuscruz.dev@gmail.com>

Author: mcruzdev

impl/core/src/main/java/io/serverlessworkflow/impl/executors/RunScriptExecutor.java

@@ -67,11 +67,11 @@ public static boolean isSupported(String lang) {
   }
 
   @FunctionalInterface
-  private interface FnExecutor {
+  private interface ScriptExecutor {
     WorkflowModel apply(WorkflowContext workflowContext, TaskContext taskContext);
   }
 
-  private FnExecutor fnExecutor;
+  private ScriptExecutor scriptExecutor;
 
   @Override
   public void init(RunScript taskConfiguration, WorkflowDefinition definition) {
@@ -90,7 +90,9 @@ public void init(RunScript taskConfiguration, WorkflowDefinition definition) {
                   Arrays.stream(ScriptLanguage.values()).map(ScriptLanguage::getLang).toArray()));
     }
 
-    fnExecutor =
+    String lowerLang = language.toLowerCase();
+
+    scriptExecutor =
         (workflowContext, taskContext) -> {
           String source;
           if (scriptUnion.getInlineScript() != null) {
@@ -112,11 +114,6 @@ taskContext, new IllegalStateException("No script source defined."))
                         taskContext.input());
           }
 
-          ByteArrayOutputStream stderr = new ByteArrayOutputStream();
-          ByteArrayOutputStream stdout = new ByteArrayOutputStream();
-
-          String lowerLang = language.toLowerCase();
-
           Map<String, String> envs = new HashMap<>();
           if (script.getEnvironment() != null) {
             for (Map.Entry<String, Object> entry :
@@ -149,6 +146,8 @@ taskContext, new IllegalStateException("No script source defined."))
             }
           }
 
+          ByteArrayOutputStream stderr = new ByteArrayOutputStream();
+          ByteArrayOutputStream stdout = new ByteArrayOutputStream();
           try (Context context =
               Context.newBuilder(lowerLang)
                   .err(stderr)
@@ -168,14 +167,14 @@ taskContext, new IllegalStateException("No script source defined."))
                 });
 
             // configure process.env for js environment variables
-            if (language.equalsIgnoreCase(ScriptLanguage.JS.lang)) {
+            if (lowerLang.equalsIgnoreCase(ScriptLanguage.JS.lang)) {
               configureProcessEnv(context, envs);
             }
 
             if (!isAwait) {
               executorService.submit(
                   () -> {
-                    context.eval(scriptUnion.getInlineScript().getLanguage(), source);
+                    context.eval(lowerLang, source);
                   });
               return application.modelFactory().fromAny(taskContext.input());
             }
@@ -205,13 +204,11 @@ taskContext, new IllegalStateException("No script source defined."))
                 case ALL ->
                     modelFactory.fromAny(
                         new ProcessResult(
-                            e.getExitStatus(),
-                            stdout.toString().trim(),
-                            getStderrMessage(e, stderr)));
+                            e.getExitStatus(), stdout.toString().trim(), buildStderr(e, stderr)));
                 case NONE -> modelFactory.fromNull();
                 case CODE -> modelFactory.from(e.getExitStatus());
                 case STDOUT -> modelFactory.from(stdout.toString().trim());
-                case STDERR -> modelFactory.from(getStderrMessage(e, stderr));
+                case STDERR -> modelFactory.from(buildStderr(e, stderr));
               };
             }
           }
@@ -225,7 +222,7 @@ taskContext, new IllegalStateException("No script source defined."))
    * @param stderr the stderr stream
    * @return the stderr message
    */
-  private String getStderrMessage(PolyglotException e, ByteArrayOutputStream stderr) {
+  private String buildStderr(PolyglotException e, ByteArrayOutputStream stderr) {
     String err = stderr.toString();
     return err.isBlank() ? e.getMessage() : err.trim();
   }
@@ -251,7 +248,8 @@ private void configureProcessEnv(Context context, Map<String, String> envs) {
   @Override
   public CompletableFuture<WorkflowModel> apply(
       WorkflowContext workflowContext, TaskContext taskContext, WorkflowModel input) {
-    return CompletableFuture.supplyAsync(() -> this.fnExecutor.apply(workflowContext, taskContext));
+    return CompletableFuture.supplyAsync(
+        () -> this.scriptExecutor.apply(workflowContext, taskContext));
   }
 
   @Override