Watcher: migrate PagerDuty v1 events API to v2 API (#32285)

The PagerDuty v1 API is EOL and will stop accepting new accounts
shortly. This commit swaps out the watcher use of the v1 API with the
new v2 API. It does not change anything about the existing watcher
API.

Closes #32243

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/actions/pagerduty/ExecutablePagerDutyAction.java

@@ -47,7 +47,7 @@ public Action.Result execute(final String actionId, WatchExecutionContext ctx, P
  return new PagerDutyAction.Result.Simulated(event);
  }
 
- SentEvent sentEvent = account.send(event, payload);
+ SentEvent sentEvent = account.send(event, payload, ctx.id().watchId());
  return new PagerDutyAction.Result.Executed(account.getName(), sentEvent);
  }
 

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/notification/pagerduty/IncidentEvent.java

@@ -24,22 +24,22 @@
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
+import java.util.stream.Collectors;
 
 /**
  * Official documentation for this can be found at
  *
- * https://developer.pagerduty.com/documentation/howto/manually-trigger-an-incident/
- * https://developer.pagerduty.com/documentation/integration/events/trigger
- * https://developer.pagerduty.com/documentation/integration/events/acknowledge
- * https://developer.pagerduty.com/documentation/integration/events/resolve
+ * https://v2.developer.pagerduty.com/docs/send-an-event-events-api-v2
  */
 public class IncidentEvent implements ToXContentObject {
 
  static final String HOST = "events.pagerduty.com";
- static final String PATH = "/generic/2010-04-15/create_event.json";
+ static final String PATH = "/v2/enqueue";
+ static final String ACCEPT_HEADER = "application/vnd.pagerduty+json;version=2";
 
  final String description;
  @Nullable final HttpProxy proxy;
@@ -93,46 +93,81 @@ public int hashCode() {
  return result;
  }
 
- public HttpRequest createRequest(final String serviceKey, final Payload payload) throws IOException {
+ HttpRequest createRequest(final String serviceKey, final Payload payload, final String watchId) throws IOException {
  return HttpRequest.builder(HOST, -1)
  .method(HttpMethod.POST)
  .scheme(Scheme.HTTPS)
  .path(PATH)
  .proxy(proxy)
- .jsonBody(new ToXContent() {
- @Override
- public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
- builder.field(Fields.SERVICE_KEY.getPreferredName(), serviceKey);
- builder.field(Fields.EVENT_TYPE.getPreferredName(), eventType);
- builder.field(Fields.DESCRIPTION.getPreferredName(), description);
- if (incidentKey != null) {
- builder.field(Fields.INCIDENT_KEY.getPreferredName(), incidentKey);
- }
- if (client != null) {
- builder.field(Fields.CLIENT.getPreferredName(), client);
- }
- if (clientUrl != null) {
- builder.field(Fields.CLIENT_URL.getPreferredName(), clientUrl);
- }
- if (attachPayload) {
- builder.startObject(Fields.DETAILS.getPreferredName());
- builder.field(Fields.PAYLOAD.getPreferredName());
- payload.toXContent(builder, params);
- builder.endObject();
- }
- if (contexts != null && contexts.length > 0) {
- builder.startArray(Fields.CONTEXTS.getPreferredName());
- for (IncidentEventContext context : contexts) {
- context.toXContent(builder, params);
- }
- builder.endArray();
- }
- return builder;
- }
- })
+ .setHeader("Accept", ACCEPT_HEADER)
+ .jsonBody((b, p) -> buildAPIXContent(b, p, serviceKey, payload, watchId))
  .build();
  }
 
+ XContentBuilder buildAPIXContent(XContentBuilder builder, Params params, String serviceKey,
+ Payload payload, String watchId) throws IOException {
+ builder.field(Fields.ROUTING_KEY.getPreferredName(), serviceKey);
+ builder.field(Fields.EVENT_ACTION.getPreferredName(), eventType);
+ if (incidentKey != null) {
+ builder.field(Fields.DEDUP_KEY.getPreferredName(), incidentKey);
+ }
+
+ builder.startObject(Fields.PAYLOAD.getPreferredName());
+ {
+ builder.field(Fields.SUMMARY.getPreferredName(), description);
+
+ if (attachPayload && payload != null) {
+ builder.startObject(Fields.CUSTOM_DETAILS.getPreferredName());
+ {
+ builder.field(Fields.PAYLOAD.getPreferredName(), payload, params);
+ }
+ builder.endObject();
+ }
+
+ if (watchId != null) {
+ builder.field(Fields.SOURCE.getPreferredName(), watchId);
+ } else {
+ builder.field(Fields.SOURCE.getPreferredName(), "watcher");
+ }
+ // TODO externalize this into something user editable
+ builder.field(Fields.SEVERITY.getPreferredName(), "critical");
+ }
+ builder.endObject();
+
+ if (client != null) {
+ builder.field(Fields.CLIENT.getPreferredName(), client);
+ }
+ if (clientUrl != null) {
+ builder.field(Fields.CLIENT_URL.getPreferredName(), clientUrl);
+ }
+
+ if (contexts != null && contexts.length > 0) {
+ toXContentV2Contexts(builder, params, contexts);
+ }
+
+ return builder;
+ }
+
+ /**
+ * Turns the V1 API contexts into 2 distinct lists, images and links. The V2 API has separated these out into 2 top level fields.
+ */
+ private void toXContentV2Contexts(XContentBuilder builder, ToXContent.Params params,
+ IncidentEventContext[] contexts) throws IOException {
+ // contexts can be either links or images, and the v2 api needs them separate
+ Map<IncidentEventContext.Type, List<IncidentEventContext>> groups = Arrays.stream(contexts)
+ .collect(Collectors.groupingBy(iec -> iec.type));
+
+ List<IncidentEventContext> links = groups.getOrDefault(IncidentEventContext.Type.LINK, Collections.emptyList());
+ if (links.isEmpty() == false) {
+ builder.array(Fields.LINKS.getPreferredName(), links.toArray());
+ }
+
+ List<IncidentEventContext> images = groups.getOrDefault(IncidentEventContext.Type.IMAGE, Collections.emptyList());
+ if (images.isEmpty() == false) {
+ builder.array(Fields.IMAGES.getPreferredName(), images.toArray());
+ }
+ }
+
  @Override
  public XContentBuilder toXContent(XContentBuilder builder, ToXContent.Params params) throws IOException {
  builder.startObject();
@@ -445,8 +480,15 @@ interface Fields {
  // we need to keep this for BWC
  ParseField CONTEXT_DEPRECATED = new ParseField("context");
 
- ParseField SERVICE_KEY = new ParseField("service_key");
  ParseField PAYLOAD = new ParseField("payload");
- ParseField DETAILS = new ParseField("details");
+ ParseField ROUTING_KEY = new ParseField("routing_key");
+ ParseField EVENT_ACTION = new ParseField("event_action");
+ ParseField DEDUP_KEY = new ParseField("dedup_key");
+ ParseField SUMMARY = new ParseField("summary");
+ ParseField SOURCE = new ParseField("source");
+ ParseField SEVERITY = new ParseField("severity");
+ ParseField LINKS = new ParseField("links");
+ ParseField IMAGES = new ParseField("images");
+ ParseField CUSTOM_DETAILS = new ParseField("custom_details");
  }
 }

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/notification/pagerduty/IncidentEventContext.java

@@ -92,6 +92,85 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
  return builder.endObject();
  }
 
