Merge pull request #50 from pragmatrix/remove-stream-timeouts

Remove Azure Translate stream timeouts

Author: pragmatrix

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "context-switch"
-version = "1.1.0"
+version = "1.1.1"
 edition = "2024"
 rust-version = "1.88"
 

audio-knife/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "audio-knife"
-version = "1.4.0"
+version = "1.4.1"
 edition = "2024"
 
 [profile.dev]

audio-knife/src/app_error.rs

@@ -5,6 +5,7 @@ use axum::{
     response::{IntoResponse, Response},
 };
 
+#[allow(unused)]
 pub struct AppError(anyhow::Error);
 
 // Tell axum how to convert `AppError` into a response.

external/azure-speech-sdk-rs

@@ -41,12 +41,12 @@ impl Service for AzureTranslate {
             sample_rate: 16000,
         };
 
-        if let Some(audio_format) = output_modalities.audio {
-            if audio_format != AUDIO_OUTPUT_FORMAT {
-                bail!(
-                    "Only {AUDIO_OUTPUT_FORMAT:?} is supported, but output modalities contains {audio_format:?}"
-                );
-            }
+        if let Some(audio_format) = output_modalities.audio
+            && audio_format != AUDIO_OUTPUT_FORMAT
+        {
+            bail!(
+                "Only {AUDIO_OUTPUT_FORMAT:?} is supported, but output modalities contains {audio_format:?}"
+            );
         }
 
         // Host / Auth is lightweight, so we can create this every time.

services/azure/src/translate.rs

@@ -31,17 +31,16 @@ impl io::Read for StreamReader {
         }
 
         // If we have a current chunk with remaining data, use it
-        if let Some(ref chunk) = self.current_chunk {
-            if self.chunk_offset < chunk.len() {
-                let remaining_in_chunk = chunk.len() - self.chunk_offset;
-                let to_copy = std::cmp::min(buf.len(), remaining_in_chunk);
+        if let Some(ref chunk) = self.current_chunk
+            && self.chunk_offset < chunk.len()
+        {
+            let remaining_in_chunk = chunk.len() - self.chunk_offset;
+            let to_copy = std::cmp::min(buf.len(), remaining_in_chunk);
 
-                buf[..to_copy]
-                    .copy_from_slice(&chunk[self.chunk_offset..self.chunk_offset + to_copy]);
-                self.chunk_offset += to_copy;
+            buf[..to_copy].copy_from_slice(&chunk[self.chunk_offset..self.chunk_offset + to_copy]);
+            self.chunk_offset += to_copy;
 
-                return Ok(to_copy);
-            }
+            return Ok(to_copy);
         }
 
         // Need to get the next chunk from the stream