Fix TestDaprInteractor

Signed-off-by: joshvanl <me@joshvanl.dev>

src/Dapr.Actors/Communication/ActorStateResponse.cs

@@ -18,7 +18,7 @@ namespace Dapr.Actors.Communication
     /// <summary>
     /// Represents a response from fetching an actor state key.
     /// </summary>
-    class ActorStateResponse<T>
+    public class ActorStateResponse<T>
     {
         /// <summary>
         /// Initializes a new instance of the <see cref="ActorStateResponse{T}"/> class.

test/Dapr.Actors.Test/TestDaprInteractor.cs

@@ -81,7 +81,7 @@ public Task SaveStateTransactionallyAsync(string actorType, string actorId, stri
         /// <param name="keyName">Name of key to get value for.</param>
         /// <param name="cancellationToken">Cancels the operation.</param>
         /// <returns>A task that represents the asynchronous operation.</returns>
-        public Task<string> GetStateAsync(string actorType, string actorId, string keyName, CancellationToken cancellationToken = default)
+        public Task<ActorStateResponse<string>> GetStateAsync(string actorType, string actorId, string keyName, CancellationToken cancellationToken = default)
         {
             throw new System.NotImplementedException();
         }

test/Dapr.E2E.Test.Actors/Reminders/IReminderActor.cs

@@ -1,4 +1,4 @@
-// ------------------------------------------------------------------------
+// ------------------------------------------------------------------------
 // Copyright 2021 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.

test/Dapr.E2E.Test.Actors/State/IStateActor.cs

@@ -18,5 +18,9 @@
 namespace Dapr.E2E.Test.Actors.State
 {
     public interface IStateActor : IPingActor, IActor
-    { }
+    {
+        Task<string> GetState(string key);
+
+        Task SetState(string key, string value, TimeSpan? ttl);
+    }
 }

test/Dapr.E2E.Test.App/Actors/StateActor.cs

@@ -18,21 +18,30 @@
 
 namespace Dapr.E2E.Test.Actors.State
 {
-    public class StateActor : Actor
+    public class StateActor : Actor, IStateActor
     {
         public StateActor(ActorHost host)
             : base(host)
         {
         }
 
+        public Task Ping()
+        {
+            return Task.CompletedTask;
+        }
+
         public Task<string> GetState(string key)
         {
             return this.StateManager.GetStateAsync<string>(key);
         }
 
-        public Task<string> SetState(string key, string value, TimeSpan? ttl)
+        public Task SetState(string key, string value, TimeSpan? ttl)
         {
-            return this.StateManager.SetStateAsync<string>(key, value, ttl: ttl);
+            if (ttl.HasValue)
+            {
+                return this.StateManager.SetStateAsync<String>(key, value, ttl: ttl.Value);
+            }
+            return this.StateManager.SetStateAsync<String>(key, value);
         }
     }
 }

test/Dapr.E2E.Test/Actors/E2ETests.StateTests.cs

@@ -30,15 +30,19 @@ public async Task ActorCanSaveStateWithTTL()
 
             await WaitForActorRuntimeAsync(proxy, cts.Token);
 
-            await proxy.SaveState("key", "value", 2, cts.Token);
+            await proxy.SetState("key", "value", TimeSpan.FromSeconds(2));
 
-            state = await.proxy.GetState("key", cts.Token);
-            Assert.Equal("value", state.Value);
+            var resp = await proxy.GetState("key");
+            Assert.Equal("value", resp);
 
-            await Task.Delay(TimeSpan.FromSeconds(2), cts.Token);
+            await Task.Delay(TimeSpan.FromSeconds(2));
 
-            state = await.proxy.GetState("key", cts.Token);
-            Assert.Null(state.Value);
+            resp = await proxy.GetState("key");
+            Assert.Null(resp);
+
+            await proxy.SetState("key", "new-value", null);
+            resp = await proxy.GetState("key");
+            Assert.Equal("new-value", resp);
         }
     }
 }