fmt

Author: s0l0ist

examples/basic-error-error-crates-integration/src/main.rs

@@ -28,7 +28,7 @@ fn miette_error() -> miette::Result<()> {
 
 /// Transform an anyhow::Error, eyre::Report, or miette::Report into a lambda_runtime::Diagnostic.
 /// It does it by enabling the feature `anyhow`, `eyre` or `miette` in the runtime dependency.
-/// Those features enable the implementation of `From<T> for Diagnostic` 
+/// Those features enable the implementation of `From<T> for Diagnostic`
 /// for `anyhow::Error`, `eyre::Report`, and `miette::Report`.
 async fn function_handler(event: LambdaEvent<Request>) -> Result<(), Diagnostic> {
     match event.payload.error_type {

examples/basic-s3-object-lambda-thumbnail/src/main.rs

@@ -84,16 +84,12 @@ fn get_thumbnail(vec: Vec<u8>, _size: u32) -> Vec<u8> {
 mod tests {
     use super::*;
     use async_trait::async_trait;
-    use aws_lambda_events::s3::object_lambda::Configuration;
-    use aws_lambda_events::s3::object_lambda::HeadObjectContext;
-    use aws_lambda_events::s3::object_lambda::ListObjectsContext;
-    use aws_lambda_events::s3::object_lambda::ListObjectsV2Context;
-    use aws_lambda_events::s3::object_lambda::UserIdentity;
-    use aws_lambda_events::s3::object_lambda::UserRequest;
+    use aws_lambda_events::s3::object_lambda::{
+        Configuration, HeadObjectContext, ListObjectsContext, ListObjectsV2Context, UserIdentity, UserRequest,
+    };
     use lambda_runtime::{Context, LambdaEvent};
     use mockall::mock;
-    use s3::GetFile;
-    use s3::SendFile;
+    use s3::{GetFile, SendFile};
     use serde_json::json;
 
     #[tokio::test]

examples/basic-s3-thumbnail/src/main.rs

@@ -139,16 +139,11 @@ mod tests {
     use super::*;
     use async_trait::async_trait;
     //use aws_lambda_events::chrono::DateTime;
-    use aws_lambda_events::s3::S3Bucket;
-    use aws_lambda_events::s3::S3Entity;
-    use aws_lambda_events::s3::S3Object;
-    use aws_lambda_events::s3::S3RequestParameters;
-    use aws_lambda_events::s3::S3UserIdentity;
+    use aws_lambda_events::s3::{S3Bucket, S3Entity, S3Object, S3RequestParameters, S3UserIdentity};
     use aws_sdk_s3::operation::get_object::GetObjectError;
     use lambda_runtime::{Context, LambdaEvent};
     use mockall::mock;
-    use s3::GetFile;
-    use s3::PutFile;
+    use s3::{GetFile, PutFile};
 
     #[tokio::test]
     async fn response_is_good() {

examples/extension-internal-flush/src/main.rs

@@ -2,8 +2,10 @@ use anyhow::anyhow;
 use aws_lambda_events::sqs::{SqsBatchResponse, SqsEventObj};
 use lambda_extension::{service_fn, tracing, Error, Extension, NextEvent};
 use serde::{Deserialize, Serialize};
-use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
-use tokio::sync::Mutex;
+use tokio::sync::{
+    mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender},
+    Mutex,
+};
 
 use std::sync::Arc;
 

examples/http-axum-diesel-ssl/src/main.rs

@@ -4,14 +4,12 @@ use axum::{
     routing::get,
     Router,
 };
-use diesel::prelude::*;
-use diesel::{ConnectionError, ConnectionResult};
+use diesel::{prelude::*, ConnectionError, ConnectionResult};
 use diesel_async::{
     pooled_connection::{bb8::Pool, AsyncDieselConnectionManager, ManagerConfig},
     AsyncPgConnection, RunQueryDsl,
 };
-use futures_util::future::BoxFuture;
-use futures_util::FutureExt;
+use futures_util::{future::BoxFuture, FutureExt};
 use lambda_http::{http::StatusCode, run, tracing, Error};
 use serde::{Deserialize, Serialize};
 use std::time::Duration;

examples/http-axum-middleware/src/main.rs

@@ -10,8 +10,7 @@
 //! ```
 
 use axum::{response::Json, routing::post, Router};
-use lambda_http::request::RequestContext::ApiGatewayV1;
-use lambda_http::{run, tracing, Error};
+use lambda_http::{request::RequestContext::ApiGatewayV1, run, tracing, Error};
 use serde_json::{json, Value};
 
 // Sample middleware that logs the request id

examples/http-axum/src/main.rs

@@ -6,10 +6,9 @@
 //! implementation to the Lambda runtime to run as a Lambda function.  By using Axum instead
 //! of a basic `tower::Service` you get web framework niceties like routing, request component
 //! extraction, validation, etc.
-use axum::extract::Query;
-use axum::http::StatusCode;
 use axum::{
-    extract::Path,
+    extract::{Path, Query},
+    http::StatusCode,
     response::Json,
     routing::{get, post},
     Router,

examples/http-tower-trace/src/main.rs

@@ -1,6 +1,9 @@
-use lambda_http::tracing::{self, Level};
-use lambda_http::{run, tower::ServiceBuilder, Error};
-use lambda_http::{Request, Response};
+use lambda_http::{
+    run,
+    tower::ServiceBuilder,
+    tracing::{self, Level},
+    Error, Request, Response,
+};
 use tower_http::trace::{DefaultOnRequest, DefaultOnResponse, TraceLayer};
 
 async fn handler(_req: Request) -> Result<Response<String>, Error> {

examples/lambda-rds-iam-auth/src/main.rs

@@ -7,8 +7,10 @@ use aws_sigv4::{
 use lambda_runtime::{run, service_fn, Error, LambdaEvent};
 use serde_json::{json, Value};
 use sqlx::postgres::PgConnectOptions;
-use std::env;
-use std::time::{Duration, SystemTime};
+use std::{
+    env,
+    time::{Duration, SystemTime},
+};
 
 const RDS_CERTS: &[u8] = include_bytes!("global-bundle.pem");