scufflecloud_core/services/
sessions.rs

1use base64::Engine;
2use core_traits::OptionExt;
3use sha2::Digest;
4
5use crate::google_api;
6use crate::http_ext::RequestExt;
7use crate::operations::Operation;
8use crate::operations::user_sessions::{InvalidateUserSessionRequest, RefreshUserSessionRequest};
9use crate::services::CoreSvc;
10
11#[async_trait::async_trait]
12impl<G: core_traits::Global> pb::scufflecloud::core::v1::sessions_service_server::SessionsService for CoreSvc<G> {
13    async fn login_with_magic_link(
14        &self,
15        req: tonic::Request<pb::scufflecloud::core::v1::LoginWithMagicLinkRequest>,
16    ) -> Result<tonic::Response<()>, tonic::Status> {
17        Operation::<G>::run(req).await.map(tonic::Response::new)
18    }
19
20    async fn complete_login_with_magic_link(
21        &self,
22        req: tonic::Request<pb::scufflecloud::core::v1::CompleteLoginWithMagicLinkRequest>,
23    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::NewUserSessionToken>, tonic::Status> {
24        Operation::<G>::run(req).await.map(tonic::Response::new)
25    }
26
27    async fn login_with_email_and_password(
28        &self,
29        req: tonic::Request<pb::scufflecloud::core::v1::LoginWithEmailAndPasswordRequest>,
30    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::NewUserSessionToken>, tonic::Status> {
31        Operation::<G>::run(req).await.map(tonic::Response::new)
32    }
33
34    async fn login_with_google(
35        &self,
36        req: tonic::Request<pb::scufflecloud::core::v1::LoginWithGoogleRequest>,
37    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::LoginWithGoogleResponse>, tonic::Status> {
38        let global = &req.global::<G>()?;
39        let payload = req.into_inner();
40
41        let device = payload.device.require("device")?;
42        let device_fingerprint = sha2::Sha256::digest(&device.public_key_data);
43        let state = base64::prelude::BASE64_URL_SAFE.encode(device_fingerprint);
44
45        let authorization_url = google_api::authorization_url(global, &state);
46
47        Ok(tonic::Response::new(pb::scufflecloud::core::v1::LoginWithGoogleResponse {
48            authorization_url,
49        }))
50    }
51
52    async fn complete_login_with_google(
53        &self,
54        req: tonic::Request<pb::scufflecloud::core::v1::CompleteLoginWithGoogleRequest>,
55    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::CompleteLoginWithGoogleResponse>, tonic::Status> {
56        Operation::<G>::run(req).await.map(tonic::Response::new)
57    }
58
59    async fn login_with_webauthn(
60        &self,
61        req: tonic::Request<pb::scufflecloud::core::v1::LoginWithWebauthnRequest>,
62    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::NewUserSessionToken>, tonic::Status> {
63        Operation::<G>::run(req).await.map(tonic::Response::new)
64    }
65
66    async fn create_user_session_request(
67        &self,
68        req: tonic::Request<pb::scufflecloud::core::v1::CreateUserSessionRequestRequest>,
69    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::UserSessionRequest>, tonic::Status> {
70        Operation::<G>::run(req).await.map(tonic::Response::new)
71    }
72
73    async fn get_user_session_request(
74        &self,
75        req: tonic::Request<pb::scufflecloud::core::v1::GetUserSessionRequestRequest>,
76    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::UserSessionRequest>, tonic::Status> {
77        Operation::<G>::run(req).await.map(tonic::Response::new)
78    }
79
80    async fn get_user_session_request_by_code(
81        &self,
82        req: tonic::Request<pb::scufflecloud::core::v1::GetUserSessionRequestByCodeRequest>,
83    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::UserSessionRequest>, tonic::Status> {
84        Operation::<G>::run(req).await.map(tonic::Response::new)
85    }
86
87    async fn approve_user_session_request_by_code(
88        &self,
89        req: tonic::Request<pb::scufflecloud::core::v1::ApproveUserSessionRequestByCodeRequest>,
90    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::UserSessionRequest>, tonic::Status> {
91        Operation::<G>::run(req).await.map(tonic::Response::new)
92    }
93
94    async fn complete_user_session_request(
95        &self,
96        req: tonic::Request<pb::scufflecloud::core::v1::CompleteUserSessionRequestRequest>,
97    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::NewUserSessionToken>, tonic::Status> {
98        Operation::<G>::run(req).await.map(tonic::Response::new)
99    }
100
101    async fn validate_mfa_for_user_session(
102        &self,
103        req: tonic::Request<pb::scufflecloud::core::v1::ValidateMfaForUserSessionRequest>,
104    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::UserSession>, tonic::Status> {
105        Operation::<G>::run(req).await.map(tonic::Response::new)
106    }
107
108    async fn refresh_user_session(
109        &self,
110        req: tonic::Request<()>,
111    ) -> Result<tonic::Response<pb::scufflecloud::core::v1::NewUserSessionToken>, tonic::Status> {
112        let (metadata, extensions, _) = req.into_parts();
113        let req = tonic::Request::from_parts(metadata, extensions, RefreshUserSessionRequest);
114        Operation::<G>::run(req).await.map(tonic::Response::new)
115    }
116
117    async fn invalidate_user_session(&self, req: tonic::Request<()>) -> Result<tonic::Response<()>, tonic::Status> {
118        let (metadata, extensions, _) = req.into_parts();
119        let req = tonic::Request::from_parts(metadata, extensions, InvalidateUserSessionRequest);
120        Operation::<G>::run(req).await.map(tonic::Response::new)
121    }
122}
scufflecloud_core/services/sessions.rs

scufflecloud_core/services/
sessions.rs
