fix: large file content may fail (#1176)

* fix: large file content may fail

* fix: in case of add empty

Author: wssgcg1213

kraken/lib/src/foundation/http_client_request.dart

@@ -170,8 +170,10 @@ class ProxyHttpClientRequest extends HttpClientRequest {
 
       request = await _createBackendClientRequest();
       // Send the real data to backend client.
-      request.add(_data);
-      _data.clear();
+      if (_data.isNotEmpty) {
+        await request.addStream(Stream.value(_data));
+        _data.clear();
+      }
 
       // Step 4: Lifecycle of shouldInterceptRequest
       HttpClientResponse? response;
@@ -222,8 +224,11 @@ class ProxyHttpClientRequest extends HttpClientRequest {
 
     } else {
       request = await _createBackendClientRequest();
-      request.add(_data);
-      _data.clear();
+      // Not using request.add, because large data will cause core exception.
+      if (_data.isNotEmpty) {
+        await request.addStream(Stream.value(_data));
+        _data.clear();
+      }
     }
 
     return _requestQueue.add(request.close);

kraken/test/local_http_server.dart

@@ -43,7 +43,7 @@ class LocalHttpServer {
           data.addAll(chunk);
 
           if (data.length >= 4) {
-            var lastFour = data.sublist(chunk.length - 4, chunk.length);
+            var lastFour = data.sublist(data.length - 4, data.length);
 
             // Ends with \r\n\r\n or
             // @TODO: content-length.

kraken/test/src/foundation/http_client.dart

@@ -80,5 +80,19 @@ void main() {
 
       assert(request.headers.value('referer') != null);
     });
+
+    test('Large content', () async {
+      var request = await httpClient.openUrl('POST',
+          server.getUri('plain_text'));
+      KrakenHttpOverrides.setContextHeader(request.headers, contextId);
+      // Mocked 3M file.
+      var data = List<int>.generate(3034764, (i) => i);
+      request.headers.set(HttpHeaders.contentLengthHeader, data.length);
+      await request.addStream(Stream.value(data));
+      request.add([13, 10, 13, 10]); // End of file, double CRLF.
+      await request.close();
+
+      // No error is ok.
+    });
   });
 }