Parse and log WorkerMetadata information (#8481)

Author: liliankasem

src/WebJobs.Script.Grpc/Channel/GrpcWorkerChannel.cs

@@ -255,12 +255,22 @@ internal void WorkerInitResponse(GrpcEvent initEvent)
             _workerChannelLogger.LogDebug("Received WorkerInitResponse. Worker process initialized");
             _initMessage = initEvent.Message.WorkerInitResponse;
             _workerChannelLogger.LogDebug($"Worker capabilities: {_initMessage.Capabilities}");
+
+            if (_initMessage.WorkerMetadata != null)
+            {
+                _initMessage.UpdateWorkerMetadata(_workerConfig);
+                var workerMetadata = _initMessage.WorkerMetadata.ToString();
+                _metricsLogger.LogEvent(MetricEventNames.WorkerMetadata, functionName: null, workerMetadata);
+                _workerChannelLogger.LogDebug($"Worker metadata: {workerMetadata}");
+            }
+
             if (_initMessage.Result.IsFailure(out Exception exc))
             {
                 HandleWorkerInitError(exc);
                 _workerInitTask.SetResult(false);
                 return;
             }
+
             _state = _state | RpcWorkerChannelState.Initialized;
             _workerCapabilities.UpdateCapabilities(_initMessage.Capabilities);
             _isSharedMemoryDataTransferEnabled = IsSharedMemoryDataTransferEnabled();

src/WebJobs.Script.Grpc/MessageExtensions/GrpcMessageExtensionUtilities.cs

@@ -7,6 +7,7 @@
 using System.Linq;
 using Microsoft.AspNetCore.Http;
 using Microsoft.Azure.WebJobs.Script.Grpc.Messages;
+using Microsoft.Azure.WebJobs.Script.Workers.Rpc;
 
 namespace Microsoft.Azure.WebJobs.Script.Grpc
 {
@@ -77,6 +78,14 @@ public static Tuple<string, string, CookieOptions> RpcHttpCookieConverter(RpcHtt
             return new Tuple<string, string, CookieOptions>(cookie.Name, cookie.Value, cookieOptions);
         }
 
+        internal static void UpdateWorkerMetadata(this WorkerInitResponse initResponse, RpcWorkerConfig workerConfig)
+        {
+            initResponse.WorkerMetadata.RuntimeName = string.IsNullOrEmpty(initResponse.WorkerMetadata.RuntimeName)
+                                            ? workerConfig.Description.Language : initResponse.WorkerMetadata.RuntimeName;
+            initResponse.WorkerMetadata.RuntimeVersion = string.IsNullOrEmpty(initResponse.WorkerMetadata.RuntimeVersion)
+                                            ? workerConfig.Description.DefaultRuntimeVersion : initResponse.WorkerMetadata.RuntimeVersion;
+        }
+
         private static SameSiteMode RpcSameSiteEnumConverter(RpcHttpCookie.Types.SameSite sameSite)
         {
             switch (sameSite)

src/WebJobs.Script/Diagnostics/MetricEventNames.cs

@@ -37,6 +37,7 @@ public static class MetricEventNames
 
         // LanguageWorkerChannel events
         public const string FunctionLoadRequestResponse = "rpcworkerchannel.functionloadrequestresponse";
+        public const string WorkerMetadata = "rpcworkerchannel.workerinitresponse.workermetadata";
 
         // ScriptStartupTypeLocator events
         public const string ParseExtensions = "ScriptStartupTypeLocator.ParseExtensions";

src/WebJobs.Script/Workers/Rpc/RpcWorkerConstants.cs

@@ -38,7 +38,7 @@ public static class RpcWorkerConstants
         // Rpc message length
         public const int DefaultMaxMessageLengthBytes = int.MaxValue;
 
-        // Capabilites
+        // Capabilities
         public const string RawHttpBodyBytes = "RawHttpBodyBytes";
         public const string TypedDataCollection = "TypedDataCollection";
         public const string RpcHttpBodyOnly = "RpcHttpBodyOnly";
@@ -50,7 +50,7 @@ public static class RpcWorkerConstants
         public const string FunctionDataCache = "FunctionDataCache";
         public const string AcceptsListOfFunctionLoadRequests = "AcceptsListOfFunctionLoadRequests";
 
-        // Host Capabilites
+        // Host Capabilities
         public const string V2Compatable = "V2Compatable";
 
         // dotnet executable file path components

test/WebJobs.Script.Tests/Workers/Rpc/TestFunctionRpcService.cs

@@ -72,7 +72,7 @@ public void PublishFunctionEnvironmentReloadResponseEvent()
             _eventManager.Publish(new InboundGrpcEvent(_workerId, responseMessage));
         }
 
-        public void PublishWorkerInitResponseEvent(IDictionary<string, string> capabilities = null)
+        public void PublishWorkerInitResponseEvent(IDictionary<string, string> capabilities = null, WorkerMetadata workerMetadata = null)
         {
             StatusResult statusResult = new StatusResult()
             {
@@ -89,6 +89,11 @@ public void PublishWorkerInitResponseEvent(IDictionary<string, string> capabilit
                 initResponse.Capabilities.Add(capabilities);
             }
 
+            if (workerMetadata != null)
+            {
+                initResponse.WorkerMetadata = workerMetadata;
+            }
+
             StreamingMessage responseMessage = new StreamingMessage()
             {
                 WorkerInitResponse = initResponse