codetether-agent 4.7.0-a-002.3

A2A-native AI coding agent for the CodeTether ecosystem
Documentation 
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

//! Background voice recording and transcription worker.

use std::sync::atomic::AtomicBool;
use std::sync::{Arc, Mutex};

use crate::tool::voice_input::{encoder, recorder};

use super::voice_transcribe::transcribe_sync;

type VoiceSlot = Arc<Mutex<Option<String>>>;

/// Start recording audio and publish the transcription result to `slot`.
pub(super) fn spawn_voice_worker(max: u64, flag: Arc<AtomicBool>, slot: VoiceSlot) {
    std::thread::spawn(move || publish_voice_text(&slot, record_text(max, flag)));
}

fn record_text(max: u64, flag: Arc<AtomicBool>) -> String {
    match recorder::record(max, flag) {
        Ok(samples) => encoder::encode_wav(&samples)
            .ok()
            .and_then(|wav| transcribe_sync(&wav))
            .unwrap_or_default(),
        Err(e) => {
            tracing::error!(error = %e, "Recording failed");
            String::new()
        }
    }
}

fn publish_voice_text(slot: &VoiceSlot, text: String) {
    if let Ok(mut guard) = slot.lock() {
        *guard = Some(text);
    }
}