@@ -5,7 +5,6 @@ import { requireProjectAccess } from "@/lib/lx/currentSite";
 import { env } from "@/lib/env";
 import { LeadFinder } from "@/components/leads/lead-finder";
 import { LeadActions } from "@/components/leads/lead-actions";
-import { CampaignPanel, type CampaignSummary } from "@/components/leads/campaign-panel";
 import { SenderAddress } from "@/components/leads/sender-address";
 import { MailboxConnect, type ConnectedMailbox } from "@/components/leads/mailbox-connect";
 import { SeedLogins } from "@/components/leads/seed-logins";
@@ -14,7 +13,7 @@ import { RepliesPanel, type ReplyRow } from "@/components/leads/replies-panel";
 import { ContactsPanel } from "@/components/leads/contacts-panel";
 import { IntentPanel, type IntentSignalRow } from "@/components/leads/intent-panel";
 import { contactNiches } from "@/lib/outreach/contactsExport";
-import { campaignFunnels, projectFunnel } from "@/lib/outreach/funnel";
+import { projectFunnel } from "@/lib/outreach/funnel";
 import { listSeedCredentials, type StoredSeedCredential } from "@/lib/outreach/seedCredentials";
 import { RefreshLeads } from "@/components/leads/refresh-leads";
 import { loadAddressSettings } from "@/lib/outreach/postalAddress";
