let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: run speech tap and handlers on safe queues

Browse Source
This commit is contained in:
Peter Steinberger
2025-12-06 03:16:41 +01:00
parent bf21ed7282
commit 135a52020c
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
apps/macos/Sources/Clawdis/AppMain.swift
View File

@@ -1393,6 +1393,7 @@ final class VoiceWakeTester {
private let audioEngine = AVAudioEngine() private let audioEngine = AVAudioEngine()
private var recognitionRequest: SFSpeechAudioBufferRecognitionRequest? private var recognitionRequest: SFSpeechAudioBufferRecognitionRequest?
private var recognitionTask: SFSpeechRecognitionTask? private var recognitionTask: SFSpeechRecognitionTask?
private let audioQueue = DispatchQueue(label: "com.steipete.clawdis.voicewake.audio", qos: .userInitiated)
init(locale: Locale = .current) { init(locale: Locale = .current) {
self.recognizer = SFSpeechRecognizer(locale: locale) self.recognizer = SFSpeechRecognizer(locale: locale)
@@ -1425,7 +1426,7 @@ final class VoiceWakeTester {
inputNode.removeTap(onBus: 0) inputNode.removeTap(onBus: 0)
inputNode.installTap(onBus: 0, bufferSize: 2048, format: format) { [weak self] buffer, _ in inputNode.installTap(onBus: 0, bufferSize: 2048, format: format) { [weak self] buffer, _ in
guard let self else { return } guard let self else { return }
self.recognitionRequest?.append(buffer) self.enqueueBuffer(buffer)
} }
audioEngine.prepare() audioEngine.prepare()
@@ -1439,7 +1440,9 @@ final class VoiceWakeTester {
let text = result?.bestTranscription.formattedString ?? "" let text = result?.bestTranscription.formattedString ?? ""
let matched = Self.matches(text: text, triggers: triggers) let matched = Self.matches(text: text, triggers: triggers)
let errorMessage = error?.localizedDescription let errorMessage = error?.localizedDescription
self.handleResult(matched: matched, text: text, isFinal: result?.isFinal ?? false, errorMessage: errorMessage, onUpdate: onUpdate) DispatchQueue.main.async {
self.handleResult(matched: matched, text: text, isFinal: result?.isFinal ?? false, errorMessage: errorMessage, onUpdate: onUpdate)
}
} }
} }
@@ -1452,6 +1455,13 @@ final class VoiceWakeTester {
audioEngine.inputNode.removeTap(onBus: 0) audioEngine.inputNode.removeTap(onBus: 0)
} }
private func enqueueBuffer(_ buffer: AVAudioPCMBuffer) {
audioQueue.async { [weak self] in
guard let self else { return }
self.recognitionRequest?.append(buffer)
}
}
private func handleResult( private func handleResult(
matched: Bool, matched: Bool,
text: String, text: String,