+ public static IncidentEventContext parse(XContentParser parser) throws IOException {
+ Type type = null;
+ String href = null;
+ String text = null;
+ String src = null;
+ String alt = null;
+
+ String currentFieldName = null;
+ XContentParser.Token token;
+ while ((token = parser.nextToken()) != XContentParser.Token.END_OBJECT) {
+ if (token == XContentParser.Token.FIELD_NAME) {
+ currentFieldName = parser.currentName();
+ } else if (Strings.hasLength(currentFieldName)) {
+ if (XField.TYPE.match(currentFieldName, parser.getDeprecationHandler())) {
+ try {
+ type = Type.valueOf(parser.text().toUpperCase(Locale.ROOT));
+ } catch (IllegalArgumentException e) {
+ String msg = "could not parse trigger incident event context. unknown context type [{}]";
+ throw new ElasticsearchParseException(msg, parser.text());
+ }
+ } else {
+ if (XField.HREF.match(currentFieldName, parser.getDeprecationHandler())) {
+ href = parser.text();
+ } else if (XField.TEXT.match(currentFieldName, parser.getDeprecationHandler())) {
+ text = parser.text();
+ } else if (XField.SRC.match(currentFieldName, parser.getDeprecationHandler())) {
+ src = parser.text();
+ } else if (XField.ALT.match(currentFieldName, parser.getDeprecationHandler())) {
+ alt = parser.text();
+ } else {
+ String msg = "could not parse trigger incident event context. unknown field [{}]";
+ throw new ElasticsearchParseException(msg, currentFieldName);
+ }
+ }
+ }
+ }
+
+ return createAndValidateTemplate(type, href, src, alt, text);
+ }
+
+ private static IncidentEventContext createAndValidateTemplate(Type type, String href, String src, String alt,
+ String text) {
+ if (type == null) {
+ throw new ElasticsearchParseException("could not parse trigger incident event context. missing required field [{}]",
+ XField.TYPE.getPreferredName());
+ }
+
+ switch (type) {
+ case LINK:
+ if (href == null) {
+ throw new ElasticsearchParseException("could not parse trigger incident event context. missing required field " +
+ "[{}] for [{}] context", XField.HREF.getPreferredName(), Type.LINK.name().toLowerCase(Locale.ROOT));
+ }
+ if (src != null) {
+ throw new ElasticsearchParseException("could not parse trigger incident event context. unexpected field [{}] for " +
+ "[{}] context", XField.SRC.getPreferredName(), Type.LINK.name().toLowerCase(Locale.ROOT));
+ }
+ if (alt != null) {
+ throw new ElasticsearchParseException("could not parse trigger incident event context. unexpected field [{}] for " +
+ "[{}] context", XField.ALT.getPreferredName(), Type.LINK.name().toLowerCase(Locale.ROOT));
+ }
+ return link(href, text);
+ case IMAGE:
+ if (src == null) {
+ throw new ElasticsearchParseException("could not parse trigger incident event context. missing required field " +
+ "[{}] for [{}] context", XField.SRC.getPreferredName(), Type.IMAGE.name().toLowerCase(Locale.ROOT));
+ }
+ if (text != null) {
+ throw new ElasticsearchParseException("could not parse trigger incident event context. unexpected field [{}] for " +
+ "[{}] context", XField.TEXT.getPreferredName(), Type.IMAGE.name().toLowerCase(Locale.ROOT));
+ }
+ return image(src, href, alt);
+ default:
+ throw new ElasticsearchParseException("could not parse trigger incident event context. unknown context type [{}]",
+ type);
+ }
+ }
+
+
  public static class Template implements ToXContentObject {
 
  final Type type;

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/notification/pagerduty/PagerDutyAccount.java

@@ -48,8 +48,8 @@ public IncidentEventDefaults getDefaults() {
  return eventDefaults;
  }
 
- public SentEvent send(IncidentEvent event, Payload payload) throws IOException {
- HttpRequest request = event.createRequest(serviceKey, payload);
+ public SentEvent send(IncidentEvent event, Payload payload, String watchId) throws IOException {
+ HttpRequest request = event.createRequest(serviceKey, payload, watchId);
  HttpResponse response = httpClient.execute(request);
  return SentEvent.responded(event, request, response);
  }

x-pack/plugin/watcher/src/test/java/org/elasticsearch/xpack/watcher/actions/pagerduty/PagerDutyActionTests.java

@@ -111,7 +111,7 @@ public void testExecute() throws Exception {
  when(response.status()).thenReturn(200);
  HttpRequest request = mock(HttpRequest.class);
  SentEvent sentEvent = SentEvent.responded(event, request, response);
- when(account.send(event, payload)).thenReturn(sentEvent);
+ when(account.send(event, payload, wid.watchId())).thenReturn(sentEvent);
  when(service.getAccount(accountName)).thenReturn(account);
 
  Action.Result result = executable.execute("_id", ctx, payload);