lint

Author: devdairy699

Cargo.toml

@@ -3,44 +3,44 @@ resolver = "2"
 
 members = [
     "llm/llm",
-    # "llm/bedrock",
-    # "llm/anthropic",
-    # "llm/grok",
-    # "llm/ollama",
-    # "llm/openai",
-    # "llm/openrouter",
-    # "embed/embed",
-    # "embed/cohere",
-    # "embed/hugging-face",
-    # "embed/openai",
-    # "embed/voyageai",
-    # "websearch/websearch",
-    # "websearch/brave",
-    # "websearch/google",
-    # "websearch/serper",
-    # "websearch/tavily",
-    # "search/search",
-    # "search/elasticsearch",
-    # "search/algolia",
-    # "search/meilisearch",
-    # "search/opensearch",
-    # "search/typesense",
-    # "graph/graph",
-    # "graph/arangodb",
-    # "graph/janusgraph",
-    # "graph/neo4j",
-    # "video/video",
-    # "video/kling",
-    # "video/runway",
-    # "video/veo",
-    # "video/stability",
-    # "exec/exec",
-    # "stt/stt",
-    # "stt/whisper",
-    # "stt/deepgram",
-    # "stt/aws",
-    # "stt/azure",
-    # "stt/google",
+    "llm/bedrock",
+    "llm/anthropic",
+    "llm/grok",
+    "llm/ollama",
+    "llm/openai",
+    "llm/openrouter",
+    "embed/embed",
+    "embed/cohere",
+    "embed/hugging-face",
+    "embed/openai",
+    "embed/voyageai",
+    "websearch/websearch",
+    "websearch/brave",
+    "websearch/google",
+    "websearch/serper",
+    "websearch/tavily",
+    "search/search",
+    "search/elasticsearch",
+    "search/algolia",
+    "search/meilisearch",
+    "search/opensearch",
+    "search/typesense",
+    "graph/graph",
+    "graph/arangodb",
+    "graph/janusgraph",
+    "graph/neo4j",
+    "video/video",
+    "video/kling",
+    "video/runway",
+    "video/veo",
+    "video/stability",
+    "exec/exec",
+    "stt/stt",
+    "stt/whisper",
+    "stt/deepgram",
+    "stt/aws",
+    "stt/azure",
+    "stt/google",
     "tts/tts",
     "tts/elevenlabs",
     "tts/polly",

tts/deepgram/src/lib.rs

@@ -127,11 +127,8 @@ impl AdvancedGuest for DeepgramComponent {
     ) -> 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,
-            chapter_breaks,
-        )?;
+        let operation =
+            deepgram.synthesize_long_form(content, voice_canonical_name, chapter_breaks)?;
         Ok(LongFormOperation::new(operation))
     }
 }
@@ -174,13 +171,8 @@ impl ExtendedAdvancedTrait for DeepgramComponent {
     ) -> 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,
-            chapter_breaks,
-        )
+        client.synthesize_long_form(content, voice_canonical_name, chapter_breaks)
     }
-  
 }
 
 type DurableDeepgramComponent = DurableTTS<DeepgramComponent>;

tts/google/src/lib.rs

@@ -143,8 +143,7 @@ impl AdvancedGuest for GoogleTtsComponent {
     ) -> Result<LongFormOperation, TtsError> {
         let google = Google::new()?;
         let voice_name = voice.id.clone();
-        let operation =
-            google.synthesize_long_form(content, voice_name, chapter_breaks)?;
+        let operation = google.synthesize_long_form(content, voice_name, chapter_breaks)?;
         Ok(LongFormOperation::new(operation))
     }
 }

tts/polly/src/aws_signer.rs

@@ -63,10 +63,11 @@ impl PollySigner {
         let date_stamp = timestamp.format("%Y%m%d").to_string();
         let amz_date = timestamp.format("%Y%m%dT%H%M%SZ").to_string();
 
-        parts
-            .headers
-            .insert("x-amz-date", HeaderValue::from_str(&amz_date)
-                .map_err(|e| TtsError::InternalError(format!("Invalid header value: {}", e)))?);
+        parts.headers.insert(
+            "x-amz-date",
+            HeaderValue::from_str(&amz_date)
+                .map_err(|e| TtsError::InternalError(format!("Invalid header value: {}", e)))?,
+        );
 
         let content_sha256 = self.hash_payload(body.as_ref());
         parts.headers.insert(
@@ -91,8 +92,12 @@ impl PollySigner {
                     host.to_string()
                 };
 
-                headers_for_signing.insert("host", HeaderValue::from_str(&host_header)
-                    .map_err(|e| TtsError::InternalError(format!("Invalid header value: {}", e)))?);
+                headers_for_signing.insert(
+                    "host",
+                    HeaderValue::from_str(&host_header).map_err(|e| {
+                        TtsError::InternalError(format!("Invalid header value: {}", e))
+                    })?,
+                );
             }
         }
 
@@ -116,10 +121,11 @@ impl PollySigner {
             "AWS4-HMAC-SHA256 Credential={credential}, SignedHeaders={signed_headers}, Signature={signature}"
         );
 
-        parts
-            .headers
-            .insert("authorization", HeaderValue::from_str(&authorization)
-                .map_err(|e| TtsError::InternalError(format!("Invalid header value: {}", e)))?);
+        parts.headers.insert(
+            "authorization",
+            HeaderValue::from_str(&authorization)
+                .map_err(|e| TtsError::InternalError(format!("Invalid header value: {}", e)))?,
+        );
 
         Ok(Request::from_parts(parts, body))
     }
