New or Updated Incident

//native

import * as wmill from "windmill-client"

/**

 * New or Updated Incident

 * Polls incidents and emits those whose status changed since the last run (created, acknowledged, or resolved), tracked via Windmill state on last_status_change_at. Optionally filter by statuses and service IDs. First run sets the watermark and emits nothing. Detects changes within the most recently created incidents window (up to 100).

 */

export async function main(

  auth: RT.Pagerduty,

  statuses: ("triggered" | "acknowledged" | "resolved")[] | undefined,

  service_ids: string[] | undefined,

) {

  const lastChecked: string | undefined = await wmill.getState()

  const url = new URL("https://api.pagerduty.com/incidents")

  url.searchParams.append("sort_by", "created_at:desc")

  url.searchParams.append("limit", "100")

  if (statuses) for (const s of statuses) url.searchParams.append("statuses[]", s)

  if (service_ids)

    for (const s of service_ids) url.searchParams.append("service_ids[]", s)

  const response = await fetch(url, {

    method: "GET",

    headers: {

      Authorization: `Token token=${auth.token}`,

      Accept: "application/vnd.pagerduty+json;version=2",

    },

  })

  if (!response.ok) {

    throw new Error(`${response.status} ${await response.text()}`)

  }

  const data = await response.json()

  const incidents: Array<{ last_status_change_at: string }> =

    data.incidents ?? []

  const maxWatermark = incidents.reduce(

    (max, i) => (i.last_status_change_at > max ? i.last_status_change_at : max),

    lastChecked ?? "",

  )

  // First run: record the watermark and don't emit a backlog.

  if (lastChecked === undefined) {

    await wmill.setState(maxWatermark)

    return []

  }

  const fresh = incidents

    .filter((i) => i.last_status_change_at > lastChecked)

    .sort((a, b) =>

      a.last_status_change_at.localeCompare(b.last_status_change_at),

    )

  if (maxWatermark > lastChecked) {

    await wmill.setState(maxWatermark)

  }

  return fresh

}