Load parallel transformers in the same isolate.

sdk/lib/_internal/pub/lib/src/barback/load_transformers.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.
 
 library pub.load_transformers;
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:isolate';
 
 import '../../../asset/dart/serialize.dart';
 import '../barback.dart';
 import '../dart.dart' as dart;
 import '../log.dart' as log;
 import '../utils.dart';
 import 'asset_environment.dart';
 import 'foreign_transformer.dart';
 import 'barback_server.dart';
 
-/// Load and return all transformers and groups from the library identified by
-/// [id].
-Future<Set> loadTransformers(AssetEnvironment environment,
-    BarbackServer transformerServer, TransformerId id) {
-  return id.getAssetId(environment.barback).then((assetId) {
-    var path = assetId.path.replaceFirst('lib/', '');
-    // TODO(nweiz): load from a "package:" URI when issue 12474 is fixed.
+/// Load and return all transformers and groups from the libraries identified by
+/// [ids].

[Bob Nystrom, 2014/06/11 20:33:36]

Document the return value.

[nweiz, 2014/06/12 20:11:17]

Done.

+Future<Map<TransformerId, Set>> loadTransformers(AssetEnvironment environment,
+    BarbackServer transformerServer, List<TransformerId> ids) {
+  return listToMapAsync(ids, (id) => id, (id) {

[Bob Nystrom, 2014/06/11 20:33:35]

I think this would be easier to read if these were named parameters. That would
also let you avoid passing an explicit identity function.

[nweiz, 2014/06/12 20:11:17]

Will do in a separate CL.

+    return id.getAssetId(environment.barback);

[Bob Nystrom, 2014/06/11 20:33:35]

=>

[nweiz, 2014/06/12 20:11:17]

I had it as that originally, but that followed by ".then" looked pretty awkward.

+  }).then((idsToAssetIds) {
+    var baseUrl = transformerServer.url;
+    var idsToUrls = mapMap(idsToAssetIds, (id, _) => id, (id, assetId) {
+      var path = assetId.path.replaceFirst('lib/', '');
+      // TODO(nweiz): load from a "package:" URI when issue 12474 is fixed.
+      return baseUrl.resolve('packages/${id.package}/$path');
+    });
 
-    var baseUrl = transformerServer.url;
-    var uri = baseUrl.resolve('packages/${id.package}/$path');
-    var code = """
-        import 'dart:isolate';
+    var code = new StringBuffer();
+    code.writeln("import 'dart:isolate';");
 
-        import '$uri';
+    for (var url in idsToUrls.values) {
+      code.writeln("import '$url';");
+    }
 
-        import r'$baseUrl/packages/\$pub/transformer_isolate.dart';
+    code.writeln("import r'$baseUrl/packages/\$pub/transformer_isolate.dart';");
+    code.writeln(
+        "void main(_, SendPort replyTo) => loadTransformers(replyTo);");
 
-        void main(_, SendPort replyTo) => loadTransformers(replyTo);
-        """;
-    log.fine("Loading transformers from $assetId");
+    log.fine("Loading transformers from $ids");
 
     var port = new ReceivePort();
-    return dart.runInIsolate(code, port.sendPort)
+    return dart.runInIsolate(code.toString(), port.sendPort)
         .then((_) => port.first)
         .then((sendPort) {
-      return call(sendPort, {
-        'library': uri.toString(),
-        'mode': environment.mode.name,
-        // TODO(nweiz): support non-JSON-encodable configuration maps.
-        'configuration': JSON.encode(id.configuration)
-      }).then((transformers) {
-        transformers = transformers.map(
-            (transformer) => deserializeTransformerLike(transformer, id))
-            .toSet();
-        log.fine("Transformers from $assetId: $transformers");
-        return transformers;
+      return mapMapAsync(idsToAssetIds, (id, _) => id, (id, assetId) {
+        return call(sendPort, {
+          'library': idsToUrls[id].toString(),
+          'mode': environment.mode.name,
+          // TODO(nweiz): support non-JSON-encodable configuration maps.
+          'configuration': JSON.encode(id.configuration)
+        }).then((transformers) {
+          transformers = transformers.map(
+              (transformer) => deserializeTransformerLike(transformer, id))
+              .toSet();
+          log.fine("Transformers from $assetId: $transformers");
+          return transformers;
+        });
       });
     }).catchError((error, stackTrace) {
       if (error is! CrossIsolateException) throw error;
       if (error.type != 'IsolateSpawnException') throw error;
+
       // TODO(nweiz): don't parse this as a string once issues 12617 and 12689
       // are fixed.
-      if (!error.message.split('\n')[1].startsWith("Failure getting $uri:")) {
-        throw error;
-      }
+      var firstErrorLine = error.message.split('\n')[1];
+      var missingTransformers = idsToUrls.keys.where((id) =>
+          firstErrorLine.startsWith("Failure getting ${idsToUrls[id]}:"));

[Bob Nystrom, 2014/06/11 20:33:36]

Will this ever match more than one transformer?

[nweiz, 2014/06/12 20:11:17]

I guess not. Changed.

+      if (missingTransformers.isEmpty) throw error;
+
+      var packageUris = toSentence(missingTransformers.map((id) =>
+          '"${idToPackageUri(idsToAssetIds[id])}"'));
+      var libraries = pluralize('library', missingTransformers.length,
+          plural: 'libraries');
 
       // If there was an IsolateSpawnException and the import that actually
       // failed was the one we were loading transformers from, throw an
       // application exception with a more user-friendly message.
-      fail('Transformer library "package:${id.package}/$path" not found.',
+      fail('Transformer $libraries $packageUris not found.',
           error, stackTrace);
     });
   });
 }