Adding logger to WorkflowActivityContext (#1534)

* Adding logger to WorkflowActivityContext

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>

* Fixing a styling issue

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>

* Add unit tests for workflow activity context

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>

* Add more unit tests to make Codecov happy

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>

* Add more unit tests

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>

* Improve code coverage

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>

* Improve test names

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>

---------

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>
Co-authored-by: Artur Ciocanu <ciocanu@adobe.com>
Co-authored-by: salaboy <Salaboy@gmail.com>

dapr-spring/dapr-spring-boot-autoconfigure/src/test/java/io/dapr/spring/boot/autoconfigure/client/DaprClientAutoConfigurationTest.java

@@ -25,8 +25,6 @@ import org.mockito.junit.jupiter.MockitoExtension;
 import org.springframework.boot.autoconfigure.AutoConfigurations;
 import org.springframework.boot.test.context.runner.ApplicationContextRunner;
 
-import java.util.Map;
-
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
@@ -111,6 +109,18 @@ class DaprClientAutoConfigurationTest {
     verify(builder).withPropertyOverride(Properties.GRPC_PORT, String.valueOf(grpcPort));
   }
 
+  @Test
+  @DisplayName("Should override API token if it exists")
+  void shouldOverrideApiTokenIfExists() {
+    String apiToken = "token";
+
+    when(connectionDetails.getApiToken()).thenReturn(apiToken);
+
+    configuration.daprClientBuilder(connectionDetails);
+
+    verify(builder).withPropertyOverride(Properties.API_TOKEN, apiToken);
+  }
+
   @Test
   @DisplayName("Should override HTTP endpoint in properties if it exists")
   void shouldOverrideHttpEndpointInPropertiesIfExists() {
@@ -159,6 +169,18 @@ class DaprClientAutoConfigurationTest {
     assertThat(result.getValue(Properties.GRPC_PORT)).isEqualTo(grpcPort);
   }
 
+  @Test
+  @DisplayName("Should override API token in properties if it exists")
+  void shouldOverrideApiTokenPropertiesIfExists() {
+    String apiToken = "token";
+
+    when(connectionDetails.getApiToken()).thenReturn(apiToken);
+
+    Properties result = configuration.createPropertiesFromConnectionDetails(connectionDetails);
+
+    assertThat(result.getValue(Properties.API_TOKEN)).isEqualTo(apiToken);
+  }
+
   private static class TestDaprClientAutoConfiguration extends DaprClientAutoConfiguration {
 
     private final DaprClientBuilder daprClientBuilder;

sdk-workflows/src/main/java/io/dapr/workflows/WorkflowActivityContext.java

@@ -13,8 +13,12 @@ limitations under the License.
 
 package io.dapr.workflows;
 
+import org.slf4j.Logger;
+
 public interface WorkflowActivityContext {
 
+  Logger getLogger();
+
   String getName();
 
   String getTaskExecutionId();

sdk-workflows/src/main/java/io/dapr/workflows/runtime/DefaultWorkflowActivityContext.java

@@ -15,12 +15,15 @@ package io.dapr.workflows.runtime;
 
 import io.dapr.durabletask.TaskActivityContext;
 import io.dapr.workflows.WorkflowActivityContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * Wrapper for Durable Task Framework {@link TaskActivityContext}.
  */
 class DefaultWorkflowActivityContext implements WorkflowActivityContext {
   private final TaskActivityContext innerContext;
+  private final Logger logger;
 
   /**
    * Constructor for WorkflowActivityContext.
@@ -29,10 +32,36 @@ class DefaultWorkflowActivityContext implements WorkflowActivityContext {
    * @throws IllegalArgumentException if context is null
    */
   public DefaultWorkflowActivityContext(TaskActivityContext context) throws IllegalArgumentException {
+    this(context, LoggerFactory.getLogger(WorkflowActivityContext.class));
+  }
+
+  /**
+   * Constructor for WorkflowActivityContext.
+   *
+   * @param context TaskActivityContext
+   * @throws IllegalArgumentException if context is null
+   */
+  public DefaultWorkflowActivityContext(TaskActivityContext context, Logger logger) throws IllegalArgumentException {
     if (context == null) {
       throw new IllegalArgumentException("Context cannot be null");
     }
+
+    if (logger == null) {
+      throw new IllegalArgumentException("Logger cannot be null");
+    }
+
     this.innerContext = context;
+    this.logger = logger;
+  }
+
+  /**
+   * Gets the logger for the current activity.
+   *
+   * @return the logger for the current activity
+   */
+  @Override
+  public Logger getLogger() {
+    return this.logger;
   }
 
   /**

sdk-workflows/src/main/java/io/dapr/workflows/runtime/DefaultWorkflowContext.java

@@ -63,6 +63,7 @@ public class DefaultWorkflowContext implements WorkflowContext {
     if (context == null) {
       throw new IllegalArgumentException("Context cannot be null");
     }
+
     if (logger == null) {
       throw new IllegalArgumentException("Logger cannot be null");
     }

sdk-workflows/src/test/java/io/dapr/workflows/runtime/DefaultWorkflowActivityContextTest.java

@@ -0,0 +1,52 @@
+package io.dapr.workflows.runtime;
+
+import io.dapr.durabletask.TaskActivityContext;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+class DefaultWorkflowActivityContextTest {
+
+  @Test
+  @DisplayName("Should successfully create context and return correct values for all methods")
+  void shouldSuccessfullyCreateContextAndReturnCorrectValuesForAllMethods() {
+    TaskActivityContext mockInnerContext = mock(TaskActivityContext.class);
+    DefaultWorkflowActivityContext context = new DefaultWorkflowActivityContext(mockInnerContext);
+
+    when(mockInnerContext.getName()).thenReturn("TestActivity");
+    when(mockInnerContext.getInput(any())).thenReturn("TestInput");
+    when(mockInnerContext.getTaskExecutionId()).thenReturn("TestExecutionId");
+
+    assertNotNull(context.getLogger());
+    assertEquals("TestActivity", context.getName());
+
+    String input = context.getInput(String.class);
+
+    assertEquals("TestInput", input);
+    assertEquals("TestExecutionId", context.getTaskExecutionId());
+  }
+
+  @Test
+  @DisplayName("Should throw IllegalArgumentException when context parameter is null")
+  void shouldThrowIllegalArgumentExceptionWhenContextParameterIsNull() {
+    IllegalArgumentException exception = assertThrows(IllegalArgumentException.class, () -> {
+      new DefaultWorkflowActivityContext(null);
+    });
+    assertEquals("Context cannot be null", exception.getMessage());
+  }
+
+  @Test
+  @DisplayName("Should throw IllegalArgumentException when logger parameter is null")
+  void shouldThrowIllegalArgumentExceptionWhenLoggerParameterIsNull() {
+    TaskActivityContext mockInnerContext = mock(TaskActivityContext.class);
+
+    IllegalArgumentException exception = assertThrows(IllegalArgumentException.class, () -> {
+      new DefaultWorkflowActivityContext(mockInnerContext, null);
+    });
+    assertEquals("Logger cannot be null", exception.getMessage());
+  }
+}