Canonicalize classified stream failures

runtime/csharp/Prompty.Core.Tests/Model/events/FailureChunkConversionTests.cs

@@ -0,0 +1,124 @@
+// <auto-generated by typra-emitter>
+using Xunit;
+
+#pragma warning disable IDE0130
+namespace Prompty.Core;
+#pragma warning restore IDE0130
+
+
+public class FailureChunkConversionTests
+{
+    [Fact]
+    public void LoadYamlInput()
+    {
+        string yamlData = """
+failure:
+  outcome: indeterminate
+  message: "SSE stream error: connection reset"
+
+""";
+
+        var instance = FailureChunk.FromYaml(yamlData);
+
+        Assert.NotNull(instance);
+    }
+
+    [Fact]
+    public void LoadJsonInput()
+    {
+        string jsonData = """
+{
+  "failure": {
+    "outcome": "indeterminate",
+    "message": "SSE stream error: connection reset"
+  }
+}
+""";
+
+        var instance = FailureChunk.FromJson(jsonData);
+        Assert.NotNull(instance);
+    }
+
+    [Fact]
+    public void RoundtripJson()
+    {
+        // Test that FromJson -> ToJson -> FromJson produces equivalent data
+        string jsonData = """
+{
+  "failure": {
+    "outcome": "indeterminate",
+    "message": "SSE stream error: connection reset"
+  }
+}
+""";
+
+        var original = FailureChunk.FromJson(jsonData);
+        Assert.NotNull(original);
+
+        var json = original.ToJson();
+        Assert.False(string.IsNullOrEmpty(json));
+
+        var reloaded = FailureChunk.FromJson(json);
+        Assert.NotNull(reloaded);
+    }
+
+    [Fact]
+    public void RoundtripYaml()
+    {
+        // Test that FromYaml -> ToYaml -> FromYaml produces equivalent data
+        string yamlData = """
+failure:
+  outcome: indeterminate
+  message: "SSE stream error: connection reset"
+
+""";
+
+        var original = FailureChunk.FromYaml(yamlData);
+        Assert.NotNull(original);
+
+        var yaml = original.ToYaml();
+        Assert.False(string.IsNullOrEmpty(yaml));
+
+        var reloaded = FailureChunk.FromYaml(yaml);
+        Assert.NotNull(reloaded);
+    }
+
+    [Fact]
+    public void ToJsonProducesValidJson()
+    {
+        string jsonData = """
+{
+  "failure": {
+    "outcome": "indeterminate",
+    "message": "SSE stream error: connection reset"
+  }
+}
+""";
+
+        var instance = FailureChunk.FromJson(jsonData);
+        var json = instance.ToJson();
+
+        // Verify it's valid JSON by parsing it
+        var parsed = System.Text.Json.JsonDocument.Parse(json);
+        Assert.NotNull(parsed);
+    }
+
+    [Fact]
+    public void ToYamlProducesValidYaml()
+    {
+        string yamlData = """
+failure:
+  outcome: indeterminate
+  message: "SSE stream error: connection reset"
+
+""";
+
+        var instance = FailureChunk.FromYaml(yamlData);
+        var yaml = instance.ToYaml();
+
+        // Verify it's valid YAML by parsing it
+        var deserializer = new YamlDotNet.Serialization.DeserializerBuilder().Build();
+        var parsed = deserializer.Deserialize<object>(yaml);
+        Assert.NotNull(parsed);
+    }
+}

runtime/csharp/Prompty.Core.Tests/Model/events/StreamFailureConversionTests.cs

@@ -0,0 +1,123 @@
+// <auto-generated by typra-emitter>
+using Xunit;
+
+#pragma warning disable IDE0130
+namespace Prompty.Core;
+#pragma warning restore IDE0130
+
+
+public class StreamFailureConversionTests
+{
+    [Fact]
+    public void LoadYamlInput()
+    {
+        string yamlData = """
+outcome: indeterminate
+message: "SSE stream error: connection reset"
+
+""";
+
+        var instance = StreamFailure.FromYaml(yamlData);
+
+        Assert.NotNull(instance);
+        Assert.Equal(StreamFailureOutcome.Indeterminate, instance.Outcome);
+        Assert.Equal("SSE stream error: connection reset", instance.Message);
+    }
+
+    [Fact]
+    public void LoadJsonInput()
+    {
+        string jsonData = """
+{
+  "outcome": "indeterminate",
+  "message": "SSE stream error: connection reset"
+}
+""";
+
+        var instance = StreamFailure.FromJson(jsonData);
+        Assert.NotNull(instance);
+        Assert.Equal(StreamFailureOutcome.Indeterminate, instance.Outcome);
+        Assert.Equal("SSE stream error: connection reset", instance.Message);
+    }
+
+    [Fact]
+    public void RoundtripJson()
+    {
+        // Test that FromJson -> ToJson -> FromJson produces equivalent data
+        string jsonData = """
+{
+  "outcome": "indeterminate",
+  "message": "SSE stream error: connection reset"
+}
+""";
+
+        var original = StreamFailure.FromJson(jsonData);
+        Assert.NotNull(original);
+
+        var json = original.ToJson();
+        Assert.False(string.IsNullOrEmpty(json));
+
+        var reloaded = StreamFailure.FromJson(json);
+        Assert.NotNull(reloaded);
+        Assert.Equal(StreamFailureOutcome.Indeterminate, reloaded.Outcome);
+        Assert.Equal("SSE stream error: connection reset", reloaded.Message);
+    }
+
+    [Fact]
+    public void RoundtripYaml()
+    {
+        // Test that FromYaml -> ToYaml -> FromYaml produces equivalent data
+        string yamlData = """
+outcome: indeterminate
+message: "SSE stream error: connection reset"
+
+""";
+
+        var original = StreamFailure.FromYaml(yamlData);
+        Assert.NotNull(original);
+
+        var yaml = original.ToYaml();
+        Assert.False(string.IsNullOrEmpty(yaml));
+
+        var reloaded = StreamFailure.FromYaml(yaml);
+        Assert.NotNull(reloaded);
+        Assert.Equal(StreamFailureOutcome.Indeterminate, reloaded.Outcome);
+        Assert.Equal("SSE stream error: connection reset", reloaded.Message);
+    }
+
+    [Fact]
+    public void ToJsonProducesValidJson()
+    {
+        string jsonData = """
+{
+  "outcome": "indeterminate",
+  "message": "SSE stream error: connection reset"
+}
+""";
+
+        var instance = StreamFailure.FromJson(jsonData);
+        var json = instance.ToJson();
+
+        // Verify it's valid JSON by parsing it
+        var parsed = System.Text.Json.JsonDocument.Parse(json);
+        Assert.NotNull(parsed);
+    }
+
+    [Fact]
+    public void ToYamlProducesValidYaml()
+    {
+        string yamlData = """
+outcome: indeterminate
+message: "SSE stream error: connection reset"
+
+""";
+
+        var instance = StreamFailure.FromYaml(yamlData);
+        var yaml = instance.ToYaml();
+
+        // Verify it's valid YAML by parsing it
+        var deserializer = new YamlDotNet.Serialization.DeserializerBuilder().Build();
+        var parsed = deserializer.Deserialize<object>(yaml);
+        Assert.NotNull(parsed);
+    }
+}