| Index: sdk/lib/_internal/pub_generated/lib/src/barback/pub_package_provider.dart
|
| diff --git a/sdk/lib/_internal/pub_generated/lib/src/barback/pub_package_provider.dart b/sdk/lib/_internal/pub_generated/lib/src/barback/pub_package_provider.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..d82da67d87dd3569232fcfd2d58c8bbb1c8e83f3
|
| --- /dev/null
|
| +++ b/sdk/lib/_internal/pub_generated/lib/src/barback/pub_package_provider.dart
|
| @@ -0,0 +1,125 @@
|
| +// 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.pub_package_provider;
|
| +
|
| +import 'dart:async';
|
| +
|
| +import 'package:barback/barback.dart';
|
| +import 'package:path/path.dart' as path;
|
| +
|
| +import '../io.dart';
|
| +import '../package_graph.dart';
|
| +import '../preprocess.dart';
|
| +import '../sdk.dart' as sdk;
|
| +import '../utils.dart';
|
| +
|
| +/// An implementation of barback's [PackageProvider] interface so that barback
|
| +/// can find assets within pub packages.
|
| +class PubPackageProvider implements StaticPackageProvider {
|
| + final PackageGraph _graph;
|
| + final List<String> staticPackages;
|
| +
|
| + Iterable<String> get packages =>
|
| + _graph.packages.keys.toSet().difference(staticPackages.toSet());
|
| +
|
| + PubPackageProvider(PackageGraph graph)
|
| + : _graph = graph,
|
| + staticPackages = [
|
| + r"$pub",
|
| + r"$sdk"]..addAll(graph.packages.keys.where(graph.isPackageStatic));
|
| +
|
| + Future<Asset> getAsset(AssetId id) {
|
| + final completer0 = new Completer();
|
| + scheduleMicrotask(() {
|
| + try {
|
| + join0() {
|
| + join1() {
|
| + var nativePath = path.fromUri(id.path);
|
| + var file = _graph.packages[id.package].path(nativePath);
|
| + _assertExists(file, id);
|
| + completer0.complete(new Asset.fromPath(id, file));
|
| + }
|
| + if (id.package == r'$sdk') {
|
| + var parts = path.split(path.fromUri(id.path));
|
| + assert(parts.isNotEmpty && parts[0] == 'lib');
|
| + parts = parts.skip(1);
|
| + var file = path.join(sdk.rootDirectory, path.joinAll(parts));
|
| + _assertExists(file, id);
|
| + completer0.complete(new Asset.fromPath(id, file));
|
| + } else {
|
| + join1();
|
| + }
|
| + }
|
| + if (id.package == r'$pub') {
|
| + var components = path.url.split(id.path);
|
| + assert(components.isNotEmpty);
|
| + assert(components.first == 'lib');
|
| + components[0] = 'dart';
|
| + var file = assetPath(path.joinAll(components));
|
| + _assertExists(file, id);
|
| + join2() {
|
| + var versions = mapMap(_graph.packages, value: ((_, package) {
|
| + return package.version;
|
| + }));
|
| + var contents = readTextFile(file);
|
| + contents = preprocess(contents, versions, path.toUri(file));
|
| + completer0.complete(new Asset.fromString(id, contents));
|
| + }
|
| + if (!_graph.packages.containsKey("barback")) {
|
| + completer0.complete(new Asset.fromPath(id, file));
|
| + } else {
|
| + join2();
|
| + }
|
| + } else {
|
| + join0();
|
| + }
|
| + } catch (e, s) {
|
| + completer0.completeError(e, s);
|
| + }
|
| + });
|
| + return completer0.future;
|
| + }
|
| +
|
| + /// Throw an [AssetNotFoundException] for [id] if [path] doesn't exist.
|
| + void _assertExists(String path, AssetId id) {
|
| + if (!fileExists(path)) throw new AssetNotFoundException(id);
|
| + }
|
| +
|
| + Stream<AssetId> getAllAssetIds(String packageName) {
|
| + if (packageName == r'$pub') {
|
| + // "$pub" is a pseudo-package that allows pub's transformer-loading
|
| + // infrastructure to share code with pub proper. We provide it only during
|
| + // the initial transformer loading process.
|
| + var dartPath = assetPath('dart');
|
| + return new Stream.fromIterable(
|
| + listDir(dartPath, recursive: true)// Don't include directories.
|
| + .where((file) => path.extension(file) == ".dart").map((library) {
|
| + var idPath = path.join('lib', path.relative(library, from: dartPath));
|
| + return new AssetId('\$pub', path.toUri(idPath).toString());
|
| + }));
|
| + } else if (packageName == r'$sdk') {
|
| + // "$sdk" is a pseudo-package that allows the dart2js transformer to find
|
| + // the Dart core libraries without hitting the file system directly. This
|
| + // ensures they work with source maps.
|
| + var libPath = path.join(sdk.rootDirectory, "lib");
|
| + return new Stream.fromIterable(
|
| + listDir(
|
| + libPath,
|
| + recursive: true).where((file) => path.extension(file) == ".dart").map((file) {
|
| + var idPath =
|
| + path.join("lib", path.relative(file, from: sdk.rootDirectory));
|
| + return new AssetId('\$sdk', path.toUri(idPath).toString());
|
| + }));
|
| + } else {
|
| + var package = _graph.packages[packageName];
|
| + return new Stream.fromIterable(
|
| + package.listFiles(beneath: 'lib').map((file) {
|
| + return new AssetId(
|
| + packageName,
|
| + path.toUri(package.relative(file)).toString());
|
| + }));
|
| + }
|
| + }
|
| +}
|
|
|