implement get file stream for writing

src/Foundatio.AzureStorage/Foundatio.AzureStorage.csproj

@@ -8,7 +8,7 @@
     <PackageReference Include="Microsoft.Azure.Storage.Blob" Version="11.2.3" />
     <PackageReference Include="Microsoft.Azure.Storage.Queue" Version="11.2.3" />
 
-    <PackageReference Include="Foundatio" Version="10.6.1" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
+    <PackageReference Include="Foundatio" Version="10.6.2-alpha.0.4" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
     <ProjectReference Include="..\..\..\Foundatio\src\Foundatio\Foundatio.csproj" Condition="'$(ReferenceFoundatioSource)' == 'true'" />
   </ItemGroup>
 </Project>

src/Foundatio.AzureStorage/Storage/AzureFileStorage.cs

@@ -43,17 +43,24 @@ public AzureFileStorage(Builder<AzureFileStorageOptionsBuilder, AzureFileStorage
 
         ISerializer IHaveSerializer.Serializer => _serializer;
 
-        public async Task<Stream> GetFileStreamAsync(string path, CancellationToken cancellationToken = default) {
-            if (String.IsNullOrEmpty(path))
-                throw new ArgumentNullException(nameof(path));
+        public Task<Stream> GetFileStreamAsync(string path, CancellationToken cancellationToken = default)
+            => GetFileStreamAsync(path, StreamMode.Read, cancellationToken);
 
+        public async Task<Stream> GetFileStreamAsync(string path, StreamMode streamMode, CancellationToken cancellationToken = default) {
+            if (String.IsNullOrEmpty(path))
+                throw new ArgumentNullException(nameof(path)); 
+
             string normalizedPath = NormalizePath(path);
             _logger.LogTrace("Getting file stream for {Path}", normalizedPath);
-            
+
             var blockBlob = _container.GetBlockBlobReference(normalizedPath);
-            
+
             try {
-                return await blockBlob.OpenReadAsync(null, null, null, cancellationToken).AnyContext();
+                return streamMode switch {
+                    StreamMode.Read => await blockBlob.OpenReadAsync(null, null, null, cancellationToken).AnyContext(),
+                    StreamMode.Write => await blockBlob.OpenWriteAsync(null, null, null, cancellationToken).AnyContext(),
+                    _ => null
+                };
             } catch (StorageException ex) when (ex is { RequestInformation.HttpStatusCode: 404}) {
                 _logger.LogDebug(ex, "Unable to get file stream for {Path}: File Not Found", normalizedPath);
                 return null;

tests/Foundatio.AzureStorage.Tests/Foundatio.AzureStorage.Tests.csproj

@@ -7,4 +7,7 @@
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>
     </None>
   </ItemGroup>
+  <ItemGroup>
+    <PackageReference Update="Foundatio.TestHarness" Version="10.6.2-alpha.0.4" />
+  </ItemGroup>
 </Project>

tests/Foundatio.AzureStorage.Tests/Storage/AzureStorageTests.cs

@@ -109,5 +109,10 @@ public override Task CanRoundTripSeekableStreamAsync() {
         public override Task WillRespectStreamOffsetAsync() {
             return base.WillRespectStreamOffsetAsync();
         }
+
+        [Fact]
+        public override Task WillWriteStreamContentAsync() {
+            return base.WillWriteStreamContentAsync();
+        }
     }
 }