@google-cloud/pubsub - npm Package Compare versions

Comparing version 4.2.0 to 4.3.0

build/src/v1/publisher_client.d.ts

@@ -20,2 +20,4 @@ /// <reference types="node" />
     private _defaults;
+    private _universeDomain;
+    private _servicePath;
     auth: gax.GoogleAuth;
@@ -90,2 +92,3 @@ descriptors: Descriptors;
      * The DNS address for this API service.
+     * @deprecated
      * @returns {string} The DNS address for this service.
@@ -95,4 +98,5 @@ */
     /**
-     * The DNS address for this API service - same as servicePath(),
+     * The DNS address for this API service - same as servicePath,
      * exists for compatibility reasons.
+     * @deprecated
      * @returns {string} The DNS address for this service.
@@ -102,2 +106,13 @@ */
     /**
+     * The DNS address for this API service.
+     * @returns {string} The DNS address for this service.
+     */
+    get servicePath(): string;
+    /**
+     * The DNS address for this API service - same as servicePath().
+     * @returns {string} The DNS address for this service.
+     */
+    get apiEndpoint(): string;
+    get universeDomain(): string;
+    /**
      * The port for this API service.
@@ -104,0 +119,0 @@ * @returns {number} The default port for this service.

build/src/v1/publisher_client.js

@@ -76,3 +76,3 @@ "use strict";
     constructor(opts, gaxInstance) {
-        var _a, _b;
+        var _a, _b, _c, _d;
         this._terminated = false;
@@ -87,7 +87,15 @@ this.descriptors = {
         const staticMembers = this.constructor;
-        const servicePath = (opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint) || staticMembers.servicePath;
+        if ((opts === null || opts === void 0 ? void 0 : opts.universe_domain) &&
+            (opts === null || opts === void 0 ? void 0 : opts.universeDomain) &&
+            (opts === null || opts === void 0 ? void 0 : opts.universe_domain) !== (opts === null || opts === void 0 ? void 0 : opts.universeDomain)) {
+            throw new Error('Please set either universe_domain or universeDomain, but not both.');
+        }
+        this._universeDomain =
+            (_b = (_a = opts === null || opts === void 0 ? void 0 : opts.universeDomain) !== null && _a !== void 0 ? _a : opts === null || opts === void 0 ? void 0 : opts.universe_domain) !== null && _b !== void 0 ? _b : 'googleapis.com';
+        this._servicePath = 'pubsub.' + this._universeDomain;
+        const servicePath = (opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint) || this._servicePath;
         this._providedCustomServicePath = !!((opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint));
         const port = (opts === null || opts === void 0 ? void 0 : opts.port) || staticMembers.port;
-        const clientConfig = (_a = opts === null || opts === void 0 ? void 0 : opts.clientConfig) !== null && _a !== void 0 ? _a : {};
-        const fallback = (_b = opts === null || opts === void 0 ? void 0 : opts.fallback) !== null && _b !== void 0 ? _b : (typeof window !== 'undefined' && typeof (window === null || window === void 0 ? void 0 : window.fetch) === 'function');
+        const clientConfig = (_c = opts === null || opts === void 0 ? void 0 : opts.clientConfig) !== null && _c !== void 0 ? _c : {};
+        const fallback = (_d = opts === null || opts === void 0 ? void 0 : opts.fallback) !== null && _d !== void 0 ? _d : (typeof window !== 'undefined' && typeof (window === null || window === void 0 ? void 0 : window.fetch) === 'function');
         opts = Object.assign({ servicePath, port, clientConfig, fallback }, opts);
@@ -97,3 +105,3 @@ // Request numeric enum values if REST transport is used.
         // If scopes are unset in options and we're connecting to a non-default endpoint, set scopes just in case.
-        if (servicePath !== staticMembers.servicePath && !('scopes' in opts)) {
+        if (servicePath !== this._servicePath && !('scopes' in opts)) {
             opts['scopes'] = staticMembers.scopes;
@@ -116,5 +124,5 @@ }
         // Set defaultServicePath on the auth object.
-        this.auth.defaultServicePath = staticMembers.servicePath;
+        this.auth.defaultServicePath = this._servicePath;
         // Set the default scopes in auth client if needed.
-        if (servicePath === staticMembers.servicePath) {
+        if (servicePath === this._servicePath) {
             this.auth.defaultScopes = staticMembers.scopes;
@@ -233,16 +241,43 @@ }
      * The DNS address for this API service.
+     * @deprecated
      * @returns {string} The DNS address for this service.
      */
     static get servicePath() {
+        if (typeof process !== undefined &&
+            typeof process.emitWarning === 'function') {
+            process.emitWarning('Static servicePath is deprecated, please use the instance method instead.', 'DeprecationWarning');
+        }
         return 'pubsub.googleapis.com';
     }
     /**
-     * The DNS address for this API service - same as servicePath(),
+     * The DNS address for this API service - same as servicePath,
      * exists for compatibility reasons.
+     * @deprecated
      * @returns {string} The DNS address for this service.
      */
     static get apiEndpoint() {
+        if (typeof process !== undefined &&
+            typeof process.emitWarning === 'function') {
+            process.emitWarning('Static apiEndpoint is deprecated, please use the instance method instead.', 'DeprecationWarning');
+        }
         return 'pubsub.googleapis.com';
     }
     /**
+     * The DNS address for this API service.
+     * @returns {string} The DNS address for this service.
+     */
+    get servicePath() {
+        return this._servicePath;
+    }
+    /**
+     * The DNS address for this API service - same as servicePath().
+     * @returns {string} The DNS address for this service.
+     */
+    get apiEndpoint() {
+        return this._servicePath;
+    }
+    get universeDomain() {
+        return this._universeDomain;
+    }
+    /**
      * The port for this API service.
@@ -249,0 +284,0 @@ * @returns {number} The default port for this service.

build/src/v1/schema_service_client.d.ts

@@ -19,2 +19,4 @@ /// <reference types="node" />
     private _defaults;
+    private _universeDomain;
+    private _servicePath;
     auth: gax.GoogleAuth;
@@ -89,2 +91,3 @@ descriptors: Descriptors;
      * The DNS address for this API service.
+     * @deprecated
      * @returns {string} The DNS address for this service.
@@ -94,4 +97,5 @@ */
     /**
-     * The DNS address for this API service - same as servicePath(),
+     * The DNS address for this API service - same as servicePath,
      * exists for compatibility reasons.
+     * @deprecated
      * @returns {string} The DNS address for this service.
@@ -101,2 +105,13 @@ */
     /**
+     * The DNS address for this API service.
+     * @returns {string} The DNS address for this service.
+     */
+    get servicePath(): string;
+    /**
+     * The DNS address for this API service - same as servicePath().
+     * @returns {string} The DNS address for this service.
+     */
+    get apiEndpoint(): string;
+    get universeDomain(): string;
+    /**
      * The port for this API service.
@@ -103,0 +118,0 @@ * @returns {number} The default port for this service.

build/src/v1/schema_service_client.js

@@ -75,3 +75,3 @@ "use strict";
     constructor(opts, gaxInstance) {
-        var _a, _b;
+        var _a, _b, _c, _d;
         this._terminated = false;
@@ -86,7 +86,15 @@ this.descriptors = {
         const staticMembers = this.constructor;
-        const servicePath = (opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint) || staticMembers.servicePath;
+        if ((opts === null || opts === void 0 ? void 0 : opts.universe_domain) &&
+            (opts === null || opts === void 0 ? void 0 : opts.universeDomain) &&
+            (opts === null || opts === void 0 ? void 0 : opts.universe_domain) !== (opts === null || opts === void 0 ? void 0 : opts.universeDomain)) {
+            throw new Error('Please set either universe_domain or universeDomain, but not both.');
+        }
+        this._universeDomain =
+            (_b = (_a = opts === null || opts === void 0 ? void 0 : opts.universeDomain) !== null && _a !== void 0 ? _a : opts === null || opts === void 0 ? void 0 : opts.universe_domain) !== null && _b !== void 0 ? _b : 'googleapis.com';
+        this._servicePath = 'pubsub.' + this._universeDomain;
+        const servicePath = (opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint) || this._servicePath;
         this._providedCustomServicePath = !!((opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint));
         const port = (opts === null || opts === void 0 ? void 0 : opts.port) || staticMembers.port;
-        const clientConfig = (_a = opts === null || opts === void 0 ? void 0 : opts.clientConfig) !== null && _a !== void 0 ? _a : {};
-        const fallback = (_b = opts === null || opts === void 0 ? void 0 : opts.fallback) !== null && _b !== void 0 ? _b : (typeof window !== 'undefined' && typeof (window === null || window === void 0 ? void 0 : window.fetch) === 'function');
+        const clientConfig = (_c = opts === null || opts === void 0 ? void 0 : opts.clientConfig) !== null && _c !== void 0 ? _c : {};
+        const fallback = (_d = opts === null || opts === void 0 ? void 0 : opts.fallback) !== null && _d !== void 0 ? _d : (typeof window !== 'undefined' && typeof (window === null || window === void 0 ? void 0 : window.fetch) === 'function');
         opts = Object.assign({ servicePath, port, clientConfig, fallback }, opts);
@@ -96,3 +104,3 @@ // Request numeric enum values if REST transport is used.
         // If scopes are unset in options and we're connecting to a non-default endpoint, set scopes just in case.
-        if (servicePath !== staticMembers.servicePath && !('scopes' in opts)) {
+        if (servicePath !== this._servicePath && !('scopes' in opts)) {
             opts['scopes'] = staticMembers.scopes;
@@ -115,5 +123,5 @@ }
         // Set defaultServicePath on the auth object.
-        this.auth.defaultServicePath = staticMembers.servicePath;
+        this.auth.defaultServicePath = this._servicePath;
         // Set the default scopes in auth client if needed.
-        if (servicePath === staticMembers.servicePath) {
+        if (servicePath === this._servicePath) {
             this.auth.defaultScopes = staticMembers.scopes;
@@ -221,16 +229,43 @@ }
      * The DNS address for this API service.
+     * @deprecated
      * @returns {string} The DNS address for this service.
      */
     static get servicePath() {
+        if (typeof process !== undefined &&
+            typeof process.emitWarning === 'function') {
+            process.emitWarning('Static servicePath is deprecated, please use the instance method instead.', 'DeprecationWarning');
+        }
         return 'pubsub.googleapis.com';
     }
     /**
-     * The DNS address for this API service - same as servicePath(),
+     * The DNS address for this API service - same as servicePath,
      * exists for compatibility reasons.
+     * @deprecated
      * @returns {string} The DNS address for this service.
      */
     static get apiEndpoint() {
+        if (typeof process !== undefined &&
+            typeof process.emitWarning === 'function') {
+            process.emitWarning('Static apiEndpoint is deprecated, please use the instance method instead.', 'DeprecationWarning');
+        }
         return 'pubsub.googleapis.com';
     }
     /**
+     * The DNS address for this API service.
+     * @returns {string} The DNS address for this service.
+     */
+    get servicePath() {
+        return this._servicePath;
+    }
+    /**
+     * The DNS address for this API service - same as servicePath().
+     * @returns {string} The DNS address for this service.
+     */
+    get apiEndpoint() {
+        return this._servicePath;
+    }
+    get universeDomain() {
+        return this._universeDomain;
+    }
+    /**
      * The port for this API service.
@@ -237,0 +272,0 @@ * @returns {number} The default port for this service.

build/src/v1/subscriber_client.js

@@ -78,3 +78,3 @@ "use strict";
     constructor(opts, gaxInstance) {
-        var _a, _b;
+        var _a, _b, _c, _d;
         this._terminated = false;
@@ -89,7 +89,15 @@ this.descriptors = {
         const staticMembers = this.constructor;
-        const servicePath = (opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint) || staticMembers.servicePath;
+        if ((opts === null || opts === void 0 ? void 0 : opts.universe_domain) &&
+            (opts === null || opts === void 0 ? void 0 : opts.universeDomain) &&
+            (opts === null || opts === void 0 ? void 0 : opts.universe_domain) !== (opts === null || opts === void 0 ? void 0 : opts.universeDomain)) {
+            throw new Error('Please set either universe_domain or universeDomain, but not both.');
+        }
+        this._universeDomain =
+            (_b = (_a = opts === null || opts === void 0 ? void 0 : opts.universeDomain) !== null && _a !== void 0 ? _a : opts === null || opts === void 0 ? void 0 : opts.universe_domain) !== null && _b !== void 0 ? _b : 'googleapis.com';
+        this._servicePath = 'pubsub.' + this._universeDomain;
+        const servicePath = (opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint) || this._servicePath;
         this._providedCustomServicePath = !!((opts === null || opts === void 0 ? void 0 : opts.servicePath) || (opts === null || opts === void 0 ? void 0 : opts.apiEndpoint));
         const port = (opts === null || opts === void 0 ? void 0 : opts.port) || staticMembers.port;
-        const clientConfig = (_a = opts === null || opts === void 0 ? void 0 : opts.clientConfig) !== null && _a !== void 0 ? _a : {};
-        const fallback = (_b = opts === null || opts === void 0 ? void 0 : opts.fallback) !== null && _b !== void 0 ? _b : (typeof window !== 'undefined' && typeof (window === null || window === void 0 ? void 0 : window.fetch) === 'function');
+        const clientConfig = (_c = opts === null || opts === void 0 ? void 0 : opts.clientConfig) !== null && _c !== void 0 ? _c : {};
+        const fallback = (_d = opts === null || opts === void 0 ? void 0 : opts.fallback) !== null && _d !== void 0 ? _d : (typeof window !== 'undefined' && typeof (window === null || window === void 0 ? void 0 : window.fetch) === 'function');
         opts = Object.assign({ servicePath, port, clientConfig, fallback }, opts);
@@ -99,3 +107,3 @@ // Request numeric enum values if REST transport is used.
         // If scopes are unset in options and we're connecting to a non-default endpoint, set scopes just in case.
-        if (servicePath !== staticMembers.servicePath && !('scopes' in opts)) {
+        if (servicePath !== this._servicePath && !('scopes' in opts)) {
             opts['scopes'] = staticMembers.scopes;
@@ -118,5 +126,5 @@ }
         // Set defaultServicePath on the auth object.
-        this.auth.defaultServicePath = staticMembers.servicePath;
+        this.auth.defaultServicePath = this._servicePath;
         // Set the default scopes in auth client if needed.
-        if (servicePath === staticMembers.servicePath) {
+        if (servicePath === this._servicePath) {
             this.auth.defaultScopes = staticMembers.scopes;
@@ -165,3 +173,3 @@ }
             streamingPull: new this._gaxModule.StreamDescriptor(this._gaxModule.StreamType.BIDI_STREAMING, !!opts.fallback, 
-            /* gaxStreamingRetries: */ true),
+            /* gaxStreamingRetries: */ false),
         };
