Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions packages/core/shield/src/request.rs
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ use serde_json::Value;
pub struct SignInRequest {
pub provider_id: String,
pub subprovider_id: Option<String>,
pub redirect_url: Option<String>,
pub data: Option<Value>,
pub form_data: Option<Value>,
}
Expand All @@ -15,6 +16,7 @@ pub struct SignInRequest {
pub struct SignInCallbackRequest {
pub provider_id: String,
pub subprovider_id: Option<String>,
pub redirect_url: Option<String>,
pub query: Option<Value>,
pub data: Option<Value>,
}
Expand Down
2 changes: 2 additions & 0 deletions packages/core/shield/src/session.rs
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,8 @@ impl Session {
pub struct SessionData {
pub authentication: Option<Authentication>,

pub redirect_url: Option<String>,

// TODO: Allow arbitrary data to be stored by providers?
pub csrf: Option<String>,
pub nonce: Option<String>,
Expand Down
45 changes: 41 additions & 4 deletions packages/core/shield/src/shield.rs
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,24 @@ impl<U: User> Shield<U> {
None => return Err(ProviderError::ProviderNotFound(request.provider_id).into()),
};

provider.sign_in(request, session, &self.options).await
// TODO: validate redirect URL

{
let session_data = session.data();
let mut session_data = session_data
.lock()
.map_err(|err| SessionError::Lock(err.to_string()))?;

session_data.redirect_url = request.redirect_url.clone();
};

let response = provider
.sign_in(request, session.clone(), &self.options)
.await;

session.update().await?;

response
}

pub async fn sign_in_callback(
Expand All @@ -127,9 +144,29 @@ impl<U: User> Shield<U> {
None => return Err(ProviderError::ProviderNotFound(request.provider_id).into()),
};

provider
.sign_in_callback(request, session, &self.options)
.await
let redirect_url = {
let session_data = session.data();
let session_data = session_data
.lock()
.map_err(|err| SessionError::Lock(err.to_string()))?;

session_data.redirect_url.clone()
};

let response = provider
.sign_in_callback(
SignInCallbackRequest {
redirect_url: request.redirect_url.or(redirect_url),
..request
},
session.clone(),
&self.options,
)
.await;

session.update().await?;

response
}

pub async fn sign_out(&self, session: Session) -> Result<Response, ShieldError> {
Expand Down
12 changes: 11 additions & 1 deletion packages/integrations/shield-axum/src/routes/sign_in.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
use axum::extract::Path;
use axum::{extract::Path, Json};
use serde::{Deserialize, Serialize};
use shield::{SignInRequest, User};

use crate::{
Expand All @@ -8,6 +9,12 @@ use crate::{
response::RouteResponse,
};

#[derive(Clone, Debug, Default, Deserialize, Serialize)]
#[cfg_attr(feature = "utoipa", derive(utoipa::ToSchema))]
pub struct SignInData {
redirect_url: Option<String>,
}

#[cfg_attr(
feature = "utoipa",
utoipa::path(
Expand All @@ -18,6 +25,7 @@ use crate::{
params(
AuthPathParams,
),
request_body = SignInData,
responses(
(status = 200, description = "Successfully signed in."),
(status = 303, description = "Redirect to authentication provider for sign in."),
Expand All @@ -34,12 +42,14 @@ pub async fn sign_in<U: User>(
}): Path<AuthPathParams>,
ExtractShield(shield): ExtractShield<U>,
ExtractSession(session): ExtractSession,
Json(data): Json<SignInData>,
) -> Result<RouteResponse, RouteError> {
let response = shield
.sign_in(
SignInRequest {
provider_id,
subprovider_id,
redirect_url: data.redirect_url,
data: None,
form_data: None,
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@ pub async fn sign_in_callback<U: User>(
SignInCallbackRequest {
provider_id,
subprovider_id,
redirect_url: None,
query: Some(query),
data: None,
},
Expand Down
1 change: 1 addition & 0 deletions packages/integrations/shield-leptos/src/routes/sign_in.rs
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ pub async fn sign_in(
SignInRequest {
provider_id,
subprovider_id,
redirect_url: None,
data: None,
form_data: None,
},
Expand Down
10 changes: 5 additions & 5 deletions packages/providers/shield-oidc/src/provider.rs
Original file line number Diff line number Diff line change
Expand Up @@ -253,8 +253,6 @@ impl<U: User> Provider for OidcProvider<U> {
session_data.oidc_connection_id = None;
}

session.update().await?;

Ok(Response::Redirect(auth_url.to_string()))
}

Expand Down Expand Up @@ -402,9 +400,11 @@ impl<U: User> Provider for OidcProvider<U> {
session_data.oidc_connection_id = Some(connection.id);
}

session.update().await?;

Ok(Response::Redirect(options.sign_in_redirect.clone()))
Ok(Response::Redirect(
request
.redirect_url
.unwrap_or(options.sign_in_redirect.clone()),
))
}

async fn sign_out(
Expand Down