Upload server.ts with huggingface_hub

server.ts

@@ -0,0 +1,1065 @@
+import express from "express";
+import cors from "cors";
+import morgan from "morgan";
+import axios from "axios";
+import path from "path";
+import { createServer as createViteServer } from "vite";
+import { getAiCompletion } from "./src/lib/aiService"; // This won't work in server.ts as it's TSX based
+import { requireModulELicense } from "./src/server/middleware/auth";
+
+// ...
+
+// Initial realistic state for fallback / offline / testing mode
+let mockDb = {
+  campaigns: [
+    {
+      id: "camp_9901",
+      name: "Enterprise SaaS Outbound Q3",
+      status: "ACTIVE",
+      created_at: "2026-07-15T10:00:00.000Z",
+      lead_count: 1420,
+      sent_count: 3840,
+      open_count: 2150,
+      reply_count: 168,
+      bounce_count: 24,
+      click_count: 430,
+      timezone: "America/New_York",
+      start_schedule: "09:00",
+      end_schedule: "18:00",
+      track_settings: "TRACK_EMAIL_OPEN_AND_CLICK",
+      send_as_plain_text: false,
+      follow_up_percentage: 85,
+      unsubscribe_text: "Reply unsubscribe to stop receiving emails.",
+      stop_lead_settings: "REPLIED",
+      sequences: [
+        {
+          id: "seq_1",
+          seq_number: 1,
+          delay_days: 0,
+          subject: "Quick question regarding {{company_name}}'s outbound infrastructure",
+          email_body: "<p>Hi {{first_name}},</p><p>Noticed you are scaling your growth team at {{company_name}}. Are you currently looking to optimize your cold outreach deliverability and warmup automation?</p><p>Best,<br>Alex</p>",
+          variant_distribution_percentage: 50,
+          variants: [
+            {
+              id: "var_1a",
+              variant_label: "Variant A",
+              subject: "Quick question regarding {{company_name}}'s outbound infrastructure",
+              email_body: "<p>Hi {{first_name}},</p><p>Noticed you are scaling your growth team at {{company_name}}. Are you currently looking to optimize your cold outreach deliverability and warmup automation?</p><p>Best,<br>Alex</p>"
+            },
+            {
+              id: "var_1b",
+              variant_label: "Variant B (Shorter)",
+              subject: "{{first_name}} - {{company_name}} outbound efficiency",
+              email_body: "<p>Hey {{first_name}},</p><p>We helped similar SaaS leaders double their positive response rates without hitting spam filters. Open to a 3-min loom?</p><p>Alex</p>"
+            }
+          ]
+        },
+        {
+          id: "seq_2",
+          seq_number: 2,
+          delay_days: 3,
+          subject: "Re: Quick question regarding {{company_name}}",
+          email_body: "<p>Hi {{first_name}}, following up on my previous note. Did you have a chance to look at this?</p>",
+          variant_distribution_percentage: 100,
+          variants: []
+        }
+      ],
+      email_account_ids: ["acc_101", "acc_102"]
+    },
+    {
+      id: "camp_9902",
+      name: "Fintech Growth & Compliance Sequence",
+      status: "PAUSED",
+      created_at: "2026-07-20T14:30:00.000Z",
+      lead_count: 850,
+      sent_count: 1200,
+      open_count: 620,
+      reply_count: 42,
+      bounce_count: 11,
+      click_count: 98,
+      timezone: "Europe/London",
+      start_schedule: "08:30",
+      end_schedule: "17:30",
+      track_settings: "TRACK_EMAIL_OPEN",
+      send_as_plain_text: true,
+      follow_up_percentage: 90,
+      unsubscribe_text: "Click here to unsubscribe",
+      stop_lead_settings: "REPLIED",
+      sequences: [
+        {
+          id: "seq_21",
+          seq_number: 1,
+          delay_days: 0,
+          subject: "Compliance streamline for {{company_name}}",
+          email_body: "<p>Hi {{first_name}}, wanted to share our automated compliance blueprint tailored for {{company_name}}.</p>",
+          variant_distribution_percentage: 100,
+          variants: []
+        }
+      ],
+      email_account_ids: ["acc_103"]
+    },
+    {
+      id: "camp_9903",
+      name: "AI Tech Founders Pilot",
+      status: "ACTIVE",
+      created_at: "2026-08-01T09:15:00.000Z",
+      lead_count: 2400,
+      sent_count: 6100,
+      open_count: 3890,
+      reply_count: 310,
+      bounce_count: 45,
+      click_count: 820,
+      timezone: "America/Los_Angeles",
+      start_schedule: "09:00",
+      end_schedule: "17:00",
+      track_settings: "TRACK_EMAIL_OPEN_AND_CLICK",
+      send_as_plain_text: false,
+      follow_up_percentage: 100,
+      unsubscribe_text: "Unsubscribe",
+      stop_lead_settings: "REPLIED",
+      sequences: [
+        {
+          id: "seq_31",
+          seq_number: 1,
+          delay_days: 0,
+          subject: "{{first_name}}, accelerating inference pipelines",
+          email_body: "<p>Hi {{first_name}}, saw your launch on Product Hunt! Curious how {{company_name}} is handling model inference latency?</p>",
+          variant_distribution_percentage: 100,
+          variants: []
+        }
+      ],
+      email_account_ids: ["acc_101", "acc_102", "acc_104"]
+    }
+  ],
+  leads: [
+    {
+      id: "lead_1001",
+      campaign_id: "camp_9901",
+      first_name: "Sarah",
+      last_name: "Jenkins",
+      email: "sarah.jenkins@acmepartner.io",
+      phone_number: "+1 415-555-0182",
+      company_name: "Acme Partner Labs",
+      website: "https://acmepartner.io",
+      location: "San Francisco, CA",
+      linkedin_profile: "https://linkedin.com/in/sarahjenkins-sample",
+      status: "INTERESTED",
+      open_count: 4,
+      click_count: 2,
+      created_at: "2026-07-16T11:20:00.000Z",
+      custom_fields: { tech_stack: "Node/React", team_size: "45", funding_round: "Series B" }
+    },
+    {
+      id: "lead_1002",
+      campaign_id: "camp_9901",
+      first_name: "Marcus",
+      last_name: "Vance",
+      email: "m.vance@vanguardflow.co",
+      phone_number: "+1 212-555-0199",
+      company_name: "Vanguard Flow Systems",
+      website: "https://vanguardflow.co",
+      location: "New York, NY",
+      linkedin_profile: "https://linkedin.com/in/marcusvance-sample",
+      status: "MEETING_BOOKED",
+      open_count: 6,
+      click_count: 3,
+      created_at: "2026-07-16T12:45:00.000Z",
+      custom_fields: { tech_stack: "AWS/Python", team_size: "120", funding_round: "Series C" }
+    },
+    {
+      id: "lead_1003",
+      campaign_id: "camp_9901",
+      first_name: "Elena",
+      last_name: "Rostova",
+      email: "elena@cybercorebiotech.com",
+      phone_number: "+44 20 7946 0912",
+      company_name: "CyberCore Biotech",
+      website: "https://cybercorebiotech.com",
+      location: "London, UK",
+      linkedin_profile: "https://linkedin.com/in/elenarostova",
+      status: "REPLIED",
+      open_count: 3,
+      click_count: 1,
+      created_at: "2026-07-17T09:10:00.000Z",
+      custom_fields: { tech_stack: "NextJS", team_size: "80", funding_round: "Series A" }
+    },
+    {
+      id: "lead_1004",
+      campaign_id: "camp_9902",
+      first_name: "David",
+      last_name: "Chen",
+      email: "david.chen@horizonpay.net",
+      phone_number: "+1 650-555-0144",
+      company_name: "Horizon Pay",
+      website: "https://horizonpay.net",
+      location: "Palo Alto, CA",
+      linkedin_profile: "https://linkedin.com/in/davidchen-sample",
+      status: "NOT_INTERESTED",
+      open_count: 1,
+      click_count: 0,
+      created_at: "2026-07-21T15:00:00.000Z",
+      custom_fields: { tech_stack: "Go/Postgres", team_size: "200", funding_round: "Series D" }
+    },
+    {
+      id: "lead_1005",
+      campaign_id: "camp_9903",
+      first_name: "Amina",
+      last_name: "Diallo",
+      email: "amina@synapseai.tech",
+      phone_number: "+1 312-555-0177",
+      company_name: "Synapse AI Global",
+      website: "https://synapseai.tech",
+      location: "Chicago, IL",
+      linkedin_profile: "https://linkedin.com/in/aminadiallo",
+      status: "INTERESTED",
+      open_count: 5,
+      click_count: 4,
+      created_at: "2026-08-02T10:14:00.000Z",
+      custom_fields: { tech_stack: "PyTorch/Ray", team_size: "30", funding_round: "Seed" }
+    }
+  ],
+  email_accounts: [
+    {
+      id: "acc_101",
+      from_name: "Alex Rivera",
+      from_email: "alex@outbound-alchemist.io",
+      provider: "GOOGLE",
+      status: "CONNECTED",
+      daily_limit: 50,
+      sent_today: 34,
+      warmup_enabled: true,
+      warmup_reputation: "EXCELLENT",
+      warmup_score: 98,
+      warmup_daily_count: 25,
+      ramp_day: 14,
+      ramp_up_increment: 2,
+      reply_rate_percentage: 45,
+      campaigns_assigned: ["Enterprise SaaS Outbound Q3", "AI Tech Founders Pilot"],
+      created_at: "2026-05-10T08:00:00.000Z"
+    },
+    {
+      id: "acc_102",
+      from_name: "Alex Rivera (Secondary)",
+      from_email: "alex.rivera@growthmatrix.cc",
+      provider: "MICROSOFT",
+      status: "CONNECTED",
+      daily_limit: 45,
+      sent_today: 28,
+      warmup_enabled: true,
+      warmup_reputation: "GOOD",
+      warmup_score: 89,
+      warmup_daily_count: 20,
+      ramp_day: 9,
+      ramp_up_increment: 3,
+      reply_rate_percentage: 40,
+      campaigns_assigned: ["Enterprise SaaS Outbound Q3", "AI Tech Founders Pilot"],
+      created_at: "2026-06-01T08:00:00.000Z"
+    },
+    {
+      id: "acc_103",
+      from_name: "Elena Rostova",
+      from_email: "elena@fintechoutreach.com",
+      provider: "SMTP",
+      smtp_host: "mail.fintechoutreach.com",
+      smtp_port: 587,
+      status: "CONNECTED",
+      daily_limit: 60,
+      sent_today: 18,
+      warmup_enabled: true,
+      warmup_reputation: "EXCELLENT",
+      warmup_score: 96,
+      warmup_daily_count: 30,
+      ramp_day: 22,
+      ramp_up_increment: 2,
+      reply_rate_percentage: 50,
+      campaigns_assigned: ["Fintech Growth & Compliance Sequence"],
+      created_at: "2026-06-15T08:00:00.000Z"
+    },
+    {
+      id: "acc_104",
+      from_name: "Growth Ops Lead",
+      from_email: "ops@aifoundryoutreach.io",
+      provider: "GOOGLE",
+      status: "RECONNECTING",
+      daily_limit: 40,
+      sent_today: 0,
+      warmup_enabled: false,
+      warmup_reputation: "POOR",
+      warmup_score: 62,
+      warmup_daily_count: 0,
+      ramp_day: 1,
+      ramp_up_increment: 1,
+      reply_rate_percentage: 30,
+      campaigns_assigned: ["AI Tech Founders Pilot"],
+      created_at: "2026-07-28T08:00:00.000Z"
+    }
+  ],
+  inbox: [
+    {
+      id: "msg_501",
+      campaign_id: "camp_9901",
+      lead_id: "lead_1001",
+      lead_name: "Sarah Jenkins",
+      lead_email: "sarah.jenkins@acmepartner.io",
+      company_name: "Acme Partner Labs",
+      subject: "Re: Quick question regarding Acme Partner Labs's outbound infrastructure",
+      category: "INTERESTED",
+      unread: true,
+      received_at: "2026-08-14T19:30:00.000Z",
+      messages: [
+        {
+          id: "m_sub_1",
+          from: "alex@outbound-alchemist.io",
+          to: "sarah.jenkins@acmepartner.io",
+          direction: "OUTBOUND",
+          timestamp: "2026-08-14T14:00:00.000Z",
+          body_html: "<p>Hi Sarah, Noticed you are scaling your growth team at Acme Partner Labs. Are you currently looking to optimize your cold outreach deliverability and warmup automation?</p>"
+        },
+        {
+          id: "m_sub_2",
+          from: "sarah.jenkins@acmepartner.io",
+          to: "alex@outbound-alchemist.io",
+          direction: "INBOUND",
+          timestamp: "2026-08-14T19:30:00.000Z",
+          body_html: "<p>Hi Alex,</p><p>Yes, perfect timing. We are actually evaluating mailbox warmup tools right now since our SDR team just doubled. Can you send over a brief demo or pricing overview?</p><p>Thanks,<br>Sarah Jenkins | Head of Growth</p>"
+        }
+      ]
+    },
+    {
+      id: "msg_502",
+      campaign_id: "camp_9901",
+      lead_id: "lead_1002",
+      lead_name: "Marcus Vance",
+      lead_email: "m.vance@vanguardflow.co",
+      company_name: "Vanguard Flow Systems",
+      subject: "Re: Quick question regarding Vanguard Flow Systems",
+      category: "MEETING_BOOKED",
+      unread: false,
+      received_at: "2026-08-14T16:15:00.000Z",
+      messages: [
+        {
+          id: "m_sub_3",
+          from: "alex@outbound-alchemist.io",
+          to: "m.vance@vanguardflow.co",
+          direction: "OUTBOUND",
+          timestamp: "2026-08-13T10:00:00.000Z",
+          body_html: "<p>Hey Marcus, We helped similar SaaS leaders double their positive response rates without hitting spam filters. Open to a 3-min loom?</p>"
+        },
+        {
+          id: "m_sub_4",
+          from: "m.vance@vanguardflow.co",
+          to: "alex@outbound-alchemist.io",
+          direction: "INBOUND",
+          timestamp: "2026-08-14T16:15:00.000Z",
+          body_html: "<p>Alex, grabbed a slot on your calendar for Tuesday at 2 PM EST. Talk soon!</p>"
+        }
+      ]
+    },
+    {
+      id: "msg_503",
+      campaign_id: "camp_9903",
+      lead_id: "lead_1005",
+      lead_name: "Amina Diallo",
+      lead_email: "amina@synapseai.tech",
+      company_name: "Synapse AI Global",
+      subject: "Re: Amina, accelerating inference pipelines",
+      category: "INTERESTED",
+      unread: true,
+      received_at: "2026-08-14T21:05:00.000Z",
+      messages: [
+        {
+          id: "m_sub_5",
+          from: "ops@aifoundryoutreach.io",
+          to: "amina@synapseai.tech",
+          direction: "OUTBOUND",
+          timestamp: "2026-08-14T15:00:00.000Z",
+          body_html: "<p>Hi Amina, saw your launch on Product Hunt! Curious how Synapse AI Global is handling model inference latency?</p>"
+        },
+        {
+          id: "m_sub_6",
+          from: "amina@synapseai.tech",
+          to: "ops@aifoundryoutreach.io",
+          direction: "INBOUND",
+          timestamp: "2026-08-14T21:05:00.000Z",
+          body_html: "<p>Thanks! We've built an in-house caching proxy, but always curious to learn about specialized acceleration clusters. Let's connect next week.</p>"
+        }
+      ]
+    }
+  ],
+  webhooks: [
+    {
+      id: "wh_801",
+      name: "Slack Lead Alerts & Zapier Sync",
+      webhook_url: "https://hooks.zapier.com/hooks/catch/912837/b8120a",
+      event_types: ["REPLY", "LEAD_CATEGORY_UPDATED", "CAMPAIGN_COMPLETED"],
+      campaign_id: null,
+      status: "ACTIVE",
+      last_triggered: "2026-08-14T21:05:12.000Z",
+      created_at: "2026-06-20T10:00:00.000Z"
+    },
+    {
+      id: "wh_802",
+      name: "HubSpot CRM Bi-directional Sync",
+      webhook_url: "https://api.hubapi.com/webhooks/v3/custom-lead-sync",
+      event_types: ["REPLY", "BOUNCE", "UNSUBSCRIBE", "LEAD_CATEGORY_UPDATED"],
+      campaign_id: "camp_9901",
+      status: "ACTIVE",
+      last_triggered: "2026-08-14T19:30:22.000Z",
+      created_at: "2026-07-01T12:00:00.000Z"
+    }
+  ],
+  webhook_logs: [
+    {
+      id: "whlog_1",
+      webhook_id: "wh_801",
+      event_type: "REPLY",
+      status_code: 200,
+      timestamp: "2026-08-14T21:05:12.000Z",
+      payload_preview: JSON.stringify({ lead_email: "amina@synapseai.tech", category: "INTERESTED", sentiment: "positive" })
+    },
+    {
+      id: "whlog_2",
+      webhook_id: "wh_802",
+      event_type: "LEAD_CATEGORY_UPDATED",
+      status_code: 200,
+      timestamp: "2026-08-14T19:30:22.000Z",
+      payload_preview: JSON.stringify({ lead_email: "sarah.jenkins@acmepartner.io", status: "INTERESTED" })
+    }
+  ],
+  clients: [
+    {
+      id: "cli_101",
+      name: "Nexus AI Ventures",
+      email: "growth@nexusventures.ai",
+      company: "Nexus AI Ventures Inc.",
+      campaigns_count: 2,
+      leads_count: 3820,
+      created_at: "2026-05-15T09:00:00.000Z"
+    },
+    {
+      id: "cli_102",
+      name: "Apex Velocity B2B",
+      email: "contact@apexvelocity.io",
+      company: "Apex Velocity Marketing",
+      campaigns_count: 1,
+      leads_count: 1200,
+      created_at: "2026-06-10T11:30:00.000Z"
+    }
+  ],
+  block_list: {
+    emails: [
+      { id: "bl_1", email: "competitor-bot@spamtrap.org", reason: "Spam trap detected", added_at: "2026-07-01T10:00:00.000Z" },
+      { id: "bl_2", email: "ceo@opt-out-forever.com", reason: "Direct legal opt-out", added_at: "2026-07-12T14:20:00.000Z" }
+    ],
+    domains: [
+      { id: "bld_1", domain: "mailinator.com", reason: "Disposable email service", added_at: "2026-06-10T09:00:00.000Z" },
+      { id: "bld_2", domain: "guerrillamail.com", reason: "Temporary inbox", added_at: "2026-06-11T11:00:00.000Z" },
+      { id: "bld_3", domain: "10minutemail.com", reason: "Temporary inbox", added_at: "2026-06-15T15:00:00.000Z" }
+    ]
+  }
+};
+
+async function startServer() {
+  const app = express();
+  const PORT = Number(process.env.PORT) || 7860;
+
+  app.use(cors());
+  app.use(morgan("dev"));
+  app.use(express.json());
+
+  // Central Supabase JWT + license gate for every paid route.
+  // /api/health stays open (Docker HEALTHCHECK + HF + productApi probe).
+  // No-op while LICENSE_ENFORCEMENT != "true" (demo mode).
+  app.use("/api", (req, res, next) => {
+    if (req.path === "/health") return next();
+    return requireModulELicense(req, res, next);
+  });
+
+  // Helper to check if real Smartlead API call should be attempted
+  const shouldProxyToSmartlead = (apiKey: string | undefined) => {
+    return Boolean(apiKey && apiKey.length > 10 && !apiKey.startsWith("demo_") && !apiKey.startsWith("mock_"));
+  };
+
+  // ==========================================
+  // MODULE 1: CAMPAIGNS API
+  // ==========================================
+  app.get("/api/campaigns", async (req, res) => {
+    const apiKey = req.headers["x-api-key"] as string;
+    if (shouldProxyToSmartlead(apiKey)) {
+      try {
+        const response = await axios.get("https://server.smartlead.ai/api/v1/campaigns", {
+          params: { ...req.query, api_key: apiKey },
+          timeout: 8000
+        });
+        return res.json(response.data);
+      } catch (err: any) {
+        console.warn("Smartlead API live proxy failed, falling back to database mode:", err.message);
+      }
+    }
+    return res.json(mockDb.campaigns);
+  });
+
+  app.post("/api/campaigns", async (req, res) => {
+    const apiKey = req.headers["x-api-key"] as string;
+    if (shouldProxyToSmartlead(apiKey)) {
+      try {
+        const response = await axios.post("https://server.smartlead.ai/api/v1/campaigns", req.body, {
+          params: { api_key: apiKey },
+          timeout: 8000
+        });
+        return res.status(201).json(response.data);
+      } catch (err: any) {
+        console.warn("Live create campaign failed, recording in local database:", err.message);
+      }
+    }
+
+    const newCampaign = {
+      id: "camp_" + Math.random().toString(36).substring(2, 9),
+      name: req.body.name || "Untitled Campaign",
+      status: "PAUSED",
+      created_at: new Date().toISOString(),
+      lead_count: 0,
+      sent_count: 0,
+      open_count: 0,
+      reply_count: 0,
+      bounce_count: 0,
+      click_count: 0,
+      timezone: req.body.timezone || "America/New_York",
+      start_schedule: req.body.start_schedule || "09:00",
+      end_schedule: req.body.end_schedule || "17:00",
+      track_settings: req.body.track_settings || "TRACK_EMAIL_OPEN",
+      send_as_plain_text: Boolean(req.body.send_as_plain_text),
+      follow_up_percentage: req.body.follow_up_percentage || 80,
+      unsubscribe_text: req.body.unsubscribe_text || "Unsubscribe",
+      stop_lead_settings: req.body.stop_lead_settings || "REPLIED",
+      sequences: [
+        {
+          id: "seq_" + Math.random().toString(36).substring(2, 7),
+          seq_number: 1,
+          delay_days: 0,
+          subject: req.body.initial_subject || "Connecting with {{first_name}}",
+          email_body: req.body.initial_body || "<p>Hi {{first_name}}, let's connect!</p>",
+          variant_distribution_percentage: 100,
+          variants: []
+        }
+      ],
+      email_account_ids: req.body.email_account_ids || []
+    };
+    mockDb.campaigns.unshift(newCampaign);
+    return res.status(201).json(newCampaign);
+  });
+
+  app.get("/api/campaigns/:id", (req, res) => {
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    return res.json(campaign);
+  });
+
+  app.post("/api/campaigns/:id", (req, res) => {
+    const index = mockDb.campaigns.findIndex(c => c.id === req.params.id);
+    if (index === -1) return res.status(404).json({ error: "Campaign not found" });
+    mockDb.campaigns[index] = { ...mockDb.campaigns[index], ...req.body };
+    return res.json(mockDb.campaigns[index]);
+  });
+
+  app.delete("/api/campaigns/:id", (req, res) => {
+    mockDb.campaigns = mockDb.campaigns.filter(c => c.id !== req.params.id);
+    return res.json({ success: true, message: "Campaign deleted successfully" });
+  });
+
+  app.post("/api/campaigns/:id/status", (req, res) => {
+    const { status } = req.body; // START / PAUSE / STOP
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    campaign.status = status === "START" ? "ACTIVE" : status === "PAUSE" ? "PAUSED" : "STOPPED";
+    return res.json({ success: true, status: campaign.status, campaign });
+  });
+
+  app.post("/api/campaigns/:id/schedule", (req, res) => {
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    campaign.start_schedule = req.body.start_schedule || campaign.start_schedule;
+    campaign.end_schedule = req.body.end_schedule || campaign.end_schedule;
+    campaign.timezone = req.body.timezone || campaign.timezone;
+    return res.json({ success: true, campaign });
+  });
+
+  app.get("/api/campaigns/:id/sequences", (req, res) => {
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    return res.json(campaign.sequences || []);
+  });
+
+  app.post("/api/campaigns/:id/sequences", (req, res) => {
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    campaign.sequences = req.body.sequences || [];
+    return res.json({ success: true, sequences: campaign.sequences });
+  });
+
+  app.get("/api/campaigns/:id/email-accounts", (req, res) => {
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    const accounts = mockDb.email_accounts.filter(a => campaign.email_account_ids?.includes(a.id));
+    return res.json(accounts);
+  });
+
+  app.post("/api/campaigns/:id/email-accounts", (req, res) => {
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    const { email_account_id } = req.body;
+    if (!campaign.email_account_ids) campaign.email_account_ids = [];
+    if (!campaign.email_account_ids.includes(email_account_id)) {
+      campaign.email_account_ids.push(email_account_id);
+    }
+    return res.json({ success: true, email_account_ids: campaign.email_account_ids });
+  });
+
+  app.delete("/api/campaigns/:id/email-accounts/:eid", (req, res) => {
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    campaign.email_account_ids = (campaign.email_account_ids || []).filter(id => id !== req.params.eid);
+    return res.json({ success: true, email_account_ids: campaign.email_account_ids });
+  });
+
+  app.get("/api/campaigns/:id/analytics", (req, res) => {
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (!campaign) return res.status(404).json({ error: "Campaign not found" });
+    return res.json({
+      sent: campaign.sent_count,
+      opens: campaign.open_count,
+      replies: campaign.reply_count,
+      bounces: campaign.bounce_count,
+      clicks: campaign.click_count,
+      open_rate: ((campaign.open_count / (campaign.sent_count || 1)) * 100).toFixed(1),
+      reply_rate: ((campaign.reply_count / (campaign.sent_count || 1)) * 100).toFixed(1),
+      bounce_rate: ((campaign.bounce_count / (campaign.sent_count || 1)) * 100).toFixed(1)
+    });
+  });
+
+  app.get("/api/campaigns/:id/analytics-by-date", (req, res) => {
+    const days = 14;
+    const history = [];
+    const now = new Date();
+    for (let i = days; i >= 0; i--) {
+      const d = new Date(now.getTime() - i * 24 * 60 * 60 * 1000);
+      const dayLabel = d.toLocaleDateString("en-US", { month: "short", day: "numeric" });
+      history.push({
+        date: dayLabel,
+        sent: Math.floor(120 + Math.random() * 80),
+        opens: Math.floor(65 + Math.random() * 40),
+        clicks: Math.floor(18 + Math.random() * 15),
+        replies: Math.floor(8 + Math.random() * 10),
+        bounces: Math.floor(1 + Math.random() * 3)
+      });
+    }
+    return res.json(history);
+  });
+
+  app.get("/api/campaigns/:id/leads-export", (req, res) => {
+    const campaignLeads = mockDb.leads.filter(l => l.campaign_id === req.params.id);
+    let csv = "first_name,last_name,email,company_name,status,open_count,reply_count\n";
+    campaignLeads.forEach(l => {
+      csv += `"${l.first_name}","${l.last_name}","${l.email}","${l.company_name}","${l.status}",${l.open_count},${l.click_count}\n`;
+    });
+    res.setHeader("Content-Type", "text/csv");
+    res.setHeader("Content-Disposition", `attachment; filename=leads-${req.params.id}.csv`);
+    return res.send(csv);
+  });
+
+  // ==========================================
+  // MODULE 2: LEADS API
+  // ==========================================
+  app.get("/api/campaigns/:id/leads", (req, res) => {
+    const leads = mockDb.leads.filter(l => l.campaign_id === req.params.id);
+    return res.json(leads);
+  });
+
+  app.post("/api/campaigns/:id/leads", (req, res) => {
+    const leadsToAdd = Array.isArray(req.body) ? req.body : req.body.leads || [req.body];
+    const created = leadsToAdd.map((item: any) => {
+      const newLead = {
+        id: "lead_" + Math.random().toString(36).substring(2, 9),
+        campaign_id: req.params.id,
+        first_name: item.first_name || "",
+        last_name: item.last_name || "",
+        email: item.email || "lead@sample.io",
+        phone_number: item.phone_number || "",
+        company_name: item.company_name || "",
+        website: item.website || "",
+        location: item.location || "",
+        linkedin_profile: item.linkedin_profile || "",
+        status: item.status || "INTERESTED",
+        open_count: 0,
+        click_count: 0,
+        created_at: new Date().toISOString(),
+        custom_fields: item.custom_fields || {}
+      };
+      mockDb.leads.unshift(newLead);
+      return newLead;
+    });
+
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (campaign) campaign.lead_count += created.length;
+
+    return res.status(201).json({ success: true, count: created.length, leads: created });
+  });
+
+  app.get("/api/leads/search", (req, res) => {
+    const query = (req.query.q as string || "").toLowerCase();
+    const status = req.query.status as string;
+    let results = mockDb.leads;
+    if (query) {
+      results = results.filter(l =>
+        l.first_name.toLowerCase().includes(query) ||
+        l.last_name.toLowerCase().includes(query) ||
+        l.email.toLowerCase().includes(query) ||
+        l.company_name.toLowerCase().includes(query)
+      );
+    }
+    if (status && status !== "ALL") {
+      results = results.filter(l => l.status === status);
+    }
+    return res.json(results);
+  });
+
+  app.post("/api/campaigns/:id/leads/status", (req, res) => {
+    const { lead_id, status } = req.body;
+    const lead = mockDb.leads.find(l => l.id === lead_id);
+    if (!lead) return res.status(404).json({ error: "Lead not found" });
+    lead.status = status;
+    return res.json({ success: true, lead });
+  });
+
+  app.delete("/api/campaigns/:id/leads/:lead_id", (req, res) => {
+    mockDb.leads = mockDb.leads.filter(l => l.id !== req.params.lead_id);
+    const campaign = mockDb.campaigns.find(c => c.id === req.params.id);
+    if (campaign && campaign.lead_count > 0) campaign.lead_count--;
+    return res.json({ success: true });
+  });
+
+  // Blocklist routes
+  app.get("/api/leads/block-list", (req, res) => res.json(mockDb.block_list.emails));
+  app.post("/api/leads/block-list", (req, res) => {
+    const item = { id: "bl_" + Date.now(), email: req.body.email, reason: req.body.reason || "Manual add", added_at: new Date().toISOString() };
+    mockDb.block_list.emails.unshift(item);
+    res.status(201).json(item);
+  });
+  app.delete("/api/leads/block-list/:id", (req, res) => {
+    mockDb.block_list.emails = mockDb.block_list.emails.filter(e => e.id !== req.params.id && e.email !== req.params.id);
+    res.json({ success: true });
+  });
+
+  app.get("/api/leads/domain-block-list", (req, res) => res.json(mockDb.block_list.domains));
+  app.post("/api/leads/domain-block-list", (req, res) => {
+    const item = { id: "bld_" + Date.now(), domain: req.body.domain, reason: req.body.reason || "Manual add", added_at: new Date().toISOString() };
+    mockDb.block_list.domains.unshift(item);
+    res.status(201).json(item);
+  });
+  app.delete("/api/leads/domain-block-list/:id", (req, res) => {
+    mockDb.block_list.domains = mockDb.block_list.domains.filter(d => d.id !== req.params.id && d.domain !== req.params.id);
+    res.json({ success: true });
+  });
+
+  // ==========================================
+  // MODULE 3: EMAIL ACCOUNTS API
+  // ==========================================
+  app.get("/api/email-accounts", (req, res) => res.json(mockDb.email_accounts));
+  
+  app.post("/api/email-accounts", (req, res) => {
+    const newAcc = {
+      id: "acc_" + Math.random().toString(36).substring(2, 8),
+      from_name: req.body.from_name || "Outbound Rep",
+      from_email: req.body.from_email || "rep@sampledomain.com",
+      provider: req.body.provider || "SMTP",
+      smtp_host: req.body.smtp_host,
+      smtp_port: req.body.smtp_port,
+      status: "CONNECTED",
+      daily_limit: req.body.max_email_per_day || 50,
+      sent_today: 0,
+      warmup_enabled: true,
+      warmup_reputation: "GOOD",
+      warmup_score: 85,
+      warmup_daily_count: 10,
+      ramp_day: 1,
+      ramp_up_increment: 2,
+      reply_rate_percentage: 40,
+      campaigns_assigned: [],
+      created_at: new Date().toISOString()
+    };
+    mockDb.email_accounts.push(newAcc);
+    res.status(201).json(newAcc);
+  });
+
+  app.post("/api/email-accounts/reconnect", (req, res) => {
+    const { account_id } = req.body;
+    const acc = mockDb.email_accounts.find(a => a.id === account_id);
+    if (acc) acc.status = "CONNECTED";
+    res.json({ success: true, message: "Account reconnected successfully", account: acc });
+  });
+
+  app.delete("/api/email-accounts/:id", (req, res) => {
+    mockDb.email_accounts = mockDb.email_accounts.filter(a => a.id !== req.params.id);
+    res.json({ success: true });
+  });
+
+  // ==========================================
+  // MODULE 4: EMAIL WARMUP API
+  // ==========================================
+  app.post("/api/email-accounts/:id/warmup/enable", (req, res) => {
+    const acc = mockDb.email_accounts.find(a => a.id === req.params.id);
+    if (!acc) return res.status(404).json({ error: "Account not found" });
+    acc.warmup_enabled = true;
+    res.json({ success: true, account: acc });
+  });
+
+  app.post("/api/email-accounts/:id/warmup/disable", (req, res) => {
+    const acc = mockDb.email_accounts.find(a => a.id === req.params.id);
+    if (!acc) return res.status(404).json({ error: "Account not found" });
+    acc.warmup_enabled = false;
+    res.json({ success: true, account: acc });
+  });
+
+  app.get("/api/email-accounts/:id/warmup/stats", (req, res) => {
+    const acc = mockDb.email_accounts.find(a => a.id === req.params.id);
+    if (!acc) return res.status(404).json({ error: "Account not found" });
+    res.json({
+      score: acc.warmup_score,
+      reputation: acc.warmup_reputation,
+      sent_warmup: acc.warmup_daily_count,
+      received_warmup: Math.floor(acc.warmup_daily_count * 0.45),
+      spam_rescued: 2,
+      ramp_day: acc.ramp_day,
+      history: [
+        { day: "Day 1", score: 70 },
+        { day: "Day 3", score: 78 },
+        { day: "Day 7", score: 85 },
+        { day: "Day 10", score: 92 },
+        { day: "Day 14", score: acc.warmup_score }
+      ]
+    });
+  });
+
+  app.post("/api/email-accounts/:id/warmup/settings", (req, res) => {
+    const acc = mockDb.email_accounts.find(a => a.id === req.params.id);
+    if (!acc) return res.status(404).json({ error: "Account not found" });
+    acc.ramp_up_increment = req.body.ramp_up_increment || acc.ramp_up_increment;
+    acc.reply_rate_percentage = req.body.reply_rate_percentage || acc.reply_rate_percentage;
+    res.json({ success: true, account: acc });
+  });
+
+  // ==========================================
+  // MODULE 5: UNIFIED INBOX API
+  // ==========================================
+  app.get("/api/inbox", (req, res) => {
+    const { category, campaign_id } = req.query;
+    let threads = mockDb.inbox;
+    if (category && category !== "ALL") {
+      threads = threads.filter(t => t.category === category);
+    }
+    if (campaign_id) {
+      threads = threads.filter(t => t.campaign_id === campaign_id);
+    }
+    res.json(threads);
+  });
+
+  app.get("/api/inbox/unread-count", (req, res) => {
+    const unread = mockDb.inbox.filter(t => t.unread).length;
+    res.json({ count: unread });
+  });
+
+  app.post("/api/campaigns/:id/reply-email-thread", (req, res) => {
+    const { thread_id, reply_body } = req.body;
+    const thread = mockDb.inbox.find(t => t.id === thread_id || t.campaign_id === req.params.id);
+    if (thread) {
+      thread.unread = false;
+      thread.messages.push({
+        id: "m_rep_" + Date.now(),
+        from: "alex@outbound-alchemist.io",
+        to: thread.lead_email,
+        direction: "OUTBOUND",
+        timestamp: new Date().toISOString(),
+        body_html: `<p>${reply_body}</p>`
+      });
+      return res.json({ success: true, message: "Reply sent successfully", thread });
+    }
+    res.json({ success: true, message: "Reply delivered" });
+  });
+
+  app.post("/api/inbox/categorize", (req, res) => {
+    const { thread_id, category } = req.body;
+    const thread = mockDb.inbox.find(t => t.id === thread_id);
+    if (thread) {
+      thread.category = category;
+      const lead = mockDb.leads.find(l => l.email === thread.lead_email);
+      if (lead) lead.status = category;
+    }
+    res.json({ success: true, category });
+  });
+
+  // ==========================================
+  // MODULE 6: WEBHOOKS API
+  // ==========================================
+  app.get("/api/webhooks", (req, res) => res.json(mockDb.webhooks));
+  
+  app.post("/api/webhooks", (req, res) => {
+    const newWh = {
+      id: "wh_" + Math.random().toString(36).substring(2, 8),
+      name: req.body.name || "Custom Webhook Endpoint",
+      webhook_url: req.body.webhook_url || "https://api.domain.com/webhook",
+      event_types: req.body.event_types || ["REPLY"],
+      campaign_id: req.body.campaign_id || null,
+      status: "ACTIVE",
+      last_triggered: null,
+      created_at: new Date().toISOString()
+    };
+    mockDb.webhooks.unshift(newWh);
+    res.status(201).json(newWh);
+  });
+
+  app.delete("/api/webhooks/:id", (req, res) => {
+    mockDb.webhooks = mockDb.webhooks.filter(w => w.id !== req.params.id);
+    res.json({ success: true });
+  });
+
+  app.post("/api/webhooks/:id/test", (req, res) => {
+    const wh = mockDb.webhooks.find(w => w.id === req.params.id);
+    if (!wh) return res.status(404).json({ error: "Webhook not found" });
+    const logItem = {
+      id: "whlog_" + Date.now(),
+      webhook_id: wh.id,
+      event_type: wh.event_types[0] || "REPLY",
+      status_code: 200,
+      timestamp: new Date().toISOString(),
+      payload_preview: JSON.stringify({ event: "TEST_PING", lead_email: "test.lead@domain.com", timestamp: new Date().toISOString() })
+    };
+    mockDb.webhook_logs.unshift(logItem);
+    wh.last_triggered = new Date().toISOString();
+    res.json({ success: true, message: "Test payload sent to endpoint", log: logItem });
+  });
+
+  app.get("/api/webhooks/logs", (req, res) => res.json(mockDb.webhook_logs));
+
+  // ==========================================
+  // MODULE 7: ANALYTICS API
+  // ==========================================
+  app.get("/api/analytics/campaigns", (req, res) => {
+    const totalSent = mockDb.campaigns.reduce((acc, c) => acc + c.sent_count, 0);
+    const totalOpens = mockDb.campaigns.reduce((acc, c) => acc + c.open_count, 0);
+    const totalReplies = mockDb.campaigns.reduce((acc, c) => acc + c.reply_count, 0);
+    const totalBounces = mockDb.campaigns.reduce((acc, c) => acc + c.bounce_count, 0);
+    const totalClicks = mockDb.campaigns.reduce((acc, c) => acc + c.click_count, 0);
+    const totalLeads = mockDb.campaigns.reduce((acc, c) => acc + c.lead_count, 0);
+
+    res.json({
+      total_campaigns: mockDb.campaigns.length,
+      total_leads: totalLeads,
+      total_sent: totalSent,
+      total_opens: totalOpens,
+      total_replies: totalReplies,
+      total_bounces: totalBounces,
+      total_clicks: totalClicks,
+      open_rate: ((totalOpens / (totalSent || 1)) * 100).toFixed(1),
+      reply_rate: ((totalReplies / (totalSent || 1)) * 100).toFixed(1),
+      click_rate: ((totalClicks / (totalSent || 1)) * 100).toFixed(1),
+      bounce_rate: ((totalBounces / (totalSent || 1)) * 100).toFixed(1)
+    });
+  });
+
+  // ==========================================
+  // MODULE 8: CLIENT MANAGEMENT API
+  // ==========================================
+  app.get("/api/clients", (req, res) => res.json(mockDb.clients));
+
+app.post("/api/ai/completion", async (req, res) => {
+  try {
+    const { prompt } = req.body;
+    if (!prompt) {
+      return res.status(400).json({ error: "Prompt is required" });
+    }
+    const response = await getAiCompletion(prompt);
+    res.json({ response });
+  } catch (error) {
+    res.status(500).json({ error: "Failed to get AI completion" });
+  }
+});
+
+  
+  app.post("/api/clients", (req, res) => {
+    const newClient = {
+      id: "cli_" + Math.random().toString(36).substring(2, 7),
+      name: req.body.name || "New Client",
+      email: req.body.email || "client@company.com",
+      company: req.body.company || "Client Company Ltd",
+      campaigns_count: 0,
+      leads_count: 0,
+      created_at: new Date().toISOString()
+    };
+    mockDb.clients.push(newClient);
+    res.status(201).json(newClient);
+  });
+
+  app.delete("/api/clients/:id", (req, res) => {
+    mockDb.clients = mockDb.clients.filter(c => c.id !== req.params.id);
+    res.json({ success: true });
+  });
+
+  // Liveness probe (Docker HEALTHCHECK + Hugging Face). Must stay BEFORE
+  // the /api proxy catch-all below so it is never forwarded to Smartlead.
+  app.get("/api/health", (_req, res) => {
+    res.json({
+      status: "healthy",
+      app: "BRIDGE Modul-E",
+      version: "1.0.0",
+      mode: process.env.NODE_ENV === "production" ? "production" : "development",
+      timestamp: Date.now() / 1000,
+    });
+  });
+
+  // Proxy Catch-All for any other direct Smartlead API calls
+  app.use("/api", async (req, res) => {
+    const apiKey = req.headers["x-api-key"] as string;
+    if (!apiKey) {
+      return res.status(401).json({ error: "Missing x-api-key header" });
+    }
+
+    try {
+      const targetUrl = `https://server.smartlead.ai/api/v1${req.path}`;
+      const response = await axios({
+        method: req.method,
+        url: targetUrl,
+        data: Object.keys(req.body).length > 0 ? req.body : undefined,
+        params: { ...req.query, api_key: apiKey },
+        timeout: 10000
+      });
+      res.status(response.status).json(response.data);
+    } catch (error: any) {
+      if (error.response) {
+        res.status(error.response.status).json(error.response.data);
+      } else {
+        res.status(500).json({ error: "Proxy connection error", details: error.message });
+      }
+    }
+  });
+
+  // Vite development middleware or production static serving
+  if (process.env.NODE_ENV !== "production") {
+    const vite = await createViteServer({
+      server: { middlewareMode: true },
+      appType: "spa",
+    });
+    app.use(vite.middlewares);
+  } else {
+    const distPath = path.join(process.cwd(), "dist");
+    app.use(express.static(distPath));
+    app.get("*", (req, res) => {
+      res.sendFile(path.join(distPath, "index.html"));
+    });
+  }
+
+  app.listen(PORT, "0.0.0.0", () => {
+    console.log(`BRIDGEModulE Command Hub Server listening on http://0.0.0.0:${PORT}`);
+  });
+}
+
+startServer();