[ Fix ] fixed the doubled stream responses from completion and fine-t…

…unes events
anasfik · Feb 17, 2023 · f01720f · f01720f
1 parent 2d39392
commit f01720f
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 6 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,8 @@
+# 1.4.8
+
+- Fix issues
+- Fix doubled stream snapshots than expected.
+
 # 1.4.6
 
 - Changed the use of dotenv to envied package.

diff --git a/lib/src/core/networking/client.dart b/lib/src/core/networking/client.dart
@@ -31,7 +31,8 @@ class OpenAINetworkingClient {
     OpenAILogger.log("starting decoding response body");
     Utf8Decoder utf8decoder = Utf8Decoder();
     final Map<String, dynamic> decodedBody =
-        jsonDecode(utf8decoder.convert(response.bodyBytes)) as Map<String, dynamic>;
+        jsonDecode(utf8decoder.convert(response.bodyBytes))
+            as Map<String, dynamic>;
 
     OpenAILogger.log("response body decoded successfully");
 
@@ -67,7 +68,8 @@ class OpenAINetworkingClient {
       streamedResponse.stream.listen((value) {
         final String data = utf8.decode(value);
 
-        final List<String> dataLines = data.split("\n");
+        final List<String> dataLines =
+            data.split("\n").where((element) => element.isNotEmpty).toList();
 
         for (String line in dataLines) {
           if (line.startsWith("data: ")) {
@@ -111,7 +113,8 @@ class OpenAINetworkingClient {
     OpenAILogger.log("starting decoding response body");
     Utf8Decoder utf8decoder = Utf8Decoder();
     final Map<String, dynamic> decodedBody =
-        jsonDecode(utf8decoder.convert(response.bodyBytes)) as Map<String, dynamic>;
+        jsonDecode(utf8decoder.convert(response.bodyBytes))
+            as Map<String, dynamic>;
     OpenAILogger.log("response body decoded successfully");
 
     if (decodedBody['error'] != null) {
@@ -192,7 +195,8 @@ class OpenAINetworkingClient {
         respond.stream.listen((value) {
           final String data = utf8.decode(value);
 
-          final List<String> dataLines = data.split("\n");
+          final List<String> dataLines =
+              data.split("\n").where((element) => element.isNotEmpty).toList();
 
           for (String line in dataLines) {
             if (line.startsWith("data: ")) {
@@ -203,6 +207,7 @@ class OpenAINetworkingClient {
               }
 
               final decoded = jsonDecode(data) as Map<String, dynamic>;
+
               controller.add(onSuccess(decoded));
             }
           }

diff --git a/pubspec.yaml b/pubspec.yaml
@@ -1,10 +1,10 @@
 name: dart_openai
 description: Dart SDK for openAI Apis (GPT-3 & DALL-E), integrate easily the power of OpenAI's state-of-the-art AI models into their Dart applications.
-version: 1.4.6
+version: 1.4.8
 homepage: https://github.com/anasfik/openai
 repository: https://github.com/anasfik/openai
 documentation: https://github.com/anasfik/openai/blob/main/README.md
-
+issue_tracker: https://github.com/anasfik/openai/issues
 environment:
   sdk: ">=2.18.5 <3.0.0"