Adding producer and consumer app examples for Spring Boot integration

.github/scripts/update_sdk_version.sh

@@ -27,4 +27,7 @@ mvn versions:set -DnewVersion=$DAPR_JAVA_SDK_ALPHA_VERSION -f testcontainers-dap
 # dapr-spring
 mvn versions:set -DnewVersion=$DAPR_JAVA_SDK_ALPHA_VERSION -f dapr-spring/pom.xml
 
+# spring-boot-examples
+mvn versions:set -DnewVersion=$DAPR_JAVA_SDK_ALPHA_VERSION -f spring-boot-examples/pom.xml
+
 git clean -f

.github/workflows/validate.yml

@@ -164,3 +164,7 @@ jobs:
         working-directory: ./examples
         run: |
           mm.py ./src/main/java/io/dapr/examples/pubsub/stream/README.md
+      - name: Validate Spring Boot examples
+        working-directory: ./spring-boot-examples
+        run: |
+          mm.py README.md    

README.md

@@ -9,6 +9,7 @@ This is the Dapr SDK for Java, including the following features:
 * Binding
 * State Store
 * Actors
+* Workflows
 
 ## Getting Started
 
@@ -112,6 +113,13 @@ Try the following examples to learn more about Dapr's Java SDK:
 * [Exception handling](./examples/src/main/java/io/dapr/examples/exception)
 * [Unit testing](./examples/src/main/java/io/dapr/examples/unittesting)
 
