feat(pubsub): add support for links in pubsub triggers

echo-pipelinetriggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/eventhandlers/PubsubEventHandler.java

@@ -78,13 +78,26 @@ protected Function<Trigger, Trigger> buildTrigger(PubsubEvent pubsubEvent) {
     Map parameters =
         payload.containsKey("parameters") ? (Map) payload.get("parameters") : new HashMap();
     MessageDescription description = pubsubEvent.getContent().getMessageDescription();
-    return trigger ->
-        trigger
-            .atMessageDescription(
-                description.getSubscriptionName(), description.getPubsubSystem().toString())
-            .atParameters(parameters)
-            .atPayload(payload)
-            .atEventId(pubsubEvent.getEventId());
+    return inputTrigger -> {
+      Trigger trigger =
+          inputTrigger
+              .atMessageDescription(
+                  description.getSubscriptionName(), description.getPubsubSystem().toString())
+              .atParameters(parameters)
+              .atPayload(payload)
+              .atEventId(pubsubEvent.getEventId());
+
+      Object linkTextObject = payload.get("linkText");
+      Object linkObject = payload.get("link");
+      if (linkTextObject instanceof String && linkObject instanceof String) {
+        String linkText = (String) linkTextObject;
+        String link = (String) linkObject;
+        if (StringUtils.isNotBlank(linkText) && StringUtils.isNotBlank(link)) {
+          trigger = trigger.withLink(link).withLinkText(linkText);
+        }
+      }
+      return trigger;
+    };
   }
 
   @Override

echo-pipelinetriggers/src/test/groovy/com/netflix/spinnaker/echo/pipelinetriggers/eventhandlers/PubsubEventHandlerSpec.groovy

@@ -257,4 +257,33 @@ class PubsubEventHandlerSpec extends Specification implements RetrofitStubs {
     enabledGooglePubsubTrigger.withAttributeConstraints([key: 'value'])      | 1
     enabledGooglePubsubTrigger.withAttributeConstraints([key: 'wrongValue']) | 0
   }
+
+  @Unroll
+  def "sets link details if defined"() {
+    given:
+    def trigger = enabledGooglePubsubTrigger
+
+    def event = new PubsubEvent()
+    def description = MessageDescription.builder()
+      .pubsubSystem(PubsubSystem.GOOGLE)
+      .ackDeadlineSeconds(1)
+      .subscriptionName("projects/project/subscriptions/subscription")
+      .messagePayload(JsonOutput.toJson([key: 'value']))
+      .messageAttributes([key: 'value'])
+      .build()
+
+    when:
+    def content = new PubsubEvent.Content()
+    content.setMessageDescription(description)
+    event.content = content
+    def link = 'https://sample.com'
+    def linkText = 'someLinkText'
+    event.payload = [link: link, linkText: linkText]
+
+    def outputTrigger = eventHandler.buildTrigger(event).apply(trigger)
+
+    then:
+    outputTrigger.link.equals(link)
+    outputTrigger.linkText.equals(linkText)
+  }
 }