[ Fix ] fixed the multi listening for HTTP streamed responses by the package logger

This commit is contained in:
Anas Fikhi
2024-02-22 00:05:03 +01:00
parent dafde94c0b
commit c91a9c65b8
3 changed files with 9 additions and 11 deletions

View File

@ -458,7 +458,7 @@ abstract class OpenAINetworkingClient {
final String encodedBody = await response.stream.bytesToString();
OpenAILogger.logResponseBody(response);
OpenAILogger.logResponseBody(encodedBody);
final Map<String, dynamic> decodedBody = decodeToMap(encodedBody);
@ -511,7 +511,7 @@ abstract class OpenAINetworkingClient {
final String encodedBody = await response.stream.bytesToString();
OpenAILogger.logResponseBody(response);
OpenAILogger.logResponseBody(encodedBody);
final Map<String, dynamic> decodedBody = decodeToMap(encodedBody);
@ -559,14 +559,14 @@ abstract class OpenAINetworkingClient {
final http.StreamedResponse response =
await request.send().timeout(OpenAIConfig.requestsTimeOut);
OpenAILogger.logResponseBody(response);
final String responseBody = await response.stream.bytesToString();
OpenAILogger.logResponseBody(responseBody);
OpenAILogger.requestToWithStatusCode(to, response.statusCode);
OpenAILogger.startingDecoding();
final String responseBody = await response.stream.bytesToString();
var resultBody;
resultBody = switch ((responseBody.canBeParsedToJson, responseMapAdapter)) {

View File

@ -56,15 +56,13 @@ abstract final class OpenAILogger {
}
/// Logs the response of a request, if the logger is active.
static Future<void> logResponseBody(response) async {
static void logResponseBody(response) {
if (_isActive && _showResponsesLogs) {
if (response is Response) {
dev.log(response.body.toString(), name: OpenAIStrings.openai);
} else if (response is StreamedResponse) {
final asString = await response.stream.bytesToString();
} else {
dev.log(
asString,
response.toString(),
name: OpenAIStrings.openai,
);
}

View File

@ -38,7 +38,7 @@ void main() async {
}
});
test('with setting a key', () {
OpenAI.apiKey = "YOUR API KEY HERE";
OpenAI.apiKey = "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";
expect(OpenAI.instance, isA<OpenAI>());
});