+### Running Spring Boot examples
+
+The Spring Boot integration for Dapr use [Testcontainers](https://testcontainers.com) to set up a local environment development flow that doesn't 
+require the use of the `dapr` CLI and it integrates with the Spring Boot programming model. 
+
+You can find a [step-by-step tutorial showing this integration here](./spring-boot-examples/README.md).
+
 ### API Documentation
 
 Please, refer to our [Javadoc](https://dapr.github.io/java-sdk/) website.

pom.xml

@@ -337,6 +337,7 @@
     <module>sdk-springboot</module>
     <module>dapr-spring</module>
     <module>examples</module>
+    <module>spring-boot-examples</module>
     <!-- We are following test containers artifact convention on purpose, don't rename -->
     <module>testcontainers-dapr</module>
   </modules>

sdk-tests/src/test/java/io/dapr/it/testcontainers/DaprContainerIT.java

@@ -62,9 +62,10 @@ public class DaprContainerIT {
 
   @Container
   private static final DaprContainer DAPR_CONTAINER = new DaprContainer("daprio/daprd")
-      .withAppName("dapr-app")
-      .withAppPort(8081)
-      .withAppChannelAddress("host.testcontainers.internal");
+          .withAppName("dapr-app")
+          .withAppPort(8081)
+          .withAppHealthCheckPath("/actuator/health")
+          .withAppChannelAddress("host.testcontainers.internal");
 
   /**
    * Sets the Dapr properties for the test.
@@ -76,32 +77,35 @@ public void setDaprProperties() {
   }
 
   private void configStub() {
+    stubFor(any(urlMatching("/actuator/health"))
+            .willReturn(aResponse().withBody("[]").withStatus(200)));
+
     stubFor(any(urlMatching("/dapr/subscribe"))
-        .willReturn(aResponse().withBody("[]").withStatus(200)));
+            .willReturn(aResponse().withBody("[]").withStatus(200)));
 
     stubFor(get(urlMatching("/dapr/config"))
-        .willReturn(aResponse().withBody("[]").withStatus(200)));
+            .willReturn(aResponse().withBody("[]").withStatus(200)));
 
     stubFor(any(urlMatching("/([a-z1-9]*)"))
-        .willReturn(aResponse().withBody("[]").withStatus(200)));
+            .willReturn(aResponse().withBody("[]").withStatus(200)));
 
     // create a stub
     stubFor(post(urlEqualTo("/events"))
-        .willReturn(aResponse().withBody("event received!").withStatus(200)));
+            .willReturn(aResponse().withBody("event received!").withStatus(200)));
 
     configureFor("localhost", 8081);
   }
 
   @Test
   public void testDaprContainerDefaults() {
     assertEquals(2,
-        DAPR_CONTAINER.getComponents().size(),
-        "The pubsub and kvstore component should be configured by default"
+            DAPR_CONTAINER.getComponents().size(),
+            "The pubsub and kvstore component should be configured by default"
     );
     assertEquals(
-        1,
-        DAPR_CONTAINER.getSubscriptions().size(),
-        "A subscription should be configured by default if none is provided"
+            1,
+            DAPR_CONTAINER.getSubscriptions().size(),
+            "A subscription should be configured by default if none is provided"
     );
   }
 
@@ -128,10 +132,10 @@ public void testPlacement() throws Exception {
     Thread.sleep(1000);
 
     OkHttpClient okHttpClient = new OkHttpClient.Builder()
-        .build();
+            .build();
     Request request = new Request.Builder()
-        .url(DAPR_CONTAINER.getHttpEndpoint() + "/v1.0/metadata")
-        .build();
+            .url(DAPR_CONTAINER.getHttpEndpoint() + "/v1.0/metadata")
+            .build();
 
     try (Response response = okHttpClient.newCall(request).execute()) {
       if (response.isSuccessful() && response.body() != null) {
@@ -157,7 +161,7 @@ public void testPubSub() throws Exception {
 
   private DaprClientBuilder createDaprClientBuilder() {
     return new DaprClientBuilder()
-        .withPropertyOverride(Properties.HTTP_ENDPOINT, DAPR_CONTAINER.getHttpEndpoint())
-        .withPropertyOverride(Properties.GRPC_ENDPOINT, DAPR_CONTAINER.getGrpcEndpoint());
+            .withPropertyOverride(Properties.HTTP_ENDPOINT, DAPR_CONTAINER.getHttpEndpoint())
+            .withPropertyOverride(Properties.GRPC_ENDPOINT, DAPR_CONTAINER.getGrpcEndpoint());
   }
 }

spring-boot-examples/README.md

@@ -0,0 +1,176 @@
+# Dapr Spring Boot and Testcontainers integration Example
+
+This example consists of two applications:
+- Producer App: 
+  - Publish messages using a Spring Messaging approach 
+  - Store and retrieve information using Spring Data CrudRepository 
+  - Implements a Workflow with Dapr Workflows
+- Consumer App:
+  - Subscribe to messages
+
+## Running these examples from source code
+
+To run these examples you will need: 
+- Java SDK
+- Maven
+- Docker or a container runtime such as Podman
+
+From the `spring-boot-examples/` directory you can start each service using the test configuration that uses 
+[Testcontainers](https://testcontainers.com) to boostrap [Dapr](https://dapr.io) by running the following command: 
+
+<!-- STEP
+name: Run Demo Producer Service
+match_order: none
+output_match_mode: substring
+expected_stdout_lines:
+- 'Started ProducerApplication'
+background: true
+expected_return_code: 143
+sleep: 30
+timeout_seconds: 45
+-->
+<!-- Timeout for above service must be more than sleep + timeout for the client-->
+
+```sh
+cd producer-app/
+../../mvnw -Dspring-boot.run.arguments="--reuse=true" spring-boot:test-run
+```
+
+<!-- END_STEP -->
+
+This will start the `producer-app` with Dapr services and the infrastructure needed by the application to run, 
+in this case RabbitMQ and PostgreSQL. The `producer-app` starts on port `8080` by default.
+
+The `-Dspring-boot.run.arguments="--reuse=true"` flag helps the application to connect to an existing shared 
+infrastructure if it already exists. For development purposes, and to connect both applications we will set the flag
+in both. For more details check the `DaprTestContainersConfig.java` classes in both, the `producer-app` and the `consumer-app`.
+
+Then run in a different terminal:
+
+<!-- STEP
+name: Run Demo Consumer Service
+match_order: none
+output_match_mode: substring
+expected_stdout_lines:
+- 'Started ConsumerApplication'
+background: true
+expected_return_code: 143
+sleep: 30
+timeout_seconds: 45
+-->
+<!-- Timeout for above service must be more than sleep + timeout for the client-->
+
+```sh
+cd consumer-app/
+../../mvnw -Dspring-boot.run.arguments="--reuse=true" spring-boot:test-run
+```
+
+<!-- END_STEP -->
+The `consumer-app` starts in port `8081` by default.
+
+## Interacting with the applications
+
+Now that both applications are up you can place an order by sending a POST request to `:8080/orders/`
+You can use `curl` to send a POST request to the `producer-app`: 
+
+
+<!-- STEP
+name: Send POST request to Producer App
+match_order: none
+output_match_mode: substring
+expected_stdout_lines:
+- 'Order Stored and Event Published'
+background: true
+sleep: 1
+timeout_seconds: 2
+-->
+<!-- Timeout for above service must be more than sleep + timeout for the client-->
+
+```sh
+curl -X POST localhost:8080/orders -H 'Content-Type: application/json' -d '{ "item": "the mars volta EP", "amount": 1 }'
+```
+
+<!-- END_STEP -->
+
+
+If you check the `producer-app` logs you should see the following lines: 
+
+```bash
+...
+Storing Order: Order{id='null', item='the mars volta EP', amount=1}
+Publishing Order Event: Order{id='d4f8ea15-b774-441e-bcd2-7a4208a80bec', item='the mars volta EP', amount=1}
+
+```
+
+If you check the `consumer-app` logs you should see the following lines, showing that the message 
+published by the `producer-app` was correctly consumed by the `consumer-app`:
+
+```bash
+Order Event Received: Order{id='d4f8ea15-b774-441e-bcd2-7a4208a80bec', item='the mars volta EP', amount=1}
+```
+
+Next, you can create a new customer to trigger the customer's tracking workflow: 
+
+<!-- STEP
+name: Start Customer Workflow
+match_order: none
+output_match_mode: substring
+expected_stdout_lines:
+- 'New Workflow Instance created for Customer'
+background: true
+sleep: 1
+timeout_seconds: 2
+-->
+<!-- Timeout for above service must be more than sleep + timeout for the client-->
+
+```sh
+curl -X POST localhost:8080/customers -H 'Content-Type: application/json' -d '{ "customerName": "salaboy" }'
+```
+
+<!-- END_STEP -->
+
+
+A new Workflow Instance was created to track the customers interactions. Now, the workflow instance
+is waiting for the customer to request a follow-up. 
+
+You should see in the `producer-app` logs: 
+
+```bash
+Workflow instance <Workflow Instance Id> started
+Let's register the customer: salaboy
+Customer: salaboy registered.
+Let's wait for the customer: salaboy to request a follow up.
+```
+
+Send an event simulating the customer request for a follow-up:
+
+<!-- STEP
+name: Emit Customer Follow-up event
+match_order: none
+output_match_mode: substring
+expected_stdout_lines:
+- 'Customer Follow-up requested'
+background: true
+sleep: 1
+timeout_seconds: 5
+-->
+<!-- Timeout for above service must be more than sleep + timeout for the client-->
+
+```sh
+curl -X POST localhost:8080/customers/followup -H 'Content-Type: application/json' -d '{ "customerName": "salaboy" }'
+```
+
+<!-- END_STEP -->
+
+In the `producer-app` logs you should see that the workflow instance id moved forward to the Customer Follow Up activity: 
+
+```bash
+Customer follow-up requested: salaboy
+Let's book a follow up for the customer: salaboy
+Customer: salaboy follow-up done.
+Congratulations the customer: salaboy is happy!
+```
+
+## Running on Kubernetes
+
+You can run the same example on a Kubernetes cluster. [Check the Kubernetes tutorial here](kubernetes/README.md).