@@ -246,16 +254,43 @@ // Put together the default options sent with requests.
      * The DNS address for this API service.
+     * @deprecated
      * @returns {string} The DNS address for this service.
      */
     static get servicePath() {
+        if (typeof process !== undefined &&
+            typeof process.emitWarning === 'function') {
+            process.emitWarning('Static servicePath is deprecated, please use the instance method instead.', 'DeprecationWarning');
+        }
         return 'pubsub.googleapis.com';
     }
     /**
-     * The DNS address for this API service - same as servicePath(),
+     * The DNS address for this API service - same as servicePath,
      * exists for compatibility reasons.
+     * @deprecated
      * @returns {string} The DNS address for this service.
      */
     static get apiEndpoint() {
+        if (typeof process !== undefined &&
+            typeof process.emitWarning === 'function') {
+            process.emitWarning('Static apiEndpoint is deprecated, please use the instance method instead.', 'DeprecationWarning');
+        }
         return 'pubsub.googleapis.com';
     }
     /**
+     * The DNS address for this API service.
+     * @returns {string} The DNS address for this service.
+     */
+    get servicePath() {
+        return this._servicePath;
+    }
+    /**
+     * The DNS address for this API service - same as servicePath().
+     * @returns {string} The DNS address for this service.
+     */
+    get apiEndpoint() {
+        return this._servicePath;
+    }
+    get universeDomain() {
+        return this._universeDomain;
+    }
+    /**
      * The port for this API service.
@@ -262,0 +297,0 @@ * @returns {number} The default port for this service.

package.json

 {
   "name": "@google-cloud/pubsub",
   "description": "Cloud Pub/Sub Client Library for Node.js",
-  "version": "4.2.0",
+  "version": "4.3.0",
   "license": "Apache-2.0",
@@ -61,3 +61,3 @@ "author": "Google Inc.",
     "google-auth-library": "^9.0.0",
-    "google-gax": "^4.0.4",
+    "google-gax": "^4.3.0",
     "heap-js": "^2.2.0",
@@ -64,0 +64,0 @@ "is-stream-ended": "^0.1.4",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

4170896

increased by0.24%

Lines of code

70074

increased by0.21%

Dependency changes

• Updatedgoogle-gax@^4.3.0