Index: sdk/lib/_internal/pub_generated/lib/src/barback/load_all_transformers.dart |
diff --git a/sdk/lib/_internal/pub_generated/lib/src/barback/load_all_transformers.dart b/sdk/lib/_internal/pub_generated/lib/src/barback/load_all_transformers.dart |
index 4f760357a362d832588b90907601aa10e4f3c4d8..8ab13b2125a4e1ed7f7a910395105d57e002416b 100644 |
--- a/sdk/lib/_internal/pub_generated/lib/src/barback/load_all_transformers.dart |
+++ b/sdk/lib/_internal/pub_generated/lib/src/barback/load_all_transformers.dart |
@@ -1,167 +1,196 @@ |
library pub.load_all_transformers; |
import 'dart:async'; |
+import 'package:barback/barback.dart'; |
import '../log.dart' as log; |
import '../package_graph.dart'; |
import '../utils.dart'; |
import 'asset_environment.dart'; |
import 'barback_server.dart'; |
+import 'dependency_computer.dart'; |
import 'transformer_id.dart'; |
import 'transformer_loader.dart'; |
-import 'transformers_needed_by_transformers.dart'; |
Future loadAllTransformers(AssetEnvironment environment, |
- BarbackServer transformerServer) { |
+ BarbackServer transformerServer, {Iterable<AssetId> entrypoints}) { |
final completer0 = new Completer(); |
scheduleMicrotask(() { |
try { |
- var transformersNeededByTransformers = |
- computeTransformersNeededByTransformers(environment.graph); |
- var buffer = new StringBuffer(); |
- buffer.writeln("Transformer dependencies:"); |
- transformersNeededByTransformers.forEach(((id, dependencies) { |
- if (dependencies.isEmpty) { |
- buffer.writeln("$id: -"); |
- } else { |
- buffer.writeln("$id: ${toSentence(dependencies)}"); |
- } |
- })); |
- log.fine(buffer); |
- var stagedTransformers = |
- _stageTransformers(transformersNeededByTransformers); |
- var packagesThatUseTransformers = |
- _packagesThatUseTransformers(environment.graph); |
- var loader = new TransformerLoader(environment, transformerServer); |
- join0(x0) { |
- var cache = x0; |
- var first = true; |
- var it0 = stagedTransformers.iterator; |
- break0(x6) { |
- join1() { |
- Future.wait(environment.graph.packages.values.map(((package) { |
- final completer0 = new Completer(); |
- scheduleMicrotask(() { |
- try { |
- loader.transformersForPhases( |
- package.pubspec.transformers).then((x0) { |
- try { |
- var phases = x0; |
- var transformers = |
- environment.getBuiltInTransformers(package); |
- join0() { |
- join1() { |
- newFuture( |
- (() => environment.barback.updateTransformers(package.name, phases))); |
- completer0.complete(null); |
- } |
- if (phases.isEmpty) { |
- completer0.complete(null); |
- } else { |
- join1(); |
- } |
- } |
- if (transformers != null) { |
- phases.add(transformers); |
- join0(); |
- } else { |
- join0(); |
- } |
- } catch (e0) { |
- completer0.completeError(e0); |
- } |
- }, onError: (e1) { |
- completer0.completeError(e1); |
- }); |
- } catch (e2) { |
- completer0.completeError(e2); |
- } |
- }); |
- return completer0.future; |
- }))).then((x1) { |
- try { |
- x1; |
- completer0.complete(null); |
- } catch (e0) { |
- completer0.completeError(e0); |
- } |
- }, onError: (e1) { |
- completer0.completeError(e1); |
- }); |
- } |
- if (cache != null) { |
- cache.save(); |
- join1(); |
+ var dependencyComputer = new DependencyComputer(environment.graph); |
+ var necessaryTransformers; |
+ join0() { |
+ var transformersNeededByTransformers = |
+ dependencyComputer.transformersNeededByTransformers(necessaryTransformers); |
+ var buffer = new StringBuffer(); |
+ buffer.writeln("Transformer dependencies:"); |
+ transformersNeededByTransformers.forEach(((id, dependencies) { |
+ if (dependencies.isEmpty) { |
+ buffer.writeln("$id: -"); |
} else { |
- join1(); |
+ buffer.writeln("$id: ${toSentence(dependencies)}"); |
} |
- } |
- continue0(x7) { |
- if (it0.moveNext()) { |
- Future.wait([]).then((x5) { |
- var stage = it0.current; |
- join2(x2) { |
- var snapshotPath = x2; |
- first = false; |
- loader.load(stage, snapshot: snapshotPath).then((x3) { |
+ })); |
+ log.fine(buffer); |
+ var stagedTransformers = |
+ _stageTransformers(transformersNeededByTransformers); |
+ var packagesThatUseTransformers = |
+ _packagesThatUseTransformers(environment.graph); |
+ var loader = new TransformerLoader(environment, transformerServer); |
+ join1(x0) { |
+ var cache = x0; |
+ var first = true; |
+ var it0 = stagedTransformers.iterator; |
+ break0(x6) { |
+ join2() { |
+ Future.wait(environment.graph.packages.values.map(((package) { |
+ final completer0 = new Completer(); |
+ scheduleMicrotask(() { |
try { |
- x3; |
- var packagesToUpdate = |
- unionAll(stage.map(((id) => packagesThatUseTransformers[id]))); |
- Future.wait(packagesToUpdate.map(((packageName) { |
- final completer0 = new Completer(); |
- scheduleMicrotask(() { |
- try { |
- var package = environment.graph.packages[packageName]; |
- loader.transformersForPhases( |
- package.pubspec.transformers).then((x0) { |
- try { |
- var phases = x0; |
- environment.barback.updateTransformers( |
- packageName, |
- phases); |
- completer0.complete(null); |
- } catch (e0) { |
- completer0.completeError(e0); |
- } |
- }, onError: (e1) { |
- completer0.completeError(e1); |
- }); |
- } catch (e2) { |
- completer0.completeError(e2); |
- } |
- }); |
- return completer0.future; |
- }))).then((x4) { |
+ loader.transformersForPhases( |
+ package.pubspec.transformers).then((x0) { |
try { |
- x4; |
- continue0(null); |
- } catch (e3) { |
- completer0.completeError(e3); |
+ var phases = x0; |
+ var transformers = |
+ environment.getBuiltInTransformers(package); |
+ join0() { |
+ join1() { |
+ newFuture( |
+ (() => environment.barback.updateTransformers(package.name, phases))); |
+ completer0.complete(null); |
+ } |
+ if (phases.isEmpty) { |
+ completer0.complete(null); |
+ } else { |
+ join1(); |
+ } |
+ } |
+ if (transformers != null) { |
+ phases.add(transformers); |
+ join0(); |
+ } else { |
+ join0(); |
+ } |
+ } catch (e0) { |
+ completer0.completeError(e0); |
} |
- }, onError: (e4) { |
- completer0.completeError(e4); |
+ }, onError: (e1) { |
+ completer0.completeError(e1); |
}); |
} catch (e2) { |
completer0.completeError(e2); |
} |
- }, onError: (e5) { |
- completer0.completeError(e5); |
}); |
- } |
- if (cache == null || !first) { |
- join2(null); |
- } else { |
- join2(cache.snapshotPath(stage)); |
- } |
- }); |
- } else { |
- break0(null); |
+ return completer0.future; |
+ }))).then((x1) { |
+ try { |
+ x1; |
+ completer0.complete(null); |
+ } catch (e0) { |
+ completer0.completeError(e0); |
+ } |
+ }, onError: (e1) { |
+ completer0.completeError(e1); |
+ }); |
+ } |
+ if (cache != null) { |
+ cache.save(); |
+ join2(); |
+ } else { |
+ join2(); |
+ } |
} |
+ continue0(x7) { |
+ if (it0.moveNext()) { |
+ Future.wait([]).then((x5) { |
+ var stage = it0.current; |
+ join3(x2) { |
+ var snapshotPath = x2; |
+ first = false; |
+ loader.load(stage, snapshot: snapshotPath).then((x3) { |
+ try { |
+ x3; |
+ var packagesToUpdate = |
+ unionAll(stage.map(((id) => packagesThatUseTransformers[id]))); |
+ Future.wait(packagesToUpdate.map(((packageName) { |
+ final completer0 = new Completer(); |
+ scheduleMicrotask(() { |
+ try { |
+ var package = |
+ environment.graph.packages[packageName]; |
+ loader.transformersForPhases( |
+ package.pubspec.transformers).then((x0) { |
+ try { |
+ var phases = x0; |
+ environment.barback.updateTransformers( |
+ packageName, |
+ phases); |
+ completer0.complete(null); |
+ } catch (e0) { |
+ completer0.completeError(e0); |
+ } |
+ }, onError: (e1) { |
+ completer0.completeError(e1); |
+ }); |
+ } catch (e2) { |
+ completer0.completeError(e2); |
+ } |
+ }); |
+ return completer0.future; |
+ }))).then((x4) { |
+ try { |
+ x4; |
+ continue0(null); |
+ } catch (e3) { |
+ completer0.completeError(e3); |
+ } |
+ }, onError: (e4) { |
+ completer0.completeError(e4); |
+ }); |
+ } catch (e2) { |
+ completer0.completeError(e2); |
+ } |
+ }, onError: (e5) { |
+ completer0.completeError(e5); |
+ }); |
+ } |
+ if (cache == null || !first) { |
+ join3(null); |
+ } else { |
+ join3(cache.snapshotPath(stage)); |
+ } |
+ }); |
+ } else { |
+ break0(null); |
+ } |
+ } |
+ continue0(null); |
+ } |
+ if (environment.rootPackage.dir == null) { |
+ join1(null); |
+ } else { |
+ join1(environment.graph.loadTransformerCache()); |
} |
- continue0(null); |
} |
- if (environment.rootPackage.dir == null) { |
- join0(null); |
+ if (entrypoints != null) { |
+ join4() { |
+ necessaryTransformers = |
+ unionAll(entrypoints.map(dependencyComputer.transformersNeededByLibrary)); |
+ join5() { |
+ join0(); |
+ } |
+ if (necessaryTransformers.isEmpty) { |
+ log.fine( |
+ "No transformers are needed for ${toSentence(entrypoints)}."); |
+ completer0.complete(null); |
+ } else { |
+ join5(); |
+ } |
+ } |
+ if (entrypoints.isEmpty) { |
+ completer0.complete(null); |
+ } else { |
+ join4(); |
+ } |
} else { |
- join0(environment.graph.loadTransformerCache()); |
+ join0(); |
} |
} catch (e6) { |
completer0.completeError(e6); |