Lambda crate update + reformatting

Author: rimutaka

rustfmt.toml

@@ -0,0 +1,4 @@
+max_width = 120
+attr_fn_like_width = 90
+wrap_comments = false
+fn_call_width = 90

src/config.rs

@@ -41,8 +41,7 @@ impl Config {
             .trim()
             .to_string();
 
-        let s3_region = Region::from_str(&s3_region)
-            .expect("Invalid S3 Region value. Must look like `us-east-1`.");
+        let s3_region = Region::from_str(&s3_region).expect("Invalid S3 Region value. Must look like `us-east-1`.");
 
         Config {
             s3_bucket: std::env::var(S3_BUCKET_ENV)
@@ -70,8 +69,7 @@ impl Config {
 fn generate_s3_client(s3_region: Region) -> S3Client {
     let https_connector = HttpsConnector::with_native_roots();
 
-    let cred_prov =
-        DefaultCredentialsProvider::new().expect("Cannot unwrap DefaultCredentialsProvider");
+    let cred_prov = DefaultCredentialsProvider::new().expect("Cannot unwrap DefaultCredentialsProvider");
 
     let mut builder = hyper::Client::builder();
     builder.pool_idle_timeout(Duration::from_secs(15));

src/handler.rs

@@ -1,7 +1,7 @@
+use crate::config::Config;
 use crate::s3;
-use crate::{config::Config, Error};
 use base64::decode;
-use lambda_runtime::Context;
+use lambda_runtime::{Context, Error};
 use ring::signature;
 use serde::{Deserialize, Serialize};
 use serde_json::Value;
@@ -51,10 +51,7 @@ pub(crate) async fn my_handler(event: Value, ctx: Context) -> Result<Value, Erro
     // parse the request
     let api_request = match serde_json::from_value::<ApiGatewayRequest>(event.clone()) {
         Err(e) => {
-            error!(
-                "Failed to deser APIGW request due to {}. Request: {}",
-                e, event
-            );
+            error!("Failed to deser APIGW request due to {}. Request: {}", e, event);
             return gw_response(Some(ERROR_500_MSG.to_owned()), 500);
         }
         Ok(v) => v,
@@ -63,9 +60,7 @@ pub(crate) async fn my_handler(event: Value, ctx: Context) -> Result<Value, Erro
     info!("Report from IP: {:?}", api_request.headers.x_forwarded_for);
 
     // these 2 headers are required no matter what
-    if api_request.headers.stackmuncher_key.is_none()
-        || api_request.headers.stackmuncher_sig.is_none()
-    {
+    if api_request.headers.stackmuncher_key.is_none() || api_request.headers.stackmuncher_sig.is_none() {
         error!(
             "Missing a header. Key: {:?}, Sig: {:?}",
             api_request.headers.stackmuncher_key, api_request.headers.stackmuncher_sig
@@ -113,10 +108,7 @@ pub(crate) async fn my_handler(event: Value, ctx: Context) -> Result<Value, Erro
     let pub_key = match bs58::decode(pub_key_bs58.clone()).into_vec() {
         Ok(v) => v,
         Err(e) => {
-            error!(
-                "Failed to decode the stackmuncher_key from based58 due to: {}",
-                e
-            );
+            error!("Failed to decode the stackmuncher_key from based58 due to: {}", e);
             return gw_response(Some(ERROR_500_MSG.to_owned()), 500);
         }
     };
@@ -132,10 +124,7 @@ pub(crate) async fn my_handler(event: Value, ctx: Context) -> Result<Value, Erro
     {
         Ok(v) => v,
         Err(e) => {
-            error!(
-                "Failed to decode the stackmuncher_key from based58 due to: {}",
-                e
-            );
+            error!("Failed to decode the stackmuncher_key from based58 due to: {}", e);
             return gw_response(Some(ERROR_500_MSG.to_owned()), 500);
         }
     };

src/main.rs

@@ -1,12 +1,11 @@
 #[cfg(not(debug_assertions))]
 use lambda_runtime::handler_fn;
+use lambda_runtime::Error;
 
 mod config;
 mod handler;
 mod s3;
 
-pub(crate) type Error = Box<dyn std::error::Error + Send + Sync + 'static>;
-
 /// Boilerplate Lambda runtime code with conditional debug proxy
 #[tokio::main]
 async fn main() -> Result<(), Error> {
@@ -44,10 +43,12 @@ mod proxy {
     pub(crate) type Error = Box<dyn std::error::Error + Send + Sync + 'static>;
 
     // these are specific to a particular account - modify as needed for development
-    // they should probably be taken out into a separate file 
-    const AWS_REGION: Region = Region::UsEast1; 
-    const REQUEST_QUEUE_URL: &str = "https://sqs.us-east-1.amazonaws.com/028534811986/STM_INBOX_LAMBDA_PROXY_REQ";
-    const RESPONSE_QUEUE_URL: &str = "	https://sqs.us-east-1.amazonaws.com/028534811986/STM_INBOX_LAMBDA_PROXY_RESP";
+    // they should probably be taken out into a separate file
+    const AWS_REGION: Region = Region::UsEast1;
+    const REQUEST_QUEUE_URL: &str =
+        "https://sqs.us-east-1.amazonaws.com/028534811986/STM_INBOX_LAMBDA_PROXY_REQ";
+    const RESPONSE_QUEUE_URL: &str =
+        "https://sqs.us-east-1.amazonaws.com/028534811986/STM_INBOX_LAMBDA_PROXY_RESP";
 
     #[derive(Deserialize, Debug)]
     struct RequestPayload {