adding duration and zoneddatetime examples

Author: salaboy

spring-boot-examples/workflows/src/main/java/io/dapr/springboot/examples/wfp/WorkflowPatternsRestController.java

@@ -24,6 +24,10 @@
 import io.dapr.springboot.examples.wfp.fanoutin.Result;
 import io.dapr.springboot.examples.wfp.remoteendpoint.Payload;
 import io.dapr.springboot.examples.wfp.remoteendpoint.RemoteEndpointWorkflow;
+//import io.dapr.springboot.examples.wfp.suspendresume.SuspendResumeWorkflow;
+import io.dapr.springboot.examples.wfp.timer.DurationTimerWorkflow;
+import io.dapr.springboot.examples.wfp.timer.ZonedDateTimeTimerWorkflow;
+
 import io.dapr.workflows.client.DaprWorkflowClient;
 import io.dapr.workflows.client.WorkflowInstanceStatus;
 import org.slf4j.Logger;
@@ -153,4 +157,50 @@ public Payload remoteEndpoint(@RequestBody Payload payload)
     return workflowInstanceStatus.readOutputAs(Payload.class);
   }
 
+  @PostMapping("wfp/suspendresume")
+  public String suspendResume(@RequestParam("orderId") String orderId) {
+    String instanceId = daprWorkflowClient.scheduleNewWorkflow(SuspendResumeWorkflow.class);
+    logger.info("Workflow instance " + instanceId + " started");
+    ordersToApprove.put(orderId, instanceId);
+    return instanceId;
+  }
+
+  @PostMapping("wfp/suspendresume/suspend")
+  public String suspendResumeExecuteSuspend(@RequestParam("orderId") String orderId) {
+    String instanceId = ordersToApprove.get(orderId);
+    daprWorkflowClient.suspendWorkflow(instanceId, "testing suspend");
+    WorkflowInstanceStatus instanceState = daprWorkflowClient.getInstanceState(instanceId, false);
+    return instanceState.getRuntimeStatus().name();
+  }
+
+  @PostMapping("wfp/suspendresume/resume")
+  public String suspendResumeExecuteResume(@RequestParam("orderId") String orderId) {
+    String instanceId = ordersToApprove.get(orderId);
+    daprWorkflowClient.resumeWorkflow(instanceId, "testing resume");
+    WorkflowInstanceStatus instanceState = daprWorkflowClient.getInstanceState(instanceId, false);
+    return instanceState.getRuntimeStatus().name();
+  }
+
+
+  @PostMapping("wfp/suspendresume/continue")
+  public Decision suspendResumeContinue(@RequestParam("orderId") String orderId, @RequestParam("decision") Boolean decision)
+          throws TimeoutException {
+    String instanceId = ordersToApprove.get(orderId);
+    logger.info("Workflow instance " + instanceId + " continue");
+    daprWorkflowClient.raiseEvent(instanceId, "Approval", decision);
+    WorkflowInstanceStatus workflowInstanceStatus = daprWorkflowClient
+            .waitForInstanceCompletion(instanceId, null, true);
+    return workflowInstanceStatus.readOutputAs(Decision.class);
+  }
+
+  @PostMapping("wfp/durationtimer")
+  public String durationTimerWorkflow() {
+    return daprWorkflowClient.scheduleNewWorkflow(DurationTimerWorkflow.class);
+  }
+
+  @PostMapping("wfp/zoneddatetimetimer")
+  public String zonedDateTimeTimerWorkflow() {
+    return daprWorkflowClient.scheduleNewWorkflow(ZonedDateTimeTimerWorkflow.class);
+  }
+
 }

spring-boot-examples/workflows/src/main/java/io/dapr/springboot/examples/wfp/timer/DurationTimerWorkflow.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright 2025 The Dapr 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.dapr.springboot.examples.wfp.timer;
+
+import io.dapr.workflows.Workflow;
+import io.dapr.workflows.WorkflowStub;
+import org.springframework.stereotype.Component;
+
+import java.time.Duration;
+import java.util.Date;
+
+@Component
+public class DurationTimerWorkflow implements Workflow {
+  @Override
+  public WorkflowStub create() {
+    return ctx -> {
+      ctx.getLogger().info("Starting Workflow: {}, instanceId: {}", ctx.getName(), ctx.getInstanceId());
+
+      ctx.getLogger().info("Let's call the first LogActivity at {}", new Date());
+      ctx.callActivity(LogActivity.class.getName()).await();
+
+      ctx.getLogger().info("Let's schedule a 10 seconds timer at {}", new Date());
+      ctx.createTimer(Duration.ofSeconds(10)).await();
+
+      ctx.getLogger().info("Let's call the second LogActivity at {}", new Date());
+      ctx.callActivity(LogActivity.class.getName()).await();
+
+      ctx.complete(true);
+      ctx.getLogger().info("Workflow completed at {}", new Date());
+    };
+  }
+}

