test: add workflow application tests

Author: ikesnowy

src/Cnblogs.DashScope.Core/ApplicationInput.cs

@@ -3,32 +3,32 @@
 /// <summary>
 /// Inputs for application call.
 /// </summary>
-/// <typeparam name="TBizContent">Type of the BizContent.</typeparam>
-public class ApplicationInput<TBizContent>
-    where TBizContent : class
+/// <typeparam name="TBizParams">Type of the BizContent.</typeparam>
+public class ApplicationInput<TBizParams>
+    where TBizParams : class
 {
     /// <summary>
     /// The prompt for model to generate response upon. Optional when <see cref="Messages"/> has been set.
     /// </summary>
     /// <remarks>
     /// Prompt will be appended to <see cref="Messages"/> when both set.
     /// </remarks>
-    public string? Prompt { get; set; } = null;
+    public string? Prompt { get; set; }
 
     /// <summary>
     /// The session id for conversation history. This will be ignored if <see cref="Messages"/> has been set.
     /// </summary>
-    public string? SessionId { get; set; } = null;
+    public string? SessionId { get; set; }
 
     /// <summary>
     /// The conversation history.
     /// </summary>
-    public IEnumerable<ApplicationMessage>? Messages { get; set; } = null;
+    public IEnumerable<ApplicationMessage>? Messages { get; set; }
 
     /// <summary>
     /// The id of memory when enabled.
     /// </summary>
-    public string? MemoryId { get; set; } = null;
+    public string? MemoryId { get; set; }
 
     /// <summary>
     /// List of image urls for inputs.
@@ -38,7 +38,7 @@ public class ApplicationInput<TBizContent>
     /// <summary>
     /// User defined content.
     /// </summary>
-    public TBizContent? Content { get; set; } = null;
+    public TBizParams? BizParams { get; set; } = null;
 }
 
 /// <summary>

src/Cnblogs.DashScope.Core/ApplicationRequest.cs

@@ -3,14 +3,14 @@
 /// <summary>
 /// Request body for an application all.
 /// </summary>
-/// <typeparam name="TBizContent">Type of the biz_content</typeparam>
-public class ApplicationRequest<TBizContent>
-    where TBizContent : class
+/// <typeparam name="TBizParams">Type of the biz_content</typeparam>
+public class ApplicationRequest<TBizParams>
+    where TBizParams : class
 {
     /// <summary>
     /// Content of this call.
     /// </summary>
-    public required ApplicationInput<TBizContent> Input { get; init; }
+    public required ApplicationInput<TBizParams> Input { get; init; }
 
     /// <summary>
     /// Optional configurations.

src/Cnblogs.DashScope.Core/ApplicationUsage.cs

@@ -3,5 +3,5 @@
 /// <summary>
 /// Total token usages of this application call.
 /// </summary>
-/// <param name="Models">All models been used and their token usages.</param>
-public record ApplicationUsage(List<ApplicationModelUsage> Models);
+/// <param name="Models">All models been used and their token usages. Can be null when workflow application without using any model.</param>
+public record ApplicationUsage(List<ApplicationModelUsage>? Models);

src/Cnblogs.DashScope.Core/IDashScopeClient.cs

@@ -1,4 +1,6 @@
-namespace Cnblogs.DashScope.Core;
+using System.Text.Json;
+
+namespace Cnblogs.DashScope.Core;
 
 /// <summary>
 /// DashScope APIs.
@@ -28,13 +30,13 @@ Task<ApplicationResponse> GetApplicationResponseAsync(
     /// <param name="applicationId">Name of the application.</param>
     /// <param name="input">The request body.</param>
     /// <param name="cancellationToken">The cancellation token to use.</param>
-    /// <typeparam name="TBizContent">Type of the biz_content.</typeparam>
+    /// <typeparam name="TBizParams">Type of the biz_content.</typeparam>
     /// <returns></returns>
-    Task<ApplicationResponse> GetApplicationResponseAsync<TBizContent>(
+    Task<ApplicationResponse> GetApplicationResponseAsync<TBizParams>(
         string applicationId,
-        ApplicationRequest<TBizContent> input,
+        ApplicationRequest<TBizParams> input,
         CancellationToken cancellationToken = default)
-        where TBizContent : class;
+        where TBizParams : class;
 
     /// <summary>
     /// Make a call to custom application.

test/Cnblogs.DashScope.Sdk.UnitTests/ApplicationSerializationTests.cs

@@ -118,4 +118,22 @@ public async Task SingleCompletion_MemoryNoSse_SuccessAsync()
             Arg.Any<CancellationToken>());
         response.Should().BeEquivalentTo(testCase.ResponseModel);
     }
+
+    [Fact]
+    public async Task SingleCompletion_WorkflowNoSse_SuccessAsync()
+    {
+        // Arrange
+        const bool sse = false;
+        var testCase = Snapshots.Application.WorkflowNoSse;
+        var (client, handler) = await Sut.GetTestClientAsync(sse, testCase);
+
+        // Act
+        var response = await client.GetApplicationResponseAsync("anyId", testCase.RequestModel);
+
+        // Assert
+        handler.Received().MockSend(
+            Arg.Is<HttpRequestMessage>(m => Checkers.IsJsonEquivalent(m.Content!, testCase.GetRequestJson(sse))),
+            Arg.Any<CancellationToken>());
+        response.Should().BeEquivalentTo(testCase.ResponseModel);
+    }
 }

