Refactor Tables converter & update tests (#1716, #1723, #1727)

Author: liliankasem

extensions/Worker.Extensions.Kafka/release_notes.md

@@ -4,6 +4,8 @@
 - My change description (#PR/#issue)
 -->
 
-### Microsoft.Azure.Functions.Worker.Extensions.Kafka <version>
+### Microsoft.Azure.Functions.Worker.Extensions.Kafka 3.9.0
 
-- <entry>
+- Add `BindingCapabilities` attribute to KafkaTrigger to express function-level retry capabilities. (#1457)
+- Updated Kafka Extension nuget package to most recent version (3.9.0) (#1713)
+- Exposed an important scaling parameter `LagThreshold`` to let a user configure their scaling preferences within Kafka Trigger function. (#1713)

extensions/Worker.Extensions.Shared/Configuration/ConfigurationExtensions.cs

@@ -1,4 +1,4 @@
-// Copyright (c) .NET Foundation. All rights reserved.
+// Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the MIT License. See License.txt in the project root for license information.
 
 using System;

extensions/Worker.Extensions.Storage.Blobs/src/Config/BlobStorageBindingOptionsSetup.cs

@@ -1,4 +1,4 @@
-// Copyright (c) .NET Foundation. All rights reserved.
+// Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the MIT License. See License.txt in the project root for license information.
 
 using System;
@@ -61,4 +61,4 @@ public void Configure(string name, BlobStorageBindingOptions options)
             options.Credential = _componentFactory.CreateTokenCredential(connectionSection);
         }
     }
-}
+}

extensions/Worker.Extensions.Tables/src/Config/TablesBindingOptions.cs

@@ -17,25 +17,25 @@ internal class TablesBindingOptions
 
         public TableClientOptions? TableClientOptions { get; set; }
 
-        private TableServiceClient? TableServiceClient;
+        internal TableServiceClient? Client;
 
         internal virtual TableServiceClient CreateClient()
         {
-            if (ConnectionString is null && ServiceUri is null)
+            if (Client is not null)
             {
-                throw new ArgumentNullException(nameof(ConnectionString) + " " + nameof(ServiceUri));
+                return Client;
             }
 
-            if (TableServiceClient is not null)
+            if (ServiceUri is not null && Credential is not null)
             {
-                return TableServiceClient;
+                Client = new TableServiceClient(ServiceUri, Credential, TableClientOptions);
+            }
+            else
+            {
+                Client = new TableServiceClient(ConnectionString, TableClientOptions);
             }
 
-            TableServiceClient = !string.IsNullOrEmpty(ConnectionString)
-                ? new TableServiceClient(ConnectionString, TableClientOptions) // Connection string based auth;
-                : new TableServiceClient(ServiceUri, Credential, TableClientOptions); // AAD auth
-
-            return TableServiceClient;
+            return Client;
         }
     }
 }

extensions/Worker.Extensions.Tables/src/Config/TablesBindingOptionsSetup.cs

@@ -36,8 +36,7 @@ public void Configure(string name, TablesBindingOptions options)
             if (!connectionSection.Exists())
             {
                 // Not found
-                throw new InvalidOperationException($"Tables connection configuration '{name}' does not exist. " +
-                                                    "Make sure that it is a defined App Setting.");
+                throw new InvalidOperationException($"Tables connection configuration '{name}' does not exist. Make sure that it is a defined App Setting.");
             }
 
             if (!string.IsNullOrWhiteSpace(connectionSection.Value))

extensions/Worker.Extensions.Tables/src/Nuget.config

@@ -4,6 +4,6 @@
 using System.Runtime.CompilerServices;
 using Microsoft.Azure.Functions.Worker.Extensions.Abstractions;
 
-[assembly: ExtensionInformation("Microsoft.Azure.WebJobs.Extensions.Tables", "1.2.0-beta.1")]
+[assembly: ExtensionInformation("Microsoft.Azure.WebJobs.Extensions.Tables", "1.2.0")]
 [assembly: InternalsVisibleTo("Microsoft.Azure.Functions.Worker.Extensions.Tests, PublicKey=00240000048000009400000006020000002400005253413100040000010001005148be37ac1d9f58bd40a2e472c9d380d635b6048278f7d47480b08c928858f0f7fe17a6e4ce98da0e7a7f0b8c308aecd9e9b02d7e9680a5b5b75ac7773cec096fbbc64aebd429e77cb5f89a569a79b28e9c76426783f624b6b70327eb37341eb498a2c3918af97c4860db6cdca4732787150841e395a29cfacb959c1fd971c1")]
 [assembly: InternalsVisibleTo("DynamicProxyGenAssembly2, PublicKey=0024000004800000940000000602000000240000525341310004000001000100c547cac37abd99c8db225ef2f6c8a3602f3b3606cc9891605d02baa56104f4cfc0734aa39b93bf7852f7d9266654753cc297e7d2edfe0bac1cdcf9f717241550e0a7b191195b7667bb4f64bcb8e2121380fd1d9d46ad2d92d2d15605093924cceaf74c4861eff62abf69b9291ed0a340e113be11e6a7d3113e92484cf7045cc7")]

extensions/Worker.Extensions.Tables/src/Properties/AssemblyInfo.cs

@@ -10,10 +10,10 @@ namespace Microsoft.Azure.Functions.Worker
     /// <summary>
     /// Attribute used to configure a parameter as the input target for the Azure Storage Tables binding.
     /// </summary>
-    [AllowConverterFallback(true)]
     [InputConverter(typeof(TableClientConverter))]
     [InputConverter(typeof(TableEntityConverter))]
     [InputConverter(typeof(TableEntityEnumerableConverter))]
+    [ConverterFallbackBehavior(ConverterFallbackBehavior.Default)]
     public class TableInputAttribute : InputBindingAttribute
     {
         /// <summary>Initializes a new instance of the <see cref="TableInputAttribute"/> class.</summary>

extensions/Worker.Extensions.Tables/src/TableInputAttribute.cs

@@ -2,7 +2,6 @@
 // Licensed under the MIT License. See License.txt in the project root for license information.
 
 using System;
-using System.Collections.Generic;
 using System.Threading.Tasks;
 using Azure.Data.Tables;
 using Microsoft.Azure.Functions.Worker.Converters;
@@ -15,10 +14,10 @@
 namespace Microsoft.Azure.Functions.Worker.Extensions.Tables.TypeConverters
 {
     /// <summary>
-    /// Converter to bind Table client parameter.
+    /// Converter to bind <see cref="TableClient" /> type parameters.
     /// </summary>
     [SupportsDeferredBinding]
-    [SupportedConverterType(typeof(TableClient))]
+    [SupportedTargetType(typeof(TableClient))]
     internal class TableClientConverter: TableConverterBase<TableClient>
     {
         public TableClientConverter(IOptionsSnapshot<TablesBindingOptions> tableOptions, ILogger<TableClientConverter> logger)
@@ -28,28 +27,23 @@ public TableClientConverter(IOptionsSnapshot<TablesBindingOptions> tableOptions,
 
         public override ValueTask<ConversionResult> ConvertAsync(ConverterContext context)
         {
-            if (!CanConvert(context))
-            {
-                return new(ConversionResult.Unhandled());
-            }
             try
             {
+                if (!CanConvert(context))
+                {
+                    return new(ConversionResult.Unhandled());
+                }
+
                 var modelBindingData = context?.Source as ModelBindingData;
                 var tableData = GetBindingDataContent(modelBindingData);
-
                 var result = ConvertModelBindingData(tableData);
 
-                if (result is not null)
-                {
-                    return new(ConversionResult.Success(result));
-                }
+                return new(ConversionResult.Success(result));
             }
             catch (Exception ex)
             {
                 return new(ConversionResult.Failed(ex));
             }
-
-            return new(ConversionResult.Unhandled());
         }
 
         private TableClient ConvertModelBindingData(TableData content)

extensions/Worker.Extensions.Tables/src/TypeConverters/TableClientConverter.cs

@@ -2,7 +2,6 @@
 // Licensed under the MIT License. See License.txt in the project root for license information.
 
 using System;
-using System.Collections.Generic;
 using System.Threading.Tasks;
 using Azure.Data.Tables;
 using Microsoft.Azure.Functions.Worker.Converters;
@@ -23,7 +22,7 @@ public TableConverterBase(IOptionsSnapshot<TablesBindingOptions> tableOptions, I
             _logger = logger ?? throw new ArgumentNullException(nameof(logger));
             _tableOptions = tableOptions ?? throw new ArgumentNullException(nameof(tableOptions));
         }
-        
+
         protected bool CanConvert(ConverterContext context)
         {
             if (context is null)
@@ -36,14 +35,14 @@ protected bool CanConvert(ConverterContext context)
                 return false;
             }
 
-            if (!(context.Source is ModelBindingData bindingData))
+            if (context.Source is not ModelBindingData bindingData)
             {
                 return false;
             }
 
             if (bindingData.Source is not Constants.TablesExtensionName)
             {
-                return false;
+                throw new InvalidBindingSourceException(bindingData.Source, Constants.TablesExtensionName);
             }
 
             return true;
@@ -56,7 +55,7 @@ protected TableData GetBindingDataContent(ModelBindingData? bindingData)
             return bindingData?.ContentType switch
             {
                 Constants.JsonContentType => bindingData.Content.ToObjectFromJson<TableData>(),
-                _ => throw new NotSupportedException($"Unexpected content-type. Currently only '{Constants.JsonContentType}' is supported.")
+                _ => throw new InvalidContentTypeException(bindingData?.ContentType, Constants.JsonContentType)
             };
         }