style: rustfmt the regenerated client

Author: zfarrell

src/apis/configuration.rs

@@ -8,7 +8,6 @@
  * Generated by: https://openapi-generator.tech
  */
 
-
 use std::collections::HashMap;
 
 #[derive(Debug, Clone)]
@@ -31,7 +30,6 @@ pub struct ApiKey {
     pub key: String,
 }
 
-
 impl Configuration {
     pub fn new() -> Configuration {
         Configuration::default()

src/apis/connection_types_api.rs

@@ -8,12 +8,10 @@
  * Generated by: https://openapi-generator.tech
  */
 
-
-use reqwest;
-use serde::{Deserialize, Serialize, de::Error as _};
+use super::{configuration, ContentType, Error};
 use crate::{apis::ResponseContent, models};
-use super::{Error, configuration, ContentType};
-
+use reqwest;
+use serde::{de::Error as _, Deserialize, Serialize};
 
 /// struct for typed errors of method [`get_connection_type`]
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -30,13 +28,19 @@ pub enum ListConnectionTypesError {
     UnknownValue(serde_json::Value),
 }
 
-
 /// Get configuration schema and authentication requirements for a specific connection type.
-pub async fn get_connection_type(configuration: &configuration::Configuration, name: &str) -> Result<models::ConnectionTypeDetail, Error<GetConnectionTypeError>> {
+pub async fn get_connection_type(
+    configuration: &configuration::Configuration,
+    name: &str,
+) -> Result<models::ConnectionTypeDetail, Error<GetConnectionTypeError>> {
     // add a prefix to parameters to efficiently prevent name collisions
     let p_path_name = name;
 
-    let uri_str = format!("{}/v1/connection-types/{name}", configuration.base_path, name=crate::apis::urlencode(p_path_name));
+    let uri_str = format!(
+        "{}/v1/connection-types/{name}",
+        configuration.base_path,
+        name = crate::apis::urlencode(p_path_name)
+    );
     let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
 
     if let Some(ref user_agent) = configuration.user_agent {
@@ -79,13 +83,18 @@ pub async fn get_connection_type(configuration: &configuration::Configuration, n
         let content = resp.text().await?;
         crate::http_log::log_response_body(&content);
         let entity: Option<GetConnectionTypeError> = serde_json::from_str(&content).ok();
-        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+        Err(Error::ResponseError(ResponseContent {
+            status,
+            content,
+            entity,
+        }))
     }
 }
 
 /// List all available connection types, including native sources and FlightDLT services.
-pub async fn list_connection_types(configuration: &configuration::Configuration, ) -> Result<models::ListConnectionTypesResponse, Error<ListConnectionTypesError>> {
-
+pub async fn list_connection_types(
+    configuration: &configuration::Configuration,
+) -> Result<models::ListConnectionTypesResponse, Error<ListConnectionTypesError>> {
     let uri_str = format!("{}/v1/connection-types", configuration.base_path);
     let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
 
@@ -129,7 +138,10 @@ pub async fn list_connection_types(configuration: &configuration::Configuration,
         let content = resp.text().await?;
         crate::http_log::log_response_body(&content);
         let entity: Option<ListConnectionTypesError> = serde_json::from_str(&content).ok();
-        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+        Err(Error::ResponseError(ResponseContent {
+            status,
+            content,
+            entity,
+        }))
     }
 }
-

src/apis/connections_api.rs

@@ -8,12 +8,10 @@
  * Generated by: https://openapi-generator.tech
  */
 
-
-use reqwest;
-use serde::{Deserialize, Serialize, de::Error as _};
+use super::{configuration, ContentType, Error};
 use crate::{apis::ResponseContent, models};
-use super::{Error, configuration, ContentType};
-
+use reqwest;
+use serde::{de::Error as _, Deserialize, Serialize};
 
 /// struct for typed errors of method [`delete_database_context`]
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -50,15 +48,25 @@ pub enum UpsertDatabaseContextError {
     UnknownValue(serde_json::Value),
 }
 
-
 /// Removes a named context document from a database.
-pub async fn delete_database_context(configuration: &configuration::Configuration, database_id: &str, name: &str) -> Result<(), Error<DeleteDatabaseContextError>> {
+pub async fn delete_database_context(
+    configuration: &configuration::Configuration,
+    database_id: &str,
+    name: &str,
+) -> Result<(), Error<DeleteDatabaseContextError>> {
     // add a prefix to parameters to efficiently prevent name collisions
     let p_path_database_id = database_id;
     let p_path_name = name;
 
-    let uri_str = format!("{}/v1/databases/{database_id}/context/{name}", configuration.base_path, database_id=crate::apis::urlencode(p_path_database_id), name=crate::apis::urlencode(p_path_name));
-    let mut req_builder = configuration.client.request(reqwest::Method::DELETE, &uri_str);
+    let uri_str = format!(
+        "{}/v1/databases/{database_id}/context/{name}",
+        configuration.base_path,
+        database_id = crate::apis::urlencode(p_path_database_id),
+        name = crate::apis::urlencode(p_path_name)
+    );
+    let mut req_builder = configuration
+        .client
+        .request(reqwest::Method::DELETE, &uri_str);
 
     if let Some(ref user_agent) = configuration.user_agent {
         req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
@@ -88,16 +96,29 @@ pub async fn delete_database_context(configuration: &configuration::Configuratio
         let content = resp.text().await?;
         crate::http_log::log_response_body(&content);
         let entity: Option<DeleteDatabaseContextError> = serde_json::from_str(&content).ok();
-        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+        Err(Error::ResponseError(ResponseContent {
+            status,
+            content,
+            entity,
+        }))
     }
 }
 
-pub async fn get_database_context(configuration: &configuration::Configuration, database_id: &str, name: &str) -> Result<models::GetDatabaseContextResponse, Error<GetDatabaseContextError>> {
+pub async fn get_database_context(
+    configuration: &configuration::Configuration,
+    database_id: &str,
+    name: &str,
+) -> Result<models::GetDatabaseContextResponse, Error<GetDatabaseContextError>> {
     // add a prefix to parameters to efficiently prevent name collisions
     let p_path_database_id = database_id;
     let p_path_name = name;
 
-    let uri_str = format!("{}/v1/databases/{database_id}/context/{name}", configuration.base_path, database_id=crate::apis::urlencode(p_path_database_id), name=crate::apis::urlencode(p_path_name));
+    let uri_str = format!(
+        "{}/v1/databases/{database_id}/context/{name}",
+        configuration.base_path,
+        database_id = crate::apis::urlencode(p_path_database_id),
+        name = crate::apis::urlencode(p_path_name)
+    );
     let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
 
     if let Some(ref user_agent) = configuration.user_agent {
@@ -140,15 +161,26 @@ pub async fn get_database_context(configuration: &configuration::Configuration,
         let content = resp.text().await?;
         crate::http_log::log_response_body(&content);
         let entity: Option<GetDatabaseContextError> = serde_json::from_str(&content).ok();
-        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+        Err(Error::ResponseError(ResponseContent {
+            status,
+            content,
+            entity,
+        }))
     }
 }
 
-pub async fn list_database_contexts(configuration: &configuration::Configuration, database_id: &str) -> Result<models::ListDatabaseContextsResponse, Error<ListDatabaseContextsError>> {
+pub async fn list_database_contexts(
+    configuration: &configuration::Configuration,
+    database_id: &str,
+) -> Result<models::ListDatabaseContextsResponse, Error<ListDatabaseContextsError>> {
     // add a prefix to parameters to efficiently prevent name collisions
     let p_path_database_id = database_id;
 
-    let uri_str = format!("{}/v1/databases/{database_id}/context", configuration.base_path, database_id=crate::apis::urlencode(p_path_database_id));
+    let uri_str = format!(
+        "{}/v1/databases/{database_id}/context",
+        configuration.base_path,
+        database_id = crate::apis::urlencode(p_path_database_id)
+    );
     let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
 
     if let Some(ref user_agent) = configuration.user_agent {
@@ -191,18 +223,32 @@ pub async fn list_database_contexts(configuration: &configuration::Configuration
         let content = resp.text().await?;
         crate::http_log::log_response_body(&content);
         let entity: Option<ListDatabaseContextsError> = serde_json::from_str(&content).ok();
-        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+        Err(Error::ResponseError(ResponseContent {
+            status,
+            content,
+            entity,
+        }))
     }
 }
 
 /// Stores a named document (for example Markdown) scoped to a database. Reuses the same name to replace content.
-pub async fn upsert_database_context(configuration: &configuration::Configuration, database_id: &str, upsert_database_context_request: models::UpsertDatabaseContextRequest) -> Result<models::UpsertDatabaseContextResponse, Error<UpsertDatabaseContextError>> {
+pub async fn upsert_database_context(
+    configuration: &configuration::Configuration,
+    database_id: &str,
+    upsert_database_context_request: models::UpsertDatabaseContextRequest,
+) -> Result<models::UpsertDatabaseContextResponse, Error<UpsertDatabaseContextError>> {
     // add a prefix to parameters to efficiently prevent name collisions
     let p_path_database_id = database_id;
     let p_body_upsert_database_context_request = upsert_database_context_request;
 
-    let uri_str = format!("{}/v1/databases/{database_id}/context", configuration.base_path, database_id=crate::apis::urlencode(p_path_database_id));
-    let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
+    let uri_str = format!(
+        "{}/v1/databases/{database_id}/context",
+        configuration.base_path,
+        database_id = crate::apis::urlencode(p_path_database_id)
+    );
+    let mut req_builder = configuration
+        .client
+        .request(reqwest::Method::POST, &uri_str);
 
     if let Some(ref user_agent) = configuration.user_agent {
         req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
@@ -245,7 +291,10 @@ pub async fn upsert_database_context(configuration: &configuration::Configuratio
         let content = resp.text().await?;
         crate::http_log::log_response_body(&content);
         let entity: Option<UpsertDatabaseContextError> = serde_json::from_str(&content).ok();
-        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+        Err(Error::ResponseError(ResponseContent {
+            status,
+            content,
+            entity,
+        }))
     }
 }
-