Move MimeMultipartTransformer and HttpBodyHandler to mime and http_server packages.

pkg/mime/test/mime_multipart_transformer_test.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
-import "package:expect/expect.dart";
+import "package:unittest/unittest.dart";
+import "package:mime/mime.dart";
 import 'dart:async';
 import 'dart:math';
-import 'dart:io';
 import 'dart:isolate';
 
 void testParse(String message,
                String boundary,
                [List<Map> expectedHeaders,
-               List expectedParts,
-               bool expectError = false]) {
-  void testWrite(List<int> data, [int chunkSize = -1]) {
+                List expectedParts,
+                bool expectError = false]) {
+  Future testWrite(List<int> data, [int chunkSize = -1]) {
     StreamController controller = new StreamController(sync: true);
 
     var stream = controller.stream.transform(
         new MimeMultipartTransformer(boundary));
     int i = 0;
-    var port = new ReceivePort();
+    var completer = new Completer();
+    var futures = [];
     stream.listen((multipart) {
       int part = i++;
       if (expectedHeaders != null) {
-        Expect.mapEquals(expectedHeaders[part], multipart.headers);
+        expect(multipart.headers, equals(expectedHeaders[part]));
       }
-      var partPort = new ReceivePort();
+      var partCompleter = new Completer();
+      futures.add(partCompleter.future);

[Bill Hesse, 2013/07/03 11:30:27]

Why not
futures.add(multipart.fold( ... ).then((data) { ... }));
and drop the partCompleter.

[Anders Johnsen, 2013/07/12 10:45:57]

Done.

       multipart.fold([], (buffer, data) => buffer..addAll(data))
           .then((data) {
             if (expectedParts[part] != null) {
-              Expect.listEquals(expectedParts[part].codeUnits, data);
+              expect(data, equals(expectedParts[part].codeUnits));
             }
-            partPort.close();
+            partCompleter.complete(true);
           });
     }, onError: (error) {
       if (!expectError) throw error;
     }, onDone: () {
       if (expectedParts != null) {
-        Expect.equals(expectedParts.length, i);
+        expect(i, equals(expectedParts.length));
       }
-      port.close();
+      Future.wait(futures)
+          .then((values) => !values.any((b) => !b))

[Bill Hesse, 2013/07/03 11:30:27]

Is this stray code?  All the values are true by construction, and
the result is not used.

Also, values.every((b) => b)

[Anders Johnsen, 2013/07/12 10:45:57]

Done.

+          .then(completer.complete);
     });
 
     if (chunkSize == -1) chunkSize = data.length;
 
     int written = 0;
     for (int pos = 0; pos < data.length; pos += chunkSize) {
       int remaining = data.length - pos;
       int writeLength = min(chunkSize, remaining);
       controller.add(data.sublist(pos, pos + writeLength));
       written += writeLength;
     }
     controller.close();
+
+    return completer.future;
   }
 
   // Test parsing the data three times delivering the data in
   // different chunks.
   List<int> data = message.codeUnits;
-  testWrite(data);
-  testWrite(data, 10);
-  testWrite(data, 2);
-  testWrite(data, 1);
+  expect(Future.wait([
+      testWrite(data),
+      testWrite(data, 10),
+      testWrite(data, 2),
+      testWrite(data, 1)])
+      .then((values) => !values.any((b) => !b)),

[Bill Hesse, 2013/07/03 11:30:27]

All the values are true anyway.

completion(anything)?

[Anders Johnsen, 2013/07/12 10:45:57]

Done.

+      completion(equals(true)));
 }
 
 void testParseValid() {
   String message;
   Map headers;
   Map headers1;
   Map headers2;
   Map headers3;
   Map headers4;
   String body1;
   String body2;
   String body3;
   String body4;
 
-  // Sample from Wikipedia.
   message = """
 This is a message with multiple parts in MIME format.\r
 --frontier\r
 Content-Type: text/plain\r
 \r
 This is the body of the message.\r
 --frontier\r
 Content-Type: application/octet-stream\r
 Content-Transfer-Encoding: base64\r
 \r
 PGh0bWw+CiAgPGhlYWQ+CiAgPC9oZWFkPgogIDxib2R5PgogICAgPHA+VGhpcyBpcyB0aGUg
 Ym9keSBvZiB0aGUgbWVzc2FnZS48L3A+CiAgPC9ib2R5Pgo8L2h0bWw+Cg=\r
 --frontier--\r\n""";
   headers1 = <String, String>{"content-type": "text/plain"};
   headers2 = <String, String>{"content-type": "application/octet-stream",
-                              "content-transfer-encoding": "base64"};
+                            "content-transfer-encoding": "base64"};

[Bill Hesse, 2013/07/03 11:30:27]

Indentation

[Anders Johnsen, 2013/07/12 10:45:57]

Done.

   body1 = "This is the body of the message.";
   body2 = """
 PGh0bWw+CiAgPGhlYWQ+CiAgPC9oZWFkPgogIDxib2R5PgogICAgPHA+VGhpcyBpcyB0aGUg
 Ym9keSBvZiB0aGUgbWVzc2FnZS48L3A+CiAgPC9ib2R5Pgo8L2h0bWw+Cg=""";
   testParse(message, "frontier", [headers1, headers2], [body1, body2]);
 
-  // Sample from HTML 4.01 Specification.
   message = """
 \r\n--AaB03x\r
 Content-Disposition: form-data; name=\"submit-name\"\r
 \r
 Larry\r
 --AaB03x\r
 Content-Disposition: form-data; name=\"files\"; filename=\"file1.txt\"\r
 Content-Type: text/plain\r
 \r
 ... contents of file1.txt ...\r
@@ skipping 197 matching lines @@
 \r
 Body2\r
 --xxx\r\n""";
   testParse(message, "xxx", null, [null, null], true);
 }
 
 void main() {
   testParseValid();
   testParseInvalid();
 }