@@ -74,7 +73,7 @@ export default async function LeadsPage({
   // project pages work. It also keeps outreach_sends unwritable from a
   // browser, so the record of what was sent stays honest.
   const supabase = serviceClient();
-  const [{ data: prospectData }, { data: sendData }, { data: campaignData }] = await Promise.all([
+  const [{ data: prospectData }, { data: sendData }] = await Promise.all([
     supabase
       .from("outreach_prospects")
       .select(
@@ -89,51 +88,10 @@ export default async function LeadsPage({
       .eq("project_id", projectId)
       .order("sent_at", { ascending: false })
       .limit(10),
-    supabase
-      .from("outreach_campaigns")
-      .select(
-        "id, name, active, auto_send, daily_send_limit, max_score, queries, seed_urls, last_run_at, last_run_note, auth_required_hosts, pitch_mode, pitch_intro, pitch_ask, pitch_facts, scan_prospects, min_intent, sells_description, angle, sender_name, reply_to",
-      )
-      .eq("project_id", projectId)
-      .order("updated_at", { ascending: false })
-      .limit(10),
   ]);
 
   const prospects = (prospectData as ProspectRow[] | null) ?? [];
   const sends = (sendData as SendRow[] | null) ?? [];
-  const campaignRows = (campaignData as (CampaignSummary & { id: string })[] | null) ?? [];
-
-  // Recent ticks per campaign. last_run_note holds only the newest line, so
-  // without this there is no way to see that a campaign has been erroring for
-  // an hour, or that it has never found anything at all.
-  const { data: runData } = await supabase
-    .from("outreach_campaign_runs")
-    .select("campaign_id, ran_at, summary, ok, errors")
-    .in("campaign_id", campaignRows.map((c) => c.id))
-    .order("ran_at", { ascending: false })
-    .limit(60);
-
-  const runsByCampaign = new Map<string, CampaignSummary["runs"]>();
-  for (const r of (runData as Record<string, unknown>[] | null) ?? []) {
-    const key = r.campaign_id as string;
-    const list = runsByCampaign.get(key) ?? [];
-    if (list.length >= 8) continue;
-    list.push({
-      ran_at: r.ran_at as string,
-      summary: (r.summary as string) ?? "",
-      ok: (r.ok as boolean) ?? true,
-      errors: Array.isArray(r.errors) ? (r.errors as string[]) : [],
-    });
-    runsByCampaign.set(key, list);
-  }
-
-  const campaigns: CampaignSummary[] = campaignRows.map((c) => ({
-    ...c,
-    pitch_facts: Array.isArray(c.pitch_facts) ? c.pitch_facts : [],
-    auth_required_hosts: Array.isArray(c.auth_required_hosts) ? c.auth_required_hosts : [],
-    runs: runsByCampaign.get(c.id) ?? [],
-  }));
-
   const byStatus = new Map<string, number>();
   for (const p of prospects) byStatus.set(p.status, (byStatus.get(p.status) ?? 0) + 1);
 
@@ -152,7 +110,6 @@ export default async function LeadsPage({
     projectId,
     ownerId: access.userId,
   });
-  const canSendLive = Boolean(addressSettings.address);
 
   // The org's default email sender, when it's a connected mailbox rather than
   // an API-key provider — that's what the connect panel reflects back.
@@ -162,12 +119,10 @@ export default async function LeadsPage({
     .eq("id", projectId)
     .maybeSingle();
   const orgId = (projectRow?.organization_id as string | null) ?? null;
-  // Measured outcomes, project-wide and per campaign. Both read the same
-  // tables the pipeline already writes, so this costs two queries rather than
-  // any new bookkeeping.
-  const [funnel, perCampaignFunnel, contacts] = await Promise.all([
+  // Measured outcomes, read from the same tables the pipeline already writes,
+  // so this costs a query rather than any new bookkeeping.
+  const [funnel, contacts] = await Promise.all([
     projectFunnel(projectId),
-    campaignFunnels(projectId),
     contactNiches(projectId),
   ]);
 
@@ -195,17 +150,6 @@ export default async function LeadsPage({
   let seedCredentials: StoredSeedCredential[] = [];
   if (orgId) seedCredentials = await listSeedCredentials(orgId);
 
-  // Hosts any campaign in this project is parked on, waiting for a sign-in.
-  const waitingHosts = [
-    ...new Set(
-      campaigns.flatMap((c) =>
-        Array.isArray((c as { auth_required_hosts?: string[] }).auth_required_hosts)
-          ? ((c as { auth_required_hosts?: string[] }).auth_required_hosts as string[])
-          : [],
-      ),
-    ),
-  ];
-
   let mailbox: ConnectedMailbox | null = null;
   if (orgId) {
     const { data: senderRow } = await supabase
@@ -249,11 +193,9 @@ export default async function LeadsPage({
 
       <LeadFinder projectId={projectId} />
 
-      <CampaignPanel projectId={projectId} campaigns={campaigns} canSendLive={canSendLive} />
-
       <IntentPanel signals={intentSignals} />
 
-      <FunnelPanel project={funnel} campaigns={perCampaignFunnel} />
+      <FunnelPanel project={funnel} campaigns={[]} />
 
       <RepliesPanel replies={replies} />
 
@@ -266,7 +208,7 @@ export default async function LeadsPage({
 
       <SeedLogins
         projectId={projectId}
-        waitingHosts={waitingHosts}
+        waitingHosts={[]}
         credentials={seedCredentials}
       />
 
@@ -284,8 +226,7 @@ export default async function LeadsPage({
 
         {prospects.length === 0 ? (
           <p className="mt-4 text-sm text-[var(--color-muted)]">
-            Nothing yet. Search for businesses above, or set up a campaign to keep the funnel full on
-            its own.
+            Nothing yet. Search for businesses above.
           </p>
         ) : (
           <ul className="mt-4 divide-y divide-[var(--color-border)]">
 
@@ -18,7 +18,6 @@ import { discoverProspects } from "@/lib/outreach/discover";
 import { recordDiscoveredPeople } from "@/lib/outreach/contacts";
 import { generatePitch } from "@/lib/outreach/generatePitch";
 import { leadRunBilling, manualRunPrice } from "@/lib/outreach/billing";
-import { runEmailCampaignTick, CAMPAIGN_COLUMNS, summarize, type CampaignRow } from "@/lib/outreach/runner";
 
 type Ok<T = Record<string, never>> = { ok: true } & T;
 type Err = { ok: false; error: string };
@@ -487,173 +486,3 @@ export async function importPostalAddressAction(input: {
   revalidatePath(leadsPath(input.projectId));
   return { ok: true, address: source, note: `Imported from ${input.from === "account" ? "your account" : "the organization"}.` };
 }
-
-export async function saveCampaignAction(input: {
-  projectId: string;
-  name: string;
-  queries: string;
-  seedUrls: string;
-  maxScore: number;
-  dailySendLimit: number;
-  autoSend: boolean;
-  active: boolean;
-  angle?: string;
-  senderName?: string;
-  replyTo?: string;
-  pitchMode?: "audit" | "custom";
-  pitchIntro?: string;
-  pitchAsk?: string;
-  pitchFacts?: string;
-  scanProspects?: boolean;
-  /**
-   * Minimum public buying intent a lead must show, 0-100. Null or absent
-   * leaves the campaign selecting on resemblance alone, which is what every
-   * campaign did before intent existed.
-   */
-  minIntent?: number | null;
-  /** Plain prose: what this campaign sells. Enables description matching. */
-  sellsDescription?: string;
-}): Promise<Ok<{ note: string }> | Err> {
-  const auth = await requireLeadAccess(input.projectId);
-  if (!auth.ok) return auth;
-  if (!input.name.trim()) return { ok: false, error: "Give the campaign a name." };
-
-  const queries = input.queries.split("\n").map((s) => s.trim()).filter(Boolean);
-  const seedUrls = input.seedUrls.split("\n").map((s) => s.trim()).filter(Boolean);
-  if (!queries.length && !seedUrls.length) {
-    return { ok: false, error: "A campaign needs at least one search query or directory URL." };
-  }
-  const pitchMode = input.pitchMode ?? "audit";
-  const pitchFacts = (input.pitchFacts ?? "")
-    .split("\n")
-    .map((s) => s.trim())
-    .filter(Boolean);
-  if (pitchMode === "custom") {
-    // The same bar the audit pitch holds itself to: without a description
-    // and some declared facts there is nothing truthful for a draft to say,
-    // and the grounding guard would reject every draft anyway.
-    if (!input.pitchIntro?.trim()) {
-      return { ok: false, error: "A custom pitch needs a description of who is writing and why." };
-    }
-    if (!pitchFacts.length) {
-      return {
-        ok: false,
-        error:
-          "A custom pitch needs at least one fact. Drafts may only state what you list here, so an empty list means every draft gets rejected.",
-      };
-    }
-  }
-
-  // Scanning is the audit pitch's evidence step; default it off for a custom
-  // pitch rather than scanning people we're emailing about something else.
-  const scanProspects = input.scanProspects ?? pitchMode === "audit";
-  if (pitchMode === "audit" && !scanProspects) {
-    return {
-      ok: false,
-      error:
-        "The audit pitch is built from scan findings, so it can't run with scanning turned off. Switch to a custom pitch instead.",
-    };
-  }
-
-  if (input.autoSend) {
-    const postal = await loadAddressSettings({ projectId: input.projectId, ownerId: auth.userId });
-    if (!postal.address) {
-      return {
-        ok: false,
-        error:
-          "No sender postal address is set. CAN-SPAM requires one in commercial email, so live sending stays off until you add it above.",
-      };
-    }
-  }
-
-  const { error } = await serviceClient()
-    .from("outreach_campaigns")
-    .upsert(
-      {
-        project_id: input.projectId,
-        owner_id: auth.userId,
-        name: input.name.trim(),
-        channel: "email",
-        active: input.active,
-        queries,
-        seed_urls: seedUrls,
-        max_score: input.maxScore,
-        daily_send_limit: input.dailySendLimit,
-        auto_send: input.autoSend,
-        // Clamped rather than rejected: a bar above 100 silently matches
-        // nothing, which looks like the sweep being broken.
-        min_intent:
-          input.minIntent === null || input.minIntent === undefined
-            ? null
-            : Math.max(0, Math.min(100, Math.round(input.minIntent))),
-        sells_description: input.sellsDescription?.trim() || null,
-        angle: input.angle?.trim() || null,
-        sender_name: input.senderName?.trim() || null,
-        reply_to: input.replyTo?.trim() || null,
-        pitch_mode: pitchMode,
-        pitch_intro: input.pitchIntro?.trim() || null,
-        pitch_ask: input.pitchAsk?.trim() || null,
-        pitch_facts: pitchFacts,
-        scan_prospects: scanProspects,
-      },
-      { onConflict: "project_id,name" },
-    );
-  if (error) return { ok: false, error: error.message };
-
-  revalidatePath(leadsPath(input.projectId));
-  return {
-    ok: true,
-    note: input.autoSend
-      ? `"${input.name}" saved — auto-send is ON, so the cron tick will email real people.`
-      : `"${input.name}" saved. It will find, scan and draft; sending stays off until you turn it on.`,
-  };
-}
-
-export async function runCampaignAction(input: {
-  projectId: string;
-  name: string;
-}): Promise<Ok<{ note: string }> | Err> {
-  const auth = await requireLeadAccess(input.projectId);
-  if (!auth.ok) return auth;
-  const { data } = await serviceClient()
-    .from("outreach_campaigns")
-    .select(CAMPAIGN_COLUMNS)
-    .eq("project_id", input.projectId)
-    .eq("name", input.name)
-    .maybeSingle();
-  if (!data) return { ok: false, error: "Campaign not found." };
-
-  const result = await runEmailCampaignTick(data as CampaignRow);
-  revalidatePath(leadsPath(input.projectId));
-  return { ok: true, note: `${result.campaign}: ${summarize(result)}` };
-}
-
-export async function toggleCampaignAction(input: {
-  projectId: string;
-  name: string;
-  field: "active" | "auto_send";
-  value: boolean;
-}): Promise<Ok<{ note: string }> | Err> {
-  const auth = await requireLeadAccess(input.projectId);
-  if (!auth.ok) return auth;
-  if (input.field === "auto_send" && input.value) {
-    const postal = await loadAddressSettings({ projectId: input.projectId, ownerId: auth.userId });
-    if (!postal.address) {
-      return { ok: false, error: "No sender postal address is set — live sending is blocked until you add one." };
-    }
-  }
-  const { error } = await serviceClient()
-    .from("outreach_campaigns")
-    .update({ [input.field]: input.value })
-    .eq("project_id", input.projectId)
-    .eq("name", input.name);
-  if (error) return { ok: false, error: error.message };
-  revalidatePath(leadsPath(input.projectId));
-  return {
-    ok: true,
-    note:
-      input.field === "active"
-        ? `"${input.name}" ${input.value ? "resumed" : "paused"}.`
-        : `"${input.name}" auto-send ${input.value ? "ON — it will email real people" : "off"}.`,
-  };
-}