Change detection via git

alice-ci/setup.cfg

@@ -1,6 +1,6 @@
 [metadata]
 name = alice-ci
-version = 0.0.5
+version = 0.0.6
 author = Daniel Gyulai
 description = Alice CI framework
 long_description = file: README.md

alice-ci/src/alice/cli.py

@@ -30,8 +30,8 @@ def parse_jobs(args):
         print("Begin pipeline steps...")
         for step in args.steps:
             if step in jobParser.jobs:
-                jobParser.execute_job(step)
-                print(f"[Step] {step}: SUCCESS")
+                status = jobParser.execute_job(step)
+                print(f"[Step] {step}: {status}")
             else:
                 print(f"Step {step} not found in {args.input}")
                 exit(1)

alice-ci/src/alice/utils.py

@@ -1,3 +1,5 @@
+import os
+import subprocess
 import yaml
 
 from alice.exceptions import ConfigException
@@ -44,10 +46,41 @@ class ConfigParser:
                 print(f"[Alice] Parsed jobs: {', '.join(jobs.keys())}")
             return jobs
         else:
-            raise ConfigException("[Alice] No jobs defined in config")
+            raise ConfigException("No jobs defined in config")
+
+    def __is_changed(self, changes):
+        try:                
+            target = changes["branch"]
+            paths = []
+            for path in changes["paths"]:
+                paths.append(os.path.abspath(path))
+            print(paths)
+            # TODO: Error handling
+            command = ["git", "diff", "--name-only", target]
+            with subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE) as p:
+                p.wait()
+                for line in p.stdout:
+                    change_path = os.path.abspath(line.decode("UTF-8").strip())
+                    for path in paths:
+                        spec_path = os.path.abspath(path)
+                        if change_path.startswith(spec_path):
+                            print(f"Modified file: {change_path}")
+                            print(f"Path match: {path}")
+                            return True
+        except KeyError:
+            raise ConfigException(f"Invalid 'changes' config: {changes}")
+        return False
 
     def execute_job(self, job_name):
         if job_name in self.jobs:
-            # Pass the job_spec to a runner
-            runner = self.factory.get_runner(self.jobs[job_name]["type"])
-            runner.run(self.jobs[job_name])
+            job_spec = self.jobs[job_name]
+            should_run = True
+            if "changes" in job_spec:
+                should_run = self.__is_changed(job_spec["changes"])
+            if should_run:
+                runner = self.factory.get_runner(job_spec["type"])
+                runner.run(job_spec)
+                return "SUCCESS"
+            else:
+                print("SKIP, no change detected")
+

ci-examples/full.yaml

@@ -18,6 +18,10 @@ runners:
 jobs:
   - name: env
     type: python
+    changes:
+      branch: origin/master
+      paths:
+        - "docs"
     env:
       - name: B
         value: E