@google-cloud/pubsub - npm Package Compare versions

Comparing version 0.5.0 to 0.6.0

package.json

 {
   "name": "@google-cloud/pubsub",
-  "version": "0.5.0",
+  "version": "0.6.0",
   "author": "Google Inc.",
@@ -53,6 +53,6 @@ "description": "Google Cloud Pub/Sub Client Library for Node.js",
   "dependencies": {
-    "@google-cloud/common": "^0.7.0",
+    "@google-cloud/common": "^0.8.0",
     "arrify": "^1.0.0",
     "extend": "^3.0.0",
-    "google-gax": "^0.8.1",
+    "google-gax": "^0.9.1",
     "google-proto-files": "^0.8.0",
@@ -59,0 +59,0 @@ "is": "^3.0.1",

README.md

@@ -82,4 +82,4 @@ # @google-cloud/pubsub
 4. Navigate to **APIs & auth** >  **Credentials** and then:
-  * If you want to use a new service account, click on **Create new Client ID** and select **Service account**. After the account is created, you will be prompted to download the JSON key file that the library uses to authenticate your requests.
-  * If you want to generate a new key for an existing service account, click on **Generate new JSON key** and download the JSON key file.
+  * If you want to use a new service account key, click on **Create credentials** and select **Service account key**. After the account key is created, you will be prompted to download the JSON key file that the library uses to authenticate your requests.
+  * If you want to generate a new service account key for an existing service account, click on **Generate new JSON key** and download the JSON key file.
 
@@ -86,0 +86,0 @@ ``` js

src/iam.js

@@ -92,7 +92,7 @@ /*!
  * @param {?error} callback.err - An error returned while making this request.
- * @param {object} callback.policy - The [policy](https://cloud.google.com/pubsub/reference/rest/Shared.Types/Policy).
+ * @param {object} callback.policy - The [policy](https://cloud.google.com/pubsub/docs/reference/rest/Shared.Types/Policy).
  * @param {object} callback.apiResponse - The full API response.
  *
- * @resource [Topics: getIamPolicy API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/getIamPolicy}
- * @resource [Subscriptions: getIamPolicy API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/getIamPolicy}
+ * @resource [Topics: getIamPolicy API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/getIamPolicy}
+ * @resource [Subscriptions: getIamPolicy API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/getIamPolicy}
  *
@@ -130,3 +130,3 @@ * @example
  *
- * @param {object} policy - The [policy](https://cloud.google.com/pubsub/reference/rest/Shared.Types/Policy).
+ * @param {object} policy - The [policy](https://cloud.google.com/pubsub/docs/reference/rest/Shared.Types/Policy).
  * @param {array=} policy.bindings - Bindings associate members with roles.
@@ -140,5 +140,5 @@ * @param {object[]=} policy.rules - Rules to be applied to the policy.
  *
- * @resource [Topics: setIamPolicy API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/setIamPolicy}
- * @resource [Subscriptions: setIamPolicy API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/setIamPolicy}
- * @resource [Policy]{@link https://cloud.google.com/pubsub/reference/rest/Shared.Types/Policy}
+ * @resource [Topics: setIamPolicy API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/setIamPolicy}
+ * @resource [Subscriptions: setIamPolicy API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/setIamPolicy}
+ * @resource [Policy]{@link https://cloud.google.com/pubsub/docs/reference/rest/Shared.Types/Policy}
  *
@@ -199,4 +199,4 @@ * @example
  *
- * @resource [Topics: testIamPermissions API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/testIamPermissions}
- * @resource [Subscriptions: testIamPermissions API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/testIamPermissions}
+ * @resource [Topics: testIamPermissions API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/testIamPermissions}
+ * @resource [Subscriptions: testIamPermissions API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/testIamPermissions}
  * @resource [Permissions Reference]{@link https://cloud.google.com/pubsub/access_control#permissions}
@@ -203,0 +203,0 @@ *

src/index.js

@@ -87,3 +87,3 @@ /*!
  *
- * @resource [Topics: create API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/create}
+ * @resource [Topics: create API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/create}
  *
@@ -149,3 +149,3 @@ * @param {string} name - Name of the topic.
  *
- * @resource [Subscriptions: list API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/list}
+ * @resource [Subscriptions: list API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/list}
  *
@@ -292,3 +292,3 @@ * @param {object=} options - Configuration object.
  *
- * @resource [Topics: list API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/list}
+ * @resource [Topics: list API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/list}
  *
@@ -413,10 +413,6 @@ * @param {object=} query - Query object.
 /**
- * Create a subscription to a topic. You may optionally provide an object to
- * customize the subscription.
+ * Create a subscription to a topic.
  *
- * Your provided callback will be invoked with an error object if an API error
- * occurred or a {module:pubsub/subscription} object.
+ * @resource [Subscriptions: create API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/create}
  *
- * @resource [Subscriptions: create API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/create}
- *
  * @throws {Error} If a Topic instance or topic name is not provided.
@@ -429,3 +425,3 @@ * @throws {Error} If a subName is not provided.
  * @param {object=} options - See a
- *     [Subscription resource](https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions)
+ *     [Subscription resource](https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions)
  * @param {number} options.ackDeadlineSeconds - The maximum time after receiving
@@ -441,2 +437,4 @@ *     a message that you must ack a message before it is redelivered.
  *     simultaneously.
+ * @param {string} options.pushEndpoint - A URL to a custom endpoint that
+ *     messages should be pushed to.
  * @param {boolean} options.reuseExisting - If the subscription already exists,
@@ -513,2 +511,8 @@ *     reuse it. The options of the existing subscription are not changed. If
 
+  if (reqOpts.pushEndpoint) {
+    reqOpts.pushConfig = {
+      pushEndpoint: reqOpts.pushEndpoint
+    };
+  }
+
   delete reqOpts.autoAck;
@@ -518,2 +522,3 @@ delete reqOpts.encoding;
   delete reqOpts.maxInProgress;
+  delete reqOpts.pushEndpoint;
   delete reqOpts.reuseExisting;
@@ -520,0 +525,0 @@ delete reqOpts.timeout;

src/subscription.js

@@ -200,3 +200,3 @@ /*!
      *
-     * @resource [Subscriptions: get API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/get}
+     * @resource [Subscriptions: get API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/get}
      *
@@ -382,3 +382,3 @@ * @param {function} callback - The callback function.
  *
- * @resource [Subscriptions: acknowledge API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/acknowledge}
+ * @resource [Subscriptions: acknowledge API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/acknowledge}
  *
@@ -472,3 +472,3 @@ * @throws {Error} If at least one ackId is not provided.
  *
- * @resource [Subscriptions: delete API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/delete}
+ * @resource [Subscriptions: delete API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/delete}
  *
@@ -528,3 +528,3 @@ * @param {function=} callback - The callback function.
  *
- * @resource [Subscriptions: pull API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/pull}
+ * @resource [Subscriptions: pull API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/pull}
  *
@@ -641,3 +641,3 @@ * @param {object=} options - Configuration object.
  *
- * @resource [Subscriptions: modifyAckDeadline API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/modifyAckDeadline}
+ * @resource [Subscriptions: modifyAckDeadline API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/modifyAckDeadline}
  *
@@ -644,0 +644,0 @@ * @param {object} options - The configuration object.

src/topic.js

@@ -79,3 +79,3 @@ /*!
      *
-     * @resource [Topics: delete API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/delete}
+     * @resource [Topics: delete API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/delete}
      *
@@ -154,3 +154,3 @@ * @param {function=} callback - The callback function.
      *
-     * @resource [Topics: get API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/get}
+     * @resource [Topics: get API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/get}
      *
@@ -271,3 +271,3 @@ * @param {function} callback - The callback function.
  *
- * @resource [Subscriptions: list API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics.subscriptions/list}
+ * @resource [Subscriptions: list API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics.subscriptions/list}
  *
@@ -365,3 +365,3 @@ * @param {object=} options - Configuration object.
  *
- * @resource [Topics: publish API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/publish}
+ * @resource [Topics: publish API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/publish}
  *
@@ -482,13 +482,10 @@ * @throws {Error} If no message is provided.
 /**
- * Create a subscription to this topic. You may optionally provide an object to
- * customize the subscription.
+ * Create a subscription to this topic.
  *
- * Your provided callback will be invoked with an error object if an API error
- * occurred or a {module:pubsub/subscription} object.
+ * @resource [Subscriptions: create API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/create}
  *
- * @resource [Subscriptions: create API Documentation]{@link https://cloud.google.com/pubsub/reference/rest/v1/projects.subscriptions/create}
- *
  * @param {string} subName - The name of the subscription.
- * @param {object=} options - Configuration object.
- * @param {number=} options.ackDeadlineSeconds - The maximum time after
+ * @param {object=} options - See a
+ *     [Subscription resource](https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions)
+ * @param {number} options.ackDeadlineSeconds - The maximum time after
  *     receiving a message that you must ack a message before it is redelivered.
@@ -499,6 +496,8 @@ * @param {boolean=} options.autoAck - Automatically acknowledge the message
  *     used when converting a message's data to a string. (default: 'utf-8')
- * @param {number=} options.interval - Interval in milliseconds to check for new
+ * @param {number} options.interval - Interval in milliseconds to check for new
  *     messages. (default: 10)
  * @param {number} options.maxInProgress - Maximum messages to consume
  *     simultaneously.
+ * @param {string} options.pushEndpoint - A URL to a custom endpoint that
+ *     messages should be pushed to.
  * @param {boolean=} options.reuseExisting - If the subscription already exists,
@@ -505,0 +504,0 @@ *     reuse it. The options of the existing subscription are not changed. If

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

151169

increased by0.17%

Lines of code

3776

increased by0.08%

Dependency changes

• + Added@google-cloud/common@0.8.1(transitive)

• + Addedgoogle-auth-library@0.10.0(transitive)

• + Addedgoogle-auto-auth@0.5.4(transitive)

• + Addedgoogle-gax@0.9.1(transitive)

• + Addedjwa@1.4.1(transitive)

• + Addedjws@3.2.2(transitive)

• - Removed@google-cloud/common@0.7.1(transitive)

• - Removedassertion-error@2.0.1(transitive)

• - Removedchai@5.1.2(transitive)

• - Removedcheck-error@2.1.1(transitive)

• - Removeddeep-eql@5.0.2(transitive)

• - Removedgoogle-auto-auth@0.3.0(transitive)

• - Removedgoogle-gax@0.8.1(transitive)

• - Removedloupe@3.1.2(transitive)

• - Removedpathval@2.0.0(transitive)

• Updated@google-cloud/common@^0.8.0

• Updatedgoogle-gax@^0.9.1