derust 0.1.1

Easy way to start your Rust asynchronous application server using Tokio and Axum frameworks.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

mod secrets_manager;
mod sns;
mod sqs;

pub use secrets_manager::*;
pub use sns::*;
pub use sqs::*;

use crate::envx::Environment;
use aws_config::{BehaviorVersion, Region, SdkConfig};
use aws_sdk_secretsmanager::config::Credentials;
use lazy_static::lazy_static;

const LOCALSTACK_ENDPOINT: &str = "http://localhost:4566";

lazy_static! {
    static ref LOCALSTACK_REGION: Region = Region::from_static("us-east-1");
    static ref LOCALSTACK_CREDENTIALS: Credentials =
        Credentials::new("test", "test", None, None, "test");
}

#[derive(Clone)]
pub struct SnsClient {
    pub client: aws_sdk_sns::Client,
}

#[derive(Clone)]
pub struct SqsClient {
    pub client: aws_sdk_sqs::Client,
}

#[derive(Clone)]
pub struct SecretsManagerClient {
    pub client: aws_sdk_secretsmanager::Client,
}

pub async fn load_aws_config(env: Environment) -> SdkConfig {
    if env.is_local() || env.is_test() {
        aws_config::from_env()
            .region(LOCALSTACK_REGION.clone())
            .credentials_provider(LOCALSTACK_CREDENTIALS.clone())
            .endpoint_url(LOCALSTACK_ENDPOINT)
            .load()
            .await
    } else {
        aws_config::load_defaults(BehaviorVersion::latest()).await
    }
}