[ST] Blob Tool 3: Build and pack (#10773)

* Add

* Update

* Update

Author: zhhyu

build.ps1

@@ -157,7 +157,8 @@ Invoke-BuildStep 'Creating job packages from jobs solution' {
             "src\Validation.PackageSigning.ProcessSignature\Validation.PackageSigning.ProcessSignature.nuspec",
             "src\Validation.PackageSigning.RevalidateCertificate\Validation.PackageSigning.RevalidateCertificate.nuspec",
             "src\Validation.PackageSigning.ValidateCertificate\Validation.PackageSigning.ValidateCertificate.nuspec",
-            "src\Validation.Symbols\Validation.Symbols.Job.nuspec"
+            "src\Validation.Symbols\Validation.Symbols.Job.nuspec",
+            "src\UpdateBlobProperties\UpdateBlobProperties.nuspec"
         $JobsNuspecProjects | ForEach-Object {
             New-Package (Join-Path $PSScriptRoot $_) -Configuration $Configuration -BuildNumber $BuildNumber -Version $JobsPackageVersion -Branch $Branch
         }

src/UpdateBlobProperties/BlobInfoOfPackageVersionIndexInFlatContainer.cs

@@ -26,7 +26,7 @@ public override string GetBlobName(PackageInfo packageInfo)
 
             if (string.IsNullOrWhiteSpace(packageInfo.Id))
             {
-                throw new ArgumentException($"Invalid package Id with null or whitespace. Package Key: {packageInfo.Key}.");
+                throw new ArgumentException($"Invalid package Id with null or whitespace. Package Registration Key: {packageInfo.Key}.");
             }
 
             return $"/{packageInfo.Id.ToLowerInvariant()}/index.json";

src/UpdateBlobProperties/Collector.cs

@@ -41,7 +41,7 @@ public async IAsyncEnumerable<IList<PackageInfo>> GetPagesOfPackageInfosAsync(in
                 var pis = await _blobInfo.GetPageOfPackageInfosToUpdateBlobsAsync(_packageRepo, pageStartKey, maxKey, maxPageSize);
                 if (pis.Count > 0)
                 {
-                    _logger.LogInformation("Loaded page: {pageIndex} of {pageSize} package infos from DB. The page starts from key: {startPackageKey} and ends at key: {endPackageKey}.",
+                    _logger.LogInformation("Loaded page: {pageIndex} of {pageSize} package infos from DB. The page starts from key: {pageStartKey} and ends at key: {pageEndKey}.",
                         pageIndex, pis.Count, pis.First().Key, pis.Last().Key);
 
                     pageStartKey = pis.Last().Key + 1;

src/UpdateBlobProperties/UpdateBlobProperties.nuspec

@@ -0,0 +1,15 @@
+<?xml version="1.0"?>
+<package>
+  <metadata>
+    <id>UpdateBlobProperties</id>
+    <version>$version$</version>
+    <title>UpdateBlobProperties</title>
+    <authors>.NET Foundation</authors>
+    <owners>.NET Foundation</owners>
+    <description>UpdateBlobProperties</description>
+    <copyright>Copyright .NET Foundation</copyright>
+  </metadata>
+  <files>
+    <file src="bin\$configuration$\net472\*.*" target="bin"/>
+  </files>
+</package>

src/UpdateBlobProperties/Updater.cs

@@ -32,6 +32,7 @@ public async Task UpdateBlobPropertiesAsync(PackageInfo packageInfo, Cancellatio
         {
             var blobName = _blobInfo.GetBlobName(packageInfo);
             var blobClient = _blobContainerClient.GetBlobClient(blobName);
+            var blobUri = blobClient.Uri.GetLeftPart(UriPartial.Path);
 
             // Retries for concurrency control (Blob client is enabled with the retry policy)
             var retries = 0;
@@ -43,36 +44,36 @@ public async Task UpdateBlobPropertiesAsync(PackageInfo packageInfo, Cancellatio
                     if (!TryGetHeadersWhenBlobPropertiesNotMatched(response.Value, _blobInfo.GetUpdatedBlobProperties(), out var blobHttpHeaders))
                     {
                         _logger.LogInformation("Blob properties of Package Id: {packageId} and Version: {packageVersion} (Blob Uri: {blobUri}) are matched.",
-                            packageInfo.Id, packageInfo.Version, blobClient.Uri);
+                            packageInfo.Id, packageInfo.Version, blobUri);
 
                         return;
                     }
 
                     if (await UpdateAsync(blobClient, blobHttpHeaders, response.Value.ETag, token))
                     {
                         _logger.LogInformation("Blob properties of Package Id: {packageId} and Version: {packageVersion} (Blob Uri: {blobUri}) are updated successfully.",
-                            packageInfo.Id, packageInfo.Version, blobClient.Uri);
+                            packageInfo.Id, packageInfo.Version, blobUri);
 
                         return;
                     }
                     else
                     {
                         _logger.LogInformation("The blob of Package Id: {packageId} and Version: {packageVersion} (Blob Uri: {blobUri}) has been updated since the last read.",
-                            packageInfo.Id, packageInfo.Version, blobClient.Uri);
+                            packageInfo.Id, packageInfo.Version, blobUri);
                     }
                 }
                 catch (RequestFailedException e) when (e.Status == (int)HttpStatusCode.NotFound)
                 {
                     _logger.LogInformation("The blob of Package Id: {packageId} and Version: {packageVersion} (Blob Uri: {blobUri}) does not exist.",
-                        packageInfo.Id, packageInfo.Version, blobClient.Uri);
+                        packageInfo.Id, packageInfo.Version, blobUri);
 
                     return;
                 }
 
                 retries++;
                 if (retries == MaxRetries)
                 {
-                    throw new Exception($"Failed to update blob properties of Package Id: {packageInfo.Id} and Version: {packageInfo.Version} (Blob Uri: {blobClient.Uri}) after {MaxRetries} retries.");
+                    throw new Exception($"Failed to update blob properties of Package Id: {packageInfo.Id} and Version: {packageInfo.Version} (Blob Uri: {blobUri}) after {MaxRetries} retries.");
                 }
 
                 await Task.Delay(TimeSpan.FromSeconds(retries * 5), token);