# AutoGen
> [!IMPORTANT]
->
+> - (11/14/24) ⚠️ In response to a number of asks to clarify and distinguish between official AutoGen and its forks that created confusion, we issued a [clarification statement](https://github.com/microsoft/autogen/discussions/4217).
> - (10/13/24) Interested in the standard AutoGen as a prior user? Find it at the actively-maintained *AutoGen* [0.2 branch](https://github.com/microsoft/autogen/tree/0.2) and `autogen-agentchat~=0.2` PyPi package.
> - (10/02/24) [AutoGen 0.4](https://microsoft.github.io/autogen/dev) is a from-the-ground-up rewrite of AutoGen. Learn more about the history, goals and future at [this blog post](https://microsoft.github.io/autogen/blog). We’re excited to work with the community to gather feedback, refine, and improve the project before we officially release 0.4. This is a big change, so AutoGen 0.2 is still available, maintained, and developed in the [0.2 branch](https://github.com/microsoft/autogen/tree/0.2).
+> - *[Join us for Community Office Hours](https://github.com/microsoft/autogen/discussions/4059)* We will host a weekly open discussion to answer questions, talk about Roadmap, etc.
AutoGen is an open-source framework for building AI agent systems.
It simplifies the creation of event-driven, distributed, scalable, and resilient agentic applications.
@@ -101,7 +104,7 @@ We look forward to your contributions!
First install the packages:
```bash
-pip install 'autogen-agentchat==0.4.0.dev6' 'autogen-ext[openai]==0.4.0.dev6'
+pip install 'autogen-agentchat==0.4.0.dev7' 'autogen-ext[openai]==0.4.0.dev7'
```
The following code uses OpenAI's GPT-4o model and you need to provide your
diff --git a/docs/design/01 - Programming Model.md b/docs/design/01 - Programming Model.md
index 732a46c6aebe..6bfa9f9766ad 100644
--- a/docs/design/01 - Programming Model.md
+++ b/docs/design/01 - Programming Model.md
@@ -6,23 +6,27 @@ The programming model is basically publish-subscribe. Agents subscribe to events
## Events Delivered as CloudEvents
-Each event in the system is defined using the [CloudEvents Specification](https://cloudevents.io/). This allows for a common event format that can be used across different systems and languages. In CloudEvents, each event has a Context Attributes that must unique *id* (eg a UUID) a *source* (a unique urn or path), a *type* (the namespace of the event - prefixed with a reverse-DNS name. The prefixed domain dictates the organization which defines the semantics of this event type: e.g *com.github.pull_request.opened* or
-*com.example.object.deleted.v2*), and optionally fields describing the data schema/content-type or extensions.
+Each event in the system is defined using the [CloudEvents Specification](https://cloudevents.io/). This allows for a common event format that can be used across different systems and languages. In CloudEvents, each event has "Context Attributes" that must include:
+
+1. *id* - A unique id (eg. a UUID).
+2. *source* - A URI or URN indicating the event's origin.
+3. *type* - The namespace of the event - prefixed with a reverse-DNS name.
+ - The prefixed domain dictates the organization which defines the semantics of this event type: e.g `com.github.pull_request.opened` or `com.example.object.deleted.v2`), and optionally fields describing the data schema/content-type or extensions.
## Event Handlers
-Each agent has a set of event handlers, that are bound to a specific match against a CloudEvents *type*. Event Handlers could match against an exact type or match for a pattern of events of a particular level in the type heirarchy (eg: *com.Microsoft.AutoGen.Agents.System.\** for all Events in the *System* namespace) Each event handler is a function that can change state, call models, access memory, call external tools, emit other events, and flow data to/from other systems. Each event handler can be a simple function or a more complex function that uses a state machine or other control logic.
+Each agent has a set of event handlers, that are bound to a specific match against a CloudEvents *type*. Event Handlers could match against an exact type or match for a pattern of events of a particular level in the type heirarchy (eg: `com.Microsoft.AutoGen.Agents.System.*` for all Events in the `System` namespace) Each event handler is a function that can change state, call models, access memory, call external tools, emit other events, and flow data to/from other systems. Each event handler can be a simple function or a more complex function that uses a state machine or other control logic.
## Orchestrating Agents
-If is possible to build a functional and scalable agent system that only reacts to external events. In many cases, however, you will want to orchestrate the agents to achieve a specific goal or follow a pre-determined workflow. In this case, you will need to build an orchestrator agent that manages the flow of events between agents.
+It is possible to build a functional and scalable agent system that only reacts to external events. In many cases, however, you will want to orchestrate the agents to achieve a specific goal or follow a pre-determined workflow. In this case, you will need to build an orchestrator agent that manages the flow of events between agents.
## Built-in Event Types
The AutoGen system comes with a set of built-in event types that are used to manage the system. These include:
-* System Events - Events that are used to manage the system itself. These include events for starting and stopping the Agents, sending messages to all agents, and other system-level events.
-* ? insert other types here ?
+- *System Events* - Events that are used to manage the system itself. These include events for starting and stopping the Agents, sending messages to all agents, and other system-level events.
+- *Insert other types here*
## Agent Contracts
diff --git a/docs/design/02 - Topics.md b/docs/design/02 - Topics.md
index aca577e748fa..7d7149c37c91 100644
--- a/docs/design/02 - Topics.md
+++ b/docs/design/02 - Topics.md
@@ -17,16 +17,16 @@ This document does not specify RPC/direct messaging
A topic is identified by two components (called a `TopicId`):
- [`type`](https://github.com/cloudevents/spec/blob/v1.0.2/cloudevents/spec.md#type) - represents the type of event that occurs, this is static and defined in code
- - SHOULD use reverse domain name notation to avoid naming conflicts. For example: `com.example.my-topic`.
+ - SHOULD use reverse domain name notation to avoid naming conflicts. For example: `com.example.my-topic`.
- [`source`](https://github.com/cloudevents/spec/blob/v1.0.2/cloudevents/spec.md#source-1) - represents where the event originated from, this is dynamic and based on the message itself
- - SHOULD be a URI
+ - SHOULD be a URI
Agent instances are identified by two components (called an `AgentId`):
- `type` - represents the type of agent, this is static and defined in code
- - MUST be a valid identifier as defined [here](https://docs.python.org/3/reference/lexical_analysis.html#identifiers) except that only the ASCII range is allowed
+ - MUST be a valid identifier as defined [here](https://docs.python.org/3/reference/lexical_analysis.html#identifiers) except that only the ASCII range is allowed
- `key` - represents the instance of the agent type for the key
- - SHOULD be a URI
+ - SHOULD be a URI
For example: `GraphicDesigner:1234`
diff --git a/docs/design/03 - Agent Worker Protocol.md b/docs/design/03 - Agent Worker Protocol.md
index 49d9e867191b..81a9b9b7e97a 100644
--- a/docs/design/03 - Agent Worker Protocol.md
+++ b/docs/design/03 - Agent Worker Protocol.md
@@ -22,7 +22,7 @@ Agents are never explicitly created or destroyed. When a request is received for
## Worker protocol flow
-The worker protocol has three phases, following the lifetime of the worker: initiation, operation, and termination.
+The worker protocol has three phases, following the lifetime of the worker: initialization, operation, and termination.
### Initialization
diff --git a/docs/design/04 - Agent and Topic ID Specs.md b/docs/design/04 - Agent and Topic ID Specs.md
index 22a8a08894fb..b0e0e0e94e60 100644
--- a/docs/design/04 - Agent and Topic ID Specs.md
+++ b/docs/design/04 - Agent and Topic ID Specs.md
@@ -8,23 +8,23 @@ This document describes the structure, constraints, and behavior of Agent IDs an
#### type
-* Type: `string`
-* Description: The agent type is not an agent class. It associates an agent with a specific factory function, which produces instances of agents of the same agent `type`. For example, different factory functions can produce the same agent class but with different constructor perameters.
-* Constraints: UTF8 and only contain alphanumeric letters (a-z) and (0-9), or underscores (_). A valid identifier cannot start with a number, or contain any spaces.
-* Examples:
- * `code_reviewer`
- * `WebSurfer`
- * `UserProxy`
+- Type: `string`
+- Description: The agent type is not an agent class. It associates an agent with a specific factory function, which produces instances of agents of the same agent `type`. For example, different factory functions can produce the same agent class but with different constructor perameters.
+- Constraints: UTF8 and only contain alphanumeric letters (a-z) and (0-9), or underscores (\_). A valid identifier cannot start with a number, or contain any spaces.
+- Examples:
+ - `code_reviewer`
+ - `WebSurfer`
+ - `UserProxy`
#### key
-* Type: `string`
-* Description: The agent key is an instance identifier for the given agent `type`
-* Constraints: UTF8 and only contain characters between (inclusive) ascii 32 (space) and 126 (~).
-* Examples:
- * `default`
- * A memory address
- * a UUID string
+- Type: `string`
+- Description: The agent key is an instance identifier for the given agent `type`
+- Constraints: UTF8 and only contain characters between (inclusive) ascii 32 (space) and 126 (~).
+- Examples:
+ - `default`
+ - A memory address
+ - a UUID string
## Topic ID
@@ -32,16 +32,16 @@ This document describes the structure, constraints, and behavior of Agent IDs an
#### type
-* Type: `string`
-* Description: topic type is usually defined by application code to mark the type of messages the topic is for.
-* Constraints: UTF8 and only contain alphanumeric letters (a-z) and (0-9), or underscores (_). A valid identifier cannot start with a number, or contain any spaces.
-* Examples:
- * `GitHub_Issues`
+- Type: `string`
+- Description: Topic type is usually defined by application code to mark the type of messages the topic is for.
+- Constraints: UTF8 and only contain alphanumeric letters (a-z) and (0-9), ':', '=', or underscores (\_). A valid identifier cannot start with a number, or contain any spaces.
+- Examples:
+ - `GitHub_Issues`
#### source
-* Type: `string`
-* Description: Topic source is the unique identifier for a topic within a topic type. It is typically defined by application data.
-* Constraints: UTF8 and only contain characters between (inclusive) ascii 32 (space) and 126 (~).
-* Examples:
- * `github.com/{repo_name}/issues/{issue_number}`
\ No newline at end of file
+- Type: `string`
+- Description: Topic source is the unique identifier for a topic within a topic type. It is typically defined by application data.
+- Constraints: UTF8 and only contain characters between (inclusive) ascii 32 (space) and 126 (~).
+- Examples:
+ - `github.com/{repo_name}/issues/{issue_number}`
diff --git a/docs/design/readme.md b/docs/design/readme.md
new file mode 100644
index 000000000000..6a8221027f75
--- /dev/null
+++ b/docs/design/readme.md
@@ -0,0 +1,3 @@
+# Docs
+
+You can find the project documentation [here](https://microsoft.github.io/autogen/dev/).
diff --git a/docs/switcher.json b/docs/switcher.json
index a4e6748ebea7..5cfbe4c05516 100644
--- a/docs/switcher.json
+++ b/docs/switcher.json
@@ -41,7 +41,12 @@
{
"name": "0.4.0.dev6",
"version": "0.4.0.dev6",
- "url": "/autogen/0.4.0.dev6/",
+ "url": "/autogen/0.4.0.dev6/"
+ },
+ {
+ "name": "0.4.0.dev7",
+ "version": "0.4.0.dev7",
+ "url": "/autogen/0.4.0.dev7/",
"preferred": true
}
]
diff --git a/dotnet/.gitignore b/dotnet/.gitignore
index 2fc32d9ac7e4..62205af71a07 100644
--- a/dotnet/.gitignore
+++ b/dotnet/.gitignore
@@ -82,6 +82,7 @@ BenchmarkDotNet.Artifacts/
project.lock.json
project.fragment.lock.json
artifacts/
+appsettings.Development.json
# Tye
.tye/
diff --git a/dotnet/.tools/test-aot-compatibility.ps1 b/dotnet/.tools/test-aot-compatibility.ps1
index 071edcd956dc..d70139fd1fd2 100644
--- a/dotnet/.tools/test-aot-compatibility.ps1
+++ b/dotnet/.tools/test-aot-compatibility.ps1
@@ -15,7 +15,7 @@ foreach ($line in $($publishOutput -split "`r`n"))
}
}
-pushd $rootDirectory/test/AutoGen.AotCompatibility.Tests/bin/Release/$targetNetFramework/linux-x64
+pushd $rootDirectory/artifacts/bin/AutoGen.AotCompatibility.Tests/release
Write-Host "Executing test App..."
./AutoGen.AotCompatibility.Tests
diff --git a/dotnet/AutoGen.sln b/dotnet/AutoGen.sln
index e3e64621533d..fafd117f7914 100644
--- a/dotnet/AutoGen.sln
+++ b/dotnet/AutoGen.sln
@@ -122,15 +122,15 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "HelloAIAgents", "samples\He
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "HelloAgent", "samples\Hello\HelloAgent\HelloAgent.csproj", "{8F7560CF-EEBB-4333-A69F-838CA40FD85D}"
EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "AIModelClientHostingExtensions", "src\Microsoft.AutoGen\Extensions\AIModelClientHostingExtensions\AIModelClientHostingExtensions.csproj", "{97550E87-48C6-4EBF-85E1-413ABAE9DBFD}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Microsoft.AutoGen.Extensions.MEAI", "src\Microsoft.AutoGen\Extensions\MEAI\Microsoft.AutoGen.Extensions.MEAI.csproj", "{97550E87-48C6-4EBF-85E1-413ABAE9DBFD}"
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "sample", "sample", "{686480D7-8FEC-4ED3-9C5D-CEBE1057A7ED}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "HelloAgentState", "samples\Hello\HelloAgentState\HelloAgentState.csproj", "{64EF61E7-00A6-4E5E-9808-62E10993A0E5}"
EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Microsoft.AutoGen.ServiceDefaults", "src\Microsoft.AutoGen\Extensions\ServiceDefaults\Microsoft.AutoGen.ServiceDefaults.csproj", "{65059914-5527-4A00-9308-9FAF23D5E85A}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Microsoft.AutoGen.Extensions.Aspire", "src\Microsoft.AutoGen\Extensions\Aspire\Microsoft.AutoGen.Extensions.Aspire.csproj", "{65059914-5527-4A00-9308-9FAF23D5E85A}"
EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Microsoft.AutoGen.Agents.Tests", "test\Microsoft.AutoGen.Agents.Tests\Microsoft.AutoGen.Agents.Tests.csproj", "{394FDAF8-74F9-4977-94A5-3371737EB774}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Microsoft.AutoGen.Agents.Tests", "test\Microsoft.AutoGen.Agents.Tests\Microsoft.AutoGen.Agents.Tests.csproj", "{394FDAF8-74F9-4977-94A5-3371737EB774}"
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Hello-distributed", "Hello-distributed", "{80A6C47B-0567-49F6-843A-667B96FA4BB4}"
EndProject
diff --git a/dotnet/AutoGen.v3.ncrunchsolution b/dotnet/AutoGen.v3.ncrunchsolution
new file mode 100644
index 000000000000..13107d39442c
--- /dev/null
+++ b/dotnet/AutoGen.v3.ncrunchsolution
@@ -0,0 +1,8 @@
+
+
+ True
+ True
+ True
+ True
+
+
\ No newline at end of file
diff --git a/dotnet/Directory.Build.props b/dotnet/Directory.Build.props
index 1e84f78232ad..e548a4b7ea83 100644
--- a/dotnet/Directory.Build.props
+++ b/dotnet/Directory.Build.props
@@ -3,6 +3,7 @@
+ truenetstandard2.0;net8.0net8.0preview
@@ -20,7 +21,6 @@
truetruefalse
-
embeddedtrue
@@ -29,6 +29,11 @@
$(MSBuildThisFileDirectory)
+
+ $(VersionPrefixForAutoGen0_2)
+ true
+
+
$(NoWarn);CA1829
diff --git a/dotnet/Directory.Packages.props b/dotnet/Directory.Packages.props
index 2cde62118bb3..3793e34573a2 100644
--- a/dotnet/Directory.Packages.props
+++ b/dotnet/Directory.Packages.props
@@ -7,6 +7,7 @@
direct
+
@@ -16,12 +17,12 @@
-
+
-
+
@@ -32,91 +33,92 @@
-
+
-
+
-
-
-
+
+
-
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+ runtime; build; native; contentfiles; analyzers; buildtransitiveall
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
+
+
+
-
-
+
+
-
-
-
-
-
+
+
+
+
+
-
-
-
-
+
+
+
+
+
-
-
+
+
+
-
+
diff --git a/dotnet/PACKAGING.md b/dotnet/PACKAGING.md
new file mode 100644
index 000000000000..af03850f7cea
--- /dev/null
+++ b/dotnet/PACKAGING.md
@@ -0,0 +1,41 @@
+# Packaging AutoGen.NET
+
+This document describes the steps to pack the `AutoGen.NET` project.
+
+## Prerequisites
+
+- .NET SDK
+
+## Create Package
+
+1. **Restore and Build the Project**
+```bash
+dotnet restore
+dotnet build --configuration Release --no-restore
+```
+
+
+2. **Create the NuGet Package**
+```bash
+dotnet pack --configuration Release --no-build
+```
+
+This will generate both the `.nupkg` file and the `.snupkg` file in the `./artifacts/package/release` directory.
+
+For more details, refer to the [official .NET documentation](https://docs.microsoft.com/en-us/dotnet/core/tools/dotnet-pack).
+
+## Add new project to package list.
+By default, when you add a new project to `AutoGen.sln`, it will not be included in the package list. To include the new project in the package, you need to add the following line to the new project's `.csproj` file
+
+e.g.
+
+```xml
+
+```
+
+The `nuget-packages.props` enables `IsPackable` to `true` for the project, it also sets nenecessary metadata for the package.
+
+For more details, refer to the [NuGet folder](./nuget/README.md).
+
+## Package versioning
+The version of the package is defined by `VersionPrefix` and `VersionPrefixForAutoGen0_2` in [MetaInfo.props](./eng/MetaInfo.props). If the name of your project starts with `AutoGen.`, the version will be set to `VersionPrefixForAutoGen0_2`, otherwise it will be set to `VersionPrefix`.
diff --git a/dotnet/README.md b/dotnet/README.md
index a5705114d72a..c34679389fc0 100644
--- a/dotnet/README.md
+++ b/dotnet/README.md
@@ -1,12 +1,12 @@
# AutoGen for .NET
Thre are two sets of packages here:
-Autogen.\* the older packages derived from Autogen 0.2 for .NET - these will gradually be deprecated and ported into the new packages
+AutoGen.\* the older packages derived from AutoGen 0.2 for .NET - these will gradually be deprecated and ported into the new packages
Microsoft.AutoGen.* the new packages for .NET that use the event-driven model - These APIs are not yet stable and are subject to change.
To get started with the new packages, please see the [samples](./samples/) and in particular the [Hello](./samples/Hello) sample.
-The remaining content is for the older Autogen.* packages.
+You can install both new and old packages from the following feeds:
[](https://github.com/microsoft/autogen/actions/workflows/dotnet-build.yml)
[](https://badge.fury.io/nu/AutoGen.Core)
@@ -14,9 +14,7 @@ The remaining content is for the older Autogen.* packages.
> [!NOTE]
> Nightly build is available at:
>
-> -   :
-> -   :
-> -    :
+> - [](https://dev.azure.com/AGPublish/AGPublic/_artifacts/feed/AutoGen-Nightly) :
Firstly, following the [installation guide](./website/articles/Installation.md) to install AutoGen packages.
diff --git a/dotnet/eng/MetaInfo.props b/dotnet/eng/MetaInfo.props
index 4f3d216aa08c..db46778a06c2 100644
--- a/dotnet/eng/MetaInfo.props
+++ b/dotnet/eng/MetaInfo.props
@@ -1,7 +1,8 @@
- 0.2.2
+ 0.4.0
+ 0.2.2AutoGenhttps://microsoft.github.io/autogen-for-net/https://github.com/microsoft/autogen
diff --git a/dotnet/global.json b/dotnet/global.json
index 5f78cce063fa..4f9e9b79a15a 100644
--- a/dotnet/global.json
+++ b/dotnet/global.json
@@ -1,6 +1,6 @@
{
"sdk": {
- "version": "8.0.104",
+ "version": "8.0.401",
"rollForward": "latestMinor"
}
}
diff --git a/dotnet/nuget/README.md b/dotnet/nuget/README.md
new file mode 100644
index 000000000000..c95a97624788
--- /dev/null
+++ b/dotnet/nuget/README.md
@@ -0,0 +1,13 @@
+# NuGet Directory
+
+This directory contains resources and metadata for packaging the AutoGen.NET SDK as a NuGet package.
+
+## Files
+
+- **icon.png**: The icon used for the NuGet package.
+- **NUGET.md**: The readme file displayed on the NuGet package page.
+- **NUGET-PACKAGE.PROPS**: The MSBuild properties file that defines the packaging settings for the NuGet package.
+
+## Purpose
+
+The files in this directory are used to configure and build the NuGet package for the AutoGen.NET SDK, ensuring that it includes necessary metadata, documentation, and resources.
\ No newline at end of file
diff --git a/dotnet/nuget/nuget-package.props b/dotnet/nuget/nuget-package.props
index 50cbafc73b66..380380794dc9 100644
--- a/dotnet/nuget/nuget-package.props
+++ b/dotnet/nuget/nuget-package.props
@@ -7,7 +7,7 @@
MicrosoftAutoGenA programming framework for agentic AI
- AI, Artificial Intelligence, SDK
+ AI, Artificial Intelligence, Agents, Multiagent, SDK$(AssemblyName)
diff --git a/dotnet/samples/Hello-distributed/Backend/Agents/OutputAgent.cs b/dotnet/samples/Hello-distributed/Backend/Agents/OutputAgent.cs
index 1771793a58a7..5c109519dd5a 100644
--- a/dotnet/samples/Hello-distributed/Backend/Agents/OutputAgent.cs
+++ b/dotnet/samples/Hello-distributed/Backend/Agents/OutputAgent.cs
@@ -16,6 +16,6 @@ public class OutputAgent(
{
public async Task Handle(NewGreetingGenerated item)
{
- _logger.LogInformation($"OutputAgent with Id: {AgentId} received NewGreetingGenerated with {item.UserMessage}");
+ _logger.LogInformation($"OutputAgent with Id: {AgentId} received NewGreetingGenerated with {item.UserMessage}");
}
}
diff --git a/dotnet/samples/Hello-distributed/Backend/Backend.csproj b/dotnet/samples/Hello-distributed/Backend/Backend.csproj
index d38faf01497a..3db680932b07 100644
--- a/dotnet/samples/Hello-distributed/Backend/Backend.csproj
+++ b/dotnet/samples/Hello-distributed/Backend/Backend.csproj
@@ -17,17 +17,18 @@
+
+
-
-
+
diff --git a/dotnet/samples/Hello-distributed/Backend/Program.cs b/dotnet/samples/Hello-distributed/Backend/Program.cs
index f94daae5eeb2..162f835a0be2 100644
--- a/dotnet/samples/Hello-distributed/Backend/Program.cs
+++ b/dotnet/samples/Hello-distributed/Backend/Program.cs
@@ -28,7 +28,7 @@
app.MapDefaultEndpoints();
-app.MapPost("/sessions", async ([FromBody]string message, Client client) =>
+app.MapPost("/sessions", async ([FromBody] string message, Client client) =>
{
var session = Guid.NewGuid().ToString();
await client.PublishEventAsync(new NewGreetingRequested { Message = message }.ToCloudEvent(session));
@@ -37,14 +37,14 @@
app.MapGet("/sessions/{session}", async (string session) =>
{
-
+
return session;
});
app.UseRouting()
.UseEndpoints(endpoints =>
{
-
+
}); ;
app.UseSwagger();
diff --git a/dotnet/samples/Hello/Backend/Backend.csproj b/dotnet/samples/Hello/Backend/Backend.csproj
index d502d7260d15..360459334805 100644
--- a/dotnet/samples/Hello/Backend/Backend.csproj
+++ b/dotnet/samples/Hello/Backend/Backend.csproj
@@ -1,4 +1,4 @@
-
+
diff --git a/dotnet/samples/Hello/Backend/Program.cs b/dotnet/samples/Hello/Backend/Program.cs
index b913d39d643f..b74dba139826 100644
--- a/dotnet/samples/Hello/Backend/Program.cs
+++ b/dotnet/samples/Hello/Backend/Program.cs
@@ -1,7 +1,5 @@
// Copyright (c) Microsoft Corporation. All rights reserved.
// Program.cs
-using Microsoft.Extensions.Hosting;
-
var app = await Microsoft.AutoGen.Agents.Host.StartAsync(local: false, useGrpc: true);
await app.WaitForShutdownAsync();
diff --git a/dotnet/samples/Hello/Backend/appsettings.json b/dotnet/samples/Hello/Backend/appsettings.json
index 3bb8d882550c..ae32fe371a70 100644
--- a/dotnet/samples/Hello/Backend/appsettings.json
+++ b/dotnet/samples/Hello/Backend/appsettings.json
@@ -1,9 +1,15 @@
{
- "Logging": {
- "LogLevel": {
- "Default": "Warning",
- "Microsoft": "Warning",
- "Microsoft.Orleans": "Warning"
- }
+ "Logging": {
+ "LogLevel": {
+ "Default": "Warning",
+ "Microsoft": "Warning",
+ "Microsoft.Orleans": "Warning"
}
- }
\ No newline at end of file
+ },
+ "AllowedHosts": "*",
+ "Kestrel": {
+ "EndpointDefaults": {
+ "Protocols": "Http2"
+ }
+ }
+}
diff --git a/dotnet/samples/Hello/Hello.AppHost/Program.cs b/dotnet/samples/Hello/Hello.AppHost/Program.cs
index d9acc3ea3f12..326eddbcc9ec 100644
--- a/dotnet/samples/Hello/Hello.AppHost/Program.cs
+++ b/dotnet/samples/Hello/Hello.AppHost/Program.cs
@@ -1,7 +1,19 @@
// Copyright (c) Microsoft Corporation. All rights reserved.
// Program.cs
+using Microsoft.Extensions.Hosting;
+
var builder = DistributedApplication.CreateBuilder(args);
-var backend = builder.AddProject("backend");
-builder.AddProject("client").WithReference(backend).WaitFor(backend);
-builder.Build().Run();
+var backend = builder.AddProject("backend").WithExternalHttpEndpoints();
+builder.AddProject("client")
+ .WithReference(backend)
+ .WithEnvironment("AGENT_HOST", $"{backend.GetEndpoint("https").Property(EndpointProperty.Url)}")
+ .WaitFor(backend);
+
+using var app = builder.Build();
+
+await app.StartAsync();
+var url = backend.GetEndpoint("http").Url;
+Console.WriteLine("Backend URL: " + url);
+
+await app.WaitForShutdownAsync();
diff --git a/dotnet/samples/Hello/HelloAIAgents/HelloAIAgents.csproj b/dotnet/samples/Hello/HelloAIAgents/HelloAIAgents.csproj
index f17ab0c9f0a5..c33bfeed5a8d 100644
--- a/dotnet/samples/Hello/HelloAIAgents/HelloAIAgents.csproj
+++ b/dotnet/samples/Hello/HelloAIAgents/HelloAIAgents.csproj
@@ -1,7 +1,7 @@
Exe
- net8.0
+ net8.0enableenable
@@ -13,6 +13,6 @@
-
+
diff --git a/dotnet/samples/Hello/HelloAgent/HelloAgent.csproj b/dotnet/samples/Hello/HelloAgent/HelloAgent.csproj
index f2f3e473fef7..93c996e32093 100644
--- a/dotnet/samples/Hello/HelloAgent/HelloAgent.csproj
+++ b/dotnet/samples/Hello/HelloAgent/HelloAgent.csproj
@@ -1,14 +1,17 @@
-
+Exe
- net8.0
+ net8.0enableenable
-
+
+
+ PreserveNewest
+
+
-
diff --git a/dotnet/samples/Hello/HelloAgent/Program.cs b/dotnet/samples/Hello/HelloAgent/Program.cs
index 506d91502328..4f74520a71e0 100644
--- a/dotnet/samples/Hello/HelloAgent/Program.cs
+++ b/dotnet/samples/Hello/HelloAgent/Program.cs
@@ -19,7 +19,7 @@
{
Message = "World"
}, local: true);
-
+//var app = await AgentsApp.StartAsync();
await app.WaitForShutdownAsync();
namespace Hello
@@ -33,7 +33,8 @@ public class HelloAgent(
ISayHello,
IHandleConsole,
IHandle,
- IHandle
+ IHandle,
+ IHandle
{
public async Task Handle(NewMessageReceived item)
{
@@ -50,13 +51,14 @@ public async Task Handle(NewMessageReceived item)
public async Task Handle(ConversationClosed item)
{
var goodbye = $"********************* {item.UserId} said {item.UserMessage} ************************";
- var evt = new Output
- {
- Message = goodbye
- };
- await PublishMessageAsync(evt).ConfigureAwait(false);
+ var evt = new Output { Message = goodbye };
+ await PublishMessageAsync(evt).ConfigureAwait(true);
+ await PublishMessageAsync(new Shutdown()).ConfigureAwait(false);
+ }
- // Signal shutdown.
+ public async Task Handle(Shutdown item)
+ {
+ Console.WriteLine("Shutting down...");
hostApplicationLifetime.StopApplication();
}
diff --git a/dotnet/samples/Hello/HelloAgentState/HelloAgentState.csproj b/dotnet/samples/Hello/HelloAgentState/HelloAgentState.csproj
index 797fe957bb75..e26b6c9521c2 100644
--- a/dotnet/samples/Hello/HelloAgentState/HelloAgentState.csproj
+++ b/dotnet/samples/Hello/HelloAgentState/HelloAgentState.csproj
@@ -1,7 +1,7 @@
Exe
- net8.0
+ net8.0enableenable
diff --git a/dotnet/samples/Hello/HelloAgentState/Program.cs b/dotnet/samples/Hello/HelloAgentState/Program.cs
index 7c15c4c54df0..664689de824d 100644
--- a/dotnet/samples/Hello/HelloAgentState/Program.cs
+++ b/dotnet/samples/Hello/HelloAgentState/Program.cs
@@ -9,7 +9,7 @@
var app = await AgentsApp.PublishMessageAsync("HelloAgents", new NewMessageReceived
{
Message = "World"
-}, local: true);
+}, local: false);
await app.WaitForShutdownAsync();
diff --git a/dotnet/samples/dev-team/DevTeam.AgentHost/DevTeam.AgentHost.csproj b/dotnet/samples/dev-team/DevTeam.AgentHost/DevTeam.AgentHost.csproj
index d8d7ebf8e48b..7508ae5af56e 100644
--- a/dotnet/samples/dev-team/DevTeam.AgentHost/DevTeam.AgentHost.csproj
+++ b/dotnet/samples/dev-team/DevTeam.AgentHost/DevTeam.AgentHost.csproj
@@ -1,7 +1,7 @@
- net8.0
+ net8.0enableenable
@@ -10,7 +10,7 @@
-
+
diff --git a/dotnet/samples/dev-team/DevTeam.Agents/DevTeam.Agents.csproj b/dotnet/samples/dev-team/DevTeam.Agents/DevTeam.Agents.csproj
index 8dfd6912e547..46a20c650fb7 100644
--- a/dotnet/samples/dev-team/DevTeam.Agents/DevTeam.Agents.csproj
+++ b/dotnet/samples/dev-team/DevTeam.Agents/DevTeam.Agents.csproj
@@ -1,7 +1,7 @@
- net8.0
+ net8.0enableenable
@@ -10,7 +10,7 @@
-
+
diff --git a/dotnet/samples/dev-team/DevTeam.AppHost/DevTeam.AppHost.csproj b/dotnet/samples/dev-team/DevTeam.AppHost/DevTeam.AppHost.csproj
index 7dc1a6deafd9..89d121b303ea 100644
--- a/dotnet/samples/dev-team/DevTeam.AppHost/DevTeam.AppHost.csproj
+++ b/dotnet/samples/dev-team/DevTeam.AppHost/DevTeam.AppHost.csproj
@@ -4,7 +4,7 @@
Exe
- net8.0
+ net8.0enableenabletrue
diff --git a/dotnet/samples/dev-team/DevTeam.Backend/DevTeam.Backend.csproj b/dotnet/samples/dev-team/DevTeam.Backend/DevTeam.Backend.csproj
index 8296f7aa670e..10e05cfb2107 100644
--- a/dotnet/samples/dev-team/DevTeam.Backend/DevTeam.Backend.csproj
+++ b/dotnet/samples/dev-team/DevTeam.Backend/DevTeam.Backend.csproj
@@ -5,7 +5,7 @@
- net8.0
+ net8.0enableenable
@@ -29,7 +29,7 @@
-
+
diff --git a/dotnet/samples/dev-team/DevTeam.Backend/Program.cs b/dotnet/samples/dev-team/DevTeam.Backend/Program.cs
index 08f3c3a8a7c1..2cadfe01e933 100644
--- a/dotnet/samples/dev-team/DevTeam.Backend/Program.cs
+++ b/dotnet/samples/dev-team/DevTeam.Backend/Program.cs
@@ -67,9 +67,9 @@
}); ;
app.UseSwagger();
-app.UseSwaggerUI(c =>
+/* app.UseSwaggerUI(c =>
{
c.SwaggerEndpoint("/swagger/v1/swagger.json", "My API V1");
-});
+}); */
app.Run();
diff --git a/dotnet/samples/dev-team/DevTeam.Shared/DevTeam.Shared.csproj b/dotnet/samples/dev-team/DevTeam.Shared/DevTeam.Shared.csproj
index bc739135da95..18fcb9745238 100644
--- a/dotnet/samples/dev-team/DevTeam.Shared/DevTeam.Shared.csproj
+++ b/dotnet/samples/dev-team/DevTeam.Shared/DevTeam.Shared.csproj
@@ -5,7 +5,7 @@
- net8.0
+ net8.0enableenable
diff --git a/dotnet/samples/dev-team/dev team.sln b/dotnet/samples/dev-team/dev team.sln
new file mode 100644
index 000000000000..f8a7aeacd924
--- /dev/null
+++ b/dotnet/samples/dev-team/dev team.sln
@@ -0,0 +1,49 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.11.35327.3
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DevTeam.AgentHost", "DevTeam.AgentHost\DevTeam.AgentHost.csproj", "{A6FC8B01-A177-4690-BD16-73EE3D0C06A0}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DevTeam.Backend", "DevTeam.Backend\DevTeam.Backend.csproj", "{2D4BAD10-85F3-4E4B-B759-13449A212A96}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DevTeam.Agents", "DevTeam.Agents\DevTeam.Agents.csproj", "{A51CE540-72B0-4271-B63D-A30CAB61C227}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DevTeam.AppHost", "DevTeam.AppHost\DevTeam.AppHost.csproj", "{2B8A3C64-9F4E-4CC5-9466-AFFD8E676D2E}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DevTeam.Shared", "DevTeam.Shared\DevTeam.Shared.csproj", "{557701A5-35D8-4CE3-BA75-D5412B4227F5}"
+EndProject
+Global
+ GlobalSection(SolutionConfigurationPlatforms) = preSolution
+ Debug|Any CPU = Debug|Any CPU
+ Release|Any CPU = Release|Any CPU
+ EndGlobalSection
+ GlobalSection(ProjectConfigurationPlatforms) = postSolution
+ {A6FC8B01-A177-4690-BD16-73EE3D0C06A0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {A6FC8B01-A177-4690-BD16-73EE3D0C06A0}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {A6FC8B01-A177-4690-BD16-73EE3D0C06A0}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {A6FC8B01-A177-4690-BD16-73EE3D0C06A0}.Release|Any CPU.Build.0 = Release|Any CPU
+ {2D4BAD10-85F3-4E4B-B759-13449A212A96}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {2D4BAD10-85F3-4E4B-B759-13449A212A96}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {2D4BAD10-85F3-4E4B-B759-13449A212A96}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {2D4BAD10-85F3-4E4B-B759-13449A212A96}.Release|Any CPU.Build.0 = Release|Any CPU
+ {A51CE540-72B0-4271-B63D-A30CAB61C227}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {A51CE540-72B0-4271-B63D-A30CAB61C227}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {A51CE540-72B0-4271-B63D-A30CAB61C227}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {A51CE540-72B0-4271-B63D-A30CAB61C227}.Release|Any CPU.Build.0 = Release|Any CPU
+ {2B8A3C64-9F4E-4CC5-9466-AFFD8E676D2E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {2B8A3C64-9F4E-4CC5-9466-AFFD8E676D2E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {2B8A3C64-9F4E-4CC5-9466-AFFD8E676D2E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {2B8A3C64-9F4E-4CC5-9466-AFFD8E676D2E}.Release|Any CPU.Build.0 = Release|Any CPU
+ {557701A5-35D8-4CE3-BA75-D5412B4227F5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {557701A5-35D8-4CE3-BA75-D5412B4227F5}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {557701A5-35D8-4CE3-BA75-D5412B4227F5}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {557701A5-35D8-4CE3-BA75-D5412B4227F5}.Release|Any CPU.Build.0 = Release|Any CPU
+ EndGlobalSection
+ GlobalSection(SolutionProperties) = preSolution
+ HideSolutionNode = FALSE
+ EndGlobalSection
+ GlobalSection(ExtensibilityGlobals) = postSolution
+ SolutionGuid = {DE04DB59-B8CD-4305-875B-E71442345CCF}
+ EndGlobalSection
+EndGlobal
diff --git a/dotnet/src/AutoGen.Core/Function/FunctionAttribute.cs b/dotnet/src/AutoGen.Core/Function/FunctionAttribute.cs
index 9418dc7fd6ae..9367f5c6f297 100644
--- a/dotnet/src/AutoGen.Core/Function/FunctionAttribute.cs
+++ b/dotnet/src/AutoGen.Core/Function/FunctionAttribute.cs
@@ -98,7 +98,7 @@ public static implicit operator AIFunctionMetadata(FunctionContract contract)
[NamespaceKey] = contract.Namespace,
[ClassNameKey] = contract.ClassName,
},
- Parameters = [.. contract.Parameters?.Select(p => (AIFunctionParameterMetadata)p)],
+ Parameters = [.. contract.Parameters?.Select(p => (AIFunctionParameterMetadata)p)!],
};
}
}
diff --git a/dotnet/src/AutoGen.Core/Message/ImageMessage.cs b/dotnet/src/AutoGen.Core/Message/ImageMessage.cs
index 369a3782d502..37be3a7c7ed1 100644
--- a/dotnet/src/AutoGen.Core/Message/ImageMessage.cs
+++ b/dotnet/src/AutoGen.Core/Message/ImageMessage.cs
@@ -2,39 +2,65 @@
// ImageMessage.cs
using System;
+using System.Text.RegularExpressions;
namespace AutoGen.Core;
public class ImageMessage : IMessage
{
- public ImageMessage(Role role, string url, string? from = null, string? mimeType = null)
- : this(role, new Uri(url), from, mimeType)
- {
- }
+ private static readonly Regex s_DataUriRegex = new Regex(@"^data:(?[^;]+);base64,(?.*)$", RegexOptions.Compiled);
- public ImageMessage(Role role, Uri uri, string? from = null, string? mimeType = null)
+ ///
+ /// Create an ImageMessage from a url.
+ /// The url can be a regular url or a data uri.
+ /// If the url is a data uri, the scheme must be "data" and the format must be data:[][;base64],
+ ///
+ public ImageMessage(Role role, string url, string? from = null, string? mimeType = null)
{
this.Role = role;
this.From = from;
- this.Url = uri.ToString();
- // try infer mimeType from uri extension if not provided
- if (mimeType is null)
+ // url might be a data uri or a regular url
+ if (url.StartsWith("data:", StringComparison.OrdinalIgnoreCase))
+ {
+ // the url must be in the format of data:[][;base64],
+ var match = s_DataUriRegex.Match(url);
+
+ if (!match.Success)
+ {
+ throw new ArgumentException("Invalid DataUri format, expected data:[][;base64],", nameof(url));
+ }
+
+ this.Data = new BinaryData(Convert.FromBase64String(match.Groups["data"].Value), match.Groups["mediatype"].Value);
+
+ this.MimeType = match.Groups["mediatype"].Value;
+ }
+ else
{
- mimeType = uri switch
+ this.Url = url;
+ // try infer mimeType from uri extension if not provided
+ if (mimeType is null)
{
- _ when uri.AbsoluteUri.EndsWith(".png", StringComparison.OrdinalIgnoreCase) => "image/png",
- _ when uri.AbsoluteUri.EndsWith(".jpg", StringComparison.OrdinalIgnoreCase) => "image/jpeg",
- _ when uri.AbsoluteUri.EndsWith(".jpeg", StringComparison.OrdinalIgnoreCase) => "image/jpeg",
- _ when uri.AbsoluteUri.EndsWith(".gif", StringComparison.OrdinalIgnoreCase) => "image/gif",
- _ when uri.AbsoluteUri.EndsWith(".bmp", StringComparison.OrdinalIgnoreCase) => "image/bmp",
- _ when uri.AbsoluteUri.EndsWith(".webp", StringComparison.OrdinalIgnoreCase) => "image/webp",
- _ when uri.AbsoluteUri.EndsWith(".svg", StringComparison.OrdinalIgnoreCase) => "image/svg+xml",
- _ => throw new ArgumentException("MimeType is required for ImageMessage", nameof(mimeType))
- };
+ mimeType = url switch
+ {
+ _ when url.EndsWith(".png", StringComparison.OrdinalIgnoreCase) => "image/png",
+ _ when url.EndsWith(".jpg", StringComparison.OrdinalIgnoreCase) => "image/jpeg",
+ _ when url.EndsWith(".jpeg", StringComparison.OrdinalIgnoreCase) => "image/jpeg",
+ _ when url.EndsWith(".gif", StringComparison.OrdinalIgnoreCase) => "image/gif",
+ _ when url.EndsWith(".bmp", StringComparison.OrdinalIgnoreCase) => "image/bmp",
+ _ when url.EndsWith(".webp", StringComparison.OrdinalIgnoreCase) => "image/webp",
+ _ when url.EndsWith(".svg", StringComparison.OrdinalIgnoreCase) => "image/svg+xml",
+ _ => throw new ArgumentException("MimeType is required for ImageMessage", nameof(mimeType))
+ };
+ }
+
+ this.MimeType = mimeType;
}
+ }
- this.MimeType = mimeType;
+ public ImageMessage(Role role, Uri uri, string? from = null, string? mimeType = null)
+ : this(role, uri.ToString(), from, mimeType)
+ {
}
public ImageMessage(Role role, BinaryData data, string? from = null)
diff --git a/dotnet/src/AutoGen.OpenAI/AutoGen.OpenAI.csproj b/dotnet/src/AutoGen.OpenAI/AutoGen.OpenAI.csproj
index 7f00b63be86c..70c0f2b0d1ce 100644
--- a/dotnet/src/AutoGen.OpenAI/AutoGen.OpenAI.csproj
+++ b/dotnet/src/AutoGen.OpenAI/AutoGen.OpenAI.csproj
@@ -18,6 +18,7 @@
+
diff --git a/dotnet/src/AutoGen.OpenAI/Orchestrator/RolePlayToolCallOrchestrator.cs b/dotnet/src/AutoGen.OpenAI/Orchestrator/RolePlayToolCallOrchestrator.cs
new file mode 100644
index 000000000000..f088e1748e66
--- /dev/null
+++ b/dotnet/src/AutoGen.OpenAI/Orchestrator/RolePlayToolCallOrchestrator.cs
@@ -0,0 +1,133 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// RolePlayToolCallOrchestrator.cs
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using AutoGen.OpenAI.Extension;
+using OpenAI.Chat;
+
+namespace AutoGen.OpenAI.Orchestrator;
+
+///
+/// Orchestrating group chat using role play tool call
+///
+public partial class RolePlayToolCallOrchestrator : IOrchestrator
+{
+ public readonly ChatClient chatClient;
+ private readonly Graph? workflow;
+
+ public RolePlayToolCallOrchestrator(ChatClient chatClient, Graph? workflow = null)
+ {
+ this.chatClient = chatClient;
+ this.workflow = workflow;
+ }
+
+ public async Task GetNextSpeakerAsync(
+ OrchestrationContext context,
+ CancellationToken cancellationToken = default)
+ {
+ var candidates = context.Candidates.ToList();
+
+ if (candidates.Count == 0)
+ {
+ return null;
+ }
+
+ if (candidates.Count == 1)
+ {
+ return candidates.First();
+ }
+
+ // if there's a workflow
+ // and the next available agent from the workflow is in the group chat
+ // then return the next agent from the workflow
+ if (this.workflow != null)
+ {
+ var lastMessage = context.ChatHistory.LastOrDefault();
+ if (lastMessage == null)
+ {
+ return null;
+ }
+ var currentSpeaker = candidates.First(candidates => candidates.Name == lastMessage.From);
+ var nextAgents = await this.workflow.TransitToNextAvailableAgentsAsync(currentSpeaker, context.ChatHistory, cancellationToken);
+ nextAgents = nextAgents.Where(nextAgent => candidates.Any(candidate => candidate.Name == nextAgent.Name));
+ candidates = nextAgents.ToList();
+ if (!candidates.Any())
+ {
+ return null;
+ }
+
+ if (candidates is { Count: 1 })
+ {
+ return candidates.First();
+ }
+ }
+
+ // In this case, since there are more than one available agents from the workflow for the next speaker
+ // We need to invoke LLM to select the next speaker via select next speaker function
+
+ var chatHistoryStringBuilder = new StringBuilder();
+ foreach (var message in context.ChatHistory)
+ {
+ var chatHistoryPrompt = $"{message.From}: {message.GetContent()}";
+
+ chatHistoryStringBuilder.AppendLine(chatHistoryPrompt);
+ }
+
+ var chatHistory = chatHistoryStringBuilder.ToString();
+
+ var prompt = $"""
+ # Task: Select the next speaker
+
+ You are in a role-play game. Carefully read the conversation history and select the next speaker from the available roles.
+
+ # Conversation
+ {chatHistory}
+
+ # Available roles
+ - {string.Join(",", candidates.Select(candidate => candidate.Name))}
+
+ Select the next speaker from the available roles and provide a reason for your selection.
+ """;
+
+ // enforce the next speaker to be selected by the LLM
+ var option = new ChatCompletionOptions
+ {
+ ToolChoice = ChatToolChoice.CreateFunctionChoice(this.SelectNextSpeakerFunctionContract.Name),
+ };
+
+ option.Tools.Add(this.SelectNextSpeakerFunctionContract.ToChatTool());
+ var toolCallMiddleware = new FunctionCallMiddleware(
+ functions: [this.SelectNextSpeakerFunctionContract],
+ functionMap: new Dictionary>>
+ {
+ [this.SelectNextSpeakerFunctionContract.Name] = this.SelectNextSpeakerWrapper,
+ });
+
+ var selectAgent = new OpenAIChatAgent(
+ chatClient,
+ "admin",
+ option)
+ .RegisterMessageConnector()
+ .RegisterMiddleware(toolCallMiddleware);
+
+ var reply = await selectAgent.SendAsync(prompt);
+
+ var nextSpeaker = candidates.FirstOrDefault(candidate => candidate.Name == reply.GetContent());
+
+ return nextSpeaker;
+ }
+
+ ///
+ /// Select the next speaker by name and reason
+ ///
+ [Function]
+ public async Task SelectNextSpeaker(string name, string reason)
+ {
+ return name;
+ }
+}
diff --git a/dotnet/src/AutoGen.SemanticKernel/Middleware/SemanticKernelChatMessageContentConnector.cs b/dotnet/src/AutoGen.SemanticKernel/Middleware/SemanticKernelChatMessageContentConnector.cs
index 073709ebad09..92947092ba28 100644
--- a/dotnet/src/AutoGen.SemanticKernel/Middleware/SemanticKernelChatMessageContentConnector.cs
+++ b/dotnet/src/AutoGen.SemanticKernel/Middleware/SemanticKernelChatMessageContentConnector.cs
@@ -181,7 +181,19 @@ private IEnumerable ProcessMessageForOthers(TextMessage mess
private IEnumerable ProcessMessageForOthers(ImageMessage message)
{
var collectionItems = new ChatMessageContentItemCollection();
- collectionItems.Add(new ImageContent(new Uri(message.Url ?? message.BuildDataUri())));
+ if (message.Url is not null)
+ {
+ collectionItems.Add(new ImageContent(new Uri(message.Url)));
+ }
+ else if (message.BuildDataUri() is string dataUri)
+ {
+ collectionItems.Add(new ImageContent(dataUri));
+ }
+ else
+ {
+ throw new InvalidOperationException("ImageMessage must have Url or DataUri");
+ }
+
return [new ChatMessageContent(AuthorRole.User, collectionItems)];
}
diff --git a/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentBase.cs b/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentBase.cs
index 14c2688c236a..ee7b9e74583c 100644
--- a/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentBase.cs
+++ b/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentBase.cs
@@ -19,4 +19,5 @@ public interface IAgentBase
Task ReadAsync(AgentId agentId, CancellationToken cancellationToken = default) where T : IMessage, new();
ValueTask PublishEventAsync(CloudEvent item, CancellationToken cancellationToken = default);
ValueTask PublishEventAsync(string topic, IMessage evt, CancellationToken cancellationToken = default);
+ List Subscribe(string topic);
}
diff --git a/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentRuntime.cs b/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentRuntime.cs
index 2125e57a8b96..6b3d4f98cdb2 100644
--- a/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentRuntime.cs
+++ b/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentRuntime.cs
@@ -13,9 +13,10 @@ public interface IAgentRuntime
ValueTask ReadAsync(AgentId agentId, CancellationToken cancellationToken = default);
ValueTask SendResponseAsync(RpcRequest request, RpcResponse response, CancellationToken cancellationToken = default);
ValueTask SendRequestAsync(IAgentBase agent, RpcRequest request, CancellationToken cancellationToken = default);
+ ValueTask SendMessageAsync(Message message, CancellationToken cancellationToken = default);
ValueTask PublishEventAsync(CloudEvent @event, CancellationToken cancellationToken = default);
- void Update(Activity? activity, RpcRequest request);
- void Update(Activity? activity, CloudEvent cloudEvent);
- (string?, string?) GetTraceIDandState(IDictionary metadata);
+ void Update(RpcRequest request, Activity? activity);
+ void Update(CloudEvent cloudEvent, Activity? activity);
+ (string?, string?) GetTraceIdAndState(IDictionary metadata);
IDictionary ExtractMetadata(IDictionary metadata);
}
diff --git a/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentState.cs b/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentState.cs
index 0a6784b54fd3..1b816b4ef3ad 100644
--- a/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentState.cs
+++ b/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentState.cs
@@ -3,8 +3,24 @@
namespace Microsoft.AutoGen.Abstractions;
+///
+/// Interface for managing the state of an agent.
+///
public interface IAgentState
{
- ValueTask ReadStateAsync();
- ValueTask WriteStateAsync(AgentState state, string eTag);
+ ///
+ /// Reads the current state of the agent asynchronously.
+ ///
+ /// A token to cancel the operation.
+ /// A task that represents the asynchronous read operation. The task result contains the current state of the agent.
+ ValueTask ReadStateAsync(CancellationToken cancellationToken = default);
+
+ ///
+ /// Writes the specified state of the agent asynchronously.
+ ///
+ /// The state to write.
+ /// The ETag for concurrency control.
+ /// A token to cancel the operation.
+ /// A task that represents the asynchronous write operation. The task result contains the ETag of the written state.
+ ValueTask WriteStateAsync(AgentState state, string eTag, CancellationToken cancellationToken = default);
}
diff --git a/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentWorker.cs b/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentWorker.cs
index 67a867d87dfa..adce9be60c9e 100644
--- a/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentWorker.cs
+++ b/dotnet/src/Microsoft.AutoGen/Abstractions/IAgentWorker.cs
@@ -8,6 +8,7 @@ public interface IAgentWorker
ValueTask PublishEventAsync(CloudEvent evt, CancellationToken cancellationToken = default);
ValueTask SendRequestAsync(IAgentBase agent, RpcRequest request, CancellationToken cancellationToken = default);
ValueTask SendResponseAsync(RpcResponse response, CancellationToken cancellationToken = default);
+ ValueTask SendMessageAsync(Message message, CancellationToken cancellationToken = default);
ValueTask StoreAsync(AgentState value, CancellationToken cancellationToken = default);
ValueTask ReadAsync(AgentId agentId, CancellationToken cancellationToken = default);
}
diff --git a/dotnet/src/Microsoft.AutoGen/Abstractions/Microsoft.AutoGen.Abstractions.csproj b/dotnet/src/Microsoft.AutoGen/Abstractions/Microsoft.AutoGen.Abstractions.csproj
index e24b52187c82..39a90664057e 100644
--- a/dotnet/src/Microsoft.AutoGen/Abstractions/Microsoft.AutoGen.Abstractions.csproj
+++ b/dotnet/src/Microsoft.AutoGen/Abstractions/Microsoft.AutoGen.Abstractions.csproj
@@ -4,12 +4,10 @@
net8.0enableenable
- AutoGen.Core
- https://github.com/microsoft/agnext
- Microsoft
- AutoGenn Core Library
+
+
@@ -20,8 +18,6 @@
-
-
diff --git a/dotnet/src/Microsoft.AutoGen/AgentHost/Microsoft.AutoGen.AgentHost.csproj b/dotnet/src/Microsoft.AutoGen/AgentHost/Microsoft.AutoGen.AgentHost.csproj
index 254ff1a6c37f..0d3ecef5d5ba 100644
--- a/dotnet/src/Microsoft.AutoGen/AgentHost/Microsoft.AutoGen.AgentHost.csproj
+++ b/dotnet/src/Microsoft.AutoGen/AgentHost/Microsoft.AutoGen.AgentHost.csproj
@@ -12,7 +12,7 @@
-
+
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/AgentBase.cs b/dotnet/src/Microsoft.AutoGen/Agents/AgentBase.cs
index f73894978fc8..545734b50575 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/AgentBase.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/AgentBase.cs
@@ -15,27 +15,40 @@ namespace Microsoft.AutoGen.Agents;
public abstract class AgentBase : IAgentBase, IHandle
{
public static readonly ActivitySource s_source = new("AutoGen.Agent");
- public AgentId AgentId => _context.AgentId;
+ public AgentId AgentId => _runtime.AgentId;
private readonly object _lock = new();
private readonly Dictionary> _pendingRequests = [];
private readonly Channel
+
+
+
-
+
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/AgentWorker.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/AgentWorker.cs
index 490051490315..f9a5050534c8 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/AgentWorker.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/AgentWorker.cs
@@ -24,6 +24,8 @@ public class AgentWorker :
private readonly CancellationTokenSource _shutdownCts;
private readonly IServiceProvider _serviceProvider;
private readonly IEnumerable> _configuredAgentTypes;
+ private readonly ConcurrentDictionary _subscriptionsByAgentType = new();
+ private readonly ConcurrentDictionary> _subscriptionsByTopic = new();
private readonly DistributedContextPropagator _distributedContextPropagator;
private readonly CancellationTokenSource _shutdownCancellationToken = new();
private Task? _mailboxTask;
@@ -47,7 +49,7 @@ public async ValueTask PublishEventAsync(CloudEvent cloudEvent, CancellationToke
{
foreach (var (typeName, _) in _agentTypes)
{
- if (typeName == "Client") { continue; }
+ if (typeName == nameof(Client)) { continue; }
var agent = GetOrActivateAgent(new AgentId(typeName, cloudEvent.Source));
agent.ReceiveMessage(new Message { CloudEvent = cloudEvent });
}
@@ -63,6 +65,10 @@ public ValueTask SendResponseAsync(RpcResponse response, CancellationToken cance
{
return _mailbox.Writer.WriteAsync(new Message { Response = response }, cancellationToken);
}
+ public ValueTask SendMessageAsync(Message message, CancellationToken cancellationToken = default)
+ {
+ return _mailbox.Writer.WriteAsync(message, cancellationToken);
+ }
public ValueTask StoreAsync(AgentState value, CancellationToken cancellationToken = default)
{
var agentId = value.AgentId ?? throw new InvalidOperationException("AgentId is required when saving AgentState.");
@@ -92,7 +98,7 @@ public async Task RunMessagePump()
if (message == null) { continue; }
switch (message)
{
- case Message msg:
+ case Message msg when msg.CloudEvent != null:
var item = msg.CloudEvent;
@@ -102,6 +108,13 @@ public async Task RunMessagePump()
agentToInvoke.ReceiveMessage(msg);
}
break;
+ case Message msg when msg.AddSubscriptionRequest != null:
+ await AddSubscriptionRequestAsync(msg.AddSubscriptionRequest).ConfigureAwait(true);
+ break;
+ case Message msg when msg.AddSubscriptionResponse != null:
+ break;
+ case Message msg when msg.RegisterAgentTypeResponse != null:
+ break;
default:
throw new InvalidOperationException($"Unexpected message '{message}'.");
}
@@ -115,6 +128,23 @@ public async Task RunMessagePump()
}
}
}
+ private async ValueTask AddSubscriptionRequestAsync(AddSubscriptionRequest subscription)
+ {
+ var topic = subscription.Subscription.TypeSubscription.TopicType;
+ var agentType = subscription.Subscription.TypeSubscription.AgentType;
+ _subscriptionsByAgentType[agentType] = subscription.Subscription;
+ _subscriptionsByTopic.GetOrAdd(topic, _ => []).Add(agentType);
+ Message response = new()
+ {
+ AddSubscriptionResponse = new()
+ {
+ RequestId = subscription.RequestId,
+ Error = "",
+ Success = true
+ }
+ };
+ await _mailbox.Writer.WriteAsync(response).ConfigureAwait(false);
+ }
public async Task StartAsync(CancellationToken cancellationToken)
{
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/AgentWorkerHostingExtensions.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/AgentWorkerHostingExtensions.cs
index c1bf57e2df68..2b578d9bff2e 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/AgentWorkerHostingExtensions.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/AgentWorkerHostingExtensions.cs
@@ -41,6 +41,7 @@ public static WebApplicationBuilder AddLocalAgentService(this WebApplicationBuil
{
return builder.AddAgentService(local: true, useGrpc);
}
+
public static WebApplication MapAgentService(this WebApplication app, bool local = false, bool useGrpc = true)
{
if (useGrpc) { app.MapGrpcService(); }
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcAgentWorker.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcAgentWorker.cs
index 431a5629c142..48f07573430d 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcAgentWorker.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcAgentWorker.cs
@@ -85,6 +85,13 @@ private async Task RunReadPump()
}
break;
+ case Message.MessageOneofCase.AddSubscriptionResponse:
+ if (!message.AddSubscriptionResponse.Success)
+ {
+ throw new InvalidOperationException($"Failed to add subscription: '{message.AddSubscriptionResponse.Error}'.");
+ }
+ break;
+
case Message.MessageOneofCase.CloudEvent:
// HACK: Send the message to an instance of each agent type
@@ -153,6 +160,13 @@ private async Task RunWritePump()
item.WriteCompletionSource?.TrySetCanceled();
break;
}
+ catch (RpcException ex) when (ex.StatusCode == StatusCode.Unavailable)
+ {
+ // we could not connect to the endpoint - most likely we have the wrong port or failed ssl
+ // we need to let the user know what port we tried to connect to and then do backoff and retry
+ _logger.LogError(ex, "Error connecting to GRPC endpoint {Endpoint}.", channel.ToString());
+ break;
+ }
catch (Exception ex) when (!_shutdownCts.IsCancellationRequested)
{
item.WriteCompletionSource?.TrySetException(ex);
@@ -230,6 +244,11 @@ await WriteChannelAsync(new Message
await WriteChannelAsync(new Message { Request = request }, cancellationToken).ConfigureAwait(false);
}
// new is intentional
+ public new async ValueTask SendMessageAsync(Message message, CancellationToken cancellationToken = default)
+ {
+ await WriteChannelAsync(message, cancellationToken).ConfigureAwait(false);
+ }
+ // new is intentional
public new async ValueTask PublishEventAsync(CloudEvent @event, CancellationToken cancellationToken = default)
{
await WriteChannelAsync(new Message { CloudEvent = @event }, cancellationToken).ConfigureAwait(false);
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcAgentWorkerHostBuilderExtension.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcAgentWorkerHostBuilderExtension.cs
index 4c63601dfaa6..4f214caa8203 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcAgentWorkerHostBuilderExtension.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcAgentWorkerHostBuilderExtension.cs
@@ -11,12 +11,12 @@ namespace Microsoft.AutoGen.Agents;
public static class GrpcAgentWorkerHostBuilderExtensions
{
- private const string _defaultAgentServiceAddress = "https://localhost:5001";
- public static IHostApplicationBuilder AddGrpcAgentWorker(this IHostApplicationBuilder builder, string agentServiceAddress = _defaultAgentServiceAddress)
+ private const string _defaultAgentServiceAddress = "https://localhost:53071";
+ public static IHostApplicationBuilder AddGrpcAgentWorker(this IHostApplicationBuilder builder, string? agentServiceAddress = null)
{
builder.Services.AddGrpcClient(options =>
{
- options.Address = new Uri(agentServiceAddress);
+ options.Address = new Uri(agentServiceAddress ?? builder.Configuration["AGENT_HOST"] ?? _defaultAgentServiceAddress);
options.ChannelOptionsActions.Add(channelOptions =>
{
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcGateway.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcGateway.cs
index 89e9c55c4648..ab24a0e15fe5 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcGateway.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcGateway.cs
@@ -16,10 +16,13 @@ public sealed class GrpcGateway : BackgroundService, IGateway
private readonly IClusterClient _clusterClient;
private readonly ConcurrentDictionary _agentState = new();
private readonly IRegistryGrain _gatewayRegistry;
+ private readonly ISubscriptionsGrain _subscriptions;
private readonly IGateway _reference;
// The agents supported by each worker process.
private readonly ConcurrentDictionary> _supportedAgentTypes = [];
public readonly ConcurrentDictionary _workers = new();
+ private readonly ConcurrentDictionary _subscriptionsByAgentType = new();
+ private readonly ConcurrentDictionary> _subscriptionsByTopic = new();
// The mapping from agent id to worker process.
private readonly ConcurrentDictionary<(string Type, string Key), GrpcWorkerConnection> _agentDirectory = new();
@@ -33,6 +36,7 @@ public GrpcGateway(IClusterClient clusterClient, ILogger logger)
_clusterClient = clusterClient;
_reference = clusterClient.CreateObjectReference(this);
_gatewayRegistry = clusterClient.GetGrain(0);
+ _subscriptions = clusterClient.GetGrain(0);
}
public async ValueTask BroadcastEvent(CloudEvent evt)
{
@@ -102,16 +106,70 @@ internal async Task OnReceivedMessageAsync(GrpcWorkerConnection connection, Mess
case Message.MessageOneofCase.RegisterAgentTypeRequest:
await RegisterAgentTypeAsync(connection, message.RegisterAgentTypeRequest);
break;
+ case Message.MessageOneofCase.AddSubscriptionRequest:
+ await AddSubscriptionAsync(connection, message.AddSubscriptionRequest);
+ break;
default:
- throw new InvalidOperationException($"Unknown message type for message '{message}'.");
+ // if it wasn't recognized return bad request
+ await RespondBadRequestAsync(connection, $"Unknown message type for message '{message}'.");
+ break;
+ };
+ }
+ private async ValueTask RespondBadRequestAsync(GrpcWorkerConnection connection, string error)
+ {
+ throw new RpcException(new Status(StatusCode.InvalidArgument, error));
+ }
+ private async ValueTask AddSubscriptionAsync(GrpcWorkerConnection connection, AddSubscriptionRequest request)
+ {
+ var topic = request.Subscription.TypeSubscription.TopicType;
+ var agentType = request.Subscription.TypeSubscription.AgentType;
+ _subscriptionsByAgentType[agentType] = request.Subscription;
+ _subscriptionsByTopic.GetOrAdd(topic, _ => []).Add(agentType);
+ await _subscriptions.Subscribe(topic, agentType);
+ //var response = new AddSubscriptionResponse { RequestId = request.RequestId, Error = "", Success = true };
+ Message response = new()
+ {
+ AddSubscriptionResponse = new()
+ {
+ RequestId = request.RequestId,
+ Error = "",
+ Success = true
+ }
};
+ await connection.ResponseStream.WriteAsync(response).ConfigureAwait(false);
}
private async ValueTask RegisterAgentTypeAsync(GrpcWorkerConnection connection, RegisterAgentTypeRequest msg)
{
connection.AddSupportedType(msg.Type);
_supportedAgentTypes.GetOrAdd(msg.Type, _ => []).Add(connection);
- await _gatewayRegistry.RegisterAgentType(msg.Type, _reference);
+ await _gatewayRegistry.RegisterAgentType(msg.Type, _reference).ConfigureAwait(true);
+ Message response = new()
+ {
+ RegisterAgentTypeResponse = new()
+ {
+ RequestId = msg.RequestId,
+ Error = "",
+ Success = true
+ }
+ };
+ // add a default subscription for the agent type
+ //TODO: we should consider having constraints on the namespace or at least migrate all our examples to use well typed namesspaces like com.microsoft.autogen/hello/HelloAgents etc
+ var subscriptionRequest = new AddSubscriptionRequest
+ {
+ RequestId = Guid.NewGuid().ToString(),
+ Subscription = new Subscription
+ {
+ TypeSubscription = new TypeSubscription
+ {
+ AgentType = msg.Type,
+ TopicType = msg.Type
+ }
+ }
+ };
+ await AddSubscriptionAsync(connection, subscriptionRequest).ConfigureAwait(true);
+
+ await connection.ResponseStream.WriteAsync(response).ConfigureAwait(false);
}
private async ValueTask DispatchEventAsync(CloudEvent evt)
{
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Host.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Host.cs
index 5b725af0c9a9..464536d54b21 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/Host.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Host.cs
@@ -14,11 +14,11 @@ public static async Task StartAsync(bool local = false, bool use
builder.AddServiceDefaults();
if (local)
{
- builder.AddLocalAgentService(useGrpc);
+ builder.AddLocalAgentService(useGrpc: useGrpc);
}
else
{
- builder.AddAgentService(useGrpc);
+ builder.AddAgentService(useGrpc: useGrpc);
}
var app = builder.Build();
app.MapAgentService(local, useGrpc);
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/HostBuilderExtensions.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/HostBuilderExtensions.cs
index c3f8a1e38bfd..2b69a983340b 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/HostBuilderExtensions.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/HostBuilderExtensions.cs
@@ -15,9 +15,25 @@ namespace Microsoft.AutoGen.Agents;
public static class HostBuilderExtensions
{
- private const string _defaultAgentServiceAddress = "https://localhost:5001";
- public static AgentApplicationBuilder AddAgentWorker(this IHostApplicationBuilder builder, string agentServiceAddress = _defaultAgentServiceAddress, bool local = false)
+ private const string _defaultAgentServiceAddress = "https://localhost:53071";
+
+ public static IHostApplicationBuilder AddAgent<
+ [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TAgent>(this IHostApplicationBuilder builder, string typeName) where TAgent : AgentBase
+ {
+ builder.Services.AddKeyedSingleton("AgentTypes", (sp, key) => Tuple.Create(typeName, typeof(TAgent)));
+
+ return builder;
+ }
+
+ public static IHostApplicationBuilder AddAgent(this IHostApplicationBuilder builder, string typeName, Type agentType)
{
+ builder.Services.AddKeyedSingleton("AgentTypes", (sp, key) => Tuple.Create(typeName, agentType));
+ return builder;
+ }
+
+ public static IHostApplicationBuilder AddAgentWorker(this IHostApplicationBuilder builder, string? agentServiceAddress = null, bool local = false)
+ {
+ agentServiceAddress ??= builder.Configuration["AGENT_HOST"] ?? _defaultAgentServiceAddress;
builder.Services.TryAddSingleton(DistributedContextPropagator.Current);
// if !local, then add the gRPC client
@@ -106,7 +122,9 @@ public static AgentApplicationBuilder AddAgentWorker(this IHostApplicationBuilde
return new EventTypes(typeRegistry, types, eventsForType, typesForEvents);
});
builder.Services.AddSingleton();
- return new AgentApplicationBuilder(builder);
+ builder.Services.AddSingleton(new AgentApplicationBuilder(builder));
+
+ return builder;
}
private static MessageDescriptor? GetMessageDescriptor(Type type)
diff --git a/dotnet/src/Microsoft.AutoGen/Abstractions/IGateway.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/IGateway.cs
similarity index 84%
rename from dotnet/src/Microsoft.AutoGen/Abstractions/IGateway.cs
rename to dotnet/src/Microsoft.AutoGen/Agents/Services/IGateway.cs
index 79b7b63e7235..539ec3eca435 100644
--- a/dotnet/src/Microsoft.AutoGen/Abstractions/IGateway.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/IGateway.cs
@@ -1,7 +1,8 @@
// Copyright (c) Microsoft Corporation. All rights reserved.
// IGateway.cs
+using Microsoft.AutoGen.Abstractions;
-namespace Microsoft.AutoGen.Abstractions;
+namespace Microsoft.AutoGen.Agents;
public interface IGateway : IGrainObserver
{
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/AgentStateGrain.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/AgentStateGrain.cs
index 50d8c3ad4542..9905f6aebac6 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/AgentStateGrain.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/AgentStateGrain.cs
@@ -7,7 +7,8 @@ namespace Microsoft.AutoGen.Agents;
internal sealed class AgentStateGrain([PersistentState("state", "AgentStateStore")] IPersistentState state) : Grain, IAgentState
{
- public async ValueTask WriteStateAsync(AgentState newState, string eTag)
+ ///
+ public async ValueTask WriteStateAsync(AgentState newState, string eTag, CancellationToken cancellationToken = default)
{
// etags for optimistic concurrency control
// if the Etag is null, its a new state
@@ -27,7 +28,8 @@ public async ValueTask WriteStateAsync(AgentState newState, string eTag)
return state.Etag;
}
- public ValueTask ReadStateAsync()
+ ///
+ public ValueTask ReadStateAsync(CancellationToken cancellationToken = default)
{
return ValueTask.FromResult(state.State);
}
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/ISubscriptionsGrain.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/ISubscriptionsGrain.cs
new file mode 100644
index 000000000000..302df9ebff98
--- /dev/null
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/ISubscriptionsGrain.cs
@@ -0,0 +1,10 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// ISubscriptionsGrain.cs
+
+namespace Microsoft.AutoGen.Agents;
+public interface ISubscriptionsGrain : IGrainWithIntegerKey
+{
+ ValueTask Subscribe(string agentType, string topic);
+ ValueTask Unsubscribe(string agentType, string topic);
+ ValueTask>> GetSubscriptions(string agentType);
+}
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/OrleansRuntimeHostingExtenions.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/OrleansRuntimeHostingExtenions.cs
index cd59bcefc385..374e49f7a500 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/OrleansRuntimeHostingExtenions.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/OrleansRuntimeHostingExtenions.cs
@@ -15,11 +15,17 @@ public static class OrleansRuntimeHostingExtenions
{
public static WebApplicationBuilder AddOrleans(this WebApplicationBuilder builder, bool local = false)
{
+ return builder.AddOrleans(local);
+ }
+ public static IHostApplicationBuilder AddOrleans(this IHostApplicationBuilder builder, bool local = false)
+ {
builder.Services.AddSerializer(serializer => serializer.AddProtobufSerializer());
+ builder.Services.AddSingleton();
+
// Ensure Orleans is added before the hosted service to guarantee that it starts first.
//TODO: make all of this configurable
- builder.Host.UseOrleans(siloBuilder =>
+ builder.UseOrleans((siloBuilder) =>
{
// Development mode or local mode uses in-memory storage and streams
if (builder.Environment.IsDevelopment() || local)
@@ -51,16 +57,16 @@ public static WebApplicationBuilder AddOrleans(this WebApplicationBuilder builde
options.SystemResponseTimeout = TimeSpan.FromMinutes(3);
});
siloBuilder.Configure(options =>
- {
- options.ResponseTimeout = TimeSpan.FromMinutes(3);
- });
+ {
+ options.ResponseTimeout = TimeSpan.FromMinutes(3);
+ });
siloBuilder.UseCosmosClustering(o =>
- {
- o.ConfigureCosmosClient(cosmosDbconnectionString);
- o.ContainerName = "AutoGen";
- o.DatabaseName = "clustering";
- o.IsResourceCreationEnabled = true;
- });
+ {
+ o.ConfigureCosmosClient(cosmosDbconnectionString);
+ o.ContainerName = "AutoGen";
+ o.DatabaseName = "clustering";
+ o.IsResourceCreationEnabled = true;
+ });
siloBuilder.UseCosmosReminderService(o =>
{
@@ -84,7 +90,7 @@ public static WebApplicationBuilder AddOrleans(this WebApplicationBuilder builde
.AddMemoryGrainStorage("PubSubStore");
}
});
- builder.Services.AddSingleton();
+
return builder;
}
}
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/RegistryGrain.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/RegistryGrain.cs
index c5114e3e7423..cb7523126436 100644
--- a/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/RegistryGrain.cs
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/RegistryGrain.cs
@@ -5,7 +5,7 @@
namespace Microsoft.AutoGen.Agents;
-public sealed class RegistryGrain : Grain, IRegistryGrain
+internal sealed class RegistryGrain : Grain, IRegistryGrain
{
// TODO: use persistent state for some of these or (better) extend Orleans to implement some of this natively.
private readonly Dictionary _workerStates = new();
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/SubscriptionsGrain.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/SubscriptionsGrain.cs
new file mode 100644
index 000000000000..682073f0b97c
--- /dev/null
+++ b/dotnet/src/Microsoft.AutoGen/Agents/Services/Orleans/SubscriptionsGrain.cs
@@ -0,0 +1,53 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// SubscriptionsGrain.cs
+
+namespace Microsoft.AutoGen.Agents;
+
+internal sealed class SubscriptionsGrain([PersistentState("state", "PubSubStore")] IPersistentState state) : Grain, ISubscriptionsGrain
+{
+ private readonly Dictionary> _subscriptions = new();
+ public ValueTask>> GetSubscriptions(string? agentType = null)
+ {
+ //if agentType is null, return all subscriptions else filter on agentType
+ if (agentType != null)
+ {
+ return new ValueTask>>(_subscriptions.Where(x => x.Value.Contains(agentType)).ToDictionary(x => x.Key, x => x.Value));
+ }
+ return new ValueTask>>(_subscriptions);
+ }
+ public ValueTask Subscribe(string agentType, string topic)
+ {
+ if (!_subscriptions.TryGetValue(topic, out var subscriptions))
+ {
+ subscriptions = _subscriptions[topic] = [];
+ }
+ if (!subscriptions.Contains(agentType))
+ {
+ subscriptions.Add(agentType);
+ }
+ _subscriptions[topic] = subscriptions;
+ state.State.Subscriptions = _subscriptions;
+ state.WriteStateAsync();
+
+ return ValueTask.CompletedTask;
+ }
+ public ValueTask Unsubscribe(string agentType, string topic)
+ {
+ if (!_subscriptions.TryGetValue(topic, out var subscriptions))
+ {
+ subscriptions = _subscriptions[topic] = [];
+ }
+ if (!subscriptions.Contains(agentType))
+ {
+ subscriptions.Remove(agentType);
+ }
+ _subscriptions[topic] = subscriptions;
+ state.State.Subscriptions = _subscriptions;
+ state.WriteStateAsync();
+ return ValueTask.CompletedTask;
+ }
+}
+public sealed class SubscriptionsState
+{
+ public Dictionary> Subscriptions { get; set; } = new();
+}
diff --git a/dotnet/src/Microsoft.AutoGen/Extensions/ServiceDefaults/Extensions.cs b/dotnet/src/Microsoft.AutoGen/Extensions/Aspire/AspireHostingExtensions.cs
similarity index 98%
rename from dotnet/src/Microsoft.AutoGen/Extensions/ServiceDefaults/Extensions.cs
rename to dotnet/src/Microsoft.AutoGen/Extensions/Aspire/AspireHostingExtensions.cs
index d69a0c6862b0..b43eb459625e 100644
--- a/dotnet/src/Microsoft.AutoGen/Extensions/ServiceDefaults/Extensions.cs
+++ b/dotnet/src/Microsoft.AutoGen/Extensions/Aspire/AspireHostingExtensions.cs
@@ -1,5 +1,5 @@
// Copyright (c) Microsoft Corporation. All rights reserved.
-// Extensions.cs
+// AspireHostingExtensions.cs
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Diagnostics.HealthChecks;
@@ -15,7 +15,7 @@ namespace Microsoft.Extensions.Hosting;
// Adds common .NET Aspire services: service discovery, resilience, health checks, and OpenTelemetry.
// This project should be referenced by each service project in your solution.
// To learn more about using this project, see https://aka.ms/dotnet/aspire/service-defaults
-public static class Extensions
+public static class AspireHostingExtensions
{
public static IHostApplicationBuilder AddServiceDefaults(this IHostApplicationBuilder builder)
{
diff --git a/dotnet/src/Microsoft.AutoGen/Extensions/ServiceDefaults/Microsoft.AutoGen.ServiceDefaults.csproj b/dotnet/src/Microsoft.AutoGen/Extensions/Aspire/Microsoft.AutoGen.Extensions.Aspire.csproj
similarity index 93%
rename from dotnet/src/Microsoft.AutoGen/Extensions/ServiceDefaults/Microsoft.AutoGen.ServiceDefaults.csproj
rename to dotnet/src/Microsoft.AutoGen/Extensions/Aspire/Microsoft.AutoGen.Extensions.Aspire.csproj
index cf2446f93349..0cab61bc27b6 100644
--- a/dotnet/src/Microsoft.AutoGen/Extensions/ServiceDefaults/Microsoft.AutoGen.ServiceDefaults.csproj
+++ b/dotnet/src/Microsoft.AutoGen/Extensions/Aspire/Microsoft.AutoGen.Extensions.Aspire.csproj
@@ -5,6 +5,9 @@
enabletrue
+
+
+
diff --git a/dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/AIModelClientHostingExtensions.cs b/dotnet/src/Microsoft.AutoGen/Extensions/MEAI/MEAIHostingExtensions.cs
similarity index 94%
rename from dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/AIModelClientHostingExtensions.cs
rename to dotnet/src/Microsoft.AutoGen/Extensions/MEAI/MEAIHostingExtensions.cs
index c3c9c197392d..d39f358f8cbe 100644
--- a/dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/AIModelClientHostingExtensions.cs
+++ b/dotnet/src/Microsoft.AutoGen/Extensions/MEAI/MEAIHostingExtensions.cs
@@ -1,11 +1,11 @@
// Copyright (c) Microsoft Corporation. All rights reserved.
-// AIModelClientHostingExtensions.cs
+// MEAIHostingExtensions.cs
using Microsoft.Extensions.AI;
namespace Microsoft.Extensions.Hosting;
-public static class AIModelClient
+public static class MEAIHostingExtensions
{
public static IHostApplicationBuilder AddChatCompletionService(this IHostApplicationBuilder builder, string serviceName)
{
diff --git a/dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/AIModelClientHostingExtensions.csproj b/dotnet/src/Microsoft.AutoGen/Extensions/MEAI/Microsoft.AutoGen.Extensions.MEAI.csproj
similarity index 87%
rename from dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/AIModelClientHostingExtensions.csproj
rename to dotnet/src/Microsoft.AutoGen/Extensions/MEAI/Microsoft.AutoGen.Extensions.MEAI.csproj
index 2358351deb6c..b8233a8e6c50 100644
--- a/dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/AIModelClientHostingExtensions.csproj
+++ b/dotnet/src/Microsoft.AutoGen/Extensions/MEAI/Microsoft.AutoGen.Extensions.MEAI.csproj
@@ -4,6 +4,9 @@
enableenable
+
+
+
@@ -14,6 +17,6 @@
-
+
diff --git a/dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/Options/AIClientOptions.cs b/dotnet/src/Microsoft.AutoGen/Extensions/MEAI/Options/AIClientOptions.cs
similarity index 100%
rename from dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/Options/AIClientOptions.cs
rename to dotnet/src/Microsoft.AutoGen/Extensions/MEAI/Options/AIClientOptions.cs
diff --git a/dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/ServiceCollectionChatCompletionExtensions.cs b/dotnet/src/Microsoft.AutoGen/Extensions/MEAI/ServiceCollectionChatCompletionExtensions.cs
similarity index 100%
rename from dotnet/src/Microsoft.AutoGen/Extensions/AIModelClientHostingExtensions/ServiceCollectionChatCompletionExtensions.cs
rename to dotnet/src/Microsoft.AutoGen/Extensions/MEAI/ServiceCollectionChatCompletionExtensions.cs
diff --git a/dotnet/src/Microsoft.AutoGen/Extensions/SemanticKernel/Microsoft.AutoGen.Extensions.SemanticKernel.csproj b/dotnet/src/Microsoft.AutoGen/Extensions/SemanticKernel/Microsoft.AutoGen.Extensions.SemanticKernel.csproj
index fb47750fd44d..c4ac5536e70c 100644
--- a/dotnet/src/Microsoft.AutoGen/Extensions/SemanticKernel/Microsoft.AutoGen.Extensions.SemanticKernel.csproj
+++ b/dotnet/src/Microsoft.AutoGen/Extensions/SemanticKernel/Microsoft.AutoGen.Extensions.SemanticKernel.csproj
@@ -1,22 +1,23 @@
-
-
-
-
-
-
net8.0enableenable
-
-
-
+
+
+
+
+
+
+
+
+
+
diff --git a/dotnet/test/AutoGen.AotCompatibility.Tests/AutoGen.AotCompatibility.Tests.csproj b/dotnet/test/AutoGen.AotCompatibility.Tests/AutoGen.AotCompatibility.Tests.csproj
index aec9660bb922..379bca541012 100644
--- a/dotnet/test/AutoGen.AotCompatibility.Tests/AutoGen.AotCompatibility.Tests.csproj
+++ b/dotnet/test/AutoGen.AotCompatibility.Tests/AutoGen.AotCompatibility.Tests.csproj
@@ -2,7 +2,7 @@
Exe
- net8.0
+ net8.0enableenabletrue
diff --git a/dotnet/test/AutoGen.OpenAI.Tests/RolePlayToolCallOrchestratorTests.cs b/dotnet/test/AutoGen.OpenAI.Tests/RolePlayToolCallOrchestratorTests.cs
new file mode 100644
index 000000000000..807bf41e9479
--- /dev/null
+++ b/dotnet/test/AutoGen.OpenAI.Tests/RolePlayToolCallOrchestratorTests.cs
@@ -0,0 +1,269 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// RolePlayToolCallOrchestratorTests.cs
+
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using AutoGen.OpenAI.Orchestrator;
+using AutoGen.Tests;
+using Azure.AI.OpenAI;
+using FluentAssertions;
+using Moq;
+using OpenAI;
+using OpenAI.Chat;
+using Xunit;
+
+namespace AutoGen.OpenAI.Tests;
+
+public class RolePlayToolCallOrchestratorTests
+{
+ [Fact]
+ public async Task ItReturnNullWhenNoCandidateIsAvailableAsync()
+ {
+ var chatClient = Mock.Of();
+ var orchestrator = new RolePlayToolCallOrchestrator(chatClient);
+ var context = new OrchestrationContext
+ {
+ Candidates = [],
+ ChatHistory = [],
+ };
+
+ var speaker = await orchestrator.GetNextSpeakerAsync(context);
+ speaker.Should().BeNull();
+ }
+
+ [Fact]
+ public async Task ItReturnCandidateWhenOnlyOneCandidateIsAvailableAsync()
+ {
+ var chatClient = Mock.Of();
+ var alice = new EchoAgent("Alice");
+ var orchestrator = new RolePlayToolCallOrchestrator(chatClient);
+ var context = new OrchestrationContext
+ {
+ Candidates = [alice],
+ ChatHistory = [],
+ };
+
+ var speaker = await orchestrator.GetNextSpeakerAsync(context);
+ speaker.Should().Be(alice);
+ }
+
+ [Fact]
+ public async Task ItSelectNextSpeakerFromWorkflowIfProvided()
+ {
+ var workflow = new Graph();
+ var alice = new EchoAgent("Alice");
+ var bob = new EchoAgent("Bob");
+ var charlie = new EchoAgent("Charlie");
+ workflow.AddTransition(Transition.Create(alice, bob));
+ workflow.AddTransition(Transition.Create(bob, charlie));
+ workflow.AddTransition(Transition.Create(charlie, alice));
+
+ var client = Mock.Of();
+ var orchestrator = new RolePlayToolCallOrchestrator(client, workflow);
+ var context = new OrchestrationContext
+ {
+ Candidates = [alice, bob, charlie],
+ ChatHistory =
+ [
+ new TextMessage(Role.User, "Hello, Bob", from: "Alice"),
+ ],
+ };
+
+ var speaker = await orchestrator.GetNextSpeakerAsync(context);
+ speaker.Should().Be(bob);
+ }
+
+ [Fact]
+ public async Task ItReturnNullIfNoAvailableAgentFromWorkflowAsync()
+ {
+ var workflow = new Graph();
+ var alice = new EchoAgent("Alice");
+ var bob = new EchoAgent("Bob");
+ workflow.AddTransition(Transition.Create(alice, bob));
+
+ var client = Mock.Of();
+ var orchestrator = new RolePlayToolCallOrchestrator(client, workflow);
+ var context = new OrchestrationContext
+ {
+ Candidates = [alice, bob],
+ ChatHistory =
+ [
+ new TextMessage(Role.User, "Hello, Alice", from: "Bob"),
+ ],
+ };
+
+ var speaker = await orchestrator.GetNextSpeakerAsync(context);
+ speaker.Should().BeNull();
+ }
+
+ [ApiKeyFact("AZURE_OPENAI_API_KEY", "AZURE_OPENAI_ENDPOINT", "AZURE_OPENAI_DEPLOY_NAME")]
+ public async Task GPT_3_5_CoderReviewerRunnerTestAsync()
+ {
+ var endpoint = Environment.GetEnvironmentVariable("AZURE_OPENAI_ENDPOINT") ?? throw new Exception("Please set AZURE_OPENAI_ENDPOINT environment variable.");
+ var key = Environment.GetEnvironmentVariable("AZURE_OPENAI_API_KEY") ?? throw new Exception("Please set AZURE_OPENAI_API_KEY environment variable.");
+ var deployName = Environment.GetEnvironmentVariable("AZURE_OPENAI_DEPLOY_NAME") ?? throw new Exception("Please set AZURE_OPENAI_DEPLOY_NAME environment variable.");
+ var openaiClient = new AzureOpenAIClient(new Uri(endpoint), new System.ClientModel.ApiKeyCredential(key));
+ var chatClient = openaiClient.GetChatClient(deployName);
+
+ await BusinessWorkflowTest(chatClient);
+ await CoderReviewerRunnerTestAsync(chatClient);
+ }
+
+ [ApiKeyFact("OPENAI_API_KEY")]
+ public async Task GPT_4o_CoderReviewerRunnerTestAsync()
+ {
+ var apiKey = Environment.GetEnvironmentVariable("OPENAI_API_KEY") ?? throw new InvalidOperationException("OPENAI_API_KEY is not set");
+ var model = "gpt-4o";
+ var openaiClient = new OpenAIClient(apiKey);
+ var chatClient = openaiClient.GetChatClient(model);
+
+ await BusinessWorkflowTest(chatClient);
+ await CoderReviewerRunnerTestAsync(chatClient);
+ }
+
+ [ApiKeyFact("OPENAI_API_KEY")]
+ public async Task GPT_4o_mini_CoderReviewerRunnerTestAsync()
+ {
+ var apiKey = Environment.GetEnvironmentVariable("OPENAI_API_KEY") ?? throw new InvalidOperationException("OPENAI_API_KEY is not set");
+ var model = "gpt-4o-mini";
+ var openaiClient = new OpenAIClient(apiKey);
+ var chatClient = openaiClient.GetChatClient(model);
+
+ await BusinessWorkflowTest(chatClient);
+ await CoderReviewerRunnerTestAsync(chatClient);
+ }
+
+ ///
+ /// This test is to mimic the conversation among coder, reviewer and runner.
+ /// The coder will write the code, the reviewer will review the code, and the runner will run the code.
+ ///
+ ///
+ ///
+ private async Task CoderReviewerRunnerTestAsync(ChatClient client)
+ {
+ var coder = new EchoAgent("Coder");
+ var reviewer = new EchoAgent("Reviewer");
+ var runner = new EchoAgent("Runner");
+ var user = new EchoAgent("User");
+ var initializeMessage = new List
+ {
+ new TextMessage(Role.User, "Hello, I am user, I will provide the coding task, please write the code first, then review and run it", from: "User"),
+ new TextMessage(Role.User, "Hello, I am coder, I will write the code", from: "Coder"),
+ new TextMessage(Role.User, "Hello, I am reviewer, I will review the code", from: "Reviewer"),
+ new TextMessage(Role.User, "Hello, I am runner, I will run the code", from: "Runner"),
+ new TextMessage(Role.User, "how to print 'hello world' using C#", from: user.Name),
+ };
+
+ var chatHistory = new List()
+ {
+ new TextMessage(Role.User, """
+ ```csharp
+ Console.WriteLine("Hello World");
+ ```
+ """, from: coder.Name),
+ new TextMessage(Role.User, "The code looks good", from: reviewer.Name),
+ new TextMessage(Role.User, "The code runs successfully, the output is 'Hello World'", from: runner.Name),
+ };
+
+ var orchestrator = new RolePlayToolCallOrchestrator(client);
+ foreach (var message in chatHistory)
+ {
+ var context = new OrchestrationContext
+ {
+ Candidates = [coder, reviewer, runner, user],
+ ChatHistory = initializeMessage,
+ };
+
+ var speaker = await orchestrator.GetNextSpeakerAsync(context);
+ speaker!.Name.Should().Be(message.From);
+ initializeMessage.Add(message);
+ }
+
+ // the last next speaker should be the user
+ var lastSpeaker = await orchestrator.GetNextSpeakerAsync(new OrchestrationContext
+ {
+ Candidates = [coder, reviewer, runner, user],
+ ChatHistory = initializeMessage,
+ });
+
+ lastSpeaker!.Name.Should().Be(user.Name);
+ }
+
+ // test if the tool call orchestrator still run business workflow when the conversation is not in English
+ private async Task BusinessWorkflowTest(ChatClient client)
+ {
+ var ceo = new EchoAgent("乙方首席执行官");
+ var pm = new EchoAgent("乙方项目经理");
+ var dev = new EchoAgent("乙方开发人员");
+ var user = new EchoAgent("甲方");
+ var initializeMessage = new List
+ {
+ new TextMessage(Role.User, "你好，我是你们的甲方", from: user.Name),
+ new TextMessage(Role.User, "你好，我是乙方首席执行官，我将负责对接甲方和给项目经理及开发人员分配任务", from: ceo.Name),
+ new TextMessage(Role.User, "你好，我是乙方项目经理，我将负责项目的进度和质量", from: pm.Name),
+ new TextMessage(Role.User, "你好，我是乙方开发人员 我将负责项目的具体开发", from: dev.Name),
+ new TextMessage(Role.User, "开发一个淘宝，预算1W", from: user.Name),
+ };
+
+ var workflow = new Graph();
+ workflow.AddTransition(Transition.Create(ceo, pm));
+ workflow.AddTransition(Transition.Create(ceo, dev));
+ workflow.AddTransition(Transition.Create(pm, ceo));
+ workflow.AddTransition(Transition.Create(dev, ceo));
+ workflow.AddTransition(Transition.Create(user, ceo));
+ workflow.AddTransition(Transition.Create(ceo, user));
+
+ var chatHistory = new List()
+ {
+ new TextMessage(Role.User, """
+ 项目经理，如何使用1W预算开发一个淘宝
+ """, from: ceo.Name),
+ new TextMessage(Role.User, """
+ 对于1万预算开发淘宝类网站,以下是关键建议:
+ 技术选择:
+ - 使用开源电商系统节省成本, 选择便宜但稳定的云服务器和域名,预算2000元/年
+ - 核心功能优先
+ - 人员安排:
+ - 找1位全栈开发,负责系统搭建(6000元)
+ - 1位兼职UI设计(2000元)
+ - 进度规划:
+ - 基础功能1个月完成,后续根据运营情况逐步优化。
+ """, from: pm.Name),
+ new TextMessage(Role.User, "好的，开发人员，请根据项目经理的规划开始开发", from: ceo.Name),
+ new TextMessage(Role.User, """
+ 好的，已开发完毕
+ ```html
+
+ ```
+ """, from: dev.Name),
+ new TextMessage(Role.User, "好的，项目已完成，甲方请付款", from: ceo.Name),
+ };
+
+ var orchestrator = new RolePlayToolCallOrchestrator(client, workflow);
+
+ foreach (var message in chatHistory)
+ {
+ var context = new OrchestrationContext
+ {
+ Candidates = [ceo, pm, dev, user],
+ ChatHistory = initializeMessage,
+ };
+
+ var speaker = await orchestrator.GetNextSpeakerAsync(context);
+ speaker!.Name.Should().Be(message.From);
+ initializeMessage.Add(message);
+ }
+
+ // the last next speaker should be the user
+ var lastSpeaker = await orchestrator.GetNextSpeakerAsync(new OrchestrationContext
+ {
+ Candidates = [ceo, pm, dev, user],
+ ChatHistory = initializeMessage,
+ });
+
+ lastSpeaker!.Name.Should().Be(user.Name);
+ }
+}
diff --git a/dotnet/test/AutoGen.Tests/AutoGen.Tests.csproj b/dotnet/test/AutoGen.Tests/AutoGen.Tests.csproj
index 248a9e29b00d..367d74619bb4 100644
--- a/dotnet/test/AutoGen.Tests/AutoGen.Tests.csproj
+++ b/dotnet/test/AutoGen.Tests/AutoGen.Tests.csproj
@@ -14,7 +14,7 @@
-
+
diff --git a/dotnet/test/AutoGen.Tests/ImageMessageTests.cs b/dotnet/test/AutoGen.Tests/ImageMessageTests.cs
index e8a30c87012c..bb256a170f2a 100644
--- a/dotnet/test/AutoGen.Tests/ImageMessageTests.cs
+++ b/dotnet/test/AutoGen.Tests/ImageMessageTests.cs
@@ -35,4 +35,18 @@ public async Task ItCreateFromUrl()
imageMessage.MimeType.Should().Be("image/png");
imageMessage.Data.Should().BeNull();
}
+
+ [Fact]
+ public async Task ItCreateFromBase64Url()
+ {
+ var image = Path.Combine("testData", "images", "background.png");
+ var binary = File.ReadAllBytes(image);
+ var base64 = Convert.ToBase64String(binary);
+
+ var base64Url = $"data:image/png;base64,{base64}";
+ var imageMessage = new ImageMessage(Role.User, base64Url);
+
+ imageMessage.BuildDataUri().Should().Be(base64Url);
+ imageMessage.MimeType.Should().Be("image/png");
+ }
}
diff --git a/dotnet/test/Microsoft.AutoGen.Agents.Tests/AgentBaseTests.cs b/dotnet/test/Microsoft.AutoGen.Agents.Tests/AgentBaseTests.cs
index 0def7029f001..7b5182e614b7 100644
--- a/dotnet/test/Microsoft.AutoGen.Agents.Tests/AgentBaseTests.cs
+++ b/dotnet/test/Microsoft.AutoGen.Agents.Tests/AgentBaseTests.cs
@@ -1,21 +1,33 @@
// Copyright (c) Microsoft Corporation. All rights reserved.
// AgentBaseTests.cs
+using System.Collections.Concurrent;
using FluentAssertions;
using Google.Protobuf.Reflection;
+using Microsoft.AspNetCore.Builder;
using Microsoft.AutoGen.Abstractions;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Moq;
using Xunit;
+using static Microsoft.AutoGen.Agents.Tests.AgentBaseTests;
namespace Microsoft.AutoGen.Agents.Tests;
-public class AgentBaseTests
+[Collection(ClusterFixtureCollection.Name)]
+public class AgentBaseTests(InMemoryAgentRuntimeFixture fixture)
{
+ private readonly InMemoryAgentRuntimeFixture _fixture = fixture;
+
[Fact]
public async Task ItInvokeRightHandlerTestAsync()
{
var mockContext = new Mock();
+ mockContext.SetupGet(x => x.AgentId).Returns(new AgentId("test", "test"));
+ // mock SendMessageAsync
+ mockContext.Setup(x => x.SendMessageAsync(It.IsAny(), It.IsAny()))
+ .Returns(new ValueTask());
var agent = new TestAgent(mockContext.Object, new EventTypes(TypeRegistry.Empty, [], [], []), new Logger(new LoggerFactory()));
await agent.HandleObject("hello world");
@@ -26,12 +38,36 @@ public async Task ItInvokeRightHandlerTestAsync()
agent.ReceivedItems[1].Should().Be(42);
}
+ [Fact]
+ public async Task ItDelegateMessageToTestAgentAsync()
+ {
+ var client = _fixture.AppHost.Services.GetRequiredService();
+
+ await client.PublishMessageAsync(new TextMessage()
+ {
+ Source = nameof(ItDelegateMessageToTestAgentAsync),
+ TextMessage_ = "buffer"
+ }, token: CancellationToken.None);
+
+ // wait for 10 seconds
+ var cts = new CancellationTokenSource(TimeSpan.FromSeconds(10));
+ while (!TestAgent.ReceivedMessages.ContainsKey(nameof(ItDelegateMessageToTestAgentAsync)) && !cts.Token.IsCancellationRequested)
+ {
+ await Task.Delay(100);
+ }
+
+ TestAgent.ReceivedMessages[nameof(ItDelegateMessageToTestAgentAsync)].Should().NotBeNull();
+ }
+
///
/// The test agent is a simple agent that is used for testing purposes.
///
- public class TestAgent : AgentBase, IHandle, IHandle
+ public class TestAgent : AgentBase, IHandle, IHandle, IHandle
{
- public TestAgent(IAgentRuntime context, EventTypes eventTypes, Logger logger) : base(context, eventTypes, logger)
+ public TestAgent(
+ IAgentRuntime context,
+ [FromKeyedServices("EventTypes")] EventTypes eventTypes,
+ Logger? logger = null) : base(context, eventTypes, logger)
{
}
@@ -47,6 +83,49 @@ public Task Handle(int item)
return Task.CompletedTask;
}
+ public Task Handle(TextMessage item)
+ {
+ ReceivedMessages[item.Source] = item.TextMessage_;
+ return Task.CompletedTask;
+ }
+
public List
-[](https://twitter.com/pyautogen)
+[](https://twitter.com/pyautogen) [](https://github.com/microsoft/autogen/discussions) [](https://microsoft.github.io/autogen/0.2/) [](https://microsoft.github.io/autogen/dev/)
+[](https://pypi.org/project/autogen-core/0.4.0.dev7/) [](https://pypi.org/project/autogen-agentchat/0.4.0.dev7/) [](https://pypi.org/project/autogen-ext/0.4.0.dev7/)
+