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