Add Dapr.IntegrationTest.Actors integration test project and fix actor HTTP endpoint configuration

all.sln

@@ -251,6 +251,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Dapr.IntegrationTest.Messag
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Dapr.IntegrationTest.Cryptography", "test\Dapr.IntegrationTest.Cryptography\Dapr.IntegrationTest.Cryptography.csproj", "{7B14879F-156B-417E-ACA3-0B5A69CC2F39}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Dapr.IntegrationTest.Actors", "test\Dapr.IntegrationTest.Actors\Dapr.IntegrationTest.Actors.csproj", "{A1B2C3D4-E5F6-7890-ABCD-EF1234567890}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -669,6 +671,10 @@ Global
 		{7B14879F-156B-417E-ACA3-0B5A69CC2F39}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{7B14879F-156B-417E-ACA3-0B5A69CC2F39}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{7B14879F-156B-417E-ACA3-0B5A69CC2F39}.Release|Any CPU.Build.0 = Release|Any CPU
+		{A1B2C3D4-E5F6-7890-ABCD-EF1234567890}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{A1B2C3D4-E5F6-7890-ABCD-EF1234567890}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{A1B2C3D4-E5F6-7890-ABCD-EF1234567890}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{A1B2C3D4-E5F6-7890-ABCD-EF1234567890}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -791,6 +797,7 @@ Global
 		{97CAEE0B-4020-4A86-97DA-9900FDF4DFC6} = {8462B106-175A-423A-BA94-BE0D39D0BD8E}
 		{01A20A89-53A1-4D5B-B563-89E157718474} = {8462B106-175A-423A-BA94-BE0D39D0BD8E}
 		{7B14879F-156B-417E-ACA3-0B5A69CC2F39} = {8462B106-175A-423A-BA94-BE0D39D0BD8E}
+		{A1B2C3D4-E5F6-7890-ABCD-EF1234567890} = {8462B106-175A-423A-BA94-BE0D39D0BD8E}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {65220BF2-EAE1-4CB2-AA58-EBE80768CB40}

src/Dapr.Testcontainers/Common/DaprHarnessBuilder.cs

@@ -116,17 +116,10 @@ public CryptographyHarness BuildCryptography(string keysDir) =>
     /// <param name="componentsDir">The path to the Dapr resources.</param>
 	public PubSubHarness BuildPubSub(string componentsDir) => new(_componentsDirectory, _startApp, _options, _environment);
 
- //    /// <summary>
- //    /// Builds a state management harness.
- //    /// </summary>
- //    /// <param name="componentsDir">The path to the Dapr resources.</param>
-	// public StateManagementHarness BuildStateManagement(string componentsDir) => new(_componentsDirectory, _startApp, _options, _environment);
- //
- //    /// <summary>
- //    /// Builds an actor harness.
- //    /// </summary>
- //    /// <param name="componentsDir">The path to the Dapr resources.</param>
-	// public ActorHarness BuildActors(string componentsDir) => new(_componentsDirectory, _startApp, _options, _environment);
+    /// <summary>
+    /// Builds an actor harness.
+    /// </summary>
+    public ActorHarness BuildActors() => new(_componentsDirectory, _startApp, _options, _environment);
 
     /// <summary>
     /// Creates a test application builder for the specified harness.

src/Dapr.Testcontainers/Harnesses/ActorHarness.cs

@@ -16,7 +16,6 @@
 using System.Threading.Tasks;
 using Dapr.Testcontainers.Common.Options;
 using Dapr.Testcontainers.Containers;
-using Dapr.Testcontainers.Containers.Dapr;
 
 namespace Dapr.Testcontainers.Harnesses;
 