spring-boot-examples/workflows/src/main/java/io/dapr/springboot/examples/wfp/timer/LogActivity.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright 2025 The Dapr 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.dapr.springboot.examples.wfp.timer;
+
+import io.dapr.workflows.WorkflowActivity;
+import io.dapr.workflows.WorkflowActivityContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+@Component
+public class LogActivity implements WorkflowActivity {
+
+  @Autowired
+  private TimerLogService logService;
+
+  @Override
+  public Object run(WorkflowActivityContext ctx) {
+    Logger logger = LoggerFactory.getLogger(LogActivity.class);
+    Date now = new Date();
+    logger.info("Running Activity: {} at {}", ctx.getName(), now);
+    logService.logDate(now);
+    return true;
+  }
+}

spring-boot-examples/workflows/src/main/java/io/dapr/springboot/examples/wfp/timer/TimerLogService.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright 2025 The Dapr 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.dapr.springboot.examples.wfp.timer;
+
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+@Component
+public class TimerLogService {
+  private final List<Date> logDates = new ArrayList<>();
+
+  public void logDate(Date date){
+    logDates.add(date);
+  }
+
+  public void clearLog(){
+    logDates.clear();
+  }
+
+  public List<Date> getLogDates(){
+    return logDates;
+  }
+}

spring-boot-examples/workflows/src/main/java/io/dapr/springboot/examples/wfp/timer/ZonedDateTimeTimerWorkflow.java

