STG 73

eng/Packages.Data.props

@@ -25,6 +25,7 @@
     <PackageReference Update="Azure.Storage.Files.Shares" Version="12.0.1" />
     <PackageReference Update="Azure.Storage.Queues" Version="12.1.1" />
     <PackageReference Update="Azure.Storage.Files.DataLake" Version="12.0.0" />
+    <PackageReference Update="Azure.Storage.Blobs.ChangeFeed" Version="12.0.0-preview.1" />
     <PackageReference Update="BenchmarkDotNet" Version="0.11.5" />
     <PackageReference Update="Castle.Core" Version="4.4.0" />
     <PackageReference Update="FluentAssertions" Version="5.10.3" />

sdk/storage/Azure.Storage.Blobs.Batch/CHANGELOG.md

@@ -1,7 +1,8 @@
 # Release History
 
 ## 12.3.0-preview.1 (Unreleased)
-
+- Added support for service version 2019-12-12.
+- This release contains bug fixes to improve quality.
 
 ## 12.2.1 (2020-03)
 - Minor bugfixes around task completion.

sdk/storage/Azure.Storage.Blobs.Batch/README.md

@@ -1,6 +1,6 @@
 # Azure Storage Blobs Batch client library for .NET
 
-> Server Version: 2019-07-07 and 2019-02-02
+> Server Version: 2019-12-12, 2019-07-07, and 2019-02-02
 
 Azure Blob storage is Microsoft's object storage solution for the cloud. Blob
 storage is optimized for storing massive amounts of unstructured data.  This

sdk/storage/Azure.Storage.Blobs.Batch/tests/BlobBatchClientTests.cs

@@ -571,6 +571,51 @@ public async Task Batch_Double_Dispose_Response_Still_Available()
             scenario.AssertStatus(202, responses);
             await scenario.AssertDeleted(blobs);
         }
+
+        [Test]
+        [ServiceVersion(Min = BlobClientOptions.ServiceVersion.V2019_12_12)]
+        public async Task SetBlobAccessTier_Snapshot()
+        {
+            await using TestScenario scenario = Scenario();
+            BlockBlobClient[] blobs = await scenario.CreateBlockBlobsAsync(1);
+            Response<BlobSnapshotInfo> blobSnapshotResponse = await blobs[0].CreateSnapshotAsync();
+            blobs[0] = blobs[0].WithSnapshot(blobSnapshotResponse.Value.Snapshot);
+
+            BlobBatchClient client = scenario.GetBlobBatchClient();
+            using BlobBatch batch = client.CreateBatch();
+            Response[] responses = new Response[]
+            {
+                batch.SetBlobAccessTier(blobs[0].Uri, AccessTier.Cool),
+            };
+            Response response = await client.SubmitBatchAsync(batch);
+
+            scenario.AssertStatus(202, response);
+            scenario.AssertStatus(200, responses);
+            await scenario.AssertTiers(AccessTier.Cool, blobs);
+        }
+
+        [Test]
+        [ServiceVersion(Min = BlobClientOptions.ServiceVersion.V2019_12_12)]
+        public async Task SetBlobAccessTier_Version()
+        {
+            await using TestScenario scenario = Scenario();
+            BlockBlobClient[] blobs = await scenario.CreateBlockBlobsAsync(1);
+            Response<BlobInfo> setMetadataResponse = await blobs[0].SetMetadataAsync(BuildMetadata());
+
+            blobs[0] = blobs[0].WithVersion(setMetadataResponse.Value.VersionId);
+
+            BlobBatchClient client = scenario.GetBlobBatchClient();
+            using BlobBatch batch = client.CreateBatch();
+            Response[] responses = new Response[]
+            {
+                batch.SetBlobAccessTier(blobs[0].Uri, AccessTier.Cool),
+            };
+            Response response = await client.SubmitBatchAsync(batch);
+
+            scenario.AssertStatus(202, response);
+            scenario.AssertStatus(200, responses);
+            await scenario.AssertTiers(AccessTier.Cool, blobs);
+        }
         #endregion SetBlobAccessTier
 
         #region Scenario helper
@@ -611,9 +656,23 @@ public async Task<BlobClient[]> CreateBlobsAsync(BlobContainerClient container,
                 return blobs;
             }
 
+            public async Task<BlockBlobClient[]> CreateBlockBlobsAsync(BlobContainerClient container, int count)
+            {
+                BlockBlobClient[] blobs = new BlockBlobClient[count];
+                for (int i = 0; i < count; i++)
+                {
+                    blobs[i] = _test.InstrumentClient(container.GetBlockBlobClient("blob" + (++_blobId)));
+                    await blobs[i].UploadAsync(new MemoryStream(_test.GetRandomBuffer(Constants.KB)));
+                }
+                return blobs;
+            }
+
             public async Task<BlobClient[]> CreateBlobsAsync(int count) =>
                 await CreateBlobsAsync(await CreateContainerAsync(), count);
 
+            public async Task<BlockBlobClient[]> CreateBlockBlobsAsync(int count) =>
+                await CreateBlockBlobsAsync(await CreateContainerAsync(), count);
+
             public async Task<Uri[]> CreateBlobUrisAsync(BlobContainerClient container, int count) =>
                 (await CreateBlobsAsync(container, count)).Select(b => b.Uri).ToArray();
 
@@ -663,9 +722,24 @@ public async Task AssertTiers(AccessTier tier, BlobClient blob)
                 }
             }
 
+            public async Task AssertTiers(AccessTier tier, BlockBlobClient blob)
+            {
+                try
+                {
+                    BlobProperties properties = await blob.GetPropertiesAsync();
+                    Assert.AreEqual(tier.ToString(), properties.AccessTier.ToString());
+                }
+                catch (RequestFailedException)
+                {
+                }
+            }
+
             public Task AssertTiers(AccessTier tier, BlobClient[] blobs) =>
                 Task.WhenAll(blobs.Select(b => AssertTiers(tier, b)));
 
+            public Task AssertTiers(AccessTier tier, BlockBlobClient[] blobs) =>
+                Task.WhenAll(blobs.Select(b => AssertTiers(tier, b)));
+
             public void AssertStatus(int status, params Response[] responses) =>
                 Assert.IsTrue(responses.All(r => r.Status == status));