Azure Ai Agents Persistent Dotnet

using Azure.AI.Agents.Persistent;using Azure.Identity;
var projectEndpoint = Environment.GetEnvironmentVariable("PROJECT_ENDPOINT");// Local dev: DefaultAzureCredential. Production: set AZURE_TOKEN_CREDENTIALS=prod or AZURE_TOKEN_CREDENTIALS=<specific_credential>var credential = new DefaultAzureCredential(    DefaultAzureCredential.DefaultEnvironmentVariableName);// Or use a specific credential directly in production:// See https://learn.microsoft.com/dotnet/api/overview/azure/identity-readme?view=azure-dotnet#credential-classes// var credential = new ManagedIdentityCredential();PersistentAgentsClient client = new(projectEndpoint, credential);

var modelDeploymentName = Environment.GetEnvironmentVariable("MODEL_DEPLOYMENT_NAME");
PersistentAgent agent = await client.Administration.CreateAgentAsync(    model: modelDeploymentName,    name: "Math Tutor",    instructions: "You are a personal math tutor. Write and run code to answer math questions.",    tools: [new CodeInterpreterToolDefinition()]);

// Create threadPersistentAgentThread thread = await client.Threads.CreateThreadAsync();
// Create messageawait client.Messages.CreateMessageAsync(    thread.Id,    MessageRole.User,    "I need to solve the equation `3x + 11 = 14`. Can you help me?");

// Create runThreadRun run = await client.Runs.CreateRunAsync(    thread.Id,    agent.Id,    additionalInstructions: "Please address the user as Jane Doe.");
// Poll for completiondo{    await Task.Delay(TimeSpan.FromMilliseconds(500));    run = await client.Runs.GetRunAsync(thread.Id, run.Id);}while (run.Status == RunStatus.Queued || run.Status == RunStatus.InProgress);
// Retrieve messagesawait foreach (PersistentThreadMessage message in client.Messages.GetMessagesAsync(    threadId: thread.Id,     order: ListSortOrder.Ascending)){    Console.Write($"{message.Role}: ");    foreach (MessageContent content in message.ContentItems)    {        if (content is MessageTextContent textContent)            Console.WriteLine(textContent.Text);    }}

AsyncCollectionResult<StreamingUpdate> stream = client.Runs.CreateRunStreamingAsync(    thread.Id,     agent.Id);
await foreach (StreamingUpdate update in stream){    if (update.UpdateKind == StreamingUpdateReason.RunCreated)    {        Console.WriteLine("--- Run started! ---");    }    else if (update is MessageContentUpdate contentUpdate)    {        Console.Write(contentUpdate.Text);    }    else if (update.UpdateKind == StreamingUpdateReason.RunCompleted)    {        Console.WriteLine("\n--- Run completed! ---");    }}

// Define function toolFunctionToolDefinition weatherTool = new(    name: "getCurrentWeather",    description: "Gets the current weather at a location.",    parameters: BinaryData.FromObjectAsJson(new    {        Type = "object",        Properties = new        {            Location = new { Type = "string", Description = "City and state, e.g. San Francisco, CA" },            Unit = new { Type = "string", Enum = new[] { "c", "f" } }        },        Required = new[] { "location" }    }, new JsonSerializerOptions { PropertyNamingPolicy = JsonNamingPolicy.CamelCase }));
// Create agent with functionPersistentAgent agent = await client.Administration.CreateAgentAsync(    model: modelDeploymentName,    name: "Weather Bot",    instructions: "You are a weather bot.",    tools: [weatherTool]);
// Handle function calls during pollingdo{    await Task.Delay(500);    run = await client.Runs.GetRunAsync(thread.Id, run.Id);
    if (run.Status == RunStatus.RequiresAction         && run.RequiredAction is SubmitToolOutputsAction submitAction)    {        List<ToolOutput> outputs = [];        foreach (RequiredToolCall toolCall in submitAction.ToolCalls)        {            if (toolCall is RequiredFunctionToolCall funcCall)            {                // Execute function and get result                string result = ExecuteFunction(funcCall.Name, funcCall.Arguments);                outputs.Add(new ToolOutput(toolCall, result));            }        }        run = await client.Runs.SubmitToolOutputsToRunAsync(run, outputs, toolApprovals: null);    }}while (run.Status == RunStatus.Queued || run.Status == RunStatus.InProgress);

// Upload filePersistentAgentFileInfo file = await client.Files.UploadFileAsync(    filePath: "document.txt",    purpose: PersistentAgentFilePurpose.Agents);
// Create vector storePersistentAgentsVectorStore vectorStore = await client.VectorStores.CreateVectorStoreAsync(    fileIds: [file.Id],    name: "my_vector_store");
// Create file search resourceFileSearchToolResource fileSearchResource = new();fileSearchResource.VectorStoreIds.Add(vectorStore.Id);
// Create agent with file searchPersistentAgent agent = await client.Administration.CreateAgentAsync(    model: modelDeploymentName,    name: "Document Assistant",    instructions: "You help users find information in documents.",    tools: [new FileSearchToolDefinition()],    toolResources: new ToolResources { FileSearch = fileSearchResource });

var bingConnectionId = Environment.GetEnvironmentVariable("AZURE_BING_CONNECTION_ID");
BingGroundingToolDefinition bingTool = new(    new BingGroundingSearchToolParameters(        [new BingGroundingSearchConfiguration(bingConnectionId)]    ));
PersistentAgent agent = await client.Administration.CreateAgentAsync(    model: modelDeploymentName,    name: "Search Agent",    instructions: "Use Bing to answer questions about current events.",    tools: [bingTool]);

AzureAISearchToolResource searchResource = new(    connectionId: searchConnectionId,    indexName: "my_index",    topK: 5,    filter: "category eq 'documentation'",    queryType: AzureAISearchQueryType.Simple);
PersistentAgent agent = await client.Administration.CreateAgentAsync(    model: modelDeploymentName,    name: "Search Agent",    instructions: "Search the documentation index to answer questions.",    tools: [new AzureAISearchToolDefinition()],    toolResources: new ToolResources { AzureAISearch = searchResource });

await client.Threads.DeleteThreadAsync(thread.Id);await client.Administration.DeleteAgentAsync(agent.Id);await client.VectorStores.DeleteVectorStoreAsync(vectorStore.Id);await client.Files.DeleteFileAsync(file.Id);

using Azure;
try{    var agent = await client.Administration.CreateAgentAsync(...);}catch (RequestFailedException ex) when (ex.Status == 404){    Console.WriteLine("Resource not found");}catch (RequestFailedException ex){    Console.WriteLine($"Error: {ex.Status} - {ex.ErrorCode}: {ex.Message}");}