@@ -253,7 +259,11 @@ impl PollySigner {
         string_to_sign
     }
 
-    fn calculate_signature(&self, string_to_sign: &str, date_stamp: &str) -> Result<String, TtsError> {
+    fn calculate_signature(
+        &self,
+        string_to_sign: &str,
+        date_stamp: &str,
+    ) -> Result<String, TtsError> {
         let secret = format!("AWS4{}", self.secret_key);
 
         let mut mac = HmacSha256::new_from_slice(secret.as_bytes())

tts/polly/src/polly.rs

@@ -75,7 +75,7 @@ impl TtsClient for Polly {
             region,
             base_url,
             signer,
-            bucket: bucket,
+            bucket,
         })
     }
 

tts/polly/src/resources.rs

@@ -166,12 +166,12 @@ impl From<String> for AwsLongFormOperation {
             SynthesisTask {
                 task_id: value,
                 creation_time: 0.0,
-                engine:String::new(),
-                output_format:String::new(),
-                task_status:String::new(),
-                task_status_reason:None,
+                engine: String::new(),
+                output_format: String::new(),
+                task_status: String::new(),
+                task_status_reason: None,
                 output_uri: None,
-                request_characters:0,
+                request_characters: 0,
                 voice_id: String::new(),
             },
             "".to_string(),

tts/tts/src/durability/advanced.rs

@@ -90,11 +90,14 @@ mod durability_impl {
 
     use crate::{
         durability::{DurableTTS, ExtendedAdvancedTrait},
-        golem::tts::{advanced::{
-            AudioSample, Guest, GuestLongFormOperation, GuestPronunciationLexicon, LanguageCode,
-            LongFormOperation, LongFormResult, OperationStatus, PronunciationEntry,
-            PronunciationLexicon, TtsError, Voice, VoiceDesignParams,
-        }, types::SynthesisMetadata},
+        golem::tts::{
+            advanced::{
+                AudioSample, Guest, GuestLongFormOperation, GuestPronunciationLexicon,
+                LanguageCode, LongFormOperation, LongFormResult, OperationStatus,
+                PronunciationEntry, PronunciationLexicon, TtsError, Voice, VoiceDesignParams,
+            },
+            types::SynthesisMetadata,
+        },
         init_logging,
     };
 
@@ -363,6 +366,7 @@ mod durability_impl {
         }
     }
 
+    #[allow(clippy::large_enum_variant)]
     enum DurableLongFormOperationState<Impl: Guest> {
         Live {
             operation: Impl::LongFormOperation,
@@ -491,7 +495,7 @@ mod durability_impl {
                                 Some(task_id.clone()),
                             )?;
 
-                            (status.clone(), Some(new_longform_synthesis))
+                            (*status, Some(new_longform_synthesis))
                         }
                         _ => unreachable!(),
                     }
@@ -505,14 +509,14 @@ mod durability_impl {
                     });
                 }
 
-                let _ = durability.persist_infallible(NoInput, status.clone());
+                let _ = durability.persist_infallible(NoInput, status);
                 Ok(status)
             } else {
                 let replay: OperationStatus = durability.replay_infallible();
                 let mut state = self.state.borrow_mut();
                 match &mut *state {
                     Some(DurableLongFormOperationState::Replay { status, .. }) => {
-                        *status = replay.clone();
+                        *status = replay;
                     }
                     _ => {
                         unreachable!()
@@ -553,7 +557,7 @@ mod durability_impl {
                                 Some(task_id.clone()),
                             )?;
 
-                            (progress.clone(), Some(new_longform_synthesis))
+                            (*progress, Some(new_longform_synthesis))
                         }
                         _ => unreachable!(),
                     }
@@ -837,24 +841,25 @@ mod durability_impl {
             );
             init_logging();
             if durability.is_live() {
-                let longform_operation = with_persistence_level(PersistenceLevel::PersistNothing, || {
-                    Impl::unwrappered_synthesize_long_form(
-                        content.clone(),
-                        voice.clone(),
-                        chapter_breaks.clone(),
-                        None,
-                    )
-                })?;
+                let longform_operation =
+                    with_persistence_level(PersistenceLevel::PersistNothing, || {
+                        Impl::unwrappered_synthesize_long_form(
+                            content.clone(),
+                            voice.clone(),
+                            chapter_breaks.clone(),
+                            None,
+                        )
+                    })?;
 
                 let task_id = with_persistence_level(PersistenceLevel::PersistNothing, || {
                     longform_operation.get_task_id()
                 })?;
 
                 let _ = durability.persist_infallible(NoInput, task_id.clone());
 
-                Ok(LongFormOperation::new(DurableLongFormOperation::<Impl>::live(
-                    longform_operation,
-                )))
+                Ok(LongFormOperation::new(
+                    DurableLongFormOperation::<Impl>::live(longform_operation),
+                ))
             } else {
                 let task_id: String = durability.replay_infallible();
 

tts/tts/src/durability/mod.rs

@@ -33,7 +33,7 @@ pub trait ExtendedAdvancedTrait: AdvancedTrait + 'static {
         content: String,
         voice: Voice,
         chapter_breaks: Option<Vec<u32>>,
-        task_id:Option<String>,
+        task_id: Option<String>,
     ) -> Result<Self::LongFormOperation, TtsError>;
 }