Use Flow actions

import * as messaging from "@flow/actions/messaging";
import * as tickets from "@flow/actions/tickets";
import { defineAutomation, schema } from "@flow/automations";

export const prioritizeRequest = defineAutomation({
  name: "prioritizeRequest",
  displayName: "Prioritize Request",
  description: "Prioritize a request and record the reason.",
  triggers: ["direct"],
  tags: ["tickets"],
  input: schema.object({ reason: schema.string() }),
  output: schema.object({ ticketId: schema.string() }),
  run: async (input, _ctx) => {
    /**
     * @step loadTicket
     * @description Load the ticket attached to this automation run.
     */
    const ticketResult = await tickets.get({ ticket: { kind: "primary" } });
    if (ticketResult.outcome === "failed") throw new Error(ticketResult.error.message);
    const ticket = ticketResult.data;

    /**
     * @step prioritizeTicket
     * @description Mark the ticket urgent if it has not changed since it was read.
     */
    const updatedResult = await tickets.update(
      {
        ticket: { kind: "id", id: ticket.id },
        expectedRevision: ticket.revision,
        changes: { priority: "urgent", status: "pending" },
      },
    );
    if (updatedResult.outcome === "failed") throw new Error(updatedResult.error.message);
    const updated = updatedResult.data;

    /**
     * @step recordReason
     * @description Add the prioritization reason for the service team.
     */
    const noteResult = await tickets.addInternalNote(
      { ticket: { kind: "id", id: updated.id }, body: input.reason },
    );
    if (noteResult.outcome === "failed") throw new Error(noteResult.error.message);

    /**
     * @step notifyRequester
     * @description Tell the requester that the ticket was prioritized.
     */
    const notificationResult = await messaging.sendNotification(
      {
        audience: { kind: "requester" },
        message: "Your request was prioritized.",
      },
    );
    if (notificationResult.outcome === "failed") {
      throw new Error(notificationResult.error.message);
    }

    return { ticketId: updated.id };
  },
});

import * as tickets from "@flow/actions/tickets";

const result = await tickets.get({ ticket: { kind: "primary" } });
if (result.outcome === "failed") {
  throw new Error(result.error.message);
}
return { ticketId: result.data.id };