clippy

Author: Rutik7066

golem-embed/embed-cohere/src/client.rs

@@ -7,7 +7,6 @@ use golem_embed::{
 use log::trace;
 use reqwest::{Client, Method, Response};
 use serde::{de::DeserializeOwned, Deserialize, Serialize};
-use serde_json;
 
 const BASE_URL: &str = "https://api.cohere.ai";
 

golem-embed/embed-cohere/src/conversions.rs

@@ -266,7 +266,6 @@ mod tests {
         assert_eq!(request.output_dimension, Some(1024));
     }
 
-
     #[test]
     fn test_embedding_response_conversion() {
         let data = EmbeddingResponse {
@@ -395,7 +394,6 @@ mod tests {
         );
     }
 
-
     #[test]
     fn test_create_rerank_request() {
         let query = "What is AI?".to_string();

golem-embed/embed-hugging-face/src/client.rs

@@ -7,7 +7,6 @@ use golem_embed::{
 use log::trace;
 use reqwest::{Client, Method, Response};
 use serde::{de::DeserializeOwned, Deserialize, Serialize};
-use serde_json;
 
 const BASE_URL: &str = "https://router.huggingface.co/hf-inference";
 
@@ -48,7 +47,6 @@ impl EmbeddingsApi {
             .map_err(|err| from_reqwest_error("Request failed", err))?;
         parse_response::<EmbeddingResponse>(response)
     }
-
 }
 
 fn parse_response<T: DeserializeOwned + Debug>(response: Response) -> Result<T, Error> {

golem-embed/embed-hugging-face/src/conversions.rs

@@ -1,18 +1,22 @@
 use golem_embed::error::unsupported;
 use golem_embed::golem::embed::embed::{
-    Config, ContentPart, EmbeddingResponse as GolemEmbeddingResponse, Error, 
-    RerankResponse as GolemRerankResponse,
+    Config, ContentPart, EmbeddingResponse as GolemEmbeddingResponse, Error,
 };
 
-use crate::client::{EmbeddingRequest, EmbeddingResponse, RerankRequest, RerankResponse};
+use crate::client::{EmbeddingRequest, EmbeddingResponse};
 
-pub fn create_embedding_request(inputs: Vec<ContentPart>, config: Config) -> Result<(EmbeddingRequest, String), Error> {
+pub fn create_embedding_request(
+    inputs: Vec<ContentPart>,
+    config: Config,
+) -> Result<(EmbeddingRequest, String), Error> {
     let mut input_texts = Vec::new();
     for content in inputs {
         match content {
             ContentPart::Text(text) => input_texts.push(text),
             ContentPart::Image(_) => {
-                return Err(unsupported("Image embeddings are not supported by Hugging Face."))
+                return Err(unsupported(
+                    "Image embeddings are not supported by Hugging Face.",
+                ))
             }
         }
     }
@@ -46,7 +50,7 @@ pub fn process_embedding_response(
 
     Ok(GolemEmbeddingResponse {
         embeddings,
-        usage: None, 
+        usage: None,
         model,
         provider_metadata_json: None,
     })
@@ -112,4 +116,4 @@ mod tests {
         let request = create_embedding_request(inputs, config);
         assert!(request.is_err());
     }
-}
+}

golem-embed/embed-hugging-face/src/lib.rs

@@ -2,15 +2,12 @@ mod client;
 mod conversions;
 
 use client::EmbeddingsApi;
-use conversions::{
-    create_embedding_request, create_rerank_request, process_embedding_response, 
-    process_rerank_response,
-};
+use conversions::{create_embedding_request, process_embedding_response};
 use golem_embed::{
     config::with_config_key,
     durability::{DurableEmbed, ExtendedGuest},
     golem::embed::embed::{
-        Config, ContentPart, EmbeddingResponse, Error, Guest, RerankResponse,
+        Config, ContentPart, EmbeddingResponse, Error, ErrorCode, Guest, RerankResponse,
     },
     LOGGING_STATE,
 };
@@ -31,8 +28,6 @@ impl HuggingFaceComponent {
             Err(err) => Err(err),
         }
     }
-
-   
 }
 
 impl Guest for HuggingFaceComponent {
@@ -61,4 +56,4 @@ impl ExtendedGuest for HuggingFaceComponent {}
 
 type DurableHuggingFaceComponent = DurableEmbed<HuggingFaceComponent>;
 
-golem_embed::export_embed!(DurableHuggingFaceComponent with_types_in golem_embed);
+golem_embed::export_embed!(DurableHuggingFaceComponent with_types_in golem_embed);

golem-embed/embed-hugging-face/wit/deps/golem-embed/golem-embed.wit

@@ -124,7 +124,6 @@ interface embed {
   ) -> result<rerank-response, error>;
 }
 
-
 world embed-library {
-    export embed;
+   export embed;
 }

golem-embed/embed-openai/src/client.rs

@@ -11,7 +11,6 @@ use log::trace;
 use reqwest::Client;
 use reqwest::{Method, Response};
 use serde::{de::DeserializeOwned, Deserialize, Serialize};
-use serde_json;
 
 const BASE_URL: &str = "https://api.openai.com";
 

golem-embed/embed-voyageai/src/client.rs

@@ -7,7 +7,6 @@ use golem_embed::{
 use log::trace;
 use reqwest::{Client, Method, Response};
 use serde::{de::DeserializeOwned, Deserialize, Serialize};
-use serde_json;
 
 const BASE_URL: &str = "https://api.voyageai.com";
 
@@ -25,7 +24,10 @@ impl VoyageAIApi {
         let client = Client::builder()
             .build()
             .expect("Failed to initialize HTTP client");
-        Self { voyageai_api_key, client }
+        Self {
+            voyageai_api_key,
+            client,
+        }
     }
 
     pub fn generate_embedding(
@@ -61,7 +63,7 @@ fn parse_response<T: DeserializeOwned + Debug>(response: Response) -> Result<T,
     let response_text = response
         .text()
         .map_err(|err| from_reqwest_error("Failed to read response body", err))?;
-    
+
     if !status.is_success() {
         if let Ok(error_response) = serde_json::from_str::<VoyageAIError>(&response_text) {
             return Err(Error {
@@ -70,7 +72,7 @@ fn parse_response<T: DeserializeOwned + Debug>(response: Response) -> Result<T,
                 provider_error_json: Some(response_text),
             });
         }
-        
+
         if let Ok(detail_error) = serde_json::from_str::<serde_json::Value>(&response_text) {
             if let Some(detail) = detail_error.get("detail").and_then(|d| d.as_str()) {
                 return Err(Error {
@@ -80,14 +82,14 @@ fn parse_response<T: DeserializeOwned + Debug>(response: Response) -> Result<T,
                 });
             }
         }
-        
+
         return Err(Error {
             code: error_code_from_status(status),
             message: format!("Request failed with status {}: {}", status, response_text),
             provider_error_json: Some(response_text),
         });
     }
-    
+
     match serde_json::from_str::<T>(&response_text) {
         Ok(response_data) => {
             trace!("Response from VoyageAI API: {response_data:?}");
@@ -163,7 +165,6 @@ pub struct EmbeddingUsage {
     pub total_tokens: u32,
 }
 
-
 #[derive(Debug, Serialize, Deserialize, Clone)]
 pub struct RerankRequest {
     pub query: String,

golem-embed/embed-voyageai/src/lib.rs

@@ -1,7 +1,8 @@
 use golem_embed::{
     config::with_config_key,
     durability::{DurableEmbed, ExtendedGuest},
-    golem::embed::embed::{Config, ContentPart, EmbeddingResponse, Error, Guest, RerankResponse}, LOGGING_STATE,
+    golem::embed::embed::{Config, ContentPart, EmbeddingResponse, Error, Guest, RerankResponse},
+    LOGGING_STATE,
 };
 
 use crate::{

golem-embed/embed-voyageai/wit/deps/golem-embed/golem-embed.wit

@@ -124,7 +124,6 @@ interface embed {
   ) -> result<rerank-response, error>;
 }
 
-
 world embed-library {
-    export embed;
+   export embed;
 }