[V2]Add worker_directory to WorkerInitRequest (#6441) (#6467)

Author: pragnagopa

src/WebJobs.Script.Grpc/azure-functions-language-worker-protobuf/README.md

@@ -1,4 +1,4 @@
-# Azure Functions Languge Worker Protobuf
+# Azure Functions Language Worker Protobuf
 
 This repository contains the protobuf definition file which defines the gRPC service which is used between the [Azure Functions Host](https://github.com/Azure/azure-functions-host) and the Azure Functions language workers. This repo is shared across many repos in many languages (for each worker) by using git commands.
 
@@ -39,7 +39,7 @@ From within the Azure Functions language worker repo:
 ## Releasing a Language Worker Protobuf version
 
 1.	Draft a release in the GitHub UI
-    -   Be sure to inculde details of the release
+    -   Be sure to include details of the release
 2.	Create a release version, following semantic versioning guidelines ([semver.org](https://semver.org/))
 3.	Tag the version with the pattern: `v<M>.<m>.<p>-protofile` (example: `v1.1.0-protofile`)
 3.	Merge `dev` to `master`

src/WebJobs.Script.Grpc/azure-functions-language-worker-protobuf/src/proto/FunctionRpc.proto

@@ -96,6 +96,9 @@ message WorkerInitRequest {
   // inform worker of supported categories and their levels
   // i.e. Worker = Verbose, Function.MyFunc = None
   map<string, RpcLog.Level> log_categories = 3;
+
+  // Full path of worker.config.json location
+  string worker_directory = 4;
 }
 
 // Worker responds with the result of initializing itself

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

@@ -138,15 +138,23 @@ internal void SendWorkerInitRequest(RpcEvent startEvent)
                 .Take(1)
                 .Subscribe(WorkerInitResponse, HandleWorkerInitError);
 
+            WorkerInitRequest initRequest = GetWorkerInitRequest();
+
             SendStreamingMessage(new StreamingMessage
             {
-                WorkerInitRequest = new WorkerInitRequest()
-                {
-                    HostVersion = ScriptHost.Version
-                }
+                WorkerInitRequest = initRequest
             });
         }
 
+        internal WorkerInitRequest GetWorkerInitRequest()
+        {
+            return new WorkerInitRequest()
+            {
+                HostVersion = ScriptHost.Version,
+                WorkerDirectory = _workerConfig.Description.WorkerDirectory
+            };
+        }
+
         internal void FunctionEnvironmentReloadResponse(FunctionEnvironmentReloadResponse res, IDisposable latencyEvent)
         {
             _workerChannelLogger.LogDebug("Received FunctionEnvironmentReloadResponse");

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

@@ -163,6 +163,16 @@ public void SendWorkerInitRequest_PublishesOutboundEvent()
             Assert.True(traces.Any(m => string.Equals(m.FormattedMessage, _expectedLogMsg)));
         }
 
+        [Fact]
+        public void WorkerInitRequest_Expected()
+        {
+            WorkerInitRequest initRequest = _workerChannel.GetWorkerInitRequest();
+            Assert.NotNull(initRequest.WorkerDirectory);
+            Assert.NotNull(initRequest.HostVersion);
+            Assert.Equal("testDir", initRequest.WorkerDirectory);
+            Assert.Equal(ScriptHost.Version, initRequest.HostVersion);
+        }
+
         [Theory]
         [InlineData(RpcLog.Types.Level.Information, RpcLog.Types.Level.Information)]
         [InlineData(RpcLog.Types.Level.Error, RpcLog.Types.Level.Error)]