_logger.LogCritical($"[{nameof(ConversationObserver)}]: Receive {value.EventName} => {value.Data.Content} ({conv.ConversationId})");
#endif
            routingCtx.AddDialogs([value.Data]);
            if (value.SaveDataToDb)
            {

    dialogs.Add(message);
    Context.AddDialogs([message]);
}

public List<RoleDialogModel> GetDialogs()
{
    _dialogs ??= [];
    return new List<RoleDialogModel>(_dialogs);
}

public partial class RoutingService
{
    public async Task<bool> InvokeAgent(string agentId, List<RoleDialogModel> dialogs, ...)
    {
        // ...
        var message = ...;
        dialogs.Add(message);
        Context.AddDialogs([message]);
        return true;
    }

    private async Task<bool> InvokeFunction(RoleDialogModel message, List<RoleDialogModel> dialogs, ...)
    {
        // ...
        await InvokeAgent(curAgentId, dialogs, options);
        // ...
    }
}

public partial class RoutingService
{
    public async Task<bool> InvokeAgent(string agentId, ...) // No 'dialogs' parameter
    {
        var dialogs = Context.GetDialogs(); // Fetched from context
        // ...
        var message = ...;
        Context.AddDialogs([message]); // Single source of truth is updated
        return true;
    }

    private async Task<bool> InvokeFunction(RoleDialogModel message, ...) // No 'dialogs' parameter
    {
        // ...
        await InvokeAgent(curAgentId, options);
        // ...
    }
}