fix(nextcloud): Make WebDAV get operations work with chunked responses

Signed-off-by: provokateurin <kate@provokateurin.de>

packages/nextcloud/lib/src/webdav/client.dart

@@ -294,25 +294,23 @@ class WebDavClient {
 
     unawaited(
       response.then(
-        (response) async {
+        (response) {
           final contentLength = response.contentLength;
-          if (contentLength == null || contentLength <= 0) {
-            onProgress?.call(1);
-          } else {
-            final completer = Completer<void>();
-            var downloaded = 0;
+          var downloaded = 0;
 
-            response.stream.listen((chunk) async {
+          response.stream.listen(
+            (chunk) async {
               controller.add(chunk);
               downloaded += chunk.length;
-              onProgress?.call(downloaded / contentLength);
-              if (downloaded >= contentLength) {
-                completer.complete();
+              if (contentLength != null) {
+                onProgress?.call(downloaded / contentLength);
               }
-            });
-            await completer.future;
-          }
-          await controller.close();
+            },
+            onDone: () {
+              onProgress?.call(1);
+              controller.close();
+            },
+          );
         },
         // ignore: avoid_types_on_closure_parameters
         onError: (Object error) {

packages/nextcloud/test/webdav_test.dart

@@ -144,6 +144,55 @@ void main() {
     });
   });
 
+  test('Chunked responses', () async {
+    await HttpServer.bind('127.0.0.1', 0).then((server) async {
+      server.listen((request) {
+        request.listen(
+          (_) {},
+          onDone: () async {
+            if (request.uri.path == '/index.php') {
+              final response = request.response..write('data-requesttoken="token"');
+              await response.close();
+
+              return;
+            }
+
+            final response = request.response
+              ..headers.chunkedTransferEncoding = true
+              ..write('1')
+              ..write('2')
+              ..write('3');
+
+            await response.close();
+
+            await server.close();
+          },
+        );
+      });
+
+      final client = NextcloudClient(
+        Uri(
+          scheme: 'http',
+          host: server.address.host,
+          port: server.port,
+        ),
+      );
+
+      final progress = <double>[];
+
+      final buffer = BytesBuilder(copy: false);
+      await client.webdav
+          .getStream(
+            PathUri.cwd(),
+            onProgress: progress.add,
+          )
+          .forEach(buffer.add);
+
+      expect(buffer.toBytes(), Uint8List.fromList(utf8.encode('123')));
+      expect(progress, [1]);
+    });
+  });
+
   presets(
     'server',
     'webdav',