test/Cnblogs.DashScope.Sdk.UnitTests/RawHttpData/application-workflow-nosse.request.body.json

@@ -0,0 +1,14 @@
+{
+  "input": {
+    "prompt": "请你跟我这样说",
+    "biz_params": {
+      "sourceCode": "code"
+    }
+  },
+  "parameters": {
+    "top_k": 100,
+    "top_p": 0.8,
+    "seed": 1234,
+    "temperature": 0.85
+  }
+}

test/Cnblogs.DashScope.Sdk.UnitTests/RawHttpData/application-workflow-nosse.request.header.txt

@@ -0,0 +1,8 @@
+POST /api/v1/apps/debbb624ccfd4ebdac605edc27f94f7a/completion HTTP/1.1
+Content-Type: application/json
+Accept: */*
+Cache-Control: no-cache
+Host: dashscope.aliyuncs.com
+Accept-Encoding: gzip, deflate, br
+Connection: keep-alive
+Content-Length: 268

test/Cnblogs.DashScope.Sdk.UnitTests/RawHttpData/application-workflow-nosse.response.body.txt

@@ -0,0 +1 @@
+{"output":{"finish_reason":"stop","session_id":"5a20b47dac2f43a7b1cbb8924ca66c47","text":"code"},"usage":{},"request_id":"10990f51-e2d0-9338-9c52-319af5f4858b"}

test/Cnblogs.DashScope.Sdk.UnitTests/RawHttpData/application-workflow-nosse.response.header.txt

@@ -0,0 +1,15 @@
+HTTP/1.1 200 OK
+vary: Origin,Access-Control-Request-Method,Access-Control-Request-Headers, Accept-Encoding
+content-type: application/json
+x-request-id: 10990f51-e2d0-9338-9c52-319af5f4858b
+x-dashscope-timeout: 180
+x-dashscope-call-gateway: true
+x-dashscope-finished: true
+req-cost-time: 414
+req-arrive-time: 1742133858888
+resp-start-time: 1742133859303
+x-envoy-upstream-service-time: 406
+content-encoding: gzip
+date: Sun, 16 Mar 2025 14:04:18 GMT
+server: istio-envoy
+transfer-encoding: chunked

test/Cnblogs.DashScope.Sdk.UnitTests/Utils/Snapshots.Application.cs

@@ -250,6 +250,29 @@ public static class Application
                         null),
                     new ApplicationUsage([new ApplicationModelUsage("qwen-plus", 1201, 43)])));
 
+        public static readonly RequestSnapshot<ApplicationRequest<TestApplicationBizParam>, ApplicationResponse>
+            WorkflowNoSse =
+                new(
+                    "application-workflow",
+                    new ApplicationRequest<TestApplicationBizParam>()
+                    {
+                        Input = new ApplicationInput<TestApplicationBizParam>()
+                        {
+                            BizParams = new TestApplicationBizParam("code"), Prompt = "请你跟我这样说"
+                        },
+                        Parameters = new ApplicationParameters()
+                        {
+                            TopK = 100,
+                            TopP = 0.8f,
+                            Seed = 1234,
+                            Temperature = 0.85f,
+                        }
+                    },
+                    new ApplicationResponse(
+                        "10990f51-e2d0-9338-9c52-319af5f4858b",
+                        new ApplicationOutput("code", "stop", "5a20b47dac2f43a7b1cbb8924ca66c47", null, null),
+                        new ApplicationUsage(null)));
+
         public static readonly RequestSnapshot<ApplicationRequest, ApplicationResponse> ConversationSessionIdNoSse =
             new(
                 "application-conversation-generation-session-id",