Compare commits

..

3 Commits

Author SHA1 Message Date
Tanner 6ad5dd9de3 Adjust README 2026-07-28 17:40:53 -06:00
Tanner df8a33f456 docs: add README.md with project overview and usage instructions
Co-authored-by: aider (gemini/gemini-3.1-pro-preview) <aider@aider.chat>
2026-07-28 17:40:53 -06:00
Tanner 1fffff87dd docs: add README.md 2026-07-28 17:40:53 -06:00
+1 -44
View File
@@ -26,18 +26,6 @@ def playback_thread(file_path, state):
stream = container.streams.audio[0] stream = container.streams.audio[0]
resampler = av.AudioResampler(format='s16', layout='stereo', rate=48000) resampler = av.AudioResampler(format='s16', layout='stereo', rate=48000)
def build_graph(template_frame):
graph = av.filter.Graph()
src = graph.add_abuffer(template=template_frame)
loudnorm = graph.add("loudnorm", "I=-16:TP=-1.5:LRA=11")
sink = graph.add("abuffersink")
src.link_to(loudnorm)
loudnorm.link_to(sink)
graph.configure()
return graph
graph = None
with open(fifo_path, 'wb') as fifo: with open(fifo_path, 'wb') as fifo:
iterator = container.decode(stream) iterator = container.decode(stream)
while state.running: while state.running:
@@ -53,7 +41,6 @@ def playback_thread(file_path, state):
with state.lock: with state.lock:
state.seek_request = None state.seek_request = None
iterator = container.decode(stream) iterator = container.decode(stream)
graph = None # Reset filter graph on seek
continue continue
if paused: if paused:
@@ -70,30 +57,7 @@ def playback_thread(file_path, state):
with state.lock: with state.lock:
state.time_pos = float(frame.pts * stream.time_base) state.time_pos = float(frame.pts * stream.time_base)
if graph is None: resampled_frames = resampler.resample(frame)
try:
graph = build_graph(frame)
except Exception as e:
print(f"Filter graph error: {e}", file=sys.stderr)
graph = "FAILED"
if graph == "FAILED":
frames_to_process = [frame]
else:
try:
graph.push(frame)
except av.AVError:
continue
frames_to_process = []
while True:
try:
frames_to_process.append(graph.pull())
except (av.AVError, BlockingIOError):
break
for filtered_frame in frames_to_process:
resampled_frames = resampler.resample(filtered_frame)
for r_frame in resampled_frames: for r_frame in resampled_frames:
arr = r_frame.to_ndarray() arr = r_frame.to_ndarray()
@@ -103,11 +67,7 @@ def playback_thread(file_path, state):
arr = arr.astype(np.float32) * multiplier arr = arr.astype(np.float32) * multiplier
arr = np.clip(arr, -32768, 32767).astype(np.int16) arr = np.clip(arr, -32768, 32767).astype(np.int16)
try:
fifo.write(arr.tobytes()) fifo.write(arr.tobytes())
except BrokenPipeError:
state.running = False
return
def handle_ipc_client(conn, state): def handle_ipc_client(conn, state):
buffer = "" buffer = ""
@@ -208,9 +168,6 @@ def main():
try: try:
playback_thread(args.file, state) playback_thread(args.file, state)
# Keep the main thread alive until Navidrome explicitly sends 'quit'
while state.running:
time.sleep(0.1)
except KeyboardInterrupt: except KeyboardInterrupt:
pass pass
finally: finally: