ForgeFlux/src/auth/adapter/out/forge/mod.rs
Aravinth Manivannan 44512bc616
Some checks failed
ci/woodpecker/push/woodpecker Pipeline failed
chore: mv src/forge/auth src/auth
2024-05-06 10:31:38 +05:30

90 lines
2.2 KiB
Rust

use std::collections::HashMap;
use std::str::FromStr;
use std::sync::Arc;
use derive_more::Display;
use serde::{Deserialize, Serialize};
use crate::auth::application::port::out::forge::oauth_auth_req_uri::OAuthAuthReqUri;
use self::forgejo::Forgejo;
pub mod forgejo;
#[derive(Clone)]
pub struct ForgeAdapter {
pub oauth_auth_req_uri_adapter: Arc<dyn OAuthAuthReqUri>,
}
#[derive(Clone, Default)]
pub struct ForgeRepository {
forges: HashMap<SupportedForges, ForgeAdapter>,
}
impl ForgeRepository {
fn add_forge(&mut self, name: SupportedForges, forge_factory: ForgeAdapter) {
self.forges.insert(name, forge_factory);
}
pub fn get_supported_forge_str(&self) -> Vec<String> {
self.forges
.clone()
.into_keys()
.map(|v| v.to_string())
.collect()
}
pub fn get_supported_forges(&self) -> Vec<SupportedForges> {
self.forges.clone().into_keys().collect()
}
pub fn get_forge(&self, name: &SupportedForges) -> Option<&ForgeAdapter> {
self.forges.get(name)
}
pub fn new(forgejo: Forgejo) -> Self {
let forgejo_adapter = ForgeAdapter {
oauth_auth_req_uri_adapter: Arc::new(forgejo),
};
let mut s = Self::default();
s.add_forge(SupportedForges::Forgejo, forgejo_adapter);
s
}
}
#[derive(Debug, Display, Clone, Hash, Serialize, Deserialize, PartialEq, Eq, PartialOrd, Ord)]
#[serde(rename_all = "lowercase")]
pub enum SupportedForges {
#[display(fmt = "forgejo")]
Forgejo,
}
impl FromStr for SupportedForges {
type Err = SupportedForgesError;
fn from_str(s: &str) -> Result<Self, Self::Err> {
match s.trim() {
"forgejo" => Ok(SupportedForges::Forgejo),
_ => Err(SupportedForgesError::UnsupportedForge),
}
}
}
#[derive(Debug, Display, Clone, Hash, Serialize, Deserialize, PartialEq, Eq, PartialOrd, Ord)]
pub enum SupportedForgesError {
UnsupportedForge,
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_supported_forges() {
assert_eq!(SupportedForges::Forgejo.to_string(), "forgejo");
assert_eq!(
SupportedForges::from_str("forgejo").unwrap(),
SupportedForges::Forgejo
);
}
}