@@ -26,45 +25,54 @@ namespace Dapr.Testcontainers.Harnesses;
 public sealed class ActorHarness : BaseHarness
 {
     private readonly RedisContainer _redis;
-	private readonly DaprPlacementContainer _placement;
-	private readonly DaprSchedulerContainer _schedueler;
-    private readonly string componentsDir;
+    private readonly bool _isSelfHostedRedis;
+    private readonly string _componentsDir;
 
     /// <summary>
     /// Provides an implementation harness for Dapr's actor building block.
     /// </summary>
     /// <param name="componentsDir">The directory to Dapr components.</param>
     /// <param name="startApp">The test app to validate in the harness.</param>
-    /// <param name="options">The dapr runtime options.</param>
-    /// <param name="environment">The isolated environment instance.</param>
-    public ActorHarness(string componentsDir, Func<int, Task>? startApp, DaprRuntimeOptions options, DaprTestEnvironment? environment = null) : base(componentsDir, startApp, options, environment)
+    /// <param name="options">The Dapr runtime options.</param>
+    /// <param name="environment">
+    /// An optional shared <see cref="DaprTestEnvironment"/>. When provided the harness reuses
+    /// its Redis, Placement, and Scheduler services instead of starting its own.
+    /// </param>
+    public ActorHarness(string componentsDir, Func<int, Task>? startApp, DaprRuntimeOptions options, DaprTestEnvironment? environment = null)
+        : base(componentsDir, startApp, options, environment)
     {
-        this.componentsDir = componentsDir;
-        _placement = new DaprPlacementContainer(options, Network, ContainerLogsDirectory);
-        _schedueler = new DaprSchedulerContainer(options, Network, ContainerLogsDirectory);
-        _redis = new RedisContainer(Network, ContainerLogsDirectory);
+        _componentsDir = componentsDir;
+        _redis = environment?.RedisContainer ?? new RedisContainer(Network, ContainerLogsDirectory);
+        _isSelfHostedRedis = environment?.RedisContainer is null;
     }
 
     /// <inheritdoc />
-	protected override async Task OnInitializeAsync(CancellationToken cancellationToken)
-	{
-		// Start infrastructure
-		await _redis.StartAsync(cancellationToken);
-        await _placement.StartAsync(cancellationToken);
-        await _schedueler.StartAsync(cancellationToken);
-
-		// Emit component YAMLs pointing to Redis
-		RedisContainer.Yaml.WriteStateStoreYamlToFolder(componentsDir, redisHost: $"{_redis.NetworkAlias}:{RedisContainer.ContainerPort}");
+    protected override async Task OnInitializeAsync(CancellationToken cancellationToken)
+    {
+        // Only start Redis if it is not provided by a shared environment.
+        if (_isSelfHostedRedis)
+        {
+            await _redis.StartAsync(cancellationToken);
+        }
+
+        // Write the state-store component YAML that points to the Redis instance.
+        RedisContainer.Yaml.WriteStateStoreYamlToFolder(
+            _componentsDir,
+            redisHost: $"{_redis.NetworkAlias}:{RedisContainer.ContainerPort}");
 
-        DaprPlacementExternalPort = _placement.ExternalPort;
-        DaprSchedulerExternalPort = _schedueler.ExternalPort;
+        // Forward placement and scheduler coordinates from the environment.
+        DaprPlacementExternalPort = Environment.PlacementExternalPort;
+        DaprPlacementAlias = Environment.PlacementAlias;
+        DaprSchedulerExternalPort = Environment.SchedulerExternalPort;
+        DaprSchedulerAlias = Environment.SchedulerAlias;
     }
-	
+
     /// <inheritdoc />
-	protected override async ValueTask OnDisposeAsync()
-	{
-		await _redis.DisposeAsync();
-		await _placement.DisposeAsync();
-		await _schedueler.DisposeAsync();
-	}
+    protected override async ValueTask OnDisposeAsync()
+    {
+        if (_isSelfHostedRedis)
+        {
+            await _redis.DisposeAsync();
+        }
+    }
 }

test/Dapr.IntegrationTest.Actors/Actors/ExceptionTesting/ExceptionActor.cs

@@ -0,0 +1,40 @@
+// ------------------------------------------------------------------------
+// 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.
+// ------------------------------------------------------------------------
+
+using System;
+using System.Threading.Tasks;
+using Dapr.Actors.Runtime;
+
+namespace Dapr.IntegrationTest.Actors.ExceptionTesting;
+
+/// <summary>
+/// Implementation of <see cref="IExceptionActor"/> that unconditionally throws to
+/// validate that the Dapr runtime correctly propagates remote exceptions to callers.
+/// </summary>
+public class ExceptionActor : Actor, IExceptionActor
+{
+    /// <summary>
+    /// Initializes a new instance of <see cref="ExceptionActor"/>.
+    /// </summary>
+    /// <param name="host">The actor host provided by the Dapr runtime.</param>
+    public ExceptionActor(ActorHost host) : base(host)
+    {
+    }
+
+    /// <inheritdoc />
+    public Task Ping() => Task.CompletedTask;
+
+    /// <inheritdoc />
+    public Task ExceptionExample() =>
+        throw new InvalidOperationException("This exception is intentional.");
+}

test/Dapr.IntegrationTest.Actors/Actors/ExceptionTesting/IExceptionActor.cs

@@ -0,0 +1,26 @@
+// ------------------------------------------------------------------------
+// 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.
+// ------------------------------------------------------------------------
+
+using System.Threading.Tasks;
+using Dapr.Actors;
+
+namespace Dapr.IntegrationTest.Actors.ExceptionTesting;
+
+/// <summary>
+/// Actor interface that deliberately throws an exception to exercise error propagation.
+/// </summary>
+public interface IExceptionActor : IPingActor, IActor
+{
+    /// <summary>Always throws an <see cref="System.Exception"/> to validate remote exception handling.</summary>
+    Task ExceptionExample();
+}

test/Dapr.IntegrationTest.Actors/Actors/IPingActor.cs

@@ -0,0 +1,26 @@
+// ------------------------------------------------------------------------
+// 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.
+// ------------------------------------------------------------------------
+
+using System.Threading.Tasks;
+using Dapr.Actors;
+
+namespace Dapr.IntegrationTest.Actors;
+
+/// <summary>
+/// Minimal actor interface used as a readiness probe.
+/// </summary>
+public interface IPingActor : IActor
+{
+    /// <summary>Pings the actor to verify that the runtime is available.</summary>
+    Task Ping();
+}

test/Dapr.IntegrationTest.Actors/Actors/Reentrancy/IReentrantActor.cs

@@ -0,0 +1,69 @@
+// ------------------------------------------------------------------------
+// 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.
+// ------------------------------------------------------------------------
+
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Dapr.Actors;
+
+namespace Dapr.IntegrationTest.Actors.Reentrancy;
+
+/// <summary>
+/// Options controlling how a reentrant call chain is executed.
+/// </summary>
+public sealed class ReentrantCallOptions
+{
+    /// <summary>Gets or sets the number of additional reentrant calls remaining to make.</summary>
+    public int CallsRemaining { get; set; }
+
+    /// <summary>Gets or sets the zero-based sequence number of the current call.</summary>
+    public int CallNumber { get; set; }
+}
+
+/// <summary>
+/// Records a single enter or exit event within a reentrant call chain.
+/// </summary>
+public sealed class CallRecord
+{
+    /// <summary>Gets or sets a value indicating whether this record represents an entry (<see langword="true"/>) or exit (<see langword="false"/>).</summary>
+    public bool IsEnter { get; set; }
+
+    /// <summary>Gets or sets the wall-clock time of this event.</summary>
+    public DateTime Timestamp { get; set; }
+
+    /// <summary>Gets or sets the sequence number of the call that produced this record.</summary>
+    public int CallNumber { get; set; }
+}
+
+/// <summary>
+/// Per-call state kept by <see cref="IReentrantActor"/>.
+/// </summary>
+public sealed class ReentrantCallState
+{
+    /// <summary>Gets the ordered list of enter/exit records for a single call number.</summary>
+    public List<CallRecord> Records { get; init; } = [];
+}
+
+/// <summary>
+/// Actor interface that exercises Dapr actor reentrancy.
+/// </summary>
+public interface IReentrantActor : IPingActor, IActor
+{
+    /// <summary>Initiates a reentrant call chain as described by <paramref name="callOptions"/>.</summary>
+    /// <param name="callOptions">Controls the depth and sequence number of the reentrant chain.</param>
+    Task ReentrantCall(ReentrantCallOptions callOptions);
+
+    /// <summary>Returns the enter/exit records accumulated for the given <paramref name="callNumber"/>.</summary>
+    /// <param name="callNumber">The zero-based call number to retrieve state for.</param>
+    Task<ReentrantCallState> GetState(int callNumber);
+}

test/Dapr.IntegrationTest.Actors/Actors/Reentrancy/ReentrantActor.cs

@@ -0,0 +1,80 @@
+// ------------------------------------------------------------------------
+// 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.
+// ------------------------------------------------------------------------
+
+using System;
+using System.Threading.Tasks;
+using Dapr.Actors.Runtime;
+
+namespace Dapr.IntegrationTest.Actors.Reentrancy;
+
+/// <summary>
+/// Implementation of <see cref="IReentrantActor"/> that recursively calls itself
+/// to produce a chain of reentrant invocations.
+/// </summary>
+public class ReentrantActor : Actor, IReentrantActor
+{
+    /// <summary>
+    /// Initializes a new instance of <see cref="ReentrantActor"/>.
+    /// </summary>
+    /// <param name="host">The actor host provided by the Dapr runtime.</param>
+    public ReentrantActor(ActorHost host) : base(host)
+    {
+    }
+
+    /// <inheritdoc />
+    public Task Ping() => Task.CompletedTask;
+
+    /// <inheritdoc />
+    public async Task ReentrantCall(ReentrantCallOptions callOptions)
+    {
+        await UpdateState(isEnter: true, callOptions.CallNumber);
+
+        var self = ProxyFactory.CreateActorProxy<IReentrantActor>(Id, "ReentrantActor");
+        if (callOptions.CallsRemaining <= 1)
+        {
+            await self.Ping();
+        }
+        else
+        {
+            await self.ReentrantCall(new ReentrantCallOptions
+            {
+                CallsRemaining = callOptions.CallsRemaining - 1,
+                CallNumber = callOptions.CallNumber + 1,
+            });
+        }
+
+        await UpdateState(isEnter: false, callOptions.CallNumber);
+    }
+
+    /// <inheritdoc />
+    public Task<ReentrantCallState> GetState(int callNumber) =>
+        StateManager.GetOrAddStateAsync($"reentrant-record{callNumber}", new ReentrantCallState());
+
+    private async Task UpdateState(bool isEnter, int callNumber)
+    {
+        var stateKey = $"reentrant-record{callNumber}";
+        var state = await StateManager.GetOrAddStateAsync(stateKey, new ReentrantCallState());
+        state.Records.Add(new CallRecord
+        {
+            IsEnter = isEnter,
+            Timestamp = DateTime.Now,
+            CallNumber = callNumber,
+        });
+        await StateManager.SetStateAsync(stateKey, state);
+
+        if (!isEnter)
+        {
+            await StateManager.SaveStateAsync();
+        }
+    }
+}