Automation Workflows API

db.automations.getAll(): AutomationRule[]

const automations = db.automations.getAll();
console.log(`Active automations: ${automations.filter(a => a.status === 'Active').length}`);

db.automations.getById(id: string): AutomationRule | null

db.automations.create(
  data: Omit<AutomationRule, 'id' | 'createdAt' | 'updatedAt' | 'stats'>
): AutomationRule

const automation = db.automations.create({
  name: 'Welcome Series',
  description: 'Onboarding sequence for new subscribers',
  status: 'Active',
  trigger: {
    type: 'contact_added_to_list',
    listId: 'list_new_subscribers'
  },
  nodes: [
    {
      id: 'node_1',
      type: 'send_email',
      subject: 'Welcome to CAFH!',
      content: '<p>Welcome email content...</p>'
    },
    {
      id: 'node_2',
      type: 'wait',
      amount: 3,
      unit: 'days'
    },
    {
      id: 'node_3',
      type: 'send_email',
      subject: 'Getting Started Guide',
      content: '<p>Follow-up content...</p>'
    }
  ]
});

db.automations.save(rule: AutomationRule): AutomationRule

db.automations.delete(id: string): void

db.automations.runForContact(
  automationId: string,
  contact: Contact
): Promise<AutomationExecution>

const contact = db.crm.getById('c_12345');
if (contact) {
  const exec = await db.automations.runForContact('aut_123', contact);
  console.log('Execution status:', exec.status);
  console.log('Log:', exec.log);
}

db.automations.runForSegment(
  automationId: string,
  targetType: 'all' | 'subscribed' | 'list' | 'tag',
  targetValue?: string
): Promise<{ count: number; executions: AutomationExecution[] }>

// Run for all subscribed contacts
const result = await db.automations.runForSegment(
  'aut_welcome',
  'subscribed'
);
console.log(`Processed ${result.count} contacts`);

// Run for specific list
const listResult = await db.automations.runForSegment(
  'aut_vip',
  'list',
  'list_vip_members'
);

db.automations.getExecutions(): AutomationExecution[]

interface SendEmailNode {
  id: string;
  type: 'send_email';
  subject: string;
  content: string;
  fromName?: string;
}

{
  id: 'node_1',
  type: 'send_email',
  subject: 'Welcome!',
  content: '<h1>Welcome</h1>',
  fromName: 'CAFH Team'
}

interface WaitNode {
  id: string;
  type: 'wait';
  amount: number;
  unit: 'minutes' | 'hours' | 'days';
}

{
  id: 'node_2',
  type: 'wait',
  amount: 2,
  unit: 'days'
}

interface ConditionNode {
  id: string;
  type: 'condition';
  check: 'email_opened' | 'email_clicked' | 'has_tag' | 'in_list';
  value?: string;
  branchTrue: AutomationNode[];
  branchFalse: AutomationNode[];
}

{
  id: 'node_3',
  type: 'condition',
  check: 'email_opened',
  branchTrue: [
    {
      id: 'node_4',
      type: 'update_tag',
      action: 'add',
      tag: 'Engaged'
    }
  ],
  branchFalse: [
    {
      id: 'node_5',
      type: 'send_email',
      subject: 'Are you still interested?',
      content: '<p>Re-engagement email...</p>'
    }
  ]
}

interface UpdateTagNode {
  id: string;
  type: 'update_tag';
  action: 'add' | 'remove';
  tag: string;
}

{
  id: 'node_6',
  type: 'update_tag',
  action: 'add',
  tag: 'Newsletter Subscriber'
}

interface MoveToListNode {
  id: string;
  type: 'move_to_list';
  listId: string;
}

{
  id: 'node_7',
  type: 'move_to_list',
  listId: 'list_active_members'
}

interface EndNode {
  id: string;
  type: 'end';
}

interface AutomationTrigger {
  type: AutomationTriggerType;
  listId?: string;        // For contact_added_to_list
  tag?: string;           // For tag_added
  campaignId?: string;    // For campaign events
  inactiveDays?: number;  // For no_activity
  scheduledAt?: string;   // For scheduled_date
}

type AutomationTriggerType =
  | 'contact_added_to_list'
  | 'tag_added'
  | 'campaign_sent'
  | 'campaign_opened'
  | 'campaign_clicked'
  | 'no_activity'
  | 'scheduled_date'
  | 'manual';

// Create a sophisticated re-engagement workflow
const reengagement = db.automations.create({
  name: 'Re-engagement Campaign',
  description: 'Win back inactive subscribers',
  status: 'Active',
  trigger: {
    type: 'no_activity',
    inactiveDays: 30
  },
  nodes: [
    {
      id: 'n1',
      type: 'send_email',
      subject: 'We miss you!',
      content: '<p>Haven\'t heard from you...</p>'
    },
    {
      id: 'n2',
      type: 'wait',
      amount: 3,
      unit: 'days'
    },
    {
      id: 'n3',
      type: 'condition',
      check: 'email_opened',
      branchTrue: [
        {
          id: 'n4',
          type: 'update_tag',
          action: 'add',
          tag: 'Re-engaged'
        },
        {
          id: 'n5',
          type: 'send_email',
          subject: 'Great to have you back!',
          content: '<p>Thanks for opening...</p>'
        }
      ],
      branchFalse: [
        {
          id: 'n6',
          type: 'update_tag',
          action: 'add',
          tag: 'Inactive'
        },
        {
          id: 'n7',
          type: 'move_to_list',
          listId: 'list_inactive'
        }
      ]
    },
    {
      id: 'n8',
      type: 'end'
    }
  ]
});

// Execute for inactive segment
const result = await db.automations.runForSegment(
  reengagement.id,
  'tag',
  'Inactive'
);

console.log(`Processed ${result.count} inactive contacts`);

interface AutomationRule {
  id: string;
  name: string;
  description?: string;
  status: 'Active' | 'Paused' | 'Draft';
  trigger: AutomationTrigger;
  nodes: AutomationNode[];
  nodePositions?: Record<string, { x: number; y: number }>;
  createdAt: string;
  updatedAt: string;
  stats: {
    totalExecutions: number;
    completed: number;
    emailsSent: number;
    tagsApplied: number;
  };
}

interface AutomationExecution {
  id: string;
  automationId: string;
  contactId: string;
  contactEmail: string;
  startedAt: string;
  completedAt?: string;
  currentStep: number;
  status: 'running' | 'completed' | 'failed';
  log: string[];
}