Initial convenience class

Author: newtork

orchestration/src/main/java/com/sap/ai/sdk/orchestration/OrchestrationClient.java

@@ -219,7 +219,13 @@ public OrchestrationChatResponse executeRequestFromJsonModuleConfig(
   @Nonnull
   public Stream<OrchestrationChatCompletionDelta> streamChatCompletionDeltas(
       @Nonnull final CompletionPostRequest request) throws OrchestrationClientException {
-    request.getConfig().setStream(GlobalStreamOptions.create().enabled(true).delimiters(null));
+    val config = request.getConfig();
+    val stream = config.getStream();
+    if (stream == null) {
+      config.setStream(GlobalStreamOptions.create().enabled(true).delimiters(null));
+    } else {
+      stream.enabled(true);
+    }
 
     return executor.stream(COMPLETION_ENDPOINT, request, customHeaders);
   }

orchestration/src/main/java/com/sap/ai/sdk/orchestration/OrchestrationStreamConfig.java

@@ -24,27 +24,32 @@ public class OrchestrationStreamConfig {
    * Number of characters that should be additionally sent to content filtering services from
    * previous chunks as additional context.
    */
-  @Nullable Integer overlap;
+  @Nullable Integer filterOverlap;
 
   /** Size of the chunks the response will be split into when streaming. */
-  @Nullable Integer chunkSize = null;
+  @Nullable Integer chunkSize;
 
   /** List of delimiters to use for chunking the response when streaming. */
-  @Nullable List<String> delimiters = null;
+  @Nullable List<String> delimiters;
+
+  /** Default constructor for OrchestrationStreamConfig. */
+  public OrchestrationStreamConfig() {
+    this(null, null, null);
+  }
 
   @Nullable
   FilteringStreamOptions createFilteringStreamOptions() {
-    return overlap == null ? null : FilteringStreamOptions.create().overlap(overlap);
+    return filterOverlap == null ? null : FilteringStreamOptions.create().overlap(filterOverlap);
   }
 
   @Nullable
   GlobalStreamOptions createGlobalStreamOptions() {
     if (chunkSize == null && delimiters == null) {
       return null;
     }
-    val opts = GlobalStreamOptions.create();
+    val opts = GlobalStreamOptions.create().enabled(true);
     Optional.ofNullable(chunkSize).ifPresent(opts::setChunkSize);
-    Optional.ofNullable(delimiters).ifPresent(d -> opts.setDelimiters(List.copyOf(d)));
+    opts.setDelimiters(delimiters == null ? null : List.copyOf(delimiters));
     return opts;
   }
 }

orchestration/src/test/java/com/sap/ai/sdk/orchestration/OrchestrationUnitTest.java

@@ -481,6 +481,28 @@ void filteringLooseStream() throws IOException {
     verify(postRequestedFor(anyUrl()).withRequestBody(equalToJson(request, true, false)));
   }
 
+  @Test
+  void convenienceConfig() {
+    final var azureFilter = new AzureContentFilter().hate(ALLOW_SAFE_LOW_MEDIUM);
+
+    OrchestrationModuleConfig myConfig =
+        config
+            .withOutputFiltering(azureFilter)
+            .withOutputFilteringStreamOptions(FilteringStreamOptions.create().overlap(1_000));
+    OrchestrationModuleConfig myConfig2 =
+        config
+            .withOutputFiltering(azureFilter)
+            .withStreamConfig(new OrchestrationStreamConfig().withFilterOverlap(1_000));
+    assertThat(myConfig).isEqualTo(myConfig2);
+
+    OrchestrationModuleConfig myConfig3 =
+        config
+            .withOutputFiltering(azureFilter)
+            .withStreamConfig(
+                new OrchestrationStreamConfig().withFilterOverlap(1_000).withChunkSize(10));
+    assertThat(myConfig2).isNotEqualTo(myConfig3);
+  }
+
   @Test
   void inputFilteringStrict() {
     stubFor(

orchestration/src/test/resources/filteringLooseRequestStream.json

@@ -12,7 +12,9 @@
             "top_p": 1,
             "n": 1
           },
-          "version": "latest"
+          "version": "latest",
+          "timeout" : 600,
+          "max_retries" : 2
         },
         "prompt": {
           "template": [