add repository event

Author: tarekbadrsh

cli/cdevents/cli/__main__.py

@@ -18,6 +18,9 @@
 from cdevents.cli.pipelinerun import finished as pipe_finished
 from cdevents.cli.pipelinerun import queued as pipe_queued
 from cdevents.cli.pipelinerun import started as pipe_started
+from cdevents.cli.repository import created as repo_created
+from cdevents.cli.repository import deleted as repo_deleted
+from cdevents.cli.repository import modified as repo_modified
 from cdevents.cli.service import deployed as service_deployed
 from cdevents.cli.service import removed as service_removed
 from cdevents.cli.service import rolledback as service_rolledback
@@ -81,6 +84,14 @@ def pipelinerun():
 pipelinerun.add_command(pipe_finished)
 pipelinerun.add_command(pipe_queued)
 
+@click.group(help=add_disclaimer_text("""Commands Repository related CloudEvent."""))
+def repository():
+    """Click group for command 'repository'."""
+
+repository.add_command(repo_created)
+repository.add_command(repo_modified)
+repository.add_command(repo_deleted)
+
 
 @click.group(help=add_disclaimer_text("""Commands Service related CloudEvent."""))
 def service():
@@ -119,6 +130,7 @@ def cli():
 cli.add_command(branch)
 cli.add_command(env)
 cli.add_command(pipelinerun)
+cli.add_command(repository)
 cli.add_command(service)
 cli.add_command(taskrun)
 

cli/cdevents/cli/repository.py

@@ -0,0 +1,94 @@
+"""Module for cli repository commands."""
+from __future__ import annotations
+
+import os
+from typing import List
+
+import click
+
+from cdevents.cli.utils import add_disclaimer_text, print_function_args
+from cdevents.cli.cdevents_command import CDeventsCommand
+
+from cdevents.core.events import Events
+from cdevents.core import event_type
+
+# pylint: disable=unused-argument
+def common_repository_options(function):
+    """Decorator for common cli options for repository."""
+    function = click.option(
+        "--id",
+        "-i",
+        required=False,
+        type=str,
+        help="Repository Id.",
+    )(function)
+    function = click.option(
+        "--name",
+        "-n",
+        required=False,
+        type=str,
+        help="Repository's Name.",
+    )(function)
+    function = click.option(
+        "--url",
+        "-u",
+        required=False,
+        type=str,
+        help="Repository's URL.",
+    )(function)
+    function = click.option(
+        "--data",
+        "-d",
+        required=False,
+        type=(str, str),
+        multiple=True,
+        help="Repository's Data.",
+    )(function)
+
+    return function
+
+
+@click.command(help=add_disclaimer_text("Repository Created CloudEvent."))
+@common_repository_options
+def created(
+    id: str,
+    name: str = None,
+    url: str = None,
+    data: List[str] = None,
+):
+    print_function_args()
+    e = Events()
+    new_event = e.create_repository_event(event_type.RepositoryCreatedEventV1, id, name, url, data)
+    cdevents_command = CDeventsCommand()
+    cdevents_command.run(new_event)
+
+
+@click.command(help=add_disclaimer_text("Repository Modified CloudEvent."))
+@common_repository_options
+def modified(
+    id: str,
+    name: str = None,
+    url: str = None,
+    data: List[str] = None,
+):
+    print_function_args()
+    e = Events()
+    new_event = e.create_repository_event(event_type.RepositoryModifiedEventV1, id, name, url, data)
+    cdevents_command = CDeventsCommand()
+    cdevents_command.run(new_event)
+
+
+@click.command(help=add_disclaimer_text("Repository Deleted CloudEvent."))
+@common_repository_options
+def deleted(
+    id: str,
+    name: str = None,
+    url: str = None,
+    data: List[str] = None,
+):
+    print_function_args()
+    e = Events()
+    new_event = e.create_repository_event(event_type.RepositoryModifiedEventV1, id, name, url, data)
+    cdevents_command = CDeventsCommand()
+    cdevents_command.run(new_event)
+

core/cdevents/core/event_type.py

@@ -1,56 +1,55 @@
 """Constants Event types."""
 
-# PipelineRun events
-PipelineRunStartedEventV1  :str = "cd.pipelinerun.started.v1"
-PipelineRunFinishedEventV1 :str = "cd.pipelinerun.finished.v1"
-PipelineRunQueuedEventV1   :str = "cd.pipelinerun.queued.v1"
-
-# TaskRun events
-TaskRunStartedEventV1  :str = "cd.taskrun.started.v1"
-TaskRunFinishedEventV1 :str = "cd.taskrun.finished.v1"
-
-# Repository events
-RepositoryCreatedEventV1  :str = "cd.repository.created.v1"
-RepositoryModifiedEventV1 :str = "cd.repository.modified.v1"
-RepositoryDeletedEventV1  :str = "cd.repository.deleted.v1"
+# Artifact Events
+ArtifactPackagedEventV1  :str = "cd.artifact.packaged.v1"
+ArtifactPublishedEventV1 :str = "cd.artifact.published.v1"
 
 # Branch Events
 BranchCreatedEventV1 :str = "cd.repository.branch.created.v1"
 BranchDeletedEventV1 :str = "cd.repository.branch.deleted.v1"
 
