Use deps graphs for invalidation.

Author: davidmorgan

_test_common/lib/test_phases.dart

@@ -19,7 +19,11 @@ Future<void> wait(int milliseconds) =>
     Future.delayed(Duration(milliseconds: milliseconds));
 
 void _printOnFailure(LogRecord record) {
-  printOnFailure('$record');
+  printOnFailure(
+    '$record'
+    '${record.error == null ? '' : '  ${record.error}'}'
+    '${record.stackTrace == null ? '' : '  ${record.stackTrace}'}',
+  );
 }
 
 /// Runs [builders] in a test environment.

build/lib/src/internal.dart

@@ -11,6 +11,7 @@ export 'library_cycle_graph/asset_deps_loader.dart';
 export 'library_cycle_graph/library_cycle.dart';
 export 'library_cycle_graph/library_cycle_graph.dart';
 export 'library_cycle_graph/library_cycle_graph_loader.dart';
+export 'library_cycle_graph/phased_asset_deps.dart';
 export 'library_cycle_graph/phased_reader.dart';
 export 'library_cycle_graph/phased_value.dart';
 export 'state/asset_finder.dart';

build/lib/src/library_cycle_graph/asset_deps.dart

@@ -4,6 +4,7 @@
 
 import 'package:built_collection/built_collection.dart';
 import 'package:built_value/built_value.dart';
+import 'package:built_value/serializer.dart';
 
 import '../../build.dart' hide Builder;
 
@@ -17,11 +18,15 @@ part 'asset_deps.g.dart';
 /// Missing or not-yet-generated sources can be represented by this class: they
 /// have no deps.
 abstract class AssetDeps implements Built<AssetDeps, AssetDepsBuilder> {
+  static Serializer<AssetDeps> get serializer => _$assetDepsSerializer;
+
   static final AssetDeps empty = _$AssetDeps._(deps: BuiltSet());
 
   BuiltSet<AssetId> get deps;
 
   factory AssetDeps(Iterable<AssetId> deps) =>
       _$AssetDeps._(deps: BuiltSet.of(deps));
+  factory AssetDeps.build(void Function(AssetDepsBuilder) updates) =
+      _$AssetDeps;
   AssetDeps._();
 }

build/lib/src/library_cycle_graph/asset_deps.g.dart

@@ -7,6 +7,7 @@ import 'package:analyzer/dart/ast/ast.dart';
 
 import '../asset/id.dart';
 import 'asset_deps.dart';
+import 'phased_asset_deps.dart';
 import 'phased_reader.dart';
 import 'phased_value.dart';
 
@@ -17,6 +18,8 @@ class AssetDepsLoader {
   final PhasedReader _reader;
 
   AssetDepsLoader(this._reader);
+  factory AssetDepsLoader.fromDeps(PhasedAssetDeps deps) =>
+      _InMemoryAssetDepsLoader(deps);
 
   /// The phase that this loader is reading build state at.
   int get phase => _reader.phase;
@@ -57,3 +60,34 @@ class AssetDepsLoader {
     return result.build();
   }
 }
+
+class _InMemoryAssetDepsLoader implements AssetDepsLoader {
+  final Future<PhasedValue<AssetDeps>> _empty = Future.value(
+    PhasedValue.fixed(AssetDeps.empty),
+  );
+  PhasedAssetDeps phasedAssetDeps;
+
+  _InMemoryAssetDepsLoader(this.phasedAssetDeps);
+
+  @override
+  ExpiringValue<AssetDeps> _parse(AssetId id, ExpiringValue<String> content) {
+    throw UnimplementedError();
+  }
+
+  @override
+  PhasedReader get _reader => throw UnimplementedError();
+
+  @override
+  Future<PhasedValue<AssetDeps>> load(AssetId id) {
+    var result = phasedAssetDeps.assetDeps[id];
+    if (result == null) return _empty;
+    // TODO(davidmorgan): do what with values that were never read? ...
+    if (!result.isComplete) {
+      result = result.followedBy(ExpiringValue(result.values.last.value));
+    }
+    return Future.value(result);
+  }
+
+  @override
+  int get phase => 0xffffffff;
+}

build/lib/src/library_cycle_graph/asset_deps_loader.dart

@@ -19,4 +19,18 @@ abstract class LibraryCycle
   factory LibraryCycle([void Function(LibraryCycleBuilder) updates]) =
       _$LibraryCycle;
   LibraryCycle._();
+
+  factory LibraryCycle.of(Iterable<AssetId> ids) =>
+      _$LibraryCycle._(ids: ids.toBuiltSet());
+
+  @memoized
+  AssetId get leastId {
+    var least = ids.first;
+    for (var id in ids) {
+      if (id.compareTo(least) < 0) {
+        least = id;
+      }
+    }
+    return least;
+  }
 }

build/lib/src/library_cycle_graph/library_cycle.dart

@@ -4,6 +4,7 @@
 
 import 'package:built_collection/built_collection.dart';
 import 'package:built_value/built_value.dart';
+import 'package:built_value/serializer.dart';
 
 import '../asset/id.dart';
 import 'library_cycle.dart';
@@ -13,22 +14,36 @@ part 'library_cycle_graph.g.dart';
 /// A directed acyclic graph of [LibraryCycle]s.
 abstract class LibraryCycleGraph
     implements Built<LibraryCycleGraph, LibraryCycleGraphBuilder> {
+  static Serializer<LibraryCycleGraph> get serializer =>
+      _$libraryCycleGraphSerializer;
   LibraryCycle get root;
-  BuiltList<LibraryCycleGraph> get children;
+  BuiltSet<AssetId> get children;
 
   factory LibraryCycleGraph([void Function(LibraryCycleGraphBuilder) updates]) =
       _$LibraryCycleGraph;
   LibraryCycleGraph._();
 
+  factory LibraryCycleGraph.of(
+    Iterable<AssetId> root, {
+    Iterable<AssetId> children = const [],
+  }) => _$LibraryCycleGraph._(
+    root: LibraryCycle.of(root),
+    children: children.toBuiltSet(),
+  );
+
   /// All subgraphs in the graph, including the root.
-  Iterable<LibraryCycleGraph> get transitiveGraphs {
+  Iterable<LibraryCycleGraph> transitiveGraphs({
+    required LibraryCycleGraph Function(AssetId) lookupGraph,
+  }) {
     final result = Set<LibraryCycleGraph>.identity();
     final nextGraphs = [this];
 
     while (nextGraphs.isNotEmpty) {
       final graph = nextGraphs.removeLast();
       if (result.add(graph)) {
-        nextGraphs.addAll(graph.children);
+        for (final child in graph.children) {
+          nextGraphs.add(lookupGraph(child));
+        }
       }
     }
 
@@ -40,8 +55,10 @@ abstract class LibraryCycleGraph
   // graph rather than being expanded into an explicit set of nodes. So, remove
   // uses of this. If in the end it's still needed, investigate if it needs to
   // be optimized.
-  Iterable<AssetId> get transitiveDeps sync* {
-    for (final graph in transitiveGraphs) {
+  Iterable<AssetId> transitiveDeps({
+    required LibraryCycleGraph Function(AssetId) lookupGraph,
+  }) sync* {
+    for (final graph in transitiveGraphs(lookupGraph: lookupGraph)) {
       yield* graph.root.ids;
     }
   }