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

Side by Side Diff: generated/googleapis_beta/test/taskqueue/v1beta2_test.dart

Issue 3006323002: Api-Roll 54: 2017-09-11 (Closed)
Patch Set: use 2.0.0-dev.infinity sdk constraint in pubspecs Created 3 years, 3 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 unified diff | Download patch
OLDNEW
1 library googleapis_beta.taskqueue.v1beta2.test; 1 library googleapis_beta.taskqueue.v1beta2.test;
2 2
3 import "dart:core" as core; 3 import "dart:core" as core;
4 import "dart:collection" as collection;
5 import "dart:async" as async; 4 import "dart:async" as async;
6 import "dart:convert" as convert; 5 import "dart:convert" as convert;
7 6
8 import 'package:http/http.dart' as http; 7 import 'package:http/http.dart' as http;
9 import 'package:http/testing.dart' as http_testing;
10 import 'package:test/test.dart' as unittest; 8 import 'package:test/test.dart' as unittest;
11 9
12 import 'package:googleapis_beta/taskqueue/v1beta2.dart' as api; 10 import 'package:googleapis_beta/taskqueue/v1beta2.dart' as api;
13 11
14 class HttpServerMock extends http.BaseClient { 12 class HttpServerMock extends http.BaseClient {
15 core.Function _callback; 13 core.Function _callback;
16 core.bool _expectJson; 14 core.bool _expectJson;
17 15
18 void register(core.Function callback, core.bool expectJson) { 16 void register(core.Function callback, core.bool expectJson) {
19 _callback = callback; 17 _callback = callback;
20 _expectJson = expectJson; 18 _expectJson = expectJson;
21 } 19 }
22 20
23 async.Future<http.StreamedResponse> send(http.BaseRequest request) { 21 async.Future<http.StreamedResponse> send(http.BaseRequest request) {
24 if (_expectJson) { 22 if (_expectJson) {
25 return request.finalize() 23 return request
24 .finalize()
26 .transform(convert.UTF8.decoder) 25 .transform(convert.UTF8.decoder)
27 .join('') 26 .join('')
28 .then((core.String jsonString) { 27 .then((core.String jsonString) {
29 if (jsonString.isEmpty) { 28 if (jsonString.isEmpty) {
30 return _callback(request, null); 29 return _callback(request, null);
31 } else { 30 } else {
32 return _callback(request, convert.JSON.decode(jsonString)); 31 return _callback(request, convert.JSON.decode(jsonString));
33 } 32 }
34 }); 33 });
35 } else { 34 } else {
36 var stream = request.finalize(); 35 var stream = request.finalize();
37 if (stream == null) { 36 if (stream == null) {
38 return _callback(request, []); 37 return _callback(request, []);
39 } else { 38 } else {
40 return stream.toBytes().then((data) { 39 return stream.toBytes().then((data) {
41 return _callback(request, data); 40 return _callback(request, data);
42 }); 41 });
43 } 42 }
44 } 43 }
45 } 44 }
46 } 45 }
47 46
48 http.StreamedResponse stringResponse( 47 http.StreamedResponse stringResponse(core.int status,
49 core.int status, core.Map<core.String, core.String> headers, core.String bod y) { 48 core.Map<core.String, core.String> headers, core.String body) {
50 var stream = new async.Stream.fromIterable([convert.UTF8.encode(body)]); 49 var stream = new async.Stream.fromIterable([convert.UTF8.encode(body)]);
51 return new http.StreamedResponse(stream, status, headers: headers); 50 return new http.StreamedResponse(stream, status, headers: headers);
52 } 51 }
53 52
54 core.int buildCounterTask = 0; 53 core.int buildCounterTask = 0;
55 buildTask() { 54 buildTask() {
56 var o = new api.Task(); 55 var o = new api.Task();
57 buildCounterTask++; 56 buildCounterTask++;
58 if (buildCounterTask < 3) { 57 if (buildCounterTask < 3) {
59 o.enqueueTimestamp = "foo"; 58 o.enqueueTimestamp = "foo";
(...skipping 17 matching lines...) Expand all
77 unittest.expect(o.kind, unittest.equals('foo')); 76 unittest.expect(o.kind, unittest.equals('foo'));
78 unittest.expect(o.leaseTimestamp, unittest.equals('foo')); 77 unittest.expect(o.leaseTimestamp, unittest.equals('foo'));
79 unittest.expect(o.payloadBase64, unittest.equals('foo')); 78 unittest.expect(o.payloadBase64, unittest.equals('foo'));
80 unittest.expect(o.queueName, unittest.equals('foo')); 79 unittest.expect(o.queueName, unittest.equals('foo'));
81 unittest.expect(o.retryCount, unittest.equals(42)); 80 unittest.expect(o.retryCount, unittest.equals(42));
82 unittest.expect(o.tag, unittest.equals('foo')); 81 unittest.expect(o.tag, unittest.equals('foo'));
83 } 82 }
84 buildCounterTask--; 83 buildCounterTask--;
85 } 84 }
86 85
87 buildUnnamed3335() { 86 buildUnnamed3328() {
88 var o = new core.List<core.String>(); 87 var o = new core.List<core.String>();
89 o.add("foo"); 88 o.add("foo");
90 o.add("foo"); 89 o.add("foo");
91 return o; 90 return o;
92 } 91 }
93 92
94 checkUnnamed3335(core.List<core.String> o) { 93 checkUnnamed3328(core.List<core.String> o) {
95 unittest.expect(o, unittest.hasLength(2)); 94 unittest.expect(o, unittest.hasLength(2));
96 unittest.expect(o[0], unittest.equals('foo')); 95 unittest.expect(o[0], unittest.equals('foo'));
97 unittest.expect(o[1], unittest.equals('foo')); 96 unittest.expect(o[1], unittest.equals('foo'));
98 } 97 }
99 98
100 buildUnnamed3336() { 99 buildUnnamed3329() {
101 var o = new core.List<core.String>(); 100 var o = new core.List<core.String>();
102 o.add("foo"); 101 o.add("foo");
103 o.add("foo"); 102 o.add("foo");
104 return o; 103 return o;
105 } 104 }
106 105
107 checkUnnamed3336(core.List<core.String> o) { 106 checkUnnamed3329(core.List<core.String> o) {
108 unittest.expect(o, unittest.hasLength(2)); 107 unittest.expect(o, unittest.hasLength(2));
109 unittest.expect(o[0], unittest.equals('foo')); 108 unittest.expect(o[0], unittest.equals('foo'));
110 unittest.expect(o[1], unittest.equals('foo')); 109 unittest.expect(o[1], unittest.equals('foo'));
111 } 110 }
112 111
113 buildUnnamed3337() { 112 buildUnnamed3330() {
114 var o = new core.List<core.String>(); 113 var o = new core.List<core.String>();
115 o.add("foo"); 114 o.add("foo");
116 o.add("foo"); 115 o.add("foo");
117 return o; 116 return o;
118 } 117 }
119 118
120 checkUnnamed3337(core.List<core.String> o) { 119 checkUnnamed3330(core.List<core.String> o) {
121 unittest.expect(o, unittest.hasLength(2)); 120 unittest.expect(o, unittest.hasLength(2));
122 unittest.expect(o[0], unittest.equals('foo')); 121 unittest.expect(o[0], unittest.equals('foo'));
123 unittest.expect(o[1], unittest.equals('foo')); 122 unittest.expect(o[1], unittest.equals('foo'));
124 } 123 }
125 124
126 core.int buildCounterTaskQueueAcl = 0; 125 core.int buildCounterTaskQueueAcl = 0;
127 buildTaskQueueAcl() { 126 buildTaskQueueAcl() {
128 var o = new api.TaskQueueAcl(); 127 var o = new api.TaskQueueAcl();
129 buildCounterTaskQueueAcl++; 128 buildCounterTaskQueueAcl++;
130 if (buildCounterTaskQueueAcl < 3) { 129 if (buildCounterTaskQueueAcl < 3) {
131 o.adminEmails = buildUnnamed3335(); 130 o.adminEmails = buildUnnamed3328();
132 o.consumerEmails = buildUnnamed3336(); 131 o.consumerEmails = buildUnnamed3329();
133 o.producerEmails = buildUnnamed3337(); 132 o.producerEmails = buildUnnamed3330();
134 } 133 }
135 buildCounterTaskQueueAcl--; 134 buildCounterTaskQueueAcl--;
136 return o; 135 return o;
137 } 136 }
138 137
139 checkTaskQueueAcl(api.TaskQueueAcl o) { 138 checkTaskQueueAcl(api.TaskQueueAcl o) {
140 buildCounterTaskQueueAcl++; 139 buildCounterTaskQueueAcl++;
141 if (buildCounterTaskQueueAcl < 3) { 140 if (buildCounterTaskQueueAcl < 3) {
142 checkUnnamed3335(o.adminEmails); 141 checkUnnamed3328(o.adminEmails);
143 checkUnnamed3336(o.consumerEmails); 142 checkUnnamed3329(o.consumerEmails);
144 checkUnnamed3337(o.producerEmails); 143 checkUnnamed3330(o.producerEmails);
145 } 144 }
146 buildCounterTaskQueueAcl--; 145 buildCounterTaskQueueAcl--;
147 } 146 }
148 147
149 core.int buildCounterTaskQueueStats = 0; 148 core.int buildCounterTaskQueueStats = 0;
150 buildTaskQueueStats() { 149 buildTaskQueueStats() {
151 var o = new api.TaskQueueStats(); 150 var o = new api.TaskQueueStats();
152 buildCounterTaskQueueStats++; 151 buildCounterTaskQueueStats++;
153 if (buildCounterTaskQueueStats < 3) { 152 if (buildCounterTaskQueueStats < 3) {
154 o.leasedLastHour = "foo"; 153 o.leasedLastHour = "foo";
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after
191 if (buildCounterTaskQueue < 3) { 190 if (buildCounterTaskQueue < 3) {
192 checkTaskQueueAcl(o.acl); 191 checkTaskQueueAcl(o.acl);
193 unittest.expect(o.id, unittest.equals('foo')); 192 unittest.expect(o.id, unittest.equals('foo'));
194 unittest.expect(o.kind, unittest.equals('foo')); 193 unittest.expect(o.kind, unittest.equals('foo'));
195 unittest.expect(o.maxLeases, unittest.equals(42)); 194 unittest.expect(o.maxLeases, unittest.equals(42));
196 checkTaskQueueStats(o.stats); 195 checkTaskQueueStats(o.stats);
197 } 196 }
198 buildCounterTaskQueue--; 197 buildCounterTaskQueue--;
199 } 198 }
200 199
201 buildUnnamed3338() { 200 buildUnnamed3331() {
202 var o = new core.List<api.Task>(); 201 var o = new core.List<api.Task>();
203 o.add(buildTask()); 202 o.add(buildTask());
204 o.add(buildTask()); 203 o.add(buildTask());
205 return o; 204 return o;
206 } 205 }
207 206
208 checkUnnamed3338(core.List<api.Task> o) { 207 checkUnnamed3331(core.List<api.Task> o) {
209 unittest.expect(o, unittest.hasLength(2)); 208 unittest.expect(o, unittest.hasLength(2));
210 checkTask(o[0]); 209 checkTask(o[0]);
211 checkTask(o[1]); 210 checkTask(o[1]);
212 } 211 }
213 212
214 core.int buildCounterTasks = 0; 213 core.int buildCounterTasks = 0;
215 buildTasks() { 214 buildTasks() {
216 var o = new api.Tasks(); 215 var o = new api.Tasks();
217 buildCounterTasks++; 216 buildCounterTasks++;
218 if (buildCounterTasks < 3) { 217 if (buildCounterTasks < 3) {
219 o.items = buildUnnamed3338(); 218 o.items = buildUnnamed3331();
220 o.kind = "foo"; 219 o.kind = "foo";
221 } 220 }
222 buildCounterTasks--; 221 buildCounterTasks--;
223 return o; 222 return o;
224 } 223 }
225 224
226 checkTasks(api.Tasks o) { 225 checkTasks(api.Tasks o) {
227 buildCounterTasks++; 226 buildCounterTasks++;
228 if (buildCounterTasks < 3) { 227 if (buildCounterTasks < 3) {
229 checkUnnamed3338(o.items); 228 checkUnnamed3331(o.items);
230 unittest.expect(o.kind, unittest.equals('foo')); 229 unittest.expect(o.kind, unittest.equals('foo'));
231 } 230 }
232 buildCounterTasks--; 231 buildCounterTasks--;
233 } 232 }
234 233
235 buildUnnamed3339() { 234 buildUnnamed3332() {
236 var o = new core.List<api.Task>(); 235 var o = new core.List<api.Task>();
237 o.add(buildTask()); 236 o.add(buildTask());
238 o.add(buildTask()); 237 o.add(buildTask());
239 return o; 238 return o;
240 } 239 }
241 240
242 checkUnnamed3339(core.List<api.Task> o) { 241 checkUnnamed3332(core.List<api.Task> o) {
243 unittest.expect(o, unittest.hasLength(2)); 242 unittest.expect(o, unittest.hasLength(2));
244 checkTask(o[0]); 243 checkTask(o[0]);
245 checkTask(o[1]); 244 checkTask(o[1]);
246 } 245 }
247 246
248 core.int buildCounterTasks2 = 0; 247 core.int buildCounterTasks2 = 0;
249 buildTasks2() { 248 buildTasks2() {
250 var o = new api.Tasks2(); 249 var o = new api.Tasks2();
251 buildCounterTasks2++; 250 buildCounterTasks2++;
252 if (buildCounterTasks2 < 3) { 251 if (buildCounterTasks2 < 3) {
253 o.items = buildUnnamed3339(); 252 o.items = buildUnnamed3332();
254 o.kind = "foo"; 253 o.kind = "foo";
255 } 254 }
256 buildCounterTasks2--; 255 buildCounterTasks2--;
257 return o; 256 return o;
258 } 257 }
259 258
260 checkTasks2(api.Tasks2 o) { 259 checkTasks2(api.Tasks2 o) {
261 buildCounterTasks2++; 260 buildCounterTasks2++;
262 if (buildCounterTasks2 < 3) { 261 if (buildCounterTasks2 < 3) {
263 checkUnnamed3339(o.items); 262 checkUnnamed3332(o.items);
264 unittest.expect(o.kind, unittest.equals('foo')); 263 unittest.expect(o.kind, unittest.equals('foo'));
265 } 264 }
266 buildCounterTasks2--; 265 buildCounterTasks2--;
267 } 266 }
268 267
269
270 main() { 268 main() {
271 unittest.group("obj-schema-Task", () { 269 unittest.group("obj-schema-Task", () {
272 unittest.test("to-json--from-json", () { 270 unittest.test("to-json--from-json", () {
273 var o = buildTask(); 271 var o = buildTask();
274 var od = new api.Task.fromJson(o.toJson()); 272 var od = new api.Task.fromJson(o.toJson());
275 checkTask(od); 273 checkTask(od);
276 }); 274 });
277 }); 275 });
278 276
279
280 unittest.group("obj-schema-TaskQueueAcl", () { 277 unittest.group("obj-schema-TaskQueueAcl", () {
281 unittest.test("to-json--from-json", () { 278 unittest.test("to-json--from-json", () {
282 var o = buildTaskQueueAcl(); 279 var o = buildTaskQueueAcl();
283 var od = new api.TaskQueueAcl.fromJson(o.toJson()); 280 var od = new api.TaskQueueAcl.fromJson(o.toJson());
284 checkTaskQueueAcl(od); 281 checkTaskQueueAcl(od);
285 }); 282 });
286 }); 283 });
287 284
288
289 unittest.group("obj-schema-TaskQueueStats", () { 285 unittest.group("obj-schema-TaskQueueStats", () {
290 unittest.test("to-json--from-json", () { 286 unittest.test("to-json--from-json", () {
291 var o = buildTaskQueueStats(); 287 var o = buildTaskQueueStats();
292 var od = new api.TaskQueueStats.fromJson(o.toJson()); 288 var od = new api.TaskQueueStats.fromJson(o.toJson());
293 checkTaskQueueStats(od); 289 checkTaskQueueStats(od);
294 }); 290 });
295 }); 291 });
296 292
297
298 unittest.group("obj-schema-TaskQueue", () { 293 unittest.group("obj-schema-TaskQueue", () {
299 unittest.test("to-json--from-json", () { 294 unittest.test("to-json--from-json", () {
300 var o = buildTaskQueue(); 295 var o = buildTaskQueue();
301 var od = new api.TaskQueue.fromJson(o.toJson()); 296 var od = new api.TaskQueue.fromJson(o.toJson());
302 checkTaskQueue(od); 297 checkTaskQueue(od);
303 }); 298 });
304 }); 299 });
305 300
306
307 unittest.group("obj-schema-Tasks", () { 301 unittest.group("obj-schema-Tasks", () {
308 unittest.test("to-json--from-json", () { 302 unittest.test("to-json--from-json", () {
309 var o = buildTasks(); 303 var o = buildTasks();
310 var od = new api.Tasks.fromJson(o.toJson()); 304 var od = new api.Tasks.fromJson(o.toJson());
311 checkTasks(od); 305 checkTasks(od);
312 }); 306 });
313 }); 307 });
314 308
315
316 unittest.group("obj-schema-Tasks2", () { 309 unittest.group("obj-schema-Tasks2", () {
317 unittest.test("to-json--from-json", () { 310 unittest.test("to-json--from-json", () {
318 var o = buildTasks2(); 311 var o = buildTasks2();
319 var od = new api.Tasks2.fromJson(o.toJson()); 312 var od = new api.Tasks2.fromJson(o.toJson());
320 checkTasks2(od); 313 checkTasks2(od);
321 }); 314 });
322 }); 315 });
323 316
324
325 unittest.group("resource-TaskqueuesResourceApi", () { 317 unittest.group("resource-TaskqueuesResourceApi", () {
326 unittest.test("method--get", () { 318 unittest.test("method--get", () {
327
328 var mock = new HttpServerMock(); 319 var mock = new HttpServerMock();
329 api.TaskqueuesResourceApi res = new api.TaskqueueApi(mock).taskqueues; 320 api.TaskqueuesResourceApi res = new api.TaskqueueApi(mock).taskqueues;
330 var arg_project = "foo"; 321 var arg_project = "foo";
331 var arg_taskqueue = "foo"; 322 var arg_taskqueue = "foo";
332 var arg_getStats = true; 323 var arg_getStats = true;
333 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { 324 mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
334 var path = (req.url).path; 325 var path = (req.url).path;
335 var pathOffset = 0; 326 var pathOffset = 0;
336 var index; 327 var index;
337 var subPart; 328 var subPart;
338 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ als("/")); 329 unittest.expect(
330 path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
339 pathOffset += 1; 331 pathOffset += 1;
340 332
341 var query = (req.url).query; 333 var query = (req.url).query;
342 var queryOffset = 0; 334 var queryOffset = 0;
343 var queryMap = {}; 335 var queryMap = {};
344 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); 336 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
345 parseBool(n) { 337 parseBool(n) {
346 if (n == "true") return true; 338 if (n == "true") return true;
347 if (n == "false") return false; 339 if (n == "false") return false;
348 if (n == null) return null; 340 if (n == null) return null;
349 throw new core.ArgumentError("Invalid boolean: $n"); 341 throw new core.ArgumentError("Invalid boolean: $n");
350 } 342 }
343
351 if (query.length > 0) { 344 if (query.length > 0) {
352 for (var part in query.split("&")) { 345 for (var part in query.split("&")) {
353 var keyvalue = part.split("="); 346 var keyvalue = part.split("=");
354 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d ecodeQueryComponent(keyvalue[1])); 347 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]),
348 core.Uri.decodeQueryComponent(keyvalue[1]));
355 } 349 }
356 } 350 }
357 unittest.expect(queryMap["getStats"].first, unittest.equals("$arg_getSta ts")); 351 unittest.expect(
358 352 queryMap["getStats"].first, unittest.equals("$arg_getStats"));
359 353
360 var h = { 354 var h = {
361 "content-type" : "application/json; charset=utf-8", 355 "content-type": "application/json; charset=utf-8",
362 }; 356 };
363 var resp = convert.JSON.encode(buildTaskQueue()); 357 var resp = convert.JSON.encode(buildTaskQueue());
364 return new async.Future.value(stringResponse(200, h, resp)); 358 return new async.Future.value(stringResponse(200, h, resp));
365 }), true); 359 }), true);
366 res.get(arg_project, arg_taskqueue, getStats: arg_getStats).then(unittest. expectAsync1(((api.TaskQueue response) { 360 res
361 .get(arg_project, arg_taskqueue, getStats: arg_getStats)
362 .then(unittest.expectAsync1(((api.TaskQueue response) {
367 checkTaskQueue(response); 363 checkTaskQueue(response);
368 }))); 364 })));
369 }); 365 });
370
371 }); 366 });
372 367
373
374 unittest.group("resource-TasksResourceApi", () { 368 unittest.group("resource-TasksResourceApi", () {
375 unittest.test("method--delete", () { 369 unittest.test("method--delete", () {
376
377 var mock = new HttpServerMock(); 370 var mock = new HttpServerMock();
378 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks; 371 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks;
379 var arg_project = "foo"; 372 var arg_project = "foo";
380 var arg_taskqueue = "foo"; 373 var arg_taskqueue = "foo";
381 var arg_task = "foo"; 374 var arg_task = "foo";
382 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { 375 mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
383 var path = (req.url).path; 376 var path = (req.url).path;
384 var pathOffset = 0; 377 var pathOffset = 0;
385 var index; 378 var index;
386 var subPart; 379 var subPart;
387 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ als("/")); 380 unittest.expect(
381 path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
388 pathOffset += 1; 382 pathOffset += 1;
389 383
390 var query = (req.url).query; 384 var query = (req.url).query;
391 var queryOffset = 0; 385 var queryOffset = 0;
392 var queryMap = {}; 386 var queryMap = {};
393 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); 387 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
394 parseBool(n) { 388 parseBool(n) {
395 if (n == "true") return true; 389 if (n == "true") return true;
396 if (n == "false") return false; 390 if (n == "false") return false;
397 if (n == null) return null; 391 if (n == null) return null;
398 throw new core.ArgumentError("Invalid boolean: $n"); 392 throw new core.ArgumentError("Invalid boolean: $n");
399 } 393 }
394
400 if (query.length > 0) { 395 if (query.length > 0) {
401 for (var part in query.split("&")) { 396 for (var part in query.split("&")) {
402 var keyvalue = part.split("="); 397 var keyvalue = part.split("=");
403 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d ecodeQueryComponent(keyvalue[1])); 398 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]),
399 core.Uri.decodeQueryComponent(keyvalue[1]));
404 } 400 }
405 } 401 }
406 402
407
408 var h = { 403 var h = {
409 "content-type" : "application/json; charset=utf-8", 404 "content-type": "application/json; charset=utf-8",
410 }; 405 };
411 var resp = ""; 406 var resp = "";
412 return new async.Future.value(stringResponse(200, h, resp)); 407 return new async.Future.value(stringResponse(200, h, resp));
413 }), true); 408 }), true);
414 res.delete(arg_project, arg_taskqueue, arg_task).then(unittest.expectAsync 1((_) {})); 409 res
410 .delete(arg_project, arg_taskqueue, arg_task)
411 .then(unittest.expectAsync1((_) {}));
415 }); 412 });
416 413
417 unittest.test("method--get", () { 414 unittest.test("method--get", () {
418
419 var mock = new HttpServerMock(); 415 var mock = new HttpServerMock();
420 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks; 416 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks;
421 var arg_project = "foo"; 417 var arg_project = "foo";
422 var arg_taskqueue = "foo"; 418 var arg_taskqueue = "foo";
423 var arg_task = "foo"; 419 var arg_task = "foo";
424 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { 420 mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
425 var path = (req.url).path; 421 var path = (req.url).path;
426 var pathOffset = 0; 422 var pathOffset = 0;
427 var index; 423 var index;
428 var subPart; 424 var subPart;
429 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ als("/")); 425 unittest.expect(
426 path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
430 pathOffset += 1; 427 pathOffset += 1;
431 428
432 var query = (req.url).query; 429 var query = (req.url).query;
433 var queryOffset = 0; 430 var queryOffset = 0;
434 var queryMap = {}; 431 var queryMap = {};
435 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); 432 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
436 parseBool(n) { 433 parseBool(n) {
437 if (n == "true") return true; 434 if (n == "true") return true;
438 if (n == "false") return false; 435 if (n == "false") return false;
439 if (n == null) return null; 436 if (n == null) return null;
440 throw new core.ArgumentError("Invalid boolean: $n"); 437 throw new core.ArgumentError("Invalid boolean: $n");
441 } 438 }
439
442 if (query.length > 0) { 440 if (query.length > 0) {
443 for (var part in query.split("&")) { 441 for (var part in query.split("&")) {
444 var keyvalue = part.split("="); 442 var keyvalue = part.split("=");
445 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d ecodeQueryComponent(keyvalue[1])); 443 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]),
444 core.Uri.decodeQueryComponent(keyvalue[1]));
446 } 445 }
447 } 446 }
448 447
449
450 var h = { 448 var h = {
451 "content-type" : "application/json; charset=utf-8", 449 "content-type": "application/json; charset=utf-8",
452 }; 450 };
453 var resp = convert.JSON.encode(buildTask()); 451 var resp = convert.JSON.encode(buildTask());
454 return new async.Future.value(stringResponse(200, h, resp)); 452 return new async.Future.value(stringResponse(200, h, resp));
455 }), true); 453 }), true);
456 res.get(arg_project, arg_taskqueue, arg_task).then(unittest.expectAsync1(( (api.Task response) { 454 res
455 .get(arg_project, arg_taskqueue, arg_task)
456 .then(unittest.expectAsync1(((api.Task response) {
457 checkTask(response); 457 checkTask(response);
458 }))); 458 })));
459 }); 459 });
460 460
461 unittest.test("method--insert", () { 461 unittest.test("method--insert", () {
462
463 var mock = new HttpServerMock(); 462 var mock = new HttpServerMock();
464 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks; 463 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks;
465 var arg_request = buildTask(); 464 var arg_request = buildTask();
466 var arg_project = "foo"; 465 var arg_project = "foo";
467 var arg_taskqueue = "foo"; 466 var arg_taskqueue = "foo";
468 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { 467 mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
469 var obj = new api.Task.fromJson(json); 468 var obj = new api.Task.fromJson(json);
470 checkTask(obj); 469 checkTask(obj);
471 470
472 var path = (req.url).path; 471 var path = (req.url).path;
473 var pathOffset = 0; 472 var pathOffset = 0;
474 var index; 473 var index;
475 var subPart; 474 var subPart;
476 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ als("/")); 475 unittest.expect(
476 path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
477 pathOffset += 1; 477 pathOffset += 1;
478 478
479 var query = (req.url).query; 479 var query = (req.url).query;
480 var queryOffset = 0; 480 var queryOffset = 0;
481 var queryMap = {}; 481 var queryMap = {};
482 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); 482 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
483 parseBool(n) { 483 parseBool(n) {
484 if (n == "true") return true; 484 if (n == "true") return true;
485 if (n == "false") return false; 485 if (n == "false") return false;
486 if (n == null) return null; 486 if (n == null) return null;
487 throw new core.ArgumentError("Invalid boolean: $n"); 487 throw new core.ArgumentError("Invalid boolean: $n");
488 } 488 }
489
489 if (query.length > 0) { 490 if (query.length > 0) {
490 for (var part in query.split("&")) { 491 for (var part in query.split("&")) {
491 var keyvalue = part.split("="); 492 var keyvalue = part.split("=");
492 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d ecodeQueryComponent(keyvalue[1])); 493 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]),
494 core.Uri.decodeQueryComponent(keyvalue[1]));
493 } 495 }
494 } 496 }
495 497
496
497 var h = { 498 var h = {
498 "content-type" : "application/json; charset=utf-8", 499 "content-type": "application/json; charset=utf-8",
499 }; 500 };
500 var resp = convert.JSON.encode(buildTask()); 501 var resp = convert.JSON.encode(buildTask());
501 return new async.Future.value(stringResponse(200, h, resp)); 502 return new async.Future.value(stringResponse(200, h, resp));
502 }), true); 503 }), true);
503 res.insert(arg_request, arg_project, arg_taskqueue).then(unittest.expectAs ync1(((api.Task response) { 504 res
505 .insert(arg_request, arg_project, arg_taskqueue)
506 .then(unittest.expectAsync1(((api.Task response) {
504 checkTask(response); 507 checkTask(response);
505 }))); 508 })));
506 }); 509 });
507 510
508 unittest.test("method--lease", () { 511 unittest.test("method--lease", () {
509
510 var mock = new HttpServerMock(); 512 var mock = new HttpServerMock();
511 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks; 513 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks;
512 var arg_project = "foo"; 514 var arg_project = "foo";
513 var arg_taskqueue = "foo"; 515 var arg_taskqueue = "foo";
514 var arg_numTasks = 42; 516 var arg_numTasks = 42;
515 var arg_leaseSecs = 42; 517 var arg_leaseSecs = 42;
516 var arg_groupByTag = true; 518 var arg_groupByTag = true;
517 var arg_tag = "foo"; 519 var arg_tag = "foo";
518 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { 520 mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
519 var path = (req.url).path; 521 var path = (req.url).path;
520 var pathOffset = 0; 522 var pathOffset = 0;
521 var index; 523 var index;
522 var subPart; 524 var subPart;
523 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ als("/")); 525 unittest.expect(
526 path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
524 pathOffset += 1; 527 pathOffset += 1;
525 528
526 var query = (req.url).query; 529 var query = (req.url).query;
527 var queryOffset = 0; 530 var queryOffset = 0;
528 var queryMap = {}; 531 var queryMap = {};
529 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); 532 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
530 parseBool(n) { 533 parseBool(n) {
531 if (n == "true") return true; 534 if (n == "true") return true;
532 if (n == "false") return false; 535 if (n == "false") return false;
533 if (n == null) return null; 536 if (n == null) return null;
534 throw new core.ArgumentError("Invalid boolean: $n"); 537 throw new core.ArgumentError("Invalid boolean: $n");
535 } 538 }
539
536 if (query.length > 0) { 540 if (query.length > 0) {
537 for (var part in query.split("&")) { 541 for (var part in query.split("&")) {
538 var keyvalue = part.split("="); 542 var keyvalue = part.split("=");
539 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d ecodeQueryComponent(keyvalue[1])); 543 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]),
544 core.Uri.decodeQueryComponent(keyvalue[1]));
540 } 545 }
541 } 546 }
542 unittest.expect(core.int.parse(queryMap["numTasks"].first), unittest.equ als(arg_numTasks)); 547 unittest.expect(core.int.parse(queryMap["numTasks"].first),
543 unittest.expect(core.int.parse(queryMap["leaseSecs"].first), unittest.eq uals(arg_leaseSecs)); 548 unittest.equals(arg_numTasks));
544 unittest.expect(queryMap["groupByTag"].first, unittest.equals("$arg_grou pByTag")); 549 unittest.expect(core.int.parse(queryMap["leaseSecs"].first),
550 unittest.equals(arg_leaseSecs));
551 unittest.expect(
552 queryMap["groupByTag"].first, unittest.equals("$arg_groupByTag"));
545 unittest.expect(queryMap["tag"].first, unittest.equals(arg_tag)); 553 unittest.expect(queryMap["tag"].first, unittest.equals(arg_tag));
546 554
547
548 var h = { 555 var h = {
549 "content-type" : "application/json; charset=utf-8", 556 "content-type": "application/json; charset=utf-8",
550 }; 557 };
551 var resp = convert.JSON.encode(buildTasks()); 558 var resp = convert.JSON.encode(buildTasks());
552 return new async.Future.value(stringResponse(200, h, resp)); 559 return new async.Future.value(stringResponse(200, h, resp));
553 }), true); 560 }), true);
554 res.lease(arg_project, arg_taskqueue, arg_numTasks, arg_leaseSecs, groupBy Tag: arg_groupByTag, tag: arg_tag).then(unittest.expectAsync1(((api.Tasks respon se) { 561 res
562 .lease(arg_project, arg_taskqueue, arg_numTasks, arg_leaseSecs,
563 groupByTag: arg_groupByTag, tag: arg_tag)
564 .then(unittest.expectAsync1(((api.Tasks response) {
555 checkTasks(response); 565 checkTasks(response);
556 }))); 566 })));
557 }); 567 });
558 568
559 unittest.test("method--list", () { 569 unittest.test("method--list", () {
560
561 var mock = new HttpServerMock(); 570 var mock = new HttpServerMock();
562 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks; 571 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks;
563 var arg_project = "foo"; 572 var arg_project = "foo";
564 var arg_taskqueue = "foo"; 573 var arg_taskqueue = "foo";
565 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { 574 mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
566 var path = (req.url).path; 575 var path = (req.url).path;
567 var pathOffset = 0; 576 var pathOffset = 0;
568 var index; 577 var index;
569 var subPart; 578 var subPart;
570 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ als("/")); 579 unittest.expect(
580 path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
571 pathOffset += 1; 581 pathOffset += 1;
572 582
573 var query = (req.url).query; 583 var query = (req.url).query;
574 var queryOffset = 0; 584 var queryOffset = 0;
575 var queryMap = {}; 585 var queryMap = {};
576 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); 586 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
577 parseBool(n) { 587 parseBool(n) {
578 if (n == "true") return true; 588 if (n == "true") return true;
579 if (n == "false") return false; 589 if (n == "false") return false;
580 if (n == null) return null; 590 if (n == null) return null;
581 throw new core.ArgumentError("Invalid boolean: $n"); 591 throw new core.ArgumentError("Invalid boolean: $n");
582 } 592 }
593
583 if (query.length > 0) { 594 if (query.length > 0) {
584 for (var part in query.split("&")) { 595 for (var part in query.split("&")) {
585 var keyvalue = part.split("="); 596 var keyvalue = part.split("=");
586 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d ecodeQueryComponent(keyvalue[1])); 597 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]),
598 core.Uri.decodeQueryComponent(keyvalue[1]));
587 } 599 }
588 } 600 }
589 601
590
591 var h = { 602 var h = {
592 "content-type" : "application/json; charset=utf-8", 603 "content-type": "application/json; charset=utf-8",
593 }; 604 };
594 var resp = convert.JSON.encode(buildTasks2()); 605 var resp = convert.JSON.encode(buildTasks2());
595 return new async.Future.value(stringResponse(200, h, resp)); 606 return new async.Future.value(stringResponse(200, h, resp));
596 }), true); 607 }), true);
597 res.list(arg_project, arg_taskqueue).then(unittest.expectAsync1(((api.Task s2 response) { 608 res
609 .list(arg_project, arg_taskqueue)
610 .then(unittest.expectAsync1(((api.Tasks2 response) {
598 checkTasks2(response); 611 checkTasks2(response);
599 }))); 612 })));
600 }); 613 });
601 614
602 unittest.test("method--patch", () { 615 unittest.test("method--patch", () {
603
604 var mock = new HttpServerMock(); 616 var mock = new HttpServerMock();
605 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks; 617 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks;
606 var arg_request = buildTask(); 618 var arg_request = buildTask();
607 var arg_project = "foo"; 619 var arg_project = "foo";
608 var arg_taskqueue = "foo"; 620 var arg_taskqueue = "foo";
609 var arg_task = "foo"; 621 var arg_task = "foo";
610 var arg_newLeaseSeconds = 42; 622 var arg_newLeaseSeconds = 42;
611 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { 623 mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
612 var obj = new api.Task.fromJson(json); 624 var obj = new api.Task.fromJson(json);
613 checkTask(obj); 625 checkTask(obj);
614 626
615 var path = (req.url).path; 627 var path = (req.url).path;
616 var pathOffset = 0; 628 var pathOffset = 0;
617 var index; 629 var index;
618 var subPart; 630 var subPart;
619 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ als("/")); 631 unittest.expect(
632 path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
620 pathOffset += 1; 633 pathOffset += 1;
621 634
622 var query = (req.url).query; 635 var query = (req.url).query;
623 var queryOffset = 0; 636 var queryOffset = 0;
624 var queryMap = {}; 637 var queryMap = {};
625 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); 638 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
626 parseBool(n) { 639 parseBool(n) {
627 if (n == "true") return true; 640 if (n == "true") return true;
628 if (n == "false") return false; 641 if (n == "false") return false;
629 if (n == null) return null; 642 if (n == null) return null;
630 throw new core.ArgumentError("Invalid boolean: $n"); 643 throw new core.ArgumentError("Invalid boolean: $n");
631 } 644 }
645
632 if (query.length > 0) { 646 if (query.length > 0) {
633 for (var part in query.split("&")) { 647 for (var part in query.split("&")) {
634 var keyvalue = part.split("="); 648 var keyvalue = part.split("=");
635 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d ecodeQueryComponent(keyvalue[1])); 649 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]),
650 core.Uri.decodeQueryComponent(keyvalue[1]));
636 } 651 }
637 } 652 }
638 unittest.expect(core.int.parse(queryMap["newLeaseSeconds"].first), unitt est.equals(arg_newLeaseSeconds)); 653 unittest.expect(core.int.parse(queryMap["newLeaseSeconds"].first),
639 654 unittest.equals(arg_newLeaseSeconds));
640 655
641 var h = { 656 var h = {
642 "content-type" : "application/json; charset=utf-8", 657 "content-type": "application/json; charset=utf-8",
643 }; 658 };
644 var resp = convert.JSON.encode(buildTask()); 659 var resp = convert.JSON.encode(buildTask());
645 return new async.Future.value(stringResponse(200, h, resp)); 660 return new async.Future.value(stringResponse(200, h, resp));
646 }), true); 661 }), true);
647 res.patch(arg_request, arg_project, arg_taskqueue, arg_task, arg_newLeaseS econds).then(unittest.expectAsync1(((api.Task response) { 662 res
663 .patch(arg_request, arg_project, arg_taskqueue, arg_task,
664 arg_newLeaseSeconds)
665 .then(unittest.expectAsync1(((api.Task response) {
648 checkTask(response); 666 checkTask(response);
649 }))); 667 })));
650 }); 668 });
651 669
652 unittest.test("method--update", () { 670 unittest.test("method--update", () {
653
654 var mock = new HttpServerMock(); 671 var mock = new HttpServerMock();
655 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks; 672 api.TasksResourceApi res = new api.TaskqueueApi(mock).tasks;
656 var arg_request = buildTask(); 673 var arg_request = buildTask();
657 var arg_project = "foo"; 674 var arg_project = "foo";
658 var arg_taskqueue = "foo"; 675 var arg_taskqueue = "foo";
659 var arg_task = "foo"; 676 var arg_task = "foo";
660 var arg_newLeaseSeconds = 42; 677 var arg_newLeaseSeconds = 42;
661 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { 678 mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
662 var obj = new api.Task.fromJson(json); 679 var obj = new api.Task.fromJson(json);
663 checkTask(obj); 680 checkTask(obj);
664 681
665 var path = (req.url).path; 682 var path = (req.url).path;
666 var pathOffset = 0; 683 var pathOffset = 0;
667 var index; 684 var index;
668 var subPart; 685 var subPart;
669 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ als("/")); 686 unittest.expect(
687 path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
670 pathOffset += 1; 688 pathOffset += 1;
671 689
672 var query = (req.url).query; 690 var query = (req.url).query;
673 var queryOffset = 0; 691 var queryOffset = 0;
674 var queryMap = {}; 692 var queryMap = {};
675 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); 693 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
676 parseBool(n) { 694 parseBool(n) {
677 if (n == "true") return true; 695 if (n == "true") return true;
678 if (n == "false") return false; 696 if (n == "false") return false;
679 if (n == null) return null; 697 if (n == null) return null;
680 throw new core.ArgumentError("Invalid boolean: $n"); 698 throw new core.ArgumentError("Invalid boolean: $n");
681 } 699 }
700
682 if (query.length > 0) { 701 if (query.length > 0) {
683 for (var part in query.split("&")) { 702 for (var part in query.split("&")) {
684 var keyvalue = part.split("="); 703 var keyvalue = part.split("=");
685 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d ecodeQueryComponent(keyvalue[1])); 704 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]),
705 core.Uri.decodeQueryComponent(keyvalue[1]));
686 } 706 }
687 } 707 }
688 unittest.expect(core.int.parse(queryMap["newLeaseSeconds"].first), unitt est.equals(arg_newLeaseSeconds)); 708 unittest.expect(core.int.parse(queryMap["newLeaseSeconds"].first),
689 709 unittest.equals(arg_newLeaseSeconds));
690 710
691 var h = { 711 var h = {
692 "content-type" : "application/json; charset=utf-8", 712 "content-type": "application/json; charset=utf-8",
693 }; 713 };
694 var resp = convert.JSON.encode(buildTask()); 714 var resp = convert.JSON.encode(buildTask());
695 return new async.Future.value(stringResponse(200, h, resp)); 715 return new async.Future.value(stringResponse(200, h, resp));
696 }), true); 716 }), true);
697 res.update(arg_request, arg_project, arg_taskqueue, arg_task, arg_newLease Seconds).then(unittest.expectAsync1(((api.Task response) { 717 res
718 .update(arg_request, arg_project, arg_taskqueue, arg_task,
719 arg_newLeaseSeconds)
720 .then(unittest.expectAsync1(((api.Task response) {
698 checkTask(response); 721 checkTask(response);
699 }))); 722 })));
700 }); 723 });
701
702 }); 724 });
703
704
705 } 725 }
706
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698