fix(edge_http_client): fix invalid content length value in client

Author: Ehesp

examples/supabase-edge-functions/lib/main.dart

@@ -1,7 +1,39 @@
+import 'dart:convert';
+
+import 'package:edge_http_client/edge_http_client.dart';
+import 'package:supabase/supabase.dart';
 import 'package:supabase_functions/supabase_functions.dart';
+import 'package:yet_another_json_isolate/yet_another_json_isolate.dart';
 
 void main() {
-  SupabaseFunctions(fetch: (request) {
-    return Response("Hello from Supabase Edge Functions!");
+  final client = SupabaseClient(
+    'https://oqikpqftjankbsrejdhv.supabase.co',
+    'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6Im9xaWtwcWZ0amFua2JzcmVqZGh2Iiwicm9sZSI6ImFub24iLCJpYXQiOjE2NzU5NDY5MTAsImV4cCI6MTk5MTUyMjkxMH0.jK4_Kqi4ZYxg7KbOJKsyHXrwkX_u3Ugp_XQyQW9m_lw',
+    httpClient: EdgeHttpClient(),
+    isolate: CurrentIsolate(),
+  );
+
+  SupabaseFunctions(fetch: (request) async {
+    List messages = await client.from('example').select();
+    return Response.json(messages);
   });
 }
+
+// This will eventually live inside of edge_io
+class CurrentIsolate implements YAJsonIsolate {
+  @override
+  Future decode(String json) {
+    return Future.value(jsonDecode(json));
+  }
+
+  @override
+  Future<void> dispose() async {}
+
+  @override
+  Future<String> encode(Object? json) {
+    return Future.value(jsonEncode(json));
+  }
+
+  @override
+  Future<void> initialize() async {}
+}

examples/supabase-edge-functions/pubspec.yaml

@@ -8,6 +8,10 @@ environment:
 
 dependencies:
   edge: ^0.0.5
+  edge_http_client: ^0.0.1
+  supabase: ^1.6.3
   supabase_functions: ^0.0.2
+  yet_another_json_isolate: ^1.0.2
+
 dev_dependencies:
   lints: ^2.0.1

packages/edge_http_client/CHANGELOG.md

@@ -1,4 +1,4 @@
-## 0.0.1+1
+## 0.0.1
 
- - Update a dependency to the latest release.
+ - Initial version.
 

packages/edge_http_client/lib/edge_http_client.dart

@@ -150,7 +150,6 @@ class EdgeHttpClient implements http.Client {
       req.contentLength = bytes.length;
       req.add(bytes);
     }
-
     final res = await req.close();
     final resHeaders = <String, String>{};
 
@@ -161,7 +160,8 @@ class EdgeHttpClient implements http.Client {
     return http.StreamedResponse(
       res,
       res.statusCode,
-      contentLength: res.contentLength,
+      request: request,
+      contentLength: res.contentLength == -1 ? null : res.contentLength,
       headers: resHeaders,
       isRedirect: res.isRedirect,
       persistentConnection: res.persistentConnection,

packages/edge_http_client/pubspec.yaml

@@ -2,7 +2,7 @@ name: edge_http_client
 description: A http package implementation for Dart Edge.
 homepage: https://dartedge.dev
 repository: https://github.com/invertase/dart_edge/tree/main/packages/edge_http_client
-version: 0.0.1+1
+version: 0.0.1
 
 environment:
   sdk: ">=2.18.5 <3.0.0"

packages/edge_runtime/lib/src/io_http_client.dart

@@ -287,7 +287,6 @@ class HttpClientRequest implements io.HttpClientRequest {
 
   @override
   Future<HttpClientResponse> close() async {
-    print('close()');
     final fetchResponse = await fetch(
       _resource,
       body: _body != null ? Uint8List.fromList(_body!) : null,