gen-job-list: add verbose option

Signed-off-by: Kent Overstreet <kent.overstreet@linux.dev>

src/bin/gen-job-list.rs

@@ -12,6 +12,7 @@ use file_lock::{FileLock, FileOptions};
 use memoize::memoize;
 use anyhow;
 use chrono::Utc;
+use clap::Parser;
 
 #[memoize]
 fn get_subtests(test_path: PathBuf) -> Vec<String> {
@@ -174,7 +175,9 @@ fn rc_test_jobs(rc: &CiConfig, repo: &git2::Repository,
     ret
 }
 
-fn write_test_jobs(rc: &CiConfig, jobs_in: Vec<TestJob>) -> anyhow::Result<()> {
+fn write_test_jobs(rc: &CiConfig, jobs_in: Vec<TestJob>, verbose: bool) -> anyhow::Result<()> {
+    eprintln!("Writing new test jobs");
+
     let jobs_fname      = rc.ktest.output_dir.join("jobs");
     let jobs_fname_new  = rc.ktest.output_dir.join("jobs.new");
     let mut jobs_out    = std::io::BufWriter::new(File::create(&jobs_fname_new)?);
@@ -259,23 +262,33 @@ fn fetch_remotes(rc: &CiConfig, repo: &git2::Repository) -> anyhow::Result<bool>
     Ok(true)
 }
 
-fn update_jobs(rc: &CiConfig, repo: &git2::Repository) -> anyhow::Result<()> {
+fn update_jobs(rc: &CiConfig, repo: &git2::Repository, verbose: bool) -> anyhow::Result<()> {
     if !fetch_remotes(rc, repo)? {
+        eprintln!("remotes unchanged, skipping updating joblist");
         return Ok(());
     }
 
     let lockfile = rc.ktest.output_dir.join("jobs.lock");
     let filelock = FileLock::lock(lockfile, true, FileOptions::new().create(true).write(true))?;
 
-    let jobs_in = rc_test_jobs(rc, repo, false);
-    write_test_jobs(rc, jobs_in)?;
+    let jobs_in = rc_test_jobs(rc, repo, verbose);
+    write_test_jobs(rc, jobs_in, verbose)?;
 
     drop(filelock);
 
     Ok(())
 }
 
+#[derive(Parser)]
+#[command(author, version, about, long_about = None)]
+struct Args {
+    #[arg(short, long)]
+    verbose:    bool,
+}
+
 fn main() {
+    let args = Args::parse();
+
     let rc = ciconfig_read();
     if let Err(e) = rc {
         eprintln!("could not read config; {}", e);
@@ -291,5 +304,7 @@ fn main() {
     }
     let repo = repo.unwrap();
 
-    update_jobs(&rc, &repo).ok();
+    if let Err(e) = update_jobs(&rc, &repo, args.verbose) {
+        eprintln!("update_jobs() error: {}", e);
+    }
 }

src/bin/get-test-job.rs

@@ -4,8 +4,8 @@ use std::process;
 use ci_cgi::{Ktestrc, ciconfig_read, lockfile_exists};
 use ci_cgi::{Worker, workers_update};
 use file_lock::{FileLock, FileOptions};
-use clap::Parser;
 use chrono::Utc;
+use clap::Parser;
 
 #[derive(Debug)]
 struct TestJob {
@@ -131,10 +131,6 @@ fn get_and_lock_job(rc: &Ktestrc) -> Option<TestJob> {
 }
 
 fn main() {
-    std::process::Command::new("gen-job-list")
-        .output()
-        .expect("failed to execute gen-job-list");
-
     let args = Args::parse();
 
     let rc = ciconfig_read();