Test DaprClient directly

Signed-off-by: Sergio Herrera <627709+seherv@users.noreply.github.com>

Author: Sergio Herrera

.github/workflows/validate_examples.yaml

@@ -152,5 +152,8 @@ jobs:
           ./dist/linux_amd64/release/placement --healthz-port 9091 &
           cd ..
       - name: Check examples
+        run: |
+          tox -e examples
+      - name: Run integration tests
         run: |
           tox -e integration

tests/examples/conftest.py

@@ -12,6 +12,10 @@
 EXAMPLES_DIR = REPO_ROOT / 'examples'
 
 
+def pytest_configure(config: pytest.Config) -> None:
+    config.addinivalue_line('markers', 'example_dir(name): set the example directory for a test')
+
+
 class DaprRunner:
     """Helper to run `dapr run` commands and capture output."""
 

tests/examples/test_configuration.py

@@ -3,6 +3,8 @@
 
 import pytest
 
+REDIS_CONTAINER = 'dapr_redis'
+
 EXPECTED_LINES = [
     'Got key=orderId1 value=100 version=1 metadata={}',
     'Got key=orderId2 value=200 version=1 metadata={}',
@@ -15,13 +17,13 @@
 def redis_config():
     """Seed configuration values in Redis before the test."""
     subprocess.run(
-        'docker exec dapr_redis redis-cli SET orderId1 "100||1"',
+        f'docker exec {REDIS_CONTAINER} redis-cli SET orderId1 "100||1"',
         shell=True,
         check=True,
         capture_output=True,
     )
     subprocess.run(
-        'docker exec dapr_redis redis-cli SET orderId2 "200||1"',
+        f'docker exec {REDIS_CONTAINER} redis-cli SET orderId2 "200||1"',
         shell=True,
         check=True,
         capture_output=True,
@@ -36,7 +38,7 @@ def test_configuration(dapr, redis_config):
     )
     # Update Redis to trigger the subscription notification
     subprocess.run(
-        'docker exec dapr_redis redis-cli SET orderId2 "210||2"',
+        f'docker exec {REDIS_CONTAINER} redis-cli SET orderId2 "210||2"',
         shell=True,
         check=True,
         capture_output=True,

tests/integration/apps/invoke_receiver.py

@@ -0,0 +1,13 @@
+"""gRPC method handler for invoke integration tests."""
+
+from dapr.ext.grpc import App, InvokeMethodRequest, InvokeMethodResponse
+
+app = App()
+
+
+@app.method(name='my-method')
+def my_method(request: InvokeMethodRequest) -> InvokeMethodResponse:
+    return InvokeMethodResponse(b'INVOKE_RECEIVED', 'text/plain; charset=UTF-8')
+
+
+app.run(50051)

tests/integration/apps/pubsub_subscriber.py

@@ -0,0 +1,25 @@
+"""Pub/sub subscriber that persists received messages to state store.
+
+Used by integration tests to verify message delivery without relying on stdout.
+"""
+
+import json
+
+from cloudevents.sdk.event import v1
+from dapr.ext.grpc import App
+
+from dapr.clients import DaprClient
+from dapr.clients.grpc._response import TopicEventResponse
+
+app = App()
+
+
+@app.subscribe(pubsub_name='pubsub', topic='TOPIC_A')
+def handle_topic_a(event: v1.Event) -> TopicEventResponse:
+    data = json.loads(event.Data())
+    with DaprClient() as d:
+        d.save_state('statestore', f'received-topic-a-{data["id"]}', event.Data())
+    return TopicEventResponse('success')
+
+
+app.run(50051)

tests/integration/components/configurationstore.yaml

@@ -0,0 +1,11 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: configurationstore
+spec:
+  type: configuration.redis
+  metadata:
+  - name: redisHost
+    value: localhost:6379
+  - name: redisPassword
+    value: ""

tests/integration/components/localsecretstore.yaml

@@ -0,0 +1,13 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: localsecretstore
+spec:
+  type: secretstores.local.file
+  metadata:
+  - name: secretsFile
+    # Relative to the Dapr process CWD (tests/integration/), set by
+    # DaprTestEnvironment via cwd=INTEGRATION_DIR.
+    value: secrets.json
+  - name: nestedSeparator
+    value: ":"

tests/integration/components/lockstore.yaml

@@ -0,0 +1,11 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: lockstore
+spec:
+  type: lock.redis
+  metadata:
+  - name: redisHost
+    value: localhost:6379
+  - name: redisPassword
+    value: ""

tests/integration/components/pubsub.yaml

@@ -0,0 +1,12 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: pubsub
+spec:
+  type: pubsub.redis
+  version: v1
+  metadata:
+  - name: redisHost
+    value: localhost:6379
+  - name: redisPassword
+    value: ""

tests/integration/components/statestore.yaml

@@ -0,0 +1,12 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: statestore
+spec:
+  type: state.redis
+  version: v1
+  metadata:
+  - name: redisHost
+    value: localhost:6379
+  - name: redisPassword
+    value: ""