File size: 1,149 Bytes
9680844
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
import logging

logger = logging.getLogger("gunicorn")


def get_transcoder_output_events(transcoder) -> list:
    speech_and_text_output = transcoder.get_buffered_output()
    if speech_and_text_output is None:
        logger.debug("No output from transcoder.get_buffered_output()")
        return []

    logger.debug(f"We DID get output from the transcoder! {speech_and_text_output}")

    lat = None

    events = []

    if speech_and_text_output.speech_samples:
        events.append(
            {
                "event": "translation_speech",
                "payload": speech_and_text_output.speech_samples,
                "sample_rate": speech_and_text_output.speech_sample_rate,
            }
        )

    if speech_and_text_output.text:
        events.append(
            {
                "event": "translation_text",
                "payload": speech_and_text_output.text,
            }
        )

    for e in events:
        e["eos"] = speech_and_text_output.final

    # if not latency_sent:
    #     lat = transcoder.first_translation_time()
    #     latency_sent = True
    #     to_send["latency"] = lat

    return events