Package Diff: google-gax @ 0.25.6 .. 0.26.0

-import { CallSettings } from './gax';

-import { GoogleError } from './GoogleError';

-export interface ArgumentFunction {

- (argument: {}, callback: APICallback): void;

-}

-/**

- * @callback APICallback

- * @param {?Error} error

- * @param {?Object} response

- */

-export declare type APICallback = (err: GoogleError | null, response?: any, next?: {} | null, rawResponse?: {} | null) => void;

-/**

- * @callback APIFunc

- * @param {Object} argument

- * @param {grpc.Metadata} metadata

- * @param {Object} options

- * @param {APICallback} callback

- */

-export declare type APIFunc = (argument: {}, metadata: {}, options: {}, callback: APICallback) => Canceller;

-/**

- * @callback APICall

- * @param {Object} argument

- * @param {CallOptions} callOptions

- * @param {APICallback} callback

- * @return {Promise|Stream|undefined}

- */

-export interface APICall {

- (argument?: {} | null, callOptions?: {} | null, callback?: APICallback): any;

-}

-export declare class Canceller {

- callback?: APICallback;

- cancelFunc?: () => void;

- completed: boolean;

- /**

- * Canceller manages callback, API calls, and cancellation

- * of the API calls.

- * @param {APICallback=} callback

- * The callback to be called asynchronously when the API call

- * finishes.

- * @constructor

- * @property {APICallback} callback

- * The callback function to be called.

- * @private

- */

- constructor(callback?: APICallback);

- /**

- * Cancels the ongoing promise.

- */

- cancel(): void;

- /**

- * Call calls the specified function. Result will be used to fulfill

- * the promise.

- *

- * @param {function(Object, APICallback=)} aFunc

- * A function for an API call.

- * @param {Object} argument

- * A request object.

- */

- call(aFunc: (obj: {}, callback: APICallback) => PromiseCanceller, argument: {}): void;

-}

-export interface CancellablePromise<T = any> extends Promise<T> {

- cancel(): void;

-}

-export declare class PromiseCanceller<T = any> extends Canceller {

- promise: CancellablePromise<T>;

- /**

- * PromiseCanceller is Canceller, but it holds a promise when

- * the API call finishes.

- * @param {Function} PromiseCtor - A constructor for a promise that implements

- * the ES6 specification of promise.

- * @constructor

- * @private

- */

- constructor(PromiseCtor: PromiseConstructor);

-}

-export interface ApiCallOtherArgs {

- options?: {

- deadline?: Date;

- };

- headers?: {};

- metadataBuilder: (abTests?: {}, headers?: {}) => {};

-}

-export interface NormalApiCallerSettings {

- promise: PromiseConstructor;

-}

-/**

- * Creates an API caller for normal methods.

- *

- * @private

- * @constructor

- */

-export declare class NormalApiCaller {

- init(settings: NormalApiCallerSettings, callback: APICallback): PromiseCanceller | Canceller;

- wrap(func: Function): Function;

- call(apiCall: APICall, argument: {}, settings: {}, canceller: PromiseCanceller): void;

- fail(canceller: PromiseCanceller, err: GoogleError): void;

- result(canceller: PromiseCanceller): CancellablePromise<any> | undefined;

-}

-/**

- * Converts an rpc call into an API call governed by the settings.

- *

- * In typical usage, `func` will be a promsie to a callable used to make an rpc

- * request. This will mostly likely be a bound method from a request stub used

- * to make an rpc call. It is not a direct function but a Promise instance,

- * because of its asynchronism (typically, obtaining the auth information).

- *

- * The result is a function which manages the API call with the given settings

- * and the options on the invocation.

- *

- * @param {Promise.<APIFunc>} funcWithAuth - is a promise to be used to make

- * a bare rpc call. This is a Promise instead of a bare function because

- * the rpc call will be involeved with asynchronous authentications.

- * @param {CallSettings} settings - provides the settings for this call

- * @param {Object=} optDescriptor - optionally specify the descriptor for

- * the method call.

- * @return {APICall} func - a bound method on a request stub used

- * to make an rpc call.

- */

-export declare function createApiCall(funcWithAuth: Promise<APIFunc>, settings: CallSettings, optDescriptor?: any): APICall;

-"use strict";

-/*

- * Copyright 2016, Google Inc.

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions are

- * met:

- *

- * * Redistributions of source code must retain the above copyright

- * notice, this list of conditions and the following disclaimer.

- * * Redistributions in binary form must reproduce the above

- * copyright notice, this list of conditions and the following disclaimer

- * in the documentation and/or other materials provided with the

- * distribution.

- * * Neither the name of Google Inc. nor the names of its

- * contributors may be used to endorse or promote products derived from

- * this software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- */

-Object.defineProperty(exports, "__esModule", { value: true });

-/**

- * Provides function wrappers that implement page streaming and retrying.

- */

-const grpc_1 = require("grpc");

-const GoogleError_1 = require("./GoogleError");

-class Canceller {

- /**

- * Canceller manages callback, API calls, and cancellation

- * of the API calls.

- * @param {APICallback=} callback

- * The callback to be called asynchronously when the API call

- * finishes.

- * @constructor

- * @property {APICallback} callback

- * The callback function to be called.

- * @private

- */

- constructor(callback) {

- this.callback = callback;

- this.completed = false;

- }

- /**

- * Cancels the ongoing promise.

- */

- cancel() {

- if (this.completed) {

- return;

- }

- this.completed = true;

- if (this.cancelFunc) {

- this.cancelFunc();

- }

- else {

- const error = new GoogleError_1.GoogleError('cancelled');

- error.code = grpc_1.status.CANCELLED;

- this.callback(error);

- }

- }

- /**

- * Call calls the specified function. Result will be used to fulfill

- * the promise.

- *

- * @param {function(Object, APICallback=)} aFunc

- * A function for an API call.

- * @param {Object} argument

- * A request object.

- */

- call(aFunc, argument) {

- if (this.completed) {

- return;

- }

- // tslint:disable-next-line no-any

- const canceller = aFunc(argument, (...args) => {

- this.completed = true;

- setImmediate(this.callback, ...args);

- });

- this.cancelFunc = () => canceller.cancel();

- }

-}

-exports.Canceller = Canceller;

-// tslint:disable-next-line no-any

-class PromiseCanceller extends Canceller {

- /**

- * PromiseCanceller is Canceller, but it holds a promise when

- * the API call finishes.

- * @param {Function} PromiseCtor - A constructor for a promise that implements

- * the ES6 specification of promise.

- * @constructor

- * @private

- */

- // tslint:disable-next-line variable-name

- constructor(PromiseCtor) {

- super();

- this.promise = new PromiseCtor((resolve, reject) => {

- this.callback = (err, response, next, rawResponse) => {

- if (err) {

- reject(err);

- }

- else {

- resolve([response, next, rawResponse]);

- }

- };

- });

- this.promise.cancel = () => {

- this.cancel();

- };

- }

-}

-exports.PromiseCanceller = PromiseCanceller;

-/**

- * Updates aFunc so that it gets called with the timeout as its final arg.

- *

- * This converts a function, aFunc, into another function with updated deadline.

- *

- * @private

- *

- * @param {APIFunc} aFunc - a function to be updated.

- * @param {number} timeout - to be added to the original function as it final

- * positional arg.

- * @param {Object} otherArgs - the additional arguments to be passed to aFunc.

- * @param {Object=} abTests - the A/B testing key/value pairs.

- * @return {function(Object, APICallback)}

- * the function with other arguments and the timeout.

- */

-function addTimeoutArg(aFunc, timeout, otherArgs, abTests) {

- // TODO: this assumes the other arguments consist of metadata and options,

- // which is specific to gRPC calls. Remove the hidden dependency on gRPC.

- return function timeoutFunc(argument, callback) {

- const now = new Date();

- const options = otherArgs.options || {};

- options.deadline = new Date(now.getTime() + timeout);

- const metadata = otherArgs.metadataBuilder ?

- otherArgs.metadataBuilder(abTests, otherArgs.headers || {}) :

- null;

- return aFunc(argument, metadata, options, callback);

- };

-}

-/**

- * Creates a function equivalent to aFunc, but that retries on certain

- * exceptions.

- *

- * @private

- *

- * @param {APIFunc} aFunc - A function.

- * @param {RetryOptions} retry - Configures the exceptions upon which the

- * function eshould retry, and the parameters to the exponential backoff retry

- * algorithm.

- * @param {Object} otherArgs - the additional arguments to be passed to aFunc.

- * @return {function(Object, APICallback)} A function that will retry.

- */

-function retryable(aFunc, retry, otherArgs) {

- const delayMult = retry.backoffSettings.retryDelayMultiplier;

- const maxDelay = retry.backoffSettings.maxRetryDelayMillis;

- const timeoutMult = retry.backoffSettings.rpcTimeoutMultiplier;

- const maxTimeout = retry.backoffSettings.maxRpcTimeoutMillis;

- let delay = retry.backoffSettings.initialRetryDelayMillis;

- let timeout = retry.backoffSettings.initialRpcTimeoutMillis;

- /**

- * Equivalent to ``aFunc``, but retries upon transient failure.

- *

- * Retrying is done through an exponential backoff algorithm configured

- * by the options in ``retry``.

- * @param {Object} argument The request object.

- * @param {APICallback} callback The callback.

- * @return {function()} cancel function.

- */

- return function retryingFunc(argument, callback) {

- let canceller;

- let timeoutId;

- let now = new Date();

- let deadline;

- if (retry.backoffSettings.totalTimeoutMillis) {

- deadline = now.getTime() + retry.backoffSettings.totalTimeoutMillis;

- }

- let retries = 0;

- const maxRetries = retry.backoffSettings.maxRetries;

- // TODO: define A/B testing values for retry behaviors.

- /** Repeat the API call as long as necessary. */

- function repeat() {

- timeoutId = null;

- if (deadline && now.getTime() >= deadline) {

- const error = new GoogleError_1.GoogleError('Retry total timeout exceeded before any response was received');

- error.code = grpc_1.status.DEADLINE_EXCEEDED;

- callback(error);

- return;

- }

- if (retries && retries >= maxRetries) {

- const error = new GoogleError_1.GoogleError('Exceeded maximum number of retries before any ' +

- 'response was received');

- error.code = grpc_1.status.DEADLINE_EXCEEDED;

- callback(error);

- return;

- }

- retries++;

- const toCall = addTimeoutArg(aFunc, timeout, otherArgs);

- canceller = toCall(argument, (err, response, next, rawResponse) => {

- if (!err) {

- callback(null, response, next, rawResponse);

- return;

- }

- canceller = null;

- if (retry.retryCodes.indexOf(err.code) < 0) {

- err.note = 'Exception occurred in retry method that was ' +

- 'not classified as transient';

- callback(err);

- }

- else {

- const toSleep = Math.random() * delay;

- timeoutId = setTimeout(() => {

- now = new Date();

- delay = Math.min(delay * delayMult, maxDelay);

- timeout = Math.min(timeout * timeoutMult, maxTimeout, deadline - now.getTime());

- repeat();

- }, toSleep);

- }

- });

- }

- if (maxRetries && deadline) {

- const error = new GoogleError_1.GoogleError('Cannot set both totalTimeoutMillis and maxRetries ' +

- 'in backoffSettings.');

- error.code = grpc_1.status.INVALID_ARGUMENT;

- callback(error);

- }

- else {

- repeat();

- }

- return {

- cancel() {

- if (timeoutId) {

- clearTimeout(timeoutId);

- }

- if (canceller) {

- canceller.cancel();

- }

- else {

- const error = new GoogleError_1.GoogleError('cancelled');

- error.code = grpc_1.status.CANCELLED;

- callback(error);

- }

- },

- };

- };

-}

-/**

- * Creates an API caller for normal methods.

- *

- * @private

- * @constructor

- */

-class NormalApiCaller {

- init(settings, callback) {

- if (callback) {

- return new Canceller(callback);

- }

- return new PromiseCanceller(settings.promise);

- }

- wrap(func) {

- return func;

- }

- call(apiCall, argument, settings, canceller) {

- canceller.call(apiCall, argument);

- }

- fail(canceller, err) {

- canceller.callback(err);

- }

- result(canceller) {

- if (canceller.promise) {

- return canceller.promise;

- }

- return;

- }

-}

-exports.NormalApiCaller = NormalApiCaller;

-/**

- * Converts an rpc call into an API call governed by the settings.

- *

- * In typical usage, `func` will be a promsie to a callable used to make an rpc

- * request. This will mostly likely be a bound method from a request stub used

- * to make an rpc call. It is not a direct function but a Promise instance,

- * because of its asynchronism (typically, obtaining the auth information).

- *

- * The result is a function which manages the API call with the given settings

- * and the options on the invocation.

- *

- * @param {Promise.<APIFunc>} funcWithAuth - is a promise to be used to make

- * a bare rpc call. This is a Promise instead of a bare function because

- * the rpc call will be involeved with asynchronous authentications.

- * @param {CallSettings} settings - provides the settings for this call

- * @param {Object=} optDescriptor - optionally specify the descriptor for

- * the method call.

- * @return {APICall} func - a bound method on a request stub used

- * to make an rpc call.

- */

-function createApiCall(funcWithAuth, settings,

-// tslint:disable-next-line no-any

-optDescriptor) {

- const apiCaller = optDescriptor ? optDescriptor.apiCaller(settings) : new NormalApiCaller();

- return function apiCallInner(request, callOptions, callback) {

- const thisSettings = settings.merge(callOptions);

- const status = apiCaller.init(thisSettings, callback);

- funcWithAuth

- .then(func => {

- func = apiCaller.wrap(func);

- const retry = thisSettings.retry;

- if (retry && retry.retryCodes && retry.retryCodes.length > 0) {

- return retryable(func, thisSettings.retry, thisSettings.otherArgs);

- }

- return addTimeoutArg(func, thisSettings.timeout, thisSettings.otherArgs);

- })

- .then(apiCall => {

- apiCaller.call(apiCall, request, thisSettings, status);

- })

- .catch(err => {

- apiCaller.fail(status, err);

- });

- return apiCaller.result(status);

- };

-}

-exports.createApiCall = createApiCall;

-//# sourceMappingURL=apiCallable.js.map

