gestalt-sdk 0.0.1-alpha.19

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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

use std::sync::Arc;

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

use crate::auth::{
    AuthSessionSettings, AuthenticationProvider, auth_session_settings_to_proto,
    authenticated_user_to_proto, begin_login_request_from_proto, begin_login_response_to_proto,
    complete_login_request_from_proto,
};
use crate::generated::v1::authentication_server::Authentication as AuthenticationProviderGrpc;
use crate::generated::v1::{
    AuthSessionSettings as ProtoAuthSessionSettings, AuthenticatedUser as ProtoAuthenticatedUser,
    BeginLoginRequest as ProtoBeginLoginRequest, BeginLoginResponse as ProtoBeginLoginResponse,
    CompleteLoginRequest as ProtoCompleteLoginRequest, ValidateExternalTokenRequest,
};
use crate::rpc_status::rpc_status;

pub struct AuthenticationServer<P> {
    provider: Arc<P>,
}

impl<P> AuthenticationServer<P> {
    pub fn new(provider: Arc<P>) -> Self {
        Self { provider }
    }
}

impl<P> Clone for AuthenticationServer<P> {
    fn clone(&self) -> Self {
        Self {
            provider: Arc::clone(&self.provider),
        }
    }
}

#[tonic::async_trait]
impl<P> AuthenticationProviderGrpc for AuthenticationServer<P>
where
    P: AuthenticationProvider,
{
    async fn begin_login(
        &self,
        request: GrpcRequest<ProtoBeginLoginRequest>,
    ) -> std::result::Result<GrpcResponse<ProtoBeginLoginResponse>, Status> {
        let response = self
            .provider
            .begin_login(begin_login_request_from_proto(request.into_inner()))
            .await
            .map_err(|error| rpc_status("begin login", error))?;
        Ok(GrpcResponse::new(begin_login_response_to_proto(response)))
    }

    async fn complete_login(
        &self,
        request: GrpcRequest<ProtoCompleteLoginRequest>,
    ) -> std::result::Result<GrpcResponse<ProtoAuthenticatedUser>, Status> {
        let user = self
            .provider
            .complete_login(complete_login_request_from_proto(request.into_inner()))
            .await
            .map_err(|error| rpc_status("complete login", error))?;
        Ok(GrpcResponse::new(authenticated_user_to_proto(user)))
    }

    async fn validate_external_token(
        &self,
        request: GrpcRequest<ValidateExternalTokenRequest>,
    ) -> std::result::Result<GrpcResponse<ProtoAuthenticatedUser>, Status> {
        let user = self
            .provider
            .validate_external_token(&request.into_inner().token)
            .await
            .map_err(|error| rpc_status("validate external token", error))?;
        let Some(user) = user else {
            return Err(Status::not_found("token not recognized"));
        };
        Ok(GrpcResponse::new(authenticated_user_to_proto(user)))
    }

    async fn get_session_settings(
        &self,
        _request: GrpcRequest<()>,
    ) -> std::result::Result<GrpcResponse<ProtoAuthSessionSettings>, Status> {
        let settings = self.provider.session_settings().or_else(|| {
            self.provider
                .session_ttl()
                .map(|session_ttl| AuthSessionSettings { session_ttl })
        });
        let Some(settings) = settings else {
            return Err(Status::unimplemented(
                "authentication provider does not expose session settings",
            ));
        };
        Ok(GrpcResponse::new(auth_session_settings_to_proto(settings)))
    }
}