DotNetWorker.sln

@@ -70,7 +70,7 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Worker.Extensions.Kafka", "
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Sdk.Analyzers", "sdk\Sdk.Analyzers\Sdk.Analyzers.csproj", "{055D602D-D2B3-416B-AC59-1972D832032A}"
 EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Sdk.Analyzers.Tests", "test\Sdk.Analyzers.Tests\Sdk.Analyzers.Tests\Sdk.Analyzers.Tests.csproj", "{A75EA1E1-2801-460C-87C0-DE6A82D30851}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Sdk.Analyzers.Tests", "test\Sdk.Analyzers.Tests\Sdk.Analyzers.Tests.csproj", "{A75EA1E1-2801-460C-87C0-DE6A82D30851}"
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{083592CA-7DAB-44CE-8979-44FAFA46AEC3}"
 EndProject
@@ -132,6 +132,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Worker.Extensions.SignalRSe
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Worker.Extensions.Tests", "test\Worker.Extensions.Tests\Worker.Extensions.Tests.csproj", "{17BDCE12-6964-4B87-B2AC-68CE270A3E9A}"
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "AspNetIntegration", "samples\AspNetIntegration\AspNetIntegration.csproj", "{D2F67410-9933-42E8-B04A-E17634D83A30}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -326,6 +328,10 @@ Global
 		{17BDCE12-6964-4B87-B2AC-68CE270A3E9A}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{17BDCE12-6964-4B87-B2AC-68CE270A3E9A}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{17BDCE12-6964-4B87-B2AC-68CE270A3E9A}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D2F67410-9933-42E8-B04A-E17634D83A30}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D2F67410-9933-42E8-B04A-E17634D83A30}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D2F67410-9933-42E8-B04A-E17634D83A30}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D2F67410-9933-42E8-B04A-E17634D83A30}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -383,6 +389,7 @@ Global
 		{1F6B7CF6-0CC8-4C7F-825F-74B0BEC1CF0A} = {A7B4FF1E-3DF7-4F28-9333-D0961CDDF702}
 		{286F9EE3-00AE-4EFA-BFD8-A2E58BC809D2} = {FD7243E4-BF18-43F8-8744-BA1D17ACF378}
 		{17BDCE12-6964-4B87-B2AC-68CE270A3E9A} = {FD7243E4-BF18-43F8-8744-BA1D17ACF378}
+		{D2F67410-9933-42E8-B04A-E17634D83A30} = {9D6603BD-7EA2-4D11-A69C-0D9E01317FD6}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {497D2ED4-A13E-4BCA-8D29-F30CA7D0EA4A}

NuGet.Config

@@ -2,7 +2,7 @@
 <configuration>
   <packageSources>
     <add key="nuget.org" value="https://api.nuget.org/v3/index.json" protocolVersion="3" />
-    <add key="azure_app_service" value="https://www.myget.org/F/azure-appservice/api/v2" />
+    <add key="AzureFunctionsTempStaging" value="https://azfunc.pkgs.visualstudio.com/e6a70c92-4128-439f-8012-382fe78d6396/_packaging/AzureFunctionsTempStaging/nuget/v3/index.json" />
     <add key="dotnet-tools" value="https://pkgs.dev.azure.com/dnceng/public/_packaging/dotnet-tools/nuget/v3/index.json"/>
   </packageSources>
 </configuration>

build/install-dotnet.yml

@@ -1,14 +1,14 @@
 steps:
-- pwsh: |
-    Invoke-WebRequest 'https://raw.githubusercontent.com/dotnet/cli/master/scripts/obtain/dotnet-install.ps1' -OutFile 'dotnet-install.ps1'
-    ./dotnet-install.ps1 -InstallDir "$env:ProgramFiles/dotnet" -Version "6.0.100" -Channel 'release'
-    dotnet --info
-  displayName: 'Install the .Net version used by the Core Tools for Windows'
-  condition: and(eq( variables['Agent.OS'], 'Windows_NT' ), eq(variables['FUNCTIONSRUNTIMEVERSION'], '4'))
+# Some tests rely on 6.0.412 existing
+- task: UseDotNet@2
+  displayName: 'Install .NET6 SDK'
+  inputs:
+    packageType: 'sdk'
+    version: "6.0.412"
 
