lint + test fixes

Author: devdairy699

test/tts/components-rust/test-tts/src/lib.rs

@@ -171,7 +171,7 @@ impl Guest for Component {
             Ok(result) => {
                 trace!("Recived result: {:?}", result.metadata);
                 let dir = "/test-audio-files";
-                let name = "test4-without-options.mp3";
+                let name = "test3-without-options.mp3";
                 let storage_msg = save_audio(&result.audio_data, dir, name);
                 push_result(&mut test_result, result, test_name, format!("{dir}/{name}"));
                 test_result.push_str(&format!("\n{}\n", storage_msg));
@@ -232,7 +232,7 @@ impl Guest for Component {
             Ok(result) => {
                 trace!("Recived result: {:?}", result.metadata);
                 let dir = "/test-audio-files";
-                let name = "test5-ssml.mp3";
+                let name = "test4-ssml.mp3";
                 let storage_msg = save_audio(&result.audio_data, dir, name);
                 push_result(&mut test_result, result, test_name, format!("{dir}/{name}"));
                 test_result.push_str(&format!("\n{}\n", storage_msg));
@@ -303,7 +303,7 @@ impl Guest for Component {
                 for result in batch {
                     trace!("#{index} Recived result: {:?}  ", result.metadata);
                     let dir = "/test-audio-files";
-                    let name = format!("test6-batch-{}.mp3", index);
+                    let name = format!("test5-batch-{}.mp3", index);
                     let storage_msg = save_audio(&result.audio_data, dir, &name);
                     test_result.push_str(&format!("Batch Item #{index}:  "));
                     push_result(&mut test_result, result, test_name, format!("{dir}/{name}"));
@@ -498,7 +498,7 @@ impl Guest for Component {
                 ));
 
                 let dir = "/test-audio-files";
-                let name = "test10-voice-conversion.mp3";
+                let name = "test7-voice-conversion.mp3";
                 let storage_msg = save_audio(&converted_audio, dir, name);
                 test_result.push_str(&format!("💾 Audio saved at {dir}/{name}  "));
                 test_result.push_str(&format!("\n{}\n", storage_msg));
@@ -528,7 +528,7 @@ impl Guest for Component {
                 ));
 
                 let dir = "/test-audio-files";
-                let name = "test10-sound-effect.mp3";
+                let name = "test7-sound-effect.mp3";
                 let storage_msg = save_audio(&sound_effect, dir, name);
                 test_result.push_str(&format!("💾 Audio saved at {dir}/{name}\n"));
                 test_result.push_str(&format!("{}\n", storage_msg));
@@ -560,37 +560,21 @@ impl Guest for Component {
 
         let long_content = format!("{}\n\n{}\n\n{}", TEXT, TEXT, TEXT);
 
-        // For AWS Polly, output_location must be an S3 location (s3://bucket/key)
-        // For other providers, it can be a local path
-        #[cfg(feature = "polly")]
-        let output_location = {
-            match std::env::var("AWS_S3_BUCKET") {
-                Ok(bucket) => format!("s3://{}/test-audio-files/test11-long-form", bucket),
-                Err(_) => {
-                    test_result.push_str(&format!("{test_name} ❌\n"));
-                    test_result.push_str("ERROR : Missing required environment variable AWS_S3_BUCKET for AWS Polly long-form synthesis\n");
-                    return test_result;
-                }
-            }
-        };
-
-        #[cfg(not(feature = "polly"))]
-        let output_location = "/test-audio-files/test11-long-form.mp3";
-
         let chapter_breaks = [0, TEXT.len() as u32, (TEXT.len() * 2) as u32];
 
-        match synthesize_long_form(
-            &long_content,
-            &voice,
-            &output_location,
-            Some(&chapter_breaks),
-        ) {
+        match synthesize_long_form(&long_content, &voice, Some(&chapter_breaks)) {
             Ok(operation) => {
                 // Monitor the operation progress
                 let mut attempts = 0;
                 let max_attempts = 30;
 
                 while attempts < max_attempts {
+                    if attempts == 3 {
+                        // Simulate crash
+                        let agent_name = std::env::var("GOLEM_WORKER_NAME").unwrap();
+                        mimic_crash(&agent_name);
+                    }
+
                     let status = operation.get_status();
                     let progress: f32 = operation.get_progress();
                     trace!(
@@ -740,13 +724,6 @@ impl Guest for Component {
 
     // Test pronunciation lexicons
     fn test9() -> String {
-        let voice = match get_voice(VOICE_UUID) {
-            Ok(voices) => voices,
-            Err(err) => {
-                return format!("❌ ERROR : {:?}", err);
-            }
-        };
-
         let mut test_result = String::new();
         test_result.push_str("Test pronunciation lexicons summary:\n");
 
@@ -805,6 +782,10 @@ impl Guest for Component {
         trace!("Exporting lexicon content...");
         let test3_name = "3. Test export lexicon";
 
+        // Simulate crash
+        let agent_name = std::env::var("GOLEM_WORKER_NAME").unwrap();
+        mimic_crash(&agent_name);
+
         match lexicon.export_content() {
             Ok(content) => {
                 trace!(

test/tts/wit/deps/golem-tts/golem-tts.wit

@@ -364,7 +364,6 @@ interface advanced {
     synthesize-long-form: func(
         content: string,
         voice: voice,
-        output-location: string,
         chapter-breaks: option<list<u32>>
     ) -> result<long-form-operation, tts-error>;
 

tts/deepgram/src/bindings.rs

@@ -1,9 +1,9 @@
 // Generated by `wit-bindgen` 0.41.0. DO NOT EDIT!
 // Options used:
 //   * runtime_path: "wit_bindgen_rt"
-//   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::types"
 //   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::synthesis"
 //   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::advanced"
+//   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::types"
 //   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::voices"
 //   * generate_unused_types
 use golem_tts::golem::tts::types as __with_name0;
@@ -16,8 +16,8 @@ use golem_tts::golem::tts::advanced as __with_name3;
 )]
 #[doc(hidden)]
 #[allow(clippy::octal_escapes)]
-pub static __WIT_BINDGEN_COMPONENT_TYPE: [u8; 4808] = *b"\
-\0asm\x0d\0\x01\0\0\x19\x16wit-component-encoding\x04\0\x07\xc6$\x01A\x02\x01A\x13\
+pub static __WIT_BINDGEN_COMPONENT_TYPE: [u8; 4791] = *b"\
+\0asm\x0d\0\x01\0\0\x19\x16wit-component-encoding\x04\0\x07\xb5$\x01A\x02\x01A\x13\
 \x01B&\x01m\x04\x0acharacters\x08requests\x07seconds\x07credits\x04\0\x0aquota-u\
 nit\x03\0\0\x01r\x04\x04usedy\x05limity\x0areset-timew\x04unit\x01\x04\0\x0aquot\
 a-info\x03\0\x02\x01q\x15\x0drequest-error\x01s\0\x0cinvalid-text\x01s\0\x0dtext\
@@ -110,11 +110,11 @@ arget-voice\x0b\x0fpreserve-timing3\04\x04\0\x0dconvert-voice\x015\x01kv\x01@\x0
 \x0bdescriptions\x10duration-seconds6\x0fstyle-influence6\04\x04\0\x15generate-s\
 ound-effect\x017\x01p\x18\x01k8\x01i\x16\x01j\x01:\x01\x01\x01@\x03\x04names\x08\
 language\x05\x07entries9\0;\x04\0\x0ecreate-lexicon\x01<\x01py\x01k=\x01i\x19\x01\
-j\x01?\x01\x01\x01@\x04\x07contents\x05voice\x0b\x0foutput-locations\x0echapter-\
-breaks>\0\xc0\0\x04\0\x14synthesize-long-form\x01A\x04\0\x18golem:tts/advanced@1\
-.0.0\x05\x0e\x04\0$golem:tts-deepgram/[email protected]\x04\0\x0b\x11\x01\0\x0bt\
-ts-library\x03\0\0\0G\x09producers\x01\x0cprocessed-by\x02\x0dwit-component\x070\
-.227.1\x10wit-bindgen-rust\x060.41.0";
+j\x01?\x01\x01\x01@\x03\x07contents\x05voice\x0b\x0echapter-breaks>\0\xc0\0\x04\0\
+\x14synthesize-long-form\x01A\x04\0\x18golem:tts/advanced@1.0.0\x05\x0e\x04\0$go\
+lem:tts-deepgram/[email protected]\x04\0\x0b\x11\x01\0\x0btts-library\x03\0\0\0G\
+\x09producers\x01\x0cprocessed-by\x02\x0dwit-component\x070.227.1\x10wit-bindgen\
+-rust\x060.41.0";
 #[inline(never)]
 #[doc(hidden)]
 pub fn __link_custom_section_describing_imports() {

tts/deepgram/src/deepgram.rs

@@ -2,10 +2,7 @@ use golem_tts::{
     client::{ApiClient, TtsClient},
     config::get_env,
     golem::tts::{
-        advanced::{
-            AudioSample, LanguageCode, PronunciationEntry, PronunciationLexicon, Voice,
-            VoiceDesignParams,
-        },
+        advanced::{AudioSample, LanguageCode, PronunciationEntry, Voice, VoiceDesignParams},
         synthesis::{SynthesisOptions, TextInput, TimingInfo, ValidationResult},
         types::{SynthesisMetadata, SynthesisResult, TextType, TtsError, VoiceGender},
         voices::{LanguageInfo, VoiceFilter},
@@ -17,10 +14,7 @@ use serde::{Deserialize, Serialize};
 
 use crate::{
     error::{from_http_error, unsupported},
-    resources::{
-        DeepgramLongFormOperation, DeepgramPronunciationLexicon,
-        VoiceResponse,
-    },
+    resources::{DeepgramLongFormOperation, DeepgramPronunciationLexicon, VoiceResponse},
     utils::estimate_duration,
 };
 
@@ -62,7 +56,7 @@ impl TtsClient for Deepgram {
             .map(|ac| ac.format.clone());
 
         // Deepgram doesn't allow sample_rate with MP3 encoding
-        let sample_rate = if encoding.as_ref().map(|e| e.as_str()) == Some("mp3") {
+        let sample_rate = if encoding.as_deref() == Some("mp3") {
             None
         } else {
             options
@@ -359,7 +353,6 @@ impl TtsClient for Deepgram {
         &self,
         _content: String,
         _voice: String,
-        _output_location: String,
         _chapter_breaks: Option<Vec<u32>>,
     ) -> Result<Self::ClientLongFormOperation, TtsError> {
         unsupported("Deepgram does not  supported Async synthesis.")

tts/deepgram/src/lib.rs

@@ -6,7 +6,10 @@ use golem_tts::{
             AudioSample, Guest as AdvancedGuest, LanguageCode, LongFormOperation,
             PronunciationEntry, PronunciationLexicon, TtsError, Voice, VoiceDesignParams,
         },
-        synthesis::{Guest as SynthesisGuest, SynthesisOptions, SynthesisResult, TextInput, TimingInfo, ValidationResult},
+        synthesis::{
+            Guest as SynthesisGuest, SynthesisOptions, SynthesisResult, TextInput, TimingInfo,
+            ValidationResult,
+        },
         voices::{Guest as VoicesGuest, LanguageInfo, VoiceFilter},
     },
 };
@@ -120,13 +123,15 @@ impl AdvancedGuest for DeepgramComponent {
     fn synthesize_long_form(
         content: String,
         voice: Voice,
-        output_location: String,
         chapter_breaks: Option<Vec<u32>>,
     ) -> Result<LongFormOperation, TtsError> {
         let deepgram = Deepgram::new()?;
         let voice_canonical_name = voice.name.clone(); // Use canonical name
-        let operation =
-            deepgram.synthesize_long_form(content, voice_canonical_name, output_location, chapter_breaks)?;
+        let operation = deepgram.synthesize_long_form(
+            content,
+            voice_canonical_name,
+            chapter_breaks,
+        )?;
         Ok(LongFormOperation::new(operation))
     }
 }
@@ -157,25 +162,25 @@ impl ExtendedAdvancedTrait for DeepgramComponent {
         language: LanguageCode,
         entries: Option<Vec<PronunciationEntry>>,
     ) -> Result<Self::PronunciationLexicon, golem_tts::golem::tts::types::TtsError> {
-        let client  = Deepgram::new()?;
+        let client = Deepgram::new()?;
         client.create_lexicon(name, language, entries)
     }
 
     fn unwrappered_synthesize_long_form(
         content: String,
         voice: Voice,
-        output_location: String,
         chapter_breaks: Option<Vec<u32>>,
     ) -> Result<Self::LongFormOperation, golem_tts::golem::tts::types::TtsError> {
         let client = Deepgram::new()?;
         let voice_canonical_name = voice.name.clone(); // Use canonical name
-        client.synthesize_long_form(content, voice_canonical_name, output_location, chapter_breaks)
+        client.synthesize_long_form(
+            content,
+            voice_canonical_name,
+            chapter_breaks,
+        )
     }
 }
 
-
-
-
 type DurableDeepgramComponent = DurableTTS<DeepgramComponent>;
 
 golem_tts::export_tts!(DurableDeepgramComponent with_types_in golem_tts);

tts/deepgram/src/resources.rs

@@ -1,8 +1,8 @@
+use golem_rust::{FromValueAndType, IntoValue};
 use golem_tts::golem::tts::advanced::{
-    GuestLongFormOperation, GuestPronunciationLexicon, LanguageCode, LongFormResult, OperationStatus,
-    TtsError, Voice,
+    GuestLongFormOperation, GuestPronunciationLexicon, LanguageCode, LongFormResult,
+    OperationStatus, TtsError,
 };
-use golem_rust::{FromValueAndType, IntoValue};
 use serde::{Deserialize, Serialize};
 
 use crate::error::unsupported;
@@ -31,8 +31,6 @@ pub struct DeepgramVoiceMetadata {
     pub use_cases: Vec<String>,
 }
 
-
-
 pub struct DeepgramPronunciationLexicon;
 
 impl GuestPronunciationLexicon for DeepgramPronunciationLexicon {

tts/deepgram/src/utils.rs

@@ -1,4 +1,4 @@
-use golem_tts::golem::tts::{types::VoiceGender, voices::Voice, };
+use golem_tts::golem::tts::{types::VoiceGender, voices::Voice};
 
 use crate::resources::VoiceResponse;
 
@@ -26,7 +26,7 @@ impl From<&VoiceResponse> for Voice {
         }
 
         Voice {
-            id: v.uuid.clone(), // Keep UUID for get_voice API
+            id: v.uuid.clone(),             // Keep UUID for get_voice API
             name: v.canonical_name.clone(), // Use canonical_name for synthesis
             language: v.languages[0].clone(),
             additional_languages: v.languages.clone(),

tts/deepgram/wit/deps/golem-tts/golem-tts.wit

@@ -364,7 +364,6 @@ interface advanced {
     synthesize-long-form: func(
         content: string,
         voice: voice,
-        output-location: string,
         chapter-breaks: option<list<u32>>
     ) -> result<long-form-operation, tts-error>;
 

tts/elevenlabs/src/bindings.rs

@@ -1,10 +1,10 @@
 // Generated by `wit-bindgen` 0.41.0. DO NOT EDIT!
 // Options used:
 //   * runtime_path: "wit_bindgen_rt"
-//   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::synthesis"
-//   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::advanced"
 //   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::types"
 //   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::voices"
+//   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::advanced"
+//   * with "golem:tts/[email protected]" = "golem_tts::golem::tts::synthesis"
 //   * generate_unused_types
 use golem_tts::golem::tts::types as __with_name0;
 use golem_tts::golem::tts::voices as __with_name1;
@@ -16,8 +16,8 @@ use golem_tts::golem::tts::advanced as __with_name3;
 )]
 #[doc(hidden)]
 #[allow(clippy::octal_escapes)]
-pub static __WIT_BINDGEN_COMPONENT_TYPE: [u8; 4810] = *b"\
-\0asm\x0d\0\x01\0\0\x19\x16wit-component-encoding\x04\0\x07\xc8$\x01A\x02\x01A\x13\
+pub static __WIT_BINDGEN_COMPONENT_TYPE: [u8; 4793] = *b"\
+\0asm\x0d\0\x01\0\0\x19\x16wit-component-encoding\x04\0\x07\xb7$\x01A\x02\x01A\x13\
 \x01B&\x01m\x04\x0acharacters\x08requests\x07seconds\x07credits\x04\0\x0aquota-u\
 nit\x03\0\0\x01r\x04\x04usedy\x05limity\x0areset-timew\x04unit\x01\x04\0\x0aquot\
 a-info\x03\0\x02\x01q\x15\x0drequest-error\x01s\0\x0cinvalid-text\x01s\0\x0dtext\
@@ -110,11 +110,11 @@ arget-voice\x0b\x0fpreserve-timing3\04\x04\0\x0dconvert-voice\x015\x01kv\x01@\x0
 \x0bdescriptions\x10duration-seconds6\x0fstyle-influence6\04\x04\0\x15generate-s\
 ound-effect\x017\x01p\x18\x01k8\x01i\x16\x01j\x01:\x01\x01\x01@\x03\x04names\x08\
 language\x05\x07entries9\0;\x04\0\x0ecreate-lexicon\x01<\x01py\x01k=\x01i\x19\x01\
-j\x01?\x01\x01\x01@\x04\x07contents\x05voice\x0b\x0foutput-locations\x0echapter-\
-breaks>\0\xc0\0\x04\0\x14synthesize-long-form\x01A\x04\0\x18golem:tts/advanced@1\
-.0.0\x05\x0e\x04\0&golem:tts-elevenlabs/[email protected]\x04\0\x0b\x11\x01\0\x0b\
-tts-library\x03\0\0\0G\x09producers\x01\x0cprocessed-by\x02\x0dwit-component\x07\
-0.227.1\x10wit-bindgen-rust\x060.41.0";
+j\x01?\x01\x01\x01@\x03\x07contents\x05voice\x0b\x0echapter-breaks>\0\xc0\0\x04\0\
+\x14synthesize-long-form\x01A\x04\0\x18golem:tts/advanced@1.0.0\x05\x0e\x04\0&go\
+lem:tts-elevenlabs/[email protected]\x04\0\x0b\x11\x01\0\x0btts-library\x03\0\0\0\
+G\x09producers\x01\x0cprocessed-by\x02\x0dwit-component\x070.227.1\x10wit-bindge\
+n-rust\x060.41.0";
 #[inline(never)]
 #[doc(hidden)]
 pub fn __link_custom_section_describing_imports() {

tts/elevenlabs/src/elevenlabs.rs

@@ -5,8 +5,7 @@ use golem_tts::{
     config::get_env,
     golem::tts::{
         advanced::{
-            AgeCategory, AudioSample, LanguageCode, PronunciationEntry, PronunciationLexicon,
-            Voice, VoiceDesignParams,
+            AgeCategory, AudioSample, LanguageCode, PronunciationEntry, Voice, VoiceDesignParams,
         },
         synthesis::{SynthesisOptions, SynthesisResult, TextInput, TimingInfo, ValidationResult},
         types::{SynthesisMetadata, TextType, TtsError, VoiceGender},
@@ -35,10 +34,7 @@ pub struct Elevenlabs {
     base_url: String,
 }
 
-
-
 impl TtsClient for Elevenlabs {
-  
     type ClientLongFormOperation = ElLongFormSynthesis;
     type ClientPronunciationLexicon = ElPronunciationLexicon;
 
@@ -847,7 +843,6 @@ impl TtsClient for Elevenlabs {
         &self,
         _content: String,
         _voice: String,
-        _output_location: String,
         _chapter_breaks: Option<Vec<u32>>,
     ) -> Result<ElLongFormSynthesis, TtsError> {
         unsupported("Long-form synthesis not yet implemented for ElevenLabs TTS")