Update exception handling in demo

- move handling to controller
- update docs/signature to tag throwing methods

Author: rpanackal

sample-code/spring-app/src/main/java/com/sap/ai/sdk/app/controllers/OrchestrationController.java

@@ -8,8 +8,10 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.sap.ai.sdk.app.services.OrchestrationService;
 import com.sap.ai.sdk.orchestration.AzureFilterThreshold;
+import com.sap.ai.sdk.orchestration.OrchestrationClientException;
 import com.sap.ai.sdk.orchestration.model.DPIEntities;
 import com.sap.cloud.sdk.cloudplatform.thread.ThreadContextExecutors;
+import java.util.Map;
 import javax.annotation.Nonnull;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -161,21 +163,31 @@ ResponseEntity<String> inputFiltering(
    * @return a {@link ResponseEntity} containing the filtered output. The response is either in JSON
    *     format if the "accept" header specifies "application/json" or in plain content format
    *     otherwise.
+   * @throws OrchestrationClientException if the output filter filtered the LLM response.
    * @throws JsonProcessingException if an error occurs while converting the response to JSON.
    */
   @GetMapping("/outputFiltering/{policy}")
   @Nonnull
   ResponseEntity<String> outputFiltering(
       @RequestHeader(value = "accept", required = false) final String accept,
       @Nonnull @PathVariable("policy") final AzureFilterThreshold policy)
-      throws JsonProcessingException {
-    final var response = service.outputFiltering(policy);
+      throws JsonProcessingException, OrchestrationClientException {
+
+    String content;
+    try {
+      content = service.outputFiltering(policy).getContent();
+    } catch (OrchestrationClientException e) {
+      content = "Failed to obtain a response as the content was flagged by output filter.";
+      log.debug(content, e);
+    }
+
     if ("application/json".equals(accept)) {
       return ResponseEntity.ok()
           .contentType(MediaType.APPLICATION_JSON)
-          .body(mapper.writeValueAsString(response));
+          .body(mapper.writeValueAsString(Map.of("content", content)));
     }
-    return ResponseEntity.ok(response.getContent());
+
+    return ResponseEntity.ok(content);
   }
 
   /**

sample-code/spring-app/src/main/java/com/sap/ai/sdk/app/services/OrchestrationService.java

@@ -93,26 +93,21 @@ public OrchestrationChatResponse messagesHistory(@Nonnull final String prevMessa
    * @link <a
    *     href="https://help.sap.com/docs/sap-ai-core/sap-ai-core-service-guide/input-filtering">SAP
    *     AI Core: Orchestration - Input Filtering</a>
+   * @throws OrchestrationClientException if input filter filters the prompt
    * @param policy the explicitness of content that should be allowed through the filter
    * @return the assistant response object
    */
   @Nonnull
-  public OrchestrationChatResponse inputFiltering(@Nonnull final AzureFilterThreshold policy) {
+  public OrchestrationChatResponse inputFiltering(@Nonnull final AzureFilterThreshold policy)
+      throws OrchestrationClientException {
     final var prompt =
         new OrchestrationPrompt("'We shall spill blood tonight', said the operation in-charge.");
     final var filterConfig =
         new AzureContentFilter().hate(policy).selfHarm(policy).sexual(policy).violence(policy);
 
     final var configWithFilter = config.withInputFiltering(filterConfig);
 
-    try {
-      return client.chatCompletion(prompt, configWithFilter);
-    } catch (OrchestrationClientException e) {
-      if (e.getMessage().contains("400 Bad Request")) {
-        log.info("Content filtered out by input filter before any response was available.");
-      }
-      throw e;
-    }
+    return client.chatCompletion(prompt, configWithFilter);
   }
 
   /**
@@ -137,20 +132,7 @@ public OrchestrationChatResponse outputFiltering(@Nonnull final AzureFilterThres
         new AzureContentFilter().hate(policy).selfHarm(policy).sexual(policy).violence(policy);
 
     final var configWithFilter = config.withOutputFiltering(filterConfig);
-    final var response = client.chatCompletion(prompt, configWithFilter);
-
-    try {
-      response.getContent();
-    } catch (OrchestrationClientException e) {
-      if (e.getMessage().contains("filtered the output")) {
-        log.info(
-            "Content filtered out by output filter but the LLM instead responded: '{}'",
-            response.getChoice().getMessage().getContent());
-      }
-      throw e;
-    }
-
-    return response;
+    return client.chatCompletion(prompt, configWithFilter);
   }
 
   /**

sample-code/spring-app/src/test/java/com/sap/ai/sdk/app/controllers/OrchestrationTest.java

@@ -210,7 +210,7 @@ void testInputFilteringLenient() {
   void testOutputFilteringStrict() {
     var policy = AzureFilterThreshold.ALLOW_SAFE;
 
-    assertThatThrownBy(() -> service.outputFiltering(policy))
+    assertThatThrownBy(() -> service.outputFiltering(policy).getContent())
         .isInstanceOf(OrchestrationClientException.class)
         .hasMessageContaining("Content filter filtered the output.");
   }