up

internal/audio/recorder.go

@@ -221,27 +221,43 @@ func (r *Recorder) RestartQSO() {
 	r.active = true
 }
 
-// SaveQSO writes the accumulated recording to path as a WAV and stops
-// accumulating. Returns an error if no recording was active.
-func (r *Recorder) SaveQSO(path string) error {
+// TakeQSO snapshots the accumulated recording as raw 16 kHz mono PCM bytes and
+// stops accumulating — fast, no encoding. The next BeginQSO can safely start a
+// new take immediately. Pair with WritePCM to encode/write off the hot path so
+// a long recording doesn't delay logging.
+func (r *Recorder) TakeQSO() ([]byte, error) {
 	r.mu.Lock()
 	if !r.active {
 		r.mu.Unlock()
-		return fmt.Errorf("no active recording")
+		return nil, fmt.Errorf("no active recording")
 	}
 	samples := r.acc
 	r.acc, r.active = nil, false
 	r.mu.Unlock()
 	if len(samples) == 0 {
-		return fmt.Errorf("recording was empty")
+		return nil, fmt.Errorf("recording was empty")
 	}
-	data := int16sToBytes(samples)
+	return int16sToBytes(samples), nil
+}
+
+// WritePCM encodes raw 16 kHz mono PCM to path (WAV, or MP3 when path ends in
+// .mp3). Slow for MP3 — call off the logging path.
+func WritePCM(path string, data []byte) error {
 	if strings.HasSuffix(strings.ToLower(path), ".mp3") {
 		return writeMP3(path, data)
 	}
 	return writeWAV(path, data)
 }
 
+// SaveQSO snapshots and writes the recording in one call (synchronous).
+func (r *Recorder) SaveQSO(path string) error {
+	data, err := r.TakeQSO()
+	if err != nil {
+		return err
+	}
+	return WritePCM(path, data)
+}
+
 // DiscardQSO drops the active accumulation without saving (callsign cleared).
 func (r *Recorder) DiscardQSO() {
 	r.mu.Lock()