fix streaming error with v1/responses

Author: MaxiDonkey@hotmail.com

source/GenAI.API.pas

@@ -243,7 +243,7 @@   TApiDeserializer = class(TApiHttpHandler)
   /// </remarks>
   TGenAIAPI = class(TApiDeserializer)
   private
-    function MockJsonResponse(const FieldName: string; Response: TStringStream): string;
+    function MockJsonResponse(const FieldName: string; Response: TStringStream): string; overload;
     function MockJsonFile(const FieldName: string; Response: TStringStream): string;
   public
     /// <summary>
@@ -362,6 +362,31 @@   TGenAIAPI = class(TApiDeserializer)
     /// </exception>
     function Post<TParams: TJSONParam>(const Endpoint: string; ParamProc: TProc<TParams>; Response: TStringStream; Event: TReceiveDataCallback): Boolean; overload;
     /// <summary>
+    /// Sends a POST request with parameters and streams the response.
+    /// </summary>
+    /// <typeparam name="TParams">
+    /// The type of the parameters object for the request.
+    /// </typeparam>
+    /// <param name="Endpoint">
+    /// The relative endpoint to send the POST request to.
+    /// </param>
+    /// <param name="ParamProc">
+    /// A callback procedure to configure the request parameters.
+    /// </param>
+    /// <param name="Response">
+    /// A string stream where the response will be written.
+    /// </param>
+    /// <param name="Event">
+    /// A callback procedure for handling the received data during streaming.
+    /// </param>
+    /// <returns>
+    /// A boolean value indicating whether the request was successful.
+    /// </returns>
+    /// <exception cref="GenAIInvalidResponseError">
+    /// Raised if the response cannot be deserialized or is non-compliant.
+    /// </exception>
+    function Post<TParams: TJSONParam>(const Endpoint: string; ParamProc: TProc<TParams>; Response: TStream; Event: TReceiveDataCallback): Boolean; overload;
+    /// <summary>
     /// Sends a POST request with parameters and returns a strongly typed object.
     /// </summary>
     /// <typeparam name="TResult">
@@ -488,6 +513,38 @@ constructor TGenAIAPI.Create(const AAPIKey: string);
   APIKey := AAPIKey;
 end;
 
+function TGenAIAPI.Post<TParams>(const Endpoint: string;
+  ParamProc: TProc<TParams>; Response: TStream;
+  Event: TReceiveDataCallback): Boolean;
+var
+  Params: TParams;
+begin
+  Monitoring.Inc;
+  Params := TParams.Create;
+  try
+    if Assigned(ParamProc) then
+      ParamProc(Params);
+    var Code := HttpClient.Post(BuildUrl(Endpoint), Params.JSON, Response, BuildJsonHeaders, Event);
+    Result := (Code > 200) and (Code < 299);
+    case Code of
+      200..299:
+        Result := True;
+      else
+        begin
+          Response.Position := 0;
+          var ErrBytes: TBytes;
+          SetLength(ErrBytes, Response.Size);
+          Response.ReadBuffer(ErrBytes, Length(ErrBytes));
+          DeserializeErrorData(Code, TEncoding.UTF8.GetString(ErrBytes));
+        end;
+    end;
+  finally
+    Params.Free;
+    ResetCustomHeader;
+    Monitoring.Dec;
+  end;
+end;
+
 function TGenAIAPI.Post<TResult, TParams>(const Endpoint: string; ParamProc: TProc<TParams>;
   const RawByteFieldName: string): TResult;
 begin

source/GenAI.HttpClientAPI.pas

@@ -142,6 +142,28 @@   THttpClientAPI = class(TInterfacedObject, IHttpClientAPI)
     /// </returns>
     function Post(const URL: string; Body: TJSONObject; Response: TStringStream; const Headers: TNetHeaders; OnReceiveData: TReceiveDataCallback): Integer; overload;
     /// <summary>
+    /// Sends an HTTP POST request with a JSON body to the specified URL and handles a full streamed responses.
+    /// </summary>
+    /// <param name="URL">
+    /// The endpoint URL to send the POST request to.
+    /// </param>
+    /// <param name="Body">
+    /// The JSON object to include in the POST request body.
+    /// </param>
+    /// <param name="Response">
+    /// A string stream to capture the response content.
+    /// </param>
+    /// <param name="Headers">
+    /// A list of HTTP headers to include in the request.
+    /// </param>
+    /// <param name="OnReceiveData">
+    /// A callback procedure to handle data as it is received during the streaming process.
+    /// </param>
+    /// <returns>
+    /// The HTTP status code returned by the server.
+    /// </returns>
+    function Post(const URL: string; Body: TJSONObject; Response: TStream; const Headers: TNetHeaders; OnReceiveData: TReceiveDataCallback): Integer; overload;
+    /// <summary>
     /// Sends an HTTP PATCH request with a JSON body to the specified URL.
     /// </summary>
     /// <param name="URL">
@@ -317,4 +339,25 @@ function THttpClientAPI.Post(const URL: string; Response: TStringStream;
   Result := FHttpClient.Post(URL, Stream, Response, Headers).StatusCode;
 end;
 
+function THttpClientAPI.Post(const URL: string; Body: TJSONObject;
+  Response: TStream; const Headers: TNetHeaders;
+  OnReceiveData: TReceiveDataCallback): Integer;
+begin
+  CheckAPISettings;
+
+  {--- Query always encoded in explicit UTF-8 }
+  var Bytes := TEncoding.UTF8.GetBytes(Body.ToJSON);
+  var Req   := TMemoryStream.Create;
+  Req.WriteBuffer(Bytes, Length(Bytes));
+  Req.Position := 0;
+
+  FHttpClient.ReceiveDataCallback := OnReceiveData;
+  try
+    Result := FHttpClient.Post(URL, Req, Response, Headers).StatusCode;
+  finally
+    FHttpClient.ReceiveDataCallback := nil;
+    Req.Free;
+  end;
+end;
+
 end.

source/GenAI.HttpClientInterface.pas

@@ -229,6 +229,28 @@ interface
     /// </returns>
     function Post(const URL: string; Body: TJSONObject; Response: TStringStream; const Headers: TNetHeaders; OnReceiveData: TReceiveDataCallback): Integer; overload;
     /// <summary>
+    /// Sends an HTTP POST request with a JSON body to the specified URL and handles full streamed responses.
+    /// </summary>
+    /// <param name="URL">
+    /// The endpoint URL to send the POST request to.
+    /// </param>
+    /// <param name="Body">
+    /// The JSON object to include in the POST request body.
+    /// </param>
+    /// <param name="Response">
+    /// A string stream to capture the response content.
+    /// </param>
+    /// <param name="Headers">
+    /// A list of HTTP headers to include in the request.
+    /// </param>
+    /// <param name="OnReceiveData">
+    /// A callback procedure to handle data as it is received during the streaming process.
+    /// </param>
+    /// <returns>
+    /// The HTTP status code returned by the server.
+    /// </returns>
+    function Post(const URL: string; Body: TJSONObject; Response: TStream; const Headers: TNetHeaders; OnReceiveData: TReceiveDataCallback): Integer; overload;
+    /// <summary>
     /// Sends an HTTP PATCH request with a JSON body to the specified URL.
     /// </summary>
     /// <param name="URL">