.Net: add amazon nova support (text) only

dotnet/src/Connectors/Connectors.Amazon/Bedrock/Core/BedrockServiceFactory.cs

@@ -32,7 +32,7 @@ internal IBedrockTextGenerationService CreateTextGenerationService(string modelI
                 }
                 throw new NotSupportedException($"Unsupported AI21 model: {modelId}");
             case "AMAZON":
-                if (modelName.StartsWith("titan-", StringComparison.OrdinalIgnoreCase))
+                if (modelName.StartsWith("titan-", StringComparison.OrdinalIgnoreCase) || modelName.StartsWith("nova-", StringComparison.OrdinalIgnoreCase))
                 {
                     return new AmazonService();
                 }

dotnet/src/Connectors/Connectors.Amazon/Bedrock/Core/Clients/BedrockTextGenerationClient.cs

@@ -7,6 +7,7 @@
 using System.Runtime.CompilerServices;
 using System.Text.Json;
 using System.Text.Json.Nodes;
+using System.Text.Json.Serialization;
 using System.Threading;
 using System.Threading.Tasks;
 using Amazon.BedrockRuntime;
@@ -76,7 +77,7 @@ internal async Task<IReadOnlyList<TextContent>> InvokeBedrockModelAsync(
         try
         {
             var requestBody = this._ioTextService.GetInvokeModelRequestBody(this._modelId, prompt, executionSettings);
-            using var requestBodyStream = new MemoryStream(JsonSerializer.SerializeToUtf8Bytes(requestBody));
+            using var requestBodyStream = new MemoryStream(JsonSerializer.SerializeToUtf8Bytes(requestBody, new JsonSerializerOptions { DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull }));
             invokeRequest.Body = requestBodyStream;
 
             response = await this._bedrockRuntime.InvokeModelAsync(invokeRequest, cancellationToken).ConfigureAwait(false);
@@ -111,7 +112,7 @@ internal async Task<IReadOnlyList<TextContent>> InvokeBedrockModelAsync(
         }
         activityStatus = BedrockClientUtilities.ConvertHttpStatusCodeToActivityStatusCode(response.HttpStatusCode);
         activity?.SetStatus(activityStatus);
-        IReadOnlyList<TextContent> textResponse = this._ioTextService.GetInvokeResponseBody(response);
+        IReadOnlyList<TextContent> textResponse = this._ioTextService.GetInvokeResponseBody(this._modelId, response);
         activity?.SetCompletionResponse(textResponse);
         return textResponse;
     }
@@ -178,7 +179,7 @@ internal async IAsyncEnumerable<StreamingTextContent> StreamTextAsync(
             {
                 continue;
             }
-            IEnumerable<string> texts = this._ioTextService.GetTextStreamOutput(chunk);
+            IEnumerable<string> texts = this._ioTextService.GetTextStreamOutput(this._modelId, chunk);
             foreach (var text in texts)
             {
                 var content = new StreamingTextContent(text);

dotnet/src/Connectors/Connectors.Amazon/Bedrock/Core/IBedrockTextGenerationService.cs

@@ -23,14 +23,15 @@ internal interface IBedrockTextGenerationService
     /// <summary>
     /// Extracts the text contents from the <see cref="InvokeModelResponse"/>.
     /// </summary>
+    /// <param name="modelId">The model ID to be used as a request parameter.</param>
     /// <param name="response">The <see cref="InvokeModelResponse"/> instance to be returned from the InvokeAsync Bedrock call.</param>
     /// <returns>The list of TextContent objects for the Semantic Kernel output.</returns>
-    internal IReadOnlyList<TextContent> GetInvokeResponseBody(InvokeModelResponse response);
+    internal IReadOnlyList<TextContent> GetInvokeResponseBody(string modelId, InvokeModelResponse response);
 
     /// <summary>
     /// Converts the streaming JSON into <see cref="IEnumerable{String}"/> for output.
     /// </summary>
     /// <param name="chunk">The payloadPart bytes provided from the streaming response.</param>
     /// <returns><see cref="IEnumerable{String}"/> output strings.</returns>
-    internal IEnumerable<string> GetTextStreamOutput(JsonNode chunk);
+    internal IEnumerable<string> GetTextStreamOutput(string modelId, JsonNode chunk);
 }

dotnet/src/Connectors/Connectors.Amazon/Bedrock/Core/Models/AI21Labs/AI21JambaService.cs

@@ -46,7 +46,7 @@ public object GetInvokeModelRequestBody(string modelId, string prompt, PromptExe
     }
 
     /// <inheritdoc/>
-    public IReadOnlyList<TextContent> GetInvokeResponseBody(InvokeModelResponse response)
+    public IReadOnlyList<TextContent> GetInvokeResponseBody(string modelId, InvokeModelResponse response)
     {
         using var reader = new StreamReader(response.Body);
         var responseBody = JsonSerializer.Deserialize<AI21JambaResponse.AI21TextResponse>(reader.ReadToEnd());
@@ -108,7 +108,7 @@ public ConverseRequest GetConverseRequest(string modelId, ChatHistory chatHistor
     }
 
     /// <inheritdoc/>
-    public IEnumerable<string> GetTextStreamOutput(JsonNode chunk)
+    public IEnumerable<string> GetTextStreamOutput(string modelId, JsonNode chunk)
     {
         var choiceDeltaContent = chunk["choices"]?[0]?["delta"]?["content"];
         if (choiceDeltaContent is not null)

dotnet/src/Connectors/Connectors.Amazon/Bedrock/Core/Models/AI21Labs/AI21JurassicService.cs

@@ -34,7 +34,7 @@ public object GetInvokeModelRequestBody(string modelId, string prompt, PromptExe
     }
 
     /// <inheritdoc/>
-    public IReadOnlyList<TextContent> GetInvokeResponseBody(InvokeModelResponse response)
+    public IReadOnlyList<TextContent> GetInvokeResponseBody(string modelId, InvokeModelResponse response)
     {
         using var reader = new StreamReader(response.Body);
         var responseBody = JsonSerializer.Deserialize<AI21JurassicResponse>(reader.ReadToEnd());
@@ -48,7 +48,7 @@ public IReadOnlyList<TextContent> GetInvokeResponseBody(InvokeModelResponse resp
     }
 
     /// <inheritdoc/>
-    public IEnumerable<string> GetTextStreamOutput(JsonNode chunk)
+    public IEnumerable<string> GetTextStreamOutput(string modelId, JsonNode chunk)
     {
         throw new NotSupportedException("Streaming not supported by this model.");
     }