[GH Idx] Save blob to azurestorage

src/NuGet.Jobs.GitHubIndexer/GitHubIndexerConfiguration.cs

@@ -24,5 +24,15 @@ public class GitHubIndexerConfiguration
         /// The number of concurrent threads running to index Git repositories
         /// </summary>
         public int MaxDegreeOfParallelism { get; set; } = 32;
+
+        /// <summary>
+        /// The connection string to be used for a <see cref="NuGetGallery.CloudBlobClientWrapper"/> instance.
+        /// </summary>
+        public string StorageConnectionString { get; set; }
+
+        /// <summary>
+        /// Gets a setting if Read Access Geo Redundant is enabled in azure storage
+        /// </summary>
+        public bool StorageReadAccessGeoRedundant { get; set; }
     }
 }

src/NuGet.Jobs.GitHubIndexer/ReposIndexer.cs

@@ -18,8 +18,9 @@ namespace NuGet.Jobs.GitHubIndexer
     public class ReposIndexer
     {
         private const string WorkingDirectory = "work";
+        private const string BlobStorageContainerName = "content";
+        private const string GitHubUsageFileName = "GitHubUsage.v1.json";
 
-        private static readonly string GitHubUsageFilePath = Path.Combine(WorkingDirectory, "GitHubUsage.v1.json");
         public static readonly string RepositoriesDirectory = Path.Combine(WorkingDirectory, "repos");
         public static readonly string CacheDirectory = Path.Combine(WorkingDirectory, "cache");
 
@@ -29,6 +30,7 @@ public class ReposIndexer
         private readonly IRepositoriesCache _repoCache;
         private readonly IRepoFetcher _repoFetcher;
         private readonly IConfigFileParser _configFileParser;
+        private readonly ICloudBlobClient _cloudClient;
 
         public ReposIndexer(
             IGitRepoSearcher searcher,
@@ -50,6 +52,7 @@ public ReposIndexer(
             }
 
             _maxDegreeOfParallelism = configuration.Value.MaxDegreeOfParallelism;
+            _cloudClient = new CloudBlobClientWrapper(configuration.Value.StorageConnectionString, configuration.Value.StorageReadAccessGeoRedundant);
         }
 
         public async Task RunAsync()
@@ -80,14 +83,27 @@ await ProcessInParallel(inputBag, repo =>
                 .ThenBy(x => x.Id)
                 .ToList();
 
-            // TODO: Replace with upload to Azure Blob Storage (https://github.com/NuGet/NuGetGallery/issues/7211)
-            File.WriteAllText(GitHubUsageFilePath, JsonConvert.SerializeObject(finalList));
+            await WriteFinalBlob(finalList);
 
             // Delete the repos and cache directory
             Directory.Delete(RepositoriesDirectory, recursive: true);
             Directory.Delete(CacheDirectory, recursive: true);
         }
 
+        private async Task WriteFinalBlob(List<RepositoryInformation> finalList)
+        {
+            var serializer = new JsonSerializer();
+            var blobReference = _cloudClient.GetContainerReference(BlobStorageContainerName).GetBlobReference(GitHubUsageFileName);
+
+            using (var stream = await blobReference.OpenWriteAsync(accessCondition: null))
+            using (var streamWriter = new StreamWriter(stream))
+            using (var jsonTextWriter = new JsonTextWriter(streamWriter))
+            {
+                blobReference.Properties.ContentType = "application/json";
+                serializer.Serialize(jsonTextWriter, finalList);
+            }
+        }
+
         private RepositoryInformation ProcessSingleRepo(WritableRepositoryInformation repo)
         {
             if (_repoCache.TryGetCachedVersion(repo, out var cachedVersion))