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,23 @@
+/*
+ * Copyright 2023 Netflix, Inc.
+ *
+ * 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.
+ */
+
+package com.netflix.spinnaker.echo.cdevents;
+
+import io.cloudevents.CloudEvent;
+
+public interface CDEventCreator {
+  CloudEvent createCDEvent();
+}

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

@@ -0,0 +1,67 @@
+/*
+ * Copyright 2023 Netflix, Inc.
+ *
+ * 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.
+ */
+
+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 implements CDEventCreator {
+
+  private String source;
+  private String subjectId;
+  private String subjectSource;
+  private String subjectPipelineName;
+  private String subjectUrl;
+
+  private String subjectError;
+
+  public CDEventPipelineRunFinished(
+      String executionId,
+      String executionUrl,
+      String executionName,
+      String spinnakerUrl,
+      String status) {
+    this.source = spinnakerUrl;
+    this.subjectId = executionId;
+    this.subjectSource = spinnakerUrl;
+    this.subjectPipelineName = executionName;
+    this.subjectUrl = executionUrl;
+    this.subjectError = status;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    PipelineRunFinishedCDEvent cdEvent = new PipelineRunFinishedCDEvent();
+    cdEvent.setSource(URI.create(source));
+    cdEvent.setSubjectId(subjectId);
+    cdEvent.setSubjectSource(URI.create(subjectSource));
+    cdEvent.setSubjectPipelineName(subjectSource);
+    cdEvent.setSubjectUrl(URI.create(subjectUrl));
+    cdEvent.setSubjectErrors(subjectError);
+
+    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 2023 Netflix, Inc.
+ *
+ * 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.
+ */
+
+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 implements CDEventCreator {
+
+  private String source;
+  private String subjectId;
+  private String subjectSource;
+  private String subjectPipelineName;
+  private String subjectUrl;
+
+  public CDEventPipelineRunQueued(
+      String executionId, String executionUrl, String executionName, String spinnakerUrl) {
+    this.source = spinnakerUrl;
+    this.subjectId = executionId;
+    this.subjectSource = spinnakerUrl;
+    this.subjectPipelineName = executionName;
+    this.subjectUrl = executionUrl;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    PipelineRunQueuedCDEvent cdEvent = new PipelineRunQueuedCDEvent();
+    cdEvent.setSource(URI.create(source));
+    cdEvent.setSubjectId(subjectId);
+    cdEvent.setSubjectSource(URI.create(subjectSource));
+    cdEvent.setSubjectPipelineName(subjectPipelineName);
+    cdEvent.setSubjectUrl(URI.create(subjectUrl));
+
+    return CDEvents.cdEventAsCloudEvent(cdEvent);
+  }
+}

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

@@ -0,0 +1,52 @@
+/*
+ * Copyright 2023 Netflix, Inc.
+ *
+ * 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.
+ */
+
+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 implements CDEventCreator {
+
+  private String source;
+  private String subjectId;
+  private String subjectSource;
+  private String subjectPipelineName;
+  private String subjectUrl;
+
+  public CDEventPipelineRunStarted(
+      String executionId, String executionUrl, String executionName, String spinnakerUrl) {
+    this.source = spinnakerUrl;
+    this.subjectId = executionId;
+    this.subjectSource = spinnakerUrl;
+    this.subjectPipelineName = executionName;
+    this.subjectUrl = executionUrl;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    PipelineRunStartedCDEvent cdEvent = new PipelineRunStartedCDEvent();
+    cdEvent.setSource(URI.create(source));
+    cdEvent.setSubjectId(subjectId);
+    cdEvent.setSubjectSource(URI.create(subjectSource));
+    cdEvent.setSubjectPipelineName(subjectPipelineName);
+    cdEvent.setSubjectUrl(URI.create(subjectUrl));
+
+    return CDEvents.cdEventAsCloudEvent(cdEvent);
+  }
+}

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

@@ -0,0 +1,69 @@
+/*
+ * Copyright 2023 Netflix, Inc.
+ *
+ * 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.
+ */
+
+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 implements CDEventCreator {
+
+  private String source;
+  private String subjectId;
+  private String subjectSource;
+  private String subjectTaskName;
+  private String subjectUrl;
+  private String subjectPipelineRunId;
+  private String subjectError;
+
+  public CDEventTaskRunFinished(
+      String executionId,
+      String executionUrl,
+      String executionName,
+      String spinnakerUrl,
+      String status) {
+    this.source = spinnakerUrl;
+    this.subjectId = executionId;
+    this.subjectSource = spinnakerUrl;
+    this.subjectTaskName = executionName;
+    this.subjectUrl = executionUrl;
+    this.subjectPipelineRunId = executionId;
+    this.subjectError = status;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    TaskRunFinishedCDEvent cdEvent = new TaskRunFinishedCDEvent();
+    cdEvent.setSource(URI.create(source));
+
+    cdEvent.setSubjectId(subjectId);
+    cdEvent.setSubjectSource(URI.create(source));
+    cdEvent.setSubjectTaskName(subjectTaskName);
+    cdEvent.setSubjectUrl(URI.create(subjectUrl));
+    cdEvent.setSubjectErrors(subjectError);
+    cdEvent.setSubjectPipelineRunId(subjectPipelineRunId);
+    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/CDEventTaskRunStarted.java

@@ -0,0 +1,56 @@
+/*
+ * Copyright 2023 Netflix, Inc.
+ *
+ * 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.
+ */
+
+package com.netflix.spinnaker.echo.cdevents;
+
+import dev.cdevents.CDEvents;
+import dev.cdevents.events.TaskRunStartedCDEvent;
+import io.cloudevents.CloudEvent;
+import java.net.URI;
+
+public class CDEventTaskRunStarted implements CDEventCreator {
+
+  private String source;
+  private String subjectId;
+  private String subjectSource;
+  private String subjectTaskName;
+  private String subjectUrl;
+  private String subjectPipelineRunId;
+
+  public CDEventTaskRunStarted(
+      String executionId, String executionUrl, String executionName, String spinnakerUrl) {
+    this.source = spinnakerUrl;
+    this.subjectId = executionId;
+    this.subjectSource = spinnakerUrl;
+    this.subjectTaskName = executionName;
+    this.subjectUrl = executionUrl;
+    this.subjectPipelineRunId = executionId;
+  }
+
+  @Override
+  public CloudEvent createCDEvent() {
+    TaskRunStartedCDEvent cdEvent = new TaskRunStartedCDEvent();
+    cdEvent.setSource(URI.create(source));
+
+    cdEvent.setSubjectId(subjectId);
+    cdEvent.setSubjectSource(URI.create(subjectSource));
+    cdEvent.setSubjectTaskName(subjectTaskName);
+    cdEvent.setSubjectUrl(URI.create(subjectUrl));
+    cdEvent.setSubjectPipelineRunId(subjectPipelineRunId);
+
+    return CDEvents.cdEventAsCloudEvent(cdEvent);
+  }
+}