Workflows & Automation

export interface AutomationWorkflow {
  id: string;
  name: string;
  description: string;
  trigger_type: string;           // 'rfm_segment', 'birthday', etc.
  trigger_condition: string;      // 'equals', '>=', 'in_days'
  trigger_value: string;          // Segment ID or condition value
  trigger_config: Record<string, any>;
  action_type: string;            // 'create_campaign_with_template'
  action_payload: Record<string, any>;
  action_config: Record<string, any>;
  category: 'rfm' | 'behavioral' | 'temporal' | 'engagement';
  priority: 'high' | 'medium' | 'low';
  is_premium: boolean;
}

{
  id: 'birthday-automatic-celebration',
  trigger_type: 'birthday',
  trigger_condition: 'in_days',
  trigger_value: '7',
  action_type: 'create_campaign_with_template',
  action_payload: {
    template_id: 'birthday-celebration',
    channel: 'email'
  },
  priority: 'high'
}

{
  id: 'nps-negative-escalation',
  trigger_type: 'nps_score',
  trigger_condition: '<=',
  trigger_value: '6',
  action_type: 'internal_alert_and_campaign',
  action_payload: {
    alert_team: true,
    alert_channels: ['email', 'slack'],
    create_followup_campaign: true
  },
  priority: 'high'
}

{
  id: 'first-reservation-welcome',
  trigger_type: 'reservation_completed',
  trigger_condition: 'first_visit',
  action_type: 'create_campaign_with_template',
  action_payload: {
    template_id: 'potential-loyalists-welcome',
    schedule_offset_days: 1
  },
  priority: 'medium'
}

{
  id: 'reservation-completed-feedback',
  trigger_type: 'reservation_completed',
  trigger_condition: 'days_after',
  trigger_value: '2',
  trigger_config: {
    days_after_completion: 2,
    exclude_if_recent_feedback: true,
    feedback_cooldown_days: 30
  },
  priority: 'medium'
}

trigger_config: {
  min_days_since_last_automation: 30  // Wait 30 days between runs
}

action_config: {
  max_per_customer: 1,                // Only once per customer
  max_per_customer_per_year: 1        // Only once per year (birthdays)
}

export const syncCoverManager = inngest.createFunction(
  { 
    id: 'sync-cover-manager',
    retries: 3,
  },
  { 
    cron: '*/30 * * * *',  // Every 30 minutes
  },
  async ({ event, step }) => {
    return await step.run('sync-reservations', async () => {
      // Sync logic
    });
  }
);

export const syncRevo = inngest.createFunction(
  { 
    id: 'sync-revo',
    retries: 3,
  },
  { 
    cron: '*/15 * * * *',  // Every 15 minutes
  },
  async ({ event, step }) => {
    // Sync logic
  }
);

export const calculateLoyalty = inngest.createFunction(
  { 
    id: 'calculate-loyalty',
    retries: 2,
  },
  { 
    cron: '0 2 * * *',  // Daily at 2 AM
  },
  async ({ event, step }) => {
    // Calculate RFM, assign tiers
  }
);

import { createClient } from '@/lib/supabase/client';

// Manually run a workflow for a specific customer
async function triggerWorkflow(workflowId: string, customerId: string) {
  const response = await fetch(`/api/automations/${workflowId}/run`, {
    method: 'POST',
    body: JSON.stringify({ customerId })
  });
  
  return response.json();
}

// Example: Trigger birthday workflow
await triggerWorkflow('birthday-automatic-celebration', 'customer-123');

interface WorkflowExecution {
  id: string;
  workflow_id: string;
  customer_id: string;
  triggered_at: string;
  completed_at: string;
  status: 'success' | 'failure' | 'pending';
  action_taken: string;
  result: Record<string, any>;
}