Skip to content

Commit c04c499

Browse files
committed
Clean up and formatting
1 parent a41e3a0 commit c04c499

2 files changed

Lines changed: 21 additions & 18 deletions

File tree

tests/Ramstack.FileSystem.Amazon.Tests/WritableAmazonFileSystemTests.cs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ namespace Ramstack.FileSystem.Amazon;
1414
[Category("Cloud:Amazon")]
1515
public class WritableAmazonFileSystemTests : VirtualFileSystemSpecificationTests
1616
{
17-
private readonly HashSet<string> _list = [];
17+
private readonly HashSet<string> _buckets = [];
1818
private readonly TempFileStorage _storage = new TempFileStorage();
1919

2020
[OneTimeSetUp]
@@ -35,17 +35,17 @@ public async Task Cleanup()
3535
{
3636
_storage.Dispose();
3737

38-
foreach (var name in _list.ToArray())
38+
foreach (var name in _buckets.ToArray())
3939
{
4040
using var fs = CreateFileSystem(name);
4141

4242
try
4343
{
4444
await fs.DeleteDirectoryAsync("/");
4545
}
46-
catch (Exception exception)
46+
catch (Exception e)
4747
{
48-
Console.WriteLine(exception);
48+
Console.WriteLine(e);
4949
}
5050
}
5151
}
@@ -61,14 +61,15 @@ public async Task File_OpenWrite_InternalBufferWriteError_DoesNotCreateFile()
6161
Assert.That(underlying, Is.Not.Null);
6262

6363
// Write enough data to trigger automatic part upload (>= 5 MiB).
64-
await stream.WriteAsync(new ReadOnlyMemory<byte>(new byte[6 * 1024 * 1024]));
64+
await stream.WriteAsync(new byte[6 * 1024 * 1024]);
6565

6666
// Simulates an internal buffer write error.
6767
await underlying.DisposeAsync();
6868

6969
try
7070
{
71-
await stream.WriteAsync(new ReadOnlyMemory<byte>(new byte[1024]));
71+
await stream.WriteAsync(new byte[1024]);
72+
Assert.Fail();
7273
}
7374
catch
7475
{
@@ -239,7 +240,6 @@ public async Task File_OpenWrite_FlushWithMultipartUpload()
239240
for (var i = 0; i < Count; i++)
240241
await stream.WriteAsync(chunk);
241242
}
242-
243243
{
244244
var file = fs.GetFile(FileName);
245245

@@ -314,7 +314,7 @@ protected override DirectoryInfo GetDirectoryInfo() =>
314314

315315
private AmazonS3FileSystem CreateFileSystem(string storageName)
316316
{
317-
_list.Add(storageName);
317+
_buckets.Add(storageName);
318318

319319
return new AmazonS3FileSystem(
320320
new BasicAWSCredentials("rustfsadmin", "rustfsadmin"),

tests/Ramstack.FileSystem.Google.Tests/WritableGoogleFileSystemTests.cs

Lines changed: 13 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,9 @@ public async Task Cleanup()
4343
{
4444
await fs.DeleteDirectoryAsync("/");
4545
}
46-
catch (Exception exception)
46+
catch (Exception e)
4747
{
48-
Console.WriteLine(exception);
48+
Console.WriteLine(e);
4949
}
5050
}
5151
}
@@ -60,22 +60,19 @@ public async Task File_OpenWrite_InternalBufferWriteError_DoesNotCreateFile()
6060
var underlying = (FileStream)stream.GetType().GetField("_stream", BindingFlags.NonPublic | BindingFlags.Instance)!.GetValue(stream)!;
6161
Assert.That(underlying, Is.Not.Null);
6262

63-
await stream.WriteAsync(new ReadOnlyMemory<byte>(new byte[1024]));
64-
65-
// Forces to upload buffer.
66-
await stream.FlushAsync();
63+
await stream.WriteAsync(new byte[1024]);
6764

6865
// Simulates an internal buffer write error.
6966
await underlying.DisposeAsync();
7067

7168
try
7269
{
73-
await stream.WriteAsync(new ReadOnlyMemory<byte>(new byte[1024]));
70+
await stream.WriteAsync(new byte[1024]);
71+
Assert.Fail();
7472
}
75-
catch (Exception exception)
73+
catch
7674
{
77-
Console.WriteLine("Exception expected!");
78-
Console.WriteLine(exception);
75+
// Ignore
7976
}
8077
}
8178

@@ -160,6 +157,9 @@ public async Task File_CopyTo_File_DifferentFileSystems()
160157
Assert.That(
161158
await reader.ReadToEndAsync(),
162159
Is.EqualTo(content));
160+
161+
await source.DeleteAsync();
162+
await destination.DeleteAsync();
163163
}
164164

165165
[Test]
@@ -189,6 +189,9 @@ public async Task File_CopyTo_File_DifferentStorages()
189189
Assert.That(
190190
await reader.ReadToEndAsync(),
191191
Is.EqualTo(content));
192+
193+
await source.DeleteAsync();
194+
await destination.DeleteAsync();
192195
}
193196

194197
protected override GoogleFileSystem GetFileSystem() =>

0 commit comments

Comments
 (0)