git-next/crates/forge-forgejo/src/lib.rs

144 lines
4.4 KiB
Rust
Raw Normal View History

pub mod branch;
mod file;
#[cfg(test)]
mod tests;
2024-05-23 16:50:36 +01:00
use git_next_config as config;
use git_next_git as git;
2024-05-23 16:50:36 +01:00
use kxio::network::{self, Network};
use tracing::{error, info, warn};
#[derive(Clone, Debug)]
2024-05-23 19:36:05 +01:00
pub struct ForgeJo {
repo_details: git::RepoDetails,
net: Network,
repo: git::Repository,
}
2024-05-23 19:36:05 +01:00
impl ForgeJo {
pub const fn new(repo_details: git::RepoDetails, net: Network, repo: git::Repository) -> Self {
Self {
repo_details,
net,
repo,
}
}
}
#[async_trait::async_trait]
2024-05-23 19:36:05 +01:00
impl git::ForgeLike for ForgeJo {
fn name(&self) -> String {
"forgejo".to_string()
}
2024-05-23 16:50:36 +01:00
async fn branches_get_all(&self) -> Result<Vec<config::BranchName>, git::branch::Error> {
branch::get_all(&self.repo_details, &self.net).await
}
async fn file_contents_get(
&self,
2024-05-23 16:50:36 +01:00
branch: &config::BranchName,
file_path: &str,
2024-05-23 16:50:36 +01:00
) -> Result<String, git::file::Error> {
file::contents_get(&self.repo_details, &self.net, branch, file_path).await
}
async fn branches_validate_positions(
&self,
repository: git::OpenRepository,
2024-05-23 16:50:36 +01:00
repo_config: config::RepoConfig,
) -> git::validation::Result {
branch::validate_positions(self, &repository, repo_config).await
}
fn branch_reset(
&self,
repository: &git::OpenRepository,
2024-05-23 16:50:36 +01:00
branch_name: config::BranchName,
to_commit: git::GitRef,
2024-05-16 14:45:25 +01:00
force: git::push::Force,
) -> git::push::Result {
repository.fetch()?;
repository.push(&self.repo_details, branch_name, to_commit, force)
}
async fn commit_status(&self, commit: &git::Commit) -> git::commit::Status {
let repo_details = &self.repo_details;
let hostname = &repo_details.forge.hostname();
let repo_path = &repo_details.repo_path;
let api_token = &repo_details.forge.token();
use secrecy::ExposeSecret;
let token = api_token.expose_secret();
let url = network::NetUrl::new(format!(
"https://{hostname}/api/v1/repos/{repo_path}/commits/{commit}/status?token={token}"
));
let request = network::NetRequest::new(
network::RequestMethod::Get,
url,
network::NetRequestHeaders::new(),
network::RequestBody::None,
network::ResponseType::Json,
None,
network::NetRequestLogging::None,
);
let result = self.net.get::<CombinedStatus>(request).await;
match result {
Ok(response) => {
match response.response_body() {
Some(status) => match status.state {
CommitStatusState::Success => git::commit::Status::Pass,
CommitStatusState::Pending => git::commit::Status::Pending,
CommitStatusState::Failure => git::commit::Status::Fail,
CommitStatusState::Error => git::commit::Status::Fail,
CommitStatusState::Blank => git::commit::Status::Pending,
},
None => {
warn!("No status found for commit");
git::commit::Status::Pending // assume issue is transient and allow retry
}
}
}
Err(e) => {
error!(?e, "Failed to get commit status");
git::commit::Status::Pending // assume issue is transient and allow retry
}
}
}
2024-05-23 16:50:36 +01:00
fn repo_clone(
&self,
gitdir: config::GitDir,
) -> Result<git::OpenRepository, git::repository::Error> {
let repository = if !gitdir.exists() {
info!("Local copy not found - cloning...");
self.repo.git_clone(&self.repo_details)?
} else {
self.repo.open(&gitdir)?
};
info!("Validating...");
git::validate(&repository, &self.repo_details)
2024-05-18 22:28:51 +01:00
.map_err(|e| git::repository::Error::Validation(e.to_string()))?;
Ok(repository)
}
}
#[derive(Debug, serde::Deserialize)]
pub struct CombinedStatus {
pub state: CommitStatusState,
}
#[derive(Debug, serde::Deserialize)]
pub enum CommitStatusState {
#[serde(rename = "success")]
Success,
#[serde(rename = "pending")]
Pending,
#[serde(rename = "failure")]
Failure,
#[serde(rename = "error")]
Error,
#[serde(rename = "")]
Blank,
}