OLD | NEW |
1 library googleapis_beta.pubsub.v1beta1.test; | 1 library googleapis_beta.pubsub.v1beta1.test; |
2 | 2 |
3 import "dart:core" as core; | 3 import "dart:core" as core; |
4 import "dart:collection" as collection; | 4 import "dart:collection" as collection; |
5 import "dart:async" as async; | 5 import "dart:async" as async; |
6 import "dart:convert" as convert; | 6 import "dart:convert" as convert; |
7 | 7 |
8 import 'package:http/http.dart' as http; | 8 import 'package:http/http.dart' as http; |
9 import 'package:http/testing.dart' as http_testing; | 9 import 'package:http/testing.dart' as http_testing; |
10 import 'package:unittest/unittest.dart' as unittest; | 10 import 'package:unittest/unittest.dart' as unittest; |
11 import 'package:googleapis_beta/common/common.dart' as common; | 11 import 'package:googleapis_beta/common/common.dart' as common; |
12 import 'package:googleapis_beta/src/common_internal.dart' as common_internal; | 12 import 'package:googleapis_beta/src/common_internal.dart' as common_internal; |
13 import '../common/common_internal_test.dart' as common_test; | 13 import '../common/common_internal_test.dart' as common_test; |
14 | 14 |
15 import 'package:googleapis_beta/pubsub/v1beta1.dart' as api; | 15 import 'package:googleapis_beta/pubsub/v1beta1.dart' as api; |
16 | 16 |
17 | 17 |
18 | 18 |
19 buildUnnamed1170() { | 19 buildUnnamed1201() { |
20 var o = new core.List<core.String>(); | 20 var o = new core.List<core.String>(); |
21 o.add("foo"); | 21 o.add("foo"); |
22 o.add("foo"); | 22 o.add("foo"); |
23 return o; | 23 return o; |
24 } | 24 } |
25 | 25 |
26 checkUnnamed1170(core.List<core.String> o) { | 26 checkUnnamed1201(core.List<core.String> o) { |
27 unittest.expect(o, unittest.hasLength(2)); | 27 unittest.expect(o, unittest.hasLength(2)); |
28 unittest.expect(o[0], unittest.equals('foo')); | 28 unittest.expect(o[0], unittest.equals('foo')); |
29 unittest.expect(o[1], unittest.equals('foo')); | 29 unittest.expect(o[1], unittest.equals('foo')); |
30 } | 30 } |
31 | 31 |
32 core.int buildCounterAcknowledgeRequest = 0; | 32 core.int buildCounterAcknowledgeRequest = 0; |
33 buildAcknowledgeRequest() { | 33 buildAcknowledgeRequest() { |
34 var o = new api.AcknowledgeRequest(); | 34 var o = new api.AcknowledgeRequest(); |
35 buildCounterAcknowledgeRequest++; | 35 buildCounterAcknowledgeRequest++; |
36 if (buildCounterAcknowledgeRequest < 3) { | 36 if (buildCounterAcknowledgeRequest < 3) { |
37 o.ackId = buildUnnamed1170(); | 37 o.ackId = buildUnnamed1201(); |
38 o.subscription = "foo"; | 38 o.subscription = "foo"; |
39 } | 39 } |
40 buildCounterAcknowledgeRequest--; | 40 buildCounterAcknowledgeRequest--; |
41 return o; | 41 return o; |
42 } | 42 } |
43 | 43 |
44 checkAcknowledgeRequest(api.AcknowledgeRequest o) { | 44 checkAcknowledgeRequest(api.AcknowledgeRequest o) { |
45 buildCounterAcknowledgeRequest++; | 45 buildCounterAcknowledgeRequest++; |
46 if (buildCounterAcknowledgeRequest < 3) { | 46 if (buildCounterAcknowledgeRequest < 3) { |
47 checkUnnamed1170(o.ackId); | 47 checkUnnamed1201(o.ackId); |
48 unittest.expect(o.subscription, unittest.equals('foo')); | 48 unittest.expect(o.subscription, unittest.equals('foo')); |
49 } | 49 } |
50 buildCounterAcknowledgeRequest--; | 50 buildCounterAcknowledgeRequest--; |
51 } | 51 } |
52 | 52 |
53 core.int buildCounterLabel = 0; | 53 core.int buildCounterLabel = 0; |
54 buildLabel() { | 54 buildLabel() { |
55 var o = new api.Label(); | 55 var o = new api.Label(); |
56 buildCounterLabel++; | 56 buildCounterLabel++; |
57 if (buildCounterLabel < 3) { | 57 if (buildCounterLabel < 3) { |
58 o.key = "foo"; | 58 o.key = "foo"; |
59 o.numValue = "foo"; | 59 o.numValue = "foo"; |
60 o.strValue = "foo"; | 60 o.strValue = "foo"; |
61 } | 61 } |
62 buildCounterLabel--; | 62 buildCounterLabel--; |
63 return o; | 63 return o; |
64 } | 64 } |
65 | 65 |
66 checkLabel(api.Label o) { | 66 checkLabel(api.Label o) { |
67 buildCounterLabel++; | 67 buildCounterLabel++; |
68 if (buildCounterLabel < 3) { | 68 if (buildCounterLabel < 3) { |
69 unittest.expect(o.key, unittest.equals('foo')); | 69 unittest.expect(o.key, unittest.equals('foo')); |
70 unittest.expect(o.numValue, unittest.equals('foo')); | 70 unittest.expect(o.numValue, unittest.equals('foo')); |
71 unittest.expect(o.strValue, unittest.equals('foo')); | 71 unittest.expect(o.strValue, unittest.equals('foo')); |
72 } | 72 } |
73 buildCounterLabel--; | 73 buildCounterLabel--; |
74 } | 74 } |
75 | 75 |
76 buildUnnamed1171() { | 76 buildUnnamed1202() { |
77 var o = new core.List<api.Subscription>(); | 77 var o = new core.List<api.Subscription>(); |
78 o.add(buildSubscription()); | 78 o.add(buildSubscription()); |
79 o.add(buildSubscription()); | 79 o.add(buildSubscription()); |
80 return o; | 80 return o; |
81 } | 81 } |
82 | 82 |
83 checkUnnamed1171(core.List<api.Subscription> o) { | 83 checkUnnamed1202(core.List<api.Subscription> o) { |
84 unittest.expect(o, unittest.hasLength(2)); | 84 unittest.expect(o, unittest.hasLength(2)); |
85 checkSubscription(o[0]); | 85 checkSubscription(o[0]); |
86 checkSubscription(o[1]); | 86 checkSubscription(o[1]); |
87 } | 87 } |
88 | 88 |
89 core.int buildCounterListSubscriptionsResponse = 0; | 89 core.int buildCounterListSubscriptionsResponse = 0; |
90 buildListSubscriptionsResponse() { | 90 buildListSubscriptionsResponse() { |
91 var o = new api.ListSubscriptionsResponse(); | 91 var o = new api.ListSubscriptionsResponse(); |
92 buildCounterListSubscriptionsResponse++; | 92 buildCounterListSubscriptionsResponse++; |
93 if (buildCounterListSubscriptionsResponse < 3) { | 93 if (buildCounterListSubscriptionsResponse < 3) { |
94 o.nextPageToken = "foo"; | 94 o.nextPageToken = "foo"; |
95 o.subscription = buildUnnamed1171(); | 95 o.subscription = buildUnnamed1202(); |
96 } | 96 } |
97 buildCounterListSubscriptionsResponse--; | 97 buildCounterListSubscriptionsResponse--; |
98 return o; | 98 return o; |
99 } | 99 } |
100 | 100 |
101 checkListSubscriptionsResponse(api.ListSubscriptionsResponse o) { | 101 checkListSubscriptionsResponse(api.ListSubscriptionsResponse o) { |
102 buildCounterListSubscriptionsResponse++; | 102 buildCounterListSubscriptionsResponse++; |
103 if (buildCounterListSubscriptionsResponse < 3) { | 103 if (buildCounterListSubscriptionsResponse < 3) { |
104 unittest.expect(o.nextPageToken, unittest.equals('foo')); | 104 unittest.expect(o.nextPageToken, unittest.equals('foo')); |
105 checkUnnamed1171(o.subscription); | 105 checkUnnamed1202(o.subscription); |
106 } | 106 } |
107 buildCounterListSubscriptionsResponse--; | 107 buildCounterListSubscriptionsResponse--; |
108 } | 108 } |
109 | 109 |
110 buildUnnamed1172() { | 110 buildUnnamed1203() { |
111 var o = new core.List<api.Topic>(); | 111 var o = new core.List<api.Topic>(); |
112 o.add(buildTopic()); | 112 o.add(buildTopic()); |
113 o.add(buildTopic()); | 113 o.add(buildTopic()); |
114 return o; | 114 return o; |
115 } | 115 } |
116 | 116 |
117 checkUnnamed1172(core.List<api.Topic> o) { | 117 checkUnnamed1203(core.List<api.Topic> o) { |
118 unittest.expect(o, unittest.hasLength(2)); | 118 unittest.expect(o, unittest.hasLength(2)); |
119 checkTopic(o[0]); | 119 checkTopic(o[0]); |
120 checkTopic(o[1]); | 120 checkTopic(o[1]); |
121 } | 121 } |
122 | 122 |
123 core.int buildCounterListTopicsResponse = 0; | 123 core.int buildCounterListTopicsResponse = 0; |
124 buildListTopicsResponse() { | 124 buildListTopicsResponse() { |
125 var o = new api.ListTopicsResponse(); | 125 var o = new api.ListTopicsResponse(); |
126 buildCounterListTopicsResponse++; | 126 buildCounterListTopicsResponse++; |
127 if (buildCounterListTopicsResponse < 3) { | 127 if (buildCounterListTopicsResponse < 3) { |
128 o.nextPageToken = "foo"; | 128 o.nextPageToken = "foo"; |
129 o.topic = buildUnnamed1172(); | 129 o.topic = buildUnnamed1203(); |
130 } | 130 } |
131 buildCounterListTopicsResponse--; | 131 buildCounterListTopicsResponse--; |
132 return o; | 132 return o; |
133 } | 133 } |
134 | 134 |
135 checkListTopicsResponse(api.ListTopicsResponse o) { | 135 checkListTopicsResponse(api.ListTopicsResponse o) { |
136 buildCounterListTopicsResponse++; | 136 buildCounterListTopicsResponse++; |
137 if (buildCounterListTopicsResponse < 3) { | 137 if (buildCounterListTopicsResponse < 3) { |
138 unittest.expect(o.nextPageToken, unittest.equals('foo')); | 138 unittest.expect(o.nextPageToken, unittest.equals('foo')); |
139 checkUnnamed1172(o.topic); | 139 checkUnnamed1203(o.topic); |
140 } | 140 } |
141 buildCounterListTopicsResponse--; | 141 buildCounterListTopicsResponse--; |
142 } | 142 } |
143 | 143 |
144 core.int buildCounterModifyAckDeadlineRequest = 0; | 144 core.int buildCounterModifyAckDeadlineRequest = 0; |
145 buildModifyAckDeadlineRequest() { | 145 buildModifyAckDeadlineRequest() { |
146 var o = new api.ModifyAckDeadlineRequest(); | 146 var o = new api.ModifyAckDeadlineRequest(); |
147 buildCounterModifyAckDeadlineRequest++; | 147 buildCounterModifyAckDeadlineRequest++; |
148 if (buildCounterModifyAckDeadlineRequest < 3) { | 148 if (buildCounterModifyAckDeadlineRequest < 3) { |
149 o.ackDeadlineSeconds = 42; | 149 o.ackDeadlineSeconds = 42; |
(...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
224 buildCounterPubsubEvent++; | 224 buildCounterPubsubEvent++; |
225 if (buildCounterPubsubEvent < 3) { | 225 if (buildCounterPubsubEvent < 3) { |
226 unittest.expect(o.deleted, unittest.isTrue); | 226 unittest.expect(o.deleted, unittest.isTrue); |
227 checkPubsubMessage(o.message); | 227 checkPubsubMessage(o.message); |
228 unittest.expect(o.subscription, unittest.equals('foo')); | 228 unittest.expect(o.subscription, unittest.equals('foo')); |
229 unittest.expect(o.truncated, unittest.isTrue); | 229 unittest.expect(o.truncated, unittest.isTrue); |
230 } | 230 } |
231 buildCounterPubsubEvent--; | 231 buildCounterPubsubEvent--; |
232 } | 232 } |
233 | 233 |
234 buildUnnamed1173() { | 234 buildUnnamed1204() { |
235 var o = new core.List<api.Label>(); | 235 var o = new core.List<api.Label>(); |
236 o.add(buildLabel()); | 236 o.add(buildLabel()); |
237 o.add(buildLabel()); | 237 o.add(buildLabel()); |
238 return o; | 238 return o; |
239 } | 239 } |
240 | 240 |
241 checkUnnamed1173(core.List<api.Label> o) { | 241 checkUnnamed1204(core.List<api.Label> o) { |
242 unittest.expect(o, unittest.hasLength(2)); | 242 unittest.expect(o, unittest.hasLength(2)); |
243 checkLabel(o[0]); | 243 checkLabel(o[0]); |
244 checkLabel(o[1]); | 244 checkLabel(o[1]); |
245 } | 245 } |
246 | 246 |
247 core.int buildCounterPubsubMessage = 0; | 247 core.int buildCounterPubsubMessage = 0; |
248 buildPubsubMessage() { | 248 buildPubsubMessage() { |
249 var o = new api.PubsubMessage(); | 249 var o = new api.PubsubMessage(); |
250 buildCounterPubsubMessage++; | 250 buildCounterPubsubMessage++; |
251 if (buildCounterPubsubMessage < 3) { | 251 if (buildCounterPubsubMessage < 3) { |
252 o.data = "foo"; | 252 o.data = "foo"; |
253 o.label = buildUnnamed1173(); | 253 o.label = buildUnnamed1204(); |
254 } | 254 } |
255 buildCounterPubsubMessage--; | 255 buildCounterPubsubMessage--; |
256 return o; | 256 return o; |
257 } | 257 } |
258 | 258 |
259 checkPubsubMessage(api.PubsubMessage o) { | 259 checkPubsubMessage(api.PubsubMessage o) { |
260 buildCounterPubsubMessage++; | 260 buildCounterPubsubMessage++; |
261 if (buildCounterPubsubMessage < 3) { | 261 if (buildCounterPubsubMessage < 3) { |
262 unittest.expect(o.data, unittest.equals('foo')); | 262 unittest.expect(o.data, unittest.equals('foo')); |
263 checkUnnamed1173(o.label); | 263 checkUnnamed1204(o.label); |
264 } | 264 } |
265 buildCounterPubsubMessage--; | 265 buildCounterPubsubMessage--; |
266 } | 266 } |
267 | 267 |
268 core.int buildCounterPullRequest = 0; | 268 core.int buildCounterPullRequest = 0; |
269 buildPullRequest() { | 269 buildPullRequest() { |
270 var o = new api.PullRequest(); | 270 var o = new api.PullRequest(); |
271 buildCounterPullRequest++; | 271 buildCounterPullRequest++; |
272 if (buildCounterPullRequest < 3) { | 272 if (buildCounterPullRequest < 3) { |
273 o.returnImmediately = true; | 273 o.returnImmediately = true; |
(...skipping 231 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
505 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; | 505 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; |
506 var arg_request = buildAcknowledgeRequest(); | 506 var arg_request = buildAcknowledgeRequest(); |
507 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 507 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
508 var obj = new api.AcknowledgeRequest.fromJson(json); | 508 var obj = new api.AcknowledgeRequest.fromJson(json); |
509 checkAcknowledgeRequest(obj); | 509 checkAcknowledgeRequest(obj); |
510 | 510 |
511 var path = (req.url).path; | 511 var path = (req.url).path; |
512 var pathOffset = 0; | 512 var pathOffset = 0; |
513 var index; | 513 var index; |
514 var subPart; | 514 var subPart; |
515 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 515 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
516 pathOffset += 16; | 516 pathOffset += 1; |
| 517 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 518 pathOffset += 15; |
517 unittest.expect(path.substring(pathOffset, pathOffset + 25), unittest.eq
uals("subscriptions/acknowledge")); | 519 unittest.expect(path.substring(pathOffset, pathOffset + 25), unittest.eq
uals("subscriptions/acknowledge")); |
518 pathOffset += 25; | 520 pathOffset += 25; |
519 | 521 |
520 var query = (req.url).query; | 522 var query = (req.url).query; |
521 var queryOffset = 0; | 523 var queryOffset = 0; |
522 var queryMap = {}; | 524 var queryMap = {}; |
523 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 525 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
524 parseBool(n) { | 526 parseBool(n) { |
525 if (n == "true") return true; | 527 if (n == "true") return true; |
526 if (n == "false") return false; | 528 if (n == "false") return false; |
(...skipping 23 matching lines...) Expand all Loading... |
550 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; | 552 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; |
551 var arg_request = buildSubscription(); | 553 var arg_request = buildSubscription(); |
552 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 554 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
553 var obj = new api.Subscription.fromJson(json); | 555 var obj = new api.Subscription.fromJson(json); |
554 checkSubscription(obj); | 556 checkSubscription(obj); |
555 | 557 |
556 var path = (req.url).path; | 558 var path = (req.url).path; |
557 var pathOffset = 0; | 559 var pathOffset = 0; |
558 var index; | 560 var index; |
559 var subPart; | 561 var subPart; |
560 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 562 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
561 pathOffset += 16; | 563 pathOffset += 1; |
| 564 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 565 pathOffset += 15; |
562 unittest.expect(path.substring(pathOffset, pathOffset + 13), unittest.eq
uals("subscriptions")); | 566 unittest.expect(path.substring(pathOffset, pathOffset + 13), unittest.eq
uals("subscriptions")); |
563 pathOffset += 13; | 567 pathOffset += 13; |
564 | 568 |
565 var query = (req.url).query; | 569 var query = (req.url).query; |
566 var queryOffset = 0; | 570 var queryOffset = 0; |
567 var queryMap = {}; | 571 var queryMap = {}; |
568 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 572 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
569 parseBool(n) { | 573 parseBool(n) { |
570 if (n == "true") return true; | 574 if (n == "true") return true; |
571 if (n == "false") return false; | 575 if (n == "false") return false; |
(...skipping 22 matching lines...) Expand all Loading... |
594 unittest.test("method--delete", () { | 598 unittest.test("method--delete", () { |
595 | 599 |
596 var mock = new common_test.HttpServerMock(); | 600 var mock = new common_test.HttpServerMock(); |
597 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; | 601 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; |
598 var arg_subscription = "foo"; | 602 var arg_subscription = "foo"; |
599 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 603 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
600 var path = (req.url).path; | 604 var path = (req.url).path; |
601 var pathOffset = 0; | 605 var pathOffset = 0; |
602 var index; | 606 var index; |
603 var subPart; | 607 var subPart; |
604 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 608 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
605 pathOffset += 16; | 609 pathOffset += 1; |
| 610 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 611 pathOffset += 15; |
606 unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.eq
uals("subscriptions/")); | 612 unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.eq
uals("subscriptions/")); |
607 pathOffset += 14; | 613 pathOffset += 14; |
608 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 614 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
609 | 615 |
610 var query = (req.url).query; | 616 var query = (req.url).query; |
611 var queryOffset = 0; | 617 var queryOffset = 0; |
612 var queryMap = {}; | 618 var queryMap = {}; |
613 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 619 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
614 parseBool(n) { | 620 parseBool(n) { |
615 if (n == "true") return true; | 621 if (n == "true") return true; |
(...skipping 21 matching lines...) Expand all Loading... |
637 unittest.test("method--get", () { | 643 unittest.test("method--get", () { |
638 | 644 |
639 var mock = new common_test.HttpServerMock(); | 645 var mock = new common_test.HttpServerMock(); |
640 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; | 646 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; |
641 var arg_subscription = "foo"; | 647 var arg_subscription = "foo"; |
642 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 648 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
643 var path = (req.url).path; | 649 var path = (req.url).path; |
644 var pathOffset = 0; | 650 var pathOffset = 0; |
645 var index; | 651 var index; |
646 var subPart; | 652 var subPart; |
647 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 653 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
648 pathOffset += 16; | 654 pathOffset += 1; |
| 655 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 656 pathOffset += 15; |
649 unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.eq
uals("subscriptions/")); | 657 unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.eq
uals("subscriptions/")); |
650 pathOffset += 14; | 658 pathOffset += 14; |
651 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 659 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
652 | 660 |
653 var query = (req.url).query; | 661 var query = (req.url).query; |
654 var queryOffset = 0; | 662 var queryOffset = 0; |
655 var queryMap = {}; | 663 var queryMap = {}; |
656 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 664 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
657 parseBool(n) { | 665 parseBool(n) { |
658 if (n == "true") return true; | 666 if (n == "true") return true; |
(...skipping 25 matching lines...) Expand all Loading... |
684 var mock = new common_test.HttpServerMock(); | 692 var mock = new common_test.HttpServerMock(); |
685 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; | 693 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; |
686 var arg_maxResults = 42; | 694 var arg_maxResults = 42; |
687 var arg_pageToken = "foo"; | 695 var arg_pageToken = "foo"; |
688 var arg_query = "foo"; | 696 var arg_query = "foo"; |
689 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 697 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
690 var path = (req.url).path; | 698 var path = (req.url).path; |
691 var pathOffset = 0; | 699 var pathOffset = 0; |
692 var index; | 700 var index; |
693 var subPart; | 701 var subPart; |
694 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 702 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
695 pathOffset += 16; | 703 pathOffset += 1; |
| 704 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 705 pathOffset += 15; |
696 unittest.expect(path.substring(pathOffset, pathOffset + 13), unittest.eq
uals("subscriptions")); | 706 unittest.expect(path.substring(pathOffset, pathOffset + 13), unittest.eq
uals("subscriptions")); |
697 pathOffset += 13; | 707 pathOffset += 13; |
698 | 708 |
699 var query = (req.url).query; | 709 var query = (req.url).query; |
700 var queryOffset = 0; | 710 var queryOffset = 0; |
701 var queryMap = {}; | 711 var queryMap = {}; |
702 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 712 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
703 parseBool(n) { | 713 parseBool(n) { |
704 if (n == "true") return true; | 714 if (n == "true") return true; |
705 if (n == "false") return false; | 715 if (n == "false") return false; |
(...skipping 28 matching lines...) Expand all Loading... |
734 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; | 744 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; |
735 var arg_request = buildModifyAckDeadlineRequest(); | 745 var arg_request = buildModifyAckDeadlineRequest(); |
736 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 746 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
737 var obj = new api.ModifyAckDeadlineRequest.fromJson(json); | 747 var obj = new api.ModifyAckDeadlineRequest.fromJson(json); |
738 checkModifyAckDeadlineRequest(obj); | 748 checkModifyAckDeadlineRequest(obj); |
739 | 749 |
740 var path = (req.url).path; | 750 var path = (req.url).path; |
741 var pathOffset = 0; | 751 var pathOffset = 0; |
742 var index; | 752 var index; |
743 var subPart; | 753 var subPart; |
744 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 754 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
745 pathOffset += 16; | 755 pathOffset += 1; |
| 756 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 757 pathOffset += 15; |
746 unittest.expect(path.substring(pathOffset, pathOffset + 31), unittest.eq
uals("subscriptions/modifyAckDeadline")); | 758 unittest.expect(path.substring(pathOffset, pathOffset + 31), unittest.eq
uals("subscriptions/modifyAckDeadline")); |
747 pathOffset += 31; | 759 pathOffset += 31; |
748 | 760 |
749 var query = (req.url).query; | 761 var query = (req.url).query; |
750 var queryOffset = 0; | 762 var queryOffset = 0; |
751 var queryMap = {}; | 763 var queryMap = {}; |
752 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 764 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
753 parseBool(n) { | 765 parseBool(n) { |
754 if (n == "true") return true; | 766 if (n == "true") return true; |
755 if (n == "false") return false; | 767 if (n == "false") return false; |
(...skipping 23 matching lines...) Expand all Loading... |
779 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; | 791 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; |
780 var arg_request = buildModifyPushConfigRequest(); | 792 var arg_request = buildModifyPushConfigRequest(); |
781 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 793 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
782 var obj = new api.ModifyPushConfigRequest.fromJson(json); | 794 var obj = new api.ModifyPushConfigRequest.fromJson(json); |
783 checkModifyPushConfigRequest(obj); | 795 checkModifyPushConfigRequest(obj); |
784 | 796 |
785 var path = (req.url).path; | 797 var path = (req.url).path; |
786 var pathOffset = 0; | 798 var pathOffset = 0; |
787 var index; | 799 var index; |
788 var subPart; | 800 var subPart; |
789 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 801 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
790 pathOffset += 16; | 802 pathOffset += 1; |
| 803 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 804 pathOffset += 15; |
791 unittest.expect(path.substring(pathOffset, pathOffset + 30), unittest.eq
uals("subscriptions/modifyPushConfig")); | 805 unittest.expect(path.substring(pathOffset, pathOffset + 30), unittest.eq
uals("subscriptions/modifyPushConfig")); |
792 pathOffset += 30; | 806 pathOffset += 30; |
793 | 807 |
794 var query = (req.url).query; | 808 var query = (req.url).query; |
795 var queryOffset = 0; | 809 var queryOffset = 0; |
796 var queryMap = {}; | 810 var queryMap = {}; |
797 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 811 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
798 parseBool(n) { | 812 parseBool(n) { |
799 if (n == "true") return true; | 813 if (n == "true") return true; |
800 if (n == "false") return false; | 814 if (n == "false") return false; |
(...skipping 23 matching lines...) Expand all Loading... |
824 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; | 838 api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions; |
825 var arg_request = buildPullRequest(); | 839 var arg_request = buildPullRequest(); |
826 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 840 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
827 var obj = new api.PullRequest.fromJson(json); | 841 var obj = new api.PullRequest.fromJson(json); |
828 checkPullRequest(obj); | 842 checkPullRequest(obj); |
829 | 843 |
830 var path = (req.url).path; | 844 var path = (req.url).path; |
831 var pathOffset = 0; | 845 var pathOffset = 0; |
832 var index; | 846 var index; |
833 var subPart; | 847 var subPart; |
834 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 848 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
835 pathOffset += 16; | 849 pathOffset += 1; |
| 850 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 851 pathOffset += 15; |
836 unittest.expect(path.substring(pathOffset, pathOffset + 18), unittest.eq
uals("subscriptions/pull")); | 852 unittest.expect(path.substring(pathOffset, pathOffset + 18), unittest.eq
uals("subscriptions/pull")); |
837 pathOffset += 18; | 853 pathOffset += 18; |
838 | 854 |
839 var query = (req.url).query; | 855 var query = (req.url).query; |
840 var queryOffset = 0; | 856 var queryOffset = 0; |
841 var queryMap = {}; | 857 var queryMap = {}; |
842 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 858 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
843 parseBool(n) { | 859 parseBool(n) { |
844 if (n == "true") return true; | 860 if (n == "true") return true; |
845 if (n == "false") return false; | 861 if (n == "false") return false; |
(...skipping 29 matching lines...) Expand all Loading... |
875 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; | 891 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; |
876 var arg_request = buildTopic(); | 892 var arg_request = buildTopic(); |
877 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 893 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
878 var obj = new api.Topic.fromJson(json); | 894 var obj = new api.Topic.fromJson(json); |
879 checkTopic(obj); | 895 checkTopic(obj); |
880 | 896 |
881 var path = (req.url).path; | 897 var path = (req.url).path; |
882 var pathOffset = 0; | 898 var pathOffset = 0; |
883 var index; | 899 var index; |
884 var subPart; | 900 var subPart; |
885 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 901 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
886 pathOffset += 16; | 902 pathOffset += 1; |
| 903 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 904 pathOffset += 15; |
887 unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equ
als("topics")); | 905 unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equ
als("topics")); |
888 pathOffset += 6; | 906 pathOffset += 6; |
889 | 907 |
890 var query = (req.url).query; | 908 var query = (req.url).query; |
891 var queryOffset = 0; | 909 var queryOffset = 0; |
892 var queryMap = {}; | 910 var queryMap = {}; |
893 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 911 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
894 parseBool(n) { | 912 parseBool(n) { |
895 if (n == "true") return true; | 913 if (n == "true") return true; |
896 if (n == "false") return false; | 914 if (n == "false") return false; |
(...skipping 22 matching lines...) Expand all Loading... |
919 unittest.test("method--delete", () { | 937 unittest.test("method--delete", () { |
920 | 938 |
921 var mock = new common_test.HttpServerMock(); | 939 var mock = new common_test.HttpServerMock(); |
922 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; | 940 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; |
923 var arg_topic = "foo"; | 941 var arg_topic = "foo"; |
924 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 942 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
925 var path = (req.url).path; | 943 var path = (req.url).path; |
926 var pathOffset = 0; | 944 var pathOffset = 0; |
927 var index; | 945 var index; |
928 var subPart; | 946 var subPart; |
929 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 947 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
930 pathOffset += 16; | 948 pathOffset += 1; |
| 949 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 950 pathOffset += 15; |
931 unittest.expect(path.substring(pathOffset, pathOffset + 7), unittest.equ
als("topics/")); | 951 unittest.expect(path.substring(pathOffset, pathOffset + 7), unittest.equ
als("topics/")); |
932 pathOffset += 7; | 952 pathOffset += 7; |
933 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 953 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
934 | 954 |
935 var query = (req.url).query; | 955 var query = (req.url).query; |
936 var queryOffset = 0; | 956 var queryOffset = 0; |
937 var queryMap = {}; | 957 var queryMap = {}; |
938 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 958 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
939 parseBool(n) { | 959 parseBool(n) { |
940 if (n == "true") return true; | 960 if (n == "true") return true; |
(...skipping 21 matching lines...) Expand all Loading... |
962 unittest.test("method--get", () { | 982 unittest.test("method--get", () { |
963 | 983 |
964 var mock = new common_test.HttpServerMock(); | 984 var mock = new common_test.HttpServerMock(); |
965 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; | 985 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; |
966 var arg_topic = "foo"; | 986 var arg_topic = "foo"; |
967 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 987 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
968 var path = (req.url).path; | 988 var path = (req.url).path; |
969 var pathOffset = 0; | 989 var pathOffset = 0; |
970 var index; | 990 var index; |
971 var subPart; | 991 var subPart; |
972 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 992 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
973 pathOffset += 16; | 993 pathOffset += 1; |
| 994 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 995 pathOffset += 15; |
974 unittest.expect(path.substring(pathOffset, pathOffset + 7), unittest.equ
als("topics/")); | 996 unittest.expect(path.substring(pathOffset, pathOffset + 7), unittest.equ
als("topics/")); |
975 pathOffset += 7; | 997 pathOffset += 7; |
976 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 998 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
977 | 999 |
978 var query = (req.url).query; | 1000 var query = (req.url).query; |
979 var queryOffset = 0; | 1001 var queryOffset = 0; |
980 var queryMap = {}; | 1002 var queryMap = {}; |
981 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1003 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
982 parseBool(n) { | 1004 parseBool(n) { |
983 if (n == "true") return true; | 1005 if (n == "true") return true; |
(...skipping 25 matching lines...) Expand all Loading... |
1009 var mock = new common_test.HttpServerMock(); | 1031 var mock = new common_test.HttpServerMock(); |
1010 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; | 1032 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; |
1011 var arg_maxResults = 42; | 1033 var arg_maxResults = 42; |
1012 var arg_pageToken = "foo"; | 1034 var arg_pageToken = "foo"; |
1013 var arg_query = "foo"; | 1035 var arg_query = "foo"; |
1014 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 1036 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
1015 var path = (req.url).path; | 1037 var path = (req.url).path; |
1016 var pathOffset = 0; | 1038 var pathOffset = 0; |
1017 var index; | 1039 var index; |
1018 var subPart; | 1040 var subPart; |
1019 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 1041 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
1020 pathOffset += 16; | 1042 pathOffset += 1; |
| 1043 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 1044 pathOffset += 15; |
1021 unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equ
als("topics")); | 1045 unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equ
als("topics")); |
1022 pathOffset += 6; | 1046 pathOffset += 6; |
1023 | 1047 |
1024 var query = (req.url).query; | 1048 var query = (req.url).query; |
1025 var queryOffset = 0; | 1049 var queryOffset = 0; |
1026 var queryMap = {}; | 1050 var queryMap = {}; |
1027 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1051 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1028 parseBool(n) { | 1052 parseBool(n) { |
1029 if (n == "true") return true; | 1053 if (n == "true") return true; |
1030 if (n == "false") return false; | 1054 if (n == "false") return false; |
(...skipping 28 matching lines...) Expand all Loading... |
1059 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; | 1083 api.TopicsResourceApi res = new api.PubsubApi(mock).topics; |
1060 var arg_request = buildPublishRequest(); | 1084 var arg_request = buildPublishRequest(); |
1061 mock.register(unittest.expectAsync((http.BaseRequest req, json) { | 1085 mock.register(unittest.expectAsync((http.BaseRequest req, json) { |
1062 var obj = new api.PublishRequest.fromJson(json); | 1086 var obj = new api.PublishRequest.fromJson(json); |
1063 checkPublishRequest(obj); | 1087 checkPublishRequest(obj); |
1064 | 1088 |
1065 var path = (req.url).path; | 1089 var path = (req.url).path; |
1066 var pathOffset = 0; | 1090 var pathOffset = 0; |
1067 var index; | 1091 var index; |
1068 var subPart; | 1092 var subPart; |
1069 unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.eq
uals("/pubsub/v1beta1/")); | 1093 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); |
1070 pathOffset += 16; | 1094 pathOffset += 1; |
| 1095 unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.eq
uals("pubsub/v1beta1/")); |
| 1096 pathOffset += 15; |
1071 unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.eq
uals("topics/publish")); | 1097 unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.eq
uals("topics/publish")); |
1072 pathOffset += 14; | 1098 pathOffset += 14; |
1073 | 1099 |
1074 var query = (req.url).query; | 1100 var query = (req.url).query; |
1075 var queryOffset = 0; | 1101 var queryOffset = 0; |
1076 var queryMap = {}; | 1102 var queryMap = {}; |
1077 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1103 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1078 parseBool(n) { | 1104 parseBool(n) { |
1079 if (n == "true") return true; | 1105 if (n == "true") return true; |
1080 if (n == "false") return false; | 1106 if (n == "false") return false; |
(...skipping 15 matching lines...) Expand all Loading... |
1096 return new async.Future.value(common_test.stringResponse(200, h, resp)); | 1122 return new async.Future.value(common_test.stringResponse(200, h, resp)); |
1097 }), true); | 1123 }), true); |
1098 res.publish(arg_request).then(unittest.expectAsync((_) {})); | 1124 res.publish(arg_request).then(unittest.expectAsync((_) {})); |
1099 }); | 1125 }); |
1100 | 1126 |
1101 }); | 1127 }); |
1102 | 1128 |
1103 | 1129 |
1104 } | 1130 } |
1105 | 1131 |
OLD | NEW |