Skip to content

Commit 949bb6c

Browse files
pepicrftclaude
pepicrft
and
claude
committed
style: apply cargo fmt formatting
🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>
1 parent 2a14a27 commit 949bb6c

4 files changed

Lines changed: 150 additions & 66 deletions

File tree

‎src/forgejo.rs‎

Lines changed: 48 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -33,12 +33,17 @@ pub fn list_jobs(path: &PathBuf) -> Result<()> {
3333
path.join(".gitea").join("workflows"),
3434
];
3535

36-
let workflows_dir = workflows_dirs.iter()
36+
let workflows_dir = workflows_dirs
37+
.iter()
3738
.find(|d| d.exists() && d.is_dir())
38-
.ok_or_else(|| anyhow::anyhow!("No .forgejo/workflows or .gitea/workflows directory found in {}", path.display()))?;
39+
.ok_or_else(|| {
40+
anyhow::anyhow!(
41+
"No .forgejo/workflows or .gitea/workflows directory found in {}",
42+
path.display()
43+
)
44+
})?;
3945

40-
let entries = std::fs::read_dir(workflows_dir)
41-
.context("Failed to read workflows directory")?;
46+
let entries = std::fs::read_dir(workflows_dir).context("Failed to read workflows directory")?;
4247

4348
println!("\n{}", "Available workflows and jobs:".green().bold());
4449

