Class OpenAIChatRequestMessageConnector

Namespace

AutoGen.OpenAI

Assembly

AutoGen.OpenAI.dll

This middleware converts the incoming IMessage to IMessage<T> where T is OpenAI.Chat.ChatMessage before sending to agent. And converts the output OpenAI.Chat.ChatCompletion to IMessage after receiving from agent.

Supported IMessage are

- TextMessage

- ImageMessage

- MultiModalMessage

- ToolCallMessage

- ToolCallResultMessage

- IMessage<T> where T is OpenAI.Chat.ChatMessage

- AggregateMessage<TMessage1, TMessage2> where TMessage1 is ToolCallMessage and TMessage2 is ToolCallResultMessage

public class OpenAIChatRequestMessageConnector : IStreamingMiddleware, IMiddleware

Inheritance

object

OpenAIChatRequestMessageConnector

Implements

IStreamingMiddleware

IMiddleware

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

OpenAIChatRequestMessageConnector(bool)

Create a new instance of OpenAIChatRequestMessageConnector.

public OpenAIChatRequestMessageConnector(bool strictMode = false)

Parameters

strictMode bool

If true, OpenAIChatRequestMessageConnector will throw an InvalidOperationException When the message type is not supported. If false, it will ignore the unsupported message type.

Properties

Name

the name of the middleware

public string? Name { get; }

Property Value

string

Methods

InvokeAsync(MiddlewareContext, IAgent, CancellationToken)

The method to invoke the middleware

public Task<IMessage> InvokeAsync(MiddlewareContext context, IAgent agent, CancellationToken cancellationToken = default)

Parameters

context MiddlewareContext

agent IAgent

cancellationToken CancellationToken

Returns

Task<IMessage>

InvokeAsync(MiddlewareContext, IStreamingAgent, CancellationToken)

The streaming version of InvokeAsync(MiddlewareContext, IAgent, CancellationToken).

public IAsyncEnumerable<IMessage> InvokeAsync(MiddlewareContext context, IStreamingAgent agent, CancellationToken cancellationToken = default)

Parameters

context MiddlewareContext

agent IStreamingAgent

cancellationToken CancellationToken

Returns

IAsyncEnumerable<IMessage>

PostProcessMessage(IMessage)

public IMessage PostProcessMessage(IMessage message)

Parameters

message IMessage

Returns

IMessage

ProcessIncomingMessages(IAgent, IEnumerable<IMessage>)

public IEnumerable<IMessage> ProcessIncomingMessages(IAgent agent, IEnumerable<IMessage> messages)

Parameters

agent IAgent

messages IEnumerable<IMessage>

Returns

IEnumerable<IMessage>