-- bash: |
-    curl -sSL https://raw.githubusercontent.com/dotnet/cli/master/scripts/obtain/dotnet-install.sh | bash /dev/stdin -v '6.0.100' -c 'release' --install-dir /usr/share/dotnet
-    dotnet --info
-  displayName: 'Install the .Net version used by the Core Tools for Linux'
-  condition: and(eq( variables['Agent.OS'], 'Linux' ), eq(variables['FUNCTIONSRUNTIMEVERSION'], '4'))
-
+# The SDK we use to build
+- task: UseDotNet@2
+  displayName: 'Install current .NET SDK'
+  inputs:
+    packageType: 'sdk'
+    useGlobalJson: true

docs/analyzer-rules/AZFW0009.md

@@ -0,0 +1,26 @@
+# AZFW0009: Invalid use of SupportsDeferredBinding attribute
+
+| | Value |
+|-|-|
+| **Rule ID** |AZFW0009|
+| **Category** |[Usage]|
+| **Severity** |Error|
+
+## Cause
+
+This rule is triggered when the `SupportsDeferredBinding` attribute is used on any class other
+than an input (`InputBindingAttribute`) or trigger (`TriggerBindingAttribute`) binding based class.
+
+## Rule description
+
+The `SupportsDeferredBinding` attribute is used to determine if a binding supports deferred binding.
+Currently, this feature is only supported for input and trigger bindings. Output bindings are not supported
+and this attribute should not be used on any other class type.
+
+## How to fix violations
+
+Remove the use of the `SupportsDeferredBinding` attribute from your class.
+
+## When to suppress warnings
+
+This rule should not be suppressed because this error may prevent your Azure Functions from running.

docs/analyzer-rules/AZFW0010.md

