[Fix #930] Adding authorization runtime expression (#940)

Signed-off-by: fjtirado <ftirados@redhat.com>

Author: fjtirado

impl/core/src/main/java/io/serverlessworkflow/impl/AuthorizationDescriptor.java

@@ -0,0 +1,18 @@
+/*
+ * Copyright 2020-Present The Serverless Workflow Specification Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.serverlessworkflow.impl;
+
+public record AuthorizationDescriptor(String scheme, String parameter) {}

impl/core/src/main/java/io/serverlessworkflow/impl/TaskContext.java

@@ -38,6 +38,7 @@ public class TaskContext implements TaskContextData {
   private Instant completedAt;
   private TransitionInfo transition;
   private short retryAttempt;
+  private AuthorizationDescriptor authorization;
 
   public TaskContext(
       WorkflowModel input,
@@ -93,6 +94,14 @@ public WorkflowModel rawInput() {
     return rawInput;
   }
 
+  public AuthorizationDescriptor authorization() {
+    return authorization;
+  }
+
+  public void authorization(String scheme, String parameter) {
+    this.authorization = new AuthorizationDescriptor(scheme, parameter);
+  }
+
   @Override
   public TaskBase task() {
     return task;

impl/core/src/main/java/io/serverlessworkflow/impl/WorkflowApplication.java

@@ -21,6 +21,7 @@
 import io.serverlessworkflow.api.types.Workflow;
 import io.serverlessworkflow.impl.additional.WorkflowAdditionalObject;
 import io.serverlessworkflow.impl.config.ConfigManager;
+import io.serverlessworkflow.impl.config.ConfigSecretManager;
 import io.serverlessworkflow.impl.config.SecretManager;
 import io.serverlessworkflow.impl.config.SystemPropertyConfigManager;
 import io.serverlessworkflow.impl.events.EventConsumer;
@@ -316,7 +317,7 @@ public WorkflowApplication build() {
         secretManager =
             ServiceLoader.load(SecretManager.class)
                 .findFirst()
-                .orElseGet(() -> s -> configManager.config(s, String.class));
+                .orElseGet(() -> new ConfigSecretManager(configManager));
       }
       return new WorkflowApplication(this);
     }

impl/core/src/main/java/io/serverlessworkflow/impl/WorkflowError.java

@@ -28,6 +28,10 @@ public static Builder authorization() {
     return error(Errors.AUTHORIZATION.toString(), Errors.AUTHORIZATION.status());
   }
 
+  public static Builder expression() {
+    return error("https://serverlessworkflow.io/spec/1.0.0/errors/expression", 400);
+  }
+
   public static Builder communication(int status, TaskContext context, Exception ex) {
     return communication(status, context, ex.getMessage());
   }

impl/core/src/main/java/io/serverlessworkflow/impl/WorkflowInstanceData.java

@@ -30,5 +30,7 @@ public interface WorkflowInstanceData {
 
   WorkflowModel output();
 
+  WorkflowModel context();
+
   <T> T outputAs(Class<T> clazz);
 }

impl/core/src/main/java/io/serverlessworkflow/impl/WorkflowMutableInstance.java

@@ -145,6 +145,11 @@ public WorkflowStatus status() {
     return status.get();
   }
 
+  @Override
+  public WorkflowModel context() {
+    return workflowContext.context();
+  }
+
   @Override
   public WorkflowModel output() {
     CompletableFuture<WorkflowModel> future = futureRef.get();

impl/core/src/main/java/io/serverlessworkflow/impl/additional/ConstantAdditionalObject.java

@@ -15,8 +15,8 @@
  */
 package io.serverlessworkflow.impl.additional;
 
-import io.serverlessworkflow.impl.TaskContext;
-import io.serverlessworkflow.impl.WorkflowContext;
+import io.serverlessworkflow.impl.TaskContextData;
+import io.serverlessworkflow.impl.WorkflowContextData;
 
 public class ConstantAdditionalObject<T> implements WorkflowAdditionalObject<T> {
 
@@ -27,7 +27,7 @@ public ConstantAdditionalObject(T object) {
   }
 
   @Override
-  public T apply(WorkflowContext t, TaskContext u) {
+  public T apply(WorkflowContextData t, TaskContextData u) {
     return object;
   }
 }

impl/core/src/main/java/io/serverlessworkflow/impl/additional/SuppliedAdditionalObject.java

@@ -15,8 +15,8 @@
  */
 package io.serverlessworkflow.impl.additional;
 
-import io.serverlessworkflow.impl.TaskContext;
-import io.serverlessworkflow.impl.WorkflowContext;
+import io.serverlessworkflow.impl.TaskContextData;
+import io.serverlessworkflow.impl.WorkflowContextData;
 import java.util.function.Supplier;
 
 public class SuppliedAdditionalObject<T> implements WorkflowAdditionalObject<T> {
@@ -28,7 +28,7 @@ public SuppliedAdditionalObject(Supplier<T> supplier) {
   }
 
   @Override
-  public T apply(WorkflowContext t, TaskContext u) {
+  public T apply(WorkflowContextData t, TaskContextData u) {
     return supplier.get();
   }
 }

impl/core/src/main/java/io/serverlessworkflow/impl/additional/WorkflowAdditionalObject.java

@@ -15,8 +15,9 @@
  */
 package io.serverlessworkflow.impl.additional;
 
-import io.serverlessworkflow.impl.TaskContext;
-import io.serverlessworkflow.impl.WorkflowContext;
+import io.serverlessworkflow.impl.TaskContextData;
+import io.serverlessworkflow.impl.WorkflowContextData;
 import java.util.function.BiFunction;
 
-public interface WorkflowAdditionalObject<T> extends BiFunction<WorkflowContext, TaskContext, T> {}
+public interface WorkflowAdditionalObject<T>
+    extends BiFunction<WorkflowContextData, TaskContextData, T> {}

impl/core/src/main/java/io/serverlessworkflow/impl/config/ConfigManager.java

@@ -19,5 +19,8 @@
 import java.util.Optional;
 
 public interface ConfigManager extends ServicePriority {
+
   <T> Optional<T> config(String propName, Class<T> propClass);
+
+  Iterable<String> names();
 }