diff --git a/buf.gen.yaml b/buf.gen.yaml index d2e6e12..94afb6b 100644 --- a/buf.gen.yaml +++ b/buf.gen.yaml @@ -11,4 +11,4 @@ plugins: out: proto/generated inputs: - git_repo: https://github.com/verbio-technologies/public-grpc-protos.git - branch: 1.0.1 \ No newline at end of file + branch: main diff --git a/cli-client/helpers/csr_client.py b/cli-client/helpers/csr_client.py index d5ad3c2..037ff5f 100644 --- a/cli-client/helpers/csr_client.py +++ b/cli-client/helpers/csr_client.py @@ -8,6 +8,7 @@ from threading import Timer from concurrent.futures import ThreadPoolExecutor import speechcenter.stt.recognition_streaming_request_pb2 as recognition_streaming_request_pb2 +import speechcenter.stt.recognition_streaming_response_pb2 as recognition_streaming_response_pb2 from helpers.common import split_audio from helpers.audio_importer import AudioImporter @@ -45,6 +46,12 @@ def _start_inactivity_timer(self, inactivity_timeout: float): self._inactivity_timer.start() def _print_result(self, response): + if response.HasField("speech_event"): + event = response.speech_event + if event.type == recognition_streaming_response_pb2.SpeechEvent.Event.SPEECH_START: + logging.info(f"New SPEECH_START event on {event.time_offset}") + return + if not response.HasField("result"): return