Email Integration Contract

-- Email messages linked to contacts via foreign key
ce_email_messages.contact_id → ce_contacts.id

// No API - direct database reference
// Contact lookup by email
const contact = await supabase
  .from('ce_contacts')
  .select('id, first_name, last_name, email')
  .eq('organization_id', orgId)
  .eq('email', emailAddress)
  .single();

-- Email messages linked to partners via foreign key
ce_email_messages.partner_id → ce_partners.id

// Partner lookup by email domain
const emailDomain = email.split('@')[1];
const partner = await supabase
  .from('ce_partners')
  .select('id, name, domain')
  .eq('organization_id', orgId)
  .eq('domain', emailDomain)
  .single();

-- Trigger: Auto-create activity when email synced
CREATE TRIGGER ce_email_create_activity
  BEFORE INSERT ON ce_email_messages
  FOR EACH ROW
  EXECUTE FUNCTION ce_create_activity_from_email();

interface EmailActivity {
  organization_id: string;
  contact_id: string | null;
  partner_id: string | null;
  lead_id: string | null;
  activity_type: 'email';
  subject: string;
  description: 'Received email' | 'Sent email';
  status: 'completed';
  activity_date: string; // ISO timestamp
  created_by: string | null;
}

import { sendNotification } from '@/platform/notifications';

interface EmailNotification {
  type: 'email_opened' | 'email_clicked' | 'email_bounced';
  recipient_user_id: string;
  data: {
    email_message_id: string;
    contact_name: string;
    subject: string;
    event_timestamp: string;
    url?: string; // For click events
  };
}

import { uploadDocument, getDocumentUrl } from '@/platform/documents';

const GMAIL_SCOPES = [
  'https://www.googleapis.com/auth/gmail.readonly',
  'https://www.googleapis.com/auth/gmail.send',
  'https://www.googleapis.com/auth/gmail.modify',
];

const OUTLOOK_SCOPES = [
  'Mail.Read',
  'Mail.Send',
  'Mail.ReadWrite',
  'offline_access',
];

interface EmailSyncedEvent {
  event_type: 'ce.email.synced';
  organization_id: string;
  email_message_id: string;
  direction: 'inbound' | 'outbound';
  contact_id: string | null;
  partner_id: string | null;
  timestamp: string;
}

interface EmailTrackingEvent {
  event_type: 'ce.email.tracking';
  organization_id: string;
  email_message_id: string;
  tracking_event: 'open' | 'click';
  url?: string; // For click events
  timestamp: string;
  ip_address: string;
  user_agent: string;
}