rephrase.py

from talon import Module, speech_system, cron
from talon.grammar import Phrase

mod = Module()

phrase_stack = []


def on_pre_phrase(d):  phrase_stack.append(d)
def on_post_phrase(_): phrase_stack.pop()


speech_system.register("pre:phrase", on_pre_phrase)
speech_system.register("post:phrase", on_post_phrase)


@mod.action_class
class Actions:
    def rephrase(phrase: Phrase, run_async: bool = False):
        """Re-evaluate and run phrase"""
        try:
            current_phrase = phrase_stack[-1]
            ts = current_phrase["_ts"]
            start = phrase.words[0].start - ts
            end = phrase.words[-1].end - ts
            samples = current_phrase["samples"]
            pstart = int(start * 16_000)
            pend = int(end * 16_000)
            samples = samples[pstart:pend]
        except KeyError:
            return

        if run_async:
            cron.after("0ms", lambda: speech_system._on_audio_frame(samples))
        else:
            speech_system._on_audio_frame(samples)