Index: sdk/lib/_internal/pub_generated/lib/src/source/git.dart |
diff --git a/sdk/lib/_internal/pub_generated/lib/src/source/git.dart b/sdk/lib/_internal/pub_generated/lib/src/source/git.dart |
index c15a63fc92d049b56b3d0852ae177101268b29dd..c36ecf4f31eed4aa090da93759d72654ec0f65ef 100644 |
--- a/sdk/lib/_internal/pub_generated/lib/src/source/git.dart |
+++ b/sdk/lib/_internal/pub_generated/lib/src/source/git.dart |
@@ -1,6 +1,13 @@ |
+// Copyright (c) 2012, 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.source.git; |
+ |
import 'dart:async'; |
+ |
import 'package:path/path.dart' as path; |
+ |
import '../git.dart' as git; |
import '../io.dart'; |
import '../log.dart' as log; |
@@ -8,11 +15,23 @@ import '../package.dart'; |
import '../pubspec.dart'; |
import '../utils.dart'; |
import 'cached.dart'; |
+ |
+/// A package source that gets packages from Git repos. |
class GitSource extends CachedSource { |
+ /// Given a valid git package description, returns the URL of the repository |
+ /// it pulls from. |
static String urlFromDescription(description) => description["url"]; |
+ |
final name = "git"; |
+ |
+ /// The paths to the canonical clones of repositories for which "git fetch" |
+ /// has already been run during this run of pub. |
final _updatedRepos = new Set<String>(); |
+ |
+ /// Given a Git repo that contains a pub package, gets the name of the pub |
+ /// package. |
Future<String> getPackageNameFromRepo(String repo) { |
+ // Clone the repo to a temp directory. |
return withTempDir((tempDir) { |
return _clone(repo, tempDir, shallow: true).then((_) { |
var pubspec = new Pubspec.load(tempDir, systemCache.sources); |
@@ -20,16 +39,34 @@ class GitSource extends CachedSource { |
}); |
}); |
} |
+ |
+ /// Since we don't have an easy way to read from a remote Git repo, this |
+ /// just installs [id] into the system cache, then describes it from there. |
Future<Pubspec> describeUncached(PackageId id) { |
return downloadToSystemCache(id).then((package) => package.pubspec); |
} |
+ |
+ /// Clones a Git repo to the local filesystem. |
+ /// |
+ /// The Git cache directory is a little idiosyncratic. At the top level, it |
+ /// contains a directory for each commit of each repository, named `<package |
+ /// name>-<commit hash>`. These are the canonical package directories that are |
+ /// linked to from the `packages/` directory. |
+ /// |
+ /// In addition, the Git system cache contains a subdirectory named `cache/` |
+ /// which contains a directory for each separate repository URL, named |
+ /// `<package name>-<url hash>`. These are used to check out the repository |
+ /// itself; each of the commit-specific directories are clones of a directory |
+ /// in `cache/`. |
Future<Package> downloadToSystemCache(PackageId id) { |
var revisionCachePath; |
+ |
if (!git.isInstalled) { |
fail( |
"Cannot get ${id.name} from Git (${_getUrl(id)}).\n" |
"Please ensure Git is correctly installed."); |
} |
+ |
ensureDir(path.join(systemCacheRoot, 'cache')); |
return _ensureRevision(id).then((_) => getDirectory(id)).then((path) { |
revisionCachePath = path; |
@@ -43,34 +80,54 @@ class GitSource extends CachedSource { |
return new Package.load(id.name, revisionCachePath, systemCache.sources); |
}); |
} |
+ |
+ /// Returns the path to the revision-specific cache of [id]. |
Future<String> getDirectory(PackageId id) { |
return _ensureRevision(id).then((rev) { |
var revisionCacheName = '${id.name}-$rev'; |
return path.join(systemCacheRoot, revisionCacheName); |
}); |
} |
+ |
+ /// Ensures [description] is a Git URL. |
dynamic parseDescription(String containingPath, description, |
{bool fromLockFile: false}) { |
+ // TODO(rnystrom): Handle git URLs that are relative file paths (#8570). |
+ // TODO(rnystrom): Now that this function can modify the description, it |
+ // may as well canonicalize it to a map so that other code in the source |
+ // can assume that. |
+ // A single string is assumed to be a Git URL. |
if (description is String) return description; |
if (description is! Map || !description.containsKey('url')) { |
throw new FormatException( |
"The description must be a Git URL or a map " "with a 'url' key."); |
} |
+ |
var parsed = new Map.from(description); |
parsed.remove('url'); |
parsed.remove('ref'); |
if (fromLockFile) parsed.remove('resolved-ref'); |
+ |
if (!parsed.isEmpty) { |
var plural = parsed.length > 1; |
var keys = parsed.keys.join(', '); |
throw new FormatException("Invalid key${plural ? 's' : ''}: $keys."); |
} |
+ |
return description; |
} |
+ |
+ /// Two Git descriptions are equal if both their URLs and their refs are |
+ /// equal. |
bool descriptionsEqual(description1, description2) { |
+ // TODO(nweiz): Do we really want to throw an error if you have two |
+ // dependencies on some repo, one of which specifies a ref and one of which |
+ // doesn't? If not, how do we handle that case in the version solver? |
return _getUrl(description1) == _getUrl(description2) && |
_getRef(description1) == _getRef(description2); |
} |
+ |
+ /// Attaches a specific commit to [id] to disambiguate it. |
Future<PackageId> resolveId(PackageId id) { |
return _ensureRevision(id).then((revision) { |
var description = { |
@@ -81,14 +138,21 @@ class GitSource extends CachedSource { |
return new PackageId(id.name, name, id.version, description); |
}); |
} |
+ |
List<Package> getCachedPackages() { |
+ // TODO(keertip): Implement getCachedPackages(). |
throw new UnimplementedError( |
"The git source doesn't support listing its cached packages yet."); |
} |
+ |
+ /// Resets all cached packages back to the pristine state of the Git |
+ /// repository at the revision they are pinned to. |
Future<Pair<int, int>> repairCachedPackages() { |
if (!dirExists(systemCacheRoot)) return new Future.value(new Pair(0, 0)); |
+ |
var successes = 0; |
var failures = 0; |
+ |
var packages = listDir( |
systemCacheRoot).where( |
(entry) => |
@@ -98,14 +162,21 @@ class GitSource extends CachedSource { |
".git"))).map( |
(packageDir) => |
new Package.load(null, packageDir, systemCache.sources)).toList(); |
+ |
+ // Note that there may be multiple packages with the same name and version |
+ // (pinned to different commits). The sort order of those is unspecified. |
packages.sort(Package.orderByNameAndVersion); |
+ |
return Future.wait(packages.map((package) { |
log.message( |
"Resetting Git repository for " |
"${log.bold(package.name)} ${package.version}..."); |
+ |
+ // Remove all untracked files. |
return git.run( |
["clean", "-d", "--force", "-x"], |
workingDir: package.dir).then((_) { |
+ // Discard all changes to tracked files. |
return git.run(["reset", "--hard", "HEAD"], workingDir: package.dir); |
}).then((_) { |
successes++; |
@@ -119,6 +190,13 @@ class GitSource extends CachedSource { |
}, test: (error) => error is git.GitException); |
})).then((_) => new Pair(successes, failures)); |
} |
+ |
+ /// Ensure that the canonical clone of the repository referred to by [id] (the |
+ /// one in `<system cache>/git/cache`) exists and contains the revision |
+ /// referred to by [id]. |
+ /// |
+ /// Returns a future that completes to the hash of the revision identified by |
+ /// [id]. |
Future<String> _ensureRevision(PackageId id) { |
return new Future.sync(() { |
var path = _repoCachePath(id); |
@@ -128,16 +206,28 @@ class GitSource extends CachedSource { |
path, |
mirror: true).then((_) => _revParse(id)); |
} |
+ |
+ // If [id] didn't come from a lockfile, it may be using a symbolic |
+ // reference. We want to get the latest version of that reference. |
var description = id.description; |
if (description is! Map || !description.containsKey('resolved-ref')) { |
return _updateRepoCache(id).then((_) => _revParse(id)); |
} |
+ |
+ // If [id] did come from a lockfile, then we want to avoid running "git |
+ // fetch" if possible to avoid networking time and errors. See if the |
+ // revision exists in the repo cache before updating it. |
return _revParse(id).catchError((error) { |
if (error is! git.GitException) throw error; |
return _updateRepoCache(id).then((_) => _revParse(id)); |
}); |
}); |
} |
+ |
+ /// Runs "git fetch" in the canonical clone of the repository referred to by |
+ /// [id]. |
+ /// |
+ /// This assumes that the canonical clone already exists. |
Future _updateRepoCache(PackageId id) { |
var path = _repoCachePath(id); |
if (_updatedRepos.contains(path)) return new Future.value(); |
@@ -145,48 +235,94 @@ class GitSource extends CachedSource { |
_updatedRepos.add(path); |
}); |
} |
+ |
+ /// Runs "git rev-parse" in the canonical clone of the repository referred to |
+ /// by [id] on the effective ref of [id]. |
+ /// |
+ /// This assumes that the canonical clone already exists. |
Future<String> _revParse(PackageId id) { |
return git.run( |
["rev-parse", _getEffectiveRef(id)], |
workingDir: _repoCachePath(id)).then((result) => result.first); |
} |
+ |
+ /// Clones the repo at the URI [from] to the path [to] on the local |
+ /// filesystem. |
+ /// |
+ /// If [mirror] is true, creates a bare, mirrored clone. This doesn't check |
+ /// out the working tree, but instead makes the repository a local mirror of |
+ /// the remote repository. See the manpage for `git clone` for more |
+ /// information. |
+ /// |
+ /// If [shallow] is true, creates a shallow clone that contains no history |
+ /// for the repository. |
Future _clone(String from, String to, {bool mirror: false, bool shallow: |
false}) { |
return new Future.sync(() { |
+ // Git on Windows does not seem to automatically create the destination |
+ // directory. |
ensureDir(to); |
var args = ["clone", from, to]; |
+ |
if (mirror) args.insert(1, "--mirror"); |
if (shallow) args.insertAll(1, ["--depth", "1"]); |
+ |
return git.run(args); |
}).then((result) => null); |
} |
+ |
+ /// Checks out the reference [ref] in [repoPath]. |
Future _checkOut(String repoPath, String ref) { |
return git.run( |
["checkout", ref], |
workingDir: repoPath).then((result) => null); |
} |
+ |
+ /// Returns the path to the canonical clone of the repository referred to by |
+ /// [id] (the one in `<system cache>/git/cache`). |
String _repoCachePath(PackageId id) { |
var repoCacheName = '${id.name}-${sha1(_getUrl(id))}'; |
return path.join(systemCacheRoot, 'cache', repoCacheName); |
} |
+ |
+ /// Returns the repository URL for [id]. |
+ /// |
+ /// [description] may be a description or a [PackageId]. |
String _getUrl(description) { |
description = _getDescription(description); |
if (description is String) return description; |
return description['url']; |
} |
+ |
+ /// Returns the commit ref that should be checked out for [description]. |
+ /// |
+ /// This differs from [_getRef] in that it doesn't just return the ref in |
+ /// [description]. It will return a sensible default if that ref doesn't |
+ /// exist, and it will respect the "resolved-ref" parameter set by |
+ /// [resolveId]. |
+ /// |
+ /// [description] may be a description or a [PackageId]. |
String _getEffectiveRef(description) { |
description = _getDescription(description); |
if (description is Map && description.containsKey('resolved-ref')) { |
return description['resolved-ref']; |
} |
+ |
var ref = _getRef(description); |
return ref == null ? 'HEAD' : ref; |
} |
+ |
+ /// Returns the commit ref for [description], or null if none is given. |
+ /// |
+ /// [description] may be a description or a [PackageId]. |
String _getRef(description) { |
description = _getDescription(description); |
if (description is String) return null; |
return description['ref']; |
} |
+ |
+ /// Returns [description] if it's a description, or [PackageId.description] if |
+ /// it's a [PackageId]. |
_getDescription(description) { |
if (description is PackageId) return description.description; |
return description; |