update events -> event

Author: tarekbadrsh

cli/cdevents/cli/artifact.py

@@ -6,7 +6,7 @@
 from cdevents.cli.utils import add_disclaimer_text, print_function_args
 from cdevents.cli.cdevents_command import CDeventsCommand
 
-from cdevents.core.artifact import Artifact, ArtifactType
+from cdevents.core.artifact import ArtifactEvent, ArtifactType
 
 # pylint: disable=unused-argument
 def common_artifact_options(function):
@@ -53,7 +53,7 @@ def packaged(
     data: List[str] = None,
 ):
     print_function_args()
-    artifact_event = Artifact(ArtifactType.ArtifactPackagedEventV1, id, name, version, data=data)
+    artifact_event = ArtifactEvent(ArtifactType.ArtifactPackagedEventV1, id, name, version, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(artifact_event)
 
@@ -67,6 +67,6 @@ def published(
     data: List[str] = None,
 ):
     print_function_args()
-    artifact_event = Artifact(ArtifactType.ArtifactPublishedEventV1, id, name, version, data=data)
+    artifact_event = ArtifactEvent(ArtifactType.ArtifactPublishedEventV1, id, name, version, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(artifact_event)

cli/cdevents/cli/branch.py

@@ -6,7 +6,7 @@
 from cdevents.cli.utils import add_disclaimer_text, print_function_args
 from cdevents.cli.cdevents_command import CDeventsCommand
 
-from cdevents.core.branch import Branch, BranchType
+from cdevents.core.branch import BranchEvent, BranchType
 
 # pylint: disable=unused-argument
 def common_branch_options(function):
@@ -53,7 +53,7 @@ def created(
     data: List[str] = None,
 ):
     print_function_args()
-    branch_event = Branch(branch_type=BranchType.BranchCreatedEventV1, id=id, name=name, repoid=repoid, data=data)
+    branch_event = BranchEvent(branch_type=BranchType.BranchCreatedEventV1, id=id, name=name, repoid=repoid, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(branch_event)
 
@@ -67,6 +67,6 @@ def deleted(
     data: List[str] = None,
 ):
     print_function_args()
-    branch_event = Branch(branch_type=BranchType.BranchDeletedEventV1, id=id, name=name, repoid=repoid, data=data)
+    branch_event = BranchEvent(branch_type=BranchType.BranchDeletedEventV1, id=id, name=name, repoid=repoid, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(branch_event)

cli/cdevents/cli/build.py

@@ -6,7 +6,7 @@
 from cdevents.cli.utils import add_disclaimer_text, print_function_args
 from cdevents.cli.cdevents_command import CDeventsCommand
 
-from cdevents.core.build import Build, BuildType
+from cdevents.core.build import BuildEvent, BuildType
 
 # pylint: disable=unused-argument
 def common_build_options(function):
@@ -54,7 +54,7 @@ def started(
     data: List[str] = None,
 ):
     print_function_args()
-    build_event = Build(build_type=BuildType.BuildStartedEventV1, id=id, name=name, artifact=artifact, data=data)
+    build_event = BuildEvent(build_type=BuildType.BuildStartedEventV1, id=id, name=name, artifact=artifact, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(build_event)
 
@@ -67,7 +67,7 @@ def finished(
     data: List[str] = None,
 ):
     print_function_args()
-    build_event = Build(build_type=BuildType.BuildFinishedEventV1, id=id, name=name, artifact=artifact, data=data)
+    build_event = BuildEvent(build_type=BuildType.BuildFinishedEventV1, id=id, name=name, artifact=artifact, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(build_event)
 
@@ -80,6 +80,6 @@ def queued(
     data: List[str] = None,
 ):
     print_function_args()
-    build_event = Build(build_type=BuildType.BuildQueuedEventV1, id=id, name=name, artifact=artifact, data=data)
+    build_event = BuildEvent(build_type=BuildType.BuildQueuedEventV1, id=id, name=name, artifact=artifact, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(build_event)

cli/cdevents/cli/env.py

@@ -6,7 +6,7 @@
 from cdevents.cli.utils import add_disclaimer_text, print_function_args
 from cdevents.cli.cdevents_command import CDeventsCommand
 
-from cdevents.core.env import Env, EnvType
+from cdevents.core.env import EnvEvent, EnvType
 
 # pylint: disable=unused-argument
 def common_env_options(function):
@@ -53,7 +53,7 @@ def created(
     data: List[str] = None,
 ):
     print_function_args()
-    env = Env(build_type=EnvType.EnvironmentCreatedEventV1, id=id, name=name, repo=repo, data=data)
+    env = EnvEvent(build_type=EnvType.EnvironmentCreatedEventV1, id=id, name=name, repo=repo, data=data)
     env_event = env.create_event(data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(env_event)
@@ -68,7 +68,7 @@ def deleted(
     data: List[str] = None,
 ):
     print_function_args()
-    env_event = Env(env_type=EnvType.EnvironmentDeletedEventV1, id=id, name=name, repo=repo, data=data)
+    env_event = EnvEvent(env_type=EnvType.EnvironmentDeletedEventV1, id=id, name=name, repo=repo, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(env_event)
 
@@ -81,6 +81,6 @@ def modified(
     data: List[str] = None,
 ):
     print_function_args()
-    env_event = Env(env_type=EnvType.EnvironmentModifiedEventV1, id=id, name=name, repo=repo, data=data)
+    env_event = EnvEvent(env_type=EnvType.EnvironmentModifiedEventV1, id=id, name=name, repo=repo, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(env_event)

cli/cdevents/cli/pipelinerun.py

@@ -6,7 +6,7 @@
 from cdevents.cli.utils import add_disclaimer_text, print_function_args
 from cdevents.cli.cdevents_command import CDeventsCommand
 
-from cdevents.core.pipelinerun import Pipelinerun, PipelinerunType
+from cdevents.core.pipelinerun import PipelinerunEvent, PipelinerunType
 
 # pylint: disable=unused-argument
 def common_pipelinerun_options(function):
@@ -69,7 +69,7 @@ def started(
     data: List[str] = None,
 ):
     print_function_args()
-    pipelinerun_event = Pipelinerun(PipelinerunType.PipelineRunStartedEventV1, id=id, name=name, status=status, url=url, errors=errors, data=data)
+    pipelinerun_event = PipelinerunEvent(PipelinerunType.PipelineRunStartedEventV1, id=id, name=name, status=status, url=url, errors=errors, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(pipelinerun_event)
 
@@ -84,7 +84,7 @@ def finished(
     data: List[str] = None,
 ):
     print_function_args()
-    pipelinerun_event = Pipelinerun(PipelinerunType.PipelineRunFinishedEventV1, id=id, name=name, status=status, url=url, errors=errors, data=data)
+    pipelinerun_event = PipelinerunEvent(PipelinerunType.PipelineRunFinishedEventV1, id=id, name=name, status=status, url=url, errors=errors, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(pipelinerun_event)
 
@@ -100,7 +100,7 @@ def queued(
     data: List[str] = None,
 ):
     print_function_args()
-    pipelinerun_event = Pipelinerun(PipelinerunType.PipelineRunQueuedEventV1, id=id, name=name, status=status, url=url, errors=errors, data=data)
+    pipelinerun_event = PipelinerunEvent(PipelinerunType.PipelineRunQueuedEventV1, id=id, name=name, status=status, url=url, errors=errors, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(pipelinerun_event)
 

cli/cdevents/cli/repository.py

@@ -6,7 +6,7 @@
 from cdevents.cli.utils import add_disclaimer_text, print_function_args
 from cdevents.cli.cdevents_command import CDeventsCommand
 
-from cdevents.core.repository import Repository, RepositoryType
+from cdevents.core.repository import RepositoryEvent, RepositoryType
 
 # pylint: disable=unused-argument
 def common_repository_options(function):
@@ -53,7 +53,7 @@ def created(
     data: List[str] = None,
 ):
     print_function_args()
-    repository_event = Repository(repository_type=RepositoryType.RepositoryCreatedEventV1, id=id, name=name, url=url, data=data)
+    repository_event = RepositoryEvent(repository_type=RepositoryType.RepositoryCreatedEventV1, id=id, name=name, url=url, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(repository_event)
 
@@ -67,7 +67,7 @@ def modified(
     data: List[str] = None,
 ):
     print_function_args()
-    repository_event = Repository(repository_type=RepositoryType.RepositoryModifiedEventV1, id=id, name=name, url=url, data=data)
+    repository_event = RepositoryEvent(repository_type=RepositoryType.RepositoryModifiedEventV1, id=id, name=name, url=url, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(repository_event)
 
@@ -81,7 +81,7 @@ def deleted(
     data: List[str] = None,
 ):
     print_function_args()
-    repository_event = Repository(repository_type=RepositoryType.RepositoryDeletedEventV1, id=id, name=name, url=url, data=data)
+    repository_event = RepositoryEvent(repository_type=RepositoryType.RepositoryDeletedEventV1, id=id, name=name, url=url, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(repository_event)
 

cli/cdevents/cli/service.py

@@ -6,7 +6,7 @@
 from cdevents.cli.utils import add_disclaimer_text, print_function_args
 from cdevents.cli.cdevents_command import CDeventsCommand
 
-from cdevents.core.service import Service, ServiceType
+from cdevents.core.service import ServiceEvent, ServiceType
 
 # pylint: disable=unused-argument
 def common_service_options(function):
@@ -53,7 +53,7 @@ def deployed(
     data: List[str] = None,
 ):
     print_function_args()
-    service_event = Service(service_type=ServiceType.ServiceDeployedEventV1, envid=envid, name=name, version=version, data=data)
+    service_event = ServiceEvent(service_type=ServiceType.ServiceDeployedEventV1, envid=envid, name=name, version=version, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(service_event)
 
@@ -66,7 +66,7 @@ def upgraded(
     data: List[str] = None,
 ):
     print_function_args()
-    service_event = Service(service_type=ServiceType.ServiceUpgradedEventV1, envid=envid, name=name, version=version, data=data)
+    service_event = ServiceEvent(service_type=ServiceType.ServiceUpgradedEventV1, envid=envid, name=name, version=version, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(service_event)
 
@@ -80,7 +80,7 @@ def removed(
     data: List[str] = None,
 ):
     print_function_args()
-    service_event = Service(service_type=ServiceType.ServiceRemovedEventV1, envid=envid, name=name, version=version, data=data)
+    service_event = ServiceEvent(service_type=ServiceType.ServiceRemovedEventV1, envid=envid, name=name, version=version, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(service_event)
 
@@ -94,6 +94,6 @@ def rolledback(
     data: List[str] = None,
 ):
     print_function_args()
-    service_event = Service(service_type=ServiceType.ServiceRolledbackEventV1, envid=envid, name=name, version=version, data=data)
+    service_event = ServiceEvent(service_type=ServiceType.ServiceRolledbackEventV1, envid=envid, name=name, version=version, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(service_event)

cli/cdevents/cli/taskrun.py

@@ -6,7 +6,7 @@
 from cdevents.cli.utils import add_disclaimer_text, print_function_args
 from cdevents.cli.cdevents_command import CDeventsCommand
 
-from cdevents.core.taskrun import TaskRun, TaskRunType
+from cdevents.core.taskrun import TaskRunEvent, TaskRunType
 
 # pylint: disable=unused-argument
 def common_taskrun_options(function):
@@ -53,7 +53,7 @@ def started(
     data: List[str] = None,
 ):
     print_function_args()
-    taskrun_event = TaskRun(taskrun_type=TaskRunType.TaskRunStartedEventV1, id=id, name=name, pipelineid=pipelineid, data=data)
+    taskrun_event = TaskRunEvent(taskrun_type=TaskRunType.TaskRunStartedEventV1, id=id, name=name, pipelineid=pipelineid, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(taskrun_event)
 
@@ -66,7 +66,7 @@ def finished(
     data: List[str] = None,
 ):
     print_function_args()
-    taskrun_event = TaskRun(taskrun_type=TaskRunType.TaskRunFinishedEventV1, id=id, name=name, pipelineid=pipelineid, data=data)
+    taskrun_event = TaskRunEvent(taskrun_type=TaskRunType.TaskRunFinishedEventV1, id=id, name=name, pipelineid=pipelineid, data=data)
     cdevents_command = CDeventsCommand()
     cdevents_command.run(taskrun_event)
 

core/cdevents/core/artifact.py

@@ -1,15 +1,15 @@
 """artifact"""
 
 from enum import Enum
-from cdevents.core.events import Events
+from cdevents.core.event import Event
 
 class ArtifactType(Enum):
     ArtifactPackagedEventV1: str = "cd.artifact.packaged.v1"
     ArtifactPublishedEventV1: str = "cd.artifact.published.v1"
 
 
-class Artifact(Events):
-    """Artifact."""
+class ArtifactEvent(Event):
+    """Artifact Event."""
 
     def __init__(self, artifact_type: ArtifactType, id: str, name: str, version: str, data: dict = {}):
         """Initializes class.

core/cdevents/core/branch.py

@@ -1,15 +1,15 @@
 """branch"""
 
 from enum import Enum
-from cdevents.core.events import Events
+from cdevents.core.event import Event
 
 class BranchType(Enum):
     BranchCreatedEventV1: str = "cd.repository.branch.created.v1"
     BranchDeletedEventV1: str = "cd.repository.branch.deleted.v1"
 
 
-class Branch(Events):
-    """Branch."""
+class BranchEvent(Event):
+    """Branch Event."""
 
     def __init__(self, branch_type: BranchType, id: str, name: str, repoid: str, data: dict = {}):
         """Initializes class.
@@ -29,3 +29,22 @@ def create_extensions(self) -> dict:
             "branchrepositoryid": self._repoid,
         }
         return extensions
+
+# TODO: Add tests for this class.
+class BranchCreatedEvent(BranchEvent):
+    
+    def __init__(self, id: str, name: str, repoid: str, data: dict = {}):
+        """Initializes class.
+        """
+        self._event_type : str = "cd.repository.branch.created.v1"
+
+        super().__init__(event_type=self._event_type, id=id, name=name, repoid=repoid, data=data)
+
+class BranchDeletedEvent(BranchEvent):
+    
+    def __init__(self, id: str, name: str, repoid: str, data: dict = {}):
+        """Initializes class.
+        """
+        self._event_type : str = "cd.repository.branch.deleted.v1"
+
+        super().__init__(event_type=self._event_type, id=id, name=name, repoid=repoid, data=data)