Mirror/intercept
1
0
Fork 0
mirror of https://github.com/smittix/intercept.git synced 2026-07-16 13:28:11 -07:00
Code Issues Packages Projects Releases Wiki Activity

Restart audio pipeline for fresh stream header

Browse Source
This commit is contained in:
Smittix
2026-02-04 11:04:43 +00:00
parent d59ebfb270
commit d64b351aef
2 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
routes/listening_post.py
+10 -3
View File
@@ -936,10 +936,17 @@ def audio_probe() -> Response:
return jsonify({'status': 'ok', 'bytes': size}) return jsonify({'status': 'ok', 'bytes': size})
@listening_post_bp.route('/audio/stream') @listening_post_bp.route('/audio/stream')
def stream_audio() -> Response: def stream_audio() -> Response:
"""Stream WAV audio.""" """Stream WAV audio."""
# Wait for audio to be ready (up to 2 seconds for modulation/squelch changes) # Optionally restart pipeline so the stream starts with a fresh header
if request.args.get('fresh') == '1' and audio_running:
try:
_start_audio_stream(audio_frequency or 0.0, audio_modulation or 'fm')
except Exception as e:
logger.error(f"Audio stream restart failed: {e}")
# Wait for audio to be ready (up to 2 seconds for modulation/squelch changes)
for _ in range(40): for _ in range(40):
if audio_running and audio_process: if audio_running and audio_process:
break break
static/js/modes/listening-post.js
+1 -1
View File
@@ -2121,7 +2121,7 @@ async function _startDirectListenInternal() {
await new Promise(r => setTimeout(r, 300)); await new Promise(r => setTimeout(r, 300));
// Connect to new stream // Connect to new stream
const streamUrl = `/listening/audio/stream?t=${Date.now()}`; const streamUrl = `/listening/audio/stream?fresh=1&t=${Date.now()}`;
console.log('[LISTEN] Connecting to stream:', streamUrl); console.log('[LISTEN] Connecting to stream:', streamUrl);
audioPlayer.src = streamUrl; audioPlayer.src = streamUrl;
audioPlayer.preload = 'auto'; audioPlayer.preload = 'auto';