@staminna Here's a more concise example you can try. Save it to a file and run it. You don't have to pass any arguments to the file.

// Copyright 2016, Google, Inc.
// 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.

'use strict';

var async = require('async');
var fs = require('fs');
var path = require('path');
var grpc = require('grpc');
var googleProtoFiles = require('google-proto-files');
var googleAuth = require('google-auto-auth');
var Transform = require('stream').Transform;
var record = require('node-record-lpcm16');

var PROTO_ROOT_DIR = googleProtoFiles('..');
var protoDescriptor = grpc.load({
  root: PROTO_ROOT_DIR,
  file: path.relative(PROTO_ROOT_DIR, googleProtoFiles.speech.v1beta1)
}, 'proto', {
  binaryAsBase64: true,
  convertFieldsToCamelCase: true
});
var speechProto = protoDescriptor.google.cloud.speech.v1beta1;

function getSpeechService (callback) {
  var googleAuthClient = googleAuth({
    scopes: [
      'https://www.googleapis.com/auth/cloud-platform'
    ]
  });

  googleAuthClient.getAuthClient(function (err, authClient) {
    if (err) {
      return callback(err);
    }

    var credentials = grpc.credentials.combineChannelCredentials(
      grpc.credentials.createSsl(),
      grpc.credentials.createFromGoogleCredential(authClient)
    );

    console.log('Loading speech service...');
    var stub = new speechProto.Speech('speech.googleapis.com', credentials);
    return callback(null, stub);
  });
}

async.waterfall([
  function (cb) {
    getSpeechService(cb);
  },
  function sendRequest (speechService, cb) {
    console.log('Analyzing speech...');
    var call = speechService.streamingRecognize()
      .on('error', cb)
      .on('data', function (recognizeResponse) {
        console.log(JSON.stringify(recognizeResponse, null, 2));
      })
      .on('end', cb);

    // Write the initial recognize reqeust
    call.write({
      streamingConfig: {
        config: {
          encoding: 'LINEAR16',
          sampleRate: 16000
        },
        interimResults: true,
        singleUtterance: false
      }
    });

    var toRecognizeRequest = new Transform({ objectMode: true });
    toRecognizeRequest._transform = function (chunk, encoding, done) {
      done(null, {
        audioContent: chunk
      });
    };

    // Start recording
    var readableMicrophoneStream = record.start({
      sampleRate : 16000,
      verbose : true
    });

    // Stream the microphone audio to the Speech API
    readableMicrophoneStream
      .pipe(toRecognizeRequest)
      .pipe(call);
  }
], function (err) {
  if (err) {
    return console.error(err);
  }
  console.log('DONE');
});

microphone input stream #157

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions