Add Makefile for running CI jobs locally.

src/discovery.rs

@@ -5,33 +5,33 @@ use crate::crd_pipeline_run::PipelineRun;
 use crate::gitea_client::GiteaClient;
 use crate::gitea_client::Tree;
 use crate::gitea_client::TreeFileReference;
-use crate::in_repo_config::InRepoConfig;
+use crate::remote_config::RemoteConfig;
 use regex::Regex;
 use tracing::debug;
 
 pub(crate) async fn discover_webhook_bridge_config(
     gitea: &GiteaClient,
     repo_tree: &Tree,
-) -> Result<InRepoConfig, Box<dyn std::error::Error>> {
-    let in_repo_config_reference = repo_tree
+) -> Result<RemoteConfig, Box<dyn std::error::Error>> {
+    let remote_config_reference = repo_tree
         .files
         .iter()
         .filter(|file_reference| file_reference.path == ".webhook_bridge/webhook_bridge.toml")
         .next()
         .ok_or("File not found in remote repo: .webhook_bridge/webhook_bridge.toml.")?;
 
-    let in_repo_config_contents =
-        String::from_utf8(gitea.read_file(in_repo_config_reference).await?)?;
-    let parsed_in_repo_config = InRepoConfig::from_str(in_repo_config_contents)?;
+    let remote_config_contents =
+        String::from_utf8(gitea.read_file(remote_config_reference).await?)?;
+    let parsed_remote_config = RemoteConfig::from_str(remote_config_contents)?;
 
-    Ok(parsed_in_repo_config)
+    Ok(parsed_remote_config)
 }
 
 pub(crate) async fn discover_matching_push_triggers<RE: AsRef<str>>(
     gitea: &GiteaClient,
     repo_tree: &Tree,
     git_ref: RE,
-    in_repo_config: &InRepoConfig,
+    remote_config: &RemoteConfig,
 ) -> Result<Vec<PipelineTemplate>, Box<dyn std::error::Error>> {
     let mut ret = Vec::new();
     let ref_to_branch_regex = Regex::new(r"refs/heads/(?P<branch>.+)")?;
@@ -41,7 +41,7 @@ pub(crate) async fn discover_matching_push_triggers<RE: AsRef<str>>(
     let branch = &captures["branch"];
     debug!("Detected branch from push as {:?}", branch);
 
-    let push_triggers = in_repo_config.get_push_triggers_for_branch(branch)?;
+    let push_triggers = remote_config.get_push_triggers_for_branch(branch)?;
     for trigger in push_triggers {
         let path_to_source = normalize_path(Path::new(".webhook_bridge").join(&trigger.source));
         let pipeline_template = repo_tree

src/kubernetes.rs

@@ -24,7 +24,12 @@ pub(crate) async fn run_pipelines(
     tracing::debug!("Using crd: {}", serde_json::to_string(&PipelineRun::crd())?);
 
     for mut pipeline in pipelines {
-        debug!("Kicking off {}", pipeline.name);
+        info!(
+            "Kicking off {} for repo {}/{}",
+            pipeline.name,
+            hook.get_repo_owner()?,
+            hook.get_repo_name()?,
+        );
         if pipeline.pipeline.spec.params.is_none() {
             pipeline.pipeline.spec.params = Some(Vec::new());
         }

src/main.rs

@@ -25,8 +25,8 @@ use self::discovery::discover_webhook_bridge_config;
 use self::gitea_client::GiteaClient;
 use self::hook_push::HookPush;
 use self::hook_push::PipelineParamters;
-use self::in_repo_config::InRepoConfig;
 use self::kubernetes::run_pipelines;
+use self::remote_config::RemoteConfig;
 use self::webhook::hook;
 use self::webhook::verify_signature;
 use kube::CustomResourceExt;
@@ -35,8 +35,8 @@ mod crd_pipeline_run;
 mod discovery;
 mod gitea_client;
 mod hook_push;
-mod in_repo_config;
 mod kubernetes;
+mod remote_config;
 mod webhook;
 
 const EXAMPLE_WEBHOOK_PAYLOAD: &'static str = include_str!("../example_webhook_payload.json");
@@ -68,9 +68,9 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             webhook_payload.get_pull_base_sha()?,
         )
         .await?;
-    let in_repo_config = discover_webhook_bridge_config(&gitea, &repo_tree).await?;
+    let remote_config = discover_webhook_bridge_config(&gitea, &repo_tree).await?;
     let pipelines =
-        discover_matching_push_triggers(&gitea, &repo_tree, "refs/heads/main", &in_repo_config)
+        discover_matching_push_triggers(&gitea, &repo_tree, "refs/heads/main", &remote_config)
             .await?;
 
     run_pipelines(webhook_payload, pipelines, kubernetes_client).await?;

src/remote_config.rs

@@ -5,7 +5,7 @@ use serde::Serialize;
 /// The webhook_bridge.toml file that lives inside repos that have their CI triggered by webhook_bridge.
 #[derive(Serialize, Deserialize, Clone, Debug)]
 #[serde(deny_unknown_fields)]
-pub(crate) struct InRepoConfig {
+pub(crate) struct RemoteConfig {
     pub(crate) version: String,
 
     #[serde(default, skip_serializing_if = "Vec::is_empty")]
@@ -29,16 +29,16 @@ pub(crate) struct TriggerPush {
     pub(crate) skip_branches: Vec<String>,
 }
 
-impl InRepoConfig {
+impl RemoteConfig {
     pub(crate) fn from_str<S: AsRef<str>>(
         contents: S,
-    ) -> Result<InRepoConfig, Box<dyn std::error::Error>> {
-        let parsed_in_repo_config: InRepoConfig = toml::from_str(contents.as_ref())?;
+    ) -> Result<RemoteConfig, Box<dyn std::error::Error>> {
+        let parsed_remote_config: RemoteConfig = toml::from_str(contents.as_ref())?;
         assert!(
-            parsed_in_repo_config.version == "0.0.1",
+            parsed_remote_config.version == "0.0.1",
             "We only support version 0.0.1 currently."
         );
-        Ok(parsed_in_repo_config)
+        Ok(parsed_remote_config)
     }
 
     pub(crate) fn get_push_triggers_for_branch<B: AsRef<str>>(