@@ -47,29 +52,35 @@ pub fn list_jobs(path: &PathBuf) -> Result<()> {
4752
let path = entry.path();
4853

4954
if path.extension().and_then(|s| s.to_str()) == Some("yml")
50-
|| path.extension().and_then(|s| s.to_str()) == Some("yaml") {
51-
55+
|| path.extension().and_then(|s| s.to_str()) == Some("yaml")
56+
{
5257
let filename = path.file_name().unwrap().to_string_lossy();
53-
let content = std::fs::read_to_string(&path)
54-
.context(format!("Failed to read {}", filename))?;
58+
let content =
59+
std::fs::read_to_string(&path).context(format!("Failed to read {}", filename))?;
5560

56-
let workflow: ForgejoWorkflow = serde_yaml::from_str(&content)
57-
.context(format!("Failed to parse {}", filename))?;
61+
let workflow: ForgejoWorkflow =
62+
serde_yaml::from_str(&content).context(format!("Failed to parse {}", filename))?;
5863

5964
let workflow_name = workflow.name.as_deref().unwrap_or(filename.as_ref());
60-
println!("\n {} {}", "Workflow:".cyan().bold(), workflow_name.yellow());
65+
println!(
66+
"\n {} {}",
67+
"Workflow:".cyan().bold(),
68+
workflow_name.yellow()
69+
);
6170

6271
for (job_name, job) in workflow.jobs {
6372
let runs_on = job.runs_on.as_deref().unwrap_or("N/A");
6473
let steps_count = job.steps.as_ref().map(|s| s.len()).unwrap_or(0);
6574
let container = job.container.as_deref().unwrap_or("N/A");
6675

67-
println!(" {} {} [runs-on: {}, container: {}, steps: {}]",
76+
println!(
77+
" {} {} [runs-on: {}, container: {}, steps: {}]",
6878
"•".cyan(),
6979
job_name.yellow(),
7080
runs_on.blue(),
7181
container.dimmed(),
72-
steps_count.to_string().dimmed());
82+
steps_count.to_string().dimmed()
83+
);
7384
}
7485
}
7586
}
@@ -85,26 +96,34 @@ pub async fn run_job(path: &PathBuf, job_name: &str) -> Result<()> {
8596
path.join(".gitea").join("workflows"),
8697
];
8798

88-
let workflows_dir = workflows_dirs.iter()
99+
let workflows_dir = workflows_dirs
100+
.iter()
89101
.find(|d| d.exists() && d.is_dir())
90-
.ok_or_else(|| anyhow::anyhow!("No .forgejo/workflows or .gitea/workflows directory found in {}", path.display()))?;
102+
.ok_or_else(|| {
103+
anyhow::anyhow!(
104+
"No .forgejo/workflows or .gitea/workflows directory found in {}",
105+
path.display()
106+
)
107+
})?;
91108

92-
let entries = std::fs::read_dir(workflows_dir)
93-
.context("Failed to read workflows directory")?;
109+
let entries = std::fs::read_dir(workflows_dir).context("Failed to read workflows directory")?;
94110

95111
for entry in entries {
96112
let entry = entry?;
97113
let path = entry.path();
98114

99115
if path.extension().and_then(|s| s.to_str()) == Some("yml")
100-
|| path.extension().and_then(|s| s.to_str()) == Some("yaml") {
101-
116+
|| path.extension().and_then(|s| s.to_str()) == Some("yaml")
117+
{
102118
let content = std::fs::read_to_string(&path)?;
103119
let workflow: ForgejoWorkflow = serde_yaml::from_str(&content)?;
104120

105121
if let Some(job) = workflow.jobs.get(job_name) {
106122
println!("{}", format!("Executing job: {}", job_name).green().bold());
107-
println!("Runs on: {}", job.runs_on.as_deref().unwrap_or("N/A").blue());
123+
println!(
124+
"Runs on: {}",
125+
job.runs_on.as_deref().unwrap_or("N/A").blue()
126+
);
108127

109128
if let Some(container) = &job.container {
110129
println!("Container: {}", container.dimmed());
@@ -118,12 +137,19 @@ pub async fn run_job(path: &PathBuf, job_name: &str) -> Result<()> {
118137
} else if let Some(uses) = &step.uses {
119138
println!(" {}. Uses: {}", i + 1, uses.dimmed());
120139
} else if let Some(run) = &step.run {
121-
println!(" {}. Run: {}", i + 1, run.lines().next().unwrap_or("").dimmed());
140+
println!(
141+
" {}. Run: {}",
142+
i + 1,
143+
run.lines().next().unwrap_or("").dimmed()
144+
);
122145
}
123146
}
124147
}
125148

126-
println!("\n{}", "Note: Actual execution is not yet implemented.".yellow());
149+
println!(
150+
"\n{}",
151+
"Note: Actual execution is not yet implemented.".yellow()
152+
);
127153
println!("This would execute the above steps in the specified environment.");
128154
return Ok(());
129155
}

‎src/github.rs‎

Lines changed: 34 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@ pub fn list_jobs(path: &PathBuf) -> Result<()> {
3232
anyhow::bail!("No .github/workflows directory found in {}", path.display());
3333
}
3434

35-
let entries = std::fs::read_dir(&workflows_dir)
36-
.context("Failed to read workflows directory")?;
35+
let entries =
36+
std::fs::read_dir(&workflows_dir).context("Failed to read workflows directory")?;
3737

3838
println!("\n{}", "Available workflows and jobs:".green().bold());
3939

@@ -42,27 +42,33 @@ pub fn list_jobs(path: &PathBuf) -> Result<()> {
4242
let path = entry.path();
4343

4444
if path.extension().and_then(|s| s.to_str()) == Some("yml")
45-
|| path.extension().and_then(|s| s.to_str()) == Some("yaml") {
46-
45+
|| path.extension().and_then(|s| s.to_str()) == Some("yaml")
46+
{
4747
let filename = path.file_name().unwrap().to_string_lossy();
48-
let content = std::fs::read_to_string(&path)
49-
.context(format!("Failed to read {}", filename))?;
48+
let content =
49+
std::fs::read_to_string(&path).context(format!("Failed to read {}", filename))?;
5050

51-
let workflow: GitHubWorkflow = serde_yaml::from_str(&content)
52-
.context(format!("Failed to parse {}", filename))?;
51+
let workflow: GitHubWorkflow =
52+
serde_yaml::from_str(&content).context(format!("Failed to parse {}", filename))?;
5353

5454
let workflow_name = workflow.name.as_deref().unwrap_or(filename.as_ref());
55-
println!("\n {} {}", "Workflow:".cyan().bold(), workflow_name.yellow());
55+
println!(
56+
"\n {} {}",
57+
"Workflow:".cyan().bold(),
58+
workflow_name.yellow()
59+
);
5660

5761
for (job_name, job) in workflow.jobs {
5862
let runs_on = job.runs_on.as_deref().unwrap_or("N/A");
5963
let steps_count = job.steps.as_ref().map(|s| s.len()).unwrap_or(0);
6064

61-
println!(" {} {} [runs-on: {}, steps: {}]",
65+
println!(
66+
" {} {} [runs-on: {}, steps: {}]",
6267
"•".cyan(),
6368
job_name.yellow(),
6469
runs_on.blue(),
65-
steps_count.to_string().dimmed());
70+
steps_count.to_string().dimmed()
71+
);
6672
}
6773
}
6874
}
@@ -78,22 +84,25 @@ pub async fn run_job(path: &PathBuf, job_name: &str) -> Result<()> {
7884
anyhow::bail!("No .github/workflows directory found in {}", path.display());
7985
}
8086

81-
let entries = std::fs::read_dir(&workflows_dir)
82-
.context("Failed to read workflows directory")?;
87+
let entries =
88+
std::fs::read_dir(&workflows_dir).context("Failed to read workflows directory")?;
8389

8490
for entry in entries {
8591
let entry = entry?;
8692
let path = entry.path();
8793

8894
if path.extension().and_then(|s| s.to_str()) == Some("yml")
89-
|| path.extension().and_then(|s| s.to_str()) == Some("yaml") {
90-
95+
|| path.extension().and_then(|s| s.to_str()) == Some("yaml")
96+
{
9197
let content = std::fs::read_to_string(&path)?;
9298
let workflow: GitHubWorkflow = serde_yaml::from_str(&content)?;
9399

94100
if let Some(job) = workflow.jobs.get(job_name) {
95101
println!("{}", format!("Executing job: {}", job_name).green().bold());
96-
println!("Runs on: {}", job.runs_on.as_deref().unwrap_or("N/A").blue());
102+
println!(
103+
"Runs on: {}",
104+
job.runs_on.as_deref().unwrap_or("N/A").blue()
105+
);
97106

98107
if let Some(steps) = &job.steps {
99108
println!("\n{}", "Steps:".cyan());
@@ -103,12 +112,19 @@ pub async fn run_job(path: &PathBuf, job_name: &str) -> Result<()> {
103112
} else if let Some(uses) = &step.uses {
104113
println!(" {}. Uses: {}", i + 1, uses.dimmed());
105114
} else if let Some(run) = &step.run {
106-
println!(" {}. Run: {}", i + 1, run.lines().next().unwrap_or("").dimmed());
115+
println!(
116+
" {}. Run: {}",
117+
i + 1,
118+
run.lines().next().unwrap_or("").dimmed()
119+
);
107120
}
108121
}
109122
}
110123

111-
println!("\n{}", "Note: Actual execution is not yet implemented.".yellow());
124+
println!(
125+
"\n{}",
126+
"Note: Actual execution is not yet implemented.".yellow()
127+
);
112128
println!("This would execute the above steps in the specified environment.");
113129
return Ok(());
114130
}

‎src/gitlab.rs‎

Lines changed: 35 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -27,16 +27,25 @@ pub fn list_jobs(path: &PathBuf) -> Result<()> {
2727
anyhow::bail!("No .gitlab-ci.yml found in {}", path.display());
2828
}
2929

30-
let content = std::fs::read_to_string(&gitlab_ci_path)
31-
.context("Failed to read .gitlab-ci.yml")?;
30+
let content =
31+
std::fs::read_to_string(&gitlab_ci_path).context("Failed to read .gitlab-ci.yml")?;
3232

33-
let ci: serde_yaml::Value = serde_yaml::from_str(&content)
34-
.context("Failed to parse .gitlab-ci.yml")?;
33+
let ci: serde_yaml::Value =
34+
serde_yaml::from_str(&content).context("Failed to parse .gitlab-ci.yml")?;
3535

3636
println!("\n{}", "Available jobs:".green().bold());
3737

3838
if let Some(obj) = ci.as_mapping() {
39-
let reserved_keys = vec!["stages", "variables", "default", "include", "workflow", "image", "before_script", "after_script"];
39+
let reserved_keys = vec![
40+
"stages",
41+
"variables",
42+
"default",
43+
"include",
44+
"workflow",
45+
"image",
46+
"before_script",
47+
"after_script",
48+
];
4049

4150
for (key, value) in obj {
4251
if let Some(key_str) = key.as_str() {
@@ -45,19 +54,23 @@ pub fn list_jobs(path: &PathBuf) -> Result<()> {
4554
}
4655

4756
if let Some(job) = value.as_mapping() {
48-
let stage = job.get(&serde_yaml::Value::String("stage".to_string()))
57+
let stage = job
58+
.get(&serde_yaml::Value::String("stage".to_string()))
4959
.and_then(|v| v.as_str())
5060
.unwrap_or("default");
5161

52-
let image = job.get(&serde_yaml::Value::String("image".to_string()))
62+
let image = job
63+
.get(&serde_yaml::Value::String("image".to_string()))
5364
.and_then(|v| v.as_str())
5465
.unwrap_or("N/A");
5566

56-
println!(" {} {} [stage: {}, image: {}]",
67+
println!(
68+
" {} {} [stage: {}, image: {}]",
5769
"•".cyan(),
5870
key_str.yellow(),
5971
stage.blue(),
60-
image.dimmed());
72+
image.dimmed()
73+
);
6174
}
6275
}
6376
}
@@ -74,19 +87,20 @@ pub async fn run_job(path: &PathBuf, job_name: &str) -> Result<()> {
7487
anyhow::bail!("No .gitlab-ci.yml found in {}", path.display());
7588
}
7689

77-
let content = std::fs::read_to_string(&gitlab_ci_path)
78-
.context("Failed to read .gitlab-ci.yml")?;
90+
let content =
91+
std::fs::read_to_string(&gitlab_ci_path).context("Failed to read .gitlab-ci.yml")?;
7992

80-
let ci: serde_yaml::Value = serde_yaml::from_str(&content)
81-
.context("Failed to parse .gitlab-ci.yml")?;
93+
let ci: serde_yaml::Value =
94+
serde_yaml::from_str(&content).context("Failed to parse .gitlab-ci.yml")?;
8295

8396
if let Some(obj) = ci.as_mapping() {
8497
if let Some(job) = obj.get(&serde_yaml::Value::String(job_name.to_string())) {
8598
if let Some(job_map) = job.as_mapping() {
8699
println!("{}", format!("Executing job: {}", job_name).green().bold());
87100

88101
// Get the script
89-
if let Some(script) = job_map.get(&serde_yaml::Value::String("script".to_string())) {
102+
if let Some(script) = job_map.get(&serde_yaml::Value::String("script".to_string()))
103+
{
90104
if let Some(script_array) = script.as_sequence() {
91105
println!("\n{}", "Script commands:".cyan());
92106
for cmd in script_array {
@@ -95,8 +109,13 @@ pub async fn run_job(path: &PathBuf, job_name: &str) -> Result<()> {
95109
}
96110
}
97111

98-
println!("\n{}", "Note: Actual execution is not yet implemented.".yellow());
99-
println!("This would execute the above commands in the specified environment.");
112+
println!(
113+
"\n{}",
114+
"Note: Actual execution is not yet implemented.".yellow()
115+
);
116+
println!(
117+
"This would execute the above commands in the specified environment."
118+
);
100119
}
101120
}
102121

0 commit comments

Comments
 (0)