BotSharp/src/Infrastructure/BotSharp.Core/Routing/RoutingService.InvokeAgent.cs

using BotSharp.Abstraction.Agents.Models;
using BotSharp.Abstraction.MLTasks.Settings;
using BotSharp.Abstraction.Templating;

namespace BotSharp.Core.Routing;

public partial class RoutingService
{
    const int MAXIMUM_RECURSION_DEPTH = 3;
    private int _currentRecursionDepth = 0;
    public async Task<bool> InvokeAgent(string agentId, List<RoleDialogModel> dialogs)
    {
        _currentRecursionDepth++;
        if (_currentRecursionDepth > MAXIMUM_RECURSION_DEPTH)
        {
            _logger.LogWarning($"Current recursive call depth greater than {MAXIMUM_RECURSION_DEPTH}, which will cause unexpected result.");
            return false;
        }

        var agentService = _services.GetRequiredService<IAgentService>();
        var agent = await agentService.LoadAgent(agentId);

        var settings = _services.GetRequiredService<ChatCompletionSetting>();
        var chatCompletion = CompletionProvider.GetChatCompletion(_services, provider: settings.Provider, model: settings.Model);

        RoleDialogModel response = chatCompletion.GetChatCompletions(agent, dialogs);

        if (response.Role == AgentRole.Function)
        {
            await InvokeFunction(agent, response, dialogs);
        }
        else
        {
            dialogs.Add(response);
        }

        return true;
    }

    private async Task<bool> InvokeFunction(Agent agent, RoleDialogModel message, List<RoleDialogModel> dialogs)
    {
        // execute function
        // Save states
        SaveStateByArgs(JsonSerializer.Deserialize<JsonDocument>(message.FunctionArgs));

        var conversationService = _services.GetRequiredService<IConversationService>();
        // Call functions
        await conversationService.CallFunctions(message);

        // Pass execution result to LLM to get response
        if (!message.StopCompletion)
        {
            // Find response template
            var templateService = _services.GetRequiredService<IResponseTemplateService>();
            var responseTemplate = await templateService.RenderFunctionResponse(agent.Id, message);
            if (!string.IsNullOrEmpty(responseTemplate))
            {
                dialogs.Add(new RoleDialogModel(AgentRole.Assistant, responseTemplate)
                {
                    CurrentAgentId = agent.Id,
                    MessageId = message.MessageId,
                    FunctionArgs = message.FunctionArgs,
                    FunctionName = message.FunctionName
                });
            }
            else
            {
                // Save to memory dialogs
                dialogs.Add(new RoleDialogModel(AgentRole.Function, message.Content)
                {
                    CurrentAgentId = agent.Id,
                    MessageId = message.MessageId,
                    FunctionArgs = message.FunctionArgs,
                    FunctionName = message.FunctionName
                });

                // Send to LLM
                await InvokeAgent(agent.Id, dialogs);
            }
        }
        else
        {
            dialogs.Add(new RoleDialogModel(AgentRole.Assistant, message.Content)
            {
                CurrentAgentId = agent.Id,
                MessageId = message.MessageId,
                FunctionArgs = message.FunctionArgs,
                FunctionName = message.FunctionName,
                StopCompletion = true
            });
        }

        return true;
    }
}