fix(client): load local file variable (#4594)

related to: #4523

clients/java/client/src/main/java/org/camunda/bpm/client/impl/EngineClient.java

@@ -52,11 +52,10 @@ public class EngineClient {
   public static final String FAILURE_RESOURCE_PATH = ID_RESOURCE_PATH + "/failure";
   public static final String BPMN_ERROR_RESOURCE_PATH = ID_RESOURCE_PATH + "/bpmnError";
   public static final String NAME_PATH_PARAM = "{name}";
-  public static final String EXECUTION_RESOURCE_PATH = "/execution";
-  public static final String EXECUTION_ID_RESOURCE_PATH = EXECUTION_RESOURCE_PATH + "/" + ID_PATH_PARAM;
-  public static final String GET_LOCAL_VARIABLE =  EXECUTION_ID_RESOURCE_PATH + "/localVariables/" + NAME_PATH_PARAM;
-  public static final String GET_LOCAL_BINARY_VARIABLE =  GET_LOCAL_VARIABLE + "/data";
-
+  public static final String PROCESS_INSTANCE_RESOURCE_PATH = "/process-instance";
+  public static final String PROCESS_INSTANCE_ID_RESOURCE_PATH = PROCESS_INSTANCE_RESOURCE_PATH + "/" + ID_PATH_PARAM;
+  public static final String GET_BINARY_VARIABLE =
+      PROCESS_INSTANCE_ID_RESOURCE_PATH + "/variables/" + NAME_PATH_PARAM + "/data";
   protected String baseUrl;
   protected String workerId;
   protected int maxTasks;
@@ -147,9 +146,9 @@ public void extendLock(String taskId, long newDuration)  {
     engineInteraction.postRequest(resourceUrl, payload, Void.class);
   }
 
-  public byte[] getLocalBinaryVariable(String variableName, String processInstanceId)  {
-    String resourcePath = baseUrl + GET_LOCAL_BINARY_VARIABLE
-            .replace(ID_PATH_PARAM, processInstanceId)
+  public byte[] getLocalBinaryVariable(String variableName, String executionId)  {
+    String resourcePath = baseUrl + GET_BINARY_VARIABLE
+            .replace(ID_PATH_PARAM, executionId)
             .replace(NAME_PATH_PARAM, variableName);
 
     return engineInteraction.getRequest(resourcePath);

clients/java/client/src/main/java/org/camunda/bpm/client/task/impl/ExternalTaskImpl.java

@@ -25,6 +25,7 @@
 import org.camunda.bpm.client.task.ExternalTask;
 import org.camunda.bpm.client.variable.impl.TypedValueField;
 import org.camunda.bpm.client.variable.impl.VariableValue;
+import org.camunda.bpm.client.variable.value.DeferredFileValue;
 import org.camunda.bpm.engine.variable.VariableMap;
 import org.camunda.bpm.engine.variable.Variables;
 import org.camunda.bpm.engine.variable.value.TypedValue;
@@ -257,6 +258,10 @@ public <T> T getVariable(String variableName) {
 
     VariableValue variableValue = receivedVariableMap.get(variableName);
     if (variableValue != null) {
+      if(variableValue.getTypedValue() instanceof DeferredFileValue) {
+        DeferredFileValue deferredFileValue = (DeferredFileValue) variableValue.getTypedValue();
+        deferredFileValue.setExecutionId(this.executionId);
+      }
       value = (T) variableValue.getValue();
     }
 
@@ -295,6 +300,10 @@ public <T extends TypedValue> T getVariableTyped(String variableName, boolean de
     VariableValue variableValue = receivedVariableMap.get(variableName);
     if (variableValue != null) {
       typedValue = variableValue.getTypedValue(deserializeObjectValues);
+      if(typedValue instanceof DeferredFileValue) {
+        DeferredFileValue deferredFileValue = (DeferredFileValue) typedValue;
+        deferredFileValue.setExecutionId(this.executionId);
+      }
     }
 
     return (T) typedValue;

clients/java/client/src/main/java/org/camunda/bpm/client/variable/impl/value/DeferredFileValueImpl.java

@@ -39,6 +39,7 @@ public class DeferredFileValueImpl extends FileValueImpl implements DeferredFile
   protected String variableName;
   protected String processInstanceId;
   protected EngineClient engineClient;
+  protected String executionId = null;
 
   public DeferredFileValueImpl(String filename, EngineClient engineClient) {
     super(PrimitiveValueType.FILE, filename);
@@ -47,7 +48,7 @@ public DeferredFileValueImpl(String filename, EngineClient engineClient) {
 
   protected void load() {
     try {
-      byte[] bytes = engineClient.getLocalBinaryVariable(variableName, processInstanceId);
+      byte[] bytes = engineClient.getLocalBinaryVariable(variableName, executionId);
       setValue(bytes);
 
       this.isLoaded = true;
@@ -79,9 +80,20 @@ public void setVariableName(String variableName) {
     this.variableName = variableName;
   }
 
+  @Override
+  public void setExecutionId(String executionId){
+    this.executionId = executionId;
+  };
+
+  @Override
+  public String getExecutionId() {
+    return executionId;
+  }
+
   @Override
   public String toString() {
-    return "DeferredFileValueImpl [mimeType=" + mimeType + ", filename=" + filename + ", type=" + type + ", isTransient=" + isTransient + ", isLoaded=" + isLoaded + "]";
+    return "DeferredFileValueImpl [mimeType=" + mimeType + ", filename=" + filename + ", type=" + type + ", "
+        + "isTransient=" + isTransient + ", isLoaded=" + isLoaded + ", processInstanceId" + processInstanceId + ", executionId" + executionId + "]";
   }
 
 }

clients/java/client/src/main/java/org/camunda/bpm/client/variable/value/DeferredFileValue.java

@@ -39,4 +39,20 @@ public interface DeferredFileValue extends FileValue {
    */
   boolean isLoaded();
 
+  /**
+   * Sets the executionId, which defines the scope of the DeferredFileValue.
+   * This identifier ensures that the correct scope is applied when loading the file value.
+   *
+   * @param executionId defines the scope of the DeferredFileValue
+   */
+  void setExecutionId(String executionId);
+
+  /**
+   * Returns the executionId, which specifies the scope of the DeferredFileValue.
+   * This identifier ensures that the correct scope is applied when loading the file value.
+   *
+   * @return the executionId which defines the scope of the DeferredFileValue
+   */
+  String getExecutionId();
+
 }