[CHANGE ME] Re-generated to pick up changes in the API or client library generator.

smoke-test/publisher_smoke_test.js

@@ -0,0 +1,92 @@
+// Copyright 2018 Google LLC
+//
+// 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
+//
+//     https://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.
+
+'use strict';
+
+describe('PublisherSmokeTest', () => {
+  if (!process.env.GCLOUD_PROJECT) {
+    throw new Error("Usage: GCLOUD_PROJECT=<project_id> node #{$0}");
+  }
+  const projectId = process.env.GCLOUD_PROJECT;
+
+  it('successfully makes a call to the service using promises', done => {
+    const pubsub = require('../src');
+
+    const client = new pubsub.v1.PublisherClient({
+      // optional auth parameters.
+    });
+
+    // Iterate over all elements.
+    const formattedProject = client.projectPath(projectId);
+
+    client.listTopics({project: formattedProject})
+      .then(responses => {
+        const resources = responses[0];
+        for (let i = 0; i < resources.length; i += 1) {
+          console.log(resources[i]);
+        }
+      })
+      .then(done)
+      .catch(done);
+  });
+
+  it('successfully makes a call to the service using callbacks', done => {
+    const pubsub = require('../src');
+
+    const client = new pubsub.v1.PublisherClient({
+      // optional auth parameters.
+    });
+
+    // Or obtain the paged response.
+    const formattedProject = client.projectPath(projectId);
+
+
+    const options = {autoPaginate: false};
+    const callback = responses => {
+      // The actual resources in a response.
+      const resources = responses[0];
+      // The next request if the response shows that there are more responses.
+      const nextRequest = responses[1];
+      // The actual response object, if necessary.
+      // const rawResponse = responses[2];
+      for (let i = 0; i < resources.length; i += 1) {
+        console.log(resources[i]);
+      }
+      if (nextRequest) {
+        // Fetch the next page.
+        return client.listTopics(nextRequest, options).then(callback);
+      }
+    }
+    client.listTopics({project: formattedProject}, options)
+      .then(callback)
+      .then(done)
+      .catch(done);
+  });
+
+  it('successfully makes a call to the service using streaming', done => {
+    const pubsub = require('../src');
+
+    const client = new pubsub.v1.PublisherClient({
+      // optional auth parameters.
+    });
+
+    const formattedProject = client.projectPath(projectId);
+    client.listTopicsStream({project: formattedProject})
+      .on('data', element => {
+        console.log(element);
+      })
+      .on('error', done)
+      .on('end', done);
+  });
+});

src/v1/publisher_client.js

@@ -109,7 +109,9 @@ class PublisherClient {
       topicPathTemplate: new gax.PathTemplate(
         'projects/{project}/topics/{topic}'
       ),
-      projectPathTemplate: new gax.PathTemplate('projects/{project}'),
+      projectPathTemplate: new gax.PathTemplate(
+        'projects/{project}'
+      ),
     };
 
     // Some of the methods on this service return "paged" results,
@@ -129,36 +131,25 @@ class PublisherClient {
     };
     let protoFilesRoot = new gax.GoogleProtoFilesRoot();
     protoFilesRoot = protobuf.loadSync(
-      path.join(
-        __dirname,
-        '..',
-        '..',
-        'protos',
-        'google/iam/v1/iam_policy.proto'
-      ),
+      path.join(__dirname, '..', '..', 'protos', 'google/iam/v1/iam_policy.proto'),
       protoFilesRoot
     );
     protoFilesRoot = protobuf.loadSync(
-      path.join(
-        __dirname,
-        '..',
-        '..',
-        'protos',
-        'google/pubsub/v1/pubsub.proto'
-      ),
+      path.join(__dirname, '..', '..', 'protos', 'google/pubsub/v1/pubsub.proto'),
       protoFilesRoot
     );
 
+
     // Some methods on this API support automatically batching
     // requests; denote this.
     this._descriptors.batching = {
       publish: new gax.BundleDescriptor(
         'messages',
-        ['topic'],
+        [
+          'topic',
+        ],
         'messageIds',
-        gax.createByteLengthFunction(
-          protoFilesRoot.lookup('google.pubsub.v1.PubsubMessage')
-        )
+        gax.createByteLengthFunction(protoFilesRoot.lookup('google.pubsub.v1.PubsubMessage'))
       ),
     };
 
@@ -199,8 +190,7 @@ class PublisherClient {
             }
         ),
         defaults[methodName],
-        this._descriptors.page[methodName] ||
-          this._descriptors.batching[methodName]
+        this._descriptors.page[methodName] || this._descriptors.batching[methodName]
       );
     }
 
@@ -232,8 +222,7 @@ class PublisherClient {
             }
         ),
         defaults[methodName],
-        this._descriptors.page[methodName] ||
-          this._descriptors.batching[methodName]
+        this._descriptors.page[methodName] || this._descriptors.batching[methodName]
       );
     }
   }
@@ -658,7 +647,7 @@ class PublisherClient {
       request,
       options
     );
