Azure · fabiocav · Nov 12, 2024 · Nov 11, 2024 · Nov 12, 2024 · Nov 12, 2024
diff --git a/src/DotNetWorker.Core/Converters/JsonPocoConverter.cs b/src/DotNetWorker.Core/Converters/JsonPocoConverter.cs
@@ -73,9 +73,9 @@ private async Task<ConversionResult> GetConversionResultFromDeserialization(byte
             }
             finally
             {
-                if (stream != null) 
+                if (stream != null)
                 {
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
 
                     await ((IAsyncDisposable)stream).DisposeAsync();
 #else

diff --git a/src/DotNetWorker.Core/Converters/MemoryConverter.cs b/src/DotNetWorker.Core/Converters/MemoryConverter.cs
@@ -18,7 +18,7 @@ public ValueTask<ConversionResult> ConvertAsync(ConverterContext context)
 
             if (context.TargetType.IsAssignableFrom(typeof(string)))
             {
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
                 var target = Encoding.UTF8.GetString(sourceMemory.Span);
 #else
                 var target = Encoding.UTF8.GetString(sourceMemory.Span.ToArray());

diff --git a/src/DotNetWorker.Core/DotNetWorker.Core.csproj b/src/DotNetWorker.Core/DotNetWorker.Core.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Library</OutputType>
-    <TargetFrameworks>net8.0;net9.0;netstandard2.0</TargetFrameworks>
+    <TargetFrameworks>net6.0;net8.0;net9.0;netstandard2.0</TargetFrameworks>
     <PackageId>Microsoft.Azure.Functions.Worker.Core</PackageId>
     <Description>This library provides the core functionality to build an Azure Functions .NET Worker, adding support for the isolated, out-of-process execution model.</Description>
     <AssemblyName>Microsoft.Azure.Functions.Worker.Core</AssemblyName>
@@ -23,16 +23,18 @@
 
   <ItemGroup>
     <PackageReference Include="Azure.Core" Version="1.42.0" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.1" />
-    <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.1" />
-    <PackageReference Include="System.Collections.Immutable" Version="8.0.0" />
-    <PackageReference Include="System.Diagnostics.DiagnosticSource" Version="8.0.1" />
   </ItemGroup>
-  
+
   <ItemGroup Condition="'$(TargetFramework)' == 'netstandard2.0'">
-    <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="8.0.2" />
-    <PackageReference Include="System.Threading.Tasks.Extensions" Version="4.5.4" />
-    <PackageReference Include="Microsoft.Extensions.Options" Version="8.0.2" />
-    <PackageReference Include="System.Text.Encodings.Web" Version="8.0.0" />
+    <PackageReference Include="System.Collections.Immutable" Version="8.0.0" />
+  </ItemGroup>
+
+  <ItemGroup Condition="'$(TargetFramework)' != 'net9.0'">
+    <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.1" />
   </ItemGroup>
+
+  <ItemGroup Condition="'$(TargetFramework)' == 'net9.0'">
+    <PackageReference Include="Microsoft.Extensions.Hosting" Version="9.0.0" />
+  </ItemGroup>
+
 </Project>
diff --git a/src/DotNetWorker.Core/Helpers/ThrowHelpers/ObjectDisposedThrowHelper.cs b/src/DotNetWorker.Core/Helpers/ThrowHelpers/ObjectDisposedThrowHelper.cs
@@ -13,7 +13,7 @@ internal static class ObjectDisposedThrowHelper
         /// <exception cref="ObjectDisposedException">The <paramref name="condition"/> is <see langword="true"/>.</exception>
         internal static void ThrowIf(bool condition, object instance)
         {
-#if NET8_0_OR_GREATER
+#if NET7_0_OR_GREATER
             ObjectDisposedException.ThrowIf(condition, instance);
 #else
             if (condition)

diff --git a/src/DotNetWorker.Core/Invocation/DefaultMethodInfoLocator.cs b/src/DotNetWorker.Core/Invocation/DefaultMethodInfoLocator.cs
@@ -1,6 +1,6 @@
 using System;
 using System.Reflection;
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
 using System.Runtime.Loader;
 #endif
 using System.Text.RegularExpressions;
@@ -21,7 +21,7 @@ public MethodInfo GetMethod(string pathToAssembly, string entryPoint)
 
             string typeName = entryPointMatch.Groups["typename"].Value;
             string methodName = entryPointMatch.Groups["methodname"].Value;
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
             Assembly assembly = AssemblyLoadContext.Default.LoadFromAssemblyPath(pathToAssembly);
 #else
             Assembly assembly = Assembly.LoadFrom(pathToAssembly);

diff --git a/src/DotNetWorker.Core/StartupHook.cs b/src/DotNetWorker.Core/StartupHook.cs
@@ -32,7 +32,7 @@ public static void Initialize()
         RemoveSelfFromStartupHooks();
         string? debuggerWaitEnabled = Environment.GetEnvironmentVariable("FUNCTIONS_ENABLE_DEBUGGER_WAIT");
         string? jsonOutputEnabled = Environment.GetEnvironmentVariable("FUNCTIONS_ENABLE_JSON_OUTPUT");
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
         int processId = Environment.ProcessId;
 #else
         int processId = Process.GetCurrentProcess().Id;
@@ -57,12 +57,12 @@ static bool WaitOnDebugger(int cycle)
 
         if (string.Equals(jsonOutputEnabled, bool.TrueString, StringComparison.OrdinalIgnoreCase))
         {
-            Console.WriteLine($"azfuncjsonlog:{{ \"name\":\"dotnet-worker-startup\", \"workerProcessId\" : { processId } }}");
+            Console.WriteLine($"azfuncjsonlog:{{ \"name\":\"dotnet-worker-startup\", \"workerProcessId\" : {processId} }}");
         }
 
         if (string.Equals(debuggerWaitEnabled, bool.TrueString, StringComparison.OrdinalIgnoreCase))
         {
-            Console.WriteLine($"Azure Functions .NET Worker (PID: { processId }) initialized in debug mode. Waiting for debugger to attach...");
+            Console.WriteLine($"Azure Functions .NET Worker (PID: {processId}) initialized in debug mode. Waiting for debugger to attach...");
 
             for (int i = 0; WaitOnDebugger(i); i++)
             {

diff --git a/src/DotNetWorker.Core/WorkerInformation.cs b/src/DotNetWorker.Core/WorkerInformation.cs
@@ -20,7 +20,7 @@ internal sealed class WorkerInformation
 
         public static WorkerInformation Instance = new();
 
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
         public int ProcessId => Environment.ProcessId;
 
         public string RuntimeIdentifier => RuntimeInformation.RuntimeIdentifier;

diff --git a/src/DotNetWorker.Grpc/DotNetWorker.Grpc.csproj b/src/DotNetWorker.Grpc/DotNetWorker.Grpc.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Library</OutputType>
-    <TargetFrameworks>net8.0;net9.0;netstandard2.0</TargetFrameworks>
+    <TargetFrameworks>net6.0;net7.0;net8.0;net9.0;netstandard2.0</TargetFrameworks>
     <PackageId>Microsoft.Azure.Functions.Worker.Grpc</PackageId>
     <Description>This library provides gRPC support for Azure Functions .NET Worker communication with the Azure Functions Host.</Description>
     <AssemblyName>Microsoft.Azure.Functions.Worker.Grpc</AssemblyName>
@@ -22,19 +22,12 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Azure.Core" Version="1.42.0" />
     <PackageReference Include="Google.Protobuf" Version="3.28.0" />
-    <PackageReference Include="Grpc.Tools" Version="2.66.0">
-      <PrivateAssets>all</PrivateAssets>
-      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
-    </PackageReference>
+    <PackageReference Include="Grpc.Tools" Version="2.66.0" PrivateAssets="all" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Abstractions" Version="1.3.0" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.1" />
-    <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.1" />
   </ItemGroup>
 
   <ItemGroup Condition="'$(TargetFramework)' != 'netstandard2.0'">
-    <PackageReference Include="Grpc.Net.Client" Version="2.65.0" />
     <PackageReference Include="Grpc.Net.ClientFactory" Version="2.65.0" />
   </ItemGroup>
 

diff --git a/src/DotNetWorker.Grpc/GrpcServiceCollectionExtensions.cs b/src/DotNetWorker.Grpc/GrpcServiceCollectionExtensions.cs
@@ -5,13 +5,13 @@
 using System.Threading.Channels;
 using Microsoft.Azure.Functions.Worker;
 using Microsoft.Azure.Functions.Worker.Core.FunctionMetadata;
+using Microsoft.Azure.Functions.Worker.Diagnostics;
+using Microsoft.Azure.Functions.Worker.Grpc;
 using Microsoft.Azure.Functions.Worker.Grpc.Messages;
+using Microsoft.Azure.Functions.Worker.Handlers;
 using Microsoft.Azure.Functions.Worker.Logging;
-using Microsoft.Azure.Functions.Worker.Grpc;
-using Microsoft.Azure.Functions.Worker.Diagnostics;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection.Extensions;
-using Microsoft.Azure.Functions.Worker.Handlers;
 using Microsoft.Extensions.Options;
 
 namespace Microsoft.Extensions.DependencyInjection
@@ -54,7 +54,7 @@ public static IServiceCollection AddGrpc(this IServiceCollection services)
             services.TryAddSingleton<IWorker, GrpcWorker>();
             services.TryAddSingleton<IInvocationHandler, InvocationHandler>();
 
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
             // If we are running in the native host process, use the native client
             // for communication (interop). Otherwise; use the gRPC client.
             if (AppContext.GetData("AZURE_FUNCTIONS_NATIVE_HOST") is not null)

diff --git a/src/DotNetWorker.Grpc/GrpcWorkerClientFactory.cs b/src/DotNetWorker.Grpc/GrpcWorkerClientFactory.cs
@@ -10,7 +10,7 @@
 using Microsoft.Extensions.Options;
 using static Microsoft.Azure.Functions.Worker.Grpc.Messages.FunctionRpc;
 
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
 using Grpc.Net.Client;
 #else
 using GrpcCore = Grpc.Core;
@@ -104,7 +104,7 @@ private async Task StartReaderAsync(IAsyncStreamReader<StreamingMessage> respons
 
             private FunctionRpcClient CreateClient()
             {
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
                 GrpcChannel grpcChannel = GrpcChannel.ForAddress(_startupOptions.HostEndpoint!.AbsoluteUri, new GrpcChannelOptions()
                 {
                     MaxReceiveMessageSize = _startupOptions.GrpcMaxMessageLength,

diff --git a/src/DotNetWorker.Grpc/Http/GrpcHttpRequestData.cs b/src/DotNetWorker.Grpc/Http/GrpcHttpRequestData.cs
@@ -7,13 +7,13 @@
 using System.Linq;
 using System.Security.Claims;
 using System.Threading.Tasks;
-using Microsoft.Azure.Functions.Worker.Http;
 using Microsoft.Azure.Functions.Worker.Grpc.Messages;
+using Microsoft.Azure.Functions.Worker.Http;
 
 namespace Microsoft.Azure.Functions.Worker
 {
     internal class GrpcHttpRequestData : HttpRequestData, IDisposable
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
         , IAsyncDisposable
 #endif
     {
@@ -73,7 +73,7 @@ public override Stream Body
                         }
 
                         var stream = new MemoryStream(memory.Length);
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
                         stream.Write(memory.Span);
 #else
                         stream.Write(memory.Span.ToArray(), 0, memory.Span.Length);
@@ -127,7 +127,7 @@ public override HttpResponseData CreateResponse()
             return new GrpcHttpResponseData(FunctionContext, System.Net.HttpStatusCode.OK);
         }
 
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
         public ValueTask DisposeAsync()
         {
             return _bodyStream?.DisposeAsync() ?? ValueTask.CompletedTask;
@@ -159,7 +159,7 @@ private IReadOnlyCollection<IHttpCookie> ToHttpCookies(string cookieString)
 
             List<IHttpCookie> httpCookiesList = new List<IHttpCookie>(separateCookies.Length);
 
-#if NET8_0_OR_GREATER
+#if NET6_0_OR_GREATER
             var separator = '=';
 #else
             var separator = new[] { '=' };

diff --git a/src/DotNetWorker.Grpc/NativeHostIntegration/NativeMethods.cs b/src/DotNetWorker.Grpc/NativeHostIntegration/NativeMethods.cs
@@ -49,7 +49,16 @@ private static IntPtr ImportResolver(string libraryName, System.Reflection.Assem
         {
             if (libraryName == NativeWorkerDll)
             {
+#if NET6_0
+                if (OperatingSystem.IsLinux())
+                {
+                    return NativeLibraryLinux.GetMainProgramHandle();
+                }
+#elif NET7_0_OR_GREATER
                 return NativeLibrary.GetMainProgramHandle();
+#else
+                throw new PlatformNotSupportedException("Interop communication with FunctionsNetHost is not supported in the current platform. Consider upgrading your project to .NET 7.0 or later.");
+#endif
             }
 
             // Return 0 so that built-in resolving code will be executed.

diff --git a/src/DotNetWorker/DotNetWorker.csproj b/src/DotNetWorker/DotNetWorker.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Library</OutputType>
-    <TargetFrameworks>net8.0;net9.0;netstandard2.0</TargetFrameworks>
+    <TargetFrameworks>net6.0;net7.0;net8.0;net9.0;netstandard2.0</TargetFrameworks>
     <PackageId>Microsoft.Azure.Functions.Worker</PackageId>
     <Description>This library enables you to create an Azure Functions .NET Worker, adding support for the isolated, out-of-process execution model.</Description>
     <AssemblyName>Microsoft.Azure.Functions.Worker</AssemblyName>
@@ -16,14 +16,9 @@
 
   <Import Project="..\..\build\Common.props" />
 
-  <ItemGroup>
-    <PackageReference Include="Azure.Core" Version="1.42.0" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.1" />
-    <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.1" />
-  </ItemGroup>
-
   <ItemGroup>
     <ProjectReference Include="..\DotNetWorker.Core\DotNetWorker.Core.csproj" />
     <ProjectReference Include="..\DotNetWorker.Grpc\DotNetWorker.Grpc.csproj" />
   </ItemGroup>
+
 </Project>