Keep team in sync

import { createJob, generateText } from "terse-sdk";
import { z } from "zod";
import {
  AttioObject,
  SlackChannel,
  Skills,
  Triggers,
  toolbox,
  type AttioDealRecordUpdatedTrigger,
} from "../terse.generated";
 
createJob({
  name: "Brief the team when a deal hits Negotiation",
  triggers: [Triggers.attio.onRecordUpdated({ object: AttioObject.Deal })],
  filter: async (event: AttioDealRecordUpdatedTrigger) => {
    // "Deal stage" attribute id — record.updated fires once per changed attribute,
    // so this keeps other deal edits from re-triggering the brief.
    return (
      event.resourceIds.attribute_id === "<STAGE_ATTRIBUTE_ID>" &&
      event.record.values.stage?.title === "Negotiation"
    );
  },
  onTrigger: async (event: AttioDealRecordUpdatedTrigger) => {
    const brief = await generateText({
      prompt:
        `A deal just moved to Negotiation. Research it and fill in the brief. ` +
        `Use the CRM (records, notes, meetings) as the source of truth for the deal, ` +
        `stakeholders, history, and risks. Use the web only for signals — recent public ` +
        `news about the company: funding, launches, hiring. If a section has nothing ` +
        `substantive, return an empty list rather than padding it. List stakeholders ` +
        `as "Name — role"; use "Unknown" for value or owner when not set. ` +
        `Context: ${event.formatForAgentRunner()}`,
      skills: [Skills.attio({ object: AttioObject.Deal }), Skills.web()],
      outputSchema: DealBrief,
    });
 
    await toolbox.slack.sendMessage({
      channelId: SlackChannel.DealDesk.channelId,
      message: renderBrief(brief),
      thread_ts: null,
      blocks: null,
    });
  },
});
 
function renderBrief(brief: DealBrief): string {
  return [
    `:handshake: *Deal moved to Negotiation: ${brief.dealName}*`,
    `*Deal*\n• Value: ${brief.dealValue}\n• Owner: ${brief.owner}`,
    `*Stakeholders*\n_Who we know:_\n${bullets(brief.knownStakeholders)}\n_Who's missing:_\n${bullets(brief.missingStakeholders)}`,
    `*History*\n${bullets(brief.history)}`,
    `*Signals*\n${bullets(brief.signals)}`,
    `*Risks*\n${bullets(brief.risks)}`,
    `*The ask this week*\n${brief.askThisWeek}`,
  ].join("\n\n");
}
 
function bullets(items: string[]): string {
  return items.length > 0
    ? items.map((item) => `• ${item}`).join("\n")
    : "• None found";
}
 
const DealBrief = z.object({
  dealName: z.string(),
  dealValue: z.string(),
  owner: z.string(),
  knownStakeholders: z.array(z.string()),
  missingStakeholders: z.array(z.string()),
  history: z.array(z.string()),
  signals: z.array(z.string()),
  risks: z.array(z.string()),
  askThisWeek: z.string(),
});
type DealBrief = z.infer<typeof DealBrief>;