gestalt-sdk 0.0.1-alpha.12

Rust SDK scaffolding and generated protocol bindings for Gestalt executable providers
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

use std::sync::Arc;

use tonic::{Request as GrpcRequest, Response as GrpcResponse, Status};

use crate::generated::v1::secrets_provider_server::SecretsProvider as SecretsProviderGrpc;
use crate::generated::v1::{GetSecretRequest, GetSecretResponse};
use crate::rpc_status::rpc_status;
use crate::secrets::SecretsProvider;

#[derive(Clone)]
pub struct SecretsServer<P> {
    secrets: Arc<P>,
}

impl<P> SecretsServer<P> {
    pub fn new(secrets: Arc<P>) -> Self {
        Self { secrets }
    }
}

#[tonic::async_trait]
impl<P> SecretsProviderGrpc for SecretsServer<P>
where
    P: SecretsProvider,
{
    async fn get_secret(
        &self,
        request: GrpcRequest<GetSecretRequest>,
    ) -> std::result::Result<GrpcResponse<GetSecretResponse>, Status> {
        let request = request.into_inner();
        let value = self
            .secrets
            .get_secret(&request.name)
            .await
            .map_err(|error| rpc_status("get secret", error))?;
        Ok(GrpcResponse::new(GetSecretResponse { value }))
    }
}