adapted to new definition

code/app.py

@@ -6,7 +6,7 @@ import logging
 from typing import List
 import os
 
-from utils import clone_repository
+from utils import clone_repository, load_runner_script
 from setup_logging import setup_logging
 from gitea_request import GiteaRequest
 
@@ -31,7 +31,7 @@ async def root():
 async def test(request: Request):
     """ Test connection to server. """
     logging.debug('Content-Type: ', request.headers.get('content-type'))
-    HTTPException(
+    raise HTTPException(
         status_code=200,
         detail='test completed'
     )
@@ -59,7 +59,10 @@ def handle_event(request: GiteaRequest):
             detail="no runner_script.yml in repository root"
         )
     # load runner commands
-
+    runner_script = load_runner_script(path=runner_script_path)
+    for pipeline_name, pipeline_step in runner_script.pipelines.items():
+        print(pipeline_name)
+        print(pipeline_step)
 
     # send response
     raise HTTPException(

code/runner_script.py

@@ -0,0 +1,22 @@
+from pydantic import BaseModel
+from typing import List, Dict
+import yaml
+from pathlib import Path
+
+class Pipeline(BaseModel):
+    name: str
+    requirements: str
+    script: List[str]
+
+class RunnerScript(BaseModel):
+    pipelines: Dict[str, Pipeline]
+
+if __name__ == '__main__':
+    path = Path(__file__).parent.parent / 'runner_script.yml'
+    with open(path, 'r') as fh:
+        script = yaml.safe_load(fh)
+    runner_script = RunnerScript.parse_obj(script)
+    print(runner_script)
+    for k, v in runner_script.pipelines.items():
+        print(k)
+        print(v)

code/utils.py

@@ -1,9 +1,12 @@
 from pydantic import AnyHttpUrl
+from typing import List
 from pathlib import Path
 from git import Repo
 import logging
 import shutil
 import os
+import yaml
+from runner_script import RunnerScript
 
 def clone_repository(repo_url: AnyHttpUrl) -> Path:
     # extract repo name
@@ -19,3 +22,11 @@ def clone_repository(repo_url: AnyHttpUrl) -> Path:
     Repo.clone_from(url=repo_url, to_path=dst_dir)
     logging.debug('finished')
     return dst_dir
+
+def load_runner_script(path: Path) -> RunnerScript:
+    assert path.exists()
+    with open(path, 'r') as fh:
+        script = yaml.safe_load(fh)
+    runner_script = RunnerScript.parse_obj(script)
+    return runner_script
+    

req-dev.txt

@@ -37,6 +37,7 @@ pydantic==1.10.11
 Pygments==2.15.1
 python-dateutil==2.8.2
 python-dotenv==1.0.0
+PyYAML==6.0
 pyzmq==25.1.0
 six==1.16.0
 smmap==5.0.0

req-prod.txt

@@ -2,3 +2,4 @@ uvicorn==0.16.0
 fastapi==0.99.1
 GitPython==3.1.31
 python-dotenv==1.0.0
+PyYAML==6.0

runner_script.yml

@@ -0,0 +1,12 @@
+definitions:
+  steps:
+    step: &step-test
+      name: test
+      requirements: req-prod.txt
+      script:
+        - command arg1 arg2
+        - command2 arg1 arg2
+
+pipelines:
+  default:
+    <<: *step-test