지금 보내기

  // frontend/src/hooks/useHandsFree.ts (cwkPippa), verbatim
  const sendNow = useCallback((): boolean => {
    if (phaseRef.current !== 'listening' || !captureRef.current) return false;
    if (sendNowRef.current !== null) return true;
    const socket = socketRef.current;
    if (windowWaitRef.current !== null && segmentsRef.current.length && !partialRef.current) {
      // Scribe already committed after silence and the loop is waiting out the
      // rest of Dad's window: nothing more to ask for.
      void finishTurn();
      return true;
    }
    sendNowRef.current = window.setTimeout(() => {
      sendNowRef.current = null;
      if (phaseRef.current !== 'listening') return;
      // The commit's words never came: what was heard live goes out.
      const partial = partialRef.current.trim();
      if (partial) segmentsRef.current.push(partial);
      if (segmentsRef.current.length) void finishTurn();
    }, SEND_NOW_WAIT_MS);
    if (socket && socket.readyState === WebSocket.OPEN) {
      socket.send(JSON.stringify({ message_type: 'input_audio_chunk', audio_base_64: '', commit: true, sample_rate: SAMPLE_RATE }));
    }
    return true;
  }, [finishTurn]);

import asyncio

SEND_NOW_WAIT = 1.5   # seconds: never wait on the ear longer than this


async def send_now(scribe_commit, heard_live: list[str], partial: str, *, phone: bool) -> str:
    """Dad pressed Send now: ask for a manual commit, never wait on it for long."""
    try:
        words = await asyncio.wait_for(scribe_commit(), SEND_NOW_WAIT)
    except asyncio.TimeoutError:
        # The commit is late, so the live words are late too.
        if phone:
            return "turn ends; the recording on the phone is transcribed whole"
        live = heard_live + ([partial] if partial else [])
        if not live:
            return "keep listening: nothing heard yet to send"
        return f"turn goes out with what was heard live: {' '.join(live)!r}"
    pieces = heard_live + ([words] if words else [])
    if not pieces:
        return "keep listening: nothing heard yet to send"
    return f"turn goes out: {' '.join(pieces)!r}"


def scribe(after: float, words: str):
    async def commit() -> str:
        await asyncio.sleep(after)   # the socket's queue, then Scribe's answer
        return words
    return commit


async def main() -> None:
    # A quick link: the manual commit answers in about a quarter-second.
    print(await send_now(scribe(0.23, "and that's the plan"), ["Okay,"], "and that's", phone=False))
    # A weak mobile link: the socket's audio is queued and the answer is late.
    print(await send_now(scribe(6.0, "and that's the plan"), ["Okay,"], "and that's", phone=False))
    print(await send_now(scribe(6.0, "and that's the plan"), ["Okay,"], "and that's", phone=True))
    # A press before a single word: Scribe commits nothing over nothing.
    print(await send_now(scribe(0.2, ""), [], "", phone=True))
    # The same empty press on the web, with the commit stuck behind the queue.
    print(await send_now(scribe(3.0, ""), [], "", phone=False))


asyncio.run(main())

# Output:
# turn goes out: "Okay, and that's the plan"
# turn goes out with what was heard live: "Okay, and that's"
# turn ends; the recording on the phone is transcribed whole
# keep listening: nothing heard yet to send
# keep listening: nothing heard yet to send