+# Build Events
+BuildStartedEventV1  :str = "cd.build.started.v1"
+BuildQueuedEventV1   :str = "cd.build.queued.v1"
+BuildFinishedEventV1 :str = "cd.build.finished.v1"
+
 # Change Events
 ChangeCreatedEventV1   :str = "cd.repository.change.created.v1"
 ChangeUpdatedEventV1   :str = "cd.repository.change.updated.v1"
 ChangeReviewedEventV1  :str = "cd.repository.change.reviewed.v1"
 ChangeMergedEventV1    :str = "cd.repository.change.merged.v1"
 ChangeAbandonedEventV1 :str = "cd.repository.change.abandoned.v1"
 
-# Build Events
-BuildStartedEventV1  :str = "cd.build.started.v1"
-BuildQueuedEventV1   :str = "cd.build.queued.v1"
-BuildFinishedEventV1 :str = "cd.build.finished.v1"
-
-# Test Events
-TestCaseStartedEventV1  :str = "cd.test.case.started.v1"
-TestCaseQueuedEventV1   :str = "cd.test.case.queued.v1"
-TestCaseFinishedEventV1 :str = "cd.test.case.finished.v1"
-
-TestSuiteStartedEventV1  :str = "cd.test.suite.started.v1"
-TestSuiteQueuedEventV1   :str = "cd.test.suite.queued.v1"
-TestSuiteFinishedEventV1 :str = "cd.test.suite.finished.v1"
-
-# Artifact Events
-ArtifactPackagedEventV1  :str = "cd.artifact.packaged.v1"
-ArtifactPublishedEventV1 :str = "cd.artifact.published.v1"
-
 # Environment Events
 EnvironmentCreatedEventV1  :str = "cd.environment.created.v1"
 EnvironmentModifiedEventV1 :str = "cd.environment.modified.v1"
 EnvironmentDeletedEventV1  :str = "cd.environment.deleted.v1"
 
+# PipelineRun events
+PipelineRunStartedEventV1  :str = "cd.pipelinerun.started.v1"
+PipelineRunFinishedEventV1 :str = "cd.pipelinerun.finished.v1"
+PipelineRunQueuedEventV1   :str = "cd.pipelinerun.queued.v1"
+
+# Repository events
+RepositoryCreatedEventV1  :str = "cd.repository.created.v1"
+RepositoryModifiedEventV1 :str = "cd.repository.modified.v1"
+RepositoryDeletedEventV1  :str = "cd.repository.deleted.v1"
+
 # Service Events
 ServiceDeployedEventV1   :str = "cd.service.deployed.v1"
 ServiceUpgradedEventV1   :str = "cd.service.upgraded.v1"
 ServiceRolledbackEventV1 :str = "cd.service.rolledback.v1"
 ServiceRemovedEventV1    :str = "cd.service.removed.v1"
 
+# TaskRun events
+TaskRunStartedEventV1  :str = "cd.taskrun.started.v1"
+TaskRunFinishedEventV1 :str = "cd.taskrun.finished.v1"
+
+# Test Events
+TestCaseStartedEventV1  :str = "cd.test.case.started.v1"
+TestCaseQueuedEventV1   :str = "cd.test.case.queued.v1"
+TestCaseFinishedEventV1 :str = "cd.test.case.finished.v1"
+
+TestSuiteStartedEventV1  :str = "cd.test.suite.started.v1"
+TestSuiteQueuedEventV1   :str = "cd.test.suite.queued.v1"
+TestSuiteFinishedEventV1 :str = "cd.test.suite.finished.v1"

core/cdevents/core/events.py

@@ -90,6 +90,21 @@ def create_pipelinerun_event(self, event_type: str , id: str, name: str, status:
 
         return event
 
+    def create_repository_event(self, event_type: str , id: str, name: str, url: str, data = {}) -> CloudEvent:
+        """Create repository event.
+        """
+            
+        extensions = {
+            "repositoryid": id,
+            "repositoryname": name,
+            "repositoryurl": url,
+        }
+
+        event = self.create_event(event_type, extensions, data)
+
+        return event
+
+
     def create_service_event(self, event_type: str , envid: str, name: str, version: str, data = {}) -> CloudEvent:
         """Create service event.
         """