Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1679)

Unified Diff: sdk/lib/_internal/pub_generated/lib/src/source/git.dart

Issue 657673002: Regenerate pub sources. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 6 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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;
« no previous file with comments | « sdk/lib/_internal/pub_generated/lib/src/source/cached.dart ('k') | sdk/lib/_internal/pub_generated/lib/src/source/hosted.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698