.Net: Process: Document generation gRPC sample

dotnet/Directory.Packages.props

@@ -30,6 +30,12 @@
     <PackageVersion Include="FastBertTokenizer" Version="1.0.28" />
     <PackageVersion Include="Google.Apis.Auth" Version="1.69.0" />
     <PackageVersion Include="ModelContextProtocol" Version="0.1.0-preview.1.25171.12" />
+    <PackageVersion Include="Google.Protobuf" Version="3.27.0" />
+    <PackageVersion Include="Grpc.AspNetCore" Version="2.70.0" />
+    <PackageVersion Include="Grpc.AspNetCore.Server" Version="2.70.0" />
+    <PackageVersion Include="Grpc.AspNetCore.Server.Reflection" Version="2.70.0" />
+    <PackageVersion Include="Grpc.Tools" Version="2.70.0" />
+    <PackageVersion Include="mcpdotnet" Version="1.0.1.3" />
     <PackageVersion Include="Microsoft.AspNetCore.Mvc.Testing" Version="8.0.13" />
     <PackageVersion Include="Microsoft.AspNetCore.OpenApi" Version="8.0.14" />
     <PackageVersion Include="Microsoft.ML.Tokenizers.Data.Cl100kBase" Version="1.0.1" />
@@ -135,7 +141,7 @@
     <PackageVersion Include="Microsoft.OpenApi.ApiManifest" Version="0.5.6-preview" />
     <PackageVersion Include="Microsoft.Plugins.Manifest" Version="1.0.0-rc3" />
     <PackageVersion Include="Google.Apis.CustomSearchAPI.v1" Version="1.68.0.3520" />
-    <PackageVersion Include="Grpc.Net.Client" Version="2.66.0" />
+    <PackageVersion Include="Grpc.Net.Client" Version="2.70.0" />
     <PackageVersion Include="protobuf-net" Version="3.2.45" />
     <PackageVersion Include="protobuf-net.Reflection" Version="3.2.12" />
     <PackageVersion Include="YamlDotNet" Version="15.3.0" />

dotnet/SK-dotnet.sln

@@ -508,6 +508,12 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "PineconeIntegrationTests",
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ModelContextProtocolPlugin", "samples\Demos\ModelContextProtocolPlugin\ModelContextProtocolPlugin.csproj", "{801C9CE4-53AF-D2DB-E0D6-9A6BB47E9654}"
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "ProcessWithCloudEvents", "ProcessWithCloudEvents", "{70E69280-8DD8-463D-A94A-A1C0C4AA3A0B}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ProcessWithCloudEvents.Processes", "samples\Demos\ProcessWithCloudEvents\ProcessWithCloudEvents.Processes\ProcessWithCloudEvents.Processes.csproj", "{31F6608A-FD36-F529-A5FC-C954A0B5E29E}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ProcessWithCloudEvents.Grpc", "samples\Demos\ProcessWithCloudEvents\ProcessWithCloudEvents.Grpc\ProcessWithCloudEvents.Grpc.csproj", "{08D84994-794A-760F-95FD-4EFA8998A16D}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -1403,6 +1409,24 @@ Global
 		{801C9CE4-53AF-D2DB-E0D6-9A6BB47E9654}.Publish|Any CPU.Build.0 = Release|Any CPU
 		{801C9CE4-53AF-D2DB-E0D6-9A6BB47E9654}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{801C9CE4-53AF-D2DB-E0D6-9A6BB47E9654}.Release|Any CPU.Build.0 = Release|Any CPU
