Index: pkg/barback/test/package_graph/transform/aggregate_test.dart |
diff --git a/pkg/barback/test/package_graph/transform/aggregate_test.dart b/pkg/barback/test/package_graph/transform/aggregate_test.dart |
deleted file mode 100644 |
index d6fb050d8cb739a9bc3f385bf46886fd54120b5d..0000000000000000000000000000000000000000 |
--- a/pkg/barback/test/package_graph/transform/aggregate_test.dart |
+++ /dev/null |
@@ -1,326 +0,0 @@ |
-// Copyright (c) 2014, 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 barback.test.package_graph.transform.aggregate_test; |
- |
-import 'package:barback/src/utils.dart'; |
-import 'package:scheduled_test/scheduled_test.dart'; |
- |
-import '../../utils.dart'; |
- |
-main() { |
- initConfig(); |
- test("an aggregate transformer can read from multiple primary inputs", () { |
- var sources = [ |
- "app|dir/foo.txt", |
- "app|dir/bar.txt", |
- "app|dir/baz.jpg", |
- "app|dir/subdir/bang.txt", |
- "app|dir/subdir/qux.txt", |
- "app|dir/subdir/zap.png" |
- ]; |
- |
- initGraph(sources, {"app": [ |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- updateSources(sources); |
- expectAsset("app|dir/out.txt", "bar\nfoo"); |
- expectAsset("app|dir/subdir/out.txt", "bang\nqux"); |
- buildShouldSucceed(); |
- }); |
- |
- test("an aggregate transformer isn't run if there are no primary inputs", () { |
- var transformer = new AggregateManyToOneTransformer("txt", "out.txt"); |
- initGraph(["app|foo.zip", "app|bar.zap"], {"app": [ |
- [transformer] |
- ]}); |
- |
- updateSources(["app|foo.zip", "app|bar.zap"]); |
- expectNoAsset("app|out.txt"); |
- buildShouldSucceed(); |
- |
- expect(transformer.numRuns, completion(equals(0))); |
- }); |
- |
- test("an aggregate transformer is re-run if a primary input changes", () { |
- initGraph(["app|foo.txt", "app|bar.txt"], {"app": [ |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- updateSources(["app|foo.txt", "app|bar.txt"]); |
- expectAsset("app|out.txt", "bar\nfoo"); |
- buildShouldSucceed(); |
- |
- modifyAsset("app|foo.txt", "new foo"); |
- updateSources(["app|foo.txt"]); |
- expectAsset("app|out.txt", "bar\nnew foo"); |
- buildShouldSucceed(); |
- }); |
- |
- test("an aggregate transformer is re-run if a primary input is removed", () { |
- initGraph(["app|foo.txt", "app|bar.txt"], {"app": [ |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- updateSources(["app|foo.txt", "app|bar.txt"]); |
- expectAsset("app|out.txt", "bar\nfoo"); |
- buildShouldSucceed(); |
- |
- removeSources(["app|foo.txt"]); |
- expectAsset("app|out.txt", "bar"); |
- buildShouldSucceed(); |
- }); |
- |
- test("an aggregate transformer is re-run if a primary input is added", () { |
- initGraph(["app|foo.txt", "app|bar.txt", "app|baz.txt"], {"app": [ |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- updateSources(["app|foo.txt", "app|bar.txt"]); |
- expectAsset("app|out.txt", "bar\nfoo"); |
- buildShouldSucceed(); |
- |
- updateSources(["app|baz.txt"]); |
- expectAsset("app|out.txt", "bar\nbaz\nfoo"); |
- buildShouldSucceed(); |
- }); |
- |
- test("an aggregate transformer ceases to run if all primary inputs are " |
- "removed", () { |
- initGraph(["app|foo.txt", "app|bar.txt"], {"app": [ |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- updateSources(["app|foo.txt", "app|bar.txt"]); |
- expectAsset("app|out.txt", "bar\nfoo"); |
- buildShouldSucceed(); |
- |
- removeSources(["app|foo.txt", "app|bar.txt"]); |
- expectNoAsset("app|out.txt"); |
- buildShouldSucceed(); |
- }); |
- |
- test("an aggregate transformer starts to run if new primary inputs are " |
- "added", () { |
- initGraph(["app|foo.txt", "app|bar.txt"], {"app": [ |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- updateSources([]); |
- expectNoAsset("app|out.txt"); |
- buildShouldSucceed(); |
- |
- updateSources(["app|foo.txt", "app|bar.txt"]); |
- expectAsset("app|out.txt", "bar\nfoo"); |
- buildShouldSucceed(); |
- }); |
- |
- group("pass-through", () { |
- test("an aggregate transformer passes through its primary inputs by " |
- "default", () { |
- initGraph(["app|foo.txt", "app|bar.txt"], {"app": [ |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- updateSources(["app|foo.txt", "app|bar.txt"]); |
- expectAsset("app|foo.txt", "foo"); |
- expectAsset("app|bar.txt", "bar"); |
- buildShouldSucceed(); |
- |
- modifyAsset("app|foo.txt", "new foo"); |
- updateSources(["app|foo.txt"]); |
- expectAsset("app|foo.txt", "new foo"); |
- buildShouldSucceed(); |
- }); |
- |
- test("an aggregate transformer can overwrite its primary inputs", () { |
- initGraph(["app|foo.txt", "app|bar.txt"], {"app": [ |
- [new AggregateManyToManyTransformer("txt")] |
- ]}); |
- |
- updateSources(["app|foo.txt", "app|bar.txt"]); |
- expectAsset("app|foo.txt", "modified foo"); |
- expectAsset("app|bar.txt", "modified bar"); |
- buildShouldSucceed(); |
- }); |
- |
- test("an aggregate transformer can consume its primary inputs", () { |
- var transformer = new AggregateManyToOneTransformer("txt", "out.txt"); |
- transformer.consumePrimaries |
- ..add("app|foo.txt") |
- ..add("app|bar.txt"); |
- |
- initGraph(["app|foo.txt", "app|bar.txt"], {"app": [[transformer]]}); |
- |
- updateSources(["app|foo.txt", "app|bar.txt"]); |
- expectNoAsset("app|foo.txt"); |
- expectNoAsset("app|bar.txt"); |
- buildShouldSucceed(); |
- }); |
- |
- test("an aggregate transformer passes through non-primary inputs", () { |
- initGraph(["app|foo.jpg", "app|bar.png"], {"app": [ |
- [new AggregateManyToManyTransformer("txt")] |
- ]}); |
- |
- updateSources(["app|foo.jpg", "app|bar.png"]); |
- expectAsset("app|foo.jpg", "foo"); |
- expectAsset("app|bar.png", "bar"); |
- buildShouldSucceed(); |
- |
- modifyAsset("app|foo.jpg", "new foo"); |
- updateSources(["app|foo.jpg"]); |
- expectAsset("app|foo.jpg", "new foo"); |
- buildShouldSucceed(); |
- }); |
- }); |
- |
- group("apply() transform stream", () { |
- test("the primary input stream doesn't close if a previous phase is still " |
- "running", () { |
- var rewrite = new RewriteTransformer("a", "b"); |
- initGraph(["app|foo.txt", "app|bar.a"], {"app": [ |
- [rewrite], |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- rewrite.pauseApply(); |
- updateSources(["app|foo.txt", "app|bar.a"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- rewrite.resumeApply(); |
- expectAsset("app|out.txt", "foo"); |
- buildShouldSucceed(); |
- }); |
- |
- test("the primary input stream doesn't close if a previous phase is " |
- "materializing a primary input", () { |
- var rewrite = new DeclaringRewriteTransformer("in", "txt"); |
- initGraph(["app|foo.txt", "app|bar.in"], {"app": [ |
- [rewrite], |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- rewrite.pauseApply(); |
- updateSources(["app|foo.txt", "app|bar.in"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- rewrite.resumeApply(); |
- expectAsset("app|out.txt", "bar.txt\nfoo"); |
- buildShouldSucceed(); |
- }); |
- |
- test("the primary input stream closes if a previous phase is only " |
- "materializing non-primary inputs", () { |
- var rewrite = new DeclaringRewriteTransformer("a", "b"); |
- initGraph(["app|foo.txt", "app|bar.a"], {"app": [ |
- [rewrite], |
- [new AggregateManyToOneTransformer("txt", "out.txt")] |
- ]}); |
- |
- rewrite.pauseApply(); |
- updateSources(["app|foo.txt", "app|bar.a"]); |
- expectAsset("app|out.txt", "foo"); |
- |
- rewrite.resumeApply(); |
- buildShouldSucceed(); |
- }); |
- |
- test("a new primary input that arrives before the stream closes doesn't " |
- "cause apply to restart", () { |
- var rewrite = new RewriteTransformer("a", "b"); |
- var aggregate = new AggregateManyToOneTransformer("txt", "out.txt"); |
- initGraph(["app|foo.txt", "app|bar.txt", "app|baz.a"], {"app": [ |
- [rewrite], |
- [aggregate] |
- ]}); |
- |
- // The stream won't close until [rewrite] finishes running `apply()`. |
- rewrite.pauseApply(); |
- |
- updateSources(["app|foo.txt", "app|baz.a"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- updateSources(["app|bar.txt"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- rewrite.resumeApply(); |
- expectAsset("app|out.txt", "bar\nfoo"); |
- buildShouldSucceed(); |
- |
- expect(aggregate.numRuns, completion(equals(1))); |
- }); |
- |
- test("a new primary input that arrives after the stream closes causes " |
- "apply to restart", () { |
- var aggregate = new AggregateManyToOneTransformer("txt", "out.txt"); |
- initGraph(["app|foo.txt", "app|bar.txt"], {"app": [[aggregate]]}); |
- |
- aggregate.pauseApply(); |
- updateSources(["app|foo.txt"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- updateSources(["app|bar.txt"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- aggregate.resumeApply(); |
- expectAsset("app|out.txt", "bar\nfoo"); |
- buildShouldSucceed(); |
- |
- expect(aggregate.numRuns, completion(equals(2))); |
- }); |
- |
- test("a primary input that's modified before the stream closes causes " |
- "apply to restart", () { |
- var rewrite = new RewriteTransformer("a", "b"); |
- var aggregate = new AggregateManyToOneTransformer("txt", "out.txt"); |
- initGraph(["app|foo.txt", "app|bar.a"], {"app": [ |
- [rewrite], |
- [aggregate] |
- ]}); |
- |
- // The stream won't close until [rewrite] finishes running `apply()`. |
- rewrite.pauseApply(); |
- |
- updateSources(["app|foo.txt", "app|bar.a"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- modifyAsset("app|foo.txt", "new foo"); |
- updateSources(["app|foo.txt"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- rewrite.resumeApply(); |
- expectAsset("app|out.txt", "new foo"); |
- buildShouldSucceed(); |
- |
- expect(aggregate.numRuns, completion(equals(2))); |
- }); |
- |
- test("a primary input that's removed before the stream closes causes apply " |
- "to restart", () { |
- var rewrite = new RewriteTransformer("a", "b"); |
- var aggregate = new AggregateManyToOneTransformer("txt", "out.txt"); |
- initGraph(["app|foo.txt", "app|bar.txt", "app|baz.a"], {"app": [ |
- [rewrite], |
- [aggregate] |
- ]}); |
- |
- // The stream won't close until [rewrite] finishes running `apply()`. |
- rewrite.pauseApply(); |
- |
- updateSources(["app|foo.txt", "app|bar.txt", "app|baz.a"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- removeSources(["app|bar.txt"]); |
- expectAssetDoesNotComplete("app|out.txt"); |
- |
- rewrite.resumeApply(); |
- expectAsset("app|out.txt", "foo"); |
- buildShouldSucceed(); |
- |
- expect(aggregate.numRuns, completion(equals(2))); |
- }); |
- }); |
-} |