From b43bd00fc0cc8a53087d54dd21ec57aaaa12c970 Mon Sep 17 00:00:00 2001 From: Mathieu Virbel Date: Thu, 17 Aug 2023 16:49:22 +0200 Subject: [PATCH] server: fixes wav not saved correctly and mp3 generation invalid if started from /tmp from another device --- server/.gitignore | 1 + server/reflector/processors/audio_file_writer.py | 6 +++--- server/reflector/views/transcripts.py | 4 +++- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/server/.gitignore b/server/.gitignore index 7d66d6f0..dbabe979 100644 --- a/server/.gitignore +++ b/server/.gitignore @@ -178,3 +178,4 @@ audio_*.wav # ignore local database reflector.sqlite3 +data/ diff --git a/server/reflector/processors/audio_file_writer.py b/server/reflector/processors/audio_file_writer.py index d67db65e..00ab2529 100644 --- a/server/reflector/processors/audio_file_writer.py +++ b/server/reflector/processors/audio_file_writer.py @@ -26,13 +26,13 @@ class AudioFileWriterProcessor(Processor): self.out_stream = self.out_container.add_stream( "pcm_s16le", rate=data.sample_rate ) - for packet in self.out_stream.encode(data): - self.out_container.mux(packet) + for packet in self.out_stream.encode(data): + self.out_container.mux(packet) await self.emit(data) async def _flush(self): if self.out_container: - for packet in self.out_stream.encode(None): + for packet in self.out_stream.encode(): self.out_container.mux(packet) self.out_container.close() self.out_container = None diff --git a/server/reflector/views/transcripts.py b/server/reflector/views/transcripts.py index 6f952938..beaafb76 100644 --- a/server/reflector/views/transcripts.py +++ b/server/reflector/views/transcripts.py @@ -108,7 +108,9 @@ class Transcript(BaseModel): out.close() # move temporary file to final location - Path(tmp.name).rename(fn) + import shutil + + shutil.move(tmp.name, fn.as_posix()) def unlink(self): self.data_path.unlink(missing_ok=True)