ForgeFlux/ForgeFlux
2
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

feat: load GetOAuthAccessToken and DeleteOAuthAccessToken
Some checks failed
ci/woodpecker/push/woodpecker Pipeline failed
Details

Browse source
This commit is contained in:
Aravinth Manivannan 2024-05-12 21:35:23 +05:30
parent 87f2655110
commit 1415e087a6
Signed by: realaravinth
GPG key ID: F8F50389936984FF
4 changed files with 16 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/auth/adapter/input/forge/refresh_access_token.rs
View file

@ -2,7 +2,8 @@ use std::sync::Arc;
use crate::auth::application::port::input::forge::refresh_access_token::RefreshAccessTokenInputPort;
use crate::auth::application::port::out::db::{
get_oauth_access_token::GetOAuthAccessToken, update_oauth_access_token::UpdateOAuthAccessToken,
delete_oauth_access_token::DeleteOAuthAccessToken, get_oauth_access_token::GetOAuthAccessToken,
save_oauth_access_token::SaveOAuthAccessToken,
};
use crate::auth::application::port::out::forge::refresh_access_token::RefreshAccessToken;
use crate::auth::application::services::refresh_access_token::{
@ -11,18 +12,21 @@ use crate::auth::application::services::refresh_access_token::{
#[derive(Clone)]
pub struct RefreshAccessTokenInputAdapter {
save_oauth_access_token_adapter: Arc<dyn SaveOAuthAccessToken>,
get_oauth_access_token_adapter: Arc<dyn GetOAuthAccessToken>,
update_oauth_access_token_adapter: Arc<dyn UpdateOAuthAccessToken>,
delete_oauth_access_token_adapter: Arc<dyn DeleteOAuthAccessToken>,
}
impl RefreshAccessTokenInputAdapter {
pub fn new(
save_oauth_access_token_adapter: Arc<dyn SaveOAuthAccessToken>,
get_oauth_access_token_adapter: Arc<dyn GetOAuthAccessToken>,
update_oauth_access_token_adapter: Arc<dyn UpdateOAuthAccessToken>,
delete_oauth_access_token_adapter: Arc<dyn DeleteOAuthAccessToken>,
) -> Self {
Self {
save_oauth_access_token_adapter,
get_oauth_access_token_adapter,
update_oauth_access_token_adapter,
delete_oauth_access_token_adapter,
}
}
}
@ -35,8 +39,9 @@ impl RefreshAccessTokenInputPort for RefreshAccessTokenInputAdapter {
cmd: RefreshAccessTokenCommand,
) -> RefreshAccessTokenServiceResult<()> {
let s = RefreshAccessTokenService::new(
self.save_oauth_access_token_adapter.clone(),
self.get_oauth_access_token_adapter.clone(),
self.update_oauth_access_token_adapter.clone(),
self.delete_oauth_access_token_adapter.clone(),
refresh_access_token_adapter,
);
s.refresh_access_token(cmd).await?;

5
src/auth/adapter/input/web/types.rs
View file

@ -4,7 +4,8 @@ use actix_web::web;
use crate::auth::adapter::out::forge::forge_repository::ForgeRepositoryInterface;
use crate::auth::application::port::out::db::{
delete_oauth_state::DeleteOAuthState, oauth_state_exists::OAuthStateExists,
delete_oauth_access_token::DeleteOAuthAccessToken, delete_oauth_state::DeleteOAuthState,
get_oauth_access_token::GetOAuthAccessToken, oauth_state_exists::OAuthStateExists,
save_oauth_access_token::SaveOAuthAccessToken, save_oauth_state::SaveOAuthState,
};
pub(super) use crate::utils::random_string::WebGenerateRandomStringInterface;
@ -21,3 +22,5 @@ pub type WebSaveOauthState = web::Data<Arc<dyn SaveOAuthState>>;
pub type WebOauthStateExists = web::Data<Arc<dyn OAuthStateExists>>;
pub type WebDeleteOauthState = web::Data<Arc<dyn DeleteOAuthState>>;
pub type WebSaveOAuthAccessToken = web::Data<Arc<dyn SaveOAuthAccessToken>>;
pub type WebGetOAuthAccessToken = web::Data<Arc<dyn GetOAuthAccessToken>>;
pub type WebDeleteOAuthAccessToken = web::Data<Arc<dyn DeleteOAuthAccessToken>>;

2
src/auth/adapter/out/db/postgres/mod.rs
View file

@ -5,13 +5,13 @@ use sqlx::postgres::PgPool;
use crate::db::{migrate::RunMigrations, sqlx_postgres::Postgres};
mod delete_oauth_access_token;
mod delete_oauth_state;
mod errors;
mod get_oauth_access_token;
mod oauth_state_exists;
mod save_oauth_access_token;
mod save_oauth_state;
mod update_oauth_access_token;
#[derive(Clone)]
pub struct DBOutPostgresAdapter {

2
src/auth/application/port/out/db/mod.rs
View file

@ -1,7 +1,7 @@
pub mod delete_oauth_access_token;
pub mod delete_oauth_state;
pub mod errors;
pub mod get_oauth_access_token;
pub mod oauth_state_exists;
pub mod save_oauth_access_token;
pub mod save_oauth_state;
pub mod update_oauth_access_token;