-{"version":3,"file":"apiCallable.js","sourceRoot":"","sources":["../../src/apiCallable.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6BG;;AAEH;;GAEG;AAEH,+BAA4B;AAE5B,+CAA0C;AAuC1C,MAAa,SAAS;IAKpB;;;;;;;;;;OAUG;IACH,YAAY,QAAsB;QAChC,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC;QACzB,IAAI,CAAC,SAAS,GAAG,KAAK,CAAC;IACzB,CAAC;IAED;;OAEG;IACH,MAAM;QACJ,IAAI,IAAI,CAAC,SAAS,EAAE;YAClB,OAAO;SACR;QACD,IAAI,CAAC,SAAS,GAAG,IAAI,CAAC;QACtB,IAAI,IAAI,CAAC,UAAU,EAAE;YACnB,IAAI,CAAC,UAAU,EAAE,CAAC;SACnB;aAAM;YACL,MAAM,KAAK,GAAG,IAAI,yBAAW,CAAC,WAAW,CAAC,CAAC;YAC3C,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,SAAS,CAAC;YAC9B,IAAI,CAAC,QAAS,CAAC,KAAK,CAAC,CAAC;SACvB;IACH,CAAC;IAGD;;;;;;;;OAQG;IACH,IAAI,CACA,KAA2D,EAC3D,QAAY;QACd,IAAI,IAAI,CAAC,SAAS,EAAE;YAClB,OAAO;SACR;QACD,kCAAkC;QAClC,MAAM,SAAS,GAAG,KAAK,CAAC,QAAQ,EAAE,CAAC,GAAG,IAAW,EAAE,EAAE;YACnD,IAAI,CAAC,SAAS,GAAG,IAAI,CAAC;YACtB,YAAY,CAAC,IAAI,CAAC,QAAS,EAAE,GAAG,IAAI,CAAC,CAAC;QACxC,CAAC,CAAC,CAAC;QACH,IAAI,CAAC,UAAU,GAAG,GAAG,EAAE,CAAC,SAAS,CAAC,MAAM,EAAE,CAAC;IAC7C,CAAC;CACF;AA7DD,8BA6DC;AAOD,kCAAkC;AAClC,MAAa,gBAA0B,SAAQ,SAAS;IAEtD;;;;;;;OAOG;IACH,yCAAyC;IACzC,YAAY,WAA+B;QACzC,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,OAAO,GAAG,IAAI,WAAW,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YAClC,IAAI,CAAC,QAAQ,GAAG,CAAC,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,WAAW,EAAE,EAAE;gBACnD,IAAI,GAAG,EAAE;oBACP,MAAM,CAAC,GAAG,CAAC,CAAC;iBACb;qBAAM;oBACL,OAAO,CAAC,CAAC,QAAQ,EAAE,IAAI,EAAE,WAAW,CAAC,CAAC,CAAC;iBACxC;YACH,CAAC,CAAC;QACJ,CAAC,CAAuB,CAAC;QACxC,IAAI,CAAC,OAAO,CAAC,MAAM,GAAG,GAAG,EAAE;YACzB,IAAI,CAAC,MAAM,EAAE,CAAC;QAChB,CAAC,CAAC;IACJ,CAAC;CACF;AA1BD,4CA0BC;AAQD;;;;;;;;;;;;;;GAcG;AACH,SAAS,aAAa,CAClB,KAAc,EAAE,OAAe,EAAE,SAA2B,EAC5D,OAAY;IACd,0EAA0E;IAC1E,yEAAyE;IACzE,OAAO,SAAS,WAAW,CAAC,QAAQ,EAAE,QAAQ;QAC5C,MAAM,GAAG,GAAG,IAAI,IAAI,EAAE,CAAC;QACvB,MAAM,OAAO,GAAG,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC;QACxC,OAAO,CAAC,QAAQ,GAAG,IAAI,IAAI,CAAC,GAAG,CAAC,OAAO,EAAE,GAAG,OAAO,CAAC,CAAC;QACrD,MAAM,QAAQ,GAAG,SAAS,CAAC,eAAe,CAAC,CAAC;YACxC,SAAS,CAAC,eAAe,CAAC,OAAO,EAAE,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC,CAAC,CAAC;YAC7D,IAAI,CAAC;QACT,OAAO,KAAK,CAAC,QAAQ,EAAE,QAAS,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;IACvD,CAAC,CAAC;AACJ,CAAC;AAED;;;;;;;;;;;;GAYG;AACH,SAAS,SAAS,CACd,KAAc,EAAE,KAAmB,EACnC,SAA2B;IAC7B,MAAM,SAAS,GAAG,KAAK,CAAC,eAAe,CAAC,oBAAoB,CAAC;IAC7D,MAAM,QAAQ,GAAG,KAAK,CAAC,eAAe,CAAC,mBAAmB,CAAC;IAC3D,MAAM,WAAW,GAAG,KAAK,CAAC,eAAe,CAAC,oBAAoB,CAAC;IAC/D,MAAM,UAAU,GAAG,KAAK,CAAC,eAAe,CAAC,mBAAmB,CAAC;IAE7D,IAAI,KAAK,GAAG,KAAK,CAAC,eAAe,CAAC,uBAAuB,CAAC;IAC1D,IAAI,OAAO,GAAG,KAAK,CAAC,eAAe,CAAC,uBAAuB,CAAC;IAE5D;;;;;;;;OAQG;IACH,OAAO,SAAS,YAAY,CAAC,QAAY,EAAE,QAAqB;QAC9D,IAAI,SAA8B,CAAC;QACnC,IAAI,SAA4B,CAAC;QACjC,IAAI,GAAG,GAAG,IAAI,IAAI,EAAE,CAAC;QACrB,IAAI,QAAgB,CAAC;QACrB,IAAI,KAAK,CAAC,eAAe,CAAC,kBAAkB,EAAE;YAC5C,QAAQ,GAAG,GAAG,CAAC,OAAO,EAAE,GAAG,KAAK,CAAC,eAAe,CAAC,kBAAkB,CAAC;SACrE;QACD,IAAI,OAAO,GAAG,CAAC,CAAC;QAChB,MAAM,UAAU,GAAG,KAAK,CAAC,eAAe,CAAC,UAAW,CAAC;QACrD,uDAAuD;QAEvD,gDAAgD;QAChD,SAAS,MAAM;YACb,SAAS,GAAG,IAAI,CAAC;YACjB,IAAI,QAAQ,IAAI,GAAG,CAAC,OAAO,EAAE,IAAI,QAAQ,EAAE;gBACzC,MAAM,KAAK,GAAG,IAAI,yBAAW,CACzB,+DAA+D,CAAC,CAAC;gBACrE,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,iBAAiB,CAAC;gBACtC,QAAQ,CAAC,KAAK,CAAC,CAAC;gBAChB,OAAO;aACR;YAED,IAAI,OAAO,IAAI,OAAO,IAAI,UAAU,EAAE;gBACpC,MAAM,KAAK,GAAG,IAAI,yBAAW,CACzB,gDAAgD;oBAChD,uBAAuB,CAAC,CAAC;gBAC7B,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,iBAAiB,CAAC;gBACtC,QAAQ,CAAC,KAAK,CAAC,CAAC;gBAChB,OAAO;aACR;YAED,OAAO,EAAE,CAAC;YACV,MAAM,MAAM,GAAG,aAAa,CAAC,KAAK,EAAE,OAAQ,EAAE,SAAS,CAAC,CAAC;YACzD,SAAS,GAAG,MAAM,CAAC,QAAQ,EAAE,CAAC,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,WAAW,EAAE,EAAE;gBAChE,IAAI,CAAC,GAAG,EAAE;oBACR,QAAQ,CAAC,IAAI,EAAE,QAAQ,EAAE,IAAI,EAAE,WAAW,CAAC,CAAC;oBAC5C,OAAO;iBACR;gBACD,SAAS,GAAG,IAAI,CAAC;gBACjB,IAAI,KAAK,CAAC,UAAU,CAAC,OAAO,CAAC,GAAI,CAAC,IAAK,CAAC,GAAG,CAAC,EAAE;oBAC5C,GAAG,CAAC,IAAI,GAAG,8CAA8C;wBACrD,6BAA6B,CAAC;oBAClC,QAAQ,CAAC,GAAG,CAAC,CAAC;iBACf;qBAAM;oBACL,MAAM,OAAO,GAAG,IAAI,CAAC,MAAM,EAAE,GAAG,KAAK,CAAC;oBACtC,SAAS,GAAG,UAAU,CAAC,GAAG,EAAE;wBAC1B,GAAG,GAAG,IAAI,IAAI,EAAE,CAAC;wBACjB,KAAK,GAAG,IAAI,CAAC,GAAG,CAAC,KAAK,GAAG,SAAS,EAAE,QAAQ,CAAC,CAAC;wBAC9C,OAAO,GAAG,IAAI,CAAC,GAAG,CACd,OAAQ,GAAG,WAAY,EAAE,UAAW,EAAE,QAAQ,GAAG,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC;wBACpE,MAAM,EAAE,CAAC;oBACX,CAAC,EAAE,OAAO,CAAC,CAAC;iBACb;YACH,CAAC,CAAC,CAAC;QACL,CAAC;QAED,IAAI,UAAU,IAAI,QAAS,EAAE;YAC3B,MAAM,KAAK,GAAG,IAAI,yBAAW,CACzB,oDAAoD;gBACpD,qBAAqB,CAAC,CAAC;YAC3B,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,gBAAgB,CAAC;YACrC,QAAQ,CAAC,KAAK,CAAC,CAAC;SACjB;aAAM;YACL,MAAM,EAAE,CAAC;SACV;QAED,OAAO;YACL,MAAM;gBACJ,IAAI,SAAS,EAAE;oBACb,YAAY,CAAC,SAAS,CAAC,CAAC;iBACzB;gBACD,IAAI,SAAS,EAAE;oBACb,SAAS,CAAC,MAAM,EAAE,CAAC;iBACpB;qBAAM;oBACL,MAAM,KAAK,GAAG,IAAI,yBAAW,CAAC,WAAW,CAAC,CAAC;oBAC3C,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,SAAS,CAAC;oBAC9B,QAAQ,CAAC,KAAK,CAAC,CAAC;iBACjB;YACH,CAAC;SACF,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC;AAMD;;;;;GAKG;AACH,MAAa,eAAe;IAC1B,IAAI,CAAC,QAAiC,EAAE,QAAqB;QAE3D,IAAI,QAAQ,EAAE;YACZ,OAAO,IAAI,SAAS,CAAC,QAAQ,CAAC,CAAC;SAChC;QACD,OAAO,IAAI,gBAAgB,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;IAChD,CAAC;IAED,IAAI,CAAC,IAAc;QACjB,OAAO,IAAI,CAAC;IACd,CAAC;IAED,IAAI,CACA,OAAgB,EAAE,QAAY,EAAE,QAAY,EAC5C,SAA2B;QAC7B,SAAS,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAC;IACpC,CAAC;IAED,IAAI,CAAC,SAA2B,EAAE,GAAgB;QAChD,SAAS,CAAC,QAAS,CAAC,GAAG,CAAC,CAAC;IAC3B,CAAC;IAED,MAAM,CAAC,SAA2B;QAChC,IAAI,SAAS,CAAC,OAAO,EAAE;YACrB,OAAO,SAAS,CAAC,OAAO,CAAC;SAC1B;QACD,OAAO;IACT,CAAC;CACF;AA7BD,0CA6BC;AAED;;;;;;;;;;;;;;;;;;;GAmBG;AACH,SAAgB,aAAa,CACzB,YAA8B,EAAE,QAAsB;AACtD,kCAAkC;AAClC,aAAmB;IACrB,MAAM,SAAS,GACX,aAAa,CAAC,CAAC,CAAC,aAAa,CAAC,SAAS,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,IAAI,eAAe,EAAE,CAAC;IAE9E,OAAO,SAAS,YAAY,CAAC,OAAQ,EAAE,WAAY,EAAE,QAAS;QAC5D,MAAM,YAAY,GAAG,QAAQ,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC;QAEjD,MAAM,MAAM,GAAG,SAAS,CAAC,IAAI,CAAC,YAAY,EAAE,QAAQ,CAAC,CAAC;QACtD,YAAY;aACP,IAAI,CAAC,IAAI,CAAC,EAAE;YACX,IAAI,GAAG,SAAS,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;YAC5B,MAAM,KAAK,GAAG,YAAY,CAAC,KAAK,CAAC;YACjC,IAAI,KAAK,IAAI,KAAK,CAAC,UAAU,IAAI,KAAK,CAAC,UAAU,CAAC,MAAM,GAAG,CAAC,EAAE;gBAC5D,OAAO,SAAS,CACZ,IAAI,EAAE,YAAY,CAAC,KAAM,EACzB,YAAY,CAAC,SAA6B,CAAC,CAAC;aACjD;YACD,OAAO,aAAa,CAChB,IAAI,EAAE,YAAY,CAAC,OAAO,EAC1B,YAAY,CAAC,SAA6B,CAAC,CAAC;QAClD,CAAC,CAAC;aACD,IAAI,CAAC,OAAO,CAAC,EAAE;YACd,SAAS,CAAC,IAAI,CAAC,OAAO,EAAE,OAAO,EAAE,YAAY,EAAE,MAAM,CAAC,CAAC;QACzD,CAAC,CAAC;aACD,KAAK,CAAC,GAAG,CAAC,EAAE;YACX,SAAS,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC;QAC9B,CAAC,CAAC,CAAC;QACP,OAAO,SAAS,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC;IAClC,CAAC,CAAC;AACJ,CAAC;AAhCD,sCAgCC"}

-/// <reference types="node" />

-import { NormalApiCaller, APICall, PromiseCanceller, APICallback } from './apiCallable';

-import { CallSettings } from './gax';

-/**

- * Compute the identifier of the `obj`. The objects of the same ID

- * will be bundled together.

- *

- * @param {Object} obj - The request object.

- * @param {String[]} discriminatorFields - The array of field names.

- * A field name may include '.' as a separator, which is used to

- * indicate object traversal.

- * @return {String|undefined} - the identifier string, or undefined if any

- * discriminator.

- * fields do not exist.

- */

-export declare function computeBundleId(obj: {}, discriminatorFields: string[]): string | undefined;

-export interface SubResponseInfo {

- field: string;

- start?: number;

- end?: number;

-}

-export interface TaskElement {

-}

-export interface TaskData {

- elements: TaskElement[];

- bytes: number;

- callback: TaskCallback;

- cancelled?: boolean;

-}

-export interface TaskCallback extends APICallback {

- id?: string;

-}

-/**

- * Creates a deep copy of the object with the consideration of subresponse

- * fields for bundling.

- *

- * @param {Object} obj - The source object.

- * @param {Object?} subresponseInfo - The information to copy the subset of

- * the field for the response. Do nothing if it's null.

- * @param {String} subresponseInfo.field - The field name.

- * @param {number} subresponseInfo.start - The offset where the copying

- * element should starts with.

- * @param {number} subresponseInfo.end - The ending index where the copying

- * region of the elements ends.

- * @return {Object} The copied object.

- * @private

- */

-export declare function deepCopyForResponse(obj: any, subresponseInfo: SubResponseInfo | null): any;

-export declare class Task {

- _apiCall: APICall;

- _request: {

- [index: string]: TaskElement[];

- };

- _bundledField: string;

- _subresponseField?: string | null;

- _data: TaskData[];

- callCanceller?: PromiseCanceller;

- /**

- * A task coordinates the execution of a single bundle.

- *

- * @param {function} apiCall - The function to conduct calling API.

- * @param {Object} bundlingRequest - The base request object to be used

- * for the actual API call.

- * @param {string} bundledField - The name of the field in bundlingRequest

- * to be bundled.

- * @param {string=} subresponseField - The name of the field in the response

- * to be passed to the callback.

- * @constructor

- * @private

- */

- constructor(apiCall: APICall, bundlingRequest: {}, bundledField: string, subresponseField?: string | null);

- /**

- * Returns the number of elements in a task.

- * @return {number} The number of elements.

- */

- getElementCount(): number;

- /**

- * Returns the total byte size of the elements in a task.

- * @return {number} The byte size.

- */

- getRequestByteSize(): number;

- /**

- * Invokes the actual API call with current elements.

- * @return {string[]} - the list of ids for invocations to be run.

- */

- run(): string[];

- /**

- * Appends the list of elements into the task.

- * @param {Object[]} elements - the new list of elements.

- * @param {number} bytes - the byte size required to encode elements in the API.

- * @param {APICallback} callback - the callback of the method call.

- */

- extend(elements: TaskElement[], bytes: number, callback: TaskCallback): void;

- /**

- * Cancels a part of elements.

- * @param {string} id - The identifier of the part of elements.

- * @return {boolean} Whether the entire task will be canceled or not.

- */

- cancel(id: string): boolean;

-}

-export interface BundleOptions {

- elementCountLimit: number;

- requestByteLimit: number;

- elementCountThreshold: number;

- requestByteThreshold: number;

- delayThreshold: number;

-}

-export declare class BundleExecutor {

- _options: BundleOptions;

- _descriptor: BundleDescriptor;

- _tasks: {

- [index: string]: Task;

- };

- _timers: {

- [index: string]: NodeJS.Timer;

- };

- _invocations: {

- [index: string]: string;

- };

- _invocationId: number;

- /**

- * Organizes requests for an api service that requires to bundle them.

- *

- * @param {BundleOptions} bundleOptions - configures strategy this instance

- * uses when executing bundled functions.

- * @param {BundleDescriptor} bundleDescriptor - the description of the bundling.

- * @constructor

- */

- constructor(bundleOptions: BundleOptions, bundleDescriptor: BundleDescriptor);

- /**

- * Schedule a method call.

- *

- * @param {function} apiCall - the function for an API call.

- * @param {Object} request - the request object to be bundled with others.

- * @param {APICallback} callback - the callback to be called when the method finished.

- * @return {function()} - the function to cancel the scheduled invocation.

- */

- schedule(apiCall: APICall, request: {

- [index: string]: Array<{}> | string;

- }, callback?: TaskCallback): any;

- /**

- * Clears scheduled timeout if it exists.

- *

- * @param {String} bundleId - the id for the task whose timeout needs to be

- * cleared.

- * @private

- */

- _maybeClearTimeout(bundleId: string): void;

- /**

- * Cancels an event.

- *

- * @param {String} id - The id for the event in the task.

- * @private

- */

- _cancel(id: string): void;

- /**

- * Invokes a task.

- *

- * @param {String} bundleId - The id for the task.

- * @private

- */

- _runNow(bundleId: string): void;

-}

-export declare class Bundleable extends NormalApiCaller {

- bundler: BundleExecutor;

- /**

- * Creates an API caller that bundles requests.

- *

- * @private

- * @constructor

- * @param {BundleExecutor} bundler - bundles API calls.

- */

- constructor(bundler: BundleExecutor);

- call(apiCall: APICall, argument: {}, settings: CallSettings, status: any): void;

-}

-export declare class BundleDescriptor {

- bundledField: string;

- requestDiscriminatorFields: string[];

- subresponseField: string | null;

- byteLengthFunction: Function;

- /**

- * Describes the structure of bundled call.

- *

- * requestDiscriminatorFields may include '.' as a separator, which is used to

- * indicate object traversal. This allows fields in nested objects to be used

- * to determine what request to bundle.

- *

- * @property {String} bundledField

- * @property {String} requestDiscriminatorFields

- * @property {String} subresponseField

- * @property {Function} byteLengthFunction

- *

- * @param {String} bundledField - the repeated field in the request message

- * that will have its elements aggregated by bundling.

- * @param {String} requestDiscriminatorFields - a list of fields in the

- * target request message class that are used to detemrine which request

- * messages should be bundled together.

- * @param {String} subresponseField - an optional field, when present it

- * indicates the field in the response message that should be used to

- * demultiplex the response into multiple response messages.

- * @param {Function} byteLengthFunction - a function to obtain the byte

- * length to be consumed for the bundled field messages. Because Node.JS

- * protobuf.js/gRPC uses builtin Objects for the user-visible data and

- * internally they are encoded/decoded in protobuf manner, this function

- * is actually necessary to calculate the byte length.

- * @constructor

- */

- constructor(bundledField: string, requestDiscriminatorFields: string[], subresponseField: string | null, byteLengthFunction: Function);

- /**

- * Returns a new API caller.

- * @private

- * @param {CallSettings} settings - the current settings.

- * @return {Bundleable} - the new bundling API caller.

- */

- apiCaller(settings: CallSettings): Bundleable;

-}

-"use strict";

-/*

- * Copyright 2016, Google Inc.

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions are

- * met:

- *

- * * Redistributions of source code must retain the above copyright

- * notice, this list of conditions and the following disclaimer.

- * * Redistributions in binary form must reproduce the above

- * copyright notice, this list of conditions and the following disclaimer

- * in the documentation and/or other materials provided with the

- * distribution.

- * * Neither the name of Google Inc. nor the names of its

- * contributors may be used to endorse or promote products derived from

- * this software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- */

-Object.defineProperty(exports, "__esModule", { value: true });

-/**

- * Provides behavior that supports request bundling.

- */

-const at = require("lodash.at");

-const grpc_1 = require("grpc");

-const apiCallable_1 = require("./apiCallable");

-const GoogleError_1 = require("./GoogleError");

-const warnings_1 = require("./warnings");

-/**

- * A function which does nothing. Used for an empty cancellation funciton.

- * @private

- */

-function noop() { }

-/**

- * Compute the identifier of the `obj`. The objects of the same ID

- * will be bundled together.

- *

- * @param {Object} obj - The request object.

- * @param {String[]} discriminatorFields - The array of field names.

- * A field name may include '.' as a separator, which is used to

- * indicate object traversal.

- * @return {String|undefined} - the identifier string, or undefined if any

- * discriminator.

- * fields do not exist.

- */

-function computeBundleId(obj, discriminatorFields) {

- const ids = [];

- let hasIds = false;

- for (let i = 0; i < discriminatorFields.length; ++i) {

- const id = at(obj, discriminatorFields[i])[0];

- if (id === undefined) {

- ids.push(null);

- }

- else {

- hasIds = true;

- ids.push(id);

- }

- }

- if (!hasIds) {

- return undefined;

- }

- return JSON.stringify(ids);

-}

-exports.computeBundleId = computeBundleId;

-/**

- * Creates a deep copy of the object with the consideration of subresponse

- * fields for bundling.

- *

- * @param {Object} obj - The source object.

- * @param {Object?} subresponseInfo - The information to copy the subset of

- * the field for the response. Do nothing if it's null.

- * @param {String} subresponseInfo.field - The field name.

- * @param {number} subresponseInfo.start - The offset where the copying

- * element should starts with.

- * @param {number} subresponseInfo.end - The ending index where the copying

- * region of the elements ends.

- * @return {Object} The copied object.

- * @private

- */

-function deepCopyForResponse(

-// tslint:disable-next-line no-any

-obj, subresponseInfo) {

- // tslint:disable-next-line no-any

- let result;

- if (obj === null) {

- return null;

- }

- if (obj === undefined) {

- return undefined;

- }

- if (Array.isArray(obj)) {

- result = [];

- obj.forEach(element => {

- result.push(deepCopyForResponse(element, null));

- });

- return result;

- }

- // Some objects (such as ByteBuffer) have copy method.

- if (obj.copy !== undefined) {

- return obj.copy();

- }

- // ArrayBuffer should be copied through slice().

- if (obj instanceof ArrayBuffer) {

- return obj.slice(0);

- }

- if (typeof obj === 'object') {

- result = {};

- Object.keys(obj).forEach(key => {

- if (subresponseInfo && key === subresponseInfo.field &&

- Array.isArray(obj[key])) {

- // Note that subresponses are not deep-copied. This is safe because

- // those subresponses are not shared among callbacks.

- result[key] =

- obj[key].slice(subresponseInfo.start, subresponseInfo.end);

- }

- else {

- result[key] = deepCopyForResponse(obj[key], null);

- }

- });

- return result;

- }

- return obj;

-}

-exports.deepCopyForResponse = deepCopyForResponse;

-class Task {

- /**

- * A task coordinates the execution of a single bundle.

- *

- * @param {function} apiCall - The function to conduct calling API.

- * @param {Object} bundlingRequest - The base request object to be used

- * for the actual API call.

- * @param {string} bundledField - The name of the field in bundlingRequest

- * to be bundled.

- * @param {string=} subresponseField - The name of the field in the response

- * to be passed to the callback.

- * @constructor

- * @private

- */

- constructor(apiCall, bundlingRequest, bundledField, subresponseField) {

- this._apiCall = apiCall;

- this._request = bundlingRequest;

- this._bundledField = bundledField;

- this._subresponseField = subresponseField;

- this._data = [];

- }

- /**

- * Returns the number of elements in a task.

- * @return {number} The number of elements.

- */

- getElementCount() {

- let count = 0;

- for (let i = 0; i < this._data.length; ++i) {

- count += this._data[i].elements.length;

- }

- return count;

- }

- /**

- * Returns the total byte size of the elements in a task.

- * @return {number} The byte size.

- */

- getRequestByteSize() {

- let size = 0;

- for (let i = 0; i < this._data.length; ++i) {

- size += this._data[i].bytes;

- }

- return size;

- }

- /**

- * Invokes the actual API call with current elements.

- * @return {string[]} - the list of ids for invocations to be run.

- */

- run() {

- if (this._data.length === 0) {

- return [];

- }

- const request = this._request;

- const elements = [];

- const ids = [];

- for (let i = 0; i < this._data.length; ++i) {

- elements.push.apply(elements, this._data[i].elements);

- ids.push(this._data[i].callback.id);

- }

- request[this._bundledField] = elements;

- const self = this;

- this.callCanceller =

- this._apiCall(request, (err, response) => {

- const responses = [];

- if (err) {

- self._data.forEach(() => {

- responses.push(null);

- });

- }

- else {

- let subresponseInfo = null;

- if (self._subresponseField) {

- subresponseInfo = {

- field: self._subresponseField,

- start: 0,

- };

- }

- self._data.forEach(data => {

- if (subresponseInfo) {

- subresponseInfo.end =

- subresponseInfo.start + data.elements.length;

- }

- responses.push(deepCopyForResponse(response, subresponseInfo));

- if (subresponseInfo) {

- subresponseInfo.start = subresponseInfo.end;

- }

- });

- }

- for (let i = 0; i < self._data.length; ++i) {

- if (self._data[i].cancelled) {

- const error = new GoogleError_1.GoogleError('cancelled');

- error.code = grpc_1.status.CANCELLED;

- self._data[i].callback(error);

- }

- else {

- self._data[i].callback(err, responses[i]);

- }

- }

- });

- return ids;

- }

- /**

- * Appends the list of elements into the task.

- * @param {Object[]} elements - the new list of elements.

- * @param {number} bytes - the byte size required to encode elements in the API.

- * @param {APICallback} callback - the callback of the method call.

- */

- extend(elements, bytes, callback) {

- this._data.push({

- elements,

- bytes,

- callback,

- });

- }

- /**

- * Cancels a part of elements.

- * @param {string} id - The identifier of the part of elements.

- * @return {boolean} Whether the entire task will be canceled or not.

- */

- cancel(id) {

- if (this.callCanceller) {

- let allCancelled = true;

- this._data.forEach(d => {

- if (d.callback.id === id) {

- d.cancelled = true;

- }

- if (!d.cancelled) {

- allCancelled = false;

- }

- });

- if (allCancelled) {

- this.callCanceller.cancel();

- }

- return allCancelled;

- }

- for (let i = 0; i < this._data.length; ++i) {

- if (this._data[i].callback.id === id) {

- const error = new GoogleError_1.GoogleError('cancelled');

- error.code = grpc_1.status.CANCELLED;

- this._data[i].callback(error);

- this._data.splice(i, 1);

- break;

- }

- }

- return this._data.length === 0;

- }

-}

-exports.Task = Task;

-class BundleExecutor {

- /**

- * Organizes requests for an api service that requires to bundle them.

- *

- * @param {BundleOptions} bundleOptions - configures strategy this instance

- * uses when executing bundled functions.

- * @param {BundleDescriptor} bundleDescriptor - the description of the bundling.

- * @constructor

- */

- constructor(bundleOptions, bundleDescriptor) {

- this._options = bundleOptions;

- this._descriptor = bundleDescriptor;

- this._tasks = {};

- this._timers = {};

- this._invocations = {};

- this._invocationId = 0;

- }

- /**

- * Schedule a method call.

- *

- * @param {function} apiCall - the function for an API call.

- * @param {Object} request - the request object to be bundled with others.

- * @param {APICallback} callback - the callback to be called when the method finished.

- * @return {function()} - the function to cancel the scheduled invocation.

- */

- schedule(apiCall, request, callback) {

- const bundleId = computeBundleId(request, this._descriptor.requestDiscriminatorFields);

- callback = (callback || noop);

- if (bundleId === undefined) {

- warnings_1.warn('bundling_schedule_bundleid_undefined', 'The request does not have enough information for request bundling. ' +

- `Invoking immediately. Request: ${JSON.stringify(request)} ` +

- `discriminator fields: ${this._descriptor.requestDiscriminatorFields}`);

- return apiCall(request, callback);

- }

- if (request[this._descriptor.bundledField] === undefined) {

- warnings_1.warn('bundling_no_bundled_field', `Request does not contain field ${this._descriptor.bundledField} that must present for bundling. ` +

- `Invoking immediately. Request: ${JSON.stringify(request)}`);

- return apiCall(request, callback);

- }

- if (!(bundleId in this._tasks)) {

- this._tasks[bundleId] = new Task(apiCall, request, this._descriptor.bundledField, this._descriptor.subresponseField);

- }

- let task = this._tasks[bundleId];

- callback.id = String(this._invocationId++);

- this._invocations[callback.id] = bundleId;

- const bundledField = request[this._descriptor.bundledField];

- const elementCount = bundledField.length;

- let requestBytes = 0;

- const self = this;

- bundledField.forEach(obj => {

- requestBytes += this._descriptor.byteLengthFunction(obj);

- });

- const countLimit = this._options.elementCountLimit || 0;

- const byteLimit = this._options.requestByteLimit || 0;

- if ((countLimit > 0 && elementCount > countLimit) ||

- (byteLimit > 0 && requestBytes >= byteLimit)) {

- let message;

- if (countLimit > 0 && elementCount > countLimit) {

- message = 'The number of elements ' + elementCount +

- ' exceeds the limit ' + this._options.elementCountLimit;

- }

- else {

- message = 'The required bytes ' + requestBytes + ' exceeds the limit ' +

- this._options.requestByteLimit;

- }

- const error = new GoogleError_1.GoogleError(message);

- error.code = grpc_1.status.INVALID_ARGUMENT;

- callback(error);

- return {

- cancel: noop,

- };

- }

- const existingCount = task.getElementCount();

- const existingBytes = task.getRequestByteSize();

- if ((countLimit > 0 && elementCount + existingCount >= countLimit) ||

- (byteLimit > 0 && requestBytes + existingBytes >= byteLimit)) {

- this._runNow(bundleId);

- this._tasks[bundleId] = new Task(apiCall, request, this._descriptor.bundledField, this._descriptor.subresponseField);

- task = this._tasks[bundleId];

- }

- task.extend(bundledField, requestBytes, callback);

- const ret = {

- cancel() {

- self._cancel(callback.id);

- },

- };

- const countThreshold = this._options.elementCountThreshold || 0;

- const sizeThreshold = this._options.requestByteThreshold || 0;

- if ((countThreshold > 0 && task.getElementCount() >= countThreshold) ||

- (sizeThreshold > 0 && task.getRequestByteSize() >= sizeThreshold)) {

- this._runNow(bundleId);

- return ret;

- }

- if (!(bundleId in this._timers) && this._options.delayThreshold > 0) {

- this._timers[bundleId] = setTimeout(() => {

- delete this._timers[bundleId];

- this._runNow(bundleId);

- }, this._options.delayThreshold);

- }

- return ret;

- }

- /**

- * Clears scheduled timeout if it exists.

- *

- * @param {String} bundleId - the id for the task whose timeout needs to be

- * cleared.

- * @private

- */

- _maybeClearTimeout(bundleId) {

- if (bundleId in this._timers) {

- const timerId = this._timers[bundleId];

- delete this._timers[bundleId];

- clearTimeout(timerId);

- }

- }

- /**

- * Cancels an event.

- *

- * @param {String} id - The id for the event in the task.

- * @private

- */

- _cancel(id) {

- if (!(id in this._invocations)) {

- return;

- }

- const bundleId = this._invocations[id];

- if (!(bundleId in this._tasks)) {

- return;

- }

- const task = this._tasks[bundleId];

- delete this._invocations[id];

- if (task.cancel(id)) {

- this._maybeClearTimeout(bundleId);

- delete this._tasks[bundleId];

- }

- }

- /**

- * Invokes a task.

- *

- * @param {String} bundleId - The id for the task.

- * @private

- */

- _runNow(bundleId) {

- if (!(bundleId in this._tasks)) {

- warnings_1.warn('bundle_runnow_bundleid_unknown', `No such bundleid: ${bundleId}`);

- return;

- }

- this._maybeClearTimeout(bundleId);

- const task = this._tasks[bundleId];

- delete this._tasks[bundleId];

- task.run().forEach(id => {

- delete this._invocations[id];

- });

- }

-}

-exports.BundleExecutor = BundleExecutor;

-class Bundleable extends apiCallable_1.NormalApiCaller {

- /**

- * Creates an API caller that bundles requests.

- *

- * @private

- * @constructor

- * @param {BundleExecutor} bundler - bundles API calls.

- */

- constructor(bundler) {

- super();

- this.bundler = bundler;

- }

- // tslint:disable-next-line no-any

- call(apiCall, argument, settings, status) {

- if (settings.isBundling) {

- status.call((argument, callback) => {

- this.bundler.schedule(apiCall, argument, callback);

- }, argument);

- }

- else {

- apiCallable_1.NormalApiCaller.prototype.call.call(this, apiCall, argument, settings, status);

- }

- }

-}

-exports.Bundleable = Bundleable;

-class BundleDescriptor {

- /**

- * Describes the structure of bundled call.

- *

- * requestDiscriminatorFields may include '.' as a separator, which is used to

- * indicate object traversal. This allows fields in nested objects to be used

- * to determine what request to bundle.

- *

- * @property {String} bundledField

- * @property {String} requestDiscriminatorFields

- * @property {String} subresponseField

- * @property {Function} byteLengthFunction

- *

- * @param {String} bundledField - the repeated field in the request message

- * that will have its elements aggregated by bundling.

- * @param {String} requestDiscriminatorFields - a list of fields in the

- * target request message class that are used to detemrine which request

- * messages should be bundled together.

- * @param {String} subresponseField - an optional field, when present it

- * indicates the field in the response message that should be used to

- * demultiplex the response into multiple response messages.

- * @param {Function} byteLengthFunction - a function to obtain the byte

- * length to be consumed for the bundled field messages. Because Node.JS

- * protobuf.js/gRPC uses builtin Objects for the user-visible data and

- * internally they are encoded/decoded in protobuf manner, this function

- * is actually necessary to calculate the byte length.

- * @constructor

- */

- constructor(bundledField, requestDiscriminatorFields, subresponseField, byteLengthFunction) {

- if (!byteLengthFunction && typeof subresponseField === 'function') {

- byteLengthFunction = subresponseField;

- subresponseField = null;

- }

- this.bundledField = bundledField;

- this.requestDiscriminatorFields = requestDiscriminatorFields;

- this.subresponseField = subresponseField;

- this.byteLengthFunction = byteLengthFunction;

- }

- /**

- * Returns a new API caller.

- * @private

- * @param {CallSettings} settings - the current settings.

- * @return {Bundleable} - the new bundling API caller.

- */

- apiCaller(settings) {

- return new Bundleable(new BundleExecutor(settings.bundleOptions, this));

- }

-}

-exports.BundleDescriptor = BundleDescriptor;

-//# sourceMappingURL=bundling.js.map

-{"version":3,"file":"bundling.js","sourceRoot":"","sources":["../../src/bundling.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6BG;;AAEH;;GAEG;AAEH,gCAAiC;AACjC,+BAA4B;AAC5B,+CAAsF;AACtF,+CAA0C;AAE1C,yCAAgC;AAEhC;;;GAGG;AACH,SAAS,IAAI,KAAI,CAAC;AAElB;;;;;;;;;;;GAWG;AACH,SAAgB,eAAe,CAAC,GAAO,EAAE,mBAA6B;IACpE,MAAM,GAAG,GAAmB,EAAE,CAAC;IAC/B,IAAI,MAAM,GAAG,KAAK,CAAC;IACnB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,mBAAmB,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE;QACnD,MAAM,EAAE,GAAG,EAAE,CAAC,GAAG,EAAE,mBAAmB,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC;QAC9C,IAAI,EAAE,KAAK,SAAS,EAAE;YACpB,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;SAChB;aAAM;YACL,MAAM,GAAG,IAAI,CAAC;YACd,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC;SACd;KACF;IACD,IAAI,CAAC,MAAM,EAAE;QACX,OAAO,SAAS,CAAC;KAClB;IACD,OAAO,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC;AAC7B,CAAC;AAhBD,0CAgBC;AAqBD;;;;;;;;;;;;;;GAcG;AACH,SAAgB,mBAAmB;AAC/B,kCAAkC;AAClC,GAAQ,EAAE,eAAqC;IACjD,kCAAkC;IAClC,IAAI,MAAW,CAAC;IAChB,IAAI,GAAG,KAAK,IAAI,EAAE;QAChB,OAAO,IAAI,CAAC;KACb;IACD,IAAI,GAAG,KAAK,SAAS,EAAE;QACrB,OAAO,SAAS,CAAC;KAClB;IACD,IAAI,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE;QACtB,MAAM,GAAG,EAAE,CAAC;QACZ,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE;YACpB,MAAM,CAAC,IAAI,CAAC,mBAAmB,CAAC,OAAO,EAAE,IAAI,CAAC,CAAC,CAAC;QAClD,CAAC,CAAC,CAAC;QACH,OAAO,MAAM,CAAC;KACf;IACD,sDAAsD;IACtD,IAAI,GAAG,CAAC,IAAI,KAAK,SAAS,EAAE;QAC1B,OAAO,GAAG,CAAC,IAAI,EAAE,CAAC;KACnB;IACD,gDAAgD;IAChD,IAAI,GAAG,YAAY,WAAW,EAAE;QAC9B,OAAQ,GAAmB,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;KACtC;IACD,IAAI,OAAO,GAAG,KAAK,QAAQ,EAAE;QAC3B,MAAM,GAAG,EAAE,CAAC;QACZ,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE;YAC7B,IAAI,eAAe,IAAI,GAAG,KAAK,eAAe,CAAC,KAAK;gBAChD,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,EAAE;gBAC3B,mEAAmE;gBACnE,qDAAqD;gBACrD,MAAM,CAAC,GAAG,CAAC;oBACP,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,eAAe,CAAC,KAAK,EAAE,eAAe,CAAC,GAAG,CAAC,CAAC;aAChE;iBAAM;gBACL,MAAM,CAAC,GAAG,CAAC,GAAG,mBAAmB,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC;aACnD;QACH,CAAC,CAAC,CAAC;QACH,OAAO,MAAM,CAAC;KACf;IACD,OAAO,GAAG,CAAC;AACb,CAAC;AA1CD,kDA0CC;AAED,MAAa,IAAI;IAQf;;;;;;;;;;;;OAYG;IACH,YACI,OAAgB,EAAE,eAAmB,EAAE,YAAoB,EAC3D,gBAA8B;QAChC,IAAI,CAAC,QAAQ,GAAG,OAAO,CAAC;QACxB,IAAI,CAAC,QAAQ,GAAG,eAAe,CAAC;QAChC,IAAI,CAAC,aAAa,GAAG,YAAY,CAAC;QAClC,IAAI,CAAC,iBAAiB,GAAG,gBAAgB,CAAC;QAC1C,IAAI,CAAC,KAAK,GAAG,EAAE,CAAC;IAClB,CAAC;IAED;;;OAGG;IACH,eAAe;QACb,IAAI,KAAK,GAAG,CAAC,CAAC;QACd,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE;YAC1C,KAAK,IAAI,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,MAAM,CAAC;SACxC;QACD,OAAO,KAAK,CAAC;IACf,CAAC;IAED;;;OAGG;IACH,kBAAkB;QAChB,IAAI,IAAI,GAAG,CAAC,CAAC;QACb,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE;YAC1C,IAAI,IAAI,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC;SAC7B;QACD,OAAO,IAAI,CAAC;IACd,CAAC;IAED;;;OAGG;IACH,GAAG;QACD,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;YAC3B,OAAO,EAAE,CAAC;SACX;QACD,MAAM,OAAO,GAAG,IAAI,CAAC,QAAQ,CAAC;QAC9B,MAAM,QAAQ,GAAkB,EAAE,CAAC;QACnC,MAAM,GAAG,GAAa,EAAE,CAAC;QACzB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE;YAC1C,QAAQ,CAAC,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC;YACtD,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,EAAG,CAAC,CAAC;SACtC;QACD,OAAO,CAAC,IAAI,CAAC,aAAa,CAAC,GAAG,QAAQ,CAAC;QAEvC,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,IAAI,CAAC,aAAa;YACd,IAAI,CAAC,QAAQ,CAAC,OAAO,EAAE,CAAC,GAAqB,EAAE,QAAa,EAAE,EAAE;gBAC9D,MAAM,SAAS,GAAmB,EAAE,CAAC;gBACrC,IAAI,GAAG,EAAE;oBACP,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,GAAG,EAAE;wBACtB,SAAS,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;oBACvB,CAAC,CAAC,CAAC;iBACJ;qBAAM;oBACL,IAAI,eAAe,GAAyB,IAAI,CAAC;oBACjD,IAAI,IAAI,CAAC,iBAAiB,EAAE;wBAC1B,eAAe,GAAG;4BAChB,KAAK,EAAE,IAAI,CAAC,iBAAiB;4BAC7B,KAAK,EAAE,CAAC;yBACT,CAAC;qBACH;oBACD,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;wBACxB,IAAI,eAAe,EAAE;4BACnB,eAAe,CAAC,GAAG;gCACf,eAAe,CAAC,KAAM,GAAG,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC;yBACnD;wBACD,SAAS,CAAC,IAAI,CAAC,mBAAmB,CAAC,QAAQ,EAAE,eAAe,CAAC,CAAC,CAAC;wBAC/D,IAAI,eAAe,EAAE;4BACnB,eAAe,CAAC,KAAK,GAAG,eAAe,CAAC,GAAG,CAAC;yBAC7C;oBACH,CAAC,CAAC,CAAC;iBACJ;gBACD,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE;oBAC1C,IAAI,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,SAAS,EAAE;wBAC3B,MAAM,KAAK,GAAG,IAAI,yBAAW,CAAC,WAAW,CAAC,CAAC;wBAC3C,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,SAAS,CAAC;wBAC9B,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC;qBAC/B;yBAAM;wBACL,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,EAAE,SAAS,CAAC,CAAC,CAAC,CAAC,CAAC;qBAC3C;iBACF;YACH,CAAC,CAAC,CAAC;QACP,OAAO,GAAG,CAAC;IACb,CAAC;IAED;;;;;OAKG;IACH,MAAM,CAAC,QAAuB,EAAE,KAAa,EAAE,QAAsB;QACnE,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC;YACd,QAAQ;YACR,KAAK;YACL,QAAQ;SACT,CAAC,CAAC;IACL,CAAC;IAED;;;;OAIG;IACH,MAAM,CAAC,EAAU;QACf,IAAI,IAAI,CAAC,aAAa,EAAE;YACtB,IAAI,YAAY,GAAG,IAAI,CAAC;YACxB,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE;gBACrB,IAAI,CAAC,CAAC,QAAQ,CAAC,EAAE,KAAK,EAAE,EAAE;oBACxB,CAAC,CAAC,SAAS,GAAG,IAAI,CAAC;iBACpB;gBACD,IAAI,CAAC,CAAC,CAAC,SAAS,EAAE;oBAChB,YAAY,GAAG,KAAK,CAAC;iBACtB;YACH,CAAC,CAAC,CAAC;YACH,IAAI,YAAY,EAAE;gBAChB,IAAI,CAAC,aAAa,CAAC,MAAM,EAAE,CAAC;aAC7B;YACD,OAAO,YAAY,CAAC;SACrB;QACD,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE;YAC1C,IAAI,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,EAAE,KAAK,EAAE,EAAE;gBACpC,MAAM,KAAK,GAAG,IAAI,yBAAW,CAAC,WAAW,CAAC,CAAC;gBAC3C,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,SAAS,CAAC;gBAC9B,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC;gBAC9B,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;gBACxB,MAAM;aACP;SACF;QACD,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAC;IACjC,CAAC;CACF;AA9JD,oBA8JC;AAUD,MAAa,cAAc;IAOzB;;;;;;;OAOG;IACH,YACI,aAA4B,EAAE,gBAAkC;QAClE,IAAI,CAAC,QAAQ,GAAG,aAAa,CAAC;QAC9B,IAAI,CAAC,WAAW,GAAG,gBAAgB,CAAC;QACpC,IAAI,CAAC,MAAM,GAAG,EAAE,CAAC;QACjB,IAAI,CAAC,OAAO,GAAG,EAAE,CAAC;QAClB,IAAI,CAAC,YAAY,GAAG,EAAE,CAAC;QACvB,IAAI,CAAC,aAAa,GAAG,CAAC,CAAC;IACzB,CAAC;IAED;;;;;;;OAOG;IACH,QAAQ,CACJ,OAAgB,EAAE,OAA4C,EAC9D,QAAuB;QACzB,MAAM,QAAQ,GACV,eAAe,CAAC,OAAO,EAAE,IAAI,CAAC,WAAW,CAAC,0BAA0B,CAAC,CAAC;QAC1E,QAAQ,GAAG,CAAC,QAAQ,IAAI,IAAI,CAAiB,CAAC;QAC9C,IAAI,QAAQ,KAAK,SAAS,EAAE;YAC1B,eAAI,CACA,sCAAsC,EACtC,qEAAqE;gBACjE,kCAAkC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG;gBAC5D,yBACI,IAAI,CAAC,WAAW,CAAC,0BAA0B,EAAE,CAAC,CAAC;YAC3D,OAAO,OAAO,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAC;SACnC;QACD,IAAI,OAAO,CAAC,IAAI,CAAC,WAAW,CAAC,YAAY,CAAC,KAAK,SAAS,EAAE;YACxD,eAAI,CACA,2BAA2B,EAC3B,kCACI,IAAI,CAAC,WAAW,CAAC,YAAY,mCAAmC;gBAChE,kCAAkC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,EAAE,CAAC,CAAC;YACrE,OAAO,OAAO,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAC;SACnC;QAED,IAAI,CAAC,CAAC,QAAQ,IAAI,IAAI,CAAC,MAAM,CAAC,EAAE;YAC9B,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,GAAG,IAAI,IAAI,CAC5B,OAAO,EAAE,OAAO,EAAE,IAAI,CAAC,WAAW,CAAC,YAAY,EAC/C,IAAI,CAAC,WAAW,CAAC,gBAAgB,CAAC,CAAC;SACxC;QACD,IAAI,IAAI,GAAG,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;QACjC,QAAQ,CAAC,EAAE,GAAG,MAAM,CAAC,IAAI,CAAC,aAAa,EAAE,CAAC,CAAC;QAC3C,IAAI,CAAC,YAAY,CAAC,QAAQ,CAAC,EAAE,CAAC,GAAG,QAAQ,CAAC;QAE1C,MAAM,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC,WAAW,CAAC,YAAY,CAAc,CAAC;QACzE,MAAM,YAAY,GAAG,YAAY,CAAC,MAAM,CAAC;QACzC,IAAI,YAAY,GAAG,CAAC,CAAC;QACrB,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,YAAY,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE;YACzB,YAAY,IAAI,IAAI,CAAC,WAAW,CAAC,kBAAkB,CAAC,GAAG,CAAC,CAAC;QAC3D,CAAC,CAAC,CAAC;QAEH,MAAM,UAAU,GAAG,IAAI,CAAC,QAAQ,CAAC,iBAAiB,IAAI,CAAC,CAAC;QACxD,MAAM,SAAS,GAAG,IAAI,CAAC,QAAQ,CAAC,gBAAgB,IAAI,CAAC,CAAC;QAEtD,IAAI,CAAC,UAAU,GAAG,CAAC,IAAI,YAAY,GAAG,UAAU,CAAC;YAC7C,CAAC,SAAS,GAAG,CAAC,IAAI,YAAY,IAAI,SAAS,CAAC,EAAE;YAChD,IAAI,OAAO,CAAC;YACZ,IAAI,UAAU,GAAG,CAAC,IAAI,YAAY,GAAG,UAAU,EAAE;gBAC/C,OAAO,GAAG,yBAAyB,GAAG,YAAY;oBAC9C,qBAAqB,GAAG,IAAI,CAAC,QAAQ,CAAC,iBAAiB,CAAC;aAC7D;iBAAM;gBACL,OAAO,GAAG,qBAAqB,GAAG,YAAY,GAAG,qBAAqB;oBAClE,IAAI,CAAC,QAAQ,CAAC,gBAAgB,CAAC;aACpC;YACD,MAAM,KAAK,GAAG,IAAI,yBAAW,CAAC,OAAO,CAAC,CAAC;YACvC,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,gBAAgB,CAAC;YACrC,QAAQ,CAAC,KAAK,CAAC,CAAC;YAChB,OAAO;gBACL,MAAM,EAAE,IAAI;aACb,CAAC;SACH;QAED,MAAM,aAAa,GAAG,IAAI,CAAC,eAAe,EAAE,CAAC;QAC7C,MAAM,aAAa,GAAG,IAAI,CAAC,kBAAkB,EAAE,CAAC;QAEhD,IAAI,CAAC,UAAU,GAAG,CAAC,IAAI,YAAY,GAAG,aAAa,IAAI,UAAU,CAAC;YAC9D,CAAC,SAAS,GAAG,CAAC,IAAI,YAAY,GAAG,aAAa,IAAI,SAAS,CAAC,EAAE;YAChE,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC;YACvB,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,GAAG,IAAI,IAAI,CAC5B,OAAO,EAAE,OAAO,EAAE,IAAI,CAAC,WAAW,CAAC,YAAY,EAC/C,IAAI,CAAC,WAAW,CAAC,gBAAgB,CAAC,CAAC;YACvC,IAAI,GAAG,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;SAC9B;QAED,IAAI,CAAC,MAAM,CAAC,YAAY,EAAE,YAAY,EAAE,QAAQ,CAAC,CAAC;QAClD,MAAM,GAAG,GAAG;YACV,MAAM;gBACJ,IAAI,CAAC,OAAO,CAAC,QAAS,CAAC,EAAG,CAAC,CAAC;YAC9B,CAAC;SACF,CAAC;QAEF,MAAM,cAAc,GAAG,IAAI,CAAC,QAAQ,CAAC,qBAAqB,IAAI,CAAC,CAAC;QAChE,MAAM,aAAa,GAAG,IAAI,CAAC,QAAQ,CAAC,oBAAoB,IAAI,CAAC,CAAC;QAC9D,IAAI,CAAC,cAAc,GAAG,CAAC,IAAI,IAAI,CAAC,eAAe,EAAE,IAAI,cAAc,CAAC;YAChE,CAAC,aAAa,GAAG,CAAC,IAAI,IAAI,CAAC,kBAAkB,EAAE,IAAI,aAAa,CAAC,EAAE;YACrE,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC;YACvB,OAAO,GAAG,CAAC;SACZ;QAED,IAAI,CAAC,CAAC,QAAQ,IAAI,IAAI,CAAC,OAAO,CAAC,IAAI,IAAI,CAAC,QAAQ,CAAC,cAAc,GAAG,CAAC,EAAE;YACnE,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,GAAG,UAAU,CAAC,GAAG,EAAE;gBACvC,OAAO,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC;gBAC9B,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC;YACzB,CAAC,EAAE,IAAI,CAAC,QAAQ,CAAC,cAAc,CAAC,CAAC;SAClC;QAED,OAAO,GAAG,CAAC;IACb,CAAC;IAED;;;;;;OAMG;IACH,kBAAkB,CAAC,QAAgB;QACjC,IAAI,QAAQ,IAAI,IAAI,CAAC,OAAO,EAAE;YAC5B,MAAM,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC;YACvC,OAAO,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC;YAC9B,YAAY,CAAC,OAAO,CAAC,CAAC;SACvB;IACH,CAAC;IAED;;;;;OAKG;IACH,OAAO,CAAC,EAAU;QAChB,IAAI,CAAC,CAAC,EAAE,IAAI,IAAI,CAAC,YAAY,CAAC,EAAE;YAC9B,OAAO;SACR;QACD,MAAM,QAAQ,GAAG,IAAI,CAAC,YAAY,CAAC,EAAE,CAAC,CAAC;QACvC,IAAI,CAAC,CAAC,QAAQ,IAAI,IAAI,CAAC,MAAM,CAAC,EAAE;YAC9B,OAAO;SACR;QAED,MAAM,IAAI,GAAG,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;QACnC,OAAO,IAAI,CAAC,YAAY,CAAC,EAAE,CAAC,CAAC;QAC7B,IAAI,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,EAAE;YACnB,IAAI,CAAC,kBAAkB,CAAC,QAAQ,CAAC,CAAC;YAClC,OAAO,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;SAC9B;IACH,CAAC;IAED;;;;;OAKG;IACH,OAAO,CAAC,QAAgB;QACtB,IAAI,CAAC,CAAC,QAAQ,IAAI,IAAI,CAAC,MAAM,CAAC,EAAE;YAC9B,eAAI,CAAC,gCAAgC,EAAE,qBAAqB,QAAQ,EAAE,CAAC,CAAC;YACxE,OAAO;SACR;QACD,IAAI,CAAC,kBAAkB,CAAC,QAAQ,CAAC,CAAC;QAClC,MAAM,IAAI,GAAG,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;QACnC,OAAO,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;QAE7B,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,EAAE,CAAC,EAAE;YACtB,OAAO,IAAI,CAAC,YAAY,CAAC,EAAE,CAAC,CAAC;QAC/B,CAAC,CAAC,CAAC;IACL,CAAC;CACF;AA7LD,wCA6LC;AAED,MAAa,UAAW,SAAQ,6BAAe;IAE7C;;;;;;OAMG;IACH,YAAY,OAAuB;QACjC,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,OAAO,GAAG,OAAO,CAAC;IACzB,CAAC;IAED,kCAAkC;IAClC,IAAI,CAAC,OAAgB,EAAE,QAAY,EAAE,QAAsB,EAAE,MAAW;QACtE,IAAI,QAAQ,CAAC,UAAU,EAAE;YACvB,MAAM,CAAC,IAAI,CAAC,CAAC,QAAY,EAAE,QAAsB,EAAE,EAAE;gBACnD,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,OAAO,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAC;YACrD,CAAC,EAAE,QAAQ,CAAC,CAAC;SACd;aAAM;YACL,6BAAe,CAAC,SAAS,CAAC,IAAI,CAAC,IAAI,CAC/B,IAAI,EAAE,OAAO,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,CAAC,CAAC;SAChD;IACH,CAAC;CACF;AAzBD,gCAyBC;AAED,MAAa,gBAAgB;IAM3B;;;;;;;;;;;;;;;;;;;;;;;;;;OA0BG;IACH,YACI,YAAoB,EAAE,0BAAoC,EAC1D,gBAA6B,EAAE,kBAA4B;QAC7D,IAAI,CAAC,kBAAkB,IAAI,OAAO,gBAAgB,KAAK,UAAU,EAAE;YACjE,kBAAkB,GAAG,gBAAgB,CAAC;YACtC,gBAAgB,GAAG,IAAI,CAAC;SACzB;QACD,IAAI,CAAC,YAAY,GAAG,YAAY,CAAC;QACjC,IAAI,CAAC,0BAA0B,GAAG,0BAA0B,CAAC;QAC7D,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;QACzC,IAAI,CAAC,kBAAkB,GAAG,kBAAkB,CAAC;IAC/C,CAAC;IAGD;;;;;OAKG;IACH,SAAS,CAAC,QAAsB;QAC9B,OAAO,IAAI,UAAU,CAAC,IAAI,cAAc,CAAC,QAAQ,CAAC,aAAc,EAAE,IAAI,CAAC,CAAC,CAAC;IAC3E,CAAC;CACF;AAxDD,4CAwDC"}

- * Copyright 2016, Google Inc.

-import { BundleOptions } from './bundling';

- pageToken?: number;

- longrunning?: boolean | null;

- pageToken?: number;

- longrunning?: boolean | null;

- * Copyright 2016, Google Inc.

- this.longrunning = 'longrunning' in settings ? settings.longrunning : null;

-{"version":3,"file":"gax.js","sourceRoot":"","sources":["../../src/gax.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6BG;;AAQH;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA2CG;AAEH;;;;;GAKG;AACH,MAAa,YAAY;IAGvB,YAAY,UAAoB,EAAE,eAAgC;QAChE,IAAI,CAAC,UAAU,GAAG,UAAU,CAAC;QAC7B,IAAI,CAAC,eAAe,GAAG,eAAe,CAAC;IACzC,CAAC;CACF;AAPD,oCAOC;AAgFD,MAAa,YAAY;IAavB;;;;;;;;;;;;;;;;;;;;OAoBG;IACH,YAAY,QAAsB;QAChC,QAAQ,GAAG,QAAQ,IAAI,EAAE,CAAC;QAC1B,IAAI,CAAC,OAAO,GAAG,QAAQ,CAAC,OAAO,IAAI,EAAE,GAAG,IAAI,CAAC;QAC7C,IAAI,CAAC,KAAK,GAAG,QAAQ,CAAC,KAAK,CAAC;QAC5B,IAAI,CAAC,YAAY;YACb,cAAc,IAAI,QAAQ,CAAC,CAAC,CAAC,QAAQ,CAAC,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC;QAC9D,IAAI,CAAC,SAAS,GAAG,QAAQ,CAAC,SAAS,CAAC;QACpC,IAAI,CAAC,UAAU,GAAG,QAAQ,CAAC,UAAU,CAAC;QACtC,IAAI,CAAC,SAAS,GAAG,QAAQ,CAAC,SAAS,IAAI,EAAE,CAAC;QAC1C,IAAI,CAAC,aAAa,GAAG,QAAQ,CAAC,aAAa,CAAC;QAC5C,IAAI,CAAC,UAAU,GAAG,YAAY,IAAI,QAAQ,CAAC,CAAC,CAAC,QAAQ,CAAC,UAAW,CAAC,CAAC,CAAC,IAAI,CAAC;QACzE,IAAI,CAAC,WAAW,GAAG,aAAa,IAAI,QAAQ,CAAC,CAAC,CAAC,QAAQ,CAAC,WAAW,CAAC,CAAC,CAAC,IAAI,CAAC;QAC3E,IAAI,CAAC,OAAO,GAAG,SAAS,IAAI,QAAQ,CAAC,CAAC,CAAC,QAAQ,CAAC,OAAQ,CAAC,CAAC,CAAC,OAAO,CAAC;IACrE,CAAC;IAED;;;;;;;OAOG;IACH,KAAK,CAAC,OAA0B;QAC9B,IAAI,CAAC,OAAO,EAAE;YACZ,OAAO,IAAI,YAAY,CAAC,IAAI,CAAC,CAAC;SAC/B;QACD,IAAI,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC3B,IAAI,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC;QACvB,IAAI,YAAY,GAAG,IAAI,CAAC,YAAY,CAAC;QACrC,IAAI,SAAS,GAAG,IAAI,CAAC,SAAS,CAAC;QAC/B,IAAI,UAAU,GAAG,IAAI,CAAC,UAAU,CAAC;QACjC,IAAI,SAAS,GAAG,IAAI,CAAC,SAAS,CAAC;QAC/B,IAAI,UAAU,GAAG,IAAI,CAAC,UAAU,CAAC;QACjC,IAAI,WAAW,GAAG,IAAI,CAAC,WAAW,CAAC;QACnC,IAAI,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC;QAC3B,IAAI,SAAS,IAAI,OAAO,EAAE;YACxB,OAAO,GAAG,OAAO,CAAC,OAAQ,CAAC;SAC5B;QACD,IAAI,OAAO,IAAI,OAAO,EAAE;YACtB,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC;SACvB;QAED,IAAI,cAAc,IAAI,OAAO,IAAI,CAAC,OAAO,CAAC,YAAY,EAAE;YACtD,YAAY,GAAG,KAAK,CAAC;SACtB;QAED,IAAI,WAAW,IAAI,OAAO,EAAE;YAC1B,YAAY,GAAG,KAAK,CAAC;YACrB,SAAS,GAAG,OAAO,CAAC,SAAS,CAAC;SAC/B;QAED,IAAI,YAAY,IAAI,OAAO,EAAE;YAC3B,UAAU,GAAG,OAAO,CAAC,UAAU,CAAC;SACjC;QAED,IAAI,WAAW,IAAI,OAAO,EAAE;YAC1B,SAAS,GAAG,EAAE,CAAC;YACf,iCAAiC;YACjC,KAAK,MAAM,GAAG,IAAI,IAAI,CAAC,SAAS,EAAE;gBAChC,SAAS,CAAC,GAAG,CAAC,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC;aACtC;YACD,iCAAiC;YACjC,KAAK,MAAM,UAAU,IAAI,OAAO,CAAC,SAAU,EAAE;gBAC3C,SAAS,CAAC,UAAU,CAAC,GAAG,OAAO,CAAC,SAAU,CAAC,UAAU,CAAC,CAAC;aACxD;SACF;QAED,IAAI,YAAY,IAAI,OAAO,EAAE;YAC3B,UAAU,GAAG,OAAO,CAAC,UAAW,CAAC;SAClC;QAED,IAAI,YAAY,IAAI,OAAO,EAAE;YAC3B,KAAM,CAAC,eAAgB,CAAC,UAAU,GAAG,OAAO,CAAC,UAAU,CAAC;YACxD,OAAO,KAAM,CAAC,eAAgB,CAAC,kBAAkB,CAAC;SACnD;QAED,IAAI,aAAa,IAAI,OAAO,EAAE;YAC5B,WAAW,GAAG,OAAO,CAAC,WAAW,CAAC;SACnC;QAED,IAAI,SAAS,IAAI,OAAO,EAAE;YACxB,OAAO,GAAG,OAAO,CAAC,OAAQ,CAAC;SAC5B;QAED,OAAO,IAAI,YAAY,CAAC;YACtB,OAAO;YACP,KAAK;YACL,aAAa,EAAE,IAAI,CAAC,aAAa;YACjC,WAAW;YACX,YAAY;YACZ,SAAS;YACT,UAAU;YACV,SAAS;YACT,UAAU;YACV,OAAO;SACR,CAAC,CAAC;IACL,CAAC;CACF;AApID,oCAoIC;AAED;;;;;;;;;GASG;AACH,SAAgB,kBAAkB,CAC9B,UAAoB,EAAE,eAAgC;IACxD,OAAO;QACL,UAAU;QACV,eAAe;KAChB,CAAC;AACJ,CAAC;AAND,gDAMC;AAED;;;;;;;;;;;;;;;;;;;;;;;;GAwBG;AACH,SAAgB,qBAAqB,CACjC,uBAA+B,EAAE,oBAA4B,EAC7D,mBAA2B,EAAE,uBAAoC,EACjE,oBAAiC,EAAE,mBAAgC,EACnE,kBAA+B;IACjC,OAAO;QACL,uBAAuB;QACvB,oBAAoB;QACpB,mBAAmB;QACnB,uBAAuB;QACvB,oBAAoB;QACpB,mBAAmB;QACnB,kBAAkB;KACnB,CAAC;AACJ,CAAC;AAdD,sDAcC;AAED;;;;;;;;;;;;;;;;;;;;;;;;GAwBG;AACH,SAAgB,+BAA+B,CAC3C,uBAA+B,EAAE,oBAA4B,EAC7D,mBAA2B,EAAE,uBAA+B,EAC5D,oBAA4B,EAAE,mBAA2B,EACzD,UAAkB;IACpB,OAAO;QACL,uBAAuB;QACvB,oBAAoB;QACpB,mBAAmB;QACnB,uBAAuB;QACvB,oBAAoB;QACpB,mBAAmB;QACnB,UAAU;KACX,CAAC;AACJ,CAAC;AAdD,0EAcC;AAED;;;;;;;GAOG;AACH,SAAgB,mBAAmB,CAAC,OAAuB;IACzD,MAAM,MAAM,GAAG;QACb,yBAAyB;QACzB,qBAAqB;QACrB,wBAAwB;QACxB,oBAAoB;QACpB,wBAAwB;KACzB,CAAC;IACF,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;QACrB,IAAI,KAAK,IAAI,OAAO,IAAI,OAAO,OAAO,CAAC,KAAK,CAAC,KAAK,QAAQ,EAAE;YAC1D,MAAM,IAAI,KAAK,CAAC,GAAG,KAAK,qBAAqB,CAAC,CAAC;SAChD;IACH,CAAC,CAAC,CAAC;IAEH,MAAM,qBAAqB,GAAG,OAAO,CAAC,uBAAuB,IAAI,CAAC,CAAC;IACnE,MAAM,iBAAiB,GAAG,OAAO,CAAC,mBAAmB,IAAI,CAAC,CAAC;IAC3D,MAAM,oBAAoB,GAAG,OAAO,CAAC,sBAAsB,IAAI,CAAC,CAAC;IACjE,MAAM,gBAAgB,GAAG,OAAO,CAAC,kBAAkB,IAAI,CAAC,CAAC;IACzD,MAAM,cAAc,GAAG,OAAO,CAAC,sBAAsB,IAAI,CAAC,CAAC;IAE3D,IAAI,qBAAqB,KAAK,CAAC,IAAI,oBAAoB,KAAK,CAAC;QACzD,cAAc,KAAK,CAAC,EAAE;QACxB,MAAM,IAAI,KAAK,CAAC,6BAA6B,CAAC,CAAC;KAChD;IACD,OAAO;QACL,qBAAqB;QACrB,iBAAiB;QACjB,oBAAoB;QACpB,gBAAgB;QAChB,cAAc;KACf,CAAC;AACJ,CAAC;AA/BD,kDA+BC;AAED;;;;;;;;;;;;;;;;;;GAkBG;AACH,SAAS,cAAc,CACnB,YAA0B,EAAE,UAAuC,EACnE,WAAkC,EAClC,UAAiC;IACnC,IAAI,CAAC,YAAY,EAAE;QACjB,OAAO,IAAI,CAAC;KACb;IAED,IAAI,KAAK,GAAkB,IAAI,CAAC;IAChC,IAAI,UAAU,IAAI,kBAAkB,IAAI,YAAY,EAAE;QACpD,MAAM,cAAc,GAAG,YAAY,CAAC,kBAAkB,CAAC,CAAC;QACxD,KAAK,GAAG,CAAC,UAAU,CAAC,cAAc,CAAC,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE;YACpD,OAAO,MAAM,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC,CAAC;QAClC,CAAC,CAAC,CAAC;KACJ;IAED,IAAI,eAAe,GAAyB,IAAI,CAAC;IACjD,IAAI,WAAW,IAAI,mBAAmB,IAAI,YAAY,EAAE;QACtD,MAAM,MAAM,GACR,WAAW,CAAC,YAAY,CAAC,iBAAiB,CAAsB,CAAC;QACrE,eAAe,GAAG,qBAAqB,CACnC,MAAM,CAAC,0BAA0B,EAAE,MAAM,CAAC,sBAAsB,EAChE,MAAM,CAAC,sBAAsB,EAAE,MAAM,CAAC,0BAA0B,EAChE,MAAM,CAAC,sBAAsB,EAAE,MAAM,CAAC,sBAAsB,EAC5D,MAAM,CAAC,oBAAoB,CAAC,CAAC;KAClC;IACD,OAAO,kBAAkB,CAAC,KAAM,EAAE,eAAgB,CAAC,CAAC;AACtD,CAAC;AAED;;;;;;;;;;;;GAYG;AACH,SAAS,iBAAiB,CACtB,KAAmB,EAAE,SAAuB;IAC9C,IAAI,CAAC,SAAS,EAAE;QACd,OAAO,IAAI,CAAC;KACb;IAED,IAAI,CAAC,SAAS,CAAC,UAAU,IAAI,CAAC,SAAS,CAAC,eAAe,EAAE;QACvD,OAAO,KAAK,CAAC;KACd;IAED,IAAI,KAAK,GAAG,KAAK,CAAC,UAAU,CAAC;IAC7B,IAAI,SAAS,CAAC,UAAU,EAAE;QACxB,KAAK,GAAG,SAAS,CAAC,UAAU,CAAC;KAC9B;IACD,IAAI,eAAe,GAAG,KAAK,CAAC,eAAe,CAAC;IAC5C,IAAI,SAAS,CAAC,eAAe,EAAE;QAC7B,eAAe,GAAG,SAAS,CAAC,eAAe,CAAC;KAC7C;IACD,OAAO,kBAAkB,CAAC,KAAK,EAAE,eAAe,CAAC,CAAC;AACpD,CAAC;AAsCD;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6DG;AACH,SAAgB,iBAAiB,CAC7B,WAAmB,EAAE,YAA0B,EAC/C,eAA6B,EAAE,UAAqC,EACpE,SAAc,EAAE,OAA4B;IAC9C,SAAS,GAAG,SAAS,IAAI,EAAE,CAAC;IAC5B,kCAAkC;IAClC,MAAM,QAAQ,GAAQ,EAAE,CAAC;IAEzB,MAAM,aAAa,GAAG,CAAC,YAAY,CAAC,UAAU,IAAI,EAAE,CAAC,CAAC,WAAW,CAAC,CAAC;IACnE,IAAI,CAAC,aAAa,EAAE;QAClB,OAAO,IAAI,CAAC;KACb;IAED,MAAM,SAAS,GAAG,CAAC,eAAe,CAAC,UAAU,IAAI,EAAE,CAAC,CAAC,WAAW,CAAC,IAAI,EAAE,CAAC;IACxE,MAAM,OAAO,GAAG,aAAa,CAAC,OAAO,CAAC;IACtC,MAAM,iBAAiB,GAAG,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC;IAClD,iCAAiC;IACjC,KAAK,MAAM,UAAU,IAAI,OAAO,EAAE;QAChC,MAAM,YAAY,GAAG,OAAO,CAAC,UAAU,CAAC,CAAC;QACzC,MAAM,MAAM,GAAG,UAAU,CAAC,CAAC,CAAC,CAAC,WAAW,EAAE,GAAG,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QAEjE,IAAI,KAAK,GAAG,cAAc,CACtB,YAAY,EAAE,aAAa,CAAC,WAAW,EAAE,aAAa,CAAC,YAAY,EACnE,UAAU,CAAC,CAAC;QAChB,IAAI,cAAc,GAAG,YAAY,CAAC,QAAQ,CAAC;QAC3C,IAAI,OAAO,GAAG,YAAY,CAAC,cAAc,CAAC;QAC1C,IAAI,UAAU,IAAI,iBAAiB,EAAE;YACnC,MAAM,gBAAgB,GAAG,iBAAiB,CAAC,UAAU,CAAC,CAAC;YACvD,IAAI,gBAAgB,EAAE;gBACpB,IAAI,UAAU,IAAI,gBAAgB,EAAE;oBAClC,cAAc,GAAG,gBAAgB,CAAC,QAAQ,CAAC;iBAC5C;gBACD,IAAI,gBAAgB,IAAI,gBAAgB,EAAE;oBACxC,OAAO,GAAG,gBAAgB,CAAC,cAAc,CAAC;iBAC3C;aACF;YACD,KAAK,GAAG,iBAAiB,CACrB,KAAM,EACN,cAAc,CACV,gBAAgB,EAAE,SAAS,CAAC,WAAW,EAAE,SAAS,CAAC,YAAY,EAC/D,UAAU,CAAE,CAAC,CAAC;SACvB;QAED,QAAQ,CAAC,MAAM,CAAC,GAAG,IAAI,YAAY,CAAC;YAClC,OAAO;YACP,KAAK;YACL,aAAa,EAAE,cAAc,CAAC,CAAC,CAAC,mBAAmB,CAAC,cAAc,CAAC,CAAC,CAAC;gBACrC,IAAI;YACpC,SAAS;YACT,OAAO,EAAE,OAAO,IAAI,OAAO;SAC5B,CAAC,CAAC;KACJ;IAED,OAAO,QAAQ,CAAC;AAClB,CAAC;AAtDD,8CAsDC"}

-import { status } from 'grpc';

-export declare class GoogleError extends Error {

- code?: status;

- note?: string;

-}

-"use strict";

-/*

- * Copyright 2018, Google Inc.

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions are

- * met:

- *

- * * Redistributions of source code must retain the above copyright

- * notice, this list of conditions and the following disclaimer.

- * * Redistributions in binary form must reproduce the above

- * copyright notice, this list of conditions and the following disclaimer

- * in the documentation and/or other materials provided with the

- * distribution.

- * * Neither the name of Google Inc. nor the names of its

- * contributors may be used to endorse or promote products derived from

- * this software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- */

-Object.defineProperty(exports, "__esModule", { value: true });

-class GoogleError extends Error {

-}

-exports.GoogleError = GoogleError;

-//# sourceMappingURL=GoogleError.js.map

-{"version":3,"file":"GoogleError.js","sourceRoot":"","sources":["../../src/GoogleError.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6BG;;AAIH,MAAa,WAAY,SAAQ,KAAK;CAGrC;AAHD,kCAGC"}

- isLegacy: boolean;

- * when necessary. Uses legacy grpc.loadObject.

- * @param {String} protoPath - The directory to search for the protofile.

- * @param {String} filename - The filename of the proto to be loaded.

- * @return {Object<string, *>} The gRPC loaded result (the toplevel namespace

- * object).

- */

- protected loadProtoLegacy(protoPath: string, filename: string): grpcTypes.GrpcObject;

- /**

- * Load grpc proto service from a filename hooking in googleapis common protos

- * when necessary. Uses the new shiny @grpc/proto-loader.

- * @param {String} protoPath - The directory to search for the protofile.

- * @param {String} filename - The filename of the proto to be loaded.

- * @return {Object<string, *>} The gRPC loaded result (the toplevel namespace

- * object).

- */

- protected loadProtoGrpcJs(protoPath: string, filename: string): grpcTypes.GrpcObject;

- /**

- * Load grpc proto service from a filename hooking in googleapis common protos

- * when necessary. Can use either legacy grpc.loadProto, or new

- * @grpc/proto-loader, depending on which gRPC backend is used.

- * Copyright 2016, Google Inc.

-const google_proto_files_1 = require("google-proto-files");

-const googleProtoFilesDir = path.normalize(google_proto_files_1.getProtoPath('..'));

-const COMMON_PROTO_DIRS = [

- // This list of directories is defined here:

- // https://github.com/googleapis/googleapis/blob/master/gapic/packaging/common_protos.yaml

- 'api',

- path.join('iam', 'v1'),

- path.join('logging', 'type'),

- path.join('monitoring', 'v3'),

- 'longrunning',

- 'protobuf',

- 'rpc',

- 'type',

-].map(dir => path.join(googleProtoFilesDir, 'google', dir));

-INCLUDE_DIRS.push(...COMMON_PROTO_DIRS);

-const COMMON_PROTO_FILES = COMMON_PROTO_DIRS

- .map(dir => {

- return walk.sync(dir)

-})

- .reduce((a, c) => a.concat(c), []);

- this.grpc.isLegacy = false;

- this.grpc.isLegacy = true;

- * when necessary. Uses legacy grpc.loadObject.

- loadProtoLegacy(protoPath, filename) {

- const resolvedPath = GrpcClient._resolveFile(protoPath, filename);

- const retval = this.grpc.loadObject(protobuf.loadSync(resolvedPath, new GoogleProtoFilesRoot()));

- return retval;

- }

- /**

- * Load grpc proto service from a filename hooking in googleapis common protos

- * when necessary. Uses the new shiny @grpc/proto-loader.

- * @param {String} protoPath - The directory to search for the protofile.

- * @param {String} filename - The filename of the proto to be loaded.

- * @return {Object<string, *>} The gRPC loaded result (the toplevel namespace

- * object).

- */

- loadProtoGrpcJs(protoPath, filename) {

- /**

- * Load grpc proto service from a filename hooking in googleapis common protos

- * when necessary. Can use either legacy grpc.loadProto, or new

- * @grpc/proto-loader, depending on which gRPC backend is used.

- * @param {String} protoPath - The directory to search for the protofile.

- * @param {String} filename - The filename of the proto to be loaded.

- * @return {Object<string, *>} The gRPC loaded result (the toplevel namespace

- * object).

- */

- loadProto(protoPath, filename) {

- return this.grpc.isLegacy ? this.loadProtoLegacy(protoPath, filename) :

- this.loadProtoGrpcJs(protoPath, filename);

- }

- // proto. If it is a common proto, use the google-proto-files proto.

-{"version":3,"file":"grpc.js","sourceRoot":"","sources":["../../src/grpc.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA8BG;;;;;;;;;;AAEH,2DAA2D,CAAE,iBAAiB;AAC9E,yBAAyB;AACzB,6DAAkE;AAClE,2DAAgD;AAChD,kCAAkC,CAAE,iBAAiB;AACrD,oCAAoC;AAEpC,6BAA6B;AAC7B,uCAAuC;AACvC,iCAAiC;AACjC,gCAAgC;AAEhC,6BAA6B;AAE7B,MAAM,mBAAmB,GAAG,IAAI,CAAC,SAAS,CAAC,iCAAY,CAAC,IAAI,CAAC,CAAC,CAAC;AAE/D,+CAA+C;AAC/C,MAAM,YAAY,GAAa,EAAE,CAAC;AAClC,YAAY,CAAC,IAAI,CAAC,mBAAmB,CAAC,CAAC;AAEvC,6DAA6D;AAC7D,8BAA8B;AAC9B,MAAM,iBAAiB,GAAG;IACxB,4CAA4C;IAC5C,0FAA0F;IAC1F,KAAK;IACL,IAAI,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAAC;IACtB,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,MAAM,CAAC;IAC5B,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE,IAAI,CAAC;IAC7B,aAAa;IACb,UAAU;IACV,KAAK;IACL,MAAM;CACP,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,QAAQ,EAAE,GAAG,CAAC,CAAC,CAAC;AAC5D,YAAY,CAAC,IAAI,CAAC,GAAG,iBAAiB,CAAC,CAAC;AAExC,MAAM,kBAAkB,GAAG,iBAAiB;KACZ,GAAG,CAAC,GAAG,CAAC,EAAE;IACT,OAAQ,IAAI,CAAC,IAAI,CAAC,GAAG,CAAc;SAC9B,MAAM,CAAC,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC,KAAK,QAAQ,CAAC;SACzC,GAAG,CACA,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,SAAS,CAC5B,mBAAmB,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC;AAC/C,CAAC,CAAC;KACD,MAAM,CAAC,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;AAiClE,MAAa,UAAW,SAAQ,SAAS,CAAC,MAAM;CAE/C;AAFD,gCAEC;AAED,MAAa,UAAU;IAOrB;;;;;;;;;;;;;;;;OAgBG;IACH,YAAY,UAA6B,EAAE;QACzC,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,IAAI,IAAI,IAAI,gCAAU,CAAC,OAAO,CAAC,CAAC;QACpD,IAAI,CAAC,OAAO,GAAG,OAAO,CAAC,OAAO,IAAI,OAAO,CAAC;QAE1C,IAAI,MAAM,IAAI,OAAO,EAAE;YACrB,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,IAAK,CAAC;YAC1B,IAAI,CAAC,WAAW,GAAG,EAAE,CAAC;SACvB;aAAM;YACL,qEAAqE;YACrE,uEAAuE;YACvE,IAAI,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,OAAO,EAAE,QAAQ,CAAC;gBACrC,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,wBAAwB,EAAE;gBAC1C,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,eAAe,CAAC,CAAC;gBACrC,IAAI,CAAC,IAAI,CAAC,QAAQ,GAAG,KAAK,CAAC;gBAC3B,IAAI,CAAC,WAAW,GAAG,OAAO,CAAC,4BAA4B,CAAC,CAAC,OAAO,CAAC;aAClE;iBAAM;gBACL,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,MAAM,CAAC,CAAC;gBAC5B,IAAI,CAAC,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC;gBAC1B,IAAI,CAAC,WAAW,GAAG,OAAO,CAAC,mBAAmB,CAAC,CAAC,OAAO,CAAC;aACzD;SACF;QACD,IAAI,CAAC,eAAe,GAAG,OAAO,CAAC,oBAAoB,CAAC,CAAC;IACvD,CAAC;IAED;;;;;;;OAOG;IACG,eAAe,CAAC,IAAuB;;YAC3C,IAAI,IAAI,CAAC,QAAQ,EAAE;gBACjB,OAAO,IAAI,CAAC,QAAQ,CAAC;aACtB;YACD,MAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC;YACvB,MAAM,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,SAAS,EAAE,CAAC;YAC9C,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,CAAC;YAC3C,MAAM,WAAW,GAAG,IAAI,CAAC,WAAW,CAAC,yBAAyB,CAC1D,QAAQ,EAAE,IAAI,CAAC,WAAW,CAAC,0BAA0B,CAAC,MAAM,CAAC,CAAC,CAAC;YACnE,OAAO,WAAW,CAAC;QACrB,CAAC;KAAA;IAED;;;;;OAKG;IACH,aAAa,CAAC,QAAgB,EAAE,OAAqC;QACnE,MAAM,UAAU,GAAG,oBAAoB,CAAC,QAAQ,CAAC,QAAQ,EAAE,OAAO,CAAC,CAAC;QACpE,OAAO,IAAI,CAAC,IAAI,CAAC,qBAAqB,CAAC,UAAU,CAAC,CAAC;IACrD,CAAC;IAED;;;;;;;OAOG;IACO,eAAe,CAAC,SAAiB,EAAE,QAAgB;QAC3D,MAAM,YAAY,GAAG,UAAU,CAAC,YAAY,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAC;QAClE,MAAM,MAAM,GAAG,IAAI,CAAC,IAAI,CAAC,UAAU,CAC/B,QAAQ,CAAC,QAAQ,CAAC,YAAY,EAAE,IAAI,oBAAoB,EAAE,CAAC,CAAC,CAAC;QACjE,OAAO,MAAM,CAAC;IAChB,CAAC;IAED;;;;;;;OAOG;IACO,eAAe,CAAC,SAAiB,EAAE,QAAgB;QAC3D,yCAAyC;QACzC,4DAA4D;QAC5D,MAAM,WAAW,GAAG,YAAY,CAAC,KAAK,EAAE,CAAC;QACzC,WAAW,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;QAC/B,MAAM,OAAO,GAAG;YACd,QAAQ,EAAE,KAAK;YACf,KAAK,EAAE,MAAM;YACb,KAAK,EAAE,MAAM;YACb,QAAQ,EAAE,IAAI;YACd,MAAM,EAAE,IAAI;YACZ,WAAW;SACZ,CAAC;QACF,OAAO,IAAI,CAAC,aAAa,CAAC,QAAQ,EAAE,OAAO,CAAC,CAAC;IAC/C,CAAC;IAED;;;;;;;;OAQG;IACH,SAAS,CAAC,SAAiB,EAAE,QAAgB;QAC3C,OAAO,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,eAAe,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAC,CAAC;YAC3C,IAAI,CAAC,eAAe,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAC;IACxE,CAAC;IAED,MAAM,CAAC,YAAY,CAAC,SAAiB,EAAE,QAAgB;QACrD,IAAI,EAAE,CAAC,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAC,EAAE;YACjD,OAAO,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAC;SACvC;aAAM,IAAI,kBAAkB,CAAC,OAAO,CAAC,QAAQ,CAAC,GAAG,CAAC,CAAC,EAAE;YACpD,OAAO,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,QAAQ,CAAC,CAAC;SACjD;QACD,MAAM,IAAI,KAAK,CAAC,QAAQ,GAAG,yBAAyB,GAAG,SAAS,CAAC,CAAC;IACpE,CAAC;IAED,eAAe,CAAC,OAA4B;QAC1C,MAAM,QAAQ,GAAG,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC;QACpC,MAAM,YAAY,GAAG,IAAI,QAAQ,EAAE,CAAC;QACpC,iCAAiC;QACjC,KAAK,MAAM,GAAG,IAAI,OAAO,EAAE;YACzB,MAAM,KAAK,GAAG,OAAO,CAAC,GAAG,CAAC,CAAC;YAC3B,IAAI,KAAK,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;gBACxB,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,CAAC,YAAY,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,CAAC,CAAC,CAAC;aAC9C;iBAAM;gBACL,YAAY,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,KAAK,EAAE,CAAC,CAAC;aACnC;SACF;QACD,OAAO,SAAS,aAAa,CACzB,OAAY,EAAE,WAAiC;YACjD,sDAAsD;YACtD,IAAI,MAAM,GAAG,KAAK,CAAC;YACnB,IAAI,QAAQ,GAAG,YAAY,CAAC;YAC5B,IAAI,WAAW,EAAE;gBACf,KAAK,MAAM,GAAG,IAAI,WAAW,EAAE;oBAC7B,IAAI,GAAG,CAAC,WAAW,EAAE,KAAK,mBAAmB;wBACzC,WAAY,CAAC,cAAc,CAAC,GAAG,CAAC,EAAE;wBACpC,IAAI,CAAC,MAAM,EAAE;4BACX,MAAM,GAAG,IAAI,CAAC;4BACd,QAAQ,GAAG,QAAQ,CAAC,KAAK,EAAE,CAAC;yBAC7B;wBACD,MAAM,KAAK,GAAG,WAAW,CAAC,GAAG,CAAC,CAAC;wBAC/B,IAAI,KAAK,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;4BACxB,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,CAAC,CAAC,CAAC;yBAC1C;6BAAM;4BACL,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,KAAK,EAAE,CAAC,CAAC;yBAC/B;qBACF;iBACF;aACF;YACD,OAAO,QAAQ,CAAC;QAClB,CAAC,CAAC;IACJ,CAAC;IAED;;;;;;;;;;OAUG;IACH,iBAAiB,CACb,WAAmB,EAAE,YAA8B,EACnD,eAAiC,EAAE,OAA4B;QACjE,OAAO,GAAG,CAAC,iBAAiB,CACxB,WAAW,EAAE,YAAY,EAAE,eAAe,EAAE,IAAI,CAAC,IAAI,CAAC,MAAM,EAC5D,EAAC,eAAe,EAAE,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,EAAC,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;IACtE,CAAC;IAED;;;;;;;;;;;OAWG;IACH,yCAAyC;IACnC,UAAU,CAAC,UAA6B,EAAE,OAA0B;;YACxE,MAAM,cAAc,GAAG,OAAO,CAAC,WAAW,GAAG,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;YAChE,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,eAAe,CAAC,OAAO,CAAC,CAAC;YAClD,MAAM,WAAW,GAA0B,EAAE,CAAC;YAC9C,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE;gBACjC,IAAI,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;oBAC9B,WAAW,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,GAAG,CAAC,CAAC;iBACjC;YACH,CAAC,CAAC,CAAC;YACH,MAAM,mBAAmB,GAAG,OAAO,CAAC,oBAAoB,CAAC,CAAC;YAC1D,IAAI,mBAAmB,EAAE;gBACvB,MAAM,SAAS,GAAG,OAAO,CAAC,kBAAkB,CAAC,mBAAmB,CAAC,CAAC;gBAClE,WAAW,CAAC,wBAAwB,CAAC,GAAG,OAAO,CAAC,yBAAyB,CAAC;gBAC1E,WAAW,CAAC,2BAA2B,CAAC;oBACpC,OAAO,CAAC,4BAA4B,CAAC;gBACzC,WAAW,CAAC,cAAc,CAAC,GAAG,SAAS,CAAC;aACzC;YACD,MAAM,IAAI,GAAG,IAAI,UAAU,CAAC,cAAc,EAAE,KAAK,EAAE,WAAW,CAAC,CAAC;YAChE,OAAO,IAAI,CAAC;QACd,CAAC;KAAA;IAED;;;;;;;;;OASG;IACH,MAAM,CAAC,wBAAwB,CAAC,OAK/B;QACC,OAAO,SAAS,aAAa,CAAC,GAAO;YACnC,OAAO,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,MAAM,EAAE,CAAC,MAAM,CAAC;QAC7C,CAAC,CAAC;IACJ,CAAC;CACF;AA5PD,gCA4PC;AAED,MAAa,oBAAqB,SAAQ,QAAQ,CAAC,IAAI;IACrD,YAAY,GAAG,IAAe;QAC5B,KAAK,CAAC,GAAG,IAAI,CAAC,CAAC;IACjB,CAAC;IAED,qEAAqE;IACrE,oEAAoE;IACpE,WAAW,CAAC,UAAkB,EAAE,WAAmB;QACjD,UAAU,GAAG,IAAI,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;QACxC,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC;QAE1C,mDAAmD;QACnD,IAAI,IAAI,CAAC,UAAU,CAAC,WAAW,CAAC,EAAE;YAChC,IAAI,CAAC,EAAE,CAAC,UAAU,CAAC,WAAW,CAAC,EAAE;gBAC/B,MAAM,IAAI,KAAK,CAAC,eAAe,GAAG,WAAW,GAAG,kBAAkB,CAAC,CAAC;aACrE;YACD,OAAO,WAAW,CAAC;SACpB;QAED,IAAI,kBAAkB,CAAC,OAAO,CAAC,WAAW,CAAC,GAAG,CAAC,CAAC,EAAE;YAChD,OAAO,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,WAAW,CAAC,CAAC;SACpD;QAED,OAAO,oBAAoB,CAAC,gBAAgB,CAAC,UAAU,EAAE,WAAW,CAAC,CAAC;IACxE,CAAC;IAED,MAAM,CAAC,gBAAgB,CAAC,UAAkB,EAAE,WAAmB;QAC7D,UAAU,GAAG,IAAI,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;QACxC,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC;QAE1C,IAAI,OAAO,GAAG,UAAU,CAAC;QACzB,IAAI,KAAK,GAAG,EAAE,CAAC,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC,CAAC;QAC3D,OAAO,CAAC,KAAK,IAAI,OAAO,CAAC,MAAM,GAAG,CAAC,EAAE;YACnC,OAAO,GAAG,OAAO,CAAC,SAAS,CAAC,CAAC,EAAE,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,CAAC;YAC9D,KAAK,GAAG,EAAE,CAAC,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC,CAAC;SACxD;QACD,IAAI,CAAC,KAAK,EAAE;YACV,MAAM,IAAI,KAAK,CAAC,eAAe,GAAG,WAAW,GAAG,kBAAkB,CAAC,CAAC;SACrE;QACD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC;IACzC,CAAC;CACF;AAzCD,oDAyCC"}

- * Copyright 2016, Google Inc.

-export { CancellablePromise, Canceller, createApiCall } from './apiCallable';

-export { BundleDescriptor, BundleExecutor } from './bundling';

-export { GoogleError } from './GoogleError';

-export { LongrunningDescriptor, Operation, operation } from './longrunning';

-export { PageDescriptor } from './pagedIteration';

-export { StreamDescriptor, StreamType } from './streaming';

- * Copyright 2016, Google Inc.

-var apiCallable_1 = require("./apiCallable");

-exports.Canceller = apiCallable_1.Canceller;

-exports.createApiCall = apiCallable_1.createApiCall;

-var bundling_1 = require("./bundling");

-exports.BundleDescriptor = bundling_1.BundleDescriptor;

-exports.BundleExecutor = bundling_1.BundleExecutor;

-var GoogleError_1 = require("./GoogleError");

-exports.GoogleError = GoogleError_1.GoogleError;

-var longrunning_1 = require("./longrunning");

-exports.LongrunningDescriptor = longrunning_1.LongrunningDescriptor;

-var pagedIteration_1 = require("./pagedIteration");

-exports.PageDescriptor = pagedIteration_1.PageDescriptor;

-var streaming_1 = require("./streaming");

-exports.StreamDescriptor = streaming_1.StreamDescriptor;

-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6BG;;AAEH,iCAAqD;AACrD,uDAAuD;AACvD,iDAAiD;AAYzC,sCAAa;AAVrB,2DAAkE;AAA1D,2CAAA,UAAU,CAAA;AAClB,6CAA2E;AAA/C,kCAAA,SAAS,CAAA;AAAE,sCAAA,aAAa,CAAA;AACpD,uCAA4D;AAApD,sCAAA,gBAAgB,CAAA;AAAE,oCAAA,cAAc,CAAA;AACxC,6BAA+F;AAA1E,6BAAA,YAAY,CAAA;AAAgB,kCAAA,iBAAiB,CAAA;AAAE,6BAAA,YAAY,CAAA;AAChF,6CAA0C;AAAlC,oCAAA,WAAW,CAAA;AACnB,+BAA2J;AAAnJ,4BAAA,UAAU,CAAA;AAAqB,sCAAA,oBAAoB,CAAA;AAAE,4BAAA,UAAU,CAAA;AACvE,6CAA0E;AAAlE,8CAAA,qBAAqB,CAAA;AAAE,kCAAA,SAAS,CAAA;AAAE,kCAAA,SAAS,CAAA;AACnD,mDAAgD;AAAxC,0CAAA,cAAc,CAAA;AACtB,+CAA4C;AAApC,sCAAA,YAAY,CAAA;AACpB,yCAAyD;AAAjD,uCAAA,gBAAgB,CAAA;AAAE,iCAAA,UAAU,CAAA;AAGpC,SAAS,GAAG,CAAC,OAA0B;IACrC,OAAO,GAAG,MAAM,CAAC,MAAM,CAAC,EAAC,MAAM,EAAE,GAAG,CAAC,UAAU,EAAC,EAAE,OAAO,CAAC,CAAC;IAC3D,MAAM,OAAO,GAAG,IAAI,iBAAU,CAAC,OAAO,CAAC,CAAC;IACxC,OAAO,IAAI,gBAAgB,CAAC,uBAAuB,CAAC,OAAO,CAAC,CAAC;AAC/D,CAAC;AAKO,kBAAG;AAHX,GAAG,CAAC,eAAe,GAAG,gBAAgB,CAAC,eAAe,CAAC;AACvD,GAAG,CAAC,UAAU,GAAG,gBAAgB,CAAC,UAAU,CAAC;AAGhC,QAAA,wBAAwB,GAAG,iBAAU,CAAC,wBAAwB,CAAC;AAC/D,QAAA,OAAO,GAAG,OAAO,CAAC,oBAAoB,CAAC,CAAC,OAAO,CAAC"}

-/**

- * Copyright 2019 Google LLC. All Rights Reserved.

- *

- * Licensed under the Apache License, Version 2.0 (the "License");

- * you may not use this file except in compliance with the License.

- * You may obtain a copy of the License at

- *

- * http://www.apache.org/licenses/LICENSE-2.0

- *

- * Unless required by applicable law or agreed to in writing, software

- * distributed under the License is distributed on an "AS IS" BASIS,

- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

- * See the License for the specific language governing permissions and

- * limitations under the License.

- */

-/**

- * Copyright 2019 Google LLC. All Rights Reserved.

- * Licensed under the Apache License, Version 2.0 (the "License");

- * you may not use this file except in compliance with the License.

- * You may obtain a copy of the License at

- * http://www.apache.org/licenses/LICENSE-2.0

- * Unless required by applicable law or agreed to in writing, software

- * distributed under the License is distributed on an "AS IS" BASIS,

- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

- * See the License for the specific language governing permissions and

- * limitations under the License.

-{"version":3,"file":"isbrowser.js","sourceRoot":"","sources":["../../src/isbrowser.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;GAcG;;AAEH,SAAgB,SAAS;IACvB,OAAO,OAAO,CAAC,MAAM,CAAC,KAAK,WAAW,CAAC;AACzC,CAAC;AAFD,8BAEC"}

-/// <reference types="node" />

-import { EventEmitter } from 'events';

-import { APICall, APICallback, CancellablePromise, NormalApiCaller, PromiseCanceller } from './apiCallable';

-import { BackoffSettings, CallOptions } from './gax';

-import { GoogleError } from './GoogleError';

-import { Metadata } from './grpc';

-import { OperationsClient } from './operationsClient';

-/**

- * A callback to upack a google.protobuf.Any message.

- * @callback anyDecoder

- * @param {google.protobuf.Any} message - The message to unpacked.

- * @return {Object} - The unpacked message.

- */

-export interface AnyDecoder {

- (message: {}): Metadata;

-}

-/**

- * @callback GetOperationCallback

- * @param {?Error} error

- * @param {?Object} result

- * @param {?Object} metadata

- * @param {?google.longrunning.Operation} rawResponse

- */

-export interface GetOperationCallback {

- (err?: Error | null, result?: {}, metadata?: {}, rawResponse?: Operation): void;

-}

-export declare class LongrunningDescriptor {

- operationsClient: OperationsClient;

- responseDecoder: AnyDecoder;

- metadataDecoder: AnyDecoder;

- /**

- * Describes the structure of a page-streaming call.

- *

- * @property {OperationsClient} operationsClient

- * @property {anyDecoder} responseDecoder

- * @property {anyDecoder} metadataDecoder

- *

- * @param {OperationsClient} operationsClient - The client used to poll or

- * cancel an operation.

- * @param {anyDecoder=} responseDecoder - The decoder to unpack

- * the response message.

- * @param {anyDecoder=} metadataDecoder - The decoder to unpack

- * the metadata message.

- *

- * @constructor

- */

- constructor(operationsClient: OperationsClient, responseDecoder: AnyDecoder, metadataDecoder: AnyDecoder);

- apiCaller(): LongrunningApiCaller;

-}

-export declare class LongrunningApiCaller extends NormalApiCaller {

- longrunningDescriptor: LongrunningDescriptor;

- /**

- * Creates an API caller that performs polling on a long running operation.

- *

- * @private

- * @constructor

- * @param {LongrunningDescriptor} longrunningDescriptor - Holds the

- * decoders used for unpacking responses and the operationsClient

- * used for polling the operation.

- */

- constructor(longrunningDescriptor: LongrunningDescriptor);

- call(apiCall: APICall, argument: {}, settings: CallOptions, canceller: PromiseCanceller): void;

- _wrapOperation(apiCall: APICall, settings: CallOptions, argument: {}, callback: APICallback): any;

-}

-export declare class Operation extends EventEmitter {

- completeListeners: number;

- hasActiveListeners: boolean;

- latestResponse: Operation;

- longrunningDescriptor: LongrunningDescriptor;

- result: {} | null;

- metadata: Metadata | null;

- backoffSettings: BackoffSettings;

- _callOptions?: CallOptions;

- currentCallPromise_?: CancellablePromise;

- name?: string;

- done?: boolean;

- error?: GoogleError;

- response?: {

- value: {};

- };

- /**

- * Wrapper for a google.longrunnung.Operation.

- *

- * @constructor

- *

- * @param {google.longrunning.Operation} grpcOp - The operation to be wrapped.

- * @param {LongrunningDescriptor} longrunningDescriptor - This defines the

- * operations service client and unpacking mechanisms for the operation.

- * @param {BackoffSettings} backoffSettings - The backoff settings used in

- * in polling the operation.

- * @param {CallOptions=} callOptions - CallOptions used in making get operation

- * requests.

- */

- constructor(grpcOp: Operation, longrunningDescriptor: LongrunningDescriptor, backoffSettings: BackoffSettings, callOptions?: CallOptions);

- /**

- * Begin listening for events on the operation. This method keeps track of how

- * many "complete" listeners are registered and removed, making sure polling

- * is handled automatically.

- *

- * As long as there is one active "complete" listener, the connection is open.

- * When there are no more listeners, the polling stops.

- *

- * @private

- */

- _listenForEvents(): void;

- /**

- * Cancels current polling api call and cancels the operation.

- *

- * @return {Promise} the promise of the OperationsClient#cancelOperation api

- * request.

- */

- cancel(): any;

- /**

- * Get the updated status of the operation. If the Operation has previously

- * completed, this will use the status of the cached completed operation.

- *

- * - callback(err): Operation failed

- * - callback(null, result, metadata, rawResponse): Operation complete

- * - callback(null, null, metadata, rawResponse): Operation incomplete

- *

- * @param {getOperationCallback} callback - Callback to handle the polled

- * operation result and metadata.

- * @return {Promise|undefined} - This returns a promise if a callback is not specified.

- * The promise resolves to an array where the first element is the unpacked

- * result, the second element is the metadata, and the third element is the

- * raw response of the api call. The promise rejects if the operation returns

- * an error.

- */

- getOperation(): Promise<{}>;

- getOperation(callback: GetOperationCallback): void;

- _unpackResponse(op: Operation, callback?: GetOperationCallback): void;

- /**

- * Poll `getOperation` to check the operation's status. This runs a loop to

- * ping using the backoff strategy specified at initialization.

- *

- * Note: This method is automatically called once a "complete" event handler

- * is registered on the operation.

- *

- * @private

- */

- startPolling_(): void;

- /**

- * Wraps the `complete` and `error` events in a Promise.

- *

- * @return {promise} - Promise that resolves on operation completion and rejects

- * on operation error.

- */

- promise(): Promise<{}>;

-}

-/**

- * Method used to create Operation objects.

- *

- * @constructor

- *

- * @param {google.longrunning.Operation} op - The operation to be wrapped.

- * @param {LongrunningDescriptor} longrunningDescriptor - This defines the

- * operations service client and unpacking mechanisms for the operation.

- * @param {BackoffSettings} backoffSettings - The backoff settings used in

- * in polling the operation.

- * @param {CallOptions=} callOptions - CallOptions used in making get operation

- * requests.

- */

-export declare function operation(op: Operation, longrunningDescriptor: LongrunningDescriptor, backoffSettings: BackoffSettings, callOptions?: CallOptions): Operation;

-"use strict";

-/*

- * Copyright 2016, Google Inc.

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions are

- * met:

- *

- * * Redistributions of source code must retain the above copyright

- * notice, this list of conditions and the following disclaimer.

- * * Redistributions in binary form must reproduce the above

- * copyright notice, this list of conditions and the following disclaimer

- * in the documentation and/or other materials provided with the

- * distribution.

- * * Neither the name of Google Inc. nor the names of its

- * contributors may be used to endorse or promote products derived from

- * this software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- */

-Object.defineProperty(exports, "__esModule", { value: true });

-const events_1 = require("events");

-const grpc_1 = require("grpc");

-const apiCallable_1 = require("./apiCallable");

-const gax_1 = require("./gax");

-const GoogleError_1 = require("./GoogleError");

-class LongrunningDescriptor {

- /**

- * Describes the structure of a page-streaming call.

- *

- * @property {OperationsClient} operationsClient

- * @property {anyDecoder} responseDecoder

- * @property {anyDecoder} metadataDecoder

- *

- * @param {OperationsClient} operationsClient - The client used to poll or

- * cancel an operation.

- * @param {anyDecoder=} responseDecoder - The decoder to unpack

- * the response message.

- * @param {anyDecoder=} metadataDecoder - The decoder to unpack

- * the metadata message.

- *

- * @constructor

- */

- constructor(operationsClient, responseDecoder, metadataDecoder) {

- this.operationsClient = operationsClient;

- this.responseDecoder = responseDecoder;

- this.metadataDecoder = metadataDecoder;

- }

- apiCaller() {

- return new LongrunningApiCaller(this);

- }

-}

-exports.LongrunningDescriptor = LongrunningDescriptor;

-class LongrunningApiCaller extends apiCallable_1.NormalApiCaller {

- /**

- * Creates an API caller that performs polling on a long running operation.

- *

- * @private

- * @constructor

- * @param {LongrunningDescriptor} longrunningDescriptor - Holds the

- * decoders used for unpacking responses and the operationsClient

- * used for polling the operation.

- */

- constructor(longrunningDescriptor) {

- super();

- this.longrunningDescriptor = longrunningDescriptor;

- }

- call(apiCall, argument, settings, canceller) {

- canceller.call((argument, callback) => {

- return this._wrapOperation(apiCall, settings, argument, callback);

- }, argument);

- }

- _wrapOperation(apiCall, settings, argument, callback) {

- // TODO: this code defies all logic, and just can't be accurate.

- // tslint:disable-next-line no-any

- let backoffSettings = settings.longrunning;

- if (!backoffSettings) {

- backoffSettings =

- gax_1.createBackoffSettings(100, 1.3, 60000, null, null, null, null);

- }

- const longrunningDescriptor = this.longrunningDescriptor;

- return apiCall(argument, (err, rawResponse) => {

- if (err) {

- callback(err, null, rawResponse);

- return;

- }

- const operation = new Operation(rawResponse, longrunningDescriptor, backoffSettings, settings);

- callback(null, operation, rawResponse);

- });

- }

-}

-exports.LongrunningApiCaller = LongrunningApiCaller;

-class Operation extends events_1.EventEmitter {

- /**

- * Wrapper for a google.longrunnung.Operation.

- *

- * @constructor

- *

- * @param {google.longrunning.Operation} grpcOp - The operation to be wrapped.

- * @param {LongrunningDescriptor} longrunningDescriptor - This defines the

- * operations service client and unpacking mechanisms for the operation.

- * @param {BackoffSettings} backoffSettings - The backoff settings used in

- * in polling the operation.

- * @param {CallOptions=} callOptions - CallOptions used in making get operation

- * requests.

- */

- constructor(grpcOp, longrunningDescriptor, backoffSettings, callOptions) {

- super();

- this.completeListeners = 0;

- this.hasActiveListeners = false;

- this.latestResponse = grpcOp;

- this.longrunningDescriptor = longrunningDescriptor;

- this.result = null;

- this.metadata = null;

- this.backoffSettings = backoffSettings;

- this._unpackResponse(grpcOp);

- this._listenForEvents();

- this._callOptions = callOptions;

- }

- /**

- * Begin listening for events on the operation. This method keeps track of how

- * many "complete" listeners are registered and removed, making sure polling

- * is handled automatically.

- *

- * As long as there is one active "complete" listener, the connection is open.

- * When there are no more listeners, the polling stops.

- *

- * @private

- */

- _listenForEvents() {

- this.on('newListener', event => {

- if (event === 'complete') {

- this.completeListeners++;

- if (!this.hasActiveListeners) {

- this.hasActiveListeners = true;

- this.startPolling_();

- }

- }

- });

- this.on('removeListener', event => {

- if (event === 'complete' && --this.completeListeners === 0) {

- this.hasActiveListeners = false;

- }

- });

- }

- /**

- * Cancels current polling api call and cancels the operation.

- *

- * @return {Promise} the promise of the OperationsClient#cancelOperation api

- * request.

- */

- cancel() {

- if (this.currentCallPromise_) {

- this.currentCallPromise_.cancel();

- }

- const operationsClient = this.longrunningDescriptor.operationsClient;

- return operationsClient.cancelOperation({ name: this.latestResponse.name });

- }

- getOperation(callback) {

- const self = this;

- const operationsClient = this.longrunningDescriptor.operationsClient;

- function promisifyResponse() {

- if (!callback) {

- // tslint:disable-next-line variable-name

- const PromiseCtor = self._callOptions.promise;

- return new PromiseCtor((resolve, reject) => {

- if (self.latestResponse.error) {

- const error = new GoogleError_1.GoogleError(self.latestResponse.error.message);

- error.code = self.latestResponse.error.code;

- reject(error);

- }

- else {

- resolve([self.result, self.metadata, self.latestResponse]);

- }

- });

- }

- return;

- }

- if (this.latestResponse.done) {

- this._unpackResponse(this.latestResponse, callback);

- return promisifyResponse();

- }

- this.currentCallPromise_ = operationsClient.getOperation({ name: this.latestResponse.name }, this._callOptions);

- const noCallbackPromise = this.currentCallPromise_.then(responses => {

- self.latestResponse = responses[0];

- self._unpackResponse(responses[0], callback);

- return promisifyResponse();

- });

- if (!callback) {

- return noCallbackPromise;

- }

- }

- _unpackResponse(op, callback) {

- const responseDecoder = this.longrunningDescriptor.responseDecoder;

- const metadataDecoder = this.longrunningDescriptor.metadataDecoder;

- let response;

- let metadata;

- if (op.done) {

- if (op.result === 'error') {

- const error = new GoogleError_1.GoogleError(op.error.message);

- error.code = op.error.code;

- if (callback) {

- callback(error);

- }

- return;

- }

- if (responseDecoder && op.response) {

- response = responseDecoder(op.response.value);

- this.result = response;

- }

- }

- if (metadataDecoder && op.metadata) {

- metadata = metadataDecoder(op.metadata.value);

- this.metadata = metadata;

- }

- if (callback) {

- callback(null, response, metadata, op);

- }

- }

- /**

- * Poll `getOperation` to check the operation's status. This runs a loop to

- * ping using the backoff strategy specified at initialization.

- *

- * Note: This method is automatically called once a "complete" event handler

- * is registered on the operation.

- *

- * @private

- */

- startPolling_() {

- const self = this;

- let now = new Date();

- const delayMult = this.backoffSettings.retryDelayMultiplier;

- const maxDelay = this.backoffSettings.maxRetryDelayMillis;

- let delay = this.backoffSettings.initialRetryDelayMillis;

- let deadline = Infinity;

- if (this.backoffSettings.totalTimeoutMillis) {

- deadline = now.getTime() + this.backoffSettings.totalTimeoutMillis;

- }

- let previousMetadataBytes;

- if (this.latestResponse.metadata) {

- previousMetadataBytes = this.latestResponse.metadata.value;

- }

- // tslint:disable-next-line no-any

- function emit(event, ...args) {

- self.emit(event, ...args);

- }

- function retry() {

- if (!self.hasActiveListeners) {

- return;

- }

- if (now.getTime() >= deadline) {

- const error = new GoogleError_1.GoogleError('Total timeout exceeded before any response was received');

- error.code = grpc_1.status.DEADLINE_EXCEEDED;

- setImmediate(emit, 'error', error);

- return;

- }

- self.getOperation((err, result, metadata, rawResponse) => {

- if (err) {

- setImmediate(emit, 'error', err);

- return;

- }

- if (!result) {

- if (rawResponse.metadata &&

- (!previousMetadataBytes ||

- !rawResponse.metadata.value.equals(previousMetadataBytes))) {

- setImmediate(emit, 'progress', metadata, rawResponse);

- previousMetadataBytes = rawResponse.metadata.value;

- }

- // special case: some APIs fail to set either result or error

- // but set done = true (e.g. speech with silent file).

- // Don't hang forever in this case.

- if (rawResponse.done) {

- const error = new GoogleError_1.GoogleError('Long running operation has finished but there was no result');

- error.code = grpc_1.status.UNKNOWN;

- setImmediate(emit, 'error', error);

- return;

- }

- setTimeout(() => {

- now = new Date();

- delay = Math.min(delay * delayMult, maxDelay);

- retry();

- }, delay);

- return;

- }

- setImmediate(emit, 'complete', result, metadata, rawResponse);

- });

- }

- retry();

- }

- /**

- * Wraps the `complete` and `error` events in a Promise.

- *

- * @return {promise} - Promise that resolves on operation completion and rejects

- * on operation error.

- */

- promise() {

- // tslint:disable-next-line variable-name

- const PromiseCtor = this._callOptions.promise;

- return new PromiseCtor((resolve, reject) => {

- this.on('error', reject)

- .on('complete', (result, metadata, rawResponse) => {

- resolve([result, metadata, rawResponse]);

- });

- });

- }

-}

-exports.Operation = Operation;

-/**

- * Method used to create Operation objects.

- *

- * @constructor

- *

- * @param {google.longrunning.Operation} op - The operation to be wrapped.

- * @param {LongrunningDescriptor} longrunningDescriptor - This defines the

- * operations service client and unpacking mechanisms for the operation.

- * @param {BackoffSettings} backoffSettings - The backoff settings used in

- * in polling the operation.

- * @param {CallOptions=} callOptions - CallOptions used in making get operation

- * requests.

- */

-function operation(op, longrunningDescriptor, backoffSettings, callOptions) {

- return new Operation(op, longrunningDescriptor, backoffSettings, callOptions);

-}

-exports.operation = operation;

-//# sourceMappingURL=longrunning.js.map

-{"version":3,"file":"longrunning.js","sourceRoot":"","sources":["../../src/longrunning.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6BG;;AAEH,mCAAoC;AACpC,+BAA4B;AAC5B,+CAA0G;AAC1G,+BAA0E;AAC1E,+CAA0C;AAyB1C,MAAa,qBAAqB;IAKhC;;;;;;;;;;;;;;;OAeG;IACH,YACI,gBAAkC,EAAE,eAA2B,EAC/D,eAA2B;QAC7B,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;QACzC,IAAI,CAAC,eAAe,GAAG,eAAe,CAAC;QACvC,IAAI,CAAC,eAAe,GAAG,eAAe,CAAC;IACzC,CAAC;IAED,SAAS;QACP,OAAO,IAAI,oBAAoB,CAAC,IAAI,CAAC,CAAC;IACxC,CAAC;CACF;AAhCD,sDAgCC;AAED,MAAa,oBAAqB,SAAQ,6BAAe;IAEvD;;;;;;;;OAQG;IACH,YAAY,qBAA4C;QACtD,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,qBAAqB,GAAG,qBAAqB,CAAC;IACrD,CAAC;IAGD,IAAI,CACA,OAAgB,EAAE,QAAY,EAAE,QAAqB,EACrD,SAA2B;QAC7B,SAAS,CAAC,IAAI,CAAC,CAAC,QAAQ,EAAE,QAAQ,EAAE,EAAE;YACpC,OAAO,IAAI,CAAC,cAAc,CAAC,OAAO,EAAE,QAAQ,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAC;QACpE,CAAC,EAAE,QAAQ,CAAC,CAAC;IACf,CAAC;IAED,cAAc,CACV,OAAgB,EAAE,QAAqB,EAAE,QAAY,EACrD,QAAqB;QACvB,gEAAgE;QAChE,kCAAkC;QAClC,IAAI,eAAe,GAAQ,QAAQ,CAAC,WAAW,CAAC;QAChD,IAAI,CAAC,eAAe,EAAE;YACpB,eAAe;gBACX,2BAAqB,CAAC,GAAG,EAAE,GAAG,EAAE,KAAK,EAAE,IAAI,EAAE,IAAI,EAAE,IAAI,EAAE,IAAI,CAAC,CAAC;SACpE;QAED,MAAM,qBAAqB,GAAG,IAAI,CAAC,qBAAqB,CAAC;QACzD,OAAO,OAAO,CAAC,QAAQ,EAAE,CAAC,GAAU,EAAE,WAAsB,EAAE,EAAE;YAC9D,IAAI,GAAG,EAAE;gBACP,QAAQ,CAAC,GAAG,EAAE,IAAI,EAAE,WAAW,CAAC,CAAC;gBACjC,OAAO;aACR;YAED,MAAM,SAAS,GAAG,IAAI,SAAS,CAC3B,WAAW,EAAE,qBAAqB,EAAE,eAAgB,EAAE,QAAQ,CAAC,CAAC;YAEpE,QAAQ,CAAC,IAAI,EAAE,SAAS,EAAE,WAAW,CAAC,CAAC;QACzC,CAAC,CAAC,CAAC;IACL,CAAC;CACF;AAjDD,oDAiDC;AAED,MAAa,SAAU,SAAQ,qBAAY;IAezC;;;;;;;;;;;;OAYG;IACH,YACI,MAAiB,EAAE,qBAA4C,EAC/D,eAAgC,EAAE,WAAyB;QAC7D,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,iBAAiB,GAAG,CAAC,CAAC;QAC3B,IAAI,CAAC,kBAAkB,GAAG,KAAK,CAAC;QAChC,IAAI,CAAC,cAAc,GAAG,MAAM,CAAC;QAC7B,IAAI,CAAC,qBAAqB,GAAG,qBAAqB,CAAC;QACnD,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC;QACnB,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC;QACrB,IAAI,CAAC,eAAe,GAAG,eAAe,CAAC;QACvC,IAAI,CAAC,eAAe,CAAC,MAAM,CAAC,CAAC;QAC7B,IAAI,CAAC,gBAAgB,EAAE,CAAC;QACxB,IAAI,CAAC,YAAY,GAAG,WAAW,CAAC;IAClC,CAAC;IAED;;;;;;;;;OASG;IACH,gBAAgB;QACd,IAAI,CAAC,EAAE,CAAC,aAAa,EAAE,KAAK,CAAC,EAAE;YAC7B,IAAI,KAAK,KAAK,UAAU,EAAE;gBACxB,IAAI,CAAC,iBAAiB,EAAE,CAAC;gBAEzB,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE;oBAC5B,IAAI,CAAC,kBAAkB,GAAG,IAAI,CAAC;oBAC/B,IAAI,CAAC,aAAa,EAAE,CAAC;iBACtB;aACF;QACH,CAAC,CAAC,CAAC;QAEH,IAAI,CAAC,EAAE,CAAC,gBAAgB,EAAE,KAAK,CAAC,EAAE;YAChC,IAAI,KAAK,KAAK,UAAU,IAAI,EAAE,IAAI,CAAC,iBAAiB,KAAK,CAAC,EAAE;gBAC1D,IAAI,CAAC,kBAAkB,GAAG,KAAK,CAAC;aACjC;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;OAKG;IACH,MAAM;QACJ,IAAI,IAAI,CAAC,mBAAmB,EAAE;YAC5B,IAAI,CAAC,mBAAmB,CAAC,MAAM,EAAE,CAAC;SACnC;QACD,MAAM,gBAAgB,GAAG,IAAI,CAAC,qBAAqB,CAAC,gBAAgB,CAAC;QACrE,OAAO,gBAAgB,CAAC,eAAe,CAAC,EAAC,IAAI,EAAE,IAAI,CAAC,cAAc,CAAC,IAAI,EAAC,CAAC,CAAC;IAC5E,CAAC;IAoBD,YAAY,CAAC,QAA+B;QAC1C,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,MAAM,gBAAgB,GAAG,IAAI,CAAC,qBAAqB,CAAC,gBAAgB,CAAC;QAErE,SAAS,iBAAiB;YACxB,IAAI,CAAC,QAAQ,EAAE;gBACb,yCAAyC;gBACzC,MAAM,WAAW,GAAG,IAAI,CAAC,YAAa,CAAC,OAAQ,CAAC;gBAChD,OAAO,IAAI,WAAW,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;oBACzC,IAAI,IAAI,CAAC,cAAc,CAAC,KAAK,EAAE;wBAC7B,MAAM,KAAK,GAAG,IAAI,yBAAW,CAAC,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC;wBACjE,KAAK,CAAC,IAAI,GAAG,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,IAAI,CAAC;wBAC5C,MAAM,CAAC,KAAK,CAAC,CAAC;qBACf;yBAAM;wBACL,OAAO,CAAC,CAAC,IAAI,CAAC,MAAM,EAAE,IAAI,CAAC,QAAQ,EAAE,IAAI,CAAC,cAAc,CAAC,CAAC,CAAC;qBAC5D;gBACH,CAAC,CAAC,CAAC;aACJ;YACD,OAAO;QACT,CAAC;QAED,IAAI,IAAI,CAAC,cAAc,CAAC,IAAI,EAAE;YAC5B,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,cAAc,EAAE,QAAQ,CAAC,CAAC;YACpD,OAAO,iBAAiB,EAAE,CAAC;SAC5B;QAED,IAAI,CAAC,mBAAmB,GAAG,gBAAgB,CAAC,YAAY,CACpD,EAAC,IAAI,EAAE,IAAI,CAAC,cAAc,CAAC,IAAI,EAAC,EAAE,IAAI,CAAC,YAAa,CAAC,CAAC;QAE1D,MAAM,iBAAiB,GAAG,IAAI,CAAC,mBAAoB,CAAC,IAAI,CAAC,SAAS,CAAC,EAAE;YACnE,IAAI,CAAC,cAAc,GAAG,SAAS,CAAC,CAAC,CAAC,CAAC;YACnC,IAAI,CAAC,eAAe,CAAC,SAAS,CAAC,CAAC,CAAC,EAAE,QAAQ,CAAC,CAAC;YAC7C,OAAO,iBAAiB,EAAG,CAAC;QAC9B,CAAC,CAAC,CAAC;QAEH,IAAI,CAAC,QAAQ,EAAE;YACb,OAAO,iBAAiB,CAAC;SAC1B;IACH,CAAC;IAED,eAAe,CAAC,EAAa,EAAE,QAA+B;QAC5D,MAAM,eAAe,GAAG,IAAI,CAAC,qBAAqB,CAAC,eAAe,CAAC;QACnE,MAAM,eAAe,GAAG,IAAI,CAAC,qBAAqB,CAAC,eAAe,CAAC;QACnE,IAAI,QAAY,CAAC;QACjB,IAAI,QAAkB,CAAC;QAEvB,IAAI,EAAE,CAAC,IAAI,EAAE;YACX,IAAI,EAAE,CAAC,MAAM,KAAK,OAAO,EAAE;gBACzB,MAAM,KAAK,GAAG,IAAI,yBAAW,CAAC,EAAE,CAAC,KAAM,CAAC,OAAO,CAAC,CAAC;gBACjD,KAAK,CAAC,IAAI,GAAG,EAAE,CAAC,KAAM,CAAC,IAAI,CAAC;gBAC5B,IAAI,QAAQ,EAAE;oBACZ,QAAQ,CAAC,KAAK,CAAC,CAAC;iBACjB;gBACD,OAAO;aACR;YAED,IAAI,eAAe,IAAI,EAAE,CAAC,QAAQ,EAAE;gBAClC,QAAQ,GAAG,eAAe,CAAC,EAAE,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC;gBAC9C,IAAI,CAAC,MAAM,GAAG,QAAQ,CAAC;aACxB;SACF;QAED,IAAI,eAAe,IAAI,EAAE,CAAC,QAAQ,EAAE;YAClC,QAAQ,GAAG,eAAe,CAAC,EAAE,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC;YAC9C,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC;SAC1B;QACD,IAAI,QAAQ,EAAE;YACZ,QAAQ,CAAC,IAAI,EAAE,QAAS,EAAE,QAAS,EAAE,EAAE,CAAC,CAAC;SAC1C;IACH,CAAC;IAED;;;;;;;;OAQG;IACH,aAAa;QACX,MAAM,IAAI,GAAG,IAAI,CAAC;QAElB,IAAI,GAAG,GAAG,IAAI,IAAI,EAAE,CAAC;QACrB,MAAM,SAAS,GAAG,IAAI,CAAC,eAAe,CAAC,oBAAoB,CAAC;QAC5D,MAAM,QAAQ,GAAG,IAAI,CAAC,eAAe,CAAC,mBAAmB,CAAC;QAC1D,IAAI,KAAK,GAAG,IAAI,CAAC,eAAe,CAAC,uBAAuB,CAAC;QACzD,IAAI,QAAQ,GAAG,QAAQ,CAAC;QACxB,IAAI,IAAI,CAAC,eAAe,CAAC,kBAAkB,EAAE;YAC3C,QAAQ,GAAG,GAAG,CAAC,OAAO,EAAE,GAAG,IAAI,CAAC,eAAe,CAAC,kBAAkB,CAAC;SACpE;QACD,IAAI,qBAAoC,CAAC;QACzC,IAAI,IAAI,CAAC,cAAc,CAAC,QAAQ,EAAE;YAChC,qBAAqB,GAAG,IAAI,CAAC,cAAc,CAAC,QAAQ,CAAC,KAAK,CAAC;SAC5D;QAED,kCAAkC;QAClC,SAAS,IAAI,CAAC,KAAoB,EAAE,GAAG,IAAW;YAChD,IAAI,CAAC,IAAI,CAAC,KAAK,EAAE,GAAG,IAAI,CAAC,CAAC;QAC5B,CAAC;QAED,SAAS,KAAK;YACZ,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE;gBAC5B,OAAO;aACR;YAED,IAAI,GAAG,CAAC,OAAO,EAAE,IAAI,QAAQ,EAAE;gBAC7B,MAAM,KAAK,GAAG,IAAI,yBAAW,CACzB,yDAAyD,CAAC,CAAC;gBAC/D,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,iBAAiB,CAAC;gBACtC,YAAY,CAAC,IAAI,EAAE,OAAO,EAAE,KAAK,CAAC,CAAC;gBACnC,OAAO;aACR;YAED,IAAI,CAAC,YAAY,CAAC,CAAC,GAAG,EAAE,MAAM,EAAE,QAAQ,EAAE,WAAW,EAAE,EAAE;gBACvD,IAAI,GAAG,EAAE;oBACP,YAAY,CAAC,IAAI,EAAE,OAAO,EAAE,GAAG,CAAC,CAAC;oBACjC,OAAO;iBACR;gBAED,IAAI,CAAC,MAAM,EAAE;oBACX,IAAI,WAAY,CAAC,QAAQ;wBACrB,CAAC,CAAC,qBAAqB;4BACtB,CAAC,WAAY,CAAC,QAAS,CAAC,KAAK,CAAC,MAAM,CAAC,qBAAqB,CAAC,CAAC,EAAE;wBACjE,YAAY,CAAC,IAAI,EAAE,UAAU,EAAE,QAAQ,EAAE,WAAW,CAAC,CAAC;wBACtD,qBAAqB,GAAG,WAAY,CAAC,QAAS,CAAC,KAAK,CAAC;qBACtD;oBACD,6DAA6D;oBAC7D,sDAAsD;oBACtD,mCAAmC;oBACnC,IAAI,WAAY,CAAC,IAAI,EAAE;wBACrB,MAAM,KAAK,GAAG,IAAI,yBAAW,CACzB,6DAA6D,CAAC,CAAC;wBACnE,KAAK,CAAC,IAAI,GAAG,aAAM,CAAC,OAAO,CAAC;wBAC5B,YAAY,CAAC,IAAI,EAAE,OAAO,EAAE,KAAK,CAAC,CAAC;wBACnC,OAAO;qBACR;oBACD,UAAU,CAAC,GAAG,EAAE;wBACd,GAAG,GAAG,IAAI,IAAI,EAAE,CAAC;wBACjB,KAAK,GAAG,IAAI,CAAC,GAAG,CAAC,KAAK,GAAG,SAAS,EAAE,QAAQ,CAAC,CAAC;wBAC9C,KAAK,EAAE,CAAC;oBACV,CAAC,EAAE,KAAK,CAAC,CAAC;oBACV,OAAO;iBACR;gBAED,YAAY,CAAC,IAAI,EAAE,UAAU,EAAE,MAAM,EAAE,QAAQ,EAAE,WAAW,CAAC,CAAC;YAChE,CAAC,CAAC,CAAC;QACL,CAAC;QACD,KAAK,EAAE,CAAC;IACV,CAAC;IAED;;;;;OAKG;IACH,OAAO;QACL,yCAAyC;QACzC,MAAM,WAAW,GAAG,IAAI,CAAC,YAAa,CAAC,OAAQ,CAAC;QAChD,OAAO,IAAI,WAAW,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACzC,IAAI,CAAC,EAAE,CAAC,OAAO,EAAE,MAAM,CAAC;iBACnB,EAAE,CAAC,UAAU,EAAE,CAAC,MAAM,EAAE,QAAQ,EAAE,WAAW,EAAE,EAAE;gBAChD,OAAO,CAAC,CAAC,MAAM,EAAE,QAAQ,EAAE,WAAW,CAAC,CAAC,CAAC;YAC3C,CAAC,CAAC,CAAC;QACT,CAAC,CAAC,CAAC;IACL,CAAC;CACF;AAhRD,8BAgRC;AAED;;;;;;;;;;;;GAYG;AACH,SAAgB,SAAS,CACrB,EAAa,EAAE,qBAA4C,EAC3D,eAAgC,EAAE,WAAyB;IAC7D,OAAO,IAAI,SAAS,CAAC,EAAE,EAAE,qBAAqB,EAAE,eAAe,EAAE,WAAW,CAAC,CAAC;AAChF,CAAC;AAJD,8BAIC"}

- getOperation(request: {}, options: {}, callback?: any): any;

- listOperations(request: any, options: any, callback: any): any;

- listOperationsStream(request: any, options?: {}): any;

- cancelOperation(request: any, options?: any, callback?: any): any;

- deleteOperation(request: any, options: any, callback: any): any;

- * Copyright 2018 Google LLC. All rights reserved.

- * Licensed under the Apache License, Version 2.0 (the "License");

- * you may not use this file except in compliance with the License.

- * You may obtain a copy of the License at

- *

- * http://www.apache.org/licenses/LICENSE-2.0

- *

- * Unless required by applicable law or agreed to in writing, software

- * distributed under the License is distributed on an "AS IS" BASIS,

- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

- * See the License for the specific language governing permissions and

- * limitations under the License.

-const google_proto_files_1 = require("google-proto-files");

-const apiCallable = require("./apiCallable");

-const gax = require("./gax");

-const pagedIteration = require("./pagedIteration");

-const pathTemplate = require("./pathTemplate");

-Object.assign(gax, apiCallable);

-Object.assign(gax, pathTemplate);

-Object.assign(gax, pagedIteration);

- listOperations: new gax['PageDescriptor']('pageToken', 'nextPageToken', 'operations'),

- googleApiClient.push(CODE_GEN_NAME_VERSION, 'gax/' + gax['version'], 'grpc/' + gaxGrpc.grpcVersion);

- this['_' + methodName] = gax['createApiCall'](operationsStub.then(operationsStub => {

- listOperationsStream(request, options = {}) {

- const protoFilesRoot = google_proto_files_1.getProtoPath('..');

-{"version":3,"file":"operationsClient.js","sourceRoot":"","sources":["../../src/operationsClient.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;GAcG;;AAIH,2DAAgD;AAEhD,6CAA6C;AAC7C,6BAA6B;AAE7B,mDAAmD;AACnD,+CAA+C;AAE/C,MAAM,UAAU,GAAG,OAAO,CAAC,4BAA4B,CAAC,CAAC;AAEzD,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,WAAW,CAAC,CAAC;AAChC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,YAAY,CAAC,CAAC;AACjC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,cAAc,CAAC,CAAC;AAEtB,QAAA,eAAe,GAAG,4BAA4B,CAAC;AAE5D,MAAM,oBAAoB,GAAG,GAAG,CAAC;AACjC,MAAM,qBAAqB,GAAG,aAAa,CAAC;AAC5C,MAAM,gBAAgB,GAAG;IACvB,cAAc,EACV,IAAI,GAAG,CAAC,gBAAgB,CAAC,CAAC,WAAW,EAAE,eAAe,EAAE,YAAY,CAAC;CAC1E,CAAC;AAEF;;;GAGG;AACU,QAAA,UAAU,GAAa,EAAE,CAAC;AAQvC;;;;;;;;;;;;;;;;;GAiBG;AACH,MAAa,gBAAgB;IAO3B;IACI,kCAAkC;IAClC,OAAmB,EAAE,WAAgB,EAAE,OAAgC;QACzE,MAAM,IAAI,GAA8C,MAAM,CAAC,MAAM,CACjE;YACE,WAAW,EAAE,uBAAe;YAC5B,IAAI,EAAE,oBAAoB;YAC1B,YAAY,EAAE,EAAE;SACjB,EACD,OAAO,CAAC,CAAC;QAEb,MAAM,eAAe,GAAG,CAAC,UAAU,GAAG,OAAO,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC;QAC7D,IAAI,IAAI,CAAC,OAAO,IAAI,IAAI,CAAC,UAAU,EAAE;YACnC,eAAe,CAAC,IAAI,CAAC,IAAI,CAAC,OAAO,GAAG,GAAG,GAAG,IAAI,CAAC,UAAU,CAAC,CAAC;SAC5D;QACD,eAAe,CAAC,IAAI,CAChB,qBAAqB,EAAE,MAAM,GAAG,GAAG,CAAC,SAAS,CAAC,EAC9C,OAAO,GAAG,OAAO,CAAC,WAAW,CAAC,CAAC;QAEnC,MAAM,QAAQ,GAAG,OAAO,CAAC,iBAAiB,CACtC,+BAA+B,EAAE,UAAU,EAAE,IAAI,CAAC,YAAY,EAC9D,EAAC,mBAAmB,EAAE,eAAe,CAAC,IAAI,CAAC,GAAG,CAAC,EAAC,CAAC,CAAC;QAEtD,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC;QACzB,MAAM,cAAc,GAChB,OAAO,CAAC,UAAU,CAAC,WAAW,CAAC,MAAM,CAAC,WAAW,CAAC,UAAU,EAAE,IAAI,CAAC,CAAC;QACxE,MAAM,qBAAqB,GAAG;YAC5B,cAAc;YACd,gBAAgB;YAChB,iBAAiB;YACjB,iBAAiB;SAClB,CAAC;QACF,qBAAqB,CAAC,OAAO,CAAC,UAAU,CAAC,EAAE;YACzC,IAAI,CAAC,GAAG,GAAG,UAAU,CAAC,GAAG,GAAG,CAAC,eAAe,CAAC,CACzC,cAAc,CAAC,IAAI,CAAC,cAAc,CAAC,EAAE;gBACnC,OAAO,CAAC,GAAG,IAAe,EAAE,EAAE;oBAC5B,OAAO,cAAc,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,cAAc,EAAE,IAAI,CAAC,CAAC;gBAChE,CAAC,CAAC;YACJ,CAAC,CAAC,EACF,QAAQ,CAAC,UAAU,CAAC,EAAE,gBAAgB,CAAC,UAAU,CAAC,CAAC,CAAC;QAC1D,CAAC,CAAC,CAAC;IACL,CAAC;IAWD,YAAY,CAAC,QAA4B;QACvC,OAAO,IAAI,CAAC,IAAI,CAAC,YAAY,CAAC,QAAS,CAAC,CAAC;IAC3C,CAAC;IAED,gBAAgB;IAEhB;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;OA8BG;IACH,YAAY,CAAC,OAAW,EAAE,OAAW,EAAE,QAAS;QAC9C,IAAI,OAAO,YAAY,QAAQ,IAAI,QAAQ,KAAK,SAAS,EAAE;YACzD,QAAQ,GAAG,OAAO,CAAC;YACnB,OAAO,GAAG,EAAE,CAAC;SACd;QACD,OAAO,GAAG,OAAO,IAAI,EAAE,CAAC;QACxB,OAAO,IAAI,CAAC,aAAa,CAAC,OAAO,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;IACxD,CAAC;IAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;OA4EG;IACH,cAAc,CAAC,OAAO,EAAE,OAAO,EAAE,QAAQ;QACvC,IAAI,OAAO,YAAY,QAAQ,IAAI,QAAQ,KAAK,SAAS,EAAE;YACzD,QAAQ,GAAG,OAAO,CAAC;YACnB,OAAO,GAAG,EAAE,CAAC;SACd;QACD,OAAO,GAAG,OAAO,IAAI,EAAE,CAAC;QACxB,OAAO,IAAI,CAAC,iBAAiB,CAAC,CAAC,OAAO,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;IAC7D,CAAC;IAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;OA2CG;IACH,oBAAoB,CAAC,OAAO,EAAE,OAAO,GAAG,EAAE;QACxC,OAAO,gBAAgB,CAAC,cAAc,CAAC,YAAY,CAC/C,IAAI,CAAC,eAAe,EAAE,OAAO,EAAE,OAAO,CAAC,CAAC;IAC9C,CAAC;IAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;OA6BG;IACH,eAAe,CAAC,OAAO,EAAE,OAAQ,EAAE,QAAS;QAC1C,IAAI,OAAO,YAAY,QAAQ,IAAI,QAAQ,KAAK,SAAS,EAAE;YACzD,QAAQ,GAAG,OAAO,CAAC;YACnB,OAAO,GAAG,EAAE,CAAC;SACd;QACD,OAAO,GAAG,OAAO,IAAI,EAAE,CAAC;QACxB,OAAO,IAAI,CAAC,gBAAgB,CAAC,OAAO,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;IAC3D,CAAC;IAED;;;;;;;;;;;;;;;;;;;;;;;OAuBG;IACH,eAAe,CAAC,OAAO,EAAE,OAAO,EAAE,QAAQ;QACxC,IAAI,OAAO,YAAY,QAAQ,IAAI,QAAQ,KAAK,SAAS,EAAE;YACzD,QAAQ,GAAG,OAAO,CAAC;YACnB,OAAO,GAAG,EAAE,CAAC;SACd;QACD,OAAO,GAAG,OAAO,IAAI,EAAE,CAAC;QACxB,OAAO,IAAI,CAAC,gBAAgB,CAAC,OAAO,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;IAC3D,CAAC;CACF;AAvTD,4CAuTC;AAED,MAAa,uBAAuB;IAGlC;;;OAGG;IACH,YAAY,OAAmB;QAC7B,MAAM,cAAc,GAAG,iCAAY,CAAC,IAAI,CAAC,CAAC;QAC1C,kCAAkC;QAClC,MAAM,gBAAgB,GAAQ,OAAO,CAAC,SAAS,CAC3C,cAAc,EAAE,qCAAqC,CAAC,CAAC;QAC3D,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,gBAAgB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC;QAEzD;;;;;;;;WAQG;QACH,IAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC,EAAE;YAC7B,OAAO,IAAI,gBAAgB,CAAC,OAAO,EAAE,gBAAgB,EAAE,IAAI,CAAC,CAAC;QAC/D,CAAC,CAAC;QACF,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,gBAAgB,EAAE,gBAAgB,CAAC,CAAC;IACzD,CAAC;CACF;AA5BD,0DA4BC"}

-/**

- * Copyright 2016, Google Inc.

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions are

- * met:

- *

- * * Redistributions of source code must retain the above copyright

- * notice, this list of conditions and the following disclaimer.

- * Redistributions in binary form must reproduce the above

- * copyright notice, this list of conditions and the following disclaimer

- * in the documentation and/or other materials provided with the

- * distribution.

- * * Neither the name of Google Inc. nor the names of its

- * contributors may be used to endorse or promote products derived from

- * this software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- */

-/// <reference types="node" />

-import { Transform } from 'stream';

-import { APICall, APICallback, NormalApiCaller, NormalApiCallerSettings } from './apiCallable';

-export declare class PagedIteration extends NormalApiCaller {

- pageDescriptor: PageDescriptor;

- /**

- * Creates an API caller that returns a stream to performs page-streaming.

- *

- * @private

- * @constructor

- * @param {PageDescriptor} pageDescriptor - indicates the structure

- * of page streaming to be performed.

- */

- constructor(pageDescriptor: PageDescriptor);

- createActualCallback(request: {

- [index: string]: {};

- }, callback: APICallback): (err: Error | null, response: {

- [index: string]: {};

- }) => void;

- wrap(func: Function): (argument: any, metadata: any, options: any, callback: any) => any;

- init(settings: NormalApiCallerSettings, callback: APICallback): import("./apiCallable").PromiseCanceller<any> | import("./apiCallable").Canceller;

- call(apiCall: APICall, argument: {

- [index: string]: {};

- }, settings: any, canceller: any): void;

-}

-export declare class PageDescriptor {

- requestPageTokenField: string;

- responsePageTokenField: string;

- requestPageSizeField?: string;

- resourceField: string;

- /**

- * Describes the structure of a page-streaming call.

- *

- * @property {String} requestPageTokenField

- * @property {String} responsePageTokenField

- * @property {String} resourceField

- *

- * @param {String} requestPageTokenField - The field name of the page token in

- * the request.

- * @param {String} responsePageTokenField - The field name of the page token in

- * the response.

- * @param {String} resourceField - The resource field name.

- *

- * @constructor

- */

- constructor(requestPageTokenField: string, responsePageTokenField: string, resourceField: string);

- /**

- * Creates a new object Stream which emits the resource on 'data' event.

- * @private

- * @param {ApiCall} apiCall - the callable object.

- * @param {Object} request - the request object.

- * @param {CallOptions=} options - the call options to customize the api call.

- * @return {Stream} - a new object Stream.

- */

- createStream(apiCall: APICall, request: any, options: any): Transform;

- /**

- * Returns a new API caller.

- * @private

- * @return {PageStreamable} - the page streaming caller.

- */

- apiCaller(): PagedIteration;

-}

-"use strict";

-/**

- * Copyright 2016, Google Inc.

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions are

- * met:

- *

- * * Redistributions of source code must retain the above copyright

- * notice, this list of conditions and the following disclaimer.

- * Redistributions in binary form must reproduce the above

- * copyright notice, this list of conditions and the following disclaimer

- * in the documentation and/or other materials provided with the

- * distribution.

- * * Neither the name of Google Inc. nor the names of its

- * contributors may be used to endorse or promote products derived from

- * this software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- */

-Object.defineProperty(exports, "__esModule", { value: true });

-const ended = require("is-stream-ended");

-const stream_1 = require("stream");

-const apiCallable_1 = require("./apiCallable");

-class PagedIteration extends apiCallable_1.NormalApiCaller {

- /**

- * Creates an API caller that returns a stream to performs page-streaming.

- *

- * @private

- * @constructor

- * @param {PageDescriptor} pageDescriptor - indicates the structure

- * of page streaming to be performed.

- */

- constructor(pageDescriptor) {

- super();

- this.pageDescriptor = pageDescriptor;

- }

- createActualCallback(request, callback) {

- const self = this;

- return function fetchNextPageToken(err, response) {

- if (err) {

- callback(err);

- return;

- }

- const resources = response[self.pageDescriptor.resourceField];

- const pageToken = response[self.pageDescriptor.responsePageTokenField];

- if (pageToken) {

- request[self.pageDescriptor.requestPageTokenField] = pageToken;

- callback(err, resources, request, response);

- }

- else {

- callback(err, resources, null, response);

- }

- };

- }

- wrap(func) {

- const self = this;

- return function wrappedCall(argument, metadata, options, callback) {

- return func(argument, metadata, options, self.createActualCallback(argument, callback));

- };

- }

- init(settings, callback) {

- return super.init(settings, callback);

- }

- call(apiCall, argument, settings, canceller) {

- argument = Object.assign({}, argument);

- if (settings.pageToken) {

- argument[this.pageDescriptor.requestPageTokenField] = settings.pageToken;

- }

- if (settings.pageSize) {

- argument[this.pageDescriptor.requestPageSizeField] = settings.pageSize;

- }

- if (!settings.autoPaginate) {

- apiCallable_1.NormalApiCaller.prototype.call.call(this, apiCall, argument, settings, canceller);

- return;

- }

- const maxResults = settings.maxResults || -1;

- const allResources = [];

- function pushResources(err, resources, next) {

- if (err) {

- canceller.callback(err);

- return;

- }

- for (let i = 0; i < resources.length; ++i) {

- allResources.push(resources[i]);

- if (allResources.length === maxResults) {

- next = null;

- break;

- }

- }

- if (!next) {

- canceller.callback(null, allResources);

- return;

- }

- setImmediate(apiCall, next, pushResources);

- }

- setImmediate(apiCall, argument, pushResources);

- }

-}

-exports.PagedIteration = PagedIteration;

-class PageDescriptor {

- /**

- * Describes the structure of a page-streaming call.

- *

- * @property {String} requestPageTokenField

- * @property {String} responsePageTokenField

- * @property {String} resourceField

- *

- * @param {String} requestPageTokenField - The field name of the page token in

- * the request.

- * @param {String} responsePageTokenField - The field name of the page token in

- * the response.

- * @param {String} resourceField - The resource field name.

- *

- * @constructor

- */

- constructor(requestPageTokenField, responsePageTokenField, resourceField) {

- this.requestPageTokenField = requestPageTokenField;

- this.responsePageTokenField = responsePageTokenField;

- this.resourceField = resourceField;

- }

- /**

- * Creates a new object Stream which emits the resource on 'data' event.

- * @private

- * @param {ApiCall} apiCall - the callable object.

- * @param {Object} request - the request object.

- * @param {CallOptions=} options - the call options to customize the api call.

- * @return {Stream} - a new object Stream.

- */

- createStream(apiCall, request, options) {

- const stream = new stream_1.PassThrough({ objectMode: true });

- options = Object.assign({}, options, { autoPaginate: false });

- const maxResults = 'maxResults' in options ? options.maxResults : -1;

- let pushCount = 0;

- let started = false;

- function callback(err, resources, next) {

- if (err) {

- stream.emit('error', err);

- return;

- }

- for (let i = 0; i < resources.length; ++i) {

- if (ended(stream)) {

- return;

- }

- if (resources[i] === null) {

- continue;

- }

- stream.push(resources[i]);

- pushCount++;

- if (pushCount === maxResults) {

- stream.end();

- }

- }

- if (ended(stream)) {

- return;

- }

- if (!next) {

- stream.end();

- return;

- }

- // When pageToken is specified in the original options, it will overwrite

- // the page token field in the next request. Therefore it must be cleared.

- if ('pageToken' in options) {

- delete options.pageToken;

- }

- if (stream.isPaused()) {

- request = next;

- started = false;

- }

- else {

- setImmediate(apiCall, next, options, callback);

- }

- }

- stream.on('resume', () => {

- if (!started) {

- started = true;

- apiCall(request, options, callback);

- }

- });

- return stream;

- }

- /**

- * Returns a new API caller.

- * @private

- * @return {PageStreamable} - the page streaming caller.

- */

- apiCaller() {

- return new PagedIteration(this);

- }

-}

-exports.PageDescriptor = PageDescriptor;

-//# sourceMappingURL=pagedIteration.js.map

-{"version":3,"file":"pagedIteration.js","sourceRoot":"","sources":["../../src/pagedIteration.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6BG;;AAEH,yCAAyC;AACzC,mCAA8C;AAE9C,+CAA6F;AAE7F,MAAa,cAAe,SAAQ,6BAAe;IAEjD;;;;;;;OAOG;IACH,YAAY,cAA8B;QACxC,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,cAAc,GAAG,cAAc,CAAC;IACvC,CAAC;IAED,oBAAoB,CAAC,OAA8B,EAAE,QAAqB;QACxE,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,OAAO,SAAS,kBAAkB,CAC9B,GAAe,EAAE,QAA+B;YAClD,IAAI,GAAG,EAAE;gBACP,QAAQ,CAAC,GAAG,CAAC,CAAC;gBACd,OAAO;aACR;YACD,MAAM,SAAS,GAAG,QAAQ,CAAC,IAAI,CAAC,cAAc,CAAC,aAAa,CAAC,CAAC;YAC9D,MAAM,SAAS,GAAG,QAAQ,CAAC,IAAI,CAAC,cAAc,CAAC,sBAAsB,CAAC,CAAC;YACvE,IAAI,SAAS,EAAE;gBACb,OAAO,CAAC,IAAI,CAAC,cAAc,CAAC,qBAAqB,CAAC,GAAG,SAAS,CAAC;gBAC/D,QAAQ,CAAC,GAAG,EAAE,SAAS,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;aAC7C;iBAAM;gBACL,QAAQ,CAAC,GAAG,EAAE,SAAS,EAAE,IAAI,EAAE,QAAQ,CAAC,CAAC;aAC1C;QACH,CAAC,CAAC;IACJ,CAAC;IAED,IAAI,CAAC,IAAc;QACjB,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,OAAO,SAAS,WAAW,CAAC,QAAQ,EAAE,QAAQ,EAAE,OAAO,EAAE,QAAQ;YAC/D,OAAO,IAAI,CACP,QAAQ,EAAE,QAAQ,EAAE,OAAO,EAC3B,IAAI,CAAC,oBAAoB,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC,CAAC;QACrD,CAAC,CAAC;IACJ,CAAC;IAED,IAAI,CAAC,QAAiC,EAAE,QAAqB;QAC3D,OAAO,KAAK,CAAC,IAAI,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;IACxC,CAAC;IAED,IAAI,CAAC,OAAgB,EAAE,QAA+B,EAAE,QAAQ,EAAE,SAAS;QACzE,QAAQ,GAAG,MAAM,CAAC,MAAM,CAAC,EAAE,EAAE,QAAQ,CAAC,CAAC;QACvC,IAAI,QAAQ,CAAC,SAAS,EAAE;YACtB,QAAQ,CAAC,IAAI,CAAC,cAAc,CAAC,qBAAqB,CAAC,GAAG,QAAQ,CAAC,SAAS,CAAC;SAC1E;QACD,IAAI,QAAQ,CAAC,QAAQ,EAAE;YACrB,QAAQ,CAAC,IAAI,CAAC,cAAc,CAAC,oBAAqB,CAAC,GAAG,QAAQ,CAAC,QAAQ,CAAC;SACzE;QACD,IAAI,CAAC,QAAQ,CAAC,YAAY,EAAE;YAC1B,6BAAe,CAAC,SAAS,CAAC,IAAI,CAAC,IAAI,CAC/B,IAAI,EAAE,OAAO,EAAE,QAAQ,EAAE,QAAQ,EAAE,SAAS,CAAC,CAAC;YAClD,OAAO;SACR;QAED,MAAM,UAAU,GAAG,QAAQ,CAAC,UAAU,IAAI,CAAC,CAAC,CAAC;QAC7C,MAAM,YAAY,GAAc,EAAE,CAAC;QACnC,SAAS,aAAa,CAAC,GAAG,EAAE,SAAS,EAAE,IAAI;YACzC,IAAI,GAAG,EAAE;gBACP,SAAS,CAAC,QAAQ,CAAC,GAAG,CAAC,CAAC;gBACxB,OAAO;aACR;YAED,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,SAAS,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE;gBACzC,YAAY,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,CAAC;gBAChC,IAAI,YAAY,CAAC,MAAM,KAAK,UAAU,EAAE;oBACtC,IAAI,GAAG,IAAI,CAAC;oBACZ,MAAM;iBACP;aACF;YACD,IAAI,CAAC,IAAI,EAAE;gBACT,SAAS,CAAC,QAAQ,CAAC,IAAI,EAAE,YAAY,CAAC,CAAC;gBACvC,OAAO;aACR;YACD,YAAY,CAAC,OAAO,EAAE,IAAI,EAAE,aAAa,CAAC,CAAC;QAC7C,CAAC;QAED,YAAY,CAAC,OAAO,EAAE,QAAQ,EAAE,aAAa,CAAC,CAAC;IACjD,CAAC;CACF;AArFD,wCAqFC;AAED,MAAa,cAAc;IAKzB;;;;;;;;;;;;;;OAcG;IACH,YACI,qBAA6B,EAAE,sBAA8B,EAC7D,aAAqB;QACvB,IAAI,CAAC,qBAAqB,GAAG,qBAAqB,CAAC;QACnD,IAAI,CAAC,sBAAsB,GAAG,sBAAsB,CAAC;QACrD,IAAI,CAAC,aAAa,GAAG,aAAa,CAAC;IACrC,CAAC;IAED;;;;;;;OAOG;IACH,YAAY,CAAC,OAAgB,EAAE,OAAO,EAAE,OAAO;QAC7C,MAAM,MAAM,GAAG,IAAI,oBAAW,CAAC,EAAC,UAAU,EAAE,IAAI,EAAC,CAAC,CAAC;QACnD,OAAO,GAAG,MAAM,CAAC,MAAM,CAAC,EAAE,EAAE,OAAO,EAAE,EAAC,YAAY,EAAE,KAAK,EAAC,CAAC,CAAC;QAC5D,MAAM,UAAU,GAAG,YAAY,IAAI,OAAO,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC;QACrE,IAAI,SAAS,GAAG,CAAC,CAAC;QAClB,IAAI,OAAO,GAAG,KAAK,CAAC;QACpB,SAAS,QAAQ,CAAC,GAAe,EAAE,SAAS,EAAE,IAAI;YAChD,IAAI,GAAG,EAAE;gBACP,MAAM,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,CAAC,CAAC;gBAC1B,OAAO;aACR;YACD,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,SAAS,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE;gBACzC,IAAI,KAAK,CAAC,MAAM,CAAC,EAAE;oBACjB,OAAO;iBACR;gBACD,IAAI,SAAS,CAAC,CAAC,CAAC,KAAK,IAAI,EAAE;oBACzB,SAAS;iBACV;gBACD,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,CAAC;gBAC1B,SAAS,EAAE,CAAC;gBACZ,IAAI,SAAS,KAAK,UAAU,EAAE;oBAC5B,MAAM,CAAC,GAAG,EAAE,CAAC;iBACd;aACF;YACD,IAAI,KAAK,CAAC,MAAM,CAAC,EAAE;gBACjB,OAAO;aACR;YACD,IAAI,CAAC,IAAI,EAAE;gBACT,MAAM,CAAC,GAAG,EAAE,CAAC;gBACb,OAAO;aACR;YACD,yEAAyE;YACzE,0EAA0E;YAC1E,IAAI,WAAW,IAAI,OAAO,EAAE;gBAC1B,OAAO,OAAO,CAAC,SAAS,CAAC;aAC1B;YACD,IAAI,MAAM,CAAC,QAAQ,EAAE,EAAE;gBACrB,OAAO,GAAG,IAAI,CAAC;gBACf,OAAO,GAAG,KAAK,CAAC;aACjB;iBAAM;gBACL,YAAY,CAAC,OAAO,EAAE,IAAI,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;aAChD;QACH,CAAC;QACD,MAAM,CAAC,EAAE,CAAC,QAAQ,EAAE,GAAG,EAAE;YACvB,IAAI,CAAC,OAAO,EAAE;gBACZ,OAAO,GAAG,IAAI,CAAC;gBACf,OAAO,CAAC,OAAO,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;aACrC;QACH,CAAC,CAAC,CAAC;QACH,OAAO,MAAM,CAAC;IAChB,CAAC;IAED;;;;OAIG;IACH,SAAS;QACP,OAAO,IAAI,cAAc,CAAC,IAAI,CAAC,CAAC;IAClC,CAAC;CACF;AAhGD,wCAgGC"}

- *

- * Copyright 2016, Google Inc.

- *

-{"version":3,"file":"parserExtras.js","sourceRoot":"","sources":["../../src/parserExtras.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;;AAEH,6BAA6B;AAG7B,wCAAwC;AAC3B,QAAA,OAAO,GAAG,CAAC,CAAC;AACZ,QAAA,WAAW,GAAG,CAAC,CAAC;AAChB,QAAA,QAAQ,GAAG,CAAC,CAAC;AAE1B;;;;;;;GAOG;AACH,SAAS,oBAAoB,CAAC,QAAmB;IAC/C,IAAI,eAAe,GAAG,KAAK,CAAC;IAC5B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,QAAQ,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;QACxC,MAAM,CAAC,GAAG,QAAQ,CAAC,CAAC,CAAC,CAAC;QACtB,IAAI,CAAC,CAAC,IAAI,KAAK,gBAAQ,IAAI,CAAC,CAAC,OAAO,KAAK,IAAI,EAAE;YAC7C,SAAS;SACV;QACD,IAAI,eAAe,EAAE;YACnB,MAAM,gBAAgB,GAAG,4CAA4C,CAAC;YACtE,MAAM,IAAI,SAAS,CAAC,gBAAgB,CAAC,CAAC;SACvC;QACD,eAAe,GAAG,IAAI,CAAC;KACxB;AACH,CAAC;AAED;;;;;;;GAOG;AACH,SAAS,cAAc,CAAC,QAAmB;IACzC,OAAO,QAAQ,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,IAAI,KAAK,gBAAQ,CAAC,CAAC,MAAM,CAAC;AAC1D,CAAC;AAED;;;;;;GAMG;AACH,SAAS,qBAAqB,CAAC,QAAmB;IAChD,IAAI,YAAY,GAAG,CAAC,CAAC;IACrB,QAAQ,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE;QACnB,IAAI,CAAC,CAAC,IAAI,KAAK,eAAO,IAAI,CAAC,CAAC,CAAC,OAAO,EAAE;YACpC,CAAC,CAAC,OAAO,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,YAAY,CAAC,CAAC;YAC7C,YAAY,IAAI,CAAC,CAAC;SACnB;IACH,CAAC,CAAC,CAAC;AACL,CAAC;AAED;;;;;;;;;;;;GAYG;AACH,SAAgB,WAAW,CAAC,QAAmB;IAC7C,oBAAoB,CAAC,QAAQ,CAAC,CAAC;IAC/B,qBAAqB,CAAC,QAAQ,CAAC,CAAC;IAChC,OAAO;QACL,QAAQ;QACR,IAAI,EAAE,cAAc,CAAC,QAAQ,CAAC;KAC/B,CAAC;AACJ,CAAC;AAPD,kCAOC"}

- *

- * Copyright 2016, Google Inc.

- *

-{"version":3,"file":"pathTemplate.js","sourceRoot":"","sources":["../../src/pathTemplate.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;;AAEH;;GAEG;AAEH,kCAAmC;AACnC,6BAA6B;AAC7B,yCAAyC;AACzC,MAAM,MAAM,GAAG,OAAO,CAAC,sBAAsB,CAAC,CAAC;AAgB/C,MAAa,YAAY;IAGvB,IAAI,IAAI;QACN,OAAO,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC;IAC/B,CAAC;IAED,IAAI,QAAQ;QACV,OAAO,IAAI,CAAC,WAAW,CAAC,QAAQ,CAAC;IACnC,CAAC;IAED;;;;OAIG;IACH,YAAY,IAAY;QACtB,IAAI,CAAC,WAAW,GAAG,MAAM,CAAC,WAAW,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC,CAAC;IAC5D,CAAC;IAED;;;;;;OAMG;IACH,KAAK,CAAC,IAAY;QAChB,MAAM,YAAY,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;QACrC,MAAM,QAAQ,GAAa,EAAE,CAAC;QAC9B,IAAI,YAAY,GAAG,IAAI,CAAC,IAAI,CAAC;QAC7B,IAAI,OAAe,CAAC;QACpB,IAAI,KAAK,GAAG,CAAC,CAAC;QACd,IAAI,CAAC,QAAQ,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE;YAC9B,IAAI,KAAK,GAAG,YAAY,CAAC,MAAM,EAAE;gBAC/B,OAAO;aACR;YACD,IAAI,OAAO,CAAC,IAAI,KAAK,MAAM,CAAC,OAAO,EAAE;gBACnC,OAAO,GAAG,OAAO,CAAC,OAAO,CAAC;aAC3B;iBAAM,IAAI,OAAO,CAAC,IAAI,KAAK,MAAM,CAAC,QAAQ,EAAE;gBAC3C,IAAI,OAAO,CAAC,OAAO,KAAK,GAAG,EAAE;oBAC3B,QAAQ,CAAC,OAAO,CAAC,GAAG,YAAY,CAAC,KAAK,CAAC,CAAC;oBACxC,KAAK,IAAI,CAAC,CAAC;iBACZ;qBAAM,IAAI,OAAO,CAAC,OAAO,KAAK,IAAI,EAAE;oBACnC,MAAM,IAAI,GAAG,YAAY,CAAC,MAAM,GAAG,YAAY,GAAG,CAAC,CAAC;oBACpD,YAAY,IAAI,IAAI,GAAG,CAAC,CAAC;oBACzB,QAAQ,CAAC,OAAO,CAAC,GAAG,YAAY,CAAC,KAAK,CAAC,KAAK,EAAE,KAAK,GAAG,IAAI,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;oBACtE,KAAK,IAAI,IAAI,CAAC;iBACf;qBAAM,IAAI,OAAO,CAAC,OAAO,KAAK,YAAY,CAAC,KAAK,CAAC,EAAE;oBAClD,KAAK,IAAI,CAAC,CAAC;iBACZ;qBAAM;oBACL,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CACnB,iDAAiD,EAAE,KAAK,EACxD,OAAO,CAAC,OAAO,EAAE,YAAY,CAAC,KAAK,CAAC,CAAC,CAAC;oBAC1C,MAAM,IAAI,SAAS,CAAC,GAAG,CAAC,CAAC;iBAC1B;aACF;QACH,CAAC,CAAC,CAAC;QACH,IAAI,KAAK,KAAK,YAAY,CAAC,MAAM,IAAI,KAAK,KAAK,YAAY,EAAE;YAC3D,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CACnB,4DAA4D,EAAE,IAAI,CAAC,CAAC;YACxE,MAAM,IAAI,SAAS,CAAC,GAAG,CAAC,CAAC;SAC1B;QACD,OAAO,QAAQ,CAAC;IAClB,CAAC;IAED;;;;;;;OAOG;IACH,MAAM,CAAC,QAAkB;QACvB,MAAM,GAAG,GAAc,EAAE,CAAC;QAC1B,IAAI,UAAU,GAAG,KAAK,CAAC;QACvB,IAAI,CAAC,QAAQ,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE;YAC9B,IAAI,OAAO,CAAC,IAAI,KAAK,MAAM,CAAC,OAAO,EAAE;gBACnC,IAAI,CAAC,GAAG,CAAC,QAAQ,EAAE,OAAO,CAAC,OAAO,CAAC,EAAE;oBACnC,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CACnB,wCAAwC,EAAE,OAAO,CAAC,OAAO,EACzD,QAAQ,CAAC,CAAC;oBACd,MAAM,IAAI,SAAS,CAAC,GAAG,CAAC,CAAC;iBAC1B;gBACD,MAAM,GAAG,GAAG,IAAI,YAAY,CAAC,QAAQ,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;gBACxD,KAAK,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,GAAG,CAAC,QAAQ,CAAC,CAAC;gBAC9C,UAAU,GAAG,IAAI,CAAC;aACnB;iBAAM,IAAI,OAAO,CAAC,IAAI,KAAK,MAAM,CAAC,WAAW,EAAE;gBAC9C,UAAU,GAAG,KAAK,CAAC;aACpB;iBAAM,IAAI,UAAU,EAAE;gBACrB,OAAO;aACR;iBAAM;gBACL,GAAG,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;aACnB;QACH,CAAC,CAAC,CAAC;QAEH,MAAM,MAAM,GAAG,cAAc,CAAC,GAAG,CAAC,CAAC;QACnC,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC;QACnB,OAAO,MAAM,CAAC;IAChB,CAAC;IAED;;;;OAIG;IACH,OAAO;QACL,OAAO,cAAc,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IACvC,CAAC;CACF;AA9GD,oCA8GC;AAED;;;;;GAKG;AACH,SAAS,cAAc,CAAC,QAAmB;IACzC,IAAI,GAAG,GAAG,EAAE,CAAC;IACb,IAAI,KAAK,GAAG,IAAI,CAAC;IACjB,QAAQ,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE;QACzB,IAAI,OAAO,CAAC,IAAI,KAAK,MAAM,CAAC,QAAQ,EAAE;YACpC,IAAI,KAAK,EAAE;gBACT,GAAG,IAAI,GAAG,CAAC;aACZ;YACD,GAAG,IAAI,OAAO,CAAC,OAAO,CAAC;YACvB,OAAO;SACR;QACD,KAAK,GAAG,IAAI,CAAC;QACb,IAAI,OAAO,CAAC,IAAI,KAAK,MAAM,CAAC,OAAO,EAAE;YACnC,GAAG,IAAI,IAAI,GAAG,OAAO,CAAC,OAAO,GAAG,GAAG,CAAC;YACpC,KAAK,GAAG,KAAK,CAAC;SACf;aAAM;YACL,GAAG,IAAI,OAAO,CAAC,OAAO,GAAG,GAAG,CAAC;SAC9B;IACH,CAAC,CAAC,CAAC;IACH,OAAO,GAAG,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC;AAC1B,CAAC"}

- * Copyright 2017, Google Inc.

-/**

- * Copyright 2016, Google Inc.

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions are

- * met:

- *

- * * Redistributions of source code must retain the above copyright

- * notice, this list of conditions and the following disclaimer.

- * Redistributions in binary form must reproduce the above

- * copyright notice, this list of conditions and the following disclaimer

- * in the documentation and/or other materials provided with the

- * distribution.

- * * Neither the name of Google Inc. nor the names of its

- * contributors may be used to endorse or promote products derived from

- * this software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- */

-/// <reference types="node" />

-import { Duplex, DuplexOptions, Readable, Stream, Writable } from 'stream';

-import { APICall, APICallback } from './apiCallable';

-declare const duplexify: DuplexifyConstructor;

-export interface DuplexifyOptions extends DuplexOptions {

- autoDestroy?: boolean;

- end?: boolean;

-}

-export interface Duplexify extends Duplex {

- readonly destroyed: boolean;

- setWritable(writable: Writable | false | null): void;

- setReadable(readable: Readable | false | null): void;

-}

-export interface DuplexifyConstructor {

- obj(writable?: Writable | false | null, readable?: Readable | false | null, options?: DuplexifyOptions): Duplexify;

- new (writable?: Writable | false | null, readable?: Readable | false | null, options?: DuplexifyOptions): Duplexify;

- (writable?: Writable | false | null, readable?: Readable | false | null, options?: DuplexifyOptions): Duplexify;

-}

-/**

- * The type of gRPC streaming.

- * @enum {number}

- */

-export declare enum StreamType {

- /** Client sends a single request, server streams responses. */

- SERVER_STREAMING = 1,

- /** Client streams requests, server returns a single response. */

- CLIENT_STREAMING = 2,

- /** Both client and server stream objects. */

- BIDI_STREAMING = 3

-}

-export declare class StreamProxy extends duplexify {

- type: StreamType;

- private _callback?;

- private _isCancelCalled;

- stream?: Duplex & {

- cancel: () => void;

- };

- /**

- * StreamProxy is a proxy to gRPC-streaming method.

- *

- * @private

- * @constructor

- * @param {StreamType} type - the type of gRPC stream.

- * @param {ApiCallback} callback - the callback for further API call.

- */

- constructor(type: StreamType, callback: APICallback);

- cancel(): void;

- /**

- * Forward events from an API request stream to the user's stream.

- * @param {Stream} stream - The API request stream.

- */

- forwardEvents(stream: Stream): void;

- /**

- * Specifies the target stream.

- * @param {ApiCall} apiCall - the API function to be called.

- * @param {Object} argument - the argument to be passed to the apiCall.

- */

- setStream(apiCall: APICall, argument: {}): void;

-}

-export declare class GrpcStreamable {

- descriptor: StreamDescriptor;

- /**

- * An API caller for methods of gRPC streaming.

- * @private

- * @constructor

- * @param {StreamDescriptor} descriptor - the descriptor of the method structure.

- */

- constructor(descriptor: StreamDescriptor);

- init(settings: {}, callback: APICallback): StreamProxy;

- wrap(func: Function): Function;

- call(apiCall: APICall, argument: {}, settings: {}, stream: StreamProxy): void;

- fail(stream: Stream, err: Error): void;

- result(stream: Stream): Stream;

-}

-export declare class StreamDescriptor {

- type: StreamType;

- /**

- * Describes the structure of gRPC streaming call.

- * @constructor

- * @param {StreamType} streamType - the type of streaming.

- */

- constructor(streamType: StreamType);

- apiCaller(settings: {

- retry: null;

- }): GrpcStreamable;

-}

-export {};

-"use strict";

-/**

- * Copyright 2016, Google Inc.

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions are

- * met:

- *

- * * Redistributions of source code must retain the above copyright

- * notice, this list of conditions and the following disclaimer.

- * Redistributions in binary form must reproduce the above

- * copyright notice, this list of conditions and the following disclaimer

- * in the documentation and/or other materials provided with the

- * distribution.

- * * Neither the name of Google Inc. nor the names of its

- * contributors may be used to endorse or promote products derived from

- * this software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- */

-Object.defineProperty(exports, "__esModule", { value: true });

-const warnings_1 = require("./warnings");

-const duplexify = require('duplexify');

-const retryRequest = require('retry-request');

-/**

- * The type of gRPC streaming.

- * @enum {number}

- */

-var StreamType;

-(function (StreamType) {

- /** Client sends a single request, server streams responses. */

- StreamType[StreamType["SERVER_STREAMING"] = 1] = "SERVER_STREAMING";

- /** Client streams requests, server returns a single response. */

- StreamType[StreamType["CLIENT_STREAMING"] = 2] = "CLIENT_STREAMING";

- /** Both client and server stream objects. */

- StreamType[StreamType["BIDI_STREAMING"] = 3] = "BIDI_STREAMING";

-})(StreamType = exports.StreamType || (exports.StreamType = {}));

-class StreamProxy extends duplexify {

- /**

- * StreamProxy is a proxy to gRPC-streaming method.

- *

- * @private

- * @constructor

- * @param {StreamType} type - the type of gRPC stream.

- * @param {ApiCallback} callback - the callback for further API call.

- */

- constructor(type, callback) {

- super(undefined, undefined, {

- objectMode: true,

- readable: type !== StreamType.CLIENT_STREAMING,

- writable: type !== StreamType.SERVER_STREAMING,

- });

- this.type = type;

- this._callback = callback;

- this._isCancelCalled = false;

- }

- cancel() {

- if (this.stream) {

- this.stream.cancel();

- }

- else {

- this._isCancelCalled = true;

- }

- }

- /**

- * Forward events from an API request stream to the user's stream.

- * @param {Stream} stream - The API request stream.

- */

- forwardEvents(stream) {

- const eventsToForward = ['metadata', 'response', 'status'];

- eventsToForward.forEach(event => {

- stream.on(event, this.emit.bind(this, event));

- });

- // We also want to supply the status data as 'response' event to support

- // the behavior of google-cloud-node expects.

- // see:

- // https://github.com/GoogleCloudPlatform/google-cloud-node/pull/1775#issuecomment-259141029

- // https://github.com/GoogleCloudPlatform/google-cloud-node/blob/116436fa789d8b0f7fc5100b19b424e3ec63e6bf/packages/common/src/grpc-service.js#L355

- stream.on('metadata', metadata => {

- // Create a response object with succeeds.

- // TODO: unify this logic with the decoration of gRPC response when it's

- // added. see: https://github.com/googleapis/gax-nodejs/issues/65

- stream.emit('response', {

- code: 200,

- details: '',

- message: 'OK',

- metadata,

- });

- });

- }

- /**

- * Specifies the target stream.

- * @param {ApiCall} apiCall - the API function to be called.

- * @param {Object} argument - the argument to be passed to the apiCall.

- */

- setStream(apiCall, argument) {

- if (this.type === StreamType.SERVER_STREAMING) {

- const retryStream = retryRequest(null, {

- objectMode: true,

- request: () => {

- if (this._isCancelCalled) {

- if (this.stream) {

- this.stream.cancel();

- }

- return;

- }

- const stream = apiCall(argument, this._callback);

- this.stream = stream;

- this.forwardEvents(stream);

- return stream;

- },

- });

- this.setReadable(retryStream);

- return;

- }

- const stream = apiCall(argument, this._callback);

- this.stream = stream;

- this.forwardEvents(stream);

- if (this.type === StreamType.CLIENT_STREAMING) {

- this.setWritable(stream);

- }

- if (this.type === StreamType.BIDI_STREAMING) {

- this.setReadable(stream);

- this.setWritable(stream);

- }

- if (this._isCancelCalled && this.stream) {

- this.stream.cancel();

- }

- }

-}

-exports.StreamProxy = StreamProxy;

-class GrpcStreamable {

- /**

- * An API caller for methods of gRPC streaming.

- * @private

- * @constructor

- * @param {StreamDescriptor} descriptor - the descriptor of the method structure.

- */

- constructor(descriptor) {

- this.descriptor = descriptor;

- }

- init(settings, callback) {

- return new StreamProxy(this.descriptor.type, callback);

- }

- wrap(func) {

- switch (this.descriptor.type) {

- case StreamType.SERVER_STREAMING:

- return (argument, metadata, options) => {

- return func(argument, metadata, options);

- };

- case StreamType.CLIENT_STREAMING:

- return (argument, metadata, options, callback) => {

- return func(metadata, options, callback);

- };

- case StreamType.BIDI_STREAMING:

- return (argument, metadata, options) => {

- return func(metadata, options);

- };

- default:

- warnings_1.warn('streaming_wrap_unknown_stream_type', `Unknown stream type: ${this.descriptor.type}`);

- }

- return func;

- }

- call(apiCall, argument, settings, stream) {

- stream.setStream(apiCall, argument);

- }

- fail(stream, err) {

- stream.emit('error', err);

- }

- result(stream) {

- return stream;

- }

-}

-exports.GrpcStreamable = GrpcStreamable;

-class StreamDescriptor {

- /**

- * Describes the structure of gRPC streaming call.

- * @constructor

- * @param {StreamType} streamType - the type of streaming.

- */

- constructor(streamType) {

- this.type = streamType;

- }

- apiCaller(settings) {

- // Right now retrying does not work with gRPC-streaming, because retryable

- // assumes an API call returns an event emitter while gRPC-streaming methods

- // return Stream.

- // TODO: support retrying.

- settings.retry = null;

- return new GrpcStreamable(this);

- }

-}

-exports.StreamDescriptor = StreamDescriptor;

-//# sourceMappingURL=streaming.js.map

-{"version":3,"file":"streaming.js","sourceRoot":"","sources":["../../src/streaming.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA6BG;;AAOH,yCAAgC;AAEhC,MAAM,SAAS,GAAyB,OAAO,CAAC,WAAW,CAAC,CAAC;AAC7D,MAAM,YAAY,GAAG,OAAO,CAAC,eAAe,CAAC,CAAC;AAuB9C;;;GAGG;AACH,IAAY,UASX;AATD,WAAY,UAAU;IACpB,+DAA+D;IAC/D,mEAAoB,CAAA;IAEpB,iEAAiE;IACjE,mEAAoB,CAAA;IAEpB,6CAA6C;IAC7C,+DAAkB,CAAA;AACpB,CAAC,EATW,UAAU,GAAV,kBAAU,KAAV,kBAAU,QASrB;AAED,MAAa,WAAY,SAAQ,SAAS;IAKxC;;;;;;;OAOG;IACH,YAAY,IAAgB,EAAE,QAAqB;QACjD,KAAK,CAAC,SAAS,EAAE,SAAS,EAAE;YAC1B,UAAU,EAAE,IAAI;YAChB,QAAQ,EAAE,IAAI,KAAK,UAAU,CAAC,gBAAgB;YAC9C,QAAQ,EAAE,IAAI,KAAK,UAAU,CAAC,gBAAgB;SAC9B,CAAC,CAAC;QACpB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,SAAS,GAAG,QAAQ,CAAC;QAC1B,IAAI,CAAC,eAAe,GAAG,KAAK,CAAC;IAC/B,CAAC;IAED,MAAM;QACJ,IAAI,IAAI,CAAC,MAAM,EAAE;YACf,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC;SACtB;aAAM;YACL,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC;SAC7B;IACH,CAAC;IAED;;;OAGG;IACH,aAAa,CAAC,MAAc;QAC1B,MAAM,eAAe,GAAG,CAAC,UAAU,EAAE,UAAU,EAAE,QAAQ,CAAC,CAAC;QAE3D,eAAe,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;YAC9B,MAAM,CAAC,EAAE,CAAC,KAAK,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC,CAAC;QAChD,CAAC,CAAC,CAAC;QAEH,wEAAwE;QACxE,6CAA6C;QAC7C,OAAO;QACP,4FAA4F;QAC5F,kJAAkJ;QAClJ,MAAM,CAAC,EAAE,CAAC,UAAU,EAAE,QAAQ,CAAC,EAAE;YAC/B,0CAA0C;YAC1C,wEAAwE;YACxE,iEAAiE;YACjE,MAAM,CAAC,IAAI,CAAC,UAAU,EAAE;gBACtB,IAAI,EAAE,GAAG;gBACT,OAAO,EAAE,EAAE;gBACX,OAAO,EAAE,IAAI;gBACb,QAAQ;aACT,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;OAIG;IACH,SAAS,CAAC,OAAgB,EAAE,QAAY;QACtC,IAAI,IAAI,CAAC,IAAI,KAAK,UAAU,CAAC,gBAAgB,EAAE;YAC7C,MAAM,WAAW,GAAG,YAAY,CAAC,IAAI,EAAE;gBACrC,UAAU,EAAE,IAAI;gBAChB,OAAO,EAAE,GAAG,EAAE;oBACZ,IAAI,IAAI,CAAC,eAAe,EAAE;wBACxB,IAAI,IAAI,CAAC,MAAM,EAAE;4BACf,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC;yBACtB;wBACD,OAAO;qBACR;oBACD,MAAM,MAAM,GAAG,OAAO,CAAC,QAAQ,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;oBACjD,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;oBACrB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;oBAC3B,OAAO,MAAM,CAAC;gBAChB,CAAC;aACF,CAAC,CAAC;YACH,IAAI,CAAC,WAAW,CAAC,WAAW,CAAC,CAAC;YAC9B,OAAO;SACR;QAED,MAAM,MAAM,GAAG,OAAO,CAAC,QAAQ,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;QACjD,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;QACrB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;QAE3B,IAAI,IAAI,CAAC,IAAI,KAAK,UAAU,CAAC,gBAAgB,EAAE;YAC7C,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;SAC1B;QAED,IAAI,IAAI,CAAC,IAAI,KAAK,UAAU,CAAC,cAAc,EAAE;YAC3C,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;YACzB,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;SAC1B;QAED,IAAI,IAAI,CAAC,eAAe,IAAI,IAAI,CAAC,MAAM,EAAE;YACvC,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC;SACtB;IACH,CAAC;CACF;AAxGD,kCAwGC;AAED,MAAa,cAAc;IAGzB;;;;;OAKG;IACH,YAAY,UAA4B;QACtC,IAAI,CAAC,UAAU,GAAG,UAAU,CAAC;IAC/B,CAAC;IAED,IAAI,CAAC,QAAY,EAAE,QAAqB;QACtC,OAAO,IAAI,WAAW,CAAC,IAAI,CAAC,UAAU,CAAC,IAAI,EAAE,QAAQ,CAAC,CAAC;IACzD,CAAC;IAED,IAAI,CAAC,IAAc;QACjB,QAAQ,IAAI,CAAC,UAAU,CAAC,IAAI,EAAE;YAC5B,KAAK,UAAU,CAAC,gBAAgB;gBAC9B,OAAO,CAAC,QAAY,EAAE,QAAY,EAAE,OAAW,EAAE,EAAE;oBACjD,OAAO,IAAI,CAAC,QAAQ,EAAE,QAAQ,EAAE,OAAO,CAAC,CAAC;gBAC3C,CAAC,CAAC;YACJ,KAAK,UAAU,CAAC,gBAAgB;gBAC9B,OAAO,CAAC,QAAY,EAAE,QAAY,EAAE,OAAW,EAAE,QAAY,EAAE,EAAE;oBAC/D,OAAO,IAAI,CAAC,QAAQ,EAAE,OAAO,EAAE,QAAQ,CAAC,CAAC;gBAC3C,CAAC,CAAC;YACJ,KAAK,UAAU,CAAC,cAAc;gBAC5B,OAAO,CAAC,QAAY,EAAE,QAAY,EAAE,OAAW,EAAE,EAAE;oBACjD,OAAO,IAAI,CAAC,QAAQ,EAAE,OAAO,CAAC,CAAC;gBACjC,CAAC,CAAC;YACJ;gBACE,eAAI,CACA,oCAAoC,EACpC,wBAAwB,IAAI,CAAC,UAAU,CAAC,IAAI,EAAE,CAAC,CAAC;SACvD;QACD,OAAO,IAAI,CAAC;IACd,CAAC;IAED,IAAI,CAAC,OAAgB,EAAE,QAAY,EAAE,QAAY,EAAE,MAAmB;QACpE,MAAM,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAC;IACtC,CAAC;IAED,IAAI,CAAC,MAAc,EAAE,GAAU;QAC7B,MAAM,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,CAAC,CAAC;IAC5B,CAAC;IAED,MAAM,CAAC,MAAc;QACnB,OAAO,MAAM,CAAC;IAChB,CAAC;CACF;AAlDD,wCAkDC;AAED,MAAa,gBAAgB;IAE3B;;;;OAIG;IACH,YAAY,UAAsB;QAChC,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC;IACzB,CAAC;IAED,SAAS,CAAC,QAAuB;QAC/B,0EAA0E;QAC1E,4EAA4E;QAC5E,iBAAiB;QACjB,0BAA0B;QAC1B,QAAQ,CAAC,KAAK,GAAG,IAAI,CAAC;QACtB,OAAO,IAAI,cAAc,CAAC,IAAI,CAAC,CAAC;IAClC,CAAC;CACF;AAnBD,4CAmBC"}

-/**

- * Copyright 2019 Google LLC. All Rights Reserved.

- *

- * Licensed under the Apache License, Version 2.0 (the "License");

- * you may not use this file except in compliance with the License.

- * You may obtain a copy of the License at

- *

- * http://www.apache.org/licenses/LICENSE-2.0

- *

- * Unless required by applicable law or agreed to in writing, software

- * distributed under the License is distributed on an "AS IS" BASIS,

- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

- * See the License for the specific language governing permissions and

- * limitations under the License.

- */

-/**

- * Copyright 2019 Google LLC. All Rights Reserved.

- * Licensed under the Apache License, Version 2.0 (the "License");

- * you may not use this file except in compliance with the License.

- * You may obtain a copy of the License at

- * http://www.apache.org/licenses/LICENSE-2.0

- * Unless required by applicable law or agreed to in writing, software

- * distributed under the License is distributed on an "AS IS" BASIS,

- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

- * See the License for the specific language governing permissions and

- * limitations under the License.

-{"version":3,"file":"warnings.js","sourceRoot":"","sources":["../../src/warnings.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;GAcG;;AAGH,2CAAsC;AAEtC,MAAM,eAAe,GAAG,IAAI,GAAG,EAAU,CAAC;AAE1C,SAAgB,IAAI,CAAC,IAAY,EAAE,OAAe;IAChD,iCAAiC;IACjC,IAAI,eAAe,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE;QAC7B,OAAO;KACR;IACD,eAAe,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;IAE1B,IAAI,qBAAS,EAAE,EAAE;QACf,OAAO,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;KACvB;SAAM;QACL,OAAO,CAAC,WAAW,CAAC,OAAO,CAAC,CAAC;KAC9B;AACH,CAAC;AAZD,oBAYC"}

- "version": "0.25.6",

- "build/src"

- "@grpc/proto-loader": "^0.4.0",

- "google-proto-files": "^0.20.0",

- "grpc": "^1.16.0",

- "@types/semver": "^5.5.0",

- "mocha": "~6.0.0",

- "nyc": "^13.1.0",

- "typescript": "~3.3.0"

- "pretest": "npm run compile",

- "prepare": "npm run compile",

- "system-test": "nyc mocha build/system-test --timeout 120000",