Account events

app.post("/webhook/platform-events", async (req, res) => {
  const event = req.body;
  if (!event?.eventId || !event?.eventType?.startsWith("account")) {
    return res.status(200).send("OK");
  }
  res.status(200).send("OK");

  switch (event.eventType) {
    case "account:created":
      await onAccountCreated(event.payload);
      break;
    case "account-custom_field_value:changed":
      await onAccountCustomFieldChanged(event.payload);
      break;
    default:
      break;
  }
});

{
  account: {
    id: string;
    name: string;
    domain?: string;
    industry?: string;
    size?: string;
    status: string;
    health: string;
    classification: string;
    metadata?: Record<string, unknown>;
    customFields?: Record<string, string[]>;
    createdAt: Date;
    updatedAt: Date;
  };
}

{
  account: AccountData;
  previousAccount: AccountData; // Previous state
}

{
  previousAccount: AccountData; // The deleted account data
}

{
  changedCustomFields: Array<{
    fieldUid: string;
    newValues: string[];
    changeType: "added";
  }>;
}

{
  changedCustomFields: Array<{
    fieldUid: string;
    previousValues: string[];
    changeType: "removed";
  }>;
}

{
  changedCustomFields: Array<{
    fieldUid: string;
    previousValues: string[];
    newValues: string[];
    changeType: "updated";
  }>;
}

{
  customerContact: {
    id: string;
    firstName: string;
    lastName: string;
    email: string;
    phone?: string;
    jobTitle?: string;
    type: string;
    status: string;
    accountId: string;
    metadata?: Record<string, unknown>;
    customFields?: Record<string, string[]>;
    createdAt: Date;
    updatedAt: Date;
  };
}

{
  customerContact: CustomerContactData;
  previousCustomerContact: CustomerContactData;
}

{
  previousCustomerContact: CustomerContactData;
}

{
  relationship: {
    id: string;
    parentAccountId: string;
    childAccountId: string;
    relationshipType: string;
    metadata?: Record<string, unknown>;
    createdAt: Date;
    updatedAt: Date;
  };
}

{
  relationship: AccountRelationshipData;
  previousRelationship: AccountRelationshipData;
}

{
  previousRelationship: AccountRelationshipData;
}

{
  activity: {
    id: string;
    accountId: string;
    title: string;
    description?: string;
    activityType: string;
    status: string;
    scheduledAt?: Date;
    completedAt?: Date;
    assignedUserId?: string;
    metadata?: Record<string, unknown>;
    createdAt: Date;
    updatedAt: Date;
  };
}

{
  activity: AccountActivityData;
  previousActivity: AccountActivityData;
}

{
  previousActivity: AccountActivityData;
}

{
  note: {
    id: string;
    accountId: string;
    title: string;
    content: string;
    visibility: string;
    authorId: string;
    metadata?: Record<string, unknown>;
    createdAt: Date;
    updatedAt: Date;
  };
}

{
  note: AccountNoteData;
  previousNote: AccountNoteData;
}

{
  previousNote: AccountNoteData;
}

{
  task: {
    id: string;
    accountId: string;
    title: string;
    description?: string;
    status: string;
    priority: string;
    dueDate?: Date;
    assignedUserId?: string;
    metadata?: Record<string, unknown>;
    createdAt: Date;
    updatedAt: Date;
  };
}

{
  task: AccountTaskData;
  previousTask: AccountTaskData;
}

{
  previousTask: AccountTaskData;
}

interface AccountEventEnvelope<T> {
  eventId: string;
  eventType: string; // One of the AccountEvents enum values
  timestamp: string;
  orgId: string;
  actor: {
    id: string;
    type: string;
    email: string;
  };
  payload: T;
}

function handleAccountHealthChange(payload) {
  const { account, previousAccount } = payload;

  if (account.health === "At Risk" && previousAccount.health !== "At Risk") {
    // Account became at risk
    triggerAccountReview(account.id);
    notifyAccountManager(account.id);
  } else if (
    account.health === "Healthy" &&
    previousAccount.health === "At Risk"
  ) {
    // Account recovered
    logAccountRecovery(account.id);
  }
}

function handleContactCreated(payload) {
  const { customerContact } = payload;

  // Sync to CRM
  syncToCRM({
    type: "contact",
    id: customerContact.id,
    email: customerContact.email,
    name: `${customerContact.firstName} ${customerContact.lastName}`,
    accountId: customerContact.accountId,
  });

  // Update marketing lists
  updateMarketingSegmentation(customerContact);
}

function handleTaskCreated(payload) {
  const { task } = payload;

  if (task.priority === "High" && task.dueDate) {
    // Create calendar reminder
    createCalendarEvent({
      title: task.title,
      date: task.dueDate,
      assignee: task.assignedUserId,
    });
  }

  // Update project management tool
  syncToProjectManagement(task);
}