@@ -0,0 +1,42 @@
+# AZFW0010: Invalid binding type
+
+| | Value |
+|-|-|
+| **Rule ID** |AZFW00010|
+| **Category** |[Usage]|
+| **Severity** |Warning|
+
+## Cause
+
+This rule is triggered when a function is binding to a type that is not supported
+by the binding attribute being used.
+
+## Rule description
+
+Some bindings advertise the types that they support. If a binding advertises supported types
+and does not support falling back to built-in converters, then this rule will will be flagged.
+
+For example if you're binding to a `QueueTrigger` and the only supported type is `string` and
+your function is binding to a `bool`, then you will see this warning.
+
+## How to fix violations
+
+Change the binding type to a type that is supported by the binding your function is using.
+
+### Supported Types
+
+You can refer to the [public documentation](https://learn.microsoft.com/azure/azure-functions/functions-bindings-storage-blob?tabs=in-process%2Cextensionv5%2Cextensionv3&pivots=programming-language-csharp) to see which types are supported.
+
+| Binding | Supported Types |
+| ------- | --------------- |
+| BlobTrigger | POCO, String, Stream, Byte[], BlobClient*, BlobContainerClient |
+| BlobInput | POCO, IEnumerable*<POCO>, String,  IEnumberable<String>, Stream, IEnumberable<Stream>, Byte[], BlobClient, IEnumerable<BlobClient>, BlobContainerClient |
+| CosmosDBTrigger | POCO, IEnumerable<POCO> |
+| CosmosDBInput | POCO, IEnumerable<POCO>, CosmosClient, Database, Container |
+| EventGridTrigger | String, IEnumerable<String>, CloudEvent, IEnumerable<CloudEvent>, EventGridEvent, IEnumerable<EventGridEvent> |
+| EventHubTrigger | POCO, POCO[], String, String[] |
+| QueueTrigger | POCO, String, BinaryData, QueueMessage |
+| ServiceBusTrigger | String, String[], ServiceBusReceivedMessage, ServiceBusReceivedMessage[] |
+| TableInput | POCO, IEnumerable<POCO>, TableEntity, IEnumerable<TableEntity>, TableClient |
+
+> \* Where `BlobClient` is supported AppendBlobClient, BaseBlobClient, BlockBlobClient and PageBlobClient are also supported

docs/analyzer-rules/AZFW0011.md

@@ -0,0 +1,25 @@
+# AZFW0011: Invalid binding type
+
+| | Value |
+|-|-|
+| **Rule ID** |AZFW00011|
+| **Category** |[Usage]|
+| **Severity** |Error|
+
+## Cause
+
+This rule is triggered when a function is binding to a non-iterable type for a blob container path.
+
+## Rule description
+
+When using the `BlobInputAttribute` with a container path, the target parameter must be of iterable type such as `IEnumerable<T>` except when binding to `BlobContainerClient`.
+
+Example, if your function uses `BlobInput("<container path>")` and it is binding to a `string`, this rule will be violated.
+
+## How to fix violations
+
+Change the binding type to an iterable type such as `IEnumerable<T>` or provide blob path `container/blob` instead of a container path when using a non-iterable binding type is desired.
+
+### Supported Types
+
+You can refer to the [public documentation](https://learn.microsoft.com/azure/azure-functions/functions-bindings-storage-blob?tabs=in-process%2Cextensionv5%2Cextensionv3&pivots=programming-language-csharp) to see which types are supported for blob container.

extensions/Worker.Extensions.Abstractions/release_notes.md

@@ -4,6 +4,6 @@
 - My change description (#PR/#issue)
 -->
 
-### Microsoft.Azure.Functions.Worker.Extensions.Abstractions 1.3.0
+### Microsoft.Azure.Functions.Worker.Extensions.Abstractions <version>
 
-- Add SupportsDeferredBinding attribute
+- <entry>

extensions/Worker.Extensions.CosmosDB/release_notes.md

@@ -4,6 +4,6 @@
 - My change description (#PR/#issue)
 -->
 
-### Microsoft.Azure.Functions.Worker.Extensions.CosmosDB <version>
+### Microsoft.Azure.Functions.Worker.Extensions.CosmosDB 4.4.1
 
-- Add BindingCapabilities attribute to CosmosDb trigger to express function-level retry capabilities. (#1457)
+- [Bug] Update CosmosOptions from using IOptionsSnapshot to IOptionsMonitor to avoid DI scoping issues

extensions/Worker.Extensions.CosmosDB/src/Config/CosmosDBBindingOptions.cs

@@ -0,0 +1,62 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using System;
+using System.Collections.Concurrent;
+using Azure.Core;
+using Microsoft.Azure.Cosmos;
+using Microsoft.Azure.Functions.Worker.Extensions.CosmosDB;
+
+namespace Microsoft.Azure.Functions.Worker
+{
+    internal class CosmosDBBindingOptions
+    {
+        public string? ConnectionName  { get; set; }
+
+        public string? ConnectionString { get; set; }
+
+        public string? AccountEndpoint { get; set; }
+
+        public TokenCredential? Credential { get; set; }
+
+        public CosmosSerializer? Serializer { get; set; }
+
+        internal string BuildCacheKey(string connection, string region) => $"{connection}|{region}";
+
+        internal ConcurrentDictionary<string, CosmosClient> ClientCache { get; } = new ConcurrentDictionary<string, CosmosClient>();
+
+        internal virtual CosmosClient GetClient(string preferredLocations = "")
+        {
+            if (string.IsNullOrEmpty(ConnectionName))
+            {
+                throw new ArgumentNullException(nameof(ConnectionName));
+            }
+
+            string cacheKey = BuildCacheKey(ConnectionName!, preferredLocations);
+
+            CosmosClientOptions cosmosClientOptions = new ()
+            {
+                ConnectionMode = ConnectionMode.Gateway
+            };
+
+            if (!string.IsNullOrEmpty(preferredLocations))
+            {
+                cosmosClientOptions.ApplicationPreferredRegions = Utilities.ParsePreferredLocations(preferredLocations);
+            }
+
+            if (Serializer is not null)
+            {
+                cosmosClientOptions.Serializer = Serializer;
+            }
+
+            return ClientCache.GetOrAdd(cacheKey, (c) => CreateService(cosmosClientOptions));
+        }
+
+        private CosmosClient CreateService(CosmosClientOptions cosmosClientOptions)
+        {
+            return string.IsNullOrEmpty(ConnectionString)
+                    ? new CosmosClient(AccountEndpoint, Credential, cosmosClientOptions) // AAD auth
+                    : new CosmosClient(ConnectionString, cosmosClientOptions); // Connection string based auth
+        }
+    }
+}

extensions/Worker.Extensions.CosmosDB/src/Config/CosmosDBBindingOptionsSetup.cs

@@ -0,0 +1,58 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using System;
+using Microsoft.Azure.Functions.Worker.Extensions;
+using Microsoft.Azure.Functions.Worker.Extensions.CosmosDB;
+using Microsoft.Extensions.Azure;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Options;
+
+namespace Microsoft.Azure.Functions.Worker
+{
+    internal class CosmosDBBindingOptionsSetup : IConfigureNamedOptions<CosmosDBBindingOptions>
+    {
+        private readonly IConfiguration _configuration;
+        private readonly AzureComponentFactory _componentFactory;
+
+        public CosmosDBBindingOptionsSetup(IConfiguration configuration, AzureComponentFactory componentFactory)
+        {
+            _configuration = configuration ?? throw new ArgumentNullException(nameof(configuration));
+            _componentFactory = componentFactory ?? throw new ArgumentNullException(nameof(componentFactory));
+        }
+
+        public void Configure(CosmosDBBindingOptions options)
+        {
+            Configure(Options.DefaultName, options);
+        }
+
+        public void Configure(string connectionName, CosmosDBBindingOptions options)
+        {
+            IConfigurationSection connectionSection = _configuration.GetWebJobsConnectionStringSection(connectionName);
+
+            if (!connectionSection.Exists())
+            {
+                throw new InvalidOperationException($"Cosmos DB connection configuration '{connectionName}' does not exist. " +
+                                                    "Make sure that it is a defined App Setting.");
+            }
+
+            options.ConnectionName = connectionName;
+
+            if (!string.IsNullOrWhiteSpace(connectionSection.Value))
+            {
+                options.ConnectionString = connectionSection.Value;
+            }
+            else
+            {
+                options.AccountEndpoint = connectionSection[Constants.AccountEndpoint];
+                if (string.IsNullOrWhiteSpace(options.AccountEndpoint))
+                {
+                    throw new InvalidOperationException($"Connection should have an '{Constants.AccountEndpoint}' property or be a " +
+                        $"string representing a connection string.");
+                }
+
+                options.Credential = _componentFactory.CreateTokenCredential(connectionSection);
+            }
+        }
+    }
+}

extensions/Worker.Extensions.CosmosDB/src/Constants.cs

@@ -0,0 +1,15 @@
+
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+namespace Microsoft.Azure.Functions.Worker.Extensions.CosmosDB
+{
+    internal static class Constants
+    {
+        internal const string CosmosExtensionName = "CosmosDB";
+        internal const string ConfigurationSectionName = "AzureWebJobs";
+        internal const string ConnectionStringsSectionName = "ConnectionStrings";
+        internal const string AccountEndpoint = "accountEndpoint";
+        internal const string JsonContentType = "application/json";
+    }
+}