Add Speech Streaming (GoogleCloudPlatform#342)

* add speech streaming
* changes the dist to trusty and adds sudo for grpc installation.

Author: bshaffer

.travis.yml

@@ -17,6 +17,8 @@ branches:
     - master
 
 language: php
+sudo: required
+dist: trusty
 
 matrix:
   include:
@@ -40,6 +42,9 @@ before_install:
   - popd
   - mkdir -p build/logs
 
+before_script:
+  - pecl install grpc
+
 script:
   - testing/run_test_suite.sh
 

speech/api/composer.json

@@ -2,13 +2,16 @@
     "require": {
         "google/cloud-speech": "^0.2",
         "google/cloud-storage": "^1.0",
+        "google/gax": "^0.8.1",
+        "google/proto-client-php": "^0.10.0",
         "symfony/console": "^3.0"
     },
     "autoload": {
         "psr-4": {
             "Google\\Cloud\\Samples\\Speech\\": "src/"
         },
         "files": [
+            "src/functions/streaming_recognize.php",
             "src/functions/transcribe_async_gcs.php",
             "src/functions/transcribe_sync.php",
             "src/functions/transcribe_sync_gcs.php"

speech/api/composer.lock

@@ -75,6 +75,12 @@ protected function configure()
                 InputOption::VALUE_NONE,
                 'Run the transcription asynchronously. '
             )
+            ->addOption(
+                'stream',
+                null,
+                InputOption::VALUE_OPTIONAL,
+                'Stream the audio file. Supply an argument to stream from a mic.'
+            )
         ;
     }
 
@@ -93,6 +99,9 @@ protected function execute(InputInterface $input, OutputInterface $output)
             list($bucketName, $objectName) = array_slice($matches, 1);
         }
         if ($isGcs) {
+            if ($input->getOption('stream')) {
+                throw new LogicException('Cannot stream from a bucket!');
+            }
             if ($input->getOption('async')) {
                 transcribe_async_gcs($bucketName, $objectName, $languageCode, $options);
             } else {
@@ -101,6 +110,10 @@ protected function execute(InputInterface $input, OutputInterface $output)
         } else {
             if ($input->getOption('async')) {
                 throw new LogicException('Async requests require a GCS URI');
+            }
+            if ($input->getOption('stream')) {
+                $encodingInt = constant("google\cloud\speech\\v1\RecognitionConfig\AudioEncoding::$encoding");
+                streaming_recognize($audioFile, $languageCode, $encodingInt, $sampleRate);
             } else {
                 transcribe_sync($audioFile, $languageCode, $options);
             }

speech/api/src/TranscribeCommand.php

@@ -0,0 +1,97 @@
+<?php
+/**
+ * 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.
+ */
+
+/**
+ * For instructions on how to run the full sample:
+ *
+ * @see https://github.com/GoogleCloudPlatform/php-docs-samples/tree/master/speech/api/README.md
+ */
+
+namespace Google\Cloud\Samples\Speech;
+
+# [START streaming_recognize]
+use Google\Cloud\Speech\V1\SpeechClient;
+use google\cloud\speech\v1\RecognitionConfig;
+use google\cloud\speech\v1\StreamingRecognitionConfig;
+use google\cloud\speech\v1\StreamingRecognizeRequest;
+
+/**
+ * Transcribe an audio file using Google Cloud Speech API
+ * Example:
+ * ```
+ * $audoEncoding =  google\cloud\speech\v1\RecognitionConfig\AudioEncoding::WAV
+ * streaming_recognize('/path/to/audiofile.wav', 'en-US');
+ * ```.
+ *
+ * @param string $audioFile path to an audio file.
+ * @param string $languageCode The language of the content to
+ *     be recognized. Accepts BCP-47 (e.g., `"en-US"`, `"es-ES"`).
+ * @param string $encoding
+ * @param string $sampleRateHertz
+ *
+ * @return string the text transcription
+ */
+function streaming_recognize($audioFile, $languageCode, $encoding, $sampleRateHertz)
+{
+    if (!defined('Grpc\STATUS_OK')) {
+        throw new \Exception('Install the grpc extension ' .
+            '(pecl install grpc)');
+    }
+    if (!class_exists('google\cloud\speech\v1\SpeechGrpcClient')) {
+        throw new \Exception('Install the proto client PHP library ' .
+            '(composer require google/proto-client-php)');
+    }
+    if (!class_exists('Google\GAX\GrpcConstants')) {
+        throw new \Exception('Install the GAX library ' .
+            '(composer require google/gax)');
+    }
+
+    $speechClient = new SpeechClient();
+    try {
+        $config = new RecognitionConfig();
+        $config->setLanguageCode($languageCode);
+        $config->setEncoding($encoding);
+        $config->setSampleRateHertz($sampleRateHertz);
+
+        $strmConfig = new StreamingRecognitionConfig();
+        $strmConfig->setConfig($config);
+
+        $strmReq = new StreamingRecognizeRequest();
+        $strmReq->setStreamingConfig($strmConfig);
+
+        $strm = $speechClient->streamingRecognize();
+        $strm->write($strmReq);
+
+        $strmReq = new StreamingRecognizeRequest();
+        $f = fopen($audioFile, "rb");
+        $fsize = filesize($audioFile);
+        $bytes = fread($f, $fsize);
+        $strmReq->setAudioContent($bytes);
+        $strm->write($strmReq);
+
+        foreach ($strm->closeWriteAndReadAll() as $response) {
+            foreach ($response->getResults() as $result) {
+                foreach ($result->getAlternatives() as $alt) {
+                    printf("Transcription: %s\n", $alt->getTranscript());
+                }
+            }
+        }
+    } finally {
+        $speechClient->close();
+    }
+}
+# [END streaming_recognize]

speech/api/src/functions/streaming_recognize.php

@@ -86,6 +86,7 @@ public function provideTranscribe()
         return [
             [__DIR__ . '/data/audio32KHz.raw', 'LINEAR16', '32000'],
             [__DIR__ . '/data/audio32KHz.flac', 'FLAC', '32000'],
+            [__DIR__ . '/data/audio32KHz.raw', 'LINEAR16', '32000', ['--stream' => true]],
             ['gs://' . self::$bucketName . '/audio32KHz.raw', 'LINEAR16', '32000'],
             ['gs://' . self::$bucketName . '/audio32KHz.raw', 'LINEAR16', '32000', ['--async' => true]],
         ];