Status and incidents: outage and maintenance notices

import express from "express";
import { verify } from "./verify.js"; // from Webhook subscriptions: Verify the signature

// Your own table: which brand each agent answers for.
const BRAND_BY_AGENT = {
  "agt_01M5…": "Zylora",
  "agt_01M6…": "Zylora",
  "agt_01M7…": "Kesar Foods",
};

const seen = new Set();     // use a table with a unique key in production
const lastSeq = new Map();  // incident id -> newest update handled

const app = express();
app.post("/mirai/events", express.raw({ type: "application/json" }), (req, res) => {
  if (!verify(req.body, req.get("X-Mirai-Signature") ?? "", process.env.MIRAI_DESTINATION_SECRET)) {
    return res.sendStatus(401);
  }
  const event = JSON.parse(req.body);
  if (seen.has(event.id)) return res.sendStatus(200);
  seen.add(event.id);

  const group = event.type.split(".")[0];
  if (event.test || (group !== "incident" && group !== "maintenance")) return res.sendStatus(200);

  const { incident, impact } = event.data;
  const seq = incident.latest_update.seq;
  if (seq <= (lastSeq.get(incident.id) ?? 0)) return res.sendStatus(200); // an older update came late
  lastSeq.set(incident.id, seq);

  // Failed calls per brand. No numbers for us: tell every brand.
  const failed = new Map();
  if (impact) {
    for (const agent of impact.agents) {
      const brand = BRAND_BY_AGENT[agent.id];
      if (brand) failed.set(brand, (failed.get(brand) ?? 0) + agent.calls_failed);
    }
  } else {
    for (const brand of Object.values(BRAND_BY_AGENT)) failed.set(brand, 0);
  }

  for (const [brand, callsFailed] of failed) {
    queueBrandNotice(brand, {
      title: incident.title,
      state: incident.state,
      message: incident.latest_update.body,
      callsFailed,
      charged: impact?.billed ?? false,
    });
  }
  res.sendStatus(200);
});

import json
import os

from flask import Flask, request

from verify import verify  # from Webhook subscriptions: Verify the signature

# Your own table: which brand each agent answers for.
BRAND_BY_AGENT = {
    "agt_01M5…": "Zylora",
    "agt_01M6…": "Zylora",
    "agt_01M7…": "Kesar Foods",
}

seen = set()   # use a table with a unique key in production
last_seq = {}  # incident id -> newest update handled

app = Flask(__name__)


@app.post("/mirai/events")
def events():
    raw = request.get_data()
    if not verify(raw, request.headers.get("X-Mirai-Signature", ""), os.environ["MIRAI_DESTINATION_SECRET"]):
        return "", 401
    event = json.loads(raw)
    if event["id"] in seen:
        return "", 200
    seen.add(event["id"])

    group = event["type"].split(".")[0]
    if event["test"] or group not in ("incident", "maintenance"):
        return "", 200

    incident, impact = event["data"]["incident"], event["data"]["impact"]
    seq = incident["latest_update"]["seq"]
    if seq <= last_seq.get(incident["id"], 0):
        return "", 200  # an older update came late
    last_seq[incident["id"]] = seq

    # Failed calls per brand. No numbers for us: tell every brand.
    failed = {}
    if impact:
        for agent in impact["agents"]:
            brand = BRAND_BY_AGENT.get(agent["id"])
            if brand:
                failed[brand] = failed.get(brand, 0) + agent["calls_failed"]
    else:
        failed = {brand: 0 for brand in BRAND_BY_AGENT.values()}

    for brand, calls_failed in failed.items():
        queue_brand_notice(brand, {
            "title": incident["title"],
            "state": incident["state"],
            "message": incident["latest_update"]["body"],
            "calls_failed": calls_failed,
            "charged": bool(impact and impact["billed"]),
        })
    return "", 200