chore(lints): fix lints and formatting

Author: Snapstromegon

src/client.rs

@@ -39,7 +39,7 @@ use url::Url;
 pub struct Client {
     base_url: Url,
     api_token: String,
-    client: reqwest::Client,
+    reqwest: reqwest::Client,
 }
 
 impl Client {
@@ -48,7 +48,7 @@ impl Client {
         Client {
             base_url,
             api_token: api_token.into(),
-            client: reqwest::Client::new(),
+            reqwest: reqwest::Client::new(),
         }
     }
 
@@ -94,8 +94,8 @@ impl Client {
             .map_err(ClientError::URLParseError)?;
 
         let request = match endpoint.method() {
-            reqwest::Method::GET => self.client.get(url),
-            reqwest::Method::POST => self.client.post(url),
+            reqwest::Method::GET => self.reqwest.get(url),
+            reqwest::Method::POST => self.reqwest.post(url),
             _ => return Err(ClientError::InvalidRequestMethod),
         }
         .header("Authorization", format!("Bearer {}", self.api_token));
@@ -311,7 +311,7 @@ impl Client {
     /// }
     /// # })
     /// ```
-    /// 
+    ///
     /// # Errors
     /// This function will return an error if the request fails or if the URL is invalid.
     pub async fn list_event_types(

src/client/client_request.rs

@@ -67,12 +67,9 @@ pub trait StreamingRequest: ClientRequest {
     fn lines_stream(
         response: reqwest::Response,
     ) -> impl Stream<Item = Result<String, ClientError>> {
-        let bytes = response.bytes_stream().map_err(|err| {
-            io::Error::new(
-                io::ErrorKind::Other,
-                format!("Failed to read response stream: {err}"),
-            )
-        });
+        let bytes = response
+            .bytes_stream()
+            .map_err(|err| io::Error::other(format!("Failed to read response stream: {err}")));
         let stream_reader = StreamReader::new(bytes);
         LinesStream::new(BufReader::new(stream_reader).lines()).map_err(ClientError::from)
     }

src/client/client_request/list_subjects.rs

@@ -12,15 +12,15 @@ pub struct ListSubjectsRequest<'a> {
     pub base_subject: &'a str,
 }
 
-impl<'a> ClientRequest for ListSubjectsRequest<'a> {
+impl ClientRequest for ListSubjectsRequest<'_> {
     const URL_PATH: &'static str = "/api/v1/read-subjects";
     const METHOD: Method = Method::POST;
 
     fn body(&self) -> Option<Result<impl Serialize, ClientError>> {
         Some(Ok(self))
     }
 }
-impl<'a> StreamingRequest for ListSubjectsRequest<'a> {
+impl StreamingRequest for ListSubjectsRequest<'_> {
     type ItemType = String;
 
     fn build_stream(

src/client/client_request/register_event_schema.rs

@@ -23,15 +23,15 @@ impl<'a> RegisterEventSchemaRequest<'a> {
     }
 }
 
-impl<'a> ClientRequest for RegisterEventSchemaRequest<'a> {
+impl ClientRequest for RegisterEventSchemaRequest<'_> {
     const URL_PATH: &'static str = "/api/v1/register-event-schema";
     const METHOD: Method = Method::POST;
 
     fn body(&self) -> Option<Result<impl Serialize, ClientError>> {
         Some(Ok(self))
     }
 }
-impl<'a> OneShotRequest for RegisterEventSchemaRequest<'a> {
+impl OneShotRequest for RegisterEventSchemaRequest<'_> {
     type Response = ManagementEvent;
 
     fn validate_response(&self, response: &Self::Response) -> Result<(), ClientError> {

src/container.rs

@@ -114,7 +114,7 @@ impl ContainerBuilder {
         Ok(Container {
             internal_port: self.internal_port,
             api_token: self.api_token.clone(),
-            container: GenericImage::new(self.image_name, self.image_tag)
+            instance: GenericImage::new(self.image_name, self.image_tag)
                 .with_exposed_port(self.internal_port)
                 .with_wait_for(WaitFor::Http(Box::new(
                     HttpWaitStrategy::new("/api/v1/ping")
@@ -152,7 +152,7 @@ impl ContainerBuilder {
 /// ```
 #[derive(Debug)]
 pub struct Container {
-    container: ContainerAsync<GenericImage>,
+    instance: ContainerAsync<GenericImage>,
     internal_port: ContainerPort,
     api_token: String,
 }
@@ -184,7 +184,7 @@ impl Container {
     /// # Errors
     /// This function will return an error if the container is not running (e.g. because it crashed) or if the host could not be retrieved
     pub async fn get_host(&self) -> Result<Host, ContainerError> {
-        Ok(self.container.get_host().await?)
+        Ok(self.instance.get_host().await?)
     }
 
     /// Get the mapped port for the database.
@@ -194,10 +194,7 @@ impl Container {
     /// # Errors
     /// This function will return an error if the container is not running (e.g. because it crashed) or if the host could not be retrieved
     pub async fn get_mapped_port(&self) -> Result<u16, ContainerError> {
-        Ok(self
-            .container
-            .get_host_port_ipv4(self.internal_port)
-            .await?)
+        Ok(self.instance.get_host_port_ipv4(self.internal_port).await?)
     }
 
     /// Get the complete http base URL for the database.
@@ -227,7 +224,7 @@ impl Container {
     /// # Errors
     /// This function will return an error if the container could not be stopped.
     pub async fn stop(self) -> Result<(), ContainerError> {
-        self.container.stop().await?;
+        self.instance.stop().await?;
         Ok(())
     }