crestapps-core-orchestration

CrestApps.Core Orchestration

The orchestrator is the agentic loop: it builds context from the profile, scopes tools, runs preemptive retrieval, calls the model with function invocation, and streams the answer. DefaultOrchestrator (name "default") is registered by AddCoreAIOrchestration(); Claude ("anthropic") and Copilot ("copilot") are alternatives.

Guidelines

• Register orchestration through AddAISuite(...) or AddCoreAIOrchestration().
• Build the context with IOrchestrationContextBuilder.BuildAsync(resource, configure, cancellationToken) instead of filling OrchestrationContext by hand; the handlers add the system message, tools, documents, RAG and security preamble.
• Resolve orchestrators with IOrchestratorResolver.Resolve(name). An empty or unknown name falls back to OrchestratorOptions.DefaultOrchestratorName.
• Let the orchestrator scope large tool sets; do not hand-pick tools per request.
• The chat deployment is resolved through the chat slot and planning runs on the utility deployment (falling back to chat). See crestapps-core-ai-runtime.

Registration

builder.Services.AddCrestAppsCore(crestApps => crestApps
    .AddAISuite(ai => ai
        .AddOpenAI()
    )
);

Raw form:

builder.Services
    .AddCoreAIServices()
    .AddCoreAIOrchestration()
    .AddCoreAIOpenAI();

Run an Orchestrated Turn

using CrestApps.Core.AI.Models;
using CrestApps.Core.AI.Orchestration;
using Microsoft.Extensions.AI;

public sealed class ProfileChatService
{
    private readonly IOrchestrationContextBuilder _contextBuilder;
    private readonly IOrchestratorResolver _orchestratorResolver;

    public ProfileChatService(
        IOrchestrationContextBuilder contextBuilder,
        IOrchestratorResolver orchestratorResolver)
    {
        _contextBuilder = contextBuilder;
        _orchestratorResolver = orchestratorResolver;
    }

    public async IAsyncEnumerable<string> StreamAsync(
        AIProfile profile,
        string userMessage,
        IList<ChatMessage> history,
        [System.Runtime.CompilerServices.EnumeratorCancellation] CancellationToken cancellationToken = default)
    {
        var context = await _contextBuilder.BuildAsync(
            profile,
            ctx =>
            {
                ctx.UserMessage = userMessage;
                ctx.ConversationHistory = history;
            },
            cancellationToken);

        var orchestrator = _orchestratorResolver.Resolve(profile.OrchestratorName);

        await foreach (var update in orchestrator.ExecuteStreamingAsync(context, cancellationToken))
        {
            if (!string.IsNullOrEmpty(update.Text))
            {
                yield return update.Text;
            }
        }
    }
}