Index: utils/pub/command_lish.dart |
diff --git a/utils/pub/command_lish.dart b/utils/pub/command_lish.dart |
deleted file mode 100644 |
index 1f767c9c94adc71d5a284103eb8b081e5c7a4e38..0000000000000000000000000000000000000000 |
--- a/utils/pub/command_lish.dart |
+++ /dev/null |
@@ -1,207 +0,0 @@ |
-// 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 command_lish; |
- |
-import 'dart:async'; |
-import 'dart:io'; |
-import 'dart:json'; |
-import 'dart:uri'; |
- |
-import 'package:args/args.dart'; |
-import 'package:http/http.dart' as http; |
-import 'package:pathos/path.dart' as path; |
- |
-import 'directory_tree.dart'; |
-import 'exit_codes.dart' as exit_codes; |
-import 'git.dart' as git; |
-import 'http.dart'; |
-import 'io.dart'; |
-import 'log.dart' as log; |
-import 'oauth2.dart' as oauth2; |
-import 'pub.dart'; |
-import 'utils.dart'; |
-import 'validator.dart'; |
- |
-/// Handles the `lish` and `publish` pub commands. |
-class LishCommand extends PubCommand { |
- final description = "Publish the current package to pub.dartlang.org."; |
- final usage = "pub publish [options]"; |
- final aliases = const ["lish", "lush"]; |
- |
- ArgParser get commandParser { |
- var parser = new ArgParser(); |
- // TODO(nweiz): Use HostedSource.defaultUrl as the default value once we use |
- // dart:io for HTTPS requests. |
- parser.addFlag('dry-run', abbr: 'n', negatable: false, |
- help: 'Validate but do not publish the package'); |
- parser.addFlag('force', abbr: 'f', negatable: false, |
- help: 'Publish without confirmation if there are no errors'); |
- parser.addOption('server', defaultsTo: 'https://pub.dartlang.org', |
- help: 'The package server to which to upload this package'); |
- return parser; |
- } |
- |
- /// The URL of the server to which to upload the package. |
- Uri get server => Uri.parse(commandOptions['server']); |
- |
- /// Whether the publish is just a preview. |
- bool get dryRun => commandOptions['dry-run']; |
- |
- /// Whether the publish requires confirmation. |
- bool get force => commandOptions['force']; |
- |
- Future _publish(packageBytes) { |
- var cloudStorageUrl; |
- return oauth2.withClient(cache, (client) { |
- // TODO(nweiz): Cloud Storage can provide an XML-formatted error. We |
- // should report that error and exit. |
- var newUri = server.resolve("/packages/versions/new.json"); |
- return client.get(newUri).then((response) { |
- var parameters = parseJsonResponse(response); |
- |
- var url = _expectField(parameters, 'url', response); |
- if (url is! String) invalidServerResponse(response); |
- cloudStorageUrl = Uri.parse(url); |
- var request = new http.MultipartRequest('POST', cloudStorageUrl); |
- |
- var fields = _expectField(parameters, 'fields', response); |
- if (fields is! Map) invalidServerResponse(response); |
- fields.forEach((key, value) { |
- if (value is! String) invalidServerResponse(response); |
- request.fields[key] = value; |
- }); |
- |
- request.followRedirects = false; |
- request.files.add(new http.MultipartFile.fromBytes( |
- 'file', packageBytes, filename: 'package.tar.gz')); |
- return client.send(request); |
- }).then(http.Response.fromStream).then((response) { |
- var location = response.headers['location']; |
- if (location == null) throw new PubHttpException(response); |
- return location; |
- }).then((location) => client.get(location)) |
- .then(handleJsonSuccess); |
- }).catchError((error) { |
- if (error is! PubHttpException) throw error; |
- var url = error.response.request.url; |
- if (urisEqual(url, cloudStorageUrl)) { |
- // TODO(nweiz): the response may have XML-formatted information about |
- // the error. Try to parse that out once we have an easily-accessible |
- // XML parser. |
- throw new Exception('Failed to upload the package.'); |
- } else if (urisEqual(Uri.parse(url.origin), Uri.parse(server.origin))) { |
- handleJsonError(error.response); |
- } else { |
- throw error; |
- } |
- }); |
- } |
- |
- Future onRun() { |
- if (force && dryRun) { |
- log.error('Cannot use both --force and --dry-run.'); |
- this.printUsage(); |
- exit(exit_codes.USAGE); |
- } |
- |
- var packageBytesFuture = _filesToPublish.then((files) { |
- log.fine('Archiving and publishing ${entrypoint.root}.'); |
- |
- // Show the package contents so the user can verify they look OK. |
- var package = entrypoint.root; |
- log.message( |
- 'Publishing "${package.name}" ${package.version}:\n' |
- '${generateTree(files)}'); |
- |
- return createTarGz(files, baseDir: entrypoint.root.dir); |
- }).then((stream) => stream.toBytes()); |
- |
- // Validate the package. |
- return _validate(packageBytesFuture.then((bytes) => bytes.length)) |
- .then((isValid) { |
- if (isValid) return packageBytesFuture.then(_publish); |
- }); |
- } |
- |
- /// The basenames of files that are automatically excluded from archives. |
- final _BLACKLISTED_FILES = const ['pubspec.lock']; |
- |
- /// The basenames of directories that are automatically excluded from |
- /// archives. |
- final _BLACKLISTED_DIRS = const ['packages']; |
- |
- /// Returns a list of files that should be included in the published package. |
- /// If this is a Git repository, this will respect .gitignore; otherwise, it |
- /// will return all non-hidden files. |
- Future<List<String>> get _filesToPublish { |
- var rootDir = entrypoint.root.dir; |
- |
- return git.isInstalled.then((gitInstalled) { |
- if (dirExists(path.join(rootDir, '.git')) && gitInstalled) { |
- // List all files that aren't gitignored, including those not checked |
- // in to Git. |
- return git.run(["ls-files", "--cached", "--others", |
- "--exclude-standard"]); |
- } |
- |
- return listDir(rootDir, recursive: true) |
- .where(fileExists) // Skip directories and broken symlinks. |
- .map((entry) => path.relative(entry, from: rootDir)); |
- }).then((files) => files.where(_shouldPublish).toList()); |
- } |
- |
- /// Returns `true` if [file] should be published. |
- bool _shouldPublish(String file) { |
- if (_BLACKLISTED_FILES.contains(path.basename(file))) return false; |
- return !path.split(file).any(_BLACKLISTED_DIRS.contains); |
- } |
- |
- /// Returns the value associated with [key] in [map]. Throws a user-friendly |
- /// error if [map] doens't contain [key]. |
- _expectField(Map map, String key, http.Response response) { |
- if (map.containsKey(key)) return map[key]; |
- invalidServerResponse(response); |
- } |
- |
- /// Validates the package. Completes to false if the upload should not |
- /// proceed. |
- Future<bool> _validate(Future<int> packageSize) { |
- return Validator.runAll(entrypoint, packageSize).then((pair) { |
- var errors = pair.first; |
- var warnings = pair.last; |
- |
- if (!errors.isEmpty) { |
- log.error("Sorry, your package is missing " |
- "${(errors.length > 1) ? 'some requirements' : 'a requirement'} " |
- "and can't be published yet.\nFor more information, see: " |
- "http://pub.dartlang.org/doc/pub-lish.html.\n"); |
- return false; |
- } |
- |
- if (force) return true; |
- |
- if (dryRun) { |
- var s = warnings.length == 1 ? '' : 's'; |
- log.warning("Package has ${warnings.length} warning$s."); |
- return false; |
- } |
- |
- var message = 'Looks great! Are you ready to upload your package'; |
- |
- if (!warnings.isEmpty) { |
- var s = warnings.length == 1 ? '' : 's'; |
- message = "Package has ${warnings.length} warning$s. Upload anyway"; |
- } |
- |
- return confirm(message).then((confirmed) { |
- if (!confirmed) { |
- log.error("Package upload canceled."); |
- return false; |
- } |
- return true; |
- }); |
- }); |
- } |
-} |