Webhooks Workflows

import { createHmac } from "node:crypto";

export default async (request) => {
  const payload = await request.text();
  const event = JSON.parse(payload);

  const signature = createHmac("sha256", process.env.WEBHOOK_SECRET)
    .update(payload)
    .digest("hex");
  if (signature !== request.headers.get("jam-signature")) {
    return new Response(null, { status: 400 });
  }

  if (event.origin !== "recording_link") {
    return new Response(null, { status: 200 });
  }

  await fetch(process.env.SLACK_WEBHOOK_URL, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({
      text: `New Jam from ${event.author.email}: <${event.jamUrl}|${event.title ?? "Untitled Jam"}>`,
    }),
  });

  return new Response(null, { status: 200 });
};

import { createHmac } from "node:crypto";

export default async (request) => {
  const payload = await request.text();
  const event = JSON.parse(payload);

  const signature = createHmac("sha256", process.env.WEBHOOK_SECRET)
    .update(payload)
    .digest("hex");
  if (signature !== request.headers.get("jam-signature")) {
    return new Response(null, { status: 400 });
  }

  const title = event.title || `Bug from ${event.author.email}`;
  const description = [
    event.jamUrl,
    "",
    event.description ?? "",
    event.originalUrl ? `Captured on: ${event.originalUrl}` : "",
  ].join("\n");

  await fetch("https://api.linear.app/graphql", {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
      Authorization: process.env.LINEAR_API_KEY,
    },
    body: JSON.stringify({
      query: `
        mutation IssueCreate($input: IssueCreateInput!) {
          issueCreate(input: $input) { success issue { id } }
        }
      `,
      variables: {
        input: {
          teamId: process.env.LINEAR_TEAM_ID,
          title,
          description,
        },
      },
    }),
  });

  return new Response(null, { status: 200 });
};

import { createHmac } from "node:crypto";

const KEY_ACCOUNT_DOMAINS = new Set(["acme.com", "bigco.com"]);

export default async (request) => {
  const payload = await request.text();
  const event = JSON.parse(payload);

  const signature = createHmac("sha256", process.env.WEBHOOK_SECRET)
    .update(payload)
    .digest("hex");
  if (signature !== request.headers.get("jam-signature")) {
    return new Response(null, { status: 400 });
  }

  const host = event.originalUrl ? new URL(event.originalUrl).hostname : "";
  const isKeyAccount = [...KEY_ACCOUNT_DOMAINS].some(
    (d) => host === d || host.endsWith(`.${d}`),
  host = event.originalUrl ? new URL(event.originalUrl).hostname : "";
  const isKeyAccount = [...KEY_ACCOUNT_DOMAINS].some(
    (d) => host === d || host.endsWith(`.${d}`),
  );

  if (isKeyAccount) {
    await postToSlack("#vip-bugs", event);
    await createLinearIssue(event, { priority: 1, labels: ["P0"] });
  } else {
    await createLinearIssue(event, { priority: 3, labels: ["triage"] });
  }

  return new Response(null, { status: 200 });
};