Account events

{
  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 AccountSNSEvent<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);
}