add command files

Author: tarekbadrsh

cli/cdevents/cli/__main__.py

@@ -7,9 +7,17 @@
 import yaml
 
 from cdevents.cli.constants import LOGGING_CONFIGURATION_FILE
-from cdevents.cli.build import finished, queued, started
 from cdevents.cli.utils import add_disclaimer_text
 
+from cdevents.cli.build import finished, queued, started
+from cdevents.cli.artifact import packaged, published
+from cdevents.cli.branch import created as branch_created, deleted as branch_deleted
+from cdevents.cli.env import created as env_created, deleted as env_deleted, modified as env_modified
+from cdevents.cli.pipelinerun import started as pipe_started, finished as pipe_finished, queued as pipe_queued
+from cdevents.cli.service import deployed as service_deployed, upgraded as service_upgraded, removed as service_removed, rolledback as service_rolledback
+from cdevents.cli.taskrun import started as taskrun_started, finished as taskrun_finished 
+
+
 def configure_logging():
     """Configures logging from file."""
     config_file = Path(LOGGING_CONFIGURATION_FILE)
@@ -26,25 +34,61 @@ def build():
 build.add_command(started)
 
 
-# @click.group(help=add_disclaimer_text("""Commands with no interaction with hostlog."""))
-# def offline():
-#     """Function for command group offline."""
+@click.group(help=add_disclaimer_text("""Commands Artifact related CloudEvent."""))
+def artifact():
+    """Click group for command 'artifact'."""
+
+artifact.add_command(packaged)
+artifact.add_command(published)
+
+
+@click.group(help=add_disclaimer_text("""Commands Branch related CloudEvent."""))
+def branch():
+    """Click group for command 'branch'."""
+
+branch.add_command(branch_created)
+branch.add_command(branch_deleted)
+
+
+@click.group(help=add_disclaimer_text("""Commands Environment related CloudEvent."""))
+def env():
+    """Click group for command 'environment'."""
+
+env.add_command(env_created)
+env.add_command(env_deleted)
+env.add_command(env_modified)
+
+
+
+
+@click.group(help=add_disclaimer_text("""Commands PipelineRun related CloudEvent."""))
+def pipelinerun():
+    """Click group for command 'environment'."""
+
+pipelinerun.add_command(pipe_started)
+pipelinerun.add_command(pipe_finished)
+pipelinerun.add_command(pipe_queued)
+
+
+
+@click.group(help=add_disclaimer_text("""Commands Service related CloudEvent."""))
+def service():
+    """Click group for command 'service'."""
 
+service.add_command(service_deployed)
+service.add_command(service_upgraded)
+service.add_command(service_removed)
+service.add_command(service_rolledback)
 
-# offline.add_command(pcap_to_hdf5)
-# TODO: activate line when command is implemented
-# offline.add_command(visualize)
-# offline.add_command(create_dissector)
-# offline.add_command(convert_to_xviz)
-# offline.add_command(topic_configuration)
 
+@click.group(help=add_disclaimer_text("""Commands TaskRun related CloudEvent."""))
+def taskrun():
+    """Click group for command 'taskrun'."""
 