+		{31F6608A-FD36-F529-A5FC-C954A0B5E29E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{31F6608A-FD36-F529-A5FC-C954A0B5E29E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{31F6608A-FD36-F529-A5FC-C954A0B5E29E}.Publish|Any CPU.ActiveCfg = Release|Any CPU
+		{31F6608A-FD36-F529-A5FC-C954A0B5E29E}.Publish|Any CPU.Build.0 = Release|Any CPU
+		{31F6608A-FD36-F529-A5FC-C954A0B5E29E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{31F6608A-FD36-F529-A5FC-C954A0B5E29E}.Release|Any CPU.Build.0 = Release|Any CPU
+		{08D84994-794A-760F-95FD-4EFA8998A16D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{08D84994-794A-760F-95FD-4EFA8998A16D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{08D84994-794A-760F-95FD-4EFA8998A16D}.Publish|Any CPU.ActiveCfg = Release|Any CPU
+		{08D84994-794A-760F-95FD-4EFA8998A16D}.Publish|Any CPU.Build.0 = Release|Any CPU
+		{08D84994-794A-760F-95FD-4EFA8998A16D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{08D84994-794A-760F-95FD-4EFA8998A16D}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D1786E2B-CAA0-4B2D-A974-9845EB9E420F}.Debug|Any CPU.ActiveCfg = Debug
+		{D1786E2B-CAA0-4B2D-A974-9845EB9E420F}.Debug|Any CPU.Build.0 = Debug
+		{D1786E2B-CAA0-4B2D-A974-9845EB9E420F}.Publish|Any CPU.ActiveCfg = Release
+		{D1786E2B-CAA0-4B2D-A974-9845EB9E420F}.Publish|Any CPU.Build.0 = Release
+		{D1786E2B-CAA0-4B2D-A974-9845EB9E420F}.Release|Any CPU.ActiveCfg = Release
+		{D1786E2B-CAA0-4B2D-A974-9845EB9E420F}.Release|Any CPU.Build.0 = Release
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -1594,6 +1618,9 @@ Global
 		{A5E6193C-8431-4C6E-B674-682CB41EAA0C} = {4F381919-F1BE-47D8-8558-3187ED04A84F}
 		{E9A74E0C-BC02-4DDD-A487-89847EDF8026} = {4F381919-F1BE-47D8-8558-3187ED04A84F}
 		{801C9CE4-53AF-D2DB-E0D6-9A6BB47E9654} = {5D4C0700-BBB5-418F-A7B2-F392B9A18263}
+		{70E69280-8DD8-463D-A94A-A1C0C4AA3A0B} = {5D4C0700-BBB5-418F-A7B2-F392B9A18263}
+		{31F6608A-FD36-F529-A5FC-C954A0B5E29E} = {70E69280-8DD8-463D-A94A-A1C0C4AA3A0B}
+		{08D84994-794A-760F-95FD-4EFA8998A16D} = {70E69280-8DD8-463D-A94A-A1C0C4AA3A0B}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {FBDC56A3-86AD-4323-AA0F-201E59123B83}

dotnet/dapr.yaml

@@ -0,0 +1,9 @@
+apps:
+- appDirPath: samples\Demos\ProcessWithCloudEvents\ProcessWithCloudEvents.Grpc
+  appID: processwithcloudevents-grpc
+  appPort: 58641
+  command:
+  - dotnet
+  - run
+  appProtocol: h2c
+version: 1

dotnet/samples/Demos/ProcessWithCloudEvents/ProcessWithCloudEvents.Grpc/Clients/DocumentGenerationGrpcClient.cs

@@ -0,0 +1,74 @@
+// Copyright (c) Microsoft. All rights reserved.
+using System.Text.Json;
+using Grpc.Net.Client;
+using Microsoft.SemanticKernel;
+using ProcessWithCloudEvents.Grpc.DocumentationGenerator;
+using ProcessWithCloudEvents.Processes;
+using ProcessWithCloudEvents.Processes.Models;
+
+namespace ProcessWithCloudEvents.Grpc.Clients;
+
+/// <summary>
+/// Client that implements the <see cref="IExternalKernelProcessMessageChannel"/> interface used internally by the SK process
+/// to emit events to external systems.<br/>
+/// This implementation is an example of a gRPC client that emits events to a gRPC server
+/// </summary>
+public class DocumentGenerationGrpcClient : IExternalKernelProcessMessageChannel
+{
+    private GrpcChannel? _grpcChannel;
+    private GrpcDocumentationGeneration.GrpcDocumentationGenerationClient? _grpcClient;
+
+    /// <inheritdoc/>
+    public async ValueTask Initialize()
+    {
+        this._grpcChannel = GrpcChannel.ForAddress("http://localhost:58641");
+        this._grpcClient = new GrpcDocumentationGeneration.GrpcDocumentationGenerationClient(this._grpcChannel);
+    }
+
+    /// <inheritdoc/>
+    public async ValueTask Uninitialize()
+    {
+        if (this._grpcChannel != null)
+        {
+            await this._grpcChannel.ShutdownAsync();
+        }
+    }
+
+    /// <inheritdoc/>
+    public async Task EmitExternalEventAsync(string externalTopicEvent, KernelProcessProxyMessage eventData)
+    {
+        if (this._grpcClient != null)
+        {
+            switch (externalTopicEvent)
+            {
+                case DocumentGenerationProcess.DocGenerationTopics.RequestUserReview:
+                    var requestDocument = JsonSerializer.Deserialize<DocumentInfo>(eventData.EventData!.ToString()!);
+                    if (requestDocument != null)
+                    {
+                        await this._grpcClient.RequestUserReviewDocumentationFromProcessAsync(new()
+                        {
+                            Title = requestDocument.Title,
+                            AssistantMessage = "Document ready for user revision. Approve or reject document",
+                            Content = requestDocument.Content,
+                            ProcessData = new() { ProcessId = eventData.ProcessId }
+                        });
+                    }
+                    return;
+
+                case DocumentGenerationProcess.DocGenerationTopics.PublishDocumentation:
+                    var publishedDocument = JsonSerializer.Deserialize<DocumentInfo>(eventData.EventData!.ToString()!);
+                    if (publishedDocument != null)
+                    {
+                        await this._grpcClient.PublishDocumentationAsync(new()
+                        {
+                            Title = publishedDocument.Title,
+                            AssistantMessage = "Published Document Ready",
+                            Content = publishedDocument.Content,
+                            ProcessData = new() { ProcessId = eventData.ProcessId }
+                        });
+                    }
+                    return;
+            }
+        }
+    }
+}

dotnet/samples/Demos/ProcessWithCloudEvents/ProcessWithCloudEvents.Grpc/ProcessWithCloudEvents.Grpc.csproj

@@ -0,0 +1,42 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <NoWarn>
+      $(NoWarn);CA2007,CA1861,VSTHRD111,SKEXP0001,SKEXP0010,SKEXP0020,SKEXP0040,SKEXP0050,SKEXP0060,SKEXP0070,SKEXP0080,SKEXP0110
+    </NoWarn>
+    <UserSecretsId>5ee045b0-aea3-4f08-8d31-32d1a6f8fed0</UserSecretsId>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Protobuf Include="Protos\documentationGenerator.proto" GrpcServices="Both" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\..\src\Connectors\Connectors.OpenAI\Connectors.OpenAI.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Experimental\Process.Abstractions\Process.Abstractions.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Experimental\Process.Core\Process.Core.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Experimental\Process.Runtime.Dapr\Process.Runtime.Dapr.csproj" />
+    <ProjectReference Include="..\ProcessWithCloudEvents.Processes\ProcessWithCloudEvents.Processes.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Dapr.Actors" />
+    <PackageReference Include="Dapr.Actors.AspNetCore" />
+    <PackageReference Include="Google.Protobuf" />
+    <PackageReference Include="Grpc.AspNetCore" />
+    <PackageReference Include="Grpc.AspNetCore.Server.Reflection" />
+    <PackageReference Include="Grpc.Net.Client" />
+    <PackageReference Include="Grpc.Tools">
+      <PrivateAssets>all</PrivateAssets>
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+    </PackageReference>
+  </ItemGroup>
+
+  <ItemGroup>
+    <Folder Include="Media\" />
+  </ItemGroup>
+
+</Project>

dotnet/samples/Demos/ProcessWithCloudEvents/ProcessWithCloudEvents.Grpc/Program.cs

@@ -0,0 +1,47 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using Microsoft.SemanticKernel;
+using ProcessWithCloudEvents.Grpc.Clients;
+using ProcessWithCloudEvents.Grpc.Services;
+
+var builder = WebApplication.CreateBuilder(args);
+
+var config = new ConfigurationBuilder()
+    .AddUserSecrets<Program>()
+    .AddEnvironmentVariables()
+    .Build();
+
+// Configure logging
+builder.Services.AddLogging((logging) =>
+{
+    logging.AddConsole();
+    logging.AddDebug();
+});
+
+// Configure the Kernel with DI. This is required for dependency injection to work with processes.
+builder.Services.AddKernel();
+
+builder.Services.AddSingleton<DocumentGenerationService>();
+// Injecting SK Process custom grpc client IExternalKernelProcessMessageChannel implementation
+builder.Services.AddSingleton<IExternalKernelProcessMessageChannel, DocumentGenerationGrpcClient>();
+
+// Configure Dapr
+builder.Services.AddActors(static options =>
+{
+    // Register the actors required to run Processes
+    options.AddProcessActors();
+});
+
+// Add grpc related services.
+builder.Services.AddGrpc();
+builder.Services.AddGrpcReflection();
+
+var app = builder.Build();
+
+// Grpc services mapping
+app.MapGrpcReflectionService();
+app.MapGrpcService<DocumentGenerationService>();
+
+// Dapr actors related mapping
+app.MapActorsHandlers();
+app.Run();

dotnet/samples/Demos/ProcessWithCloudEvents/ProcessWithCloudEvents.Grpc/Protos/documentationGenerator.proto

@@ -0,0 +1,38 @@
+syntax = "proto3";
+
+option csharp_namespace = "ProcessWithCloudEvents.Grpc.DocumentationGenerator";
+
+service GrpcDocumentationGeneration {  
+    rpc UserRequestFeatureDocumentation (FeatureDocumentationRequest) returns (ProcessData);
+    rpc RequestUserReviewDocumentationFromProcess (DocumentationContentRequest) returns (Empty);
+    rpc RequestUserReviewDocumentation (ProcessData) returns (stream DocumentationContentRequest);
+    rpc UserReviewedDocumentation (DocumentationApprovalRequest) returns (Empty);
+    rpc PublishDocumentation (DocumentationContentRequest) returns (Empty);
+    rpc ReceivePublishedDocumentation (ProcessData) returns (stream DocumentationContentRequest);
+}
+
+message FeatureDocumentationRequest { 
+    string title = 1;
+    string userDescription = 2;
+    string content = 3;
+    string processId = 10;
+}
+
+message DocumentationContentRequest {
+    string title = 1;
+    string content = 2;
+    string assistantMessage = 3;
+    ProcessData processData = 10;
+}
+
+message DocumentationApprovalRequest {  
+    bool documentationApproved = 1;
+    string reason = 2;
+    ProcessData processData = 10;
+}
+
+message ProcessData {
+    string processId = 1;
+}
+
+message Empty {}