Skip to content

Commit e6ac6c4

Browse files
committed
PR fixes
1 parent 96fbf8a commit e6ac6c4

File tree

3 files changed

+10
-12
lines changed

3 files changed

+10
-12
lines changed

test/Extensions/Tester.Redis/Utility/CommonFixture.cs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -40,11 +40,9 @@ public async Task<IGrainStorage> GetStorageProvider(bool useOrleansSerializer =
4040
{
4141
IGrainStorageSerializer grainStorageSerializer = useOrleansSerializer ? new OrleansGrainStorageSerializer(this.DefaultProviderRuntime.ServiceProvider.GetService<Serializer>())
4242
: new JsonGrainStorageSerializer(this.DefaultProviderRuntime.ServiceProvider.GetService<OrleansJsonSerializer>());
43-
44-
var redisOptions = ConfigurationOptions.Parse(TestDefaultConfiguration.RedisConnectionString);
4543
var options = new RedisStorageOptions()
4644
{
47-
ConnectionString = redisOptions.ToString(),
45+
ConfigurationOptions = ConfigurationOptions.Parse(TestDefaultConfiguration.RedisConnectionString),
4846
GrainStorageSerializer = grainStorageSerializer
4947
};
5048

test/TesterInternal/StorageTests/CommonStorageTests.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -187,18 +187,18 @@ await RetryHelper.RetryOnExceptionAsync(5, RetryOperation.Sigmoid, async () =>
187187
await Storage.WriteStateAsync(grainTypeName, grainId, grainState);
188188
var writtenStateVersion = grainState.ETag;
189189
var recordExitsAfterWriting = grainState.RecordExists;
190+
Assert.True(recordExitsAfterWriting);
190191

191192
await Storage.ClearStateAsync(grainTypeName, grainId, grainState).ConfigureAwait(false);
192193
var clearedStateVersion = grainState.ETag;
193-
var recordExitsAfterClearing = grainState.RecordExists;
194+
Assert.NotEqual(writtenStateVersion, clearedStateVersion);
194195

195-
var storedGrainState = new GrainState<T> { State = new T() };
196-
await Storage.ReadStateAsync(grainTypeName, grainId, storedGrainState).ConfigureAwait(false);
196+
var recordExitsAfterClearing = grainState.RecordExists;
197+
Assert.False(recordExitsAfterClearing);
197198

198-
Assert.NotEqual(writtenStateVersion, clearedStateVersion);
199+
var storedGrainState = new GrainState<T> { State = new T(), ETag = clearedStateVersion };
200+
await Storage.WriteStateAsync(grainTypeName, grainId, storedGrainState).ConfigureAwait(false);
199201
Assert.Equal(storedGrainState.State, Activator.CreateInstance<T>());
200-
Assert.True(recordExitsAfterWriting);
201-
Assert.False(recordExitsAfterClearing);
202202
Assert.True(storedGrainState.RecordExists);
203203
}
204204

test/TesterInternal/StorageTests/CommonStorageUtilities.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
using Xunit;
1+
using Xunit;
22

33

44
namespace UnitTests.StorageTests.Relational
@@ -17,8 +17,8 @@ public static void AssertRelationalInconsistentExceptionMessage(string exception
1717
Assert.Contains("ServiceId=", exceptionMessage);
1818
Assert.Contains("ProviderName=", exceptionMessage);
1919
Assert.Contains("GrainType=", exceptionMessage);
20-
Assert.Contains($"GrainId=", exceptionMessage);
21-
Assert.Contains($"ETag=", exceptionMessage);
20+
Assert.Contains("GrainId=", exceptionMessage);
21+
Assert.Contains("ETag=", exceptionMessage);
2222
}
2323
}
2424
}

0 commit comments

Comments
 (0)