-# @click.group(help=add_disclaimer_text("Commands for local web UI."))
-# def web():
-#     """Click group for command 'web'."""
+taskrun.add_command(taskrun_started)
+taskrun.add_command(taskrun_finished)
 
 
-# web.add_command(web_start)
 
 
 @click.group(
@@ -60,8 +104,12 @@ def cli():
 
 
 cli.add_command(build)
-# cli.add_command(offline)
-# cli.add_command(web)
+cli.add_command(artifact)
+cli.add_command(branch)
+cli.add_command(env)
+cli.add_command(pipelinerun)
+cli.add_command(service)
+cli.add_command(taskrun)
 
 if __name__ == "__main__":
     cli()

cli/cdevents/cli/artifact.py

@@ -0,0 +1,110 @@
+"""Module for cli artifact commands."""
+from __future__ import annotations
+import os
+
+from typing import List
+
+import click
+import requests
+
+from cloudevents.http import CloudEvent, to_structured
+
+from cdevents.cli.utils import (
+    add_disclaimer_text,
+    print_function_args,
+)
+
+
+# pylint: disable=unused-argument
+def common_artifact_options(function):
+    """Decorator for common cli options for artifact."""
+    function = click.option(
+        "--cde_sink",
+        "-c",
+        required=False,
+        type=str,
+        default=lambda: os.environ.get("CDE_SINK", "http://localhost:8080"),
+        help="CDE_SINK",
+    )(function)
+    function = click.option(
+        "--id",
+        "-i",
+        required=False,
+        type=str,
+        help="Artifact Id.",
+    )(function)
+    function = click.option(
+        "--name",
+        "-n",
+        required=False,
+        type=str,
+        help="Artifact Name.",
+    )(function)
+    function = click.option(
+        "--version",
+        "-v",
+        required=False,
+        type=str,
+        help="Artifact Version.",
+    )(function)
+    function = click.option(
+        "--data",
+        "-d",
+        required=False,
+        type=(str,str),
+        multiple=True,
+        help="Artifact Data.",
+    )(function)
+
+    return function
+
+
+@click.command(help=add_disclaimer_text("Artifact Packaged CloudEvent."))
+@common_artifact_options
+def packaged(
+    cde_sink: str,
+    id: str,
+    name: str = None,
+    version: str = None,
+    data :List[str] = None,
+):
+    print_function_args()
+    attributes = {
+        "type": "cd.artifact.packaged.v1",
+        "source": "cde-cli",
+        "extensions": {
+            "artifactid": id,
+            "artifactname": name,
+            "artifactversion": version,
+        },
+    }
+    event = CloudEvent(attributes, dict(data))
+    headers, body = to_structured(event)
+
+    # send and print event
+    requests.post(cde_sink, headers=headers, data=body)
+
+@click.command(help=add_disclaimer_text("Artifact Published CloudEvent."))
+@common_artifact_options
+def published(
+    cde_sink: str,
+    id: str,
+    name: str = None,
+    version: str = None,
+    data :List[str] = None,
+):
+    print_function_args()
+    attributes = {
+        "type": "cd.artifact.published.v1",
+        "source": "cde-cli",
+        "extensions": {
+            "artifactid": id,
+            "artifactname": name,
+            "artifactversion": version,
+        },
+    }
+    event = CloudEvent(attributes, dict(data))
+    headers, body = to_structured(event)
+
+    # send and print event
+    requests.post(cde_sink, headers=headers, data=body)

cli/cdevents/cli/branch.py

@@ -0,0 +1,112 @@
+"""Module for cli branch commands."""
+from __future__ import annotations
+import os
+
+from typing import List
+
+import click
+import requests
+
+from cloudevents.http import CloudEvent, to_structured
+
+from cdevents.cli.utils import (
+    add_disclaimer_text,
+    print_function_args,
+)
+
+
+# pylint: disable=unused-argument
+def common_branch_options(function):
+    """Decorator for common cli options for branch."""
+    function = click.option(
+        "--cde_sink",
+        "-c",
+        required=False,
+        type=str,
+        default=lambda: os.environ.get("CDE_SINK", "http://localhost:8080"),
+        help="CDE_SINK",
+    )(function)
+    function = click.option(
+        "--id",
+        "-i",
+        required=False,
+        type=str,
+        help="Branch Id.",
+    )(function)
+    function = click.option(
+        "--name",
+        "-n",
+        required=False,
+        type=str,
+        help="Branch Name.",
+    )(function)
+    function = click.option(
+        "--repoid",
+        "-v",
+        required=False,
+        type=str,
+        help="Branch Repository Id.",
+    )(function)
+    function = click.option(
+        "--data",
+        "-d",
+        required=False,
+        type=(str,str),
+        multiple=True,
+        help="Branch Data.",
+    )(function)
+
+    return function
+
+
+@click.command(help=add_disclaimer_text("Branch Created CloudEvent."))
+@common_branch_options
+def created(
+    cde_sink: str,
+    id: str,
+    name: str = None,
+    repoid: str = None,
+    data :List[str] = None,
+):
+    print_function_args()
+    attributes = {
+        "type": "cd.repository.branch.created.v1",
+        "source": "cde-cli",
+        "extensions": {
+            "branchid": id,
+            "branchname": name,
+            "branchrepositoryid": repoid,
+        },
+    }
+    event = CloudEvent(attributes, dict(data))
+    headers, body = to_structured(event)
+
+    # send and print event
+    requests.post(cde_sink, headers=headers, data=body)
+
+
+@click.command(help=add_disclaimer_text("Branch Deleted CloudEvent."))
+@common_branch_options
+def deleted(
+    cde_sink: str,
+    id: str,
+    name: str = None,
+    repoid: str = None,
+    data :List[str] = None,
+):
+    print_function_args()
+    attributes = {
+        "type": "cd.repository.branch.deleted.v1",
+        "source": "cde-cli",
+        "extensions": {
+            "branchid": id,
+            "branchname": name,
+            "branchrepositoryid": repoid,
+        },
+    }
+    event = CloudEvent(attributes, dict(data))
+    headers, body = to_structured(event)
+
+    # send and print event
+    requests.post(cde_sink, headers=headers, data=body)
+