Edits history of script submission #22627 for ' New or Updated Incident (pagerduty)'

• bunnative

  Edit in Windmill

  Embed

  //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
  }
  

  Submitted by hugo989 5 days ago