use async_trait::async_trait; use juniper::{graphql_object, ID}; use validator::Validate; use super::{GitReference, RepositoryProvider}; use crate::{ context::ContextSourceIdValue, job::JobInfo, juniper::relay::NodeType, schema::{Context, Result}, }; #[derive(Validate)] pub struct CreateGitRepositoryInput { #[validate(regex( code = "name", path = "*crate::schema::constants::REPOSITORY_NAME_REGEX", message = "Invalid repository name" ))] pub name: String, #[validate(url(code = "gitUrl", message = "Invalid Git URL"))] pub git_url: String, pub refs: Option>, } pub struct GitRepository { pub id: juniper::ID, pub name: String, pub git_url: String, pub refs: Vec, pub job_info: JobInfo, } impl GitRepository { pub fn format_source_id(id: &ID) -> String { format!("git:{id}") } } #[graphql_object(context = Context, impl = [ContextSourceIdValue])] impl GitRepository { fn id(&self) -> &ID { &self.id } pub fn source_id(&self) -> String { Self::format_source_id(&self.id) } fn name(&self) -> &String { &self.name } fn git_url(&self) -> &String { &self.git_url } fn refs(&self) -> &Vec { &self.refs } fn job_info(&self) -> &JobInfo { &self.job_info } } impl NodeType for GitRepository { type Cursor = String; fn cursor(&self) -> Self::Cursor { self.id.to_string() } fn connection_type_name() -> &'static str { "RepositoryConnection" } fn edge_type_name() -> &'static str { "RepositoryEdge" } } #[async_trait] pub trait GitRepositoryService: Send + Sync + RepositoryProvider { async fn list( &self, after: Option, before: Option, first: Option, last: Option, ) -> Result>; async fn create(&self, name: String, git_url: String, refs: Vec) -> Result; async fn delete(&self, id: &ID) -> Result; async fn update(&self, id: &ID, refs: Vec) -> Result; }