modify helpers.js to be compatible with generated code (#116)

* modify helpers.js to be compatible with generated code

* add newline to config

Author: crwilcox

packages/google-cloud-speech/.circleci/config.yml

@@ -143,13 +143,13 @@ jobs:
           command: npm run samples-test
           environment:
             GCLOUD_PROJECT: long-door-651
-            GOOGLE_APPLICATION_CREDENTIALS: /home/node/speech-samples/.circleci/key.json
+            GOOGLE_APPLICATION_CREDENTIALS: /home/node/samples/.circleci/key.json
             NPM_CONFIG_PREFIX: /home/node/.npm-global
       - run:
           name: Remove unencrypted key.
           command: rm .circleci/key.json
           when: always
-    working_directory: /home/node/speech-samples/
+    working_directory: /home/node/samples/
   system_tests:
     docker:
       - image: 'node:8'
@@ -181,3 +181,4 @@ jobs:
       - checkout
       - run: 'echo "//registry.npmjs.org/:_authToken=${NPM_TOKEN}" > ~/.npmrc'
       - run: npm publish
+

packages/google-cloud-speech/src/helpers.js

@@ -87,10 +87,8 @@ module.exports = () => {
         recognizeStream.emit('response', response);
       });
 
-      // Write the initial configuration to the stream.
-      requestStream.write({
-        streamingConfig: config,
-      });
+      // The first message should contain the streaming config.
+      let first_message = true;
 
       // Set up appropriate piping between the stream returned by
       // the underlying API method and the one that we return.
@@ -99,9 +97,17 @@ module.exports = () => {
         // This entails that the user sends raw audio; it is wrapped in
         // the appropriate request structure.
         through.obj((obj, _, next) => {
-          next(null, {
-            audioContent: obj,
-          });
+          let payload = {};
+          if (first_message && config !== undefined) {
+            // Write the initial configuration to the stream.
+            payload.streamingConfig = config;
+          }
+
+          if (Object.keys(obj || {}).length) {
+            payload.audioContent = obj;
+          }
+
+          next(null, payload);
         }),
         requestStream,
         through.obj(),

packages/google-cloud-speech/synth.py

@@ -30,16 +30,14 @@
     library = gapic.node_library('speech', version)
 
     # skip index, protos, package.json, and README.md
-    # Skip tests as they are handedited until the Generator is fixed.
-    # https://github.com/googleapis/gapic-generator/issues/2129
     s.copy(
         library,
-        excludes=['package.json', 'README.md', 'src/index.js',
-                  f'test/gapic-{version}.js']
+        excludes=['package.json', 'README.md', 'src/index.js',]
     )
 
 templates = common_templates.node_library(package_name="@google-cloud/speech")
 s.copy(templates)
+
 #
 # Node.js specific cleanup
 #

packages/google-cloud-speech/test/gapic-v1.js

@@ -229,22 +229,18 @@ describe('SpeechClient', () => {
 
       // Mock response
       var expectedResponse = {};
-      var expectedRequests = [{streamingConfig: undefined}, {audioContent: {}}];
 
       // Mock Grpc layer
       client._innerApiCalls.streamingRecognize = mockBidiStreamingGrpcMethod(
-        expectedRequests,
+        request,
         expectedResponse
       );
 
-      let loops = 0;
       var stream = client
         .streamingRecognize()
         .on('data', response => {
           assert.deepStrictEqual(response, expectedResponse);
-          if (++loops === expectedRequests.length) {
-            done();
-          }
+          done();
         })
         .on('error', err => {
           done(err);
@@ -261,15 +257,10 @@ describe('SpeechClient', () => {
 
       // Mock request
       var request = {};
-      var expectedRequests = [
-        {streamingConfig: undefined},
-        {streamingConfig: undefined},
-        {streamingConfig: undefined},
-      ];
 
       // Mock Grpc layer
       client._innerApiCalls.streamingRecognize = mockBidiStreamingGrpcMethod(
-        expectedRequests,
+        request,
         null,
         error
       );
@@ -303,11 +294,10 @@ function mockSimpleGrpcMethod(expectedRequest, response, error) {
   };
 }
 
-let callCount = 0;
-function mockBidiStreamingGrpcMethod(expectedRequests, response, error) {
+function mockBidiStreamingGrpcMethod(expectedRequest, response, error) {
   return () => {
     var mockStream = through2.obj((chunk, enc, callback) => {
-      assert.deepStrictEqual(chunk, expectedRequests[callCount++]);
+      assert.deepStrictEqual(chunk, expectedRequest);
       if (error) {
         callback(error);
       } else {

packages/google-cloud-speech/test/gapic-v1p1beta1.js

@@ -226,25 +226,21 @@ describe('SpeechClient', () => {
 
       // Mock request
       var request = {};
-      var expectedRequests = [{streamingConfig: undefined}, {audioContent: {}}];
 
       // Mock response
       var expectedResponse = {};
 
       // Mock Grpc layer
       client._innerApiCalls.streamingRecognize = mockBidiStreamingGrpcMethod(
-        expectedRequests,
+        request,
         expectedResponse
       );
 
-      let loops = 0;
       var stream = client
         .streamingRecognize()
         .on('data', response => {
           assert.deepStrictEqual(response, expectedResponse);
-          if (++loops === expectedRequests.length) {
-            done();
-          }
+          done();
         })
         .on('error', err => {
           done(err);
@@ -261,15 +257,10 @@ describe('SpeechClient', () => {
 
       // Mock request
       var request = {};
-      var expectedRequests = [
-        {streamingConfig: undefined},
-        {streamingConfig: undefined},
-        {streamingConfig: undefined},
-      ];
 
       // Mock Grpc layer
       client._innerApiCalls.streamingRecognize = mockBidiStreamingGrpcMethod(
-        expectedRequests,
+        request,
         null,
         error
       );
@@ -303,11 +294,10 @@ function mockSimpleGrpcMethod(expectedRequest, response, error) {
   };
 }
 
-let callCount = 0;
-function mockBidiStreamingGrpcMethod(expectedRequests, response, error) {
+function mockBidiStreamingGrpcMethod(expectedRequest, response, error) {
   return () => {
     var mockStream = through2.obj((chunk, enc, callback) => {
-      assert.deepStrictEqual(chunk, expectedRequests[callCount++]);
+      assert.deepStrictEqual(chunk, expectedRequest);
       if (error) {
         callback(error);
       } else {

packages/google-cloud-speech/test/helpers.test.js

@@ -66,7 +66,7 @@ describe('Speech helper methods', () => {
         next(null, data);
       };
 
-      userStream.emit('writing');
+      userStream.write(undefined);
     });
 
     it('does not require options', () => {
@@ -140,11 +140,11 @@ describe('Speech helper methods', () => {
       var audioContent = Buffer.from('audio content');
 
       requestStream._write = (data, enc, next) => {
-        if (data && data.streamingConfig !== CONFIG) {
-          assert.deepStrictEqual(data, {audioContent});
-          setImmediate(done);
-        }
-
+        assert.deepStrictEqual(data, {
+          audioContent: audioContent,
+          streamingConfig: CONFIG,
+        });
+        setImmediate(done);
         next(null, data);
       };