Add null-forgiving operators on settings object for remaining CS8602 warnings

Co-authored-by: philnach <[email protected]>

Author: Copilot

Extensions/AzureTableAPI/Cosmos.DataTransfer.AzureTableAPIExtension/AzureTableAPIDataSourceExtension.cs

@@ -23,7 +23,7 @@ public async IAsyncEnumerable<IDataItem> ReadAsync(IConfiguration config, ILogge
 
             TableServiceClient serviceClient;
 
-            if (settings.UseRbacAuth)
+            if (settings!.UseRbacAuth)
             {
                 logger.LogInformation("Connecting to Storage account {AccountEndpoint} using {UseRbacAuth} with {EnableInteractiveCredentials}'", settings.AccountEndpoint, nameof(AzureTableAPIDataSourceSettings.UseRbacAuth), nameof(AzureTableAPIDataSourceSettings.EnableInteractiveCredentials));
 

Extensions/CognitiveSearch/Cosmos.DataTransfer.CognitiveSearchExtension/CognitiveSearchDataSinkExtension.cs

@@ -22,7 +22,7 @@ public async Task WriteAsync(IAsyncEnumerable<IDataItem> dataItems, IConfigurati
             var settings = config.Get<CognitiveSearchDataSinkSettings>();
             settings.Validate();
 
-            var indexClient = new SearchIndexClient(new Uri(settings.Endpoint!), new AzureKeyCredential(settings.ApiKey!));
+            var indexClient = new SearchIndexClient(new Uri(settings!.Endpoint!), new AzureKeyCredential(settings.ApiKey!));
             var searchClient = indexClient.GetSearchClient(settings.Index!);
 
             var convertedObjects = dataItems.Select(di => BuildObject(di)).Where(o => o != null).OfType<ExpandoObject>();

Extensions/CognitiveSearch/Cosmos.DataTransfer.CognitiveSearchExtension/CognitiveSearchDataSourceExtension.cs

@@ -20,7 +20,7 @@ public async IAsyncEnumerable<IDataItem> ReadAsync(IConfiguration config, ILogge
             var settings = config.Get<CognitiveSearchDataSourceSettings>();
             settings.Validate();
 
-            var indexClient = new SearchIndexClient(new Uri(settings.Endpoint!), new AzureKeyCredential(settings.ApiKey!));
+            var indexClient = new SearchIndexClient(new Uri(settings!.Endpoint!), new AzureKeyCredential(settings.ApiKey!));
             var searchClient = indexClient.GetSearchClient(settings.Index!);
 
             var response = await searchClient.SearchAsync<JsonElement>("*"

Extensions/Mongo/Cosmos.DataTransfer.MongoExtension/MongoDataSinkExtension.cs

@@ -16,7 +16,7 @@ public async Task WriteAsync(IAsyncEnumerable<IDataItem> dataItems, IConfigurati
         var settings = config.Get<MongoSinkSettings>();
         settings.Validate();
 
-        if (!string.IsNullOrEmpty(settings.ConnectionString) && !string.IsNullOrEmpty(settings.DatabaseName) && !string.IsNullOrEmpty(settings.Collection))
+        if (!string.IsNullOrEmpty(settings!.ConnectionString) && !string.IsNullOrEmpty(settings.DatabaseName) && !string.IsNullOrEmpty(settings.Collection))
         {
             var context = new Context(settings.ConnectionString!, settings.DatabaseName!);
             var repo = context.GetRepository<BsonDocument>(settings.Collection!);

Extensions/Mongo/Cosmos.DataTransfer.MongoExtension/MongoDataSourceExtension.cs

@@ -18,7 +18,7 @@ public async IAsyncEnumerable<IDataItem> ReadAsync(IConfiguration config, ILogge
         var settings = config.Get<MongoSourceSettings>();
         settings.Validate();
 
-        if (!string.IsNullOrEmpty(settings.ConnectionString) && !string.IsNullOrEmpty(settings.DatabaseName))
+        if (!string.IsNullOrEmpty(settings!.ConnectionString) && !string.IsNullOrEmpty(settings.DatabaseName))
         {
             var context = new Context(settings.ConnectionString!, settings.DatabaseName!, settings.KeyVaultNamespace, settings.KMSProviders);
 

Extensions/Mongo/Cosmos.DataTransfer.MongoVectorExtension/MongoVectorDataSinkExtension.cs

@@ -19,7 +19,7 @@ public async Task WriteAsync(IAsyncEnumerable<IDataItem> dataItems, IConfigurati
         var settings = config.Get<MongoVectorSinkSettings>();        
         settings.Validate();
 
-        if (!string.IsNullOrEmpty(settings.ConnectionString) && !string.IsNullOrEmpty(settings.DatabaseName) && !string.IsNullOrEmpty(settings.Collection))
+        if (!string.IsNullOrEmpty(settings!.ConnectionString) && !string.IsNullOrEmpty(settings.DatabaseName) && !string.IsNullOrEmpty(settings.Collection))
         {
             var Isembeddingsetsvalid = false;
             var client = new OpenAIClient("");

Interfaces/Cosmos.DataTransfer.Common/FileDataSink.cs

@@ -12,7 +12,7 @@ public async Task WriteToTargetAsync(Func<Stream, Task> writeToStream, IConfigur
         var settings = config.Get<FileSinkSettings>();
         settings.Validate();
 
-        using var writer = GetCompressor(settings.Compression, settings.FilePath!, settings.Append);
+        using var writer = GetCompressor(settings!.Compression, settings.FilePath!, settings.Append);
         await writeToStream(writer);
         writer.Close();
     }

Interfaces/Cosmos.DataTransfer.Common/FileDataSource.cs

@@ -33,7 +33,7 @@ public class FileDataSource : IComposableDataSource
         var settings = config.Get<FileSourceSettings>();
         settings.Validate();
 
-        if (File.Exists(settings.FilePath!))
+        if (File.Exists(settings!.FilePath!))
         {
             yield return ReadFile(settings.FilePath, settings.Compression, logger);
         }