mirror of
https://github.com/microsoft/agent-framework.git
synced 2026-06-16 21:04:09 +08:00
Reuben Bond
1108 lines
39 KiB
C#
1108 lines
39 KiB
C#
// Copyright (c) Microsoft. All rights reserved.
|
|
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text.Json;
|
|
using Microsoft.Agents.AI.Hosting.OpenAI.Responses.Models;
|
|
using Microsoft.Agents.AI.Hosting.OpenAI.Tests;
|
|
|
|
namespace Microsoft.Agents.AI.Hosting.OpenAI.UnitTests;
|
|
|
|
/// <summary>
|
|
/// Tests for OpenAI Responses API model serialization and deserialization.
|
|
/// These tests verify that our models correctly serialize to and deserialize from JSON
|
|
/// matching the OpenAI wire format, without testing actual API implementation behavior.
|
|
/// </summary>
|
|
public sealed class OpenAIResponsesSerializationTests : ConformanceTestBase
|
|
{
|
|
#region Request Serialization Tests
|
|
|
|
[Fact]
|
|
public void Deserialize_BasicRequest_Success()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("basic/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.Equal("gpt-4o-mini", request.Model);
|
|
Assert.NotNull(request.Input);
|
|
Assert.Equal(100, request.MaxOutputTokens);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_BasicRequest_RoundTrip()
|
|
{
|
|
// Arrange
|
|
string originalJson = LoadResponsesTraceFile("basic/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(originalJson, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
string reserializedJson = JsonSerializer.Serialize(request, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
CreateResponse? roundtripped = JsonSerializer.Deserialize(reserializedJson, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.NotNull(roundtripped);
|
|
Assert.Equal(request.Model, roundtripped.Model);
|
|
Assert.Equal(request.MaxOutputTokens, roundtripped.MaxOutputTokens);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_StreamingRequest_HasStreamFlag()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("streaming/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.True(request.Stream);
|
|
Assert.Equal(200, request.MaxOutputTokens);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ConversationRequest_HasPreviousResponseId()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("conversation/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.NotNull(request.PreviousResponseId);
|
|
Assert.StartsWith("resp_", request.PreviousResponseId);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_MetadataRequest_HasAllParameters()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("metadata/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.NotNull(request.Metadata);
|
|
Assert.Equal(3, request.Metadata.Count);
|
|
Assert.Equal("test_user_123", request.Metadata["user_id"]);
|
|
Assert.Equal("session_456", request.Metadata["session_id"]);
|
|
Assert.Equal("conformance_test", request.Metadata["purpose"]);
|
|
|
|
Assert.NotNull(request.Instructions);
|
|
Assert.Equal("Respond in a friendly, educational tone.", request.Instructions);
|
|
|
|
Assert.Equal(0.7, request.Temperature);
|
|
Assert.Equal(0.9, request.TopP);
|
|
Assert.Equal(150, request.MaxOutputTokens);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ToolCallRequest_HasToolDefinitions()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("tool_call/request.json");
|
|
|
|
// Act
|
|
// CreateResponse doesn't have Tools property - it uses dynamic JSON
|
|
using var doc = JsonDocument.Parse(json);
|
|
var root = doc.RootElement;
|
|
|
|
// Assert
|
|
Assert.True(root.TryGetProperty("tools", out var tools));
|
|
Assert.Equal(JsonValueKind.Array, tools.ValueKind);
|
|
Assert.Equal(1, tools.GetArrayLength());
|
|
|
|
var tool = tools[0];
|
|
Assert.Equal("function", tool.GetProperty("type").GetString());
|
|
Assert.Equal("get_weather", tool.GetProperty("name").GetString());
|
|
Assert.True(tool.TryGetProperty("description", out _));
|
|
Assert.True(tool.TryGetProperty("parameters", out var parameters));
|
|
Assert.Equal("object", parameters.GetProperty("type").GetString());
|
|
}
|
|
|
|
[Fact]
|
|
public void Serialize_CreateMinimalRequest_MatchesFormat()
|
|
{
|
|
// Arrange
|
|
var request = new CreateResponse
|
|
{
|
|
Model = "gpt-4o-mini",
|
|
Input = ResponseInput.FromText("Hello")
|
|
};
|
|
|
|
// Act
|
|
string json = JsonSerializer.Serialize(request, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
using var doc = JsonDocument.Parse(json);
|
|
var root = doc.RootElement;
|
|
|
|
// Assert
|
|
Assert.Equal("gpt-4o-mini", root.GetProperty("model").GetString());
|
|
Assert.True(root.TryGetProperty("input", out var input));
|
|
|
|
// Input can be string or object - verify one exists
|
|
Assert.True(input.ValueKind is JsonValueKind.String or JsonValueKind.Object);
|
|
}
|
|
|
|
[Fact]
|
|
public void Serialize_CreateRequestWithOptions_IncludesAllFields()
|
|
{
|
|
// Arrange
|
|
var request = new CreateResponse
|
|
{
|
|
Model = "gpt-4o-mini",
|
|
Input = ResponseInput.FromText("Test input"),
|
|
MaxOutputTokens = 100,
|
|
Temperature = 0.7,
|
|
TopP = 0.9,
|
|
Stream = false,
|
|
Instructions = "Test instructions",
|
|
Metadata = new Dictionary<string, string>
|
|
{
|
|
["key1"] = "value1",
|
|
["key2"] = "value2"
|
|
}
|
|
};
|
|
|
|
// Act
|
|
string json = JsonSerializer.Serialize(request, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
using var doc = JsonDocument.Parse(json);
|
|
var root = doc.RootElement;
|
|
|
|
// Assert
|
|
Assert.Equal("gpt-4o-mini", root.GetProperty("model").GetString());
|
|
Assert.Equal(100, root.GetProperty("max_output_tokens").GetInt32());
|
|
Assert.Equal(0.7, root.GetProperty("temperature").GetDouble());
|
|
Assert.Equal(0.9, root.GetProperty("top_p").GetDouble());
|
|
Assert.False(root.GetProperty("stream").GetBoolean());
|
|
Assert.Equal("Test instructions", root.GetProperty("instructions").GetString());
|
|
|
|
var metadata = root.GetProperty("metadata");
|
|
Assert.Equal("value1", metadata.GetProperty("key1").GetString());
|
|
Assert.Equal("value2", metadata.GetProperty("key2").GetString());
|
|
}
|
|
|
|
[Fact]
|
|
public void Serialize_NullableFields_AreOmittedWhenNull()
|
|
{
|
|
// Arrange
|
|
var request = new CreateResponse
|
|
{
|
|
Model = "gpt-4o-mini",
|
|
Input = ResponseInput.FromText("Test")
|
|
};
|
|
|
|
// Act
|
|
string json = JsonSerializer.Serialize(request, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
using var doc = JsonDocument.Parse(json);
|
|
var root = doc.RootElement;
|
|
|
|
// Assert - Optional fields should not be present when null
|
|
Assert.False(root.TryGetProperty("previous_response_id", out _) &&
|
|
root.GetProperty("previous_response_id").ValueKind != JsonValueKind.Null,
|
|
"previous_response_id should be omitted or null");
|
|
Assert.False(root.TryGetProperty("instructions", out _) &&
|
|
root.GetProperty("instructions").ValueKind != JsonValueKind.Null,
|
|
"instructions should be omitted or null");
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ImageInputRequest_HasImageData()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("image_input/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.NotNull(request.Input);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ImageInputStreamingRequest_HasStreamAndImage()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("image_input_streaming/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.True(request.Stream);
|
|
Assert.NotNull(request.Input);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_JsonOutputRequest_HasJsonSchema()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("json_output/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.NotNull(request.Input);
|
|
Assert.NotNull(request.Text);
|
|
Assert.NotNull(request.Text.Format);
|
|
Assert.IsType<ResponseTextFormatConfigurationJsonSchema>(request.Text.Format);
|
|
var jsonSchemaFormat = (ResponseTextFormatConfigurationJsonSchema)request.Text.Format;
|
|
Assert.Equal("json_schema", jsonSchemaFormat.Type);
|
|
Assert.NotNull(jsonSchemaFormat.Name);
|
|
Assert.NotEqual(default, jsonSchemaFormat.Schema);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_JsonOutputStreamingRequest_HasJsonSchemaAndStream()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("json_output_streaming/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.True(request.Stream);
|
|
Assert.NotNull(request.Input);
|
|
Assert.NotNull(request.Text);
|
|
Assert.NotNull(request.Text.Format);
|
|
Assert.IsType<ResponseTextFormatConfigurationJsonSchema>(request.Text.Format);
|
|
var jsonSchemaFormat = (ResponseTextFormatConfigurationJsonSchema)request.Text.Format;
|
|
Assert.Equal("json_schema", jsonSchemaFormat.Type);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ReasoningRequest_HasReasoningConfiguration()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("reasoning/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.NotNull(request.Reasoning);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ReasoningStreamingRequest_HasReasoningAndStream()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("reasoning_streaming/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.True(request.Stream);
|
|
Assert.NotNull(request.Reasoning);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_RefusalRequest_CanBeDeserialized()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("refusal/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.NotNull(request.Input);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_RefusalStreamingRequest_HasStream()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("refusal_streaming/request.json");
|
|
|
|
// Act
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
|
|
// Assert
|
|
Assert.NotNull(request);
|
|
Assert.True(request.Stream);
|
|
Assert.NotNull(request.Input);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_InvalidInputObject_ThrowsHelpfulException()
|
|
{
|
|
// Arrange
|
|
const string Json = "{\"model\":\"gpt-4o-mini\",\"input\":{\"input\":\"testing!\"},\"stream\":true}";
|
|
|
|
// Act & Assert
|
|
var exception = Assert.Throws<JsonException>(() =>
|
|
JsonSerializer.Deserialize(Json, OpenAIHostingJsonContext.Default.CreateResponse));
|
|
|
|
Assert.Contains("ResponseInput must be either a string or an array of messages", exception.Message);
|
|
Assert.Contains("Objects are not supported", exception.Message);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_AllRequests_CanBeDeserialized()
|
|
{
|
|
// Arrange
|
|
string[] requestPaths =
|
|
[
|
|
"basic/request.json",
|
|
"streaming/request.json",
|
|
"conversation/request.json",
|
|
"metadata/request.json",
|
|
"tool_call/request.json",
|
|
"image_input/request.json",
|
|
"image_input_streaming/request.json",
|
|
"json_output/request.json",
|
|
"json_output_streaming/request.json",
|
|
"reasoning/request.json",
|
|
"reasoning_streaming/request.json",
|
|
"refusal/request.json",
|
|
"refusal_streaming/request.json"
|
|
];
|
|
|
|
foreach (var path in requestPaths)
|
|
{
|
|
string json = LoadResponsesTraceFile(path);
|
|
|
|
// Act & Assert - Should not throw
|
|
CreateResponse? request = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.CreateResponse);
|
|
Assert.NotNull(request);
|
|
Assert.NotNull(request.Input);
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region Response Deserialization Tests
|
|
|
|
[Fact]
|
|
public void Deserialize_BasicResponse_Success()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("basic/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.StartsWith("resp_", response.Id);
|
|
Assert.Equal("response", response.Object);
|
|
Assert.True(response.CreatedAt > 0);
|
|
Assert.Equal(ResponseStatus.Completed, response.Status);
|
|
Assert.NotNull(response.Model);
|
|
Assert.StartsWith("gpt-4o-mini", response.Model);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_BasicResponse_HasCorrectOutput()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("basic/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(response.Output);
|
|
Assert.Single(response.Output);
|
|
|
|
var outputItem = response.Output[0];
|
|
Assert.NotNull(outputItem);
|
|
|
|
// Verify it's a message type
|
|
using var doc = JsonDocument.Parse(JsonSerializer.Serialize(outputItem, OpenAIHostingJsonContext.Default.ItemResource));
|
|
var root = doc.RootElement;
|
|
Assert.Equal("message", root.GetProperty("type").GetString());
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_BasicResponse_HasCorrectUsage()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("basic/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(response.Usage);
|
|
Assert.True(response.Usage.InputTokens > 0);
|
|
Assert.True(response.Usage.OutputTokens > 0);
|
|
Assert.Equal(response.Usage.InputTokens + response.Usage.OutputTokens, response.Usage.TotalTokens);
|
|
Assert.NotNull(response.Usage.InputTokensDetails);
|
|
Assert.NotNull(response.Usage.OutputTokensDetails);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ConversationResponse_HasPreviousResponseId()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("conversation/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(response.PreviousResponseId);
|
|
Assert.StartsWith("resp_", response.PreviousResponseId);
|
|
Assert.NotEqual(response.Id, response.PreviousResponseId);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_MetadataResponse_PreservesMetadata()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("metadata/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(response.Metadata);
|
|
Assert.Equal("test_user_123", response.Metadata["user_id"]);
|
|
Assert.Equal("session_456", response.Metadata["session_id"]);
|
|
Assert.Equal("conformance_test", response.Metadata["purpose"]);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_MetadataResponse_HasIncompleteStatus()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("metadata/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.Equal(ResponseStatus.Incomplete, response.Status);
|
|
Assert.NotNull(response.IncompleteDetails);
|
|
Assert.Equal("max_output_tokens", response.IncompleteDetails.Reason);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_MetadataResponse_HasInstructions()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("metadata/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(response.Instructions);
|
|
Assert.Equal("Respond in a friendly, educational tone.", response.Instructions);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_MetadataResponse_HasModelParameters()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("metadata/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.Equal(0.7, response.Temperature);
|
|
Assert.Equal(0.9, response.TopP);
|
|
Assert.Equal(150, response.MaxOutputTokens);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ToolCallResponse_HasFunctionCall()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("tool_call/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(response.Output);
|
|
Assert.Single(response.Output);
|
|
|
|
// Verify the output is a function_call type
|
|
using var doc = JsonDocument.Parse(JsonSerializer.Serialize(response.Output[0], OpenAIHostingJsonContext.Default.ItemResource));
|
|
var root = doc.RootElement;
|
|
Assert.Equal("function_call", root.GetProperty("type").GetString());
|
|
Assert.Equal("get_weather", root.GetProperty("name").GetString());
|
|
Assert.True(root.TryGetProperty("arguments", out var args));
|
|
Assert.True(root.TryGetProperty("call_id", out var callId));
|
|
Assert.StartsWith("call_", callId.GetString());
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ToolCallResponse_HasToolDefinitions()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("tool_call/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(response.Tools);
|
|
Assert.Single(response.Tools);
|
|
|
|
var tool = response.Tools[0];
|
|
Assert.Equal(JsonValueKind.Object, tool.ValueKind);
|
|
|
|
var toolObj = tool;
|
|
Assert.Equal("function", toolObj.GetProperty("type").GetString());
|
|
Assert.Equal("get_weather", toolObj.GetProperty("name").GetString());
|
|
Assert.True(toolObj.TryGetProperty("parameters", out var parameters));
|
|
Assert.Equal("object", parameters.GetProperty("type").GetString());
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ImageInputResponse_HasImageInInput()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("image_input/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.Equal(ResponseStatus.Completed, response.Status);
|
|
Assert.NotNull(response.Output);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_JsonOutputResponse_HasStructuredOutput()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("json_output/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.Equal(ResponseStatus.Completed, response.Status);
|
|
Assert.NotNull(response.Output);
|
|
Assert.NotNull(response.Text);
|
|
Assert.NotNull(response.Text.Format);
|
|
Assert.IsType<ResponseTextFormatConfigurationJsonSchema>(response.Text.Format);
|
|
var jsonSchemaFormat = (ResponseTextFormatConfigurationJsonSchema)response.Text.Format;
|
|
Assert.Equal("json_schema", jsonSchemaFormat.Type);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ReasoningResponse_HasReasoningItems()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("reasoning/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.Equal(ResponseStatus.Completed, response.Status);
|
|
Assert.NotNull(response.Output);
|
|
Assert.NotNull(response.Reasoning);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_RefusalResponse_HasRefusalContent()
|
|
{
|
|
// Arrange
|
|
string json = LoadResponsesTraceFile("refusal/response.json");
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.Equal(ResponseStatus.Completed, response.Status);
|
|
Assert.NotNull(response.Output);
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_AllResponses_HaveRequiredFields()
|
|
{
|
|
// Arrange
|
|
string[] responsePaths =
|
|
[
|
|
"basic/response.json",
|
|
"conversation/response.json",
|
|
"metadata/response.json",
|
|
"tool_call/response.json",
|
|
"image_input/response.json",
|
|
"json_output/response.json",
|
|
"reasoning/response.json",
|
|
"refusal/response.json"
|
|
];
|
|
|
|
foreach (var path in responsePaths)
|
|
{
|
|
string json = LoadResponsesTraceFile(path);
|
|
|
|
// Act
|
|
Response? response = JsonSerializer.Deserialize(json, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(response.Id);
|
|
Assert.Equal("response", response.Object);
|
|
Assert.True(response.CreatedAt > 0, $"Response from {path} should have created_at");
|
|
Assert.NotNull(response.Model);
|
|
Assert.NotNull(response.Output);
|
|
}
|
|
}
|
|
|
|
[Fact]
|
|
public void Deserialize_ResponseRoundTrip_PreservesData()
|
|
{
|
|
// Arrange
|
|
string originalJson = LoadResponsesTraceFile("basic/response.json");
|
|
|
|
// Act - Deserialize and re-serialize
|
|
Response? response = JsonSerializer.Deserialize(originalJson, OpenAIHostingJsonContext.Default.Response);
|
|
string reserializedJson = JsonSerializer.Serialize(response, OpenAIHostingJsonContext.Default.Response);
|
|
Response? roundtripped = JsonSerializer.Deserialize(reserializedJson, OpenAIHostingJsonContext.Default.Response);
|
|
|
|
// Assert
|
|
Assert.NotNull(response);
|
|
Assert.NotNull(roundtripped);
|
|
Assert.Equal(response.Id, roundtripped.Id);
|
|
Assert.Equal(response.CreatedAt, roundtripped.CreatedAt);
|
|
Assert.Equal(response.Status, roundtripped.Status);
|
|
Assert.Equal(response.Model, roundtripped.Model);
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region Streaming Event Deserialization Tests
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_BasicFormat_Success()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
|
|
// Act
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
|
|
// Assert
|
|
Assert.NotEmpty(events);
|
|
Assert.All(events, evt =>
|
|
{
|
|
Assert.True(evt.TryGetProperty("type", out var type));
|
|
Assert.True(evt.TryGetProperty("sequence_number", out var seqNum));
|
|
Assert.Equal(JsonValueKind.Number, seqNum.ValueKind);
|
|
});
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_HasCorrectEventTypes()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
|
|
// Act
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var eventTypes = events.Select(e => e.GetProperty("type").GetString()).ToHashSet();
|
|
|
|
// Assert
|
|
Assert.Contains("response.created", eventTypes);
|
|
Assert.Contains("response.in_progress", eventTypes);
|
|
Assert.Contains("response.output_item.added", eventTypes);
|
|
Assert.Contains("response.content_part.added", eventTypes);
|
|
Assert.Contains("response.output_text.delta", eventTypes);
|
|
Assert.Contains("response.output_text.done", eventTypes);
|
|
Assert.Contains("response.content_part.done", eventTypes);
|
|
Assert.Contains("response.output_item.done", eventTypes);
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_DeserializeCreatedEvent_Success()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var createdEventJson = events.First(e => e.GetProperty("type").GetString() == "response.created");
|
|
|
|
// Act
|
|
string jsonString = createdEventJson.GetRawText();
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(jsonString, OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
|
|
// Assert
|
|
Assert.NotNull(evt);
|
|
Assert.IsType<StreamingResponseCreated>(evt);
|
|
var created = (StreamingResponseCreated)evt;
|
|
Assert.Equal(0, created.SequenceNumber);
|
|
Assert.NotNull(created.Response);
|
|
Assert.NotNull(created.Response.Id);
|
|
Assert.StartsWith("resp_", created.Response.Id);
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_DeserializeInProgressEvent_Success()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var inProgressEventJson = events.First(e => e.GetProperty("type").GetString() == "response.in_progress");
|
|
|
|
// Act
|
|
string jsonString = inProgressEventJson.GetRawText();
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(jsonString, OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
|
|
// Assert
|
|
Assert.NotNull(evt);
|
|
Assert.IsType<StreamingResponseInProgress>(evt);
|
|
var inProgress = (StreamingResponseInProgress)evt;
|
|
Assert.Equal(1, inProgress.SequenceNumber);
|
|
Assert.NotNull(inProgress.Response);
|
|
Assert.Equal(ResponseStatus.InProgress, inProgress.Response.Status);
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_DeserializeOutputItemAdded_Success()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var itemAddedJson = events.First(e => e.GetProperty("type").GetString() == "response.output_item.added");
|
|
|
|
// Act
|
|
string jsonString = itemAddedJson.GetRawText();
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(jsonString, OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
|
|
// Assert
|
|
Assert.NotNull(evt);
|
|
Assert.IsType<StreamingOutputItemAdded>(evt);
|
|
var itemAdded = (StreamingOutputItemAdded)evt;
|
|
Assert.Equal(0, itemAdded.OutputIndex);
|
|
Assert.NotNull(itemAdded.Item);
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_DeserializeContentPartAdded_Success()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var partAddedJson = events.First(e => e.GetProperty("type").GetString() == "response.content_part.added");
|
|
|
|
// Act
|
|
string jsonString = partAddedJson.GetRawText();
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(jsonString, OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
|
|
// Assert
|
|
Assert.NotNull(evt);
|
|
Assert.IsType<StreamingContentPartAdded>(evt);
|
|
var partAdded = (StreamingContentPartAdded)evt;
|
|
Assert.NotNull(partAdded.ItemId);
|
|
Assert.Equal(0, partAdded.OutputIndex);
|
|
Assert.Equal(0, partAdded.ContentIndex);
|
|
Assert.NotNull(partAdded.Part);
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_DeserializeTextDelta_Success()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var textDeltaJson = events.First(e => e.GetProperty("type").GetString() == "response.output_text.delta");
|
|
|
|
// Act
|
|
string jsonString = textDeltaJson.GetRawText();
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(jsonString, OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
|
|
// Assert
|
|
Assert.NotNull(evt);
|
|
Assert.IsType<StreamingOutputTextDelta>(evt);
|
|
var textDelta = (StreamingOutputTextDelta)evt;
|
|
Assert.NotNull(textDelta.ItemId);
|
|
Assert.Equal(0, textDelta.OutputIndex);
|
|
Assert.Equal(0, textDelta.ContentIndex);
|
|
Assert.NotNull(textDelta.Delta);
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_AccumulateTextDeltas_MatchesFinalText()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
|
|
// Act
|
|
var deltas = new List<string>();
|
|
string? finalText = null;
|
|
|
|
foreach (var eventJson in events)
|
|
{
|
|
string jsonString = eventJson.GetRawText();
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(jsonString, OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
|
|
if (evt is StreamingOutputTextDelta delta)
|
|
{
|
|
deltas.Add(delta.Delta);
|
|
}
|
|
else if (evt is StreamingOutputTextDone done)
|
|
{
|
|
finalText = done.Text;
|
|
}
|
|
}
|
|
|
|
// Assert
|
|
Assert.NotEmpty(deltas);
|
|
Assert.NotNull(finalText);
|
|
|
|
string accumulated = string.Concat(deltas);
|
|
Assert.Equal(accumulated, finalText);
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_SequenceNumbersAreSequential()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
|
|
// Act
|
|
var sequenceNumbers = new List<int>();
|
|
foreach (var eventJson in events)
|
|
{
|
|
string jsonString = eventJson.GetRawText();
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(jsonString, OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
Assert.NotNull(evt);
|
|
sequenceNumbers.Add(evt.SequenceNumber);
|
|
}
|
|
|
|
// Assert
|
|
Assert.NotEmpty(sequenceNumbers);
|
|
Assert.Equal(0, sequenceNumbers.First());
|
|
|
|
for (int i = 0; i < sequenceNumbers.Count; i++)
|
|
{
|
|
Assert.Equal(i, sequenceNumbers[i]);
|
|
}
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_FinalEvent_IsTerminalState()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var lastEventJson = events.Last();
|
|
|
|
// Act
|
|
string jsonString = lastEventJson.GetRawText();
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(jsonString, OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
|
|
// Assert
|
|
Assert.NotNull(evt);
|
|
|
|
// Should be one of the terminal events
|
|
bool isTerminal = evt is StreamingResponseCompleted or
|
|
StreamingResponseIncomplete or
|
|
StreamingResponseFailed;
|
|
Assert.True(isTerminal, $"Expected terminal event, got: {evt.GetType().Name}");
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_ImageInputStreaming_HasImageEvents()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("image_input_streaming/response.txt");
|
|
|
|
// Act
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
|
|
// Assert
|
|
Assert.NotEmpty(events);
|
|
Assert.All(events, evt =>
|
|
{
|
|
StreamingResponseEvent? parsed = JsonSerializer.Deserialize(evt.GetRawText(), OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
Assert.NotNull(parsed);
|
|
});
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_JsonOutputStreaming_HasJsonSchemaEvents()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("json_output_streaming/response.txt");
|
|
|
|
// Act
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
|
|
// Assert
|
|
Assert.NotEmpty(events);
|
|
Assert.All(events, evt =>
|
|
{
|
|
StreamingResponseEvent? parsed = JsonSerializer.Deserialize(evt.GetRawText(), OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
Assert.NotNull(parsed);
|
|
});
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_ReasoningStreaming_HasReasoningEvents()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("reasoning_streaming/response.txt");
|
|
|
|
// Act
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var eventTypes = events.Select(e => e.GetProperty("type").GetString()).ToHashSet();
|
|
|
|
// Assert
|
|
Assert.NotEmpty(events);
|
|
// Should have reasoning-related events
|
|
Assert.Contains("response.created", eventTypes);
|
|
Assert.All(events, evt =>
|
|
{
|
|
StreamingResponseEvent? parsed = JsonSerializer.Deserialize(evt.GetRawText(), OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
Assert.NotNull(parsed);
|
|
});
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_RefusalStreaming_HasRefusalEvents()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("refusal_streaming/response.txt");
|
|
|
|
// Act
|
|
var events = ParseSseEventsFromContent(sseContent);
|
|
var eventTypes = events.Select(e => e.GetProperty("type").GetString()).ToHashSet();
|
|
|
|
// Assert
|
|
Assert.NotEmpty(events);
|
|
// Should have refusal-related events
|
|
Assert.All(events, evt =>
|
|
{
|
|
StreamingResponseEvent? parsed = JsonSerializer.Deserialize(evt.GetRawText(), OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
Assert.NotNull(parsed);
|
|
});
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_AllStreamingTraces_CanBeDeserialized()
|
|
{
|
|
// Arrange
|
|
string[] streamingPaths =
|
|
[
|
|
"streaming/response.txt",
|
|
"image_input_streaming/response.txt",
|
|
"json_output_streaming/response.txt",
|
|
"reasoning_streaming/response.txt",
|
|
"refusal_streaming/response.txt"
|
|
];
|
|
|
|
foreach (var path in streamingPaths)
|
|
{
|
|
string sseContent = LoadResponsesTraceFile(path);
|
|
|
|
// Act & Assert
|
|
foreach (var eventJson in ParseSseEventsFromContent(sseContent))
|
|
{
|
|
// Should not throw
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(eventJson.GetRawText(), OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
Assert.NotNull(evt);
|
|
}
|
|
}
|
|
}
|
|
|
|
[Fact]
|
|
public void ParseStreamingEvents_AllEvents_CanBeDeserialized()
|
|
{
|
|
// Arrange
|
|
string sseContent = LoadResponsesTraceFile("streaming/response.txt");
|
|
|
|
// Act & Assert
|
|
foreach (var eventJson in ParseSseEventsFromContent(sseContent))
|
|
{
|
|
// Should not throw
|
|
StreamingResponseEvent? evt = JsonSerializer.Deserialize(eventJson.GetRawText(), OpenAIHostingJsonContext.Default.StreamingResponseEvent);
|
|
Assert.NotNull(evt);
|
|
|
|
// Verify polymorphic deserialization worked
|
|
Assert.True(
|
|
evt is StreamingResponseCreated or
|
|
StreamingResponseInProgress or
|
|
StreamingResponseCompleted or
|
|
StreamingResponseIncomplete or
|
|
StreamingResponseFailed or
|
|
StreamingOutputItemAdded or
|
|
StreamingOutputItemDone or
|
|
StreamingContentPartAdded or
|
|
StreamingContentPartDone or
|
|
StreamingOutputTextDelta or
|
|
StreamingOutputTextDone or
|
|
StreamingFunctionCallArgumentsDelta or
|
|
StreamingFunctionCallArgumentsDone,
|
|
$"Unknown event type: {evt.GetType().Name}");
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Helper to parse SSE events from a streaming response content string.
|
|
/// </summary>
|
|
private static List<JsonElement> ParseSseEventsFromContent(string sseContent)
|
|
{
|
|
var events = new List<JsonElement>();
|
|
var lines = sseContent.Split('\n');
|
|
|
|
for (int i = 0; i < lines.Length; i++)
|
|
{
|
|
var line = lines[i].TrimEnd('\r');
|
|
|
|
if (line.StartsWith("event: ", StringComparison.Ordinal))
|
|
{
|
|
// Next line should have the data
|
|
if (i + 1 < lines.Length)
|
|
{
|
|
var dataLine = lines[i + 1].TrimEnd('\r');
|
|
if (dataLine.StartsWith("data: ", StringComparison.Ordinal))
|
|
{
|
|
var jsonData = dataLine.Substring("data: ".Length);
|
|
var doc = JsonDocument.Parse(jsonData);
|
|
events.Add(doc.RootElement.Clone());
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return events;
|
|
}
|
|
|
|
#endregion
|
|
}
|