arche 3.1.0

An opinionated backend foundation for Axum applications, providing batteries-included integrations for cloud services, databases, authentication, middleware, and logging.
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
49

use google_sheets4::{
    Sheets,
    hyper_util::{self, client::legacy::Client},
    yup_oauth2,
};

use crate::config::resolve_required_string;
use crate::error::AppError;
use crate::gcp::auth::{ProxiedConnector, build_proxy_aware_connector, build_sa_authenticator};

pub use crate::config::gcp::{GcpSheetsConfig, GcpSheetsConfigBuilder};

pub type GCPSheetsClient = Sheets<ProxiedConnector>;

#[allow(dead_code)]
pub async fn get_sheets_client(
    config: impl Into<Option<GcpSheetsConfig>>,
) -> Result<GCPSheetsClient, AppError> {
    let config = config.into().unwrap_or_default();

    let gcp_sheets_key = resolve_required_string(
        config.service_account_key_path,
        "GCP_SHEETS_KEY",
        "service_account_key_path",
    )?;

    let sa_key = yup_oauth2::read_service_account_key(&gcp_sheets_key)
        .await
        .map_err(|e| {
            tracing::error!(
                error = %e,
                service = "google_sheets",
                "Failed to read service account key"
            );
            AppError::internal_error(
                format!(
                    "Config error [service_account_key/GCP_SHEETS_KEY]: Failed to read GCP key: {}",
                    e
                ),
                None,
            )
        })?;

    let authenticator = build_sa_authenticator("google_sheets", sa_key).await?;
    let connector = build_proxy_aware_connector("google_sheets")?;
    let client = Client::builder(hyper_util::rt::TokioExecutor::new()).build(connector);

    Ok(Sheets::new(client, authenticator))
}