feat(cdevents-notification): Implementing produce CDEvents using Notification

echo-notifications/echo-notifications.gradle

@@ -34,6 +34,9 @@ dependencies {
   implementation "org.jsoup:jsoup:1.8.3"
   implementation "com.atlassian.commonmark:commonmark:0.9.0"
   implementation "org.codehaus.groovy:groovy-json"
+  implementation "io.cloudevents:cloudevents-http-basic:2.5.0"
+  implementation "io.cloudevents:cloudevents-json-jackson:2.5.0"
+  implementation ("dev.cdevents:cdevents-sdk-java:0.1.2")
   testImplementation("com.icegreen:greenmail:1.5.14") {
     exclude group: "com.sun.mail", module: "javax.mail"
   }

echo-notifications/src/main/groovy/com/netflix/spinnaker/echo/cdevents/CDEventCreator.java

@@ -0,0 +1,67 @@
+/*
+    Copyright (C) 2023 Nordix Foundation.
+    For a full list of individual contributors, please see the commit history.
+    Licensed under the Apache License, Version 2.0 (the "License");
+    you may not use this file except in compliance with the License.
+    You may obtain a copy of the License at
+          http://www.apache.org/licenses/LICENSE-2.0
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+    SPDX-License-Identifier: Apache-2.0
+*/
+
+package com.netflix.spinnaker.echo.cdevents;
+
+import io.cloudevents.CloudEvent;
+
+public abstract class CDEventCreator {
+  abstract CloudEvent createCDEvent();
+
+  private String source;
+  private String subjectId;
+  private String subjectSource;
+  private String subjectUrl;
+
+  public CDEventCreator(String source, String subjectId, String subjectSource, String subjectUrl) {
+    this.source = source;
+    this.subjectId = subjectId;
+    this.subjectSource = subjectSource;
+    this.subjectUrl = subjectUrl;
+  }
+
+  public String getSource() {
+    return source;
+  }
+
+  public void setSource(String source) {
+    this.source = source;
+  }
+
+  public String getSubjectId() {
+    return subjectId;
+  }
+
+  public void setSubjectId(String subjectId) {
+    this.subjectId = subjectId;
+  }
+
+  public String getSubjectSource() {
+    return subjectSource;
+  }
+
+  public void setSubjectSource(String subjectSource) {
+    this.subjectSource = subjectSource;
+  }
+
+  public String getSubjectUrl() {
+    return subjectUrl;
+  }
+
+  public void setSubjectUrl(String subjectUrl) {
+    this.subjectUrl = subjectUrl;
+  }
+}

echo-notifications/src/main/groovy/com/netflix/spinnaker/echo/cdevents/CDEventPipelineRunFinished.java

@@ -0,0 +1,75 @@
+/*
+    Copyright (C) 2023 Nordix Foundation.
+    For a full list of individual contributors, please see the commit history.
+    Licensed under the Apache License, Version 2.0 (the "License");
+    you may not use this file except in compliance with the License.
+    You may obtain a copy of the License at
+          http://www.apache.org/licenses/LICENSE-2.0
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+    SPDX-License-Identifier: Apache-2.0
+*/
+
+package com.netflix.spinnaker.echo.cdevents;
+
+import dev.cdevents.CDEvents;
+import dev.cdevents.constants.CDEventConstants;
+import dev.cdevents.events.PipelineRunFinishedCDEvent;
+import io.cloudevents.CloudEvent;
+import java.net.URI;
+
+public class CDEventPipelineRunFinished extends CDEventCreator {
+
+  private String subjectPipelineName;
+  private String subjectError;
+
+  public CDEventPipelineRunFinished(
+      String executionId,
+      String executionUrl,
+      String executionName,
+      String spinnakerUrl,
+      String status) {
+    super(spinnakerUrl, executionId, spinnakerUrl, executionUrl);
+    this.subjectPipelineName = executionName;
+    this.subjectError = status;
+  }
+
+  public String getSubjectPipelineName() {
+    return subjectPipelineName;
+  }
+
+  public void setSubjectPipelineName(String subjectPipelineName) {
+    this.subjectPipelineName = subjectPipelineName;
+  }
+
+  public String getSubjectError() {
+    return subjectError;
+  }
+
+  public void setSubjectError(String subjectError) {
+    this.subjectError = subjectError;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    PipelineRunFinishedCDEvent cdEvent = new PipelineRunFinishedCDEvent();
+    cdEvent.setSource(URI.create(getSource()));
+    cdEvent.setSubjectId(getSubjectId());
+    cdEvent.setSubjectSource(URI.create(getSubjectSource()));
+    cdEvent.setSubjectPipelineName(getSubjectPipelineName());
+    cdEvent.setSubjectUrl(URI.create(getSubjectUrl()));
+    cdEvent.setSubjectErrors(getSubjectError());
+
+    if (subjectError.equals("complete")) {
+      cdEvent.setSubjectOutcome(CDEventConstants.Outcome.SUCCESS);
+    } else if (subjectError.equals("failed")) {
+      cdEvent.setSubjectOutcome(CDEventConstants.Outcome.FAILURE);
+    }
+
+    return CDEvents.cdEventAsCloudEvent(cdEvent);
+  }
+}

echo-notifications/src/main/groovy/com/netflix/spinnaker/echo/cdevents/CDEventPipelineRunQueued.java

@@ -0,0 +1,52 @@
+/*
+    Copyright (C) 2023 Nordix Foundation.
+    For a full list of individual contributors, please see the commit history.
+    Licensed under the Apache License, Version 2.0 (the "License");
+    you may not use this file except in compliance with the License.
+    You may obtain a copy of the License at
+          http://www.apache.org/licenses/LICENSE-2.0
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+    SPDX-License-Identifier: Apache-2.0
+*/
+package com.netflix.spinnaker.echo.cdevents;
+
+import dev.cdevents.CDEvents;
+import dev.cdevents.events.PipelineRunQueuedCDEvent;
+import io.cloudevents.CloudEvent;
+import java.net.URI;
+
+public class CDEventPipelineRunQueued extends CDEventCreator {
+
+  private String subjectPipelineName;
+
+  public CDEventPipelineRunQueued(
+      String executionId, String executionUrl, String executionName, String spinnakerUrl) {
+    super(spinnakerUrl, executionId, spinnakerUrl, executionUrl);
+    this.subjectPipelineName = executionName;
+  }
+
+  public String getSubjectPipelineName() {
+    return subjectPipelineName;
+  }
+
+  public void setSubjectPipelineName(String subjectPipelineName) {
+    this.subjectPipelineName = subjectPipelineName;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    PipelineRunQueuedCDEvent cdEvent = new PipelineRunQueuedCDEvent();
+    cdEvent.setSource(URI.create(getSource()));
+    cdEvent.setSubjectId(getSubjectId());
+    cdEvent.setSubjectSource(URI.create(getSubjectSource()));
+    cdEvent.setSubjectPipelineName(getSubjectPipelineName());
+    cdEvent.setSubjectUrl(URI.create(getSubjectUrl()));
+
+    return CDEvents.cdEventAsCloudEvent(cdEvent);
+  }
+}

echo-notifications/src/main/groovy/com/netflix/spinnaker/echo/cdevents/CDEventPipelineRunStarted.java

@@ -0,0 +1,53 @@
+/*
+    Copyright (C) 2023 Nordix Foundation.
+    For a full list of individual contributors, please see the commit history.
+    Licensed under the Apache License, Version 2.0 (the "License");
+    you may not use this file except in compliance with the License.
+    You may obtain a copy of the License at
+          http://www.apache.org/licenses/LICENSE-2.0
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+    SPDX-License-Identifier: Apache-2.0
+*/
+
+package com.netflix.spinnaker.echo.cdevents;
+
+import dev.cdevents.CDEvents;
+import dev.cdevents.events.PipelineRunStartedCDEvent;
+import io.cloudevents.CloudEvent;
+import java.net.URI;
+
+public class CDEventPipelineRunStarted extends CDEventCreator {
+
+  private String subjectPipelineName;
+
+  public CDEventPipelineRunStarted(
+      String executionId, String executionUrl, String executionName, String spinnakerUrl) {
+    super(spinnakerUrl, executionId, spinnakerUrl, executionUrl);
+    this.subjectPipelineName = executionName;
+  }
+
+  public String getSubjectPipelineName() {
+    return subjectPipelineName;
+  }
+
+  public void setSubjectPipelineName(String subjectPipelineName) {
+    this.subjectPipelineName = subjectPipelineName;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    PipelineRunStartedCDEvent cdEvent = new PipelineRunStartedCDEvent();
+    cdEvent.setSource(URI.create(getSource()));
+    cdEvent.setSubjectId(getSubjectId());
+    cdEvent.setSubjectSource(URI.create(getSubjectSource()));
+    cdEvent.setSubjectPipelineName(getSubjectPipelineName());
+    cdEvent.setSubjectUrl(URI.create(getSubjectUrl()));
+
+    return CDEvents.cdEventAsCloudEvent(cdEvent);
+  }
+}

echo-notifications/src/main/groovy/com/netflix/spinnaker/echo/cdevents/CDEventTaskRunFinished.java

@@ -0,0 +1,85 @@
+/*
+    Copyright (C) 2023 Nordix Foundation.
+    For a full list of individual contributors, please see the commit history.
+    Licensed under the Apache License, Version 2.0 (the "License");
+    you may not use this file except in compliance with the License.
+    You may obtain a copy of the License at
+          http://www.apache.org/licenses/LICENSE-2.0
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+    SPDX-License-Identifier: Apache-2.0
+*/
+
+package com.netflix.spinnaker.echo.cdevents;
+
+import dev.cdevents.CDEvents;
+import dev.cdevents.constants.CDEventConstants;
+import dev.cdevents.events.TaskRunFinishedCDEvent;
+import io.cloudevents.CloudEvent;
+import java.net.URI;
+
+public class CDEventTaskRunFinished extends CDEventCreator {
+
+  private String subjectTaskName;
+  private String subjectPipelineRunId;
+  private String subjectError;
+
+  public CDEventTaskRunFinished(
+      String executionId,
+      String executionUrl,
+      String executionName,
+      String spinnakerUrl,
+      String status) {
+    super(spinnakerUrl, executionId, spinnakerUrl, executionUrl);
+    this.subjectTaskName = executionName;
+    this.subjectPipelineRunId = executionId;
+    this.subjectError = status;
+  }
+
+  public String getSubjectTaskName() {
+    return subjectTaskName;
+  }
+
+  public void setSubjectTaskName(String subjectTaskName) {
+    this.subjectTaskName = subjectTaskName;
+  }
+
+  public String getSubjectPipelineRunId() {
+    return subjectPipelineRunId;
+  }
+
+  public void setSubjectPipelineRunId(String subjectPipelineRunId) {
+    this.subjectPipelineRunId = subjectPipelineRunId;
+  }
+
+  public String getSubjectError() {
+    return subjectError;
+  }
+
+  public void setSubjectError(String subjectError) {
+    this.subjectError = subjectError;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    TaskRunFinishedCDEvent cdEvent = new TaskRunFinishedCDEvent();
+    cdEvent.setSource(URI.create(getSource()));
+    cdEvent.setSubjectId(getSubjectId());
+    cdEvent.setSubjectSource(URI.create(getSubjectSource()));
+    cdEvent.setSubjectTaskName(getSubjectTaskName());
+    cdEvent.setSubjectUrl(URI.create(getSubjectUrl()));
+    cdEvent.setSubjectErrors(getSubjectError());
+    cdEvent.setSubjectPipelineRunId(getSubjectPipelineRunId());
+    if (getSubjectError().equals("complete")) {
+      cdEvent.setSubjectOutcome(CDEventConstants.Outcome.SUCCESS);
+    } else if (getSubjectError().equals("failed")) {
+      cdEvent.setSubjectOutcome(CDEventConstants.Outcome.FAILURE);
+    }
+
+    return CDEvents.cdEventAsCloudEvent(cdEvent);
+  }
+}