blob: 3f91e283a62f532f9faf7fd526dce589b0ce44bd [file] [log] [blame]
// 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.
import 'dart:async';
import '../command.dart';
import '../exit_codes.dart' as exit_codes;
import '../http.dart';
import '../io.dart';
import '../log.dart' as log;
import '../oauth2.dart' as oauth2;
/// Handles the `uploader` pub command.
class UploaderCommand extends PubCommand {
String get name => 'uploader';
String get description =>
'Manage uploaders for a package on';
String get invocation => 'pub uploader [options] {add/remove} <email>';
String get docUrl => '';
/// The URL of the package hosting server.
Uri get server => Uri.parse(argResults['server']);
UploaderCommand() {
defaultsTo: cache.sources.hosted.defaultUrl,
help: 'The package server on which the package is hosted.');
help: 'The package whose uploaders will be modified.\n'
'(defaults to the current package)');
Future run() {
if ( {
log.error('No uploader command given.');
return flushThenExit(exit_codes.USAGE);
var rest =;
// TODO(rnystrom): Use subcommands for these.
var command = rest.removeAt(0);
if (!['add', 'remove'].contains(command)) {
log.error('Unknown uploader command "$command".');
return flushThenExit(exit_codes.USAGE);
} else if (rest.isEmpty) {
log.error('No uploader given for "pub uploader $command".');
return flushThenExit(exit_codes.USAGE);
return Future.sync(() {
var package = argResults['package'];
if (package != null) return package;
.then((package) {
var uploader = rest[0];
return oauth2.withClient(cache, (client) {
if (command == 'add') {
var url = server.resolve('/api/packages/'
return client
.post(url, headers: pubApiHeaders, body: {'email': uploader});
} else {
// command == 'remove'
var url = server.resolve('/api/packages/'
return client.delete(url, headers: pubApiHeaders);
.catchError((error) => handleJsonError(error.response),
test: (e) => e is PubHttpException);