Fixing build issues.

Author: alliscode

dotnet/src/Experimental/Process.IntegrationTestRunner.Dapr/ProcessTestFixture.cs

@@ -128,30 +128,10 @@ private async Task WaitForHostStartupAsync()
         throw new InvalidProgramException("Dapr Test Host did not start");
     }
 
-    /// <summary>
-    /// Starts a process.
-    /// </summary>
-    /// <param name="process">The process to start.</param>
-    /// <param name="kernel">An instance of <see cref="Kernel"/></param>
-    /// <param name="initialEvent">An optional initial event.</param>
-    /// <param name="externalMessageChannel">channel used for external messages</param>
-    /// <returns>A <see cref="Task{KernelProcessContext}"/></returns>
-    public async Task<KernelProcessContext> StartProcessAsync(KernelProcess process, Kernel kernel, KernelProcessEvent initialEvent, IExternalKernelProcessMessageChannel? externalMessageChannel = null)
-    {
-        // Actual Kernel injection of Kernel and ExternalKernelProcessMessageChannel is in dotnet\src\Experimental\Process.IntegrationTestHost.Dapr\Program.cs
-        return await this.StartAsync(process, process.State.StepId, initialEvent);
-    }
-
-    /// <summary>
-    /// Starts the specified process.
-    /// </summary>
-    /// <param name="key"></param>
-    /// <param name="processId"></param>
-    /// <param name="initialEvent"></param>
-    /// <returns></returns>
-    public async Task<KernelProcessContext> StartAsync(KernelProcess process, string runId, KernelProcessEvent initialEvent)
+    /// <inheritdoc/>
+    public async Task<KernelProcessContext> StartProcessAsync(KernelProcess process, Kernel kernel, KernelProcessEvent initialEvent, IExternalKernelProcessMessageChannel? externalMessageChannel = null, string? runId = null)
     {
-        // Actual Kernel injection of Kernel and ExternalKernelProcessMessageChannel is in dotnet\src\Experimental\Process.IntegrationTestHost.Dapr\Program.cs
+        runId ??= Guid.NewGuid().ToString();
         var context = new DaprTestProcessContext(process, runId, this._httpClient!);
         await context.StartKeyedWithEventAsync(process.State.StepId, initialEvent);
         return context;

dotnet/src/Experimental/Process.IntegrationTestRunner.Local/ProcessTestFixture.cs

@@ -19,8 +19,9 @@ public class ProcessTestFixture
     /// <param name="kernel">An instance of <see cref="Kernel"/></param>
     /// <param name="initialEvent">An optional initial event.</param>
     /// <param name="externalMessageChannel">channel used for external messages</param>
+    /// <param name="runId">The Id of the run.</param>
     /// <returns>A <see cref="Task{KernelProcessContext}"/></returns>
-    public async Task<KernelProcessContext> StartProcessAsync(KernelProcess process, Kernel kernel, KernelProcessEvent initialEvent, IExternalKernelProcessMessageChannel? externalMessageChannel = null)
+    public async Task<KernelProcessContext> StartProcessAsync(KernelProcess process, Kernel kernel, KernelProcessEvent initialEvent, IExternalKernelProcessMessageChannel? externalMessageChannel = null, string? runId = null)
     {
         return await process.StartAsync(kernel, initialEvent, externalMessageChannel: externalMessageChannel);
     }

dotnet/src/Experimental/Process.IntegrationTests.Shared/ProcessTestFixture.cs

@@ -18,8 +18,9 @@ public abstract class ProcessTestFixture
     /// <param name="kernel">An instance of <see cref="Kernel"/></param>
     /// <param name="initialEvent">An optional initial event.</param>
     /// <param name="externalMessageChannel">channel used for external messages</param>
+    /// <param name="runId">An optional run Id.</param>
     /// <returns>A <see cref="Task{KernelProcessContext}"/></returns>
-    public abstract Task<KernelProcessContext> StartProcessAsync(KernelProcess process, Kernel kernel, KernelProcessEvent initialEvent, IExternalKernelProcessMessageChannel? externalMessageChannel = null);
+    public abstract Task<KernelProcessContext> StartProcessAsync(KernelProcess process, Kernel kernel, KernelProcessEvent initialEvent, IExternalKernelProcessMessageChannel? externalMessageChannel = null, string? runId = null);
 
     /// <summary>
     /// Starts the specified process.

dotnet/src/Experimental/Process.IntegrationTests.Shared/ProcessTests.cs

@@ -81,8 +81,8 @@ public async Task ProcessWithWhenAllListenerAsync()
 
         // Act
         string testInput = "Test";
-        var processHandle = await this._fixture.StartAsync(process, Guid.NewGuid().ToString(), new() { Id = ProcessTestsEvents.StartProcess, Data = testInput });
-        //var processHandle = await this._fixture.StartProcessAsync(process, kernel, new() { Id = ProcessTestsEvents.StartProcess, Data = testInput });
+        var processHandle = await this._fixture.StartProcessAsync(process, new(), new() { Id = ProcessTestsEvents.StartProcess, Data = testInput }, runId: Guid.NewGuid().ToString());
+
         var processInfo = await processHandle.GetStateAsync();
 
         // Assert

dotnet/src/Experimental/Process.LocalRuntime/LocalKernelProcessContext.cs

@@ -1,4 +1,5 @@
 // Copyright (c) Microsoft. All rights reserved.
+using System.Collections.Generic;
 using System.Threading.Tasks;
 using Microsoft.SemanticKernel.Process;
 
@@ -37,11 +38,6 @@ internal LocalKernelProcessContext(KernelProcess process, Kernel kernel, Process
     internal Task StartWithEventAsync(KernelProcessEvent initialEvent, Kernel? kernel = null) =>
         this._localProcess.RunOnceAsync(initialEvent, kernel);
 
-    //internal RunUntilEndAsync(KernelProcessEvent initialEvent, Kernel? kernel = null, TimeSpan? timeout = null)
-    //{
-
-    //}
-
     /// <summary>
     /// Sends a message to the process.
     /// </summary>
@@ -78,4 +74,14 @@ public async ValueTask DisposeAsync()
 
     /// <inheritdoc/>
     public override Task<string> GetProcessIdAsync() => Task.FromResult(this._localProcess.Id);
+
+    /// <summary>
+    /// Read the step states in from the process.
+    /// </summary>
+    /// <returns></returns>
+    /// <exception cref="System.NotImplementedException"></exception>
+    public override Task<IDictionary<string, KernelProcessStepState>> GetStepStatesAsync()
+    {
+        throw new System.NotImplementedException();
+    }
 }