Cold outreach that earns a reply.
Not ignored.

Learned ICP Winning Patterns (Calculated from Historical Responses) 77.8% Positive Ratio

-- Track replies and link to original emails
CREATE TABLE public.email_replies (
  id              UUID DEFAULT gen_random_uuid() PRIMARY KEY,
  user_id         UUID REFERENCES auth.users(id) ON DELETE CASCADE,
  email_id        UUID REFERENCES public.emails(id),
  lead_id         UUID REFERENCES public.leads(id),
  prospect_text   TEXT NOT NULL,
  sentiment       TEXT CHECK (sentiment IN ('positive','negative','neutral','objection')),
  intent_signals  JSONB,    -- ['interested', 'wants_demo', 'not_right_time']
  key_phrases     TEXT[],   -- phrases they responded to
  implied_pain    TEXT,     -- what pain point resonated
  meeting_booked  BOOLEAN DEFAULT false,
  replied_at      TIMESTAMPTZ DEFAULT now(),
  created_at      TIMESTAMPTZ DEFAULT now()
);

-- Store user's learned patterns
CREATE TABLE public.reply_intelligence (
  id              UUID DEFAULT gen_random_uuid() PRIMARY KEY,
  user_id         UUID REFERENCES auth.users(id) ON DELETE CASCADE UNIQUE,
  insights        JSONB,    -- ReplyInsight[] — the learned patterns
  total_replies   INTEGER DEFAULT 0,
  positive_count  INTEGER DEFAULT 0,
  avg_reply_rate  DECIMAL(5,2),
  last_updated    TIMESTAMPTZ DEFAULT now()
);

-- Auto-update intelligence when new reply comes in
CREATE OR REPLACE FUNCTION update_reply_intelligence()
RETURNS trigger AS $$
BEGIN
  INSERT INTO public.reply_intelligence (user_id, total_replies, positive_count)
  VALUES (NEW.user_id, 1, CASE WHEN NEW.sentiment = 'positive' THEN 1 ELSE 0 END)
  ON CONFLICT (user_id) DO UPDATE SET
    total_replies  = reply_intelligence.total_replies + 1,
    positive_count = reply_intelligence.positive_count + (CASE WHEN NEW.sentiment = 'positive' THEN 1 ELSE 0 END),
    avg_reply_rate = (reply_intelligence.positive_count::DECIMAL / (reply_intelligence.total_replies + 1)) * 100,
    last_updated   = now();
  RETURN NEW;
END;
$$ LANGUAGE plpgsql SECURITY DEFINER;

CREATE TRIGGER on_reply_received
  AFTER INSERT ON public.email_replies
  FOR EACH ROW EXECUTE FUNCTION update_reply_intelligence();

ALTER TABLE public.email_replies ENABLE ROW LEVEL SECURITY;
ALTER TABLE public.reply_intelligence ENABLE ROW LEVEL SECURITY;
CREATE POLICY "Users own replies" ON public.email_replies FOR ALL USING (auth.uid() = user_id);
CREATE POLICY "Users own intelligence" ON public.reply_intelligence FOR ALL USING (auth.uid() = user_id);

-- ── SEND TIMING & SCHEDULES ARCHITECTURE (PostgreSQL / Supabase) ──
CREATE TABLE public.send_schedules (
  id             UUID DEFAULT gen_random_uuid() PRIMARY KEY,
  email_id       UUID REFERENCES public.emails(id) ON DELETE CASCADE,
  lead_id        UUID REFERENCES public.leads(id) ON DELETE CASCADE,
  user_id        UUID REFERENCES auth.users(id) ON DELETE CASCADE,
  scheduled_for  TIMESTAMPTZ NOT NULL,
  sent_at        TIMESTAMPTZ,
  confidence     INTEGER,    -- 0-100, how confident in timing prediction
  data_points    INTEGER,    -- number of activity observations used
  timing_reason  TEXT,       -- human-readable explanation
  status         TEXT DEFAULT 'scheduled' CHECK (status IN ('scheduled', 'sent', 'cancelled')),
  created_at     TIMESTAMPTZ DEFAULT now()
);

-- High-performance Index for the scheduled cron worker
CREATE INDEX schedule_due ON public.send_schedules (scheduled_for, status)
  WHERE status = 'scheduled';

-- Enable Row Level Security (RLS)
ALTER TABLE public.send_schedules ENABLE ROW LEVEL SECURITY;
CREATE POLICY "Users manage own schedules" ON public.send_schedules FOR ALL USING (auth.uid() = user_id);

-- ── DOMAIN HEALTH & DELIVERABILITY SHIELD (PostgreSQL / Supabase) ──
CREATE TABLE public.domain_health_logs (
  id               UUID DEFAULT gen_random_uuid() PRIMARY KEY,
  user_id          UUID REFERENCES auth.users(id) ON DELETE CASCADE,
  domain           TEXT NOT NULL,
  overall_score    INTEGER NOT NULL CHECK (overall_score >= 0 AND overall_score <= 100),
  risk_level       TEXT CHECK (risk_level IN ('clean', 'watch', 'warning', 'critical', 'blacklisted')),
  predicted_inbox  INTEGER NOT NULL,
  checks_summary   JSONB NOT NULL,    -- SPF, DKIM, DMARC, MX, Blacklists, Bounce, Volume
  recommendations  JSONB,            -- DomainFix[]
  auto_pause       BOOLEAN DEFAULT false,
  checked_at       TIMESTAMPTZ DEFAULT now()
);

CREATE INDEX idx_domain_health_user ON public.domain_health_logs (user_id, domain, checked_at DESC);

-- Enable Row Level Security (RLS)
ALTER TABLE public.domain_health_logs ENABLE ROW LEVEL SECURITY;
CREATE POLICY "Users own domain health logs" ON public.domain_health_logs FOR ALL USING (auth.uid() = user_id);

Services & Compliance Hub

Set Up Your Outbound Engine

Step 1 of 3