test(response): json-seq sequential media type

Author: Fresa

tests/Example.OpenApi32.IntegrationTests/ExportFooEventsTests.cs

@@ -31,4 +31,31 @@ public async Task ExportingFooEvents_ShouldReturnOkWithJsonl()
         JsonNode.Parse(lines[0]).GetValue<string>("#/Name").Should().Be("foo1");
         JsonNode.Parse(lines[1]).GetValue<string>("#/Name").Should().Be("foo2");
     }
-}
+    
+    [Fact]
+    public async Task ExportingFooEvents_ShouldReturnOkWithJsonSeq()
+    {
+        using var client = app.CreateClient();
+        var request = new HttpRequestMessage
+        {
+            RequestUri = new Uri(client.BaseAddress!, "/foo/1/events"),
+            Method = HttpMethod.Get
+        };
+        request.Headers.Accept.ParseAdd("application/json-seq");
+
+        var result = await client.SendAsync(request, CancellationToken);
+
+        result.StatusCode.Should().Be(HttpStatusCode.OK);
+        result.Content.Headers.ContentType?.MediaType.Should().Be("application/json-seq");
+
+        var content = await result.Content.ReadAsStringAsync(CancellationToken);
+        testOutput.WriteLine("Content:");
+        testOutput.WriteLine(content);
+        var lines = content.Split('\n', StringSplitOptions.RemoveEmptyEntries)
+            .Select(s => s.Trim((char)0x1E))
+            .ToArray();
+        lines.Should().HaveCount(2);
+        JsonNode.Parse(lines[0]).GetValue<string>("#/Name").Should().Be("foo1");
+        JsonNode.Parse(lines[1]).GetValue<string>("#/Name").Should().Be("foo2");
+    }
+}

tests/Example.OpenApi32/Paths/FooFooIdEvents/Get/Operation.Handler.cs

@@ -8,10 +8,15 @@ internal partial Task<Response> HandleAsync(Request request, CancellationToken c
         {
             case false:
             case true when matchedMediaType == Response.OK200.ApplicationJsonl.ContentMediaType:
-                var response = new Response.OK200.ApplicationJsonl(request);
-                response.WriteItem(Components.Schemas.FooProperties.Create(name: "foo1"));
-                response.WriteItem(Components.Schemas.FooProperties.Create(name: "foo2"));
-                return Task.FromResult<Response>(response);
+                var jsonl = new Response.OK200.ApplicationJsonl(request);
+                jsonl.WriteItem(Components.Schemas.FooProperties.Create(name: "foo1"));
+                jsonl.WriteItem(Components.Schemas.FooProperties.Create(name: "foo2"));
+                return Task.FromResult<Response>(jsonl);
+            case true when matchedMediaType == Response.OK200.ApplicationJsonSeq.ContentMediaType:
+                var jsonSeq = new Response.OK200.ApplicationJsonSeq(request);
+                jsonSeq.WriteItem(Components.Schemas.FooProperties.Create(name: "foo1"));
+                jsonSeq.WriteItem(Components.Schemas.FooProperties.Create(name: "foo2"));
+                return Task.FromResult<Response>(jsonSeq);
             default:
                 throw new NotImplementedException($"Content media type {matchedMediaType} has not been implemented");
         }

tests/Example.OpenApi32/openapi.json

@@ -92,6 +92,11 @@
                 "itemSchema": {
                   "$ref": "#/components/schemas/FooProperties"
                 }
+              },
+              "application/json-seq": {
+                "itemSchema": {
+                  "$ref": "#/components/schemas/FooProperties"
+                }
               }
             }
           }