| OLD | NEW |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 library pub_uploader_test; | 5 library pub_uploader_test; |
| 6 | 6 |
| 7 import 'dart:convert'; | 7 import 'dart:convert'; |
| 8 | 8 |
| 9 import 'package:scheduled_test/scheduled_process.dart'; | 9 import 'package:scheduled_test/scheduled_process.dart'; |
| 10 import 'package:scheduled_test/scheduled_server.dart'; | 10 import 'package:scheduled_test/scheduled_server.dart'; |
| (...skipping 14 matching lines...) Expand all Loading... |
| 25 (defaults to "https://pub.dartlang.org") | 25 (defaults to "https://pub.dartlang.org") |
| 26 | 26 |
| 27 --package The package whose uploaders will be modified. | 27 --package The package whose uploaders will be modified. |
| 28 (defaults to the current package) | 28 (defaults to the current package) |
| 29 | 29 |
| 30 Run "pub help" to see global options. | 30 Run "pub help" to see global options. |
| 31 See http://dartlang.org/tools/pub/cmd/pub-uploader.html for detailed documentati
on. | 31 See http://dartlang.org/tools/pub/cmd/pub-uploader.html for detailed documentati
on. |
| 32 '''; | 32 '''; |
| 33 | 33 |
| 34 ScheduledProcess startPubUploader(ScheduledServer server, List<String> args) { | 34 ScheduledProcess startPubUploader(ScheduledServer server, List<String> args) { |
| 35 var tokenEndpoint = server.url.then((url) => | 35 var tokenEndpoint = |
| 36 url.resolve('/token').toString()); | 36 server.url.then((url) => url.resolve('/token').toString()); |
| 37 args = flatten(['uploader', '--server', tokenEndpoint, args]); | 37 args = flatten(['uploader', '--server', tokenEndpoint, args]); |
| 38 return startPub(args: args, tokenEndpoint: tokenEndpoint); | 38 return startPub(args: args, tokenEndpoint: tokenEndpoint); |
| 39 } | 39 } |
| 40 | 40 |
| 41 main() { | 41 main() { |
| 42 initConfig(); | 42 initConfig(); |
| 43 group('displays usage', () { | 43 group('displays usage', () { |
| 44 integration('when run with no arguments', () { | 44 integration('when run with no arguments', () { |
| 45 schedulePub(args: ['uploader'], | 45 schedulePub( |
| 46 output: USAGE_STRING, exitCode: exit_codes.USAGE); | 46 args: ['uploader'], |
| 47 output: USAGE_STRING, |
| 48 exitCode: exit_codes.USAGE); |
| 47 }); | 49 }); |
| 48 | 50 |
| 49 integration('when run with only a command', () { | 51 integration('when run with only a command', () { |
| 50 schedulePub(args: ['uploader', 'add'], | 52 schedulePub( |
| 51 output: USAGE_STRING, exitCode: exit_codes.USAGE); | 53 args: ['uploader', 'add'], |
| 54 output: USAGE_STRING, |
| 55 exitCode: exit_codes.USAGE); |
| 52 }); | 56 }); |
| 53 | 57 |
| 54 integration('when run with an invalid command', () { | 58 integration('when run with an invalid command', () { |
| 55 schedulePub(args: ['uploader', 'foo', 'email'], | 59 schedulePub( |
| 56 output: USAGE_STRING, exitCode: exit_codes.USAGE); | 60 args: ['uploader', 'foo', 'email'], |
| 61 output: USAGE_STRING, |
| 62 exitCode: exit_codes.USAGE); |
| 57 }); | 63 }); |
| 58 }); | 64 }); |
| 59 | 65 |
| 60 integration('adds an uploader', () { | 66 integration('adds an uploader', () { |
| 61 var server = new ScheduledServer(); | 67 var server = new ScheduledServer(); |
| 62 d.credentialsFile(server, 'access token').create(); | 68 d.credentialsFile(server, 'access token').create(); |
| 63 var pub = startPubUploader(server, ['--package', 'pkg', 'add', 'email']); | 69 var pub = startPubUploader(server, ['--package', 'pkg', 'add', 'email']); |
| 64 | 70 |
| 65 server.handle('POST', '/api/packages/pkg/uploaders', (request) { | 71 server.handle('POST', '/api/packages/pkg/uploaders', (request) { |
| 66 return request.readAsString().then((body) { | 72 return request.readAsString().then((body) { |
| 67 expect(body, equals('email=email')); | 73 expect(body, equals('email=email')); |
| 68 | 74 |
| 69 return new shelf.Response.ok(JSON.encode({ | 75 return new shelf.Response.ok(JSON.encode({ |
| 70 'success': {'message': 'Good job!'} | 76 'success': { |
| 71 }), headers: {'content-type': 'application/json'}); | 77 'message': 'Good job!' |
| 78 } |
| 79 }), headers: { |
| 80 'content-type': 'application/json' |
| 81 }); |
| 72 }); | 82 }); |
| 73 }); | 83 }); |
| 74 | 84 |
| 75 pub.stdout.expect('Good job!'); | 85 pub.stdout.expect('Good job!'); |
| 76 pub.shouldExit(exit_codes.SUCCESS); | 86 pub.shouldExit(exit_codes.SUCCESS); |
| 77 }); | 87 }); |
| 78 | 88 |
| 79 integration('removes an uploader', () { | 89 integration('removes an uploader', () { |
| 80 var server = new ScheduledServer(); | 90 var server = new ScheduledServer(); |
| 81 d.credentialsFile(server, 'access token').create(); | 91 d.credentialsFile(server, 'access token').create(); |
| 82 var pub = startPubUploader(server, ['--package', 'pkg', 'remove', 'email']); | 92 var pub = startPubUploader(server, ['--package', 'pkg', 'remove', 'email']); |
| 83 | 93 |
| 84 server.handle('DELETE', '/api/packages/pkg/uploaders/email', (request) { | 94 server.handle('DELETE', '/api/packages/pkg/uploaders/email', (request) { |
| 85 return new shelf.Response.ok(JSON.encode({ | 95 return new shelf.Response.ok(JSON.encode({ |
| 86 'success': {'message': 'Good job!'} | 96 'success': { |
| 87 }), headers: {'content-type': 'application/json'}); | 97 'message': 'Good job!' |
| 98 } |
| 99 }), headers: { |
| 100 'content-type': 'application/json' |
| 101 }); |
| 88 }); | 102 }); |
| 89 | 103 |
| 90 pub.stdout.expect('Good job!'); | 104 pub.stdout.expect('Good job!'); |
| 91 pub.shouldExit(exit_codes.SUCCESS); | 105 pub.shouldExit(exit_codes.SUCCESS); |
| 92 }); | 106 }); |
| 93 | 107 |
| 94 integration('defaults to the current package', () { | 108 integration('defaults to the current package', () { |
| 95 d.validPackage.create(); | 109 d.validPackage.create(); |
| 96 | 110 |
| 97 var server = new ScheduledServer(); | 111 var server = new ScheduledServer(); |
| 98 d.credentialsFile(server, 'access token').create(); | 112 d.credentialsFile(server, 'access token').create(); |
| 99 var pub = startPubUploader(server, ['add', 'email']); | 113 var pub = startPubUploader(server, ['add', 'email']); |
| 100 | 114 |
| 101 server.handle('POST', '/api/packages/test_pkg/uploaders', (request) { | 115 server.handle('POST', '/api/packages/test_pkg/uploaders', (request) { |
| 102 return new shelf.Response.ok(JSON.encode({ | 116 return new shelf.Response.ok(JSON.encode({ |
| 103 'success': {'message': 'Good job!'} | 117 'success': { |
| 104 }), headers: {'content-type': 'application/json'}); | 118 'message': 'Good job!' |
| 119 } |
| 120 }), headers: { |
| 121 'content-type': 'application/json' |
| 122 }); |
| 105 }); | 123 }); |
| 106 | 124 |
| 107 pub.stdout.expect('Good job!'); | 125 pub.stdout.expect('Good job!'); |
| 108 pub.shouldExit(exit_codes.SUCCESS); | 126 pub.shouldExit(exit_codes.SUCCESS); |
| 109 }); | 127 }); |
| 110 | 128 |
| 111 integration('add provides an error', () { | 129 integration('add provides an error', () { |
| 112 var server = new ScheduledServer(); | 130 var server = new ScheduledServer(); |
| 113 d.credentialsFile(server, 'access token').create(); | 131 d.credentialsFile(server, 'access token').create(); |
| 114 var pub = startPubUploader(server, ['--package', 'pkg', 'add', 'email']); | 132 var pub = startPubUploader(server, ['--package', 'pkg', 'add', 'email']); |
| 115 | 133 |
| 116 server.handle('POST', '/api/packages/pkg/uploaders', (request) { | 134 server.handle('POST', '/api/packages/pkg/uploaders', (request) { |
| 117 return new shelf.Response(400, | 135 return new shelf.Response(400, body: JSON.encode({ |
| 118 body: JSON.encode({'error': {'message': 'Bad job!'}}), | 136 'error': { |
| 119 headers: {'content-type': 'application/json'}); | 137 'message': 'Bad job!' |
| 138 } |
| 139 }), headers: { |
| 140 'content-type': 'application/json' |
| 141 }); |
| 120 }); | 142 }); |
| 121 | 143 |
| 122 pub.stderr.expect('Bad job!'); | 144 pub.stderr.expect('Bad job!'); |
| 123 pub.shouldExit(1); | 145 pub.shouldExit(1); |
| 124 }); | 146 }); |
| 125 | 147 |
| 126 integration('remove provides an error', () { | 148 integration('remove provides an error', () { |
| 127 var server = new ScheduledServer(); | 149 var server = new ScheduledServer(); |
| 128 d.credentialsFile(server, 'access token').create(); | 150 d.credentialsFile(server, 'access token').create(); |
| 129 var pub = startPubUploader(server, | 151 var pub = |
| 130 ['--package', 'pkg', 'remove', 'e/mail']); | 152 startPubUploader(server, ['--package', 'pkg', 'remove', 'e/mail']); |
| 131 | 153 |
| 132 server.handle('DELETE', '/api/packages/pkg/uploaders/e%2Fmail', (request) { | 154 server.handle('DELETE', '/api/packages/pkg/uploaders/e%2Fmail', (request) { |
| 133 return new shelf.Response(400, | 155 return new shelf.Response(400, body: JSON.encode({ |
| 134 body: JSON.encode({'error': {'message': 'Bad job!'}}), | 156 'error': { |
| 135 headers: {'content-type': 'application/json'}); | 157 'message': 'Bad job!' |
| 158 } |
| 159 }), headers: { |
| 160 'content-type': 'application/json' |
| 161 }); |
| 136 }); | 162 }); |
| 137 | 163 |
| 138 pub.stderr.expect('Bad job!'); | 164 pub.stderr.expect('Bad job!'); |
| 139 pub.shouldExit(1); | 165 pub.shouldExit(1); |
| 140 }); | 166 }); |
| 141 | 167 |
| 142 integration('add provides invalid JSON', () { | 168 integration('add provides invalid JSON', () { |
| 143 var server = new ScheduledServer(); | 169 var server = new ScheduledServer(); |
| 144 d.credentialsFile(server, 'access token').create(); | 170 d.credentialsFile(server, 'access token').create(); |
| 145 var pub = startPubUploader(server, ['--package', 'pkg', 'add', 'email']); | 171 var pub = startPubUploader(server, ['--package', 'pkg', 'add', 'email']); |
| 146 | 172 |
| 147 server.handle('POST', '/api/packages/pkg/uploaders', | 173 server.handle( |
| 174 'POST', |
| 175 '/api/packages/pkg/uploaders', |
| 148 (request) => new shelf.Response.ok("{not json")); | 176 (request) => new shelf.Response.ok("{not json")); |
| 149 | 177 |
| 150 pub.stderr.expect(emitsLines( | 178 pub.stderr.expect(emitsLines('Invalid server response:\n' '{not json')); |
| 151 'Invalid server response:\n' | |
| 152 '{not json')); | |
| 153 pub.shouldExit(1); | 179 pub.shouldExit(1); |
| 154 }); | 180 }); |
| 155 | 181 |
| 156 integration('remove provides invalid JSON', () { | 182 integration('remove provides invalid JSON', () { |
| 157 var server = new ScheduledServer(); | 183 var server = new ScheduledServer(); |
| 158 d.credentialsFile(server, 'access token').create(); | 184 d.credentialsFile(server, 'access token').create(); |
| 159 var pub = startPubUploader(server, ['--package', 'pkg', 'remove', 'email']); | 185 var pub = startPubUploader(server, ['--package', 'pkg', 'remove', 'email']); |
| 160 | 186 |
| 161 server.handle('DELETE', '/api/packages/pkg/uploaders/email', | 187 server.handle( |
| 188 'DELETE', |
| 189 '/api/packages/pkg/uploaders/email', |
| 162 (request) => new shelf.Response.ok("{not json")); | 190 (request) => new shelf.Response.ok("{not json")); |
| 163 | 191 |
| 164 pub.stderr.expect(emitsLines( | 192 pub.stderr.expect(emitsLines('Invalid server response:\n' '{not json')); |
| 165 'Invalid server response:\n' | |
| 166 '{not json')); | |
| 167 pub.shouldExit(1); | 193 pub.shouldExit(1); |
| 168 }); | 194 }); |
| 169 } | 195 } |
| OLD | NEW |