@@ -0,0 +1,47 @@
+/*
+ * Copyright 2025 The Dapr 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.dapr.springboot.examples.wfp.timer;
+
+import io.dapr.workflows.Workflow;
+import io.dapr.workflows.WorkflowStub;
+import org.springframework.stereotype.Component;
+
+import java.time.ZonedDateTime;
+import java.util.Date;
+
+@Component
+public class ZonedDateTimeTimerWorkflow implements Workflow {
+  @Override
+  public WorkflowStub create() {
+    return ctx -> {
+      ctx.getLogger().info("Starting Workflow: {}, instanceId: {}", ctx.getName(), ctx.getInstanceId());
+
+      ctx.getLogger().info("Let's call the first LogActivity at {}", new Date());
+      ctx.callActivity(LogActivity.class.getName()).await();
+
+      ZonedDateTime now = ZonedDateTime.now();
+      //Let's create a ZonedDateTime 10 seconds in the future
+      ZonedDateTime inTheFuture = now.plusSeconds(10);
+      ctx.getLogger().info("Creating a timer that due {} at: {}", inTheFuture, new Date());
+      ctx.createTimer(inTheFuture).await();
+      ctx.getLogger().info("The timer fired at: {}", new Date());
+
+      ctx.getLogger().info("Let's call the second LogActivity at {}", new Date());
+      ctx.callActivity(LogActivity.class.getName()).await();
+
+      ctx.complete(true);
+      ctx.getLogger().info("Workflow completed at {}", new Date());
+    };
+  }
+}

spring-boot-examples/workflows/src/test/java/io/dapr/springboot/examples/wfp/WorkflowPatternsAppTests.java

@@ -17,6 +17,8 @@
 import io.dapr.springboot.DaprAutoConfiguration;
 import io.dapr.springboot.examples.wfp.continueasnew.CleanUpLog;
 import io.dapr.springboot.examples.wfp.remoteendpoint.Payload;
+import io.dapr.springboot.examples.wfp.timer.TimerLogService;
+import io.dapr.workflows.client.WorkflowRuntimeStatus;
 import io.github.microcks.testcontainers.MicrocksContainersEnsemble;
 import io.restassured.RestAssured;
 import io.restassured.http.ContentType;
@@ -25,13 +27,17 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
+import java.time.Duration;
 import java.util.Arrays;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 import static io.restassured.RestAssured.given;
+import static org.awaitility.Awaitility.await;
 import static org.hamcrest.CoreMatchers.containsString;
 import static org.hamcrest.Matchers.equalTo;
 import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
 
 @SpringBootTest(classes = {TestWorkflowPatternsApplication.class, DaprTestContainersConfig.class,
         DaprAutoConfiguration.class, },
@@ -44,10 +50,14 @@ class WorkflowPatternsAppTests {
   @Autowired
   private MicrocksContainersEnsemble ensemble;
 
+  @Autowired
+  private TimerLogService logService;
+
   @BeforeEach
   void setUp() {
     RestAssured.baseURI = "http://localhost:" + 8080;
     org.testcontainers.Testcontainers.exposeHostPorts(8080);
+    logService.clearLog();
   }
 
 
@@ -160,4 +170,107 @@ void testRemoteEndpoint() {
             .getServiceInvocationsCount("API Payload Processor", "1.0.0"));
   }
 
+  @Test
+  void testSuspendResume() {
+
+    String instanceId = given()
+            .queryParam("orderId", "123")
+            .when()
+            .post("/wfp/suspendresume")
+            .then()
+            .statusCode(200).extract().asString();
+
+    assertNotNull(instanceId);
+
+    // The workflow is waiting on an event, let's suspend the workflow
+    String state = given()
+            .queryParam("orderId", "123")
+            .when()
+            .post("/wfp/suspendresume/suspend")
+            .then()
+            .statusCode(200).extract().asString();
+
+    assertEquals(WorkflowRuntimeStatus.SUSPENDED.name(), state);
+
+    // The let's resume the suspended workflow and check the state
+    state = given()
+            .queryParam("orderId", "123")
+            .when()
+            .post("/wfp/suspendresume/resume")
+            .then()
+            .statusCode(200).extract().asString();
+
+    assertEquals(WorkflowRuntimeStatus.RUNNING.name(), state);
+
+    // Now complete the workflow by sending an event
+    given()
+            .queryParam("orderId", "123")
+            .queryParam("decision", false)
+            .when()
+            .post("/wfp/suspendresume/continue")
+            .then()
+            .statusCode(200).body("approved", equalTo(false));
+
+  }
+
+  @Test
+  void testDurationTimer() throws InterruptedException {
+
+    String instanceId = given()
+            .when()
+            .post("/wfp/durationtimer")
+            .then()
+            .statusCode(200).extract().asString();
+
+    assertNotNull(instanceId);
+
+    // Check that the workflow completed successfully
+    await().atMost(Duration.ofSeconds(30))
+            .pollDelay(500, TimeUnit.MILLISECONDS)
+            .pollInterval(500, TimeUnit.MILLISECONDS)
+            .until(() -> {
+              System.out.println("Log Size: " + logService.getLogDates().size());
+              if( logService.getLogDates().size() == 2 ) {
+                long diffInMillis = Math.abs(logService.getLogDates().get(1).getTime() - logService.getLogDates().get(0).getTime());
+                long diff = TimeUnit.SECONDS.convert(diffInMillis, TimeUnit.MILLISECONDS);
+                System.out.println("First Log at: " + logService.getLogDates().get(0));
+                System.out.println("Second Log at: " + logService.getLogDates().get(1));
+                System.out.println("Diff in seconds: " + diff);
+                // The updated time differences should be between 9 and 11 seconds
+                return diff >= 9 && diff <= 11;
+              }
+              return false;
+            });
+  }
+
+  @Test
+  void testZonedDateTimeTimer() throws InterruptedException {
+
+    String instanceId = given()
+            .when()
+            .post("/wfp/zoneddatetimetimer")
+            .then()
+            .statusCode(200).extract().asString();
+
+    assertNotNull(instanceId);
+
+    // Check that the workflow completed successfully
+    await().atMost(Duration.ofSeconds(30))
+            .pollDelay(500, TimeUnit.MILLISECONDS)
+            .pollInterval(500, TimeUnit.MILLISECONDS)
+            .until(() -> {
+              System.out.println("Log Size: " + logService.getLogDates().size());
+              if( logService.getLogDates().size() == 2 ) {
+                long diffInMillis = Math.abs(logService.getLogDates().get(1).getTime() - logService.getLogDates().get(0).getTime());
+                long diff = TimeUnit.SECONDS.convert(diffInMillis, TimeUnit.MILLISECONDS);
+                System.out.println("First Log at: " + logService.getLogDates().get(0));
+                System.out.println("Second Log at: " + logService.getLogDates().get(1));
+                System.out.println("Diff in seconds: " + diff);
+                // The updated time differences should be between 9 and 11 seconds
+                return diff >= 9 && diff <= 11;
+              }
+              return false;
+            });
+  }
+
 }