-  }
+  };
 
   /**
    * Lists the names of the subscriptions on this topic.
@@ -752,11 +741,7 @@ class PublisherClient {
     }
     options = options || {};
 
-    return this._innerApiCalls.listTopicSubscriptions(
-      request,
-      options,
-      callback
-    );
+    return this._innerApiCalls.listTopicSubscriptions(request, options, callback);
   }
 
   /**
@@ -813,7 +798,7 @@ class PublisherClient {
       request,
       options
     );
-  }
+  };
 
   /**
    * Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
@@ -1067,7 +1052,9 @@ class PublisherClient {
    * @returns {String} - A string representing the project.
    */
   matchProjectFromTopicName(topicName) {
-    return this._pathTemplates.topicPathTemplate.match(topicName).project;
+    return this._pathTemplates.topicPathTemplate
+      .match(topicName)
+      .project;
   }
 
   /**
@@ -1078,7 +1065,9 @@ class PublisherClient {
    * @returns {String} - A string representing the topic.
    */
   matchTopicFromTopicName(topicName) {
-    return this._pathTemplates.topicPathTemplate.match(topicName).topic;
+    return this._pathTemplates.topicPathTemplate
+      .match(topicName)
+      .topic;
   }
 
   /**
@@ -1089,8 +1078,11 @@ class PublisherClient {
    * @returns {String} - A string representing the project.
    */
   matchProjectFromProjectName(projectName) {
-    return this._pathTemplates.projectPathTemplate.match(projectName).project;
+    return this._pathTemplates.projectPathTemplate
+      .match(projectName)
+      .project;
   }
 }
 
+
 module.exports = PublisherClient;

src/v1/publisher_client_config.json

@@ -6,10 +6,6 @@
           "DEADLINE_EXCEEDED",
           "UNAVAILABLE"
         ],
-        "http_get": [
-          "DEADLINE_EXCEEDED",
-          "UNAVAILABLE"
-        ],
         "non_idempotent": [],
         "one_plus_delivery": [
           "ABORTED",

src/v1/subscriber_client.js

@@ -112,7 +112,9 @@ class SubscriberClient {
       topicPathTemplate: new gax.PathTemplate(
         'projects/{project}/topics/{topic}'
       ),
-      projectPathTemplate: new gax.PathTemplate('projects/{project}'),
+      projectPathTemplate: new gax.PathTemplate(
+        'projects/{project}'
+      ),
       snapshotPathTemplate: new gax.PathTemplate(
         'projects/{project}/snapshots/{snapshot}'
       ),
@@ -177,8 +179,7 @@ class SubscriberClient {
             }
         ),
         defaults[methodName],
-        this._descriptors.page[methodName] ||
-          this._descriptors.stream[methodName]
+        this._descriptors.page[methodName] || this._descriptors.stream[methodName]
       );
     }
 
@@ -218,8 +219,7 @@ class SubscriberClient {
             }
         ),
         defaults[methodName],
-        this._descriptors.page[methodName] ||
-          this._descriptors.stream[methodName]
+        this._descriptors.page[methodName] || this._descriptors.stream[methodName]
       );
     }
 
@@ -664,7 +664,7 @@ class SubscriberClient {
       request,
       options
     );
-  }
+  };
 
   /**
    * Deletes an existing subscription. All messages retained in the subscription
@@ -1137,7 +1137,7 @@ class SubscriberClient {
       request,
       options
     );
-  }
+  };
 
   /**
    * Creates a snapshot from the requested subscription.<br><br>
@@ -1644,7 +1644,8 @@ class SubscriberClient {
    * @returns {String} - A string representing the project.
    */
   matchProjectFromSubscriptionName(subscriptionName) {
-    return this._pathTemplates.subscriptionPathTemplate.match(subscriptionName)
+    return this._pathTemplates.subscriptionPathTemplate
+      .match(subscriptionName)
       .project;
   }
 
@@ -1656,7 +1657,8 @@ class SubscriberClient {
    * @returns {String} - A string representing the subscription.
    */
   matchSubscriptionFromSubscriptionName(subscriptionName) {
-    return this._pathTemplates.subscriptionPathTemplate.match(subscriptionName)
+    return this._pathTemplates.subscriptionPathTemplate
+      .match(subscriptionName)
       .subscription;
   }
 
@@ -1668,7 +1670,9 @@ class SubscriberClient {
    * @returns {String} - A string representing the project.
    */
   matchProjectFromTopicName(topicName) {
-    return this._pathTemplates.topicPathTemplate.match(topicName).project;
+    return this._pathTemplates.topicPathTemplate
+      .match(topicName)
+      .project;
   }
 
   /**
@@ -1679,7 +1683,9 @@ class SubscriberClient {
    * @returns {String} - A string representing the topic.
    */
   matchTopicFromTopicName(topicName) {
-    return this._pathTemplates.topicPathTemplate.match(topicName).topic;
+    return this._pathTemplates.topicPathTemplate
+      .match(topicName)
+      .topic;
   }
 
   /**
@@ -1690,7 +1696,9 @@ class SubscriberClient {
    * @returns {String} - A string representing the project.
    */
   matchProjectFromProjectName(projectName) {
-    return this._pathTemplates.projectPathTemplate.match(projectName).project;
+    return this._pathTemplates.projectPathTemplate
+      .match(projectName)
+      .project;
   }
 
   /**
@@ -1701,7 +1709,9 @@ class SubscriberClient {
    * @returns {String} - A string representing the project.
    */
   matchProjectFromSnapshotName(snapshotName) {
-    return this._pathTemplates.snapshotPathTemplate.match(snapshotName).project;
+    return this._pathTemplates.snapshotPathTemplate
+      .match(snapshotName)
+      .project;
   }
 
   /**
@@ -1712,9 +1722,11 @@ class SubscriberClient {
    * @returns {String} - A string representing the snapshot.
    */
   matchSnapshotFromSnapshotName(snapshotName) {
-    return this._pathTemplates.snapshotPathTemplate.match(snapshotName)
+    return this._pathTemplates.snapshotPathTemplate
+      .match(snapshotName)
       .snapshot;
   }
 }
 
+
 module.exports = SubscriberClient;

src/v1/subscriber_client_config.json

@@ -12,10 +12,6 @@
           "RESOURCE_EXHAUSTED",
           "UNAVAILABLE"
         ],
-        "http_get": [
-          "DEADLINE_EXCEEDED",
-          "UNAVAILABLE"
-        ],
         "non_idempotent": []
       },
       "retry_params": {