OLD | NEW |
1 library googleapis_beta.pubsub.v1beta2.test; | 1 library googleapis_beta.pubsub.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/pubsub/v1beta2.dart' as api; | 10 import 'package:googleapis_beta/pubsub/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 buildUnnamed3340() { | 53 buildUnnamed3333() { |
55 var o = new core.List<core.String>(); | 54 var o = new core.List<core.String>(); |
56 o.add("foo"); | 55 o.add("foo"); |
57 o.add("foo"); | 56 o.add("foo"); |
58 return o; | 57 return o; |
59 } | 58 } |
60 | 59 |
61 checkUnnamed3340(core.List<core.String> o) { | 60 checkUnnamed3333(core.List<core.String> o) { |
62 unittest.expect(o, unittest.hasLength(2)); | 61 unittest.expect(o, unittest.hasLength(2)); |
63 unittest.expect(o[0], unittest.equals('foo')); | 62 unittest.expect(o[0], unittest.equals('foo')); |
64 unittest.expect(o[1], unittest.equals('foo')); | 63 unittest.expect(o[1], unittest.equals('foo')); |
65 } | 64 } |
66 | 65 |
67 core.int buildCounterAcknowledgeRequest = 0; | 66 core.int buildCounterAcknowledgeRequest = 0; |
68 buildAcknowledgeRequest() { | 67 buildAcknowledgeRequest() { |
69 var o = new api.AcknowledgeRequest(); | 68 var o = new api.AcknowledgeRequest(); |
70 buildCounterAcknowledgeRequest++; | 69 buildCounterAcknowledgeRequest++; |
71 if (buildCounterAcknowledgeRequest < 3) { | 70 if (buildCounterAcknowledgeRequest < 3) { |
72 o.ackIds = buildUnnamed3340(); | 71 o.ackIds = buildUnnamed3333(); |
73 } | 72 } |
74 buildCounterAcknowledgeRequest--; | 73 buildCounterAcknowledgeRequest--; |
75 return o; | 74 return o; |
76 } | 75 } |
77 | 76 |
78 checkAcknowledgeRequest(api.AcknowledgeRequest o) { | 77 checkAcknowledgeRequest(api.AcknowledgeRequest o) { |
79 buildCounterAcknowledgeRequest++; | 78 buildCounterAcknowledgeRequest++; |
80 if (buildCounterAcknowledgeRequest < 3) { | 79 if (buildCounterAcknowledgeRequest < 3) { |
81 checkUnnamed3340(o.ackIds); | 80 checkUnnamed3333(o.ackIds); |
82 } | 81 } |
83 buildCounterAcknowledgeRequest--; | 82 buildCounterAcknowledgeRequest--; |
84 } | 83 } |
85 | 84 |
86 buildUnnamed3341() { | 85 buildUnnamed3334() { |
87 var o = new core.List<core.String>(); | 86 var o = new core.List<core.String>(); |
88 o.add("foo"); | 87 o.add("foo"); |
89 o.add("foo"); | 88 o.add("foo"); |
90 return o; | 89 return o; |
91 } | 90 } |
92 | 91 |
93 checkUnnamed3341(core.List<core.String> o) { | 92 checkUnnamed3334(core.List<core.String> o) { |
94 unittest.expect(o, unittest.hasLength(2)); | 93 unittest.expect(o, unittest.hasLength(2)); |
95 unittest.expect(o[0], unittest.equals('foo')); | 94 unittest.expect(o[0], unittest.equals('foo')); |
96 unittest.expect(o[1], unittest.equals('foo')); | 95 unittest.expect(o[1], unittest.equals('foo')); |
97 } | 96 } |
98 | 97 |
99 core.int buildCounterBinding = 0; | 98 core.int buildCounterBinding = 0; |
100 buildBinding() { | 99 buildBinding() { |
101 var o = new api.Binding(); | 100 var o = new api.Binding(); |
102 buildCounterBinding++; | 101 buildCounterBinding++; |
103 if (buildCounterBinding < 3) { | 102 if (buildCounterBinding < 3) { |
104 o.members = buildUnnamed3341(); | 103 o.members = buildUnnamed3334(); |
105 o.role = "foo"; | 104 o.role = "foo"; |
106 } | 105 } |
107 buildCounterBinding--; | 106 buildCounterBinding--; |
108 return o; | 107 return o; |
109 } | 108 } |
110 | 109 |
111 checkBinding(api.Binding o) { | 110 checkBinding(api.Binding o) { |
112 buildCounterBinding++; | 111 buildCounterBinding++; |
113 if (buildCounterBinding < 3) { | 112 if (buildCounterBinding < 3) { |
114 checkUnnamed3341(o.members); | 113 checkUnnamed3334(o.members); |
115 unittest.expect(o.role, unittest.equals('foo')); | 114 unittest.expect(o.role, unittest.equals('foo')); |
116 } | 115 } |
117 buildCounterBinding--; | 116 buildCounterBinding--; |
118 } | 117 } |
119 | 118 |
120 core.int buildCounterEmpty = 0; | 119 core.int buildCounterEmpty = 0; |
121 buildEmpty() { | 120 buildEmpty() { |
122 var o = new api.Empty(); | 121 var o = new api.Empty(); |
123 buildCounterEmpty++; | 122 buildCounterEmpty++; |
124 if (buildCounterEmpty < 3) { | 123 if (buildCounterEmpty < 3) {} |
125 } | |
126 buildCounterEmpty--; | 124 buildCounterEmpty--; |
127 return o; | 125 return o; |
128 } | 126 } |
129 | 127 |
130 checkEmpty(api.Empty o) { | 128 checkEmpty(api.Empty o) { |
131 buildCounterEmpty++; | 129 buildCounterEmpty++; |
132 if (buildCounterEmpty < 3) { | 130 if (buildCounterEmpty < 3) {} |
133 } | |
134 buildCounterEmpty--; | 131 buildCounterEmpty--; |
135 } | 132 } |
136 | 133 |
137 buildUnnamed3342() { | 134 buildUnnamed3335() { |
138 var o = new core.List<api.Subscription>(); | 135 var o = new core.List<api.Subscription>(); |
139 o.add(buildSubscription()); | 136 o.add(buildSubscription()); |
140 o.add(buildSubscription()); | 137 o.add(buildSubscription()); |
141 return o; | 138 return o; |
142 } | 139 } |
143 | 140 |
144 checkUnnamed3342(core.List<api.Subscription> o) { | 141 checkUnnamed3335(core.List<api.Subscription> o) { |
145 unittest.expect(o, unittest.hasLength(2)); | 142 unittest.expect(o, unittest.hasLength(2)); |
146 checkSubscription(o[0]); | 143 checkSubscription(o[0]); |
147 checkSubscription(o[1]); | 144 checkSubscription(o[1]); |
148 } | 145 } |
149 | 146 |
150 core.int buildCounterListSubscriptionsResponse = 0; | 147 core.int buildCounterListSubscriptionsResponse = 0; |
151 buildListSubscriptionsResponse() { | 148 buildListSubscriptionsResponse() { |
152 var o = new api.ListSubscriptionsResponse(); | 149 var o = new api.ListSubscriptionsResponse(); |
153 buildCounterListSubscriptionsResponse++; | 150 buildCounterListSubscriptionsResponse++; |
154 if (buildCounterListSubscriptionsResponse < 3) { | 151 if (buildCounterListSubscriptionsResponse < 3) { |
155 o.nextPageToken = "foo"; | 152 o.nextPageToken = "foo"; |
156 o.subscriptions = buildUnnamed3342(); | 153 o.subscriptions = buildUnnamed3335(); |
157 } | 154 } |
158 buildCounterListSubscriptionsResponse--; | 155 buildCounterListSubscriptionsResponse--; |
159 return o; | 156 return o; |
160 } | 157 } |
161 | 158 |
162 checkListSubscriptionsResponse(api.ListSubscriptionsResponse o) { | 159 checkListSubscriptionsResponse(api.ListSubscriptionsResponse o) { |
163 buildCounterListSubscriptionsResponse++; | 160 buildCounterListSubscriptionsResponse++; |
164 if (buildCounterListSubscriptionsResponse < 3) { | 161 if (buildCounterListSubscriptionsResponse < 3) { |
165 unittest.expect(o.nextPageToken, unittest.equals('foo')); | 162 unittest.expect(o.nextPageToken, unittest.equals('foo')); |
166 checkUnnamed3342(o.subscriptions); | 163 checkUnnamed3335(o.subscriptions); |
167 } | 164 } |
168 buildCounterListSubscriptionsResponse--; | 165 buildCounterListSubscriptionsResponse--; |
169 } | 166 } |
170 | 167 |
171 buildUnnamed3343() { | 168 buildUnnamed3336() { |
172 var o = new core.List<core.String>(); | 169 var o = new core.List<core.String>(); |
173 o.add("foo"); | 170 o.add("foo"); |
174 o.add("foo"); | 171 o.add("foo"); |
175 return o; | 172 return o; |
176 } | 173 } |
177 | 174 |
178 checkUnnamed3343(core.List<core.String> o) { | 175 checkUnnamed3336(core.List<core.String> o) { |
179 unittest.expect(o, unittest.hasLength(2)); | 176 unittest.expect(o, unittest.hasLength(2)); |
180 unittest.expect(o[0], unittest.equals('foo')); | 177 unittest.expect(o[0], unittest.equals('foo')); |
181 unittest.expect(o[1], unittest.equals('foo')); | 178 unittest.expect(o[1], unittest.equals('foo')); |
182 } | 179 } |
183 | 180 |
184 core.int buildCounterListTopicSubscriptionsResponse = 0; | 181 core.int buildCounterListTopicSubscriptionsResponse = 0; |
185 buildListTopicSubscriptionsResponse() { | 182 buildListTopicSubscriptionsResponse() { |
186 var o = new api.ListTopicSubscriptionsResponse(); | 183 var o = new api.ListTopicSubscriptionsResponse(); |
187 buildCounterListTopicSubscriptionsResponse++; | 184 buildCounterListTopicSubscriptionsResponse++; |
188 if (buildCounterListTopicSubscriptionsResponse < 3) { | 185 if (buildCounterListTopicSubscriptionsResponse < 3) { |
189 o.nextPageToken = "foo"; | 186 o.nextPageToken = "foo"; |
190 o.subscriptions = buildUnnamed3343(); | 187 o.subscriptions = buildUnnamed3336(); |
191 } | 188 } |
192 buildCounterListTopicSubscriptionsResponse--; | 189 buildCounterListTopicSubscriptionsResponse--; |
193 return o; | 190 return o; |
194 } | 191 } |
195 | 192 |
196 checkListTopicSubscriptionsResponse(api.ListTopicSubscriptionsResponse o) { | 193 checkListTopicSubscriptionsResponse(api.ListTopicSubscriptionsResponse o) { |
197 buildCounterListTopicSubscriptionsResponse++; | 194 buildCounterListTopicSubscriptionsResponse++; |
198 if (buildCounterListTopicSubscriptionsResponse < 3) { | 195 if (buildCounterListTopicSubscriptionsResponse < 3) { |
199 unittest.expect(o.nextPageToken, unittest.equals('foo')); | 196 unittest.expect(o.nextPageToken, unittest.equals('foo')); |
200 checkUnnamed3343(o.subscriptions); | 197 checkUnnamed3336(o.subscriptions); |
201 } | 198 } |
202 buildCounterListTopicSubscriptionsResponse--; | 199 buildCounterListTopicSubscriptionsResponse--; |
203 } | 200 } |
204 | 201 |
205 buildUnnamed3344() { | 202 buildUnnamed3337() { |
206 var o = new core.List<api.Topic>(); | 203 var o = new core.List<api.Topic>(); |
207 o.add(buildTopic()); | 204 o.add(buildTopic()); |
208 o.add(buildTopic()); | 205 o.add(buildTopic()); |
209 return o; | 206 return o; |
210 } | 207 } |
211 | 208 |
212 checkUnnamed3344(core.List<api.Topic> o) { | 209 checkUnnamed3337(core.List<api.Topic> o) { |
213 unittest.expect(o, unittest.hasLength(2)); | 210 unittest.expect(o, unittest.hasLength(2)); |
214 checkTopic(o[0]); | 211 checkTopic(o[0]); |
215 checkTopic(o[1]); | 212 checkTopic(o[1]); |
216 } | 213 } |
217 | 214 |
218 core.int buildCounterListTopicsResponse = 0; | 215 core.int buildCounterListTopicsResponse = 0; |
219 buildListTopicsResponse() { | 216 buildListTopicsResponse() { |
220 var o = new api.ListTopicsResponse(); | 217 var o = new api.ListTopicsResponse(); |
221 buildCounterListTopicsResponse++; | 218 buildCounterListTopicsResponse++; |
222 if (buildCounterListTopicsResponse < 3) { | 219 if (buildCounterListTopicsResponse < 3) { |
223 o.nextPageToken = "foo"; | 220 o.nextPageToken = "foo"; |
224 o.topics = buildUnnamed3344(); | 221 o.topics = buildUnnamed3337(); |
225 } | 222 } |
226 buildCounterListTopicsResponse--; | 223 buildCounterListTopicsResponse--; |
227 return o; | 224 return o; |
228 } | 225 } |
229 | 226 |
230 checkListTopicsResponse(api.ListTopicsResponse o) { | 227 checkListTopicsResponse(api.ListTopicsResponse o) { |
231 buildCounterListTopicsResponse++; | 228 buildCounterListTopicsResponse++; |
232 if (buildCounterListTopicsResponse < 3) { | 229 if (buildCounterListTopicsResponse < 3) { |
233 unittest.expect(o.nextPageToken, unittest.equals('foo')); | 230 unittest.expect(o.nextPageToken, unittest.equals('foo')); |
234 checkUnnamed3344(o.topics); | 231 checkUnnamed3337(o.topics); |
235 } | 232 } |
236 buildCounterListTopicsResponse--; | 233 buildCounterListTopicsResponse--; |
237 } | 234 } |
238 | 235 |
239 buildUnnamed3345() { | 236 buildUnnamed3338() { |
240 var o = new core.List<core.String>(); | 237 var o = new core.List<core.String>(); |
241 o.add("foo"); | 238 o.add("foo"); |
242 o.add("foo"); | 239 o.add("foo"); |
243 return o; | 240 return o; |
244 } | 241 } |
245 | 242 |
246 checkUnnamed3345(core.List<core.String> o) { | 243 checkUnnamed3338(core.List<core.String> o) { |
247 unittest.expect(o, unittest.hasLength(2)); | 244 unittest.expect(o, unittest.hasLength(2)); |
248 unittest.expect(o[0], unittest.equals('foo')); | 245 unittest.expect(o[0], unittest.equals('foo')); |
249 unittest.expect(o[1], unittest.equals('foo')); | 246 unittest.expect(o[1], unittest.equals('foo')); |
250 } | 247 } |
251 | 248 |
252 core.int buildCounterModifyAckDeadlineRequest = 0; | 249 core.int buildCounterModifyAckDeadlineRequest = 0; |
253 buildModifyAckDeadlineRequest() { | 250 buildModifyAckDeadlineRequest() { |
254 var o = new api.ModifyAckDeadlineRequest(); | 251 var o = new api.ModifyAckDeadlineRequest(); |
255 buildCounterModifyAckDeadlineRequest++; | 252 buildCounterModifyAckDeadlineRequest++; |
256 if (buildCounterModifyAckDeadlineRequest < 3) { | 253 if (buildCounterModifyAckDeadlineRequest < 3) { |
257 o.ackDeadlineSeconds = 42; | 254 o.ackDeadlineSeconds = 42; |
258 o.ackId = "foo"; | 255 o.ackId = "foo"; |
259 o.ackIds = buildUnnamed3345(); | 256 o.ackIds = buildUnnamed3338(); |
260 } | 257 } |
261 buildCounterModifyAckDeadlineRequest--; | 258 buildCounterModifyAckDeadlineRequest--; |
262 return o; | 259 return o; |
263 } | 260 } |
264 | 261 |
265 checkModifyAckDeadlineRequest(api.ModifyAckDeadlineRequest o) { | 262 checkModifyAckDeadlineRequest(api.ModifyAckDeadlineRequest o) { |
266 buildCounterModifyAckDeadlineRequest++; | 263 buildCounterModifyAckDeadlineRequest++; |
267 if (buildCounterModifyAckDeadlineRequest < 3) { | 264 if (buildCounterModifyAckDeadlineRequest < 3) { |
268 unittest.expect(o.ackDeadlineSeconds, unittest.equals(42)); | 265 unittest.expect(o.ackDeadlineSeconds, unittest.equals(42)); |
269 unittest.expect(o.ackId, unittest.equals('foo')); | 266 unittest.expect(o.ackId, unittest.equals('foo')); |
270 checkUnnamed3345(o.ackIds); | 267 checkUnnamed3338(o.ackIds); |
271 } | 268 } |
272 buildCounterModifyAckDeadlineRequest--; | 269 buildCounterModifyAckDeadlineRequest--; |
273 } | 270 } |
274 | 271 |
275 core.int buildCounterModifyPushConfigRequest = 0; | 272 core.int buildCounterModifyPushConfigRequest = 0; |
276 buildModifyPushConfigRequest() { | 273 buildModifyPushConfigRequest() { |
277 var o = new api.ModifyPushConfigRequest(); | 274 var o = new api.ModifyPushConfigRequest(); |
278 buildCounterModifyPushConfigRequest++; | 275 buildCounterModifyPushConfigRequest++; |
279 if (buildCounterModifyPushConfigRequest < 3) { | 276 if (buildCounterModifyPushConfigRequest < 3) { |
280 o.pushConfig = buildPushConfig(); | 277 o.pushConfig = buildPushConfig(); |
281 } | 278 } |
282 buildCounterModifyPushConfigRequest--; | 279 buildCounterModifyPushConfigRequest--; |
283 return o; | 280 return o; |
284 } | 281 } |
285 | 282 |
286 checkModifyPushConfigRequest(api.ModifyPushConfigRequest o) { | 283 checkModifyPushConfigRequest(api.ModifyPushConfigRequest o) { |
287 buildCounterModifyPushConfigRequest++; | 284 buildCounterModifyPushConfigRequest++; |
288 if (buildCounterModifyPushConfigRequest < 3) { | 285 if (buildCounterModifyPushConfigRequest < 3) { |
289 checkPushConfig(o.pushConfig); | 286 checkPushConfig(o.pushConfig); |
290 } | 287 } |
291 buildCounterModifyPushConfigRequest--; | 288 buildCounterModifyPushConfigRequest--; |
292 } | 289 } |
293 | 290 |
294 buildUnnamed3346() { | 291 buildUnnamed3339() { |
295 var o = new core.List<api.Binding>(); | 292 var o = new core.List<api.Binding>(); |
296 o.add(buildBinding()); | 293 o.add(buildBinding()); |
297 o.add(buildBinding()); | 294 o.add(buildBinding()); |
298 return o; | 295 return o; |
299 } | 296 } |
300 | 297 |
301 checkUnnamed3346(core.List<api.Binding> o) { | 298 checkUnnamed3339(core.List<api.Binding> o) { |
302 unittest.expect(o, unittest.hasLength(2)); | 299 unittest.expect(o, unittest.hasLength(2)); |
303 checkBinding(o[0]); | 300 checkBinding(o[0]); |
304 checkBinding(o[1]); | 301 checkBinding(o[1]); |
305 } | 302 } |
306 | 303 |
307 core.int buildCounterPolicy = 0; | 304 core.int buildCounterPolicy = 0; |
308 buildPolicy() { | 305 buildPolicy() { |
309 var o = new api.Policy(); | 306 var o = new api.Policy(); |
310 buildCounterPolicy++; | 307 buildCounterPolicy++; |
311 if (buildCounterPolicy < 3) { | 308 if (buildCounterPolicy < 3) { |
312 o.bindings = buildUnnamed3346(); | 309 o.bindings = buildUnnamed3339(); |
313 o.etag = "foo"; | 310 o.etag = "foo"; |
314 o.version = 42; | 311 o.version = 42; |
315 } | 312 } |
316 buildCounterPolicy--; | 313 buildCounterPolicy--; |
317 return o; | 314 return o; |
318 } | 315 } |
319 | 316 |
320 checkPolicy(api.Policy o) { | 317 checkPolicy(api.Policy o) { |
321 buildCounterPolicy++; | 318 buildCounterPolicy++; |
322 if (buildCounterPolicy < 3) { | 319 if (buildCounterPolicy < 3) { |
323 checkUnnamed3346(o.bindings); | 320 checkUnnamed3339(o.bindings); |
324 unittest.expect(o.etag, unittest.equals('foo')); | 321 unittest.expect(o.etag, unittest.equals('foo')); |
325 unittest.expect(o.version, unittest.equals(42)); | 322 unittest.expect(o.version, unittest.equals(42)); |
326 } | 323 } |
327 buildCounterPolicy--; | 324 buildCounterPolicy--; |
328 } | 325 } |
329 | 326 |
330 buildUnnamed3347() { | 327 buildUnnamed3340() { |
331 var o = new core.List<api.PubsubMessage>(); | 328 var o = new core.List<api.PubsubMessage>(); |
332 o.add(buildPubsubMessage()); | 329 o.add(buildPubsubMessage()); |
333 o.add(buildPubsubMessage()); | 330 o.add(buildPubsubMessage()); |
334 return o; | 331 return o; |
335 } | 332 } |
336 | 333 |
337 checkUnnamed3347(core.List<api.PubsubMessage> o) { | 334 checkUnnamed3340(core.List<api.PubsubMessage> o) { |
338 unittest.expect(o, unittest.hasLength(2)); | 335 unittest.expect(o, unittest.hasLength(2)); |
339 checkPubsubMessage(o[0]); | 336 checkPubsubMessage(o[0]); |
340 checkPubsubMessage(o[1]); | 337 checkPubsubMessage(o[1]); |
341 } | 338 } |
342 | 339 |
343 core.int buildCounterPublishRequest = 0; | 340 core.int buildCounterPublishRequest = 0; |
344 buildPublishRequest() { | 341 buildPublishRequest() { |
345 var o = new api.PublishRequest(); | 342 var o = new api.PublishRequest(); |
346 buildCounterPublishRequest++; | 343 buildCounterPublishRequest++; |
347 if (buildCounterPublishRequest < 3) { | 344 if (buildCounterPublishRequest < 3) { |
348 o.messages = buildUnnamed3347(); | 345 o.messages = buildUnnamed3340(); |
349 } | 346 } |
350 buildCounterPublishRequest--; | 347 buildCounterPublishRequest--; |
351 return o; | 348 return o; |
352 } | 349 } |
353 | 350 |
354 checkPublishRequest(api.PublishRequest o) { | 351 checkPublishRequest(api.PublishRequest o) { |
355 buildCounterPublishRequest++; | 352 buildCounterPublishRequest++; |
356 if (buildCounterPublishRequest < 3) { | 353 if (buildCounterPublishRequest < 3) { |
357 checkUnnamed3347(o.messages); | 354 checkUnnamed3340(o.messages); |
358 } | 355 } |
359 buildCounterPublishRequest--; | 356 buildCounterPublishRequest--; |
360 } | 357 } |
361 | 358 |
362 buildUnnamed3348() { | 359 buildUnnamed3341() { |
363 var o = new core.List<core.String>(); | 360 var o = new core.List<core.String>(); |
364 o.add("foo"); | 361 o.add("foo"); |
365 o.add("foo"); | 362 o.add("foo"); |
366 return o; | 363 return o; |
367 } | 364 } |
368 | 365 |
369 checkUnnamed3348(core.List<core.String> o) { | 366 checkUnnamed3341(core.List<core.String> o) { |
370 unittest.expect(o, unittest.hasLength(2)); | 367 unittest.expect(o, unittest.hasLength(2)); |
371 unittest.expect(o[0], unittest.equals('foo')); | 368 unittest.expect(o[0], unittest.equals('foo')); |
372 unittest.expect(o[1], unittest.equals('foo')); | 369 unittest.expect(o[1], unittest.equals('foo')); |
373 } | 370 } |
374 | 371 |
375 core.int buildCounterPublishResponse = 0; | 372 core.int buildCounterPublishResponse = 0; |
376 buildPublishResponse() { | 373 buildPublishResponse() { |
377 var o = new api.PublishResponse(); | 374 var o = new api.PublishResponse(); |
378 buildCounterPublishResponse++; | 375 buildCounterPublishResponse++; |
379 if (buildCounterPublishResponse < 3) { | 376 if (buildCounterPublishResponse < 3) { |
380 o.messageIds = buildUnnamed3348(); | 377 o.messageIds = buildUnnamed3341(); |
381 } | 378 } |
382 buildCounterPublishResponse--; | 379 buildCounterPublishResponse--; |
383 return o; | 380 return o; |
384 } | 381 } |
385 | 382 |
386 checkPublishResponse(api.PublishResponse o) { | 383 checkPublishResponse(api.PublishResponse o) { |
387 buildCounterPublishResponse++; | 384 buildCounterPublishResponse++; |
388 if (buildCounterPublishResponse < 3) { | 385 if (buildCounterPublishResponse < 3) { |
389 checkUnnamed3348(o.messageIds); | 386 checkUnnamed3341(o.messageIds); |
390 } | 387 } |
391 buildCounterPublishResponse--; | 388 buildCounterPublishResponse--; |
392 } | 389 } |
393 | 390 |
394 buildUnnamed3349() { | 391 buildUnnamed3342() { |
395 var o = new core.Map<core.String, core.String>(); | 392 var o = new core.Map<core.String, core.String>(); |
396 o["x"] = "foo"; | 393 o["x"] = "foo"; |
397 o["y"] = "foo"; | 394 o["y"] = "foo"; |
398 return o; | 395 return o; |
399 } | 396 } |
400 | 397 |
401 checkUnnamed3349(core.Map<core.String, core.String> o) { | 398 checkUnnamed3342(core.Map<core.String, core.String> o) { |
402 unittest.expect(o, unittest.hasLength(2)); | 399 unittest.expect(o, unittest.hasLength(2)); |
403 unittest.expect(o["x"], unittest.equals('foo')); | 400 unittest.expect(o["x"], unittest.equals('foo')); |
404 unittest.expect(o["y"], unittest.equals('foo')); | 401 unittest.expect(o["y"], unittest.equals('foo')); |
405 } | 402 } |
406 | 403 |
407 core.int buildCounterPubsubMessage = 0; | 404 core.int buildCounterPubsubMessage = 0; |
408 buildPubsubMessage() { | 405 buildPubsubMessage() { |
409 var o = new api.PubsubMessage(); | 406 var o = new api.PubsubMessage(); |
410 buildCounterPubsubMessage++; | 407 buildCounterPubsubMessage++; |
411 if (buildCounterPubsubMessage < 3) { | 408 if (buildCounterPubsubMessage < 3) { |
412 o.attributes = buildUnnamed3349(); | 409 o.attributes = buildUnnamed3342(); |
413 o.data = "foo"; | 410 o.data = "foo"; |
414 o.messageId = "foo"; | 411 o.messageId = "foo"; |
415 o.publishTime = "foo"; | 412 o.publishTime = "foo"; |
416 } | 413 } |
417 buildCounterPubsubMessage--; | 414 buildCounterPubsubMessage--; |
418 return o; | 415 return o; |
419 } | 416 } |
420 | 417 |
421 checkPubsubMessage(api.PubsubMessage o) { | 418 checkPubsubMessage(api.PubsubMessage o) { |
422 buildCounterPubsubMessage++; | 419 buildCounterPubsubMessage++; |
423 if (buildCounterPubsubMessage < 3) { | 420 if (buildCounterPubsubMessage < 3) { |
424 checkUnnamed3349(o.attributes); | 421 checkUnnamed3342(o.attributes); |
425 unittest.expect(o.data, unittest.equals('foo')); | 422 unittest.expect(o.data, unittest.equals('foo')); |
426 unittest.expect(o.messageId, unittest.equals('foo')); | 423 unittest.expect(o.messageId, unittest.equals('foo')); |
427 unittest.expect(o.publishTime, unittest.equals('foo')); | 424 unittest.expect(o.publishTime, unittest.equals('foo')); |
428 } | 425 } |
429 buildCounterPubsubMessage--; | 426 buildCounterPubsubMessage--; |
430 } | 427 } |
431 | 428 |
432 core.int buildCounterPullRequest = 0; | 429 core.int buildCounterPullRequest = 0; |
433 buildPullRequest() { | 430 buildPullRequest() { |
434 var o = new api.PullRequest(); | 431 var o = new api.PullRequest(); |
435 buildCounterPullRequest++; | 432 buildCounterPullRequest++; |
436 if (buildCounterPullRequest < 3) { | 433 if (buildCounterPullRequest < 3) { |
437 o.maxMessages = 42; | 434 o.maxMessages = 42; |
438 o.returnImmediately = true; | 435 o.returnImmediately = true; |
439 } | 436 } |
440 buildCounterPullRequest--; | 437 buildCounterPullRequest--; |
441 return o; | 438 return o; |
442 } | 439 } |
443 | 440 |
444 checkPullRequest(api.PullRequest o) { | 441 checkPullRequest(api.PullRequest o) { |
445 buildCounterPullRequest++; | 442 buildCounterPullRequest++; |
446 if (buildCounterPullRequest < 3) { | 443 if (buildCounterPullRequest < 3) { |
447 unittest.expect(o.maxMessages, unittest.equals(42)); | 444 unittest.expect(o.maxMessages, unittest.equals(42)); |
448 unittest.expect(o.returnImmediately, unittest.isTrue); | 445 unittest.expect(o.returnImmediately, unittest.isTrue); |
449 } | 446 } |
450 buildCounterPullRequest--; | 447 buildCounterPullRequest--; |
451 } | 448 } |
452 | 449 |
453 buildUnnamed3350() { | 450 buildUnnamed3343() { |
454 var o = new core.List<api.ReceivedMessage>(); | 451 var o = new core.List<api.ReceivedMessage>(); |
455 o.add(buildReceivedMessage()); | 452 o.add(buildReceivedMessage()); |
456 o.add(buildReceivedMessage()); | 453 o.add(buildReceivedMessage()); |
457 return o; | 454 return o; |
458 } | 455 } |
459 | 456 |
460 checkUnnamed3350(core.List<api.ReceivedMessage> o) { | 457 checkUnnamed3343(core.List<api.ReceivedMessage> o) { |
461 unittest.expect(o, unittest.hasLength(2)); | 458 unittest.expect(o, unittest.hasLength(2)); |
462 checkReceivedMessage(o[0]); | 459 checkReceivedMessage(o[0]); |
463 checkReceivedMessage(o[1]); | 460 checkReceivedMessage(o[1]); |
464 } | 461 } |
465 | 462 |
466 core.int buildCounterPullResponse = 0; | 463 core.int buildCounterPullResponse = 0; |
467 buildPullResponse() { | 464 buildPullResponse() { |
468 var o = new api.PullResponse(); | 465 var o = new api.PullResponse(); |
469 buildCounterPullResponse++; | 466 buildCounterPullResponse++; |
470 if (buildCounterPullResponse < 3) { | 467 if (buildCounterPullResponse < 3) { |
471 o.receivedMessages = buildUnnamed3350(); | 468 o.receivedMessages = buildUnnamed3343(); |
472 } | 469 } |
473 buildCounterPullResponse--; | 470 buildCounterPullResponse--; |
474 return o; | 471 return o; |
475 } | 472 } |
476 | 473 |
477 checkPullResponse(api.PullResponse o) { | 474 checkPullResponse(api.PullResponse o) { |
478 buildCounterPullResponse++; | 475 buildCounterPullResponse++; |
479 if (buildCounterPullResponse < 3) { | 476 if (buildCounterPullResponse < 3) { |
480 checkUnnamed3350(o.receivedMessages); | 477 checkUnnamed3343(o.receivedMessages); |
481 } | 478 } |
482 buildCounterPullResponse--; | 479 buildCounterPullResponse--; |
483 } | 480 } |
484 | 481 |
485 buildUnnamed3351() { | 482 buildUnnamed3344() { |
486 var o = new core.Map<core.String, core.String>(); | 483 var o = new core.Map<core.String, core.String>(); |
487 o["x"] = "foo"; | 484 o["x"] = "foo"; |
488 o["y"] = "foo"; | 485 o["y"] = "foo"; |
489 return o; | 486 return o; |
490 } | 487 } |
491 | 488 |
492 checkUnnamed3351(core.Map<core.String, core.String> o) { | 489 checkUnnamed3344(core.Map<core.String, core.String> o) { |
493 unittest.expect(o, unittest.hasLength(2)); | 490 unittest.expect(o, unittest.hasLength(2)); |
494 unittest.expect(o["x"], unittest.equals('foo')); | 491 unittest.expect(o["x"], unittest.equals('foo')); |
495 unittest.expect(o["y"], unittest.equals('foo')); | 492 unittest.expect(o["y"], unittest.equals('foo')); |
496 } | 493 } |
497 | 494 |
498 core.int buildCounterPushConfig = 0; | 495 core.int buildCounterPushConfig = 0; |
499 buildPushConfig() { | 496 buildPushConfig() { |
500 var o = new api.PushConfig(); | 497 var o = new api.PushConfig(); |
501 buildCounterPushConfig++; | 498 buildCounterPushConfig++; |
502 if (buildCounterPushConfig < 3) { | 499 if (buildCounterPushConfig < 3) { |
503 o.attributes = buildUnnamed3351(); | 500 o.attributes = buildUnnamed3344(); |
504 o.pushEndpoint = "foo"; | 501 o.pushEndpoint = "foo"; |
505 } | 502 } |
506 buildCounterPushConfig--; | 503 buildCounterPushConfig--; |
507 return o; | 504 return o; |
508 } | 505 } |
509 | 506 |
510 checkPushConfig(api.PushConfig o) { | 507 checkPushConfig(api.PushConfig o) { |
511 buildCounterPushConfig++; | 508 buildCounterPushConfig++; |
512 if (buildCounterPushConfig < 3) { | 509 if (buildCounterPushConfig < 3) { |
513 checkUnnamed3351(o.attributes); | 510 checkUnnamed3344(o.attributes); |
514 unittest.expect(o.pushEndpoint, unittest.equals('foo')); | 511 unittest.expect(o.pushEndpoint, unittest.equals('foo')); |
515 } | 512 } |
516 buildCounterPushConfig--; | 513 buildCounterPushConfig--; |
517 } | 514 } |
518 | 515 |
519 core.int buildCounterReceivedMessage = 0; | 516 core.int buildCounterReceivedMessage = 0; |
520 buildReceivedMessage() { | 517 buildReceivedMessage() { |
521 var o = new api.ReceivedMessage(); | 518 var o = new api.ReceivedMessage(); |
522 buildCounterReceivedMessage++; | 519 buildCounterReceivedMessage++; |
523 if (buildCounterReceivedMessage < 3) { | 520 if (buildCounterReceivedMessage < 3) { |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
574 buildCounterSubscription++; | 571 buildCounterSubscription++; |
575 if (buildCounterSubscription < 3) { | 572 if (buildCounterSubscription < 3) { |
576 unittest.expect(o.ackDeadlineSeconds, unittest.equals(42)); | 573 unittest.expect(o.ackDeadlineSeconds, unittest.equals(42)); |
577 unittest.expect(o.name, unittest.equals('foo')); | 574 unittest.expect(o.name, unittest.equals('foo')); |
578 checkPushConfig(o.pushConfig); | 575 checkPushConfig(o.pushConfig); |
579 unittest.expect(o.topic, unittest.equals('foo')); | 576 unittest.expect(o.topic, unittest.equals('foo')); |
580 } | 577 } |
581 buildCounterSubscription--; | 578 buildCounterSubscription--; |
582 } | 579 } |
583 | 580 |
584 buildUnnamed3352() { | 581 buildUnnamed3345() { |
585 var o = new core.List<core.String>(); | 582 var o = new core.List<core.String>(); |
586 o.add("foo"); | 583 o.add("foo"); |
587 o.add("foo"); | 584 o.add("foo"); |
588 return o; | 585 return o; |
589 } | 586 } |
590 | 587 |
591 checkUnnamed3352(core.List<core.String> o) { | 588 checkUnnamed3345(core.List<core.String> o) { |
592 unittest.expect(o, unittest.hasLength(2)); | 589 unittest.expect(o, unittest.hasLength(2)); |
593 unittest.expect(o[0], unittest.equals('foo')); | 590 unittest.expect(o[0], unittest.equals('foo')); |
594 unittest.expect(o[1], unittest.equals('foo')); | 591 unittest.expect(o[1], unittest.equals('foo')); |
595 } | 592 } |
596 | 593 |
597 core.int buildCounterTestIamPermissionsRequest = 0; | 594 core.int buildCounterTestIamPermissionsRequest = 0; |
598 buildTestIamPermissionsRequest() { | 595 buildTestIamPermissionsRequest() { |
599 var o = new api.TestIamPermissionsRequest(); | 596 var o = new api.TestIamPermissionsRequest(); |
600 buildCounterTestIamPermissionsRequest++; | 597 buildCounterTestIamPermissionsRequest++; |
601 if (buildCounterTestIamPermissionsRequest < 3) { | 598 if (buildCounterTestIamPermissionsRequest < 3) { |
602 o.permissions = buildUnnamed3352(); | 599 o.permissions = buildUnnamed3345(); |
603 } | 600 } |
604 buildCounterTestIamPermissionsRequest--; | 601 buildCounterTestIamPermissionsRequest--; |
605 return o; | 602 return o; |
606 } | 603 } |
607 | 604 |
608 checkTestIamPermissionsRequest(api.TestIamPermissionsRequest o) { | 605 checkTestIamPermissionsRequest(api.TestIamPermissionsRequest o) { |
609 buildCounterTestIamPermissionsRequest++; | 606 buildCounterTestIamPermissionsRequest++; |
610 if (buildCounterTestIamPermissionsRequest < 3) { | 607 if (buildCounterTestIamPermissionsRequest < 3) { |
611 checkUnnamed3352(o.permissions); | 608 checkUnnamed3345(o.permissions); |
612 } | 609 } |
613 buildCounterTestIamPermissionsRequest--; | 610 buildCounterTestIamPermissionsRequest--; |
614 } | 611 } |
615 | 612 |
616 buildUnnamed3353() { | 613 buildUnnamed3346() { |
617 var o = new core.List<core.String>(); | 614 var o = new core.List<core.String>(); |
618 o.add("foo"); | 615 o.add("foo"); |
619 o.add("foo"); | 616 o.add("foo"); |
620 return o; | 617 return o; |
621 } | 618 } |
622 | 619 |
623 checkUnnamed3353(core.List<core.String> o) { | 620 checkUnnamed3346(core.List<core.String> o) { |
624 unittest.expect(o, unittest.hasLength(2)); | 621 unittest.expect(o, unittest.hasLength(2)); |
625 unittest.expect(o[0], unittest.equals('foo')); | 622 unittest.expect(o[0], unittest.equals('foo')); |
626 unittest.expect(o[1], unittest.equals('foo')); | 623 unittest.expect(o[1], unittest.equals('foo')); |
627 } | 624 } |
628 | 625 |
629 core.int buildCounterTestIamPermissionsResponse = 0; | 626 core.int buildCounterTestIamPermissionsResponse = 0; |
630 buildTestIamPermissionsResponse() { | 627 buildTestIamPermissionsResponse() { |
631 var o = new api.TestIamPermissionsResponse(); | 628 var o = new api.TestIamPermissionsResponse(); |
632 buildCounterTestIamPermissionsResponse++; | 629 buildCounterTestIamPermissionsResponse++; |
633 if (buildCounterTestIamPermissionsResponse < 3) { | 630 if (buildCounterTestIamPermissionsResponse < 3) { |
634 o.permissions = buildUnnamed3353(); | 631 o.permissions = buildUnnamed3346(); |
635 } | 632 } |
636 buildCounterTestIamPermissionsResponse--; | 633 buildCounterTestIamPermissionsResponse--; |
637 return o; | 634 return o; |
638 } | 635 } |
639 | 636 |
640 checkTestIamPermissionsResponse(api.TestIamPermissionsResponse o) { | 637 checkTestIamPermissionsResponse(api.TestIamPermissionsResponse o) { |
641 buildCounterTestIamPermissionsResponse++; | 638 buildCounterTestIamPermissionsResponse++; |
642 if (buildCounterTestIamPermissionsResponse < 3) { | 639 if (buildCounterTestIamPermissionsResponse < 3) { |
643 checkUnnamed3353(o.permissions); | 640 checkUnnamed3346(o.permissions); |
644 } | 641 } |
645 buildCounterTestIamPermissionsResponse--; | 642 buildCounterTestIamPermissionsResponse--; |
646 } | 643 } |
647 | 644 |
648 core.int buildCounterTopic = 0; | 645 core.int buildCounterTopic = 0; |
649 buildTopic() { | 646 buildTopic() { |
650 var o = new api.Topic(); | 647 var o = new api.Topic(); |
651 buildCounterTopic++; | 648 buildCounterTopic++; |
652 if (buildCounterTopic < 3) { | 649 if (buildCounterTopic < 3) { |
653 o.name = "foo"; | 650 o.name = "foo"; |
654 } | 651 } |
655 buildCounterTopic--; | 652 buildCounterTopic--; |
656 return o; | 653 return o; |
657 } | 654 } |
658 | 655 |
659 checkTopic(api.Topic o) { | 656 checkTopic(api.Topic o) { |
660 buildCounterTopic++; | 657 buildCounterTopic++; |
661 if (buildCounterTopic < 3) { | 658 if (buildCounterTopic < 3) { |
662 unittest.expect(o.name, unittest.equals('foo')); | 659 unittest.expect(o.name, unittest.equals('foo')); |
663 } | 660 } |
664 buildCounterTopic--; | 661 buildCounterTopic--; |
665 } | 662 } |
666 | 663 |
667 | |
668 main() { | 664 main() { |
669 unittest.group("obj-schema-AcknowledgeRequest", () { | 665 unittest.group("obj-schema-AcknowledgeRequest", () { |
670 unittest.test("to-json--from-json", () { | 666 unittest.test("to-json--from-json", () { |
671 var o = buildAcknowledgeRequest(); | 667 var o = buildAcknowledgeRequest(); |
672 var od = new api.AcknowledgeRequest.fromJson(o.toJson()); | 668 var od = new api.AcknowledgeRequest.fromJson(o.toJson()); |
673 checkAcknowledgeRequest(od); | 669 checkAcknowledgeRequest(od); |
674 }); | 670 }); |
675 }); | 671 }); |
676 | 672 |
677 | |
678 unittest.group("obj-schema-Binding", () { | 673 unittest.group("obj-schema-Binding", () { |
679 unittest.test("to-json--from-json", () { | 674 unittest.test("to-json--from-json", () { |
680 var o = buildBinding(); | 675 var o = buildBinding(); |
681 var od = new api.Binding.fromJson(o.toJson()); | 676 var od = new api.Binding.fromJson(o.toJson()); |
682 checkBinding(od); | 677 checkBinding(od); |
683 }); | 678 }); |
684 }); | 679 }); |
685 | 680 |
686 | |
687 unittest.group("obj-schema-Empty", () { | 681 unittest.group("obj-schema-Empty", () { |
688 unittest.test("to-json--from-json", () { | 682 unittest.test("to-json--from-json", () { |
689 var o = buildEmpty(); | 683 var o = buildEmpty(); |
690 var od = new api.Empty.fromJson(o.toJson()); | 684 var od = new api.Empty.fromJson(o.toJson()); |
691 checkEmpty(od); | 685 checkEmpty(od); |
692 }); | 686 }); |
693 }); | 687 }); |
694 | 688 |
695 | |
696 unittest.group("obj-schema-ListSubscriptionsResponse", () { | 689 unittest.group("obj-schema-ListSubscriptionsResponse", () { |
697 unittest.test("to-json--from-json", () { | 690 unittest.test("to-json--from-json", () { |
698 var o = buildListSubscriptionsResponse(); | 691 var o = buildListSubscriptionsResponse(); |
699 var od = new api.ListSubscriptionsResponse.fromJson(o.toJson()); | 692 var od = new api.ListSubscriptionsResponse.fromJson(o.toJson()); |
700 checkListSubscriptionsResponse(od); | 693 checkListSubscriptionsResponse(od); |
701 }); | 694 }); |
702 }); | 695 }); |
703 | 696 |
704 | |
705 unittest.group("obj-schema-ListTopicSubscriptionsResponse", () { | 697 unittest.group("obj-schema-ListTopicSubscriptionsResponse", () { |
706 unittest.test("to-json--from-json", () { | 698 unittest.test("to-json--from-json", () { |
707 var o = buildListTopicSubscriptionsResponse(); | 699 var o = buildListTopicSubscriptionsResponse(); |
708 var od = new api.ListTopicSubscriptionsResponse.fromJson(o.toJson()); | 700 var od = new api.ListTopicSubscriptionsResponse.fromJson(o.toJson()); |
709 checkListTopicSubscriptionsResponse(od); | 701 checkListTopicSubscriptionsResponse(od); |
710 }); | 702 }); |
711 }); | 703 }); |
712 | 704 |
713 | |
714 unittest.group("obj-schema-ListTopicsResponse", () { | 705 unittest.group("obj-schema-ListTopicsResponse", () { |
715 unittest.test("to-json--from-json", () { | 706 unittest.test("to-json--from-json", () { |
716 var o = buildListTopicsResponse(); | 707 var o = buildListTopicsResponse(); |
717 var od = new api.ListTopicsResponse.fromJson(o.toJson()); | 708 var od = new api.ListTopicsResponse.fromJson(o.toJson()); |
718 checkListTopicsResponse(od); | 709 checkListTopicsResponse(od); |
719 }); | 710 }); |
720 }); | 711 }); |
721 | 712 |
722 | |
723 unittest.group("obj-schema-ModifyAckDeadlineRequest", () { | 713 unittest.group("obj-schema-ModifyAckDeadlineRequest", () { |
724 unittest.test("to-json--from-json", () { | 714 unittest.test("to-json--from-json", () { |
725 var o = buildModifyAckDeadlineRequest(); | 715 var o = buildModifyAckDeadlineRequest(); |
726 var od = new api.ModifyAckDeadlineRequest.fromJson(o.toJson()); | 716 var od = new api.ModifyAckDeadlineRequest.fromJson(o.toJson()); |
727 checkModifyAckDeadlineRequest(od); | 717 checkModifyAckDeadlineRequest(od); |
728 }); | 718 }); |
729 }); | 719 }); |
730 | 720 |
731 | |
732 unittest.group("obj-schema-ModifyPushConfigRequest", () { | 721 unittest.group("obj-schema-ModifyPushConfigRequest", () { |
733 unittest.test("to-json--from-json", () { | 722 unittest.test("to-json--from-json", () { |
734 var o = buildModifyPushConfigRequest(); | 723 var o = buildModifyPushConfigRequest(); |
735 var od = new api.ModifyPushConfigRequest.fromJson(o.toJson()); | 724 var od = new api.ModifyPushConfigRequest.fromJson(o.toJson()); |
736 checkModifyPushConfigRequest(od); | 725 checkModifyPushConfigRequest(od); |
737 }); | 726 }); |
738 }); | 727 }); |
739 | 728 |
740 | |
741 unittest.group("obj-schema-Policy", () { | 729 unittest.group("obj-schema-Policy", () { |
742 unittest.test("to-json--from-json", () { | 730 unittest.test("to-json--from-json", () { |
743 var o = buildPolicy(); | 731 var o = buildPolicy(); |
744 var od = new api.Policy.fromJson(o.toJson()); | 732 var od = new api.Policy.fromJson(o.toJson()); |
745 checkPolicy(od); | 733 checkPolicy(od); |
746 }); | 734 }); |
747 }); | 735 }); |
748 | 736 |
749 | |
750 unittest.group("obj-schema-PublishRequest", () { | 737 unittest.group("obj-schema-PublishRequest", () { |
751 unittest.test("to-json--from-json", () { | 738 unittest.test("to-json--from-json", () { |
752 var o = buildPublishRequest(); | 739 var o = buildPublishRequest(); |
753 var od = new api.PublishRequest.fromJson(o.toJson()); | 740 var od = new api.PublishRequest.fromJson(o.toJson()); |
754 checkPublishRequest(od); | 741 checkPublishRequest(od); |
755 }); | 742 }); |
756 }); | 743 }); |
757 | 744 |
758 | |
759 unittest.group("obj-schema-PublishResponse", () { | 745 unittest.group("obj-schema-PublishResponse", () { |
760 unittest.test("to-json--from-json", () { | 746 unittest.test("to-json--from-json", () { |
761 var o = buildPublishResponse(); | 747 var o = buildPublishResponse(); |
762 var od = new api.PublishResponse.fromJson(o.toJson()); | 748 var od = new api.PublishResponse.fromJson(o.toJson()); |
763 checkPublishResponse(od); | 749 checkPublishResponse(od); |
764 }); | 750 }); |
765 }); | 751 }); |
766 | 752 |
767 | |
768 unittest.group("obj-schema-PubsubMessage", () { | 753 unittest.group("obj-schema-PubsubMessage", () { |
769 unittest.test("to-json--from-json", () { | 754 unittest.test("to-json--from-json", () { |
770 var o = buildPubsubMessage(); | 755 var o = buildPubsubMessage(); |
771 var od = new api.PubsubMessage.fromJson(o.toJson()); | 756 var od = new api.PubsubMessage.fromJson(o.toJson()); |
772 checkPubsubMessage(od); | 757 checkPubsubMessage(od); |
773 }); | 758 }); |
774 }); | 759 }); |
775 | 760 |
776 | |
777 unittest.group("obj-schema-PullRequest", () { | 761 unittest.group("obj-schema-PullRequest", () { |
778 unittest.test("to-json--from-json", () { | 762 unittest.test("to-json--from-json", () { |
779 var o = buildPullRequest(); | 763 var o = buildPullRequest(); |
780 var od = new api.PullRequest.fromJson(o.toJson()); | 764 var od = new api.PullRequest.fromJson(o.toJson()); |
781 checkPullRequest(od); | 765 checkPullRequest(od); |
782 }); | 766 }); |
783 }); | 767 }); |
784 | 768 |
785 | |
786 unittest.group("obj-schema-PullResponse", () { | 769 unittest.group("obj-schema-PullResponse", () { |
787 unittest.test("to-json--from-json", () { | 770 unittest.test("to-json--from-json", () { |
788 var o = buildPullResponse(); | 771 var o = buildPullResponse(); |
789 var od = new api.PullResponse.fromJson(o.toJson()); | 772 var od = new api.PullResponse.fromJson(o.toJson()); |
790 checkPullResponse(od); | 773 checkPullResponse(od); |
791 }); | 774 }); |
792 }); | 775 }); |
793 | 776 |
794 | |
795 unittest.group("obj-schema-PushConfig", () { | 777 unittest.group("obj-schema-PushConfig", () { |
796 unittest.test("to-json--from-json", () { | 778 unittest.test("to-json--from-json", () { |
797 var o = buildPushConfig(); | 779 var o = buildPushConfig(); |
798 var od = new api.PushConfig.fromJson(o.toJson()); | 780 var od = new api.PushConfig.fromJson(o.toJson()); |
799 checkPushConfig(od); | 781 checkPushConfig(od); |
800 }); | 782 }); |
801 }); | 783 }); |
802 | 784 |
803 | |
804 unittest.group("obj-schema-ReceivedMessage", () { | 785 unittest.group("obj-schema-ReceivedMessage", () { |
805 unittest.test("to-json--from-json", () { | 786 unittest.test("to-json--from-json", () { |
806 var o = buildReceivedMessage(); | 787 var o = buildReceivedMessage(); |
807 var od = new api.ReceivedMessage.fromJson(o.toJson()); | 788 var od = new api.ReceivedMessage.fromJson(o.toJson()); |
808 checkReceivedMessage(od); | 789 checkReceivedMessage(od); |
809 }); | 790 }); |
810 }); | 791 }); |
811 | 792 |
812 | |
813 unittest.group("obj-schema-SetIamPolicyRequest", () { | 793 unittest.group("obj-schema-SetIamPolicyRequest", () { |
814 unittest.test("to-json--from-json", () { | 794 unittest.test("to-json--from-json", () { |
815 var o = buildSetIamPolicyRequest(); | 795 var o = buildSetIamPolicyRequest(); |
816 var od = new api.SetIamPolicyRequest.fromJson(o.toJson()); | 796 var od = new api.SetIamPolicyRequest.fromJson(o.toJson()); |
817 checkSetIamPolicyRequest(od); | 797 checkSetIamPolicyRequest(od); |
818 }); | 798 }); |
819 }); | 799 }); |
820 | 800 |
821 | |
822 unittest.group("obj-schema-Subscription", () { | 801 unittest.group("obj-schema-Subscription", () { |
823 unittest.test("to-json--from-json", () { | 802 unittest.test("to-json--from-json", () { |
824 var o = buildSubscription(); | 803 var o = buildSubscription(); |
825 var od = new api.Subscription.fromJson(o.toJson()); | 804 var od = new api.Subscription.fromJson(o.toJson()); |
826 checkSubscription(od); | 805 checkSubscription(od); |
827 }); | 806 }); |
828 }); | 807 }); |
829 | 808 |
830 | |
831 unittest.group("obj-schema-TestIamPermissionsRequest", () { | 809 unittest.group("obj-schema-TestIamPermissionsRequest", () { |
832 unittest.test("to-json--from-json", () { | 810 unittest.test("to-json--from-json", () { |
833 var o = buildTestIamPermissionsRequest(); | 811 var o = buildTestIamPermissionsRequest(); |
834 var od = new api.TestIamPermissionsRequest.fromJson(o.toJson()); | 812 var od = new api.TestIamPermissionsRequest.fromJson(o.toJson()); |
835 checkTestIamPermissionsRequest(od); | 813 checkTestIamPermissionsRequest(od); |
836 }); | 814 }); |
837 }); | 815 }); |
838 | 816 |
839 | |
840 unittest.group("obj-schema-TestIamPermissionsResponse", () { | 817 unittest.group("obj-schema-TestIamPermissionsResponse", () { |
841 unittest.test("to-json--from-json", () { | 818 unittest.test("to-json--from-json", () { |
842 var o = buildTestIamPermissionsResponse(); | 819 var o = buildTestIamPermissionsResponse(); |
843 var od = new api.TestIamPermissionsResponse.fromJson(o.toJson()); | 820 var od = new api.TestIamPermissionsResponse.fromJson(o.toJson()); |
844 checkTestIamPermissionsResponse(od); | 821 checkTestIamPermissionsResponse(od); |
845 }); | 822 }); |
846 }); | 823 }); |
847 | 824 |
848 | |
849 unittest.group("obj-schema-Topic", () { | 825 unittest.group("obj-schema-Topic", () { |
850 unittest.test("to-json--from-json", () { | 826 unittest.test("to-json--from-json", () { |
851 var o = buildTopic(); | 827 var o = buildTopic(); |
852 var od = new api.Topic.fromJson(o.toJson()); | 828 var od = new api.Topic.fromJson(o.toJson()); |
853 checkTopic(od); | 829 checkTopic(od); |
854 }); | 830 }); |
855 }); | 831 }); |
856 | 832 |
857 | |
858 unittest.group("resource-ProjectsSubscriptionsResourceApi", () { | 833 unittest.group("resource-ProjectsSubscriptionsResourceApi", () { |
859 unittest.test("method--acknowledge", () { | 834 unittest.test("method--acknowledge", () { |
860 | |
861 var mock = new HttpServerMock(); | 835 var mock = new HttpServerMock(); |
862 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 836 api.ProjectsSubscriptionsResourceApi res = |
| 837 new api.PubsubApi(mock).projects.subscriptions; |
863 var arg_request = buildAcknowledgeRequest(); | 838 var arg_request = buildAcknowledgeRequest(); |
864 var arg_subscription = "foo"; | 839 var arg_subscription = "foo"; |
865 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 840 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
866 var obj = new api.AcknowledgeRequest.fromJson(json); | 841 var obj = new api.AcknowledgeRequest.fromJson(json); |
867 checkAcknowledgeRequest(obj); | 842 checkAcknowledgeRequest(obj); |
868 | 843 |
869 var path = (req.url).path; | 844 var path = (req.url).path; |
870 var pathOffset = 0; | 845 var pathOffset = 0; |
871 var index; | 846 var index; |
872 var subPart; | 847 var subPart; |
873 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 848 unittest.expect( |
| 849 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
874 pathOffset += 1; | 850 pathOffset += 1; |
875 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 851 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 852 unittest.equals("v1beta2/")); |
876 pathOffset += 8; | 853 pathOffset += 8; |
877 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 854 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
878 | 855 |
879 var query = (req.url).query; | 856 var query = (req.url).query; |
880 var queryOffset = 0; | 857 var queryOffset = 0; |
881 var queryMap = {}; | 858 var queryMap = {}; |
882 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 859 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
883 parseBool(n) { | 860 parseBool(n) { |
884 if (n == "true") return true; | 861 if (n == "true") return true; |
885 if (n == "false") return false; | 862 if (n == "false") return false; |
886 if (n == null) return null; | 863 if (n == null) return null; |
887 throw new core.ArgumentError("Invalid boolean: $n"); | 864 throw new core.ArgumentError("Invalid boolean: $n"); |
888 } | 865 } |
| 866 |
889 if (query.length > 0) { | 867 if (query.length > 0) { |
890 for (var part in query.split("&")) { | 868 for (var part in query.split("&")) { |
891 var keyvalue = part.split("="); | 869 var keyvalue = part.split("="); |
892 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 870 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 871 core.Uri.decodeQueryComponent(keyvalue[1])); |
893 } | 872 } |
894 } | 873 } |
895 | 874 |
896 | |
897 var h = { | 875 var h = { |
898 "content-type" : "application/json; charset=utf-8", | 876 "content-type": "application/json; charset=utf-8", |
899 }; | 877 }; |
900 var resp = convert.JSON.encode(buildEmpty()); | 878 var resp = convert.JSON.encode(buildEmpty()); |
901 return new async.Future.value(stringResponse(200, h, resp)); | 879 return new async.Future.value(stringResponse(200, h, resp)); |
902 }), true); | 880 }), true); |
903 res.acknowledge(arg_request, arg_subscription).then(unittest.expectAsync1(
((api.Empty response) { | 881 res |
| 882 .acknowledge(arg_request, arg_subscription) |
| 883 .then(unittest.expectAsync1(((api.Empty response) { |
904 checkEmpty(response); | 884 checkEmpty(response); |
905 }))); | 885 }))); |
906 }); | 886 }); |
907 | 887 |
908 unittest.test("method--create", () { | 888 unittest.test("method--create", () { |
909 | |
910 var mock = new HttpServerMock(); | 889 var mock = new HttpServerMock(); |
911 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 890 api.ProjectsSubscriptionsResourceApi res = |
| 891 new api.PubsubApi(mock).projects.subscriptions; |
912 var arg_request = buildSubscription(); | 892 var arg_request = buildSubscription(); |
913 var arg_name = "foo"; | 893 var arg_name = "foo"; |
914 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 894 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
915 var obj = new api.Subscription.fromJson(json); | 895 var obj = new api.Subscription.fromJson(json); |
916 checkSubscription(obj); | 896 checkSubscription(obj); |
917 | 897 |
918 var path = (req.url).path; | 898 var path = (req.url).path; |
919 var pathOffset = 0; | 899 var pathOffset = 0; |
920 var index; | 900 var index; |
921 var subPart; | 901 var subPart; |
922 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 902 unittest.expect( |
| 903 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
923 pathOffset += 1; | 904 pathOffset += 1; |
924 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 905 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 906 unittest.equals("v1beta2/")); |
925 pathOffset += 8; | 907 pathOffset += 8; |
926 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 908 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
927 | 909 |
928 var query = (req.url).query; | 910 var query = (req.url).query; |
929 var queryOffset = 0; | 911 var queryOffset = 0; |
930 var queryMap = {}; | 912 var queryMap = {}; |
931 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 913 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
932 parseBool(n) { | 914 parseBool(n) { |
933 if (n == "true") return true; | 915 if (n == "true") return true; |
934 if (n == "false") return false; | 916 if (n == "false") return false; |
935 if (n == null) return null; | 917 if (n == null) return null; |
936 throw new core.ArgumentError("Invalid boolean: $n"); | 918 throw new core.ArgumentError("Invalid boolean: $n"); |
937 } | 919 } |
| 920 |
938 if (query.length > 0) { | 921 if (query.length > 0) { |
939 for (var part in query.split("&")) { | 922 for (var part in query.split("&")) { |
940 var keyvalue = part.split("="); | 923 var keyvalue = part.split("="); |
941 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 924 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 925 core.Uri.decodeQueryComponent(keyvalue[1])); |
942 } | 926 } |
943 } | 927 } |
944 | 928 |
945 | |
946 var h = { | 929 var h = { |
947 "content-type" : "application/json; charset=utf-8", | 930 "content-type": "application/json; charset=utf-8", |
948 }; | 931 }; |
949 var resp = convert.JSON.encode(buildSubscription()); | 932 var resp = convert.JSON.encode(buildSubscription()); |
950 return new async.Future.value(stringResponse(200, h, resp)); | 933 return new async.Future.value(stringResponse(200, h, resp)); |
951 }), true); | 934 }), true); |
952 res.create(arg_request, arg_name).then(unittest.expectAsync1(((api.Subscri
ption response) { | 935 res |
| 936 .create(arg_request, arg_name) |
| 937 .then(unittest.expectAsync1(((api.Subscription response) { |
953 checkSubscription(response); | 938 checkSubscription(response); |
954 }))); | 939 }))); |
955 }); | 940 }); |
956 | 941 |
957 unittest.test("method--delete", () { | 942 unittest.test("method--delete", () { |
958 | |
959 var mock = new HttpServerMock(); | 943 var mock = new HttpServerMock(); |
960 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 944 api.ProjectsSubscriptionsResourceApi res = |
| 945 new api.PubsubApi(mock).projects.subscriptions; |
961 var arg_subscription = "foo"; | 946 var arg_subscription = "foo"; |
962 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 947 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
963 var path = (req.url).path; | 948 var path = (req.url).path; |
964 var pathOffset = 0; | 949 var pathOffset = 0; |
965 var index; | 950 var index; |
966 var subPart; | 951 var subPart; |
967 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 952 unittest.expect( |
| 953 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
968 pathOffset += 1; | 954 pathOffset += 1; |
969 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 955 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 956 unittest.equals("v1beta2/")); |
970 pathOffset += 8; | 957 pathOffset += 8; |
971 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 958 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
972 | 959 |
973 var query = (req.url).query; | 960 var query = (req.url).query; |
974 var queryOffset = 0; | 961 var queryOffset = 0; |
975 var queryMap = {}; | 962 var queryMap = {}; |
976 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 963 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
977 parseBool(n) { | 964 parseBool(n) { |
978 if (n == "true") return true; | 965 if (n == "true") return true; |
979 if (n == "false") return false; | 966 if (n == "false") return false; |
980 if (n == null) return null; | 967 if (n == null) return null; |
981 throw new core.ArgumentError("Invalid boolean: $n"); | 968 throw new core.ArgumentError("Invalid boolean: $n"); |
982 } | 969 } |
| 970 |
983 if (query.length > 0) { | 971 if (query.length > 0) { |
984 for (var part in query.split("&")) { | 972 for (var part in query.split("&")) { |
985 var keyvalue = part.split("="); | 973 var keyvalue = part.split("="); |
986 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 974 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 975 core.Uri.decodeQueryComponent(keyvalue[1])); |
987 } | 976 } |
988 } | 977 } |
989 | 978 |
990 | |
991 var h = { | 979 var h = { |
992 "content-type" : "application/json; charset=utf-8", | 980 "content-type": "application/json; charset=utf-8", |
993 }; | 981 }; |
994 var resp = convert.JSON.encode(buildEmpty()); | 982 var resp = convert.JSON.encode(buildEmpty()); |
995 return new async.Future.value(stringResponse(200, h, resp)); | 983 return new async.Future.value(stringResponse(200, h, resp)); |
996 }), true); | 984 }), true); |
997 res.delete(arg_subscription).then(unittest.expectAsync1(((api.Empty respon
se) { | 985 res |
| 986 .delete(arg_subscription) |
| 987 .then(unittest.expectAsync1(((api.Empty response) { |
998 checkEmpty(response); | 988 checkEmpty(response); |
999 }))); | 989 }))); |
1000 }); | 990 }); |
1001 | 991 |
1002 unittest.test("method--get", () { | 992 unittest.test("method--get", () { |
1003 | |
1004 var mock = new HttpServerMock(); | 993 var mock = new HttpServerMock(); |
1005 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 994 api.ProjectsSubscriptionsResourceApi res = |
| 995 new api.PubsubApi(mock).projects.subscriptions; |
1006 var arg_subscription = "foo"; | 996 var arg_subscription = "foo"; |
1007 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 997 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1008 var path = (req.url).path; | 998 var path = (req.url).path; |
1009 var pathOffset = 0; | 999 var pathOffset = 0; |
1010 var index; | 1000 var index; |
1011 var subPart; | 1001 var subPart; |
1012 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1002 unittest.expect( |
| 1003 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1013 pathOffset += 1; | 1004 pathOffset += 1; |
1014 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1005 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1006 unittest.equals("v1beta2/")); |
1015 pathOffset += 8; | 1007 pathOffset += 8; |
1016 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1008 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1017 | 1009 |
1018 var query = (req.url).query; | 1010 var query = (req.url).query; |
1019 var queryOffset = 0; | 1011 var queryOffset = 0; |
1020 var queryMap = {}; | 1012 var queryMap = {}; |
1021 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1013 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1022 parseBool(n) { | 1014 parseBool(n) { |
1023 if (n == "true") return true; | 1015 if (n == "true") return true; |
1024 if (n == "false") return false; | 1016 if (n == "false") return false; |
1025 if (n == null) return null; | 1017 if (n == null) return null; |
1026 throw new core.ArgumentError("Invalid boolean: $n"); | 1018 throw new core.ArgumentError("Invalid boolean: $n"); |
1027 } | 1019 } |
| 1020 |
1028 if (query.length > 0) { | 1021 if (query.length > 0) { |
1029 for (var part in query.split("&")) { | 1022 for (var part in query.split("&")) { |
1030 var keyvalue = part.split("="); | 1023 var keyvalue = part.split("="); |
1031 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1024 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1025 core.Uri.decodeQueryComponent(keyvalue[1])); |
1032 } | 1026 } |
1033 } | 1027 } |
1034 | 1028 |
1035 | |
1036 var h = { | 1029 var h = { |
1037 "content-type" : "application/json; charset=utf-8", | 1030 "content-type": "application/json; charset=utf-8", |
1038 }; | 1031 }; |
1039 var resp = convert.JSON.encode(buildSubscription()); | 1032 var resp = convert.JSON.encode(buildSubscription()); |
1040 return new async.Future.value(stringResponse(200, h, resp)); | 1033 return new async.Future.value(stringResponse(200, h, resp)); |
1041 }), true); | 1034 }), true); |
1042 res.get(arg_subscription).then(unittest.expectAsync1(((api.Subscription re
sponse) { | 1035 res |
| 1036 .get(arg_subscription) |
| 1037 .then(unittest.expectAsync1(((api.Subscription response) { |
1043 checkSubscription(response); | 1038 checkSubscription(response); |
1044 }))); | 1039 }))); |
1045 }); | 1040 }); |
1046 | 1041 |
1047 unittest.test("method--getIamPolicy", () { | 1042 unittest.test("method--getIamPolicy", () { |
1048 | |
1049 var mock = new HttpServerMock(); | 1043 var mock = new HttpServerMock(); |
1050 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 1044 api.ProjectsSubscriptionsResourceApi res = |
| 1045 new api.PubsubApi(mock).projects.subscriptions; |
1051 var arg_resource = "foo"; | 1046 var arg_resource = "foo"; |
1052 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1047 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1053 var path = (req.url).path; | 1048 var path = (req.url).path; |
1054 var pathOffset = 0; | 1049 var pathOffset = 0; |
1055 var index; | 1050 var index; |
1056 var subPart; | 1051 var subPart; |
1057 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1052 unittest.expect( |
| 1053 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1058 pathOffset += 1; | 1054 pathOffset += 1; |
1059 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1055 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1056 unittest.equals("v1beta2/")); |
1060 pathOffset += 8; | 1057 pathOffset += 8; |
1061 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1058 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1062 | 1059 |
1063 var query = (req.url).query; | 1060 var query = (req.url).query; |
1064 var queryOffset = 0; | 1061 var queryOffset = 0; |
1065 var queryMap = {}; | 1062 var queryMap = {}; |
1066 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1063 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1067 parseBool(n) { | 1064 parseBool(n) { |
1068 if (n == "true") return true; | 1065 if (n == "true") return true; |
1069 if (n == "false") return false; | 1066 if (n == "false") return false; |
1070 if (n == null) return null; | 1067 if (n == null) return null; |
1071 throw new core.ArgumentError("Invalid boolean: $n"); | 1068 throw new core.ArgumentError("Invalid boolean: $n"); |
1072 } | 1069 } |
| 1070 |
1073 if (query.length > 0) { | 1071 if (query.length > 0) { |
1074 for (var part in query.split("&")) { | 1072 for (var part in query.split("&")) { |
1075 var keyvalue = part.split("="); | 1073 var keyvalue = part.split("="); |
1076 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1074 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1075 core.Uri.decodeQueryComponent(keyvalue[1])); |
1077 } | 1076 } |
1078 } | 1077 } |
1079 | 1078 |
1080 | |
1081 var h = { | 1079 var h = { |
1082 "content-type" : "application/json; charset=utf-8", | 1080 "content-type": "application/json; charset=utf-8", |
1083 }; | 1081 }; |
1084 var resp = convert.JSON.encode(buildPolicy()); | 1082 var resp = convert.JSON.encode(buildPolicy()); |
1085 return new async.Future.value(stringResponse(200, h, resp)); | 1083 return new async.Future.value(stringResponse(200, h, resp)); |
1086 }), true); | 1084 }), true); |
1087 res.getIamPolicy(arg_resource).then(unittest.expectAsync1(((api.Policy res
ponse) { | 1085 res |
| 1086 .getIamPolicy(arg_resource) |
| 1087 .then(unittest.expectAsync1(((api.Policy response) { |
1088 checkPolicy(response); | 1088 checkPolicy(response); |
1089 }))); | 1089 }))); |
1090 }); | 1090 }); |
1091 | 1091 |
1092 unittest.test("method--list", () { | 1092 unittest.test("method--list", () { |
1093 | |
1094 var mock = new HttpServerMock(); | 1093 var mock = new HttpServerMock(); |
1095 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 1094 api.ProjectsSubscriptionsResourceApi res = |
| 1095 new api.PubsubApi(mock).projects.subscriptions; |
1096 var arg_project = "foo"; | 1096 var arg_project = "foo"; |
1097 var arg_pageToken = "foo"; | 1097 var arg_pageToken = "foo"; |
1098 var arg_pageSize = 42; | 1098 var arg_pageSize = 42; |
1099 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1099 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1100 var path = (req.url).path; | 1100 var path = (req.url).path; |
1101 var pathOffset = 0; | 1101 var pathOffset = 0; |
1102 var index; | 1102 var index; |
1103 var subPart; | 1103 var subPart; |
1104 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1104 unittest.expect( |
| 1105 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1105 pathOffset += 1; | 1106 pathOffset += 1; |
1106 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1107 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1108 unittest.equals("v1beta2/")); |
1107 pathOffset += 8; | 1109 pathOffset += 8; |
1108 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1110 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1109 | 1111 |
1110 var query = (req.url).query; | 1112 var query = (req.url).query; |
1111 var queryOffset = 0; | 1113 var queryOffset = 0; |
1112 var queryMap = {}; | 1114 var queryMap = {}; |
1113 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1115 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1114 parseBool(n) { | 1116 parseBool(n) { |
1115 if (n == "true") return true; | 1117 if (n == "true") return true; |
1116 if (n == "false") return false; | 1118 if (n == "false") return false; |
1117 if (n == null) return null; | 1119 if (n == null) return null; |
1118 throw new core.ArgumentError("Invalid boolean: $n"); | 1120 throw new core.ArgumentError("Invalid boolean: $n"); |
1119 } | 1121 } |
| 1122 |
1120 if (query.length > 0) { | 1123 if (query.length > 0) { |
1121 for (var part in query.split("&")) { | 1124 for (var part in query.split("&")) { |
1122 var keyvalue = part.split("="); | 1125 var keyvalue = part.split("="); |
1123 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1126 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1127 core.Uri.decodeQueryComponent(keyvalue[1])); |
1124 } | 1128 } |
1125 } | 1129 } |
1126 unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageTok
en)); | 1130 unittest.expect( |
1127 unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equ
als(arg_pageSize)); | 1131 queryMap["pageToken"].first, unittest.equals(arg_pageToken)); |
1128 | 1132 unittest.expect(core.int.parse(queryMap["pageSize"].first), |
| 1133 unittest.equals(arg_pageSize)); |
1129 | 1134 |
1130 var h = { | 1135 var h = { |
1131 "content-type" : "application/json; charset=utf-8", | 1136 "content-type": "application/json; charset=utf-8", |
1132 }; | 1137 }; |
1133 var resp = convert.JSON.encode(buildListSubscriptionsResponse()); | 1138 var resp = convert.JSON.encode(buildListSubscriptionsResponse()); |
1134 return new async.Future.value(stringResponse(200, h, resp)); | 1139 return new async.Future.value(stringResponse(200, h, resp)); |
1135 }), true); | 1140 }), true); |
1136 res.list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize).th
en(unittest.expectAsync1(((api.ListSubscriptionsResponse response) { | 1141 res |
| 1142 .list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize) |
| 1143 .then( |
| 1144 unittest.expectAsync1(((api.ListSubscriptionsResponse response) { |
1137 checkListSubscriptionsResponse(response); | 1145 checkListSubscriptionsResponse(response); |
1138 }))); | 1146 }))); |
1139 }); | 1147 }); |
1140 | 1148 |
1141 unittest.test("method--modifyAckDeadline", () { | 1149 unittest.test("method--modifyAckDeadline", () { |
1142 | |
1143 var mock = new HttpServerMock(); | 1150 var mock = new HttpServerMock(); |
1144 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 1151 api.ProjectsSubscriptionsResourceApi res = |
| 1152 new api.PubsubApi(mock).projects.subscriptions; |
1145 var arg_request = buildModifyAckDeadlineRequest(); | 1153 var arg_request = buildModifyAckDeadlineRequest(); |
1146 var arg_subscription = "foo"; | 1154 var arg_subscription = "foo"; |
1147 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1155 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1148 var obj = new api.ModifyAckDeadlineRequest.fromJson(json); | 1156 var obj = new api.ModifyAckDeadlineRequest.fromJson(json); |
1149 checkModifyAckDeadlineRequest(obj); | 1157 checkModifyAckDeadlineRequest(obj); |
1150 | 1158 |
1151 var path = (req.url).path; | 1159 var path = (req.url).path; |
1152 var pathOffset = 0; | 1160 var pathOffset = 0; |
1153 var index; | 1161 var index; |
1154 var subPart; | 1162 var subPart; |
1155 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1163 unittest.expect( |
| 1164 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1156 pathOffset += 1; | 1165 pathOffset += 1; |
1157 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1166 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1167 unittest.equals("v1beta2/")); |
1158 pathOffset += 8; | 1168 pathOffset += 8; |
1159 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1169 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1160 | 1170 |
1161 var query = (req.url).query; | 1171 var query = (req.url).query; |
1162 var queryOffset = 0; | 1172 var queryOffset = 0; |
1163 var queryMap = {}; | 1173 var queryMap = {}; |
1164 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1174 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1165 parseBool(n) { | 1175 parseBool(n) { |
1166 if (n == "true") return true; | 1176 if (n == "true") return true; |
1167 if (n == "false") return false; | 1177 if (n == "false") return false; |
1168 if (n == null) return null; | 1178 if (n == null) return null; |
1169 throw new core.ArgumentError("Invalid boolean: $n"); | 1179 throw new core.ArgumentError("Invalid boolean: $n"); |
1170 } | 1180 } |
| 1181 |
1171 if (query.length > 0) { | 1182 if (query.length > 0) { |
1172 for (var part in query.split("&")) { | 1183 for (var part in query.split("&")) { |
1173 var keyvalue = part.split("="); | 1184 var keyvalue = part.split("="); |
1174 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1185 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1186 core.Uri.decodeQueryComponent(keyvalue[1])); |
1175 } | 1187 } |
1176 } | 1188 } |
1177 | 1189 |
1178 | |
1179 var h = { | 1190 var h = { |
1180 "content-type" : "application/json; charset=utf-8", | 1191 "content-type": "application/json; charset=utf-8", |
1181 }; | 1192 }; |
1182 var resp = convert.JSON.encode(buildEmpty()); | 1193 var resp = convert.JSON.encode(buildEmpty()); |
1183 return new async.Future.value(stringResponse(200, h, resp)); | 1194 return new async.Future.value(stringResponse(200, h, resp)); |
1184 }), true); | 1195 }), true); |
1185 res.modifyAckDeadline(arg_request, arg_subscription).then(unittest.expectA
sync1(((api.Empty response) { | 1196 res |
| 1197 .modifyAckDeadline(arg_request, arg_subscription) |
| 1198 .then(unittest.expectAsync1(((api.Empty response) { |
1186 checkEmpty(response); | 1199 checkEmpty(response); |
1187 }))); | 1200 }))); |
1188 }); | 1201 }); |
1189 | 1202 |
1190 unittest.test("method--modifyPushConfig", () { | 1203 unittest.test("method--modifyPushConfig", () { |
1191 | |
1192 var mock = new HttpServerMock(); | 1204 var mock = new HttpServerMock(); |
1193 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 1205 api.ProjectsSubscriptionsResourceApi res = |
| 1206 new api.PubsubApi(mock).projects.subscriptions; |
1194 var arg_request = buildModifyPushConfigRequest(); | 1207 var arg_request = buildModifyPushConfigRequest(); |
1195 var arg_subscription = "foo"; | 1208 var arg_subscription = "foo"; |
1196 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1209 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1197 var obj = new api.ModifyPushConfigRequest.fromJson(json); | 1210 var obj = new api.ModifyPushConfigRequest.fromJson(json); |
1198 checkModifyPushConfigRequest(obj); | 1211 checkModifyPushConfigRequest(obj); |
1199 | 1212 |
1200 var path = (req.url).path; | 1213 var path = (req.url).path; |
1201 var pathOffset = 0; | 1214 var pathOffset = 0; |
1202 var index; | 1215 var index; |
1203 var subPart; | 1216 var subPart; |
1204 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1217 unittest.expect( |
| 1218 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1205 pathOffset += 1; | 1219 pathOffset += 1; |
1206 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1220 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1221 unittest.equals("v1beta2/")); |
1207 pathOffset += 8; | 1222 pathOffset += 8; |
1208 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1223 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1209 | 1224 |
1210 var query = (req.url).query; | 1225 var query = (req.url).query; |
1211 var queryOffset = 0; | 1226 var queryOffset = 0; |
1212 var queryMap = {}; | 1227 var queryMap = {}; |
1213 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1228 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1214 parseBool(n) { | 1229 parseBool(n) { |
1215 if (n == "true") return true; | 1230 if (n == "true") return true; |
1216 if (n == "false") return false; | 1231 if (n == "false") return false; |
1217 if (n == null) return null; | 1232 if (n == null) return null; |
1218 throw new core.ArgumentError("Invalid boolean: $n"); | 1233 throw new core.ArgumentError("Invalid boolean: $n"); |
1219 } | 1234 } |
| 1235 |
1220 if (query.length > 0) { | 1236 if (query.length > 0) { |
1221 for (var part in query.split("&")) { | 1237 for (var part in query.split("&")) { |
1222 var keyvalue = part.split("="); | 1238 var keyvalue = part.split("="); |
1223 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1239 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1240 core.Uri.decodeQueryComponent(keyvalue[1])); |
1224 } | 1241 } |
1225 } | 1242 } |
1226 | 1243 |
1227 | |
1228 var h = { | 1244 var h = { |
1229 "content-type" : "application/json; charset=utf-8", | 1245 "content-type": "application/json; charset=utf-8", |
1230 }; | 1246 }; |
1231 var resp = convert.JSON.encode(buildEmpty()); | 1247 var resp = convert.JSON.encode(buildEmpty()); |
1232 return new async.Future.value(stringResponse(200, h, resp)); | 1248 return new async.Future.value(stringResponse(200, h, resp)); |
1233 }), true); | 1249 }), true); |
1234 res.modifyPushConfig(arg_request, arg_subscription).then(unittest.expectAs
ync1(((api.Empty response) { | 1250 res |
| 1251 .modifyPushConfig(arg_request, arg_subscription) |
| 1252 .then(unittest.expectAsync1(((api.Empty response) { |
1235 checkEmpty(response); | 1253 checkEmpty(response); |
1236 }))); | 1254 }))); |
1237 }); | 1255 }); |
1238 | 1256 |
1239 unittest.test("method--pull", () { | 1257 unittest.test("method--pull", () { |
1240 | |
1241 var mock = new HttpServerMock(); | 1258 var mock = new HttpServerMock(); |
1242 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 1259 api.ProjectsSubscriptionsResourceApi res = |
| 1260 new api.PubsubApi(mock).projects.subscriptions; |
1243 var arg_request = buildPullRequest(); | 1261 var arg_request = buildPullRequest(); |
1244 var arg_subscription = "foo"; | 1262 var arg_subscription = "foo"; |
1245 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1263 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1246 var obj = new api.PullRequest.fromJson(json); | 1264 var obj = new api.PullRequest.fromJson(json); |
1247 checkPullRequest(obj); | 1265 checkPullRequest(obj); |
1248 | 1266 |
1249 var path = (req.url).path; | 1267 var path = (req.url).path; |
1250 var pathOffset = 0; | 1268 var pathOffset = 0; |
1251 var index; | 1269 var index; |
1252 var subPart; | 1270 var subPart; |
1253 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1271 unittest.expect( |
| 1272 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1254 pathOffset += 1; | 1273 pathOffset += 1; |
1255 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1274 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1275 unittest.equals("v1beta2/")); |
1256 pathOffset += 8; | 1276 pathOffset += 8; |
1257 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1277 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1258 | 1278 |
1259 var query = (req.url).query; | 1279 var query = (req.url).query; |
1260 var queryOffset = 0; | 1280 var queryOffset = 0; |
1261 var queryMap = {}; | 1281 var queryMap = {}; |
1262 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1282 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1263 parseBool(n) { | 1283 parseBool(n) { |
1264 if (n == "true") return true; | 1284 if (n == "true") return true; |
1265 if (n == "false") return false; | 1285 if (n == "false") return false; |
1266 if (n == null) return null; | 1286 if (n == null) return null; |
1267 throw new core.ArgumentError("Invalid boolean: $n"); | 1287 throw new core.ArgumentError("Invalid boolean: $n"); |
1268 } | 1288 } |
| 1289 |
1269 if (query.length > 0) { | 1290 if (query.length > 0) { |
1270 for (var part in query.split("&")) { | 1291 for (var part in query.split("&")) { |
1271 var keyvalue = part.split("="); | 1292 var keyvalue = part.split("="); |
1272 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1293 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1294 core.Uri.decodeQueryComponent(keyvalue[1])); |
1273 } | 1295 } |
1274 } | 1296 } |
1275 | 1297 |
1276 | |
1277 var h = { | 1298 var h = { |
1278 "content-type" : "application/json; charset=utf-8", | 1299 "content-type": "application/json; charset=utf-8", |
1279 }; | 1300 }; |
1280 var resp = convert.JSON.encode(buildPullResponse()); | 1301 var resp = convert.JSON.encode(buildPullResponse()); |
1281 return new async.Future.value(stringResponse(200, h, resp)); | 1302 return new async.Future.value(stringResponse(200, h, resp)); |
1282 }), true); | 1303 }), true); |
1283 res.pull(arg_request, arg_subscription).then(unittest.expectAsync1(((api.P
ullResponse response) { | 1304 res |
| 1305 .pull(arg_request, arg_subscription) |
| 1306 .then(unittest.expectAsync1(((api.PullResponse response) { |
1284 checkPullResponse(response); | 1307 checkPullResponse(response); |
1285 }))); | 1308 }))); |
1286 }); | 1309 }); |
1287 | 1310 |
1288 unittest.test("method--setIamPolicy", () { | 1311 unittest.test("method--setIamPolicy", () { |
1289 | |
1290 var mock = new HttpServerMock(); | 1312 var mock = new HttpServerMock(); |
1291 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 1313 api.ProjectsSubscriptionsResourceApi res = |
| 1314 new api.PubsubApi(mock).projects.subscriptions; |
1292 var arg_request = buildSetIamPolicyRequest(); | 1315 var arg_request = buildSetIamPolicyRequest(); |
1293 var arg_resource = "foo"; | 1316 var arg_resource = "foo"; |
1294 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1317 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1295 var obj = new api.SetIamPolicyRequest.fromJson(json); | 1318 var obj = new api.SetIamPolicyRequest.fromJson(json); |
1296 checkSetIamPolicyRequest(obj); | 1319 checkSetIamPolicyRequest(obj); |
1297 | 1320 |
1298 var path = (req.url).path; | 1321 var path = (req.url).path; |
1299 var pathOffset = 0; | 1322 var pathOffset = 0; |
1300 var index; | 1323 var index; |
1301 var subPart; | 1324 var subPart; |
1302 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1325 unittest.expect( |
| 1326 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1303 pathOffset += 1; | 1327 pathOffset += 1; |
1304 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1328 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1329 unittest.equals("v1beta2/")); |
1305 pathOffset += 8; | 1330 pathOffset += 8; |
1306 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1331 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1307 | 1332 |
1308 var query = (req.url).query; | 1333 var query = (req.url).query; |
1309 var queryOffset = 0; | 1334 var queryOffset = 0; |
1310 var queryMap = {}; | 1335 var queryMap = {}; |
1311 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1336 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1312 parseBool(n) { | 1337 parseBool(n) { |
1313 if (n == "true") return true; | 1338 if (n == "true") return true; |
1314 if (n == "false") return false; | 1339 if (n == "false") return false; |
1315 if (n == null) return null; | 1340 if (n == null) return null; |
1316 throw new core.ArgumentError("Invalid boolean: $n"); | 1341 throw new core.ArgumentError("Invalid boolean: $n"); |
1317 } | 1342 } |
| 1343 |
1318 if (query.length > 0) { | 1344 if (query.length > 0) { |
1319 for (var part in query.split("&")) { | 1345 for (var part in query.split("&")) { |
1320 var keyvalue = part.split("="); | 1346 var keyvalue = part.split("="); |
1321 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1347 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1348 core.Uri.decodeQueryComponent(keyvalue[1])); |
1322 } | 1349 } |
1323 } | 1350 } |
1324 | 1351 |
1325 | |
1326 var h = { | 1352 var h = { |
1327 "content-type" : "application/json; charset=utf-8", | 1353 "content-type": "application/json; charset=utf-8", |
1328 }; | 1354 }; |
1329 var resp = convert.JSON.encode(buildPolicy()); | 1355 var resp = convert.JSON.encode(buildPolicy()); |
1330 return new async.Future.value(stringResponse(200, h, resp)); | 1356 return new async.Future.value(stringResponse(200, h, resp)); |
1331 }), true); | 1357 }), true); |
1332 res.setIamPolicy(arg_request, arg_resource).then(unittest.expectAsync1(((a
pi.Policy response) { | 1358 res |
| 1359 .setIamPolicy(arg_request, arg_resource) |
| 1360 .then(unittest.expectAsync1(((api.Policy response) { |
1333 checkPolicy(response); | 1361 checkPolicy(response); |
1334 }))); | 1362 }))); |
1335 }); | 1363 }); |
1336 | 1364 |
1337 unittest.test("method--testIamPermissions", () { | 1365 unittest.test("method--testIamPermissions", () { |
1338 | |
1339 var mock = new HttpServerMock(); | 1366 var mock = new HttpServerMock(); |
1340 api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).project
s.subscriptions; | 1367 api.ProjectsSubscriptionsResourceApi res = |
| 1368 new api.PubsubApi(mock).projects.subscriptions; |
1341 var arg_request = buildTestIamPermissionsRequest(); | 1369 var arg_request = buildTestIamPermissionsRequest(); |
1342 var arg_resource = "foo"; | 1370 var arg_resource = "foo"; |
1343 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1371 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1344 var obj = new api.TestIamPermissionsRequest.fromJson(json); | 1372 var obj = new api.TestIamPermissionsRequest.fromJson(json); |
1345 checkTestIamPermissionsRequest(obj); | 1373 checkTestIamPermissionsRequest(obj); |
1346 | 1374 |
1347 var path = (req.url).path; | 1375 var path = (req.url).path; |
1348 var pathOffset = 0; | 1376 var pathOffset = 0; |
1349 var index; | 1377 var index; |
1350 var subPart; | 1378 var subPart; |
1351 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1379 unittest.expect( |
| 1380 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1352 pathOffset += 1; | 1381 pathOffset += 1; |
1353 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1382 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1383 unittest.equals("v1beta2/")); |
1354 pathOffset += 8; | 1384 pathOffset += 8; |
1355 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1385 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1356 | 1386 |
1357 var query = (req.url).query; | 1387 var query = (req.url).query; |
1358 var queryOffset = 0; | 1388 var queryOffset = 0; |
1359 var queryMap = {}; | 1389 var queryMap = {}; |
1360 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1390 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1361 parseBool(n) { | 1391 parseBool(n) { |
1362 if (n == "true") return true; | 1392 if (n == "true") return true; |
1363 if (n == "false") return false; | 1393 if (n == "false") return false; |
1364 if (n == null) return null; | 1394 if (n == null) return null; |
1365 throw new core.ArgumentError("Invalid boolean: $n"); | 1395 throw new core.ArgumentError("Invalid boolean: $n"); |
1366 } | 1396 } |
| 1397 |
1367 if (query.length > 0) { | 1398 if (query.length > 0) { |
1368 for (var part in query.split("&")) { | 1399 for (var part in query.split("&")) { |
1369 var keyvalue = part.split("="); | 1400 var keyvalue = part.split("="); |
1370 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1401 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1402 core.Uri.decodeQueryComponent(keyvalue[1])); |
1371 } | 1403 } |
1372 } | 1404 } |
1373 | 1405 |
1374 | |
1375 var h = { | 1406 var h = { |
1376 "content-type" : "application/json; charset=utf-8", | 1407 "content-type": "application/json; charset=utf-8", |
1377 }; | 1408 }; |
1378 var resp = convert.JSON.encode(buildTestIamPermissionsResponse()); | 1409 var resp = convert.JSON.encode(buildTestIamPermissionsResponse()); |
1379 return new async.Future.value(stringResponse(200, h, resp)); | 1410 return new async.Future.value(stringResponse(200, h, resp)); |
1380 }), true); | 1411 }), true); |
1381 res.testIamPermissions(arg_request, arg_resource).then(unittest.expectAsyn
c1(((api.TestIamPermissionsResponse response) { | 1412 res.testIamPermissions(arg_request, arg_resource).then( |
| 1413 unittest.expectAsync1(((api.TestIamPermissionsResponse response) { |
1382 checkTestIamPermissionsResponse(response); | 1414 checkTestIamPermissionsResponse(response); |
1383 }))); | 1415 }))); |
1384 }); | 1416 }); |
1385 | |
1386 }); | 1417 }); |
1387 | 1418 |
1388 | |
1389 unittest.group("resource-ProjectsTopicsResourceApi", () { | 1419 unittest.group("resource-ProjectsTopicsResourceApi", () { |
1390 unittest.test("method--create", () { | 1420 unittest.test("method--create", () { |
1391 | |
1392 var mock = new HttpServerMock(); | 1421 var mock = new HttpServerMock(); |
1393 api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topic
s; | 1422 api.ProjectsTopicsResourceApi res = |
| 1423 new api.PubsubApi(mock).projects.topics; |
1394 var arg_request = buildTopic(); | 1424 var arg_request = buildTopic(); |
1395 var arg_name = "foo"; | 1425 var arg_name = "foo"; |
1396 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1426 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1397 var obj = new api.Topic.fromJson(json); | 1427 var obj = new api.Topic.fromJson(json); |
1398 checkTopic(obj); | 1428 checkTopic(obj); |
1399 | 1429 |
1400 var path = (req.url).path; | 1430 var path = (req.url).path; |
1401 var pathOffset = 0; | 1431 var pathOffset = 0; |
1402 var index; | 1432 var index; |
1403 var subPart; | 1433 var subPart; |
1404 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1434 unittest.expect( |
| 1435 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1405 pathOffset += 1; | 1436 pathOffset += 1; |
1406 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1437 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1438 unittest.equals("v1beta2/")); |
1407 pathOffset += 8; | 1439 pathOffset += 8; |
1408 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1440 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1409 | 1441 |
1410 var query = (req.url).query; | 1442 var query = (req.url).query; |
1411 var queryOffset = 0; | 1443 var queryOffset = 0; |
1412 var queryMap = {}; | 1444 var queryMap = {}; |
1413 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1445 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1414 parseBool(n) { | 1446 parseBool(n) { |
1415 if (n == "true") return true; | 1447 if (n == "true") return true; |
1416 if (n == "false") return false; | 1448 if (n == "false") return false; |
1417 if (n == null) return null; | 1449 if (n == null) return null; |
1418 throw new core.ArgumentError("Invalid boolean: $n"); | 1450 throw new core.ArgumentError("Invalid boolean: $n"); |
1419 } | 1451 } |
| 1452 |
1420 if (query.length > 0) { | 1453 if (query.length > 0) { |
1421 for (var part in query.split("&")) { | 1454 for (var part in query.split("&")) { |
1422 var keyvalue = part.split("="); | 1455 var keyvalue = part.split("="); |
1423 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1456 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1457 core.Uri.decodeQueryComponent(keyvalue[1])); |
1424 } | 1458 } |
1425 } | 1459 } |
1426 | 1460 |
1427 | |
1428 var h = { | 1461 var h = { |
1429 "content-type" : "application/json; charset=utf-8", | 1462 "content-type": "application/json; charset=utf-8", |
1430 }; | 1463 }; |
1431 var resp = convert.JSON.encode(buildTopic()); | 1464 var resp = convert.JSON.encode(buildTopic()); |
1432 return new async.Future.value(stringResponse(200, h, resp)); | 1465 return new async.Future.value(stringResponse(200, h, resp)); |
1433 }), true); | 1466 }), true); |
1434 res.create(arg_request, arg_name).then(unittest.expectAsync1(((api.Topic r
esponse) { | 1467 res |
| 1468 .create(arg_request, arg_name) |
| 1469 .then(unittest.expectAsync1(((api.Topic response) { |
1435 checkTopic(response); | 1470 checkTopic(response); |
1436 }))); | 1471 }))); |
1437 }); | 1472 }); |
1438 | 1473 |
1439 unittest.test("method--delete", () { | 1474 unittest.test("method--delete", () { |
1440 | |
1441 var mock = new HttpServerMock(); | 1475 var mock = new HttpServerMock(); |
1442 api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topic
s; | 1476 api.ProjectsTopicsResourceApi res = |
| 1477 new api.PubsubApi(mock).projects.topics; |
1443 var arg_topic = "foo"; | 1478 var arg_topic = "foo"; |
1444 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1479 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1445 var path = (req.url).path; | 1480 var path = (req.url).path; |
1446 var pathOffset = 0; | 1481 var pathOffset = 0; |
1447 var index; | 1482 var index; |
1448 var subPart; | 1483 var subPart; |
1449 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1484 unittest.expect( |
| 1485 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1450 pathOffset += 1; | 1486 pathOffset += 1; |
1451 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1487 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1488 unittest.equals("v1beta2/")); |
1452 pathOffset += 8; | 1489 pathOffset += 8; |
1453 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1490 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1454 | 1491 |
1455 var query = (req.url).query; | 1492 var query = (req.url).query; |
1456 var queryOffset = 0; | 1493 var queryOffset = 0; |
1457 var queryMap = {}; | 1494 var queryMap = {}; |
1458 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1495 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1459 parseBool(n) { | 1496 parseBool(n) { |
1460 if (n == "true") return true; | 1497 if (n == "true") return true; |
1461 if (n == "false") return false; | 1498 if (n == "false") return false; |
1462 if (n == null) return null; | 1499 if (n == null) return null; |
1463 throw new core.ArgumentError("Invalid boolean: $n"); | 1500 throw new core.ArgumentError("Invalid boolean: $n"); |
1464 } | 1501 } |
| 1502 |
1465 if (query.length > 0) { | 1503 if (query.length > 0) { |
1466 for (var part in query.split("&")) { | 1504 for (var part in query.split("&")) { |
1467 var keyvalue = part.split("="); | 1505 var keyvalue = part.split("="); |
1468 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1506 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1507 core.Uri.decodeQueryComponent(keyvalue[1])); |
1469 } | 1508 } |
1470 } | 1509 } |
1471 | 1510 |
1472 | |
1473 var h = { | 1511 var h = { |
1474 "content-type" : "application/json; charset=utf-8", | 1512 "content-type": "application/json; charset=utf-8", |
1475 }; | 1513 }; |
1476 var resp = convert.JSON.encode(buildEmpty()); | 1514 var resp = convert.JSON.encode(buildEmpty()); |
1477 return new async.Future.value(stringResponse(200, h, resp)); | 1515 return new async.Future.value(stringResponse(200, h, resp)); |
1478 }), true); | 1516 }), true); |
1479 res.delete(arg_topic).then(unittest.expectAsync1(((api.Empty response) { | 1517 res.delete(arg_topic).then(unittest.expectAsync1(((api.Empty response) { |
1480 checkEmpty(response); | 1518 checkEmpty(response); |
1481 }))); | 1519 }))); |
1482 }); | 1520 }); |
1483 | 1521 |
1484 unittest.test("method--get", () { | 1522 unittest.test("method--get", () { |
1485 | |
1486 var mock = new HttpServerMock(); | 1523 var mock = new HttpServerMock(); |
1487 api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topic
s; | 1524 api.ProjectsTopicsResourceApi res = |
| 1525 new api.PubsubApi(mock).projects.topics; |
1488 var arg_topic = "foo"; | 1526 var arg_topic = "foo"; |
1489 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1527 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1490 var path = (req.url).path; | 1528 var path = (req.url).path; |
1491 var pathOffset = 0; | 1529 var pathOffset = 0; |
1492 var index; | 1530 var index; |
1493 var subPart; | 1531 var subPart; |
1494 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1532 unittest.expect( |
| 1533 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1495 pathOffset += 1; | 1534 pathOffset += 1; |
1496 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1535 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1536 unittest.equals("v1beta2/")); |
1497 pathOffset += 8; | 1537 pathOffset += 8; |
1498 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1538 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1499 | 1539 |
1500 var query = (req.url).query; | 1540 var query = (req.url).query; |
1501 var queryOffset = 0; | 1541 var queryOffset = 0; |
1502 var queryMap = {}; | 1542 var queryMap = {}; |
1503 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1543 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1504 parseBool(n) { | 1544 parseBool(n) { |
1505 if (n == "true") return true; | 1545 if (n == "true") return true; |
1506 if (n == "false") return false; | 1546 if (n == "false") return false; |
1507 if (n == null) return null; | 1547 if (n == null) return null; |
1508 throw new core.ArgumentError("Invalid boolean: $n"); | 1548 throw new core.ArgumentError("Invalid boolean: $n"); |
1509 } | 1549 } |
| 1550 |
1510 if (query.length > 0) { | 1551 if (query.length > 0) { |
1511 for (var part in query.split("&")) { | 1552 for (var part in query.split("&")) { |
1512 var keyvalue = part.split("="); | 1553 var keyvalue = part.split("="); |
1513 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1554 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1555 core.Uri.decodeQueryComponent(keyvalue[1])); |
1514 } | 1556 } |
1515 } | 1557 } |
1516 | 1558 |
1517 | |
1518 var h = { | 1559 var h = { |
1519 "content-type" : "application/json; charset=utf-8", | 1560 "content-type": "application/json; charset=utf-8", |
1520 }; | 1561 }; |
1521 var resp = convert.JSON.encode(buildTopic()); | 1562 var resp = convert.JSON.encode(buildTopic()); |
1522 return new async.Future.value(stringResponse(200, h, resp)); | 1563 return new async.Future.value(stringResponse(200, h, resp)); |
1523 }), true); | 1564 }), true); |
1524 res.get(arg_topic).then(unittest.expectAsync1(((api.Topic response) { | 1565 res.get(arg_topic).then(unittest.expectAsync1(((api.Topic response) { |
1525 checkTopic(response); | 1566 checkTopic(response); |
1526 }))); | 1567 }))); |
1527 }); | 1568 }); |
1528 | 1569 |
1529 unittest.test("method--getIamPolicy", () { | 1570 unittest.test("method--getIamPolicy", () { |
1530 | |
1531 var mock = new HttpServerMock(); | 1571 var mock = new HttpServerMock(); |
1532 api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topic
s; | 1572 api.ProjectsTopicsResourceApi res = |
| 1573 new api.PubsubApi(mock).projects.topics; |
1533 var arg_resource = "foo"; | 1574 var arg_resource = "foo"; |
1534 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1575 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1535 var path = (req.url).path; | 1576 var path = (req.url).path; |
1536 var pathOffset = 0; | 1577 var pathOffset = 0; |
1537 var index; | 1578 var index; |
1538 var subPart; | 1579 var subPart; |
1539 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1580 unittest.expect( |
| 1581 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1540 pathOffset += 1; | 1582 pathOffset += 1; |
1541 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1583 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1584 unittest.equals("v1beta2/")); |
1542 pathOffset += 8; | 1585 pathOffset += 8; |
1543 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1586 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1544 | 1587 |
1545 var query = (req.url).query; | 1588 var query = (req.url).query; |
1546 var queryOffset = 0; | 1589 var queryOffset = 0; |
1547 var queryMap = {}; | 1590 var queryMap = {}; |
1548 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1591 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1549 parseBool(n) { | 1592 parseBool(n) { |
1550 if (n == "true") return true; | 1593 if (n == "true") return true; |
1551 if (n == "false") return false; | 1594 if (n == "false") return false; |
1552 if (n == null) return null; | 1595 if (n == null) return null; |
1553 throw new core.ArgumentError("Invalid boolean: $n"); | 1596 throw new core.ArgumentError("Invalid boolean: $n"); |
1554 } | 1597 } |
| 1598 |
1555 if (query.length > 0) { | 1599 if (query.length > 0) { |
1556 for (var part in query.split("&")) { | 1600 for (var part in query.split("&")) { |
1557 var keyvalue = part.split("="); | 1601 var keyvalue = part.split("="); |
1558 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1602 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1603 core.Uri.decodeQueryComponent(keyvalue[1])); |
1559 } | 1604 } |
1560 } | 1605 } |
1561 | 1606 |
1562 | |
1563 var h = { | 1607 var h = { |
1564 "content-type" : "application/json; charset=utf-8", | 1608 "content-type": "application/json; charset=utf-8", |
1565 }; | 1609 }; |
1566 var resp = convert.JSON.encode(buildPolicy()); | 1610 var resp = convert.JSON.encode(buildPolicy()); |
1567 return new async.Future.value(stringResponse(200, h, resp)); | 1611 return new async.Future.value(stringResponse(200, h, resp)); |
1568 }), true); | 1612 }), true); |
1569 res.getIamPolicy(arg_resource).then(unittest.expectAsync1(((api.Policy res
ponse) { | 1613 res |
| 1614 .getIamPolicy(arg_resource) |
| 1615 .then(unittest.expectAsync1(((api.Policy response) { |
1570 checkPolicy(response); | 1616 checkPolicy(response); |
1571 }))); | 1617 }))); |
1572 }); | 1618 }); |
1573 | 1619 |
1574 unittest.test("method--list", () { | 1620 unittest.test("method--list", () { |
1575 | |
1576 var mock = new HttpServerMock(); | 1621 var mock = new HttpServerMock(); |
1577 api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topic
s; | 1622 api.ProjectsTopicsResourceApi res = |
| 1623 new api.PubsubApi(mock).projects.topics; |
1578 var arg_project = "foo"; | 1624 var arg_project = "foo"; |
1579 var arg_pageToken = "foo"; | 1625 var arg_pageToken = "foo"; |
1580 var arg_pageSize = 42; | 1626 var arg_pageSize = 42; |
1581 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1627 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1582 var path = (req.url).path; | 1628 var path = (req.url).path; |
1583 var pathOffset = 0; | 1629 var pathOffset = 0; |
1584 var index; | 1630 var index; |
1585 var subPart; | 1631 var subPart; |
1586 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1632 unittest.expect( |
| 1633 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1587 pathOffset += 1; | 1634 pathOffset += 1; |
1588 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1635 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1636 unittest.equals("v1beta2/")); |
1589 pathOffset += 8; | 1637 pathOffset += 8; |
1590 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1638 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1591 | 1639 |
1592 var query = (req.url).query; | 1640 var query = (req.url).query; |
1593 var queryOffset = 0; | 1641 var queryOffset = 0; |
1594 var queryMap = {}; | 1642 var queryMap = {}; |
1595 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1643 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1596 parseBool(n) { | 1644 parseBool(n) { |
1597 if (n == "true") return true; | 1645 if (n == "true") return true; |
1598 if (n == "false") return false; | 1646 if (n == "false") return false; |
1599 if (n == null) return null; | 1647 if (n == null) return null; |
1600 throw new core.ArgumentError("Invalid boolean: $n"); | 1648 throw new core.ArgumentError("Invalid boolean: $n"); |
1601 } | 1649 } |
| 1650 |
1602 if (query.length > 0) { | 1651 if (query.length > 0) { |
1603 for (var part in query.split("&")) { | 1652 for (var part in query.split("&")) { |
1604 var keyvalue = part.split("="); | 1653 var keyvalue = part.split("="); |
1605 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1654 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1655 core.Uri.decodeQueryComponent(keyvalue[1])); |
1606 } | 1656 } |
1607 } | 1657 } |
1608 unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageTok
en)); | 1658 unittest.expect( |
1609 unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equ
als(arg_pageSize)); | 1659 queryMap["pageToken"].first, unittest.equals(arg_pageToken)); |
1610 | 1660 unittest.expect(core.int.parse(queryMap["pageSize"].first), |
| 1661 unittest.equals(arg_pageSize)); |
1611 | 1662 |
1612 var h = { | 1663 var h = { |
1613 "content-type" : "application/json; charset=utf-8", | 1664 "content-type": "application/json; charset=utf-8", |
1614 }; | 1665 }; |
1615 var resp = convert.JSON.encode(buildListTopicsResponse()); | 1666 var resp = convert.JSON.encode(buildListTopicsResponse()); |
1616 return new async.Future.value(stringResponse(200, h, resp)); | 1667 return new async.Future.value(stringResponse(200, h, resp)); |
1617 }), true); | 1668 }), true); |
1618 res.list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize).th
en(unittest.expectAsync1(((api.ListTopicsResponse response) { | 1669 res |
| 1670 .list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize) |
| 1671 .then(unittest.expectAsync1(((api.ListTopicsResponse response) { |
1619 checkListTopicsResponse(response); | 1672 checkListTopicsResponse(response); |
1620 }))); | 1673 }))); |
1621 }); | 1674 }); |
1622 | 1675 |
1623 unittest.test("method--publish", () { | 1676 unittest.test("method--publish", () { |
1624 | |
1625 var mock = new HttpServerMock(); | 1677 var mock = new HttpServerMock(); |
1626 api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topic
s; | 1678 api.ProjectsTopicsResourceApi res = |
| 1679 new api.PubsubApi(mock).projects.topics; |
1627 var arg_request = buildPublishRequest(); | 1680 var arg_request = buildPublishRequest(); |
1628 var arg_topic = "foo"; | 1681 var arg_topic = "foo"; |
1629 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1682 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1630 var obj = new api.PublishRequest.fromJson(json); | 1683 var obj = new api.PublishRequest.fromJson(json); |
1631 checkPublishRequest(obj); | 1684 checkPublishRequest(obj); |
1632 | 1685 |
1633 var path = (req.url).path; | 1686 var path = (req.url).path; |
1634 var pathOffset = 0; | 1687 var pathOffset = 0; |
1635 var index; | 1688 var index; |
1636 var subPart; | 1689 var subPart; |
1637 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1690 unittest.expect( |
| 1691 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1638 pathOffset += 1; | 1692 pathOffset += 1; |
1639 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1693 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1694 unittest.equals("v1beta2/")); |
1640 pathOffset += 8; | 1695 pathOffset += 8; |
1641 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1696 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1642 | 1697 |
1643 var query = (req.url).query; | 1698 var query = (req.url).query; |
1644 var queryOffset = 0; | 1699 var queryOffset = 0; |
1645 var queryMap = {}; | 1700 var queryMap = {}; |
1646 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1701 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1647 parseBool(n) { | 1702 parseBool(n) { |
1648 if (n == "true") return true; | 1703 if (n == "true") return true; |
1649 if (n == "false") return false; | 1704 if (n == "false") return false; |
1650 if (n == null) return null; | 1705 if (n == null) return null; |
1651 throw new core.ArgumentError("Invalid boolean: $n"); | 1706 throw new core.ArgumentError("Invalid boolean: $n"); |
1652 } | 1707 } |
| 1708 |
1653 if (query.length > 0) { | 1709 if (query.length > 0) { |
1654 for (var part in query.split("&")) { | 1710 for (var part in query.split("&")) { |
1655 var keyvalue = part.split("="); | 1711 var keyvalue = part.split("="); |
1656 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1712 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1713 core.Uri.decodeQueryComponent(keyvalue[1])); |
1657 } | 1714 } |
1658 } | 1715 } |
1659 | 1716 |
1660 | |
1661 var h = { | 1717 var h = { |
1662 "content-type" : "application/json; charset=utf-8", | 1718 "content-type": "application/json; charset=utf-8", |
1663 }; | 1719 }; |
1664 var resp = convert.JSON.encode(buildPublishResponse()); | 1720 var resp = convert.JSON.encode(buildPublishResponse()); |
1665 return new async.Future.value(stringResponse(200, h, resp)); | 1721 return new async.Future.value(stringResponse(200, h, resp)); |
1666 }), true); | 1722 }), true); |
1667 res.publish(arg_request, arg_topic).then(unittest.expectAsync1(((api.Publi
shResponse response) { | 1723 res |
| 1724 .publish(arg_request, arg_topic) |
| 1725 .then(unittest.expectAsync1(((api.PublishResponse response) { |
1668 checkPublishResponse(response); | 1726 checkPublishResponse(response); |
1669 }))); | 1727 }))); |
1670 }); | 1728 }); |
1671 | 1729 |
1672 unittest.test("method--setIamPolicy", () { | 1730 unittest.test("method--setIamPolicy", () { |
1673 | |
1674 var mock = new HttpServerMock(); | 1731 var mock = new HttpServerMock(); |
1675 api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topic
s; | 1732 api.ProjectsTopicsResourceApi res = |
| 1733 new api.PubsubApi(mock).projects.topics; |
1676 var arg_request = buildSetIamPolicyRequest(); | 1734 var arg_request = buildSetIamPolicyRequest(); |
1677 var arg_resource = "foo"; | 1735 var arg_resource = "foo"; |
1678 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1736 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1679 var obj = new api.SetIamPolicyRequest.fromJson(json); | 1737 var obj = new api.SetIamPolicyRequest.fromJson(json); |
1680 checkSetIamPolicyRequest(obj); | 1738 checkSetIamPolicyRequest(obj); |
1681 | 1739 |
1682 var path = (req.url).path; | 1740 var path = (req.url).path; |
1683 var pathOffset = 0; | 1741 var pathOffset = 0; |
1684 var index; | 1742 var index; |
1685 var subPart; | 1743 var subPart; |
1686 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1744 unittest.expect( |
| 1745 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1687 pathOffset += 1; | 1746 pathOffset += 1; |
1688 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1747 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1748 unittest.equals("v1beta2/")); |
1689 pathOffset += 8; | 1749 pathOffset += 8; |
1690 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1750 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1691 | 1751 |
1692 var query = (req.url).query; | 1752 var query = (req.url).query; |
1693 var queryOffset = 0; | 1753 var queryOffset = 0; |
1694 var queryMap = {}; | 1754 var queryMap = {}; |
1695 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1755 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1696 parseBool(n) { | 1756 parseBool(n) { |
1697 if (n == "true") return true; | 1757 if (n == "true") return true; |
1698 if (n == "false") return false; | 1758 if (n == "false") return false; |
1699 if (n == null) return null; | 1759 if (n == null) return null; |
1700 throw new core.ArgumentError("Invalid boolean: $n"); | 1760 throw new core.ArgumentError("Invalid boolean: $n"); |
1701 } | 1761 } |
| 1762 |
1702 if (query.length > 0) { | 1763 if (query.length > 0) { |
1703 for (var part in query.split("&")) { | 1764 for (var part in query.split("&")) { |
1704 var keyvalue = part.split("="); | 1765 var keyvalue = part.split("="); |
1705 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1766 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1767 core.Uri.decodeQueryComponent(keyvalue[1])); |
1706 } | 1768 } |
1707 } | 1769 } |
1708 | 1770 |
1709 | |
1710 var h = { | 1771 var h = { |
1711 "content-type" : "application/json; charset=utf-8", | 1772 "content-type": "application/json; charset=utf-8", |
1712 }; | 1773 }; |
1713 var resp = convert.JSON.encode(buildPolicy()); | 1774 var resp = convert.JSON.encode(buildPolicy()); |
1714 return new async.Future.value(stringResponse(200, h, resp)); | 1775 return new async.Future.value(stringResponse(200, h, resp)); |
1715 }), true); | 1776 }), true); |
1716 res.setIamPolicy(arg_request, arg_resource).then(unittest.expectAsync1(((a
pi.Policy response) { | 1777 res |
| 1778 .setIamPolicy(arg_request, arg_resource) |
| 1779 .then(unittest.expectAsync1(((api.Policy response) { |
1717 checkPolicy(response); | 1780 checkPolicy(response); |
1718 }))); | 1781 }))); |
1719 }); | 1782 }); |
1720 | 1783 |
1721 unittest.test("method--testIamPermissions", () { | 1784 unittest.test("method--testIamPermissions", () { |
1722 | |
1723 var mock = new HttpServerMock(); | 1785 var mock = new HttpServerMock(); |
1724 api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topic
s; | 1786 api.ProjectsTopicsResourceApi res = |
| 1787 new api.PubsubApi(mock).projects.topics; |
1725 var arg_request = buildTestIamPermissionsRequest(); | 1788 var arg_request = buildTestIamPermissionsRequest(); |
1726 var arg_resource = "foo"; | 1789 var arg_resource = "foo"; |
1727 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1790 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1728 var obj = new api.TestIamPermissionsRequest.fromJson(json); | 1791 var obj = new api.TestIamPermissionsRequest.fromJson(json); |
1729 checkTestIamPermissionsRequest(obj); | 1792 checkTestIamPermissionsRequest(obj); |
1730 | 1793 |
1731 var path = (req.url).path; | 1794 var path = (req.url).path; |
1732 var pathOffset = 0; | 1795 var pathOffset = 0; |
1733 var index; | 1796 var index; |
1734 var subPart; | 1797 var subPart; |
1735 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1798 unittest.expect( |
| 1799 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1736 pathOffset += 1; | 1800 pathOffset += 1; |
1737 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1801 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1802 unittest.equals("v1beta2/")); |
1738 pathOffset += 8; | 1803 pathOffset += 8; |
1739 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1804 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1740 | 1805 |
1741 var query = (req.url).query; | 1806 var query = (req.url).query; |
1742 var queryOffset = 0; | 1807 var queryOffset = 0; |
1743 var queryMap = {}; | 1808 var queryMap = {}; |
1744 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1809 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1745 parseBool(n) { | 1810 parseBool(n) { |
1746 if (n == "true") return true; | 1811 if (n == "true") return true; |
1747 if (n == "false") return false; | 1812 if (n == "false") return false; |
1748 if (n == null) return null; | 1813 if (n == null) return null; |
1749 throw new core.ArgumentError("Invalid boolean: $n"); | 1814 throw new core.ArgumentError("Invalid boolean: $n"); |
1750 } | 1815 } |
| 1816 |
1751 if (query.length > 0) { | 1817 if (query.length > 0) { |
1752 for (var part in query.split("&")) { | 1818 for (var part in query.split("&")) { |
1753 var keyvalue = part.split("="); | 1819 var keyvalue = part.split("="); |
1754 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1820 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1821 core.Uri.decodeQueryComponent(keyvalue[1])); |
1755 } | 1822 } |
1756 } | 1823 } |
1757 | 1824 |
1758 | |
1759 var h = { | 1825 var h = { |
1760 "content-type" : "application/json; charset=utf-8", | 1826 "content-type": "application/json; charset=utf-8", |
1761 }; | 1827 }; |
1762 var resp = convert.JSON.encode(buildTestIamPermissionsResponse()); | 1828 var resp = convert.JSON.encode(buildTestIamPermissionsResponse()); |
1763 return new async.Future.value(stringResponse(200, h, resp)); | 1829 return new async.Future.value(stringResponse(200, h, resp)); |
1764 }), true); | 1830 }), true); |
1765 res.testIamPermissions(arg_request, arg_resource).then(unittest.expectAsyn
c1(((api.TestIamPermissionsResponse response) { | 1831 res.testIamPermissions(arg_request, arg_resource).then( |
| 1832 unittest.expectAsync1(((api.TestIamPermissionsResponse response) { |
1766 checkTestIamPermissionsResponse(response); | 1833 checkTestIamPermissionsResponse(response); |
1767 }))); | 1834 }))); |
1768 }); | 1835 }); |
1769 | |
1770 }); | 1836 }); |
1771 | 1837 |
1772 | |
1773 unittest.group("resource-ProjectsTopicsSubscriptionsResourceApi", () { | 1838 unittest.group("resource-ProjectsTopicsSubscriptionsResourceApi", () { |
1774 unittest.test("method--list", () { | 1839 unittest.test("method--list", () { |
1775 | |
1776 var mock = new HttpServerMock(); | 1840 var mock = new HttpServerMock(); |
1777 api.ProjectsTopicsSubscriptionsResourceApi res = new api.PubsubApi(mock).p
rojects.topics.subscriptions; | 1841 api.ProjectsTopicsSubscriptionsResourceApi res = |
| 1842 new api.PubsubApi(mock).projects.topics.subscriptions; |
1778 var arg_topic = "foo"; | 1843 var arg_topic = "foo"; |
1779 var arg_pageToken = "foo"; | 1844 var arg_pageToken = "foo"; |
1780 var arg_pageSize = 42; | 1845 var arg_pageSize = 42; |
1781 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { | 1846 mock.register(unittest.expectAsync2((http.BaseRequest req, json) { |
1782 var path = (req.url).path; | 1847 var path = (req.url).path; |
1783 var pathOffset = 0; | 1848 var pathOffset = 0; |
1784 var index; | 1849 var index; |
1785 var subPart; | 1850 var subPart; |
1786 unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equ
als("/")); | 1851 unittest.expect( |
| 1852 path.substring(pathOffset, pathOffset + 1), unittest.equals("/")); |
1787 pathOffset += 1; | 1853 pathOffset += 1; |
1788 unittest.expect(path.substring(pathOffset, pathOffset + 8), unittest.equ
als("v1beta2/")); | 1854 unittest.expect(path.substring(pathOffset, pathOffset + 8), |
| 1855 unittest.equals("v1beta2/")); |
1789 pathOffset += 8; | 1856 pathOffset += 8; |
1790 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; | 1857 // NOTE: We cannot test reserved expansions due to the inability to reve
rse the operation; |
1791 | 1858 |
1792 var query = (req.url).query; | 1859 var query = (req.url).query; |
1793 var queryOffset = 0; | 1860 var queryOffset = 0; |
1794 var queryMap = {}; | 1861 var queryMap = {}; |
1795 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); | 1862 addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v); |
1796 parseBool(n) { | 1863 parseBool(n) { |
1797 if (n == "true") return true; | 1864 if (n == "true") return true; |
1798 if (n == "false") return false; | 1865 if (n == "false") return false; |
1799 if (n == null) return null; | 1866 if (n == null) return null; |
1800 throw new core.ArgumentError("Invalid boolean: $n"); | 1867 throw new core.ArgumentError("Invalid boolean: $n"); |
1801 } | 1868 } |
| 1869 |
1802 if (query.length > 0) { | 1870 if (query.length > 0) { |
1803 for (var part in query.split("&")) { | 1871 for (var part in query.split("&")) { |
1804 var keyvalue = part.split("="); | 1872 var keyvalue = part.split("="); |
1805 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.d
ecodeQueryComponent(keyvalue[1])); | 1873 addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), |
| 1874 core.Uri.decodeQueryComponent(keyvalue[1])); |
1806 } | 1875 } |
1807 } | 1876 } |
1808 unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageTok
en)); | 1877 unittest.expect( |
1809 unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equ
als(arg_pageSize)); | 1878 queryMap["pageToken"].first, unittest.equals(arg_pageToken)); |
1810 | 1879 unittest.expect(core.int.parse(queryMap["pageSize"].first), |
| 1880 unittest.equals(arg_pageSize)); |
1811 | 1881 |
1812 var h = { | 1882 var h = { |
1813 "content-type" : "application/json; charset=utf-8", | 1883 "content-type": "application/json; charset=utf-8", |
1814 }; | 1884 }; |
1815 var resp = convert.JSON.encode(buildListTopicSubscriptionsResponse()); | 1885 var resp = convert.JSON.encode(buildListTopicSubscriptionsResponse()); |
1816 return new async.Future.value(stringResponse(200, h, resp)); | 1886 return new async.Future.value(stringResponse(200, h, resp)); |
1817 }), true); | 1887 }), true); |
1818 res.list(arg_topic, pageToken: arg_pageToken, pageSize: arg_pageSize).then
(unittest.expectAsync1(((api.ListTopicSubscriptionsResponse response) { | 1888 res |
| 1889 .list(arg_topic, pageToken: arg_pageToken, pageSize: arg_pageSize) |
| 1890 .then(unittest |
| 1891 .expectAsync1(((api.ListTopicSubscriptionsResponse response) { |
1819 checkListTopicSubscriptionsResponse(response); | 1892 checkListTopicSubscriptionsResponse(response); |
1820 }))); | 1893 }))); |
1821 }); | 1894 }); |
1822 | |
1823 }); | 1895 }); |
1824 | |
1825 | |
1826 } | 1896 } |
1827 | |
OLD | NEW |