update

backend/app/database.py

@@ -84,6 +84,7 @@ class UploadedFile(Base):
     filename = Column(String)
     contact_count = Column(Integer)
     file_path = Column(String)
+    sequence_plan_json = Column(Text, nullable=True)
     created_at = Column(DateTime, default=datetime.utcnow)
 
 
@@ -116,6 +117,7 @@ class GeneratedSequence(Base):
     product = Column(String)
     subject = Column(String)
     email_content = Column(Text)
+    step_order = Column(Integer, nullable=True)
     created_at = Column(DateTime, default=datetime.utcnow)
 
 
@@ -407,6 +409,15 @@ def run_migrations(connection_engine):
                         "UPDATE generated_sequences SET channel = 'email' WHERE channel IS NULL OR channel = ''"
                     )
                 )
+            gcols2 = [c["name"] for c in insp.get_columns("generated_sequences")]
+            if "step_order" not in gcols2:
+                conn.execute(text("ALTER TABLE generated_sequences ADD COLUMN step_order INTEGER"))
+
+        insp = inspect(connection_engine)
+        if insp.has_table("uploaded_files"):
+            ufcols = [c["name"] for c in insp.get_columns("uploaded_files")]
+            if "sequence_plan_json" not in ufcols:
+                conn.execute(text("ALTER TABLE uploaded_files ADD COLUMN sequence_plan_json TEXT"))
 
         insp = inspect(connection_engine)
         if insp.has_table("unipile_accounts"):

backend/app/gpt_service.py

@@ -16,7 +16,12 @@ logger = logging.getLogger(__name__)
 client = OpenAI(api_key=os.getenv("OPENAI_API_KEY"))
 
 
-def generate_email_sequence(contact: Dict, prompt_template: str, product_name: str) -> List[Dict]:
+def generate_email_sequence(
+    contact: Dict,
+    prompt_template: str,
+    product_name: str,
+    campaign_sequence: Optional[Dict[str, Any]] = None,
+) -> List[Dict]:
     """
     Generate a personalized email sequence for a contact using GPT.
     """
@@ -72,9 +77,34 @@ def generate_email_sequence(contact: Dict, prompt_template: str, product_name: s
                 num_emails = 9
             elif "10-email" in prompt_template or "10 email" in prompt_template:
                 num_emails = 10
-            
-            user_prompt = f"""Generate a complete email sequence for this contact:
+            if campaign_sequence and campaign_sequence.get("email_count"):
+                try:
+                    num_emails = max(1, min(10, int(campaign_sequence["email_count"])))
+                except (TypeError, ValueError):
+                    pass
 
+            plan_block = ""
+            if campaign_sequence:
+                titles = campaign_sequence.get("email_titles") or []
+                waits = (campaign_sequence.get("wait_context") or "").strip()
+                if titles:
+                    plan_block += "\n\n🔒 CAMPAIGN SEQUENCE (AUTHORITATIVE — OVERRIDES ANY OTHER EMAIL COUNT IN THIS PROMPT)\n"
+                    plan_block += f"You MUST output exactly {num_emails} emails labeled Email 1 … Email {num_emails}.\n"
+                    plan_block += "Each email corresponds to one Gmail touch in this campaign, in order:\n"
+                    for i, t in enumerate(titles, start=1):
+                        plan_block += f"  {i}. {t}\n"
+                    if waits:
+                        plan_block += "\nDelays between touches (context only — do not output extra emails for waits):\n" + waits + "\n"
+                    plan_block += (
+                        "\nLinkedIn steps in this campaign are generated separately; write only the Gmail emails here.\n"
+                        "Keep narrative continuity where a prospect may also see LinkedIn touches in the same week.\n"
+                    )
+
+            user_prompt = (
+                f"""Generate a complete email sequence for this contact:
+"""
+                + plan_block
+                + f"""
 Contact Information:
 - First Name: {first_name}
 - Last Name: {last_name}
@@ -106,6 +136,7 @@ Anna
 ... (continue for all {num_emails} emails, each starting with "Hi {first_name},")
 
 Remember: Use only the information provided above. Do not reference anything not explicitly mentioned."""
+            )
         else:
             # Use standard prompt for other products
             system_prompt = """You are an expert email outreach specialist. Your task is to personalize email templates for B2B sales outreach. 
@@ -125,9 +156,29 @@ Personalize this email template:
 Replace all variables like {{first_name}}, {{company}}, {{sender_name}} with the actual information.
 Make it sound natural and personalized. Keep the same structure and format.
 If sender_name is not provided, use "Alex Thompson" as the sender name."""
+            if campaign_sequence and int(campaign_sequence.get("email_count") or 0) > 1:
+                n = int(campaign_sequence["email_count"])
+                titles = campaign_sequence.get("email_titles") or []
+                title_lines = "\n".join(f"  {i}. {t}" for i, t in enumerate(titles, start=1)) if titles else ""
+                waits = (campaign_sequence.get("wait_context") or "").strip()
+                user_prompt += f"""
+
+🔒 CAMPAIGN SEQUENCE (AUTHORITATIVE)
+Output exactly {n} emails for this contact, labeled Email 1 through Email {n}, each with Subject: and Body: lines (same structure as a multi-touch sequence).
+Each body must start with "Hi {first_name},".
+Touches in order:
+{title_lines or "(see template)"}
+{f"Delays between touches (context only): {waits}" if waits else ""}
+"""
+
+        use_structured_parse = is_ap_automation_prompt or (
+            campaign_sequence is not None and int(campaign_sequence.get("email_count") or 0) > 1
+        )
 
         # Use higher max_tokens for AP Automation comprehensive prompts
         max_tokens = 2000 if is_ap_automation_prompt else 1000
+        if campaign_sequence and int(campaign_sequence.get("email_count") or 0) > 1:
+            max_tokens = max(max_tokens, 2800)
         
         response = client.chat.completions.create(
             model="gpt-4o-mini",  # Using gpt-4o-mini for cost efficiency, can be changed to gpt-4
@@ -144,7 +195,7 @@ If sender_name is not provided, use "Alex Thompson" as the sender name."""
         # Parse multiple emails from the response
         emails = []
         
-        if is_ap_automation_prompt:
+        if use_structured_parse:
             # Parse the structured format: Email 1, Email 2, etc.
             lines = generated_text.split('\n')
             current_email = None
@@ -312,7 +363,12 @@ If sender_name is not provided, use "Alex Thompson" as the sender name."""
         }]
 
 
-def generate_linkedin_sequence(contact: Dict, prompt_template: str, product_name: str) -> List[Dict]:
+def generate_linkedin_sequence(
+    contact: Dict,
+    prompt_template: str,
+    product_name: str,
+    campaign_sequence: Optional[Dict[str, Any]] = None,
+) -> List[Dict]:
     """
     Generate LinkedIn DM-style messages (connection note + follow-ups) for a contact.
     Stored like email sequences with subject empty and channel=linkedin on the row.
@@ -340,12 +396,33 @@ def generate_linkedin_sequence(contact: Dict, prompt_template: str, product_name
             raise ValueError(f"Contact missing email address: {contact}")
 
         system_prompt = prompt_template
-        num_messages = 3
-        if "4-message" in prompt_template or "4 message" in prompt_template.lower():
-            num_messages = 4
-        elif "5-message" in prompt_template or "5 message" in prompt_template.lower():
-            num_messages = 5
-
+        li_actions: List[str] = []
+        if campaign_sequence and isinstance(campaign_sequence.get("linkedin_actions"), list):
+            li_actions = [str(x) for x in campaign_sequence["linkedin_actions"] if x]
+        if li_actions:
+            connects = [a for a in li_actions if a == "linkedin_connect"]
+            dms = [a for a in li_actions if a == "linkedin_dm"]
+            other = [a for a in li_actions if a not in ("linkedin_connect", "linkedin_dm")]
+            li_actions = connects + dms + other
+            num_messages = len(li_actions)
+        else:
+            num_messages = 3
+            if "4-message" in prompt_template or "4 message" in prompt_template.lower():
+                num_messages = 4
+            elif "5-message" in prompt_template or "5 message" in prompt_template.lower():
+                num_messages = 5
+
+        plan_extra = ""
+        if li_actions:
+            plan_extra = "\nStrict mapping:\n"
+            for i, act in enumerate(li_actions, start=1):
+                if act == "linkedin_connect":
+                    plan_extra += f"  Message {i}: LinkedIn CONNECTION REQUEST note (short, under 300 characters when possible).\n"
+                else:
+                    plan_extra += f"  Message {i}: LinkedIn DM / follow-up after connection (professional, concise).\n"
+            plan_extra += (
+                "\nThe first LinkedIn touch in this list is always a connection request before any follow-up DMs.\n"
+            )
         user_prompt = f"""Generate a complete LinkedIn outreach sequence for this contact.
 
 Contact Information:
@@ -358,6 +435,7 @@ Contact Information:
 - Location: {location if location else 'Not specified'}
 
 Generate all {num_messages} messages following the rules in the system prompt.
+{plan_extra}
 CRITICAL: Write for LinkedIn DMs or connection notes — short, plain, professional. No email-style subjects.
 
 Output format (strict):

backend/app/main.py

@@ -12,7 +12,8 @@ import os
 import csv
 import io
 import concurrent.futures
-from typing import Dict, List, Optional
+from functools import partial
+from typing import Any, Dict, List, Optional
 import json
 import asyncio
 import math
@@ -3421,11 +3422,95 @@ async def save_prompts(request: PromptSaveRequest, t: TenantContext = Depends(ge
             )
 
         db.commit()
+
+        uf = (
+            db.query(UploadedFile)
+            .filter(UploadedFile.tenant_id == t.tenant_id, UploadedFile.file_id == request.file_id)
+            .first()
+        )
+        if uf is not None:
+            if request.sequence_plan is not None:
+                uf.sequence_plan_json = json.dumps(request.sequence_plan)
+            db.commit()
+
         return {"message": "Prompts saved successfully"}
     except Exception as e:
         raise HTTPException(status_code=500, detail=f"Error saving prompts: {str(e)}")
 
 
+def _normalize_campaign_plan_steps(raw_data) -> Optional[List[Dict]]:
+    if raw_data is None:
+        return None
+    if isinstance(raw_data, dict) and isinstance(raw_data.get("steps"), list):
+        return raw_data["steps"]
+    if isinstance(raw_data, list):
+        return raw_data
+    return None
+
+
+def _parse_campaign_plan_pack(db_file) -> Optional[Dict[str, Any]]:
+    """Build GPT kwargs + per-row step_order alignment from wizard sequence JSON on UploadedFile."""
+    raw = getattr(db_file, "sequence_plan_json", None)
+    if not raw or not str(raw).strip():
+        return None
+    try:
+        parsed = json.loads(raw)
+    except Exception:
+        return None
+    steps = _normalize_campaign_plan_steps(parsed)
+    if not steps:
+        return None
+    gmail_specs: List[Dict[str, Any]] = []
+    li_wizard: List[Dict[str, Any]] = []
+    wait_lines: List[str] = []
+    ord_global = 0
+    for s in steps:
+        if not isinstance(s, dict):
+            continue
+        if s.get("type") == "wait":
+            try:
+                d = int(s.get("days") or 1)
+            except (TypeError, ValueError):
+                d = 1
+            wait_lines.append(f"Wait {d} day(s) between surrounding sequence touches.")
+            continue
+        if s.get("type") != "action":
+            continue
+        ord_global += 1
+        ch = s.get("channel")
+        act = s.get("action")
+        title = (s.get("title") or "").strip() or ("Email" if ch == "gmail" else "LinkedIn touch")
+        if ch == "gmail":
+            gmail_specs.append({"step_order": ord_global, "title": title})
+        elif ch == "linkedin" and act in ("linkedin_connect", "linkedin_dm"):
+            li_wizard.append({"step_order": ord_global, "action": act, "title": title})
+    li_connects = [x for x in li_wizard if x["action"] == "linkedin_connect"]
+    li_dms = [x for x in li_wizard if x["action"] == "linkedin_dm"]
+    li_other = [x for x in li_wizard if x["action"] not in ("linkedin_connect", "linkedin_dm")]
+    li_for_gpt = li_connects + li_dms + li_other
+    total_actions = len(gmail_specs) + len(li_wizard)
+    if total_actions == 0:
+        return None
+    email_campaign_kw = None
+    if gmail_specs:
+        email_campaign_kw = {
+            "email_count": len(gmail_specs),
+            "email_titles": [g["title"] for g in gmail_specs],
+            "wait_context": "\n".join(wait_lines),
+        }
+    linkedin_campaign_kw = None
+    if li_for_gpt:
+        linkedin_campaign_kw = {"linkedin_actions": [x["action"] for x in li_for_gpt]}
+    return {
+        "gmail_specs": gmail_specs,
+        "li_wizard": li_wizard,
+        "li_for_gpt": li_for_gpt,
+        "total_actions": total_actions,
+        "email_campaign_kw": email_campaign_kw,
+        "linkedin_campaign_kw": linkedin_campaign_kw,
+    }
+
+
 @app.get("/api/generation-status")
 async def generation_status(file_id: str = Query(...), t: TenantContext = Depends(get_tenant_context)):
     """Return progress for sequence generation (so frontend can resume after sleep/reconnect)."""
@@ -3441,6 +3526,16 @@ async def generation_status(file_id: str = Query(...), t: TenantContext = Depend
     if not db_file:
         raise HTTPException(status_code=404, detail="File not found")
     total_contacts = db_file.contact_count or 0
+    plan_actions = 0
+    if getattr(db_file, "sequence_plan_json", None):
+        try:
+            raw = json.loads(db_file.sequence_plan_json)
+            if isinstance(raw, list):
+                plan_actions = sum(1 for s in raw if isinstance(s, dict) and s.get("type") == "action")
+            elif isinstance(raw, dict) and isinstance(raw.get("steps"), list):
+                plan_actions = sum(1 for s in raw["steps"] if isinstance(s, dict) and s.get("type") == "action")
+        except Exception:
+            plan_actions = 0
     has_linkedin = (
         db.query(Prompt.id)
         .filter(
@@ -3471,14 +3566,27 @@ async def generation_status(file_id: str = Query(...), t: TenantContext = Depend
         .distinct()
         .count()
     )
-    completed_units = email_done + (li_done if has_linkedin else 0)
-    expected_units = total_contacts * (2 if has_linkedin else 1)
+    if plan_actions > 0:
+        row_count = (
+            db.query(GeneratedSequence.id)
+            .filter(
+                GeneratedSequence.tenant_id == t.tenant_id,
+                GeneratedSequence.file_id == file_id,
+            )
+            .count()
+        )
+        completed_units = row_count
+        expected_units = total_contacts * plan_actions
+    else:
+        completed_units = email_done + (li_done if has_linkedin else 0)
+        expected_units = total_contacts * (2 if has_linkedin else 1)
     return {
         "file_id": file_id,
         "total_contacts": total_contacts,
         "completed_count": completed_units,
         "is_complete": total_contacts > 0 and completed_units >= expected_units,
         "has_linkedin_prompts": has_linkedin,
+        "campaign_sequence_actions": plan_actions or None,
     }
 
 
@@ -3492,7 +3600,11 @@ async def get_sequences(file_id: str = Query(...), t: TenantContext = Depends(ge
             GeneratedSequence.tenant_id == t.tenant_id,
             GeneratedSequence.file_id == file_id,
         )
-        .order_by(GeneratedSequence.sequence_id, GeneratedSequence.email_number)
+        .order_by(
+            GeneratedSequence.sequence_id,
+            func.coalesce(GeneratedSequence.step_order, 999999),
+            GeneratedSequence.email_number,
+        )
         .all()
     )
     out = []
@@ -3509,6 +3621,7 @@ async def get_sequences(file_id: str = Query(...), t: TenantContext = Depends(ge
             "subject": seq.subject,
             "emailContent": seq.email_content,
             "channel": getattr(seq, "channel", None) or "email",
+            "stepOrder": getattr(seq, "step_order", None),
         })
     return {"sequences": out}
 
@@ -3555,13 +3668,31 @@ async def generate_sequences(
                 if getattr(p, "prompt_kind", None) == "linkedin"
             }
 
-            if not email_prompt_dict:
+            plan_pack = _parse_campaign_plan_pack(db_file)
+            run_email = True
+            run_linkedin = len(linkedin_prompt_dict) > 0
+            email_kw: Optional[Dict[str, Any]] = None
+            li_kw: Optional[Dict[str, Any]] = None
+            gmail_specs: List[Dict[str, Any]] = []
+            li_meta_for_rows: List[Dict[str, Any]] = []
+
+            if plan_pack:
+                run_email = bool(plan_pack.get("email_campaign_kw"))
+                run_linkedin = bool(plan_pack.get("linkedin_campaign_kw"))
+                email_kw = plan_pack.get("email_campaign_kw")
+                li_kw = plan_pack.get("linkedin_campaign_kw")
+                gmail_specs = plan_pack.get("gmail_specs") or []
+                li_meta_for_rows = plan_pack.get("li_for_gpt") or []
+
+            if run_email and not email_prompt_dict:
                 yield f"data: {json.dumps({'type': 'error', 'error': 'No prompts found'})}\n\n"
                 return
+            if run_linkedin and not linkedin_prompt_dict:
+                yield f"data: {json.dumps({'type': 'error', 'error': 'No LinkedIn prompts found'})}\n\n"
+                return
 
-            products = list(email_prompt_dict.keys())
-            li_products = list(linkedin_prompt_dict.keys())
-            run_linkedin = len(li_products) > 0
+            products = list(email_prompt_dict.keys()) if email_prompt_dict else []
+            li_products = list(linkedin_prompt_dict.keys()) if linkedin_prompt_dict else []
 
             if reset:
                 db.query(GeneratedSequence).filter(
@@ -3581,129 +3712,227 @@ async def generate_sequences(
                     return min(100.0, max(0.0, 50.0 + (seq_id / total_contacts) * 50.0))
                 return min(100.0, max(0.0, (seq_id / total_contacts) * 100.0))
 
-            sequence_id = 1
-            for idx, row in df.iterrows():
-                existing = (
-                    db.query(GeneratedSequence)
+            def plan_progress_pct() -> float:
+                if not plan_pack or total_contacts <= 0:
+                    return 0.0
+                cnt = (
+                    db.query(func.count(GeneratedSequence.id))
                     .filter(
                         GeneratedSequence.tenant_id == tenant_id,
                         GeneratedSequence.file_id == file_id,
-                        GeneratedSequence.sequence_id == sequence_id,
-                        GeneratedSequence.channel == "email",
                     )
-                    .order_by(GeneratedSequence.email_number)
-                    .all()
+                    .scalar()
+                    or 0
                 )
-                if existing:
-                    for seq in existing:
-                        sequence_response = {
-                            "id": seq.sequence_id,
-                            "emailNumber": seq.email_number,
-                            "firstName": seq.first_name,
-                            "lastName": seq.last_name,
-                            "email": seq.email,
-                            "company": seq.company,
-                            "title": seq.title or "",
-                            "product": seq.product,
-                            "subject": seq.subject,
-                            "emailContent": seq.email_content,
-                            "channel": "email",
-                        }
-                        yield f"data: {json.dumps({'type': 'sequence', 'sequence': sequence_response})}\n\n"
-                    yield f"data: {json.dumps({'type': 'progress', 'progress': progress_pct(sequence_id, linkedin_phase=False)})}\n\n"
-                    sequence_id += 1
-                    await asyncio.sleep(0.05)
-                    continue
+                exp = total_contacts * plan_pack["total_actions"]
+                return min(100.0, max(0.0, (cnt / max(1, exp)) * 100.0))
+
+            def orm_to_sequence_response(seq: GeneratedSequence) -> Dict[str, Any]:
+                ch = getattr(seq, "channel", None) or "email"
+                return {
+                    "id": seq.sequence_id,
+                    "emailNumber": seq.email_number,
+                    "firstName": seq.first_name,
+                    "lastName": seq.last_name,
+                    "email": seq.email,
+                    "company": seq.company,
+                    "title": seq.title or "",
+                    "product": seq.product,
+                    "subject": (seq.subject or "") if ch == "linkedin" else seq.subject,
+                    "emailContent": seq.email_content,
+                    "channel": ch,
+                    "stepOrder": getattr(seq, "step_order", None),
+                }
 
-                contact = row.to_dict()
-                product_name = products[(sequence_id - 1) % len(products)]
-                prompt_template = email_prompt_dict[product_name]
-
-                loop = asyncio.get_event_loop()
-                with concurrent.futures.ThreadPoolExecutor() as executor:
-                    sequence_data_list = await loop.run_in_executor(
-                        executor,
-                        generate_email_sequence,
-                        contact,
-                        prompt_template,
-                        product_name,
-                    )
+            sequence_id = 1
+            if run_email:
+                for idx, row in df.iterrows():
+                    if plan_pack and gmail_specs:
+                        email_done_n = (
+                            db.query(func.count(GeneratedSequence.id))
+                            .filter(
+                                GeneratedSequence.tenant_id == tenant_id,
+                                GeneratedSequence.file_id == file_id,
+                                GeneratedSequence.sequence_id == sequence_id,
+                                GeneratedSequence.channel == "email",
+                            )
+                            .scalar()
+                            or 0
+                        )
+                        if email_done_n >= len(gmail_specs):
+                            existing_em = (
+                                db.query(GeneratedSequence)
+                                .filter(
+                                    GeneratedSequence.tenant_id == tenant_id,
+                                    GeneratedSequence.file_id == file_id,
+                                    GeneratedSequence.sequence_id == sequence_id,
+                                    GeneratedSequence.channel == "email",
+                                )
+                                .order_by(
+                                    func.coalesce(GeneratedSequence.step_order, 999999),
+                                    GeneratedSequence.email_number,
+                                )
+                                .all()
+                            )
+                            for seq in existing_em:
+                                yield f"data: {json.dumps({'type': 'sequence', 'sequence': orm_to_sequence_response(seq)})}\n\n"
+                            prog = plan_progress_pct() if plan_pack else progress_pct(sequence_id, linkedin_phase=False)
+                            yield f"data: {json.dumps({'type': 'progress', 'progress': prog})}\n\n"
+                            sequence_id += 1
+                            await asyncio.sleep(0.05)
+                            continue
+                    else:
+                        existing = (
+                            db.query(GeneratedSequence)
+                            .filter(
+                                GeneratedSequence.tenant_id == tenant_id,
+                                GeneratedSequence.file_id == file_id,
+                                GeneratedSequence.sequence_id == sequence_id,
+                                GeneratedSequence.channel == "email",
+                            )
+                            .order_by(GeneratedSequence.email_number)
+                            .all()
+                        )
+                        if existing:
+                            for seq in existing:
+                                yield f"data: {json.dumps({'type': 'sequence', 'sequence': orm_to_sequence_response(seq)})}\n\n"
+                            prog = plan_progress_pct() if plan_pack else progress_pct(sequence_id, linkedin_phase=False)
+                            yield f"data: {json.dumps({'type': 'progress', 'progress': prog})}\n\n"
+                            sequence_id += 1
+                            await asyncio.sleep(0.05)
+                            continue
 
-                for seq_data in sequence_data_list:
-                    db_sequence = GeneratedSequence(
-                        tenant_id=tenant_id,
-                        file_id=file_id,
-                        sequence_id=sequence_id,
-                        email_number=seq_data["email_number"],
-                        channel="email",
-                        first_name=seq_data["first_name"],
-                        last_name=seq_data["last_name"],
-                        email=seq_data["email"],
-                        company=seq_data["company"],
-                        title=seq_data.get("title", ""),
-                        product=seq_data["product"],
-                        subject=seq_data["subject"],
-                        email_content=seq_data["email_content"],
-                    )
-                    db.add(db_sequence)
+                    contact = row.to_dict()
+                    product_name = products[(sequence_id - 1) % len(products)]
+                    prompt_template = email_prompt_dict[product_name]
 
-                db.commit()
+                    loop = asyncio.get_event_loop()
+                    with concurrent.futures.ThreadPoolExecutor() as executor:
+                        if plan_pack and email_kw:
+                            gen_fn = partial(generate_email_sequence, campaign_sequence=email_kw)
+                            sequence_data_list = await loop.run_in_executor(
+                                executor,
+                                gen_fn,
+                                contact,
+                                prompt_template,
+                                product_name,
+                            )
+                        else:
+                            sequence_data_list = await loop.run_in_executor(
+                                executor,
+                                generate_email_sequence,
+                                contact,
+                                prompt_template,
+                                product_name,
+                            )
+
+                    for i, seq_data in enumerate(sequence_data_list):
+                        step_order_v = None
+                        if plan_pack and gmail_specs and i < len(gmail_specs):
+                            step_order_v = gmail_specs[i]["step_order"]
+                        db_sequence = GeneratedSequence(
+                            tenant_id=tenant_id,
+                            file_id=file_id,
+                            sequence_id=sequence_id,
+                            email_number=seq_data["email_number"],
+                            channel="email",
+                            first_name=seq_data["first_name"],
+                            last_name=seq_data["last_name"],
+                            email=seq_data["email"],
+                            company=seq_data["company"],
+                            title=seq_data.get("title", ""),
+                            product=seq_data["product"],
+                            subject=seq_data["subject"],
+                            email_content=seq_data["email_content"],
+                            step_order=step_order_v,
+                        )
+                        db.add(db_sequence)
 
-                for seq_data in sequence_data_list:
-                    sequence_response = {
-                        "id": sequence_id,
-                        "emailNumber": seq_data["email_number"],
-                        "firstName": seq_data["first_name"],
-                        "lastName": seq_data["last_name"],
-                        "email": seq_data["email"],
-                        "company": seq_data["company"],
-                        "title": seq_data.get("title", ""),
-                        "product": seq_data["product"],
-                        "subject": seq_data["subject"],
-                        "emailContent": seq_data["email_content"],
-                        "channel": "email",
-                    }
-                    yield f"data: {json.dumps({'type': 'sequence', 'sequence': sequence_response})}\n\n"
+                    db.commit()
+
+                    for i, seq_data in enumerate(sequence_data_list):
+                        step_order_v = None
+                        if plan_pack and gmail_specs and i < len(gmail_specs):
+                            step_order_v = gmail_specs[i]["step_order"]
+                        sequence_response = {
+                            "id": sequence_id,
+                            "emailNumber": seq_data["email_number"],
+                            "firstName": seq_data["first_name"],
+                            "lastName": seq_data["last_name"],
+                            "email": seq_data["email"],
+                            "company": seq_data["company"],
+                            "title": seq_data.get("title", ""),
+                            "product": seq_data["product"],
+                            "subject": seq_data["subject"],
+                            "emailContent": seq_data["email_content"],
+                            "channel": "email",
+                            "stepOrder": step_order_v,
+                        }
+                        yield f"data: {json.dumps({'type': 'sequence', 'sequence': sequence_response})}\n\n"
 
-                yield f"data: {json.dumps({'type': 'progress', 'progress': progress_pct(sequence_id, linkedin_phase=False)})}\n\n"
-                sequence_id += 1
-                await asyncio.sleep(0.1)
+                    prog = plan_progress_pct() if plan_pack else progress_pct(sequence_id, linkedin_phase=False)
+                    yield f"data: {json.dumps({'type': 'progress', 'progress': prog})}\n\n"
+                    sequence_id += 1
+                    await asyncio.sleep(0.1)
 
             if run_linkedin:
                 yield f"data: {json.dumps({'type': 'phase', 'phase': 'linkedin', 'message': 'Generating LinkedIn sequences'})}\n\n"
                 sequence_id = 1
                 for idx, row in df.iterrows():
-                    existing_li = (
-                        db.query(GeneratedSequence)
-                        .filter(
-                            GeneratedSequence.tenant_id == tenant_id,
-                            GeneratedSequence.file_id == file_id,
-                            GeneratedSequence.sequence_id == sequence_id,
-                            GeneratedSequence.channel == "linkedin",
+                    if plan_pack and li_meta_for_rows:
+                        li_done_n = (
+                            db.query(func.count(GeneratedSequence.id))
+                            .filter(
+                                GeneratedSequence.tenant_id == tenant_id,
+                                GeneratedSequence.file_id == file_id,
+                                GeneratedSequence.sequence_id == sequence_id,
+                                GeneratedSequence.channel == "linkedin",
+                            )
+                            .scalar()
+                            or 0
                         )
-                        .order_by(GeneratedSequence.email_number)
-                        .all()
-                    )
-                    if existing_li:
-                        for seq in existing_li:
-                            sequence_response = {
-                                "id": seq.sequence_id,
-                                "emailNumber": seq.email_number,
-                                "firstName": seq.first_name,
-                                "lastName": seq.last_name,
-                                "email": seq.email,
-                                "company": seq.company,
-                                "title": seq.title or "",
-                                "product": seq.product,
-                                "subject": seq.subject or "",
-                                "emailContent": seq.email_content,
-                                "channel": "linkedin",
-                            }
-                            yield f"data: {json.dumps({'type': 'sequence', 'sequence': sequence_response})}\n\n"
-                        yield f"data: {json.dumps({'type': 'progress', 'progress': progress_pct(sequence_id, linkedin_phase=True)})}\n\n"
-                        sequence_id += 1
-                        await asyncio.sleep(0.05)
-                        continue
+                        if li_done_n >= len(li_meta_for_rows):
+                            existing_li = (
+                                db.query(GeneratedSequence)
+                                .filter(
+                                    GeneratedSequence.tenant_id == tenant_id,
+                                    GeneratedSequence.file_id == file_id,
+                                    GeneratedSequence.sequence_id == sequence_id,
+                                    GeneratedSequence.channel == "linkedin",
+                                )
+                                .order_by(
+                                    func.coalesce(GeneratedSequence.step_order, 999999),
+                                    GeneratedSequence.email_number,
+                                )
+                                .all()
+                            )
+                            for seq in existing_li:
+                                yield f"data: {json.dumps({'type': 'sequence', 'sequence': orm_to_sequence_response(seq)})}\n\n"
+                            prog = plan_progress_pct() if plan_pack else progress_pct(sequence_id, linkedin_phase=True)
+                            yield f"data: {json.dumps({'type': 'progress', 'progress': prog})}\n\n"
+                            sequence_id += 1
+                            await asyncio.sleep(0.05)
+                            continue
+                    else:
+                        existing_li = (
+                            db.query(GeneratedSequence)
+                            .filter(
+                                GeneratedSequence.tenant_id == tenant_id,
+                                GeneratedSequence.file_id == file_id,
+                                GeneratedSequence.sequence_id == sequence_id,
+                                GeneratedSequence.channel == "linkedin",
+                            )
+                            .order_by(GeneratedSequence.email_number)
+                            .all()
+                        )
+                        if existing_li:
+                            for seq in existing_li:
+                                yield f"data: {json.dumps({'type': 'sequence', 'sequence': orm_to_sequence_response(seq)})}\n\n"
+                            prog = plan_progress_pct() if plan_pack else progress_pct(sequence_id, linkedin_phase=True)
+                            yield f"data: {json.dumps({'type': 'progress', 'progress': prog})}\n\n"
+                            sequence_id += 1
+                            await asyncio.sleep(0.05)
+                            continue
 
                     contact = row.to_dict()
                     li_product = li_products[(sequence_id - 1) % len(li_products)]
@@ -3711,15 +3940,28 @@ async def generate_sequences(
 
                     loop = asyncio.get_event_loop()
                     with concurrent.futures.ThreadPoolExecutor() as executor:
-                        li_list = await loop.run_in_executor(
-                            executor,
-                            generate_linkedin_sequence,
-                            contact,
-                            li_template,
-                            li_product,
-                        )
-
-                    for seq_data in li_list:
+                        if plan_pack and li_kw:
+                            gen_li = partial(generate_linkedin_sequence, campaign_sequence=li_kw)
+                            li_list = await loop.run_in_executor(
+                                executor,
+                                gen_li,
+                                contact,
+                                li_template,
+                                li_product,
+                            )
+                        else:
+                            li_list = await loop.run_in_executor(
+                                executor,
+                                generate_linkedin_sequence,
+                                contact,
+                                li_template,
+                                li_product,
+                            )
+
+                    for i, seq_data in enumerate(li_list):
+                        step_order_v = None
+                        if plan_pack and li_meta_for_rows and i < len(li_meta_for_rows):
+                            step_order_v = li_meta_for_rows[i]["step_order"]
                         db_sequence = GeneratedSequence(
                             tenant_id=tenant_id,
                             file_id=file_id,
@@ -3734,12 +3976,16 @@ async def generate_sequences(
                             product=seq_data["product"],
                             subject=seq_data.get("subject") or "",
                             email_content=seq_data["email_content"],
+                            step_order=step_order_v,
                         )
                         db.add(db_sequence)
 
                     db.commit()
 
-                    for seq_data in li_list:
+                    for i, seq_data in enumerate(li_list):
+                        step_order_v = None
+                        if plan_pack and li_meta_for_rows and i < len(li_meta_for_rows):
+                            step_order_v = li_meta_for_rows[i]["step_order"]
                         sequence_response = {
                             "id": sequence_id,
                             "emailNumber": seq_data["email_number"],
@@ -3752,10 +3998,12 @@ async def generate_sequences(
                             "subject": seq_data.get("subject") or "",
                             "emailContent": seq_data["email_content"],
                             "channel": "linkedin",
+                            "stepOrder": step_order_v,
                         }
                         yield f"data: {json.dumps({'type': 'sequence', 'sequence': sequence_response})}\n\n"
 
-                    yield f"data: {json.dumps({'type': 'progress', 'progress': progress_pct(sequence_id, linkedin_phase=True)})}\n\n"
+                    prog = plan_progress_pct() if plan_pack else progress_pct(sequence_id, linkedin_phase=True)
+                    yield f"data: {json.dumps({'type': 'progress', 'progress': prog})}\n\n"
                     sequence_id += 1
                     await asyncio.sleep(0.1)
 

backend/app/models.py

@@ -14,6 +14,7 @@ class PromptSaveRequest(BaseModel):
     prompts: Dict[str, str]
     products: List[str]
     linkedin_prompts: Dict[str, str] = Field(default_factory=dict)
+    sequence_plan: Optional[List[Dict]] = Field(default=None)
 
 
 class SequenceResponse(BaseModel):

frontend/src/components/campaigns/CampaignsDashboardTab.jsx

@@ -144,6 +144,7 @@ export default function CampaignsDashboardTab() {
                 name: payload.name,
                 status: 'running',
                 contacts,
+                fileId: payload.fileId || null,
                 openRate: null,
                 replyRate: null,
                 teamExtra: 0,

frontend/src/components/campaigns/CreateCampaignWizard.jsx

@@ -1,11 +1,20 @@
-import React, { useCallback, useEffect, useState } from 'react';
+import React, { useCallback, useEffect, useMemo, useRef, useState } from 'react';
 import { apiFetch } from '@/lib/api';
+import { mergeSequenceIntoContacts } from '@/lib/mergeSequenceIntoContacts';
 import { createPortal } from 'react-dom';
-import { X, Upload, ArrowRight, ArrowLeft } from 'lucide-react';
+import { X, Upload, ArrowRight, ArrowLeft, Sparkles, Loader2, CheckCircle2, Search, Filter } from 'lucide-react';
 import { Button } from '@/components/ui/button';
 import { Input } from '@/components/ui/input';
+import { Progress } from '@/components/ui/progress';
+import { Select, SelectContent, SelectItem, SelectTrigger, SelectValue } from '@/components/ui/select';
 import { cn } from '@/lib/utils';
 import CampaignSequenceBuilder, { createDefaultSequenceSteps } from '@/components/campaigns/CampaignSequenceBuilder';
+import ProductSelector from '@/components/products/ProductSelector';
+import PromptEditor, {
+    DEFAULT_TEMPLATES,
+    LINKEDIN_DEFAULT_TEMPLATES,
+} from '@/components/prompts/PromptEditor';
+import SequenceCard from '@/components/sequences/SequenceCard';
 
 const STEPS = [
     { id: 1, label: 'Upload & Select' },
@@ -14,6 +23,8 @@ const STEPS = [
     { id: 4, label: 'Review & Launch' },
 ];
 
+const WIZARD_SEQUENCE_TAG = '🔒 CAMPAIGN WIZARD — SEQUENCE';
+
 function estimateCsvRows(file) {
     if (!file) return 0;
     return new Promise((resolve) => {
@@ -28,23 +39,223 @@ function estimateCsvRows(file) {
     });
 }
 
+function buildCampaignSequenceAppendix(steps) {
+    const lines = [
+        WIZARD_SEQUENCE_TAG,
+        '(AUTHORITATIVE — OVERRIDES ANY FIXED “N EMAILS” OR “N MESSAGES” COUNT IN THIS PROMPT)',
+        '',
+        'The campaign sequence is fixed. Generate content only for the channels below; the system maps rows to Gmail vs LinkedIn.',
+        'Respect wait steps as pacing context between touches (do not invent extra touches for waits).',
+        '',
+    ];
+    let n = 0;
+    (steps || []).forEach((s) => {
+        if (s.type === 'wait') {
+            lines.push(`• Wait ${s.days ?? 1} day(s)`);
+        }
+        if (s.type === 'action') {
+            n += 1;
+            if (s.channel === 'gmail') {
+                lines.push(`${n}. Gmail — ${s.title || 'Email'}`);
+            } else if (s.channel === 'linkedin') {
+                const kind =
+                    s.action === 'linkedin_connect'
+                        ? 'LinkedIn connection request (must be the first LinkedIn output before any DM)'
+                        : 'LinkedIn DM / follow-up';
+                lines.push(`${n}. ${kind} — ${s.title || ''}`);
+            }
+        }
+    });
+    lines.push(
+        '',
+        'LinkedIn: the first LinkedIn message in your output must be the connection request whenever the sequence includes a connection step before DMs.',
+        'Keep narrative continuity with Gmail touches in the same campaign week where relevant.'
+    );
+    return lines.join('\n');
+}
+
+function WizardSequencePreview({
+    contacts,
+    sequences,
+    isGenerating,
+    generationComplete,
+    progress,
+    contactCount,
+    selectedProducts,
+    sequenceHasLinkedin,
+    genPhase,
+}) {
+    const [searchQuery, setSearchQuery] = useState('');
+    const [filterProduct, setFilterProduct] = useState('all');
+    const [displayedCount, setDisplayedCount] = useState(50);
+
+    useEffect(() => {
+        setDisplayedCount(50);
+    }, [searchQuery, filterProduct]);
+
+    const filteredContacts = contacts.filter((contact) => {
+        const matchesSearch =
+            searchQuery === '' ||
+            contact.firstName?.toLowerCase().includes(searchQuery.toLowerCase()) ||
+            contact.lastName?.toLowerCase().includes(searchQuery.toLowerCase()) ||
+            contact.company?.toLowerCase().includes(searchQuery.toLowerCase()) ||
+            contact.email?.toLowerCase().includes(searchQuery.toLowerCase());
+        const matchesFilter = filterProduct === 'all' || contact.product === filterProduct;
+        return matchesSearch && matchesFilter;
+    });
+    const displayedContacts = filteredContacts.slice(0, displayedCount);
+    const hasMore = filteredContacts.length > displayedCount;
+    const showProgress = isGenerating || !generationComplete;
+    const phaseLabel =
+        sequenceHasLinkedin && genPhase === 'linkedin' && isGenerating
+            ? 'LinkedIn sequences'
+            : 'Email sequences';
+
+    return (
+        <div className="w-full space-y-4">
+            <div className="mb-2 rounded-2xl border border-slate-200 bg-white p-6">
+                <div className="mb-4 flex items-center justify-between">
+                    <div className="flex items-center gap-3">
+                        {generationComplete ? (
+                            <div className="rounded-xl bg-green-100 p-3">
+                                <CheckCircle2 className="h-6 w-6 text-green-600" />
+                            </div>
+                        ) : (
+                            <div className="rounded-xl bg-violet-100 p-3">
+                                <Loader2 className="h-6 w-6 animate-spin text-violet-600" />
+                            </div>
+                        )}
+                        <div>
+                            <h3 className="font-semibold text-slate-800">
+                                {generationComplete ? 'Generation complete!' : `Generating ${phaseLabel}…`}
+                            </h3>
+                            <p className="text-sm text-slate-500">
+                                {contacts.length} contacts · {sequences.length} generated rows
+                                {contactCount ? ` · ~${contactCount} contacts in file` : ''}
+                            </p>
+                        </div>
+                    </div>
+                </div>
+                {showProgress ? <Progress value={progress} className="h-2" /> : null}
+            </div>
+
+            {sequences.length > 0 && (
+                <div className="flex flex-col gap-3 sm:flex-row">
+                    <div className="relative flex-1">
+                        <Search className="absolute left-3 top-1/2 h-4 w-4 -translate-y-1/2 text-slate-400" />
+                        <Input
+                            placeholder="Search contacts…"
+                            value={searchQuery}
+                            onChange={(e) => setSearchQuery(e.target.value)}
+                            className="pl-10"
+                        />
+                    </div>
+                    <Select value={filterProduct} onValueChange={setFilterProduct}>
+                        <SelectTrigger className="w-full sm:w-48">
+                            <Filter className="mr-2 h-4 w-4 text-slate-400" />
+                            <SelectValue placeholder="Filter by product" />
+                        </SelectTrigger>
+                        <SelectContent>
+                            <SelectItem value="all">All Products</SelectItem>
+                            {selectedProducts.map((product) => (
+                                <SelectItem key={product.id} value={product.name}>
+                                    {product.name}
+                                </SelectItem>
+                            ))}
+                        </SelectContent>
+                    </Select>
+                </div>
+            )}
+
+            <div className="custom-scrollbar max-h-[min(420px,50vh)] space-y-3 overflow-y-auto pr-1">
+                {displayedContacts.map((contact, index) => (
+                    <SequenceCard
+                        key={contact.id || `${contact.firstName}-${contact.lastName}-${contact.email}`}
+                        contact={contact}
+                        index={index}
+                    />
+                ))}
+                {hasMore && (
+                    <div className="py-3 text-center">
+                        <Button
+                            type="button"
+                            variant="outline"
+                            onClick={() => setDisplayedCount((c) => Math.min(c + 50, filteredContacts.length))}
+                        >
+                            Load more ({filteredContacts.length - displayedCount} remaining)
+                        </Button>
+                    </div>
+                )}
+            </div>
+
+            {!isGenerating && contacts.length === 0 && sequences.length === 0 && (
+                <div className="rounded-xl border border-dashed border-slate-200 bg-slate-50/80 py-12 text-center text-sm text-slate-500">
+                    Generated messages will appear here. You can continue to the next step while generation runs in the
+                    background.
+                </div>
+            )}
+        </div>
+    );
+}
+
 export default function CreateCampaignWizard({ open, onOpenChange, onComplete }) {
     const [step, setStep] = useState(1);
     const [campaignName, setCampaignName] = useState('');
     const [prospectFile, setProspectFile] = useState(null);
+    const [wizardUpload, setWizardUpload] = useState(null);
+    const [uploadingCsv, setUploadingCsv] = useState(false);
     const [dragOver, setDragOver] = useState(false);
     const [estimatedContacts, setEstimatedContacts] = useState(0);
     const [sequenceSteps, setSequenceSteps] = useState(() => createDefaultSequenceSteps());
     const [linkedinDefaults, setLinkedinDefaults] = useState(null);
     const [mailboxDefaults, setMailboxDefaults] = useState(null);
 
+    const [selectedProducts, setSelectedProducts] = useState([]);
+    const [prompts, setPrompts] = useState({});
+    const [linkedinPrompts, setLinkedinPrompts] = useState({});
+
+    const [genSequences, setGenSequences] = useState([]);
+    const [genContacts, setGenContacts] = useState([]);
+    const [genProgress, setGenProgress] = useState(0);
+    const [genRunning, setGenRunning] = useState(false);
+    const [genComplete, setGenComplete] = useState(false);
+    const [genPhase, setGenPhase] = useState('email');
+    const [genRunId, setGenRunId] = useState(0);
+    const eventSourceRef = useRef(null);
+    const prevGenRunIdRef = useRef(null);
+
+    const sequenceHasLinkedin = useMemo(
+        () =>
+            sequenceSteps.some(
+                (s) => s.type === 'action' && s.channel === 'linkedin' && s.action !== 'email'
+            ),
+        [sequenceSteps]
+    );
+
     const reset = useCallback(() => {
+        if (eventSourceRef.current) {
+            eventSourceRef.current.close();
+            eventSourceRef.current = null;
+        }
         setStep(1);
         setCampaignName('');
         setProspectFile(null);
+        setWizardUpload(null);
+        setUploadingCsv(false);
         setEstimatedContacts(0);
         setDragOver(false);
         setSequenceSteps(createDefaultSequenceSteps());
+        setSelectedProducts([]);
+        setPrompts({});
+        setLinkedinPrompts({});
+        setGenSequences([]);
+        setGenContacts([]);
+        setGenProgress(0);
+        setGenRunning(false);
+        setGenComplete(false);
+        setGenPhase('email');
+        setGenRunId(0);
+        prevGenRunIdRef.current = null;
     }, []);
 
     useEffect(() => {
@@ -129,15 +340,161 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
         );
     }, [linkedinDefaults]);
 
-    const pickFile = (file) => {
+    useEffect(() => {
+        if (step !== 3 || selectedProducts.length === 0) return;
+        const appendix = buildCampaignSequenceAppendix(sequenceSteps);
+        setPrompts((prev) => {
+            const next = { ...prev };
+            let changed = false;
+            selectedProducts.forEach((p) => {
+                let cur = (next[p.name] || '').trim();
+                if (!cur) {
+                    cur = DEFAULT_TEMPLATES[p.name] || '';
+                }
+                if (!cur || cur.includes(WIZARD_SEQUENCE_TAG)) return;
+                next[p.name] = `${cur}\n\n${appendix}`;
+                changed = true;
+            });
+            return changed ? next : prev;
+        });
+        if (!sequenceHasLinkedin) return;
+        setLinkedinPrompts((prev) => {
+            const next = { ...prev };
+            let changed = false;
+            selectedProducts.forEach((p) => {
+                let cur = (next[p.name] || '').trim();
+                if (!cur) {
+                    cur =
+                        LINKEDIN_DEFAULT_TEMPLATES[p.name] ||
+                        `🔒 LINKEDIN SYSTEM PROMPT\n\nGenerate a 3-message LinkedIn sequence for ${p.name}.\nLabel: Message 1, Message 2, Message 3.\nUse {{first_name}}, {{company}}. Sender: Anna.`;
+                }
+                if (!cur || cur.includes(WIZARD_SEQUENCE_TAG)) return;
+                next[p.name] = `${cur}\n\n${appendix}`;
+                changed = true;
+            });
+            return changed ? next : prev;
+        });
+    }, [step, sequenceSteps, selectedProducts, sequenceHasLinkedin]);
+
+    useEffect(() => {
+        if (!genRunning || !wizardUpload?.fileId) return;
+
+        const isNewRun = prevGenRunIdRef.current !== genRunId;
+        if (isNewRun) {
+            prevGenRunIdRef.current = genRunId;
+            setGenSequences([]);
+            setGenContacts([]);
+            setGenProgress(0);
+            setGenComplete(false);
+            setGenPhase('email');
+        }
+
+        if (eventSourceRef.current) {
+            eventSourceRef.current.close();
+            eventSourceRef.current = null;
+        }
+
+        const resetParam = isNewRun ? 1 : 0;
+        const url = `/api/generate-sequences?file_id=${encodeURIComponent(wizardUpload.fileId)}&reset=${resetParam}`;
+        const es = new EventSource(url);
+        eventSourceRef.current = es;
+
+        es.onmessage = (event) => {
+            try {
+                const data = JSON.parse(event.data);
+                if (data.type === 'sequence') {
+                    const seq = data.sequence;
+                    setGenSequences((prev) => {
+                        const sig = `${seq.id}-${seq.emailNumber}-${seq.channel || 'email'}-${seq.stepOrder ?? ''}`;
+                        if (
+                            prev.some(
+                                (s) =>
+                                    `${s.id}-${s.emailNumber}-${s.channel || 'email'}-${s.stepOrder ?? ''}` === sig
+                            )
+                        ) {
+                            return prev;
+                        }
+                        return [...prev, seq];
+                    });
+                    setGenContacts((prev) => mergeSequenceIntoContacts(prev, seq));
+                } else if (data.type === 'progress' && typeof data.progress === 'number') {
+                    setGenProgress(data.progress);
+                } else if (data.type === 'phase' && data.phase === 'linkedin') {
+                    setGenPhase('linkedin');
+                } else if (data.type === 'complete') {
+                    setGenRunning(false);
+                    setGenComplete(true);
+                    es.close();
+                    if (eventSourceRef.current === es) eventSourceRef.current = null;
+                } else if (data.type === 'error') {
+                    console.error(data.error);
+                    alert(`Generation error: ${data.error}`);
+                    setGenRunning(false);
+                    es.close();
+                    if (eventSourceRef.current === es) eventSourceRef.current = null;
+                }
+            } catch (e) {
+                console.error(e);
+            }
+        };
+
+        es.onerror = () => {
+            es.close();
+            if (eventSourceRef.current === es) eventSourceRef.current = null;
+        };
+
+        return () => {
+            es.close();
+            if (eventSourceRef.current === es) eventSourceRef.current = null;
+        };
+    }, [genRunning, wizardUpload?.fileId, genRunId]);
+
+    const pickFile = async (file) => {
         if (!file) return;
-        const ok =
-            file.name.toLowerCase().endsWith('.csv') || file.name.toLowerCase().endsWith('.xlsx');
-        if (!ok) return;
+        if (!file.name.toLowerCase().endsWith('.csv')) {
+            alert('Please upload a .csv file (Apollo export), same as Email / AI Generator.');
+            return;
+        }
         setProspectFile(file);
+        setWizardUpload(null);
+        setUploadingCsv(true);
+        try {
+            const formData = new FormData();
+            formData.append('file', file);
+            const response = await apiFetch('/api/upload-csv', {
+                method: 'POST',
+                body: formData,
+            });
+            if (!response.ok) {
+                throw new Error('Upload failed');
+            }
+            const data = await response.json();
+            setWizardUpload({
+                fileId: data.file_id,
+                contactCount: data.contact_count,
+                name: file.name,
+            });
+        } catch (err) {
+            console.error(err);
+            alert('Could not upload CSV. Please try again.');
+            setProspectFile(null);
+            setWizardUpload(null);
+        } finally {
+            setUploadingCsv(false);
+        }
     };
 
-    const canContinueStep1 = campaignName.trim().length > 0 && prospectFile;
+    const canContinueStep1 =
+        campaignName.trim().length > 0 && !!wizardUpload?.fileId && !uploadingCsv;
+
+    const canGenerate = useMemo(() => {
+        const emailOk =
+            selectedProducts.length > 0 &&
+            selectedProducts.every((p) => (prompts[p.name] || '').trim());
+        if (!emailOk || !wizardUpload?.fileId) return false;
+        if (!sequenceHasLinkedin) return true;
+        return selectedProducts.every((p) => (linkedinPrompts[p.name] || '').trim());
+    }, [selectedProducts, prompts, linkedinPrompts, wizardUpload?.fileId, sequenceHasLinkedin]);
 
     const handleContinue = () => {
         if (step === 1 && !canContinueStep1) return;
@@ -148,6 +505,39 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
         if (step > 1) setStep((s) => s - 1);
     };
 
+    const handleGenerate = async () => {
+        if (!canGenerate) {
+            alert('Select products and fill all prompt templates before generating.');
+            return;
+        }
+        try {
+            const res = await apiFetch('/api/save-prompts', {
+                method: 'POST',
+                headers: { 'Content-Type': 'application/json' },
+                body: JSON.stringify({
+                    file_id: wizardUpload.fileId,
+                    prompts,
+                    products: selectedProducts.map((p) => p.name),
+                    linkedin_prompts: sequenceHasLinkedin ? linkedinPrompts : {},
+                    sequence_plan: sequenceSteps,
+                }),
+            });
+            if (!res.ok) {
+                const err = await res.json().catch(() => ({}));
+                throw new Error(err.detail || res.statusText);
+            }
+        } catch (e) {
+            console.error(e);
+            alert('Failed to save prompts. Please try again.');
+            return;
+        }
+        alert(
+            'Generation has started. It will continue in the background — you can continue to Review & Launch and save the campaign while rows are still being created.'
+        );
+        setGenRunId((r) => r + 1);
+        setGenRunning(true);
+    };
+
     const handleLaunch = () => {
         if (!onComplete) {
             onOpenChange(false);
@@ -155,8 +545,9 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
         }
         onComplete({
             name: campaignName.trim(),
-            contacts: estimatedContacts || 0,
-            prospectFileName: prospectFile?.name || '',
+            contacts: wizardUpload?.contactCount || estimatedContacts || 0,
+            prospectFileName: wizardUpload?.name || prospectFile?.name || '',
+            fileId: wizardUpload?.fileId || null,
             sequence: sequenceSteps,
         });
         onOpenChange(false);
@@ -181,7 +572,7 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
             <div
                 className={cn(
                     'relative z-[101] flex max-h-[min(92vh,900px)] w-full flex-col overflow-hidden rounded-2xl border border-slate-200 bg-white shadow-2xl shadow-violet-200/30',
-                    step === 2 ? 'max-w-4xl' : 'max-w-3xl'
+                    step === 2 || step === 3 ? 'max-w-4xl' : 'max-w-3xl'
                 )}
             >
                 <div className="flex items-center justify-between border-b border-slate-100 px-5 py-4">
@@ -197,7 +588,6 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
                     </button>
                 </div>
 
-                {/* Stepper */}
                 <div className="border-b border-slate-100 bg-slate-50/80 px-4 py-4 sm:px-6">
                     <div className="flex flex-wrap items-start justify-between gap-4">
                         {STEPS.map((s) => {
@@ -271,12 +661,12 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
                                         const f = e.dataTransfer.files?.[0];
                                         pickFile(f);
                                     }}
-                                    onClick={() => document.getElementById('wizard-csv-input')?.click()}
+                                    onClick={() => !uploadingCsv && document.getElementById('wizard-csv-input')?.click()}
                                 >
                                     <input
                                         id="wizard-csv-input"
                                         type="file"
-                                        accept=".csv,.xlsx"
+                                        accept=".csv"
                                         className="hidden"
                                         onChange={(e) => pickFile(e.target.files?.[0])}
                                     />
@@ -290,6 +680,7 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
                                         type="button"
                                         variant="outline"
                                         className="mt-4"
+                                        disabled={uploadingCsv}
                                         onClick={(e) => {
                                             e.stopPropagation();
                                             document.getElementById('wizard-csv-input')?.click();
@@ -297,13 +688,19 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
                                     >
                                         Browse Files
                                     </Button>
-                                    {prospectFile ? (
+                                    {uploadingCsv ? (
+                                        <p className="mt-3 text-xs font-medium text-violet-700">Uploading…</p>
+                                    ) : wizardUpload ? (
                                         <p className="mt-3 text-xs font-medium text-violet-700">
-                                            {prospectFile.name}
-                                            {estimatedContacts > 0
-                                                ? ` · ~${estimatedContacts.toLocaleString()} rows`
-                                                : ''}
+                                            {wizardUpload.name}
+                                            {wizardUpload.contactCount
+                                                ? ` · ${Number(wizardUpload.contactCount).toLocaleString()} contacts`
+                                                : estimatedContacts > 0
+                                                  ? ` · ~${estimatedContacts.toLocaleString()} rows`
+                                                  : ''}
                                         </p>
+                                    ) : prospectFile ? (
+                                        <p className="mt-3 text-xs text-amber-700">Upload failed — try another file.</p>
                                     ) : null}
                                 </div>
                             </div>
@@ -316,10 +713,76 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
                             mailboxDefaults={mailboxDefaults}
                         />
                     ) : step === 3 ? (
-                        <PlaceholderStep
-                            title="Generate Contents"
-                            body="AI-generated messages and personalization will live here. Details coming soon."
-                        />
+                        <div className="space-y-8">
+                            <div>
+                                <span className="inline-flex rounded-md bg-slate-100 px-2 py-0.5 text-[10px] font-medium uppercase tracking-wide text-slate-500">
+                                    Step 3
+                                </span>
+                                <h3 className="mt-2 text-lg font-semibold text-slate-900">Prompts & generation</h3>
+                                <p className="mt-1 text-sm text-slate-600">
+                                    Same experience as Email / AI Generator: templates follow your product defaults, with
+                                    an added block that mirrors the sequence you configured (Gmail + LinkedIn). Touch
+                                    counts in the prompt are ignored — the wizard sequence is authoritative.
+                                </p>
+                            </div>
+                            <ProductSelector
+                                selectedProducts={selectedProducts}
+                                onProductsChange={setSelectedProducts}
+                            />
+                            {selectedProducts.length > 0 ? (
+                                <>
+                                    <PromptEditor
+                                        selectedProducts={selectedProducts}
+                                        prompts={prompts}
+                                        onPromptsChange={setPrompts}
+                                        variant="email"
+                                    />
+                                    {sequenceHasLinkedin ? (
+                                        <div className="space-y-2">
+                                            <h4 className="text-base font-semibold text-slate-800">LinkedIn prompts</h4>
+                                            <p className="text-sm text-slate-500">
+                                                Required because this campaign includes LinkedIn steps.
+                                            </p>
+                                            <PromptEditor
+                                                selectedProducts={selectedProducts}
+                                                prompts={linkedinPrompts}
+                                                onPromptsChange={setLinkedinPrompts}
+                                                variant="linkedin"
+                                            />
+                                        </div>
+                                    ) : null}
+                                    <div className="flex flex-wrap items-center gap-3">
+                                        <Button
+                                            type="button"
+                                            disabled={!canGenerate || genRunning}
+                                            className="bg-gradient-to-r from-violet-600 to-purple-600 hover:from-violet-700 hover:to-purple-700"
+                                            onClick={handleGenerate}
+                                        >
+                                            <Sparkles className="mr-2 h-4 w-4" />
+                                            {genRunning ? 'Generating…' : 'Generate'}
+                                        </Button>
+                                        {genRunning ? (
+                                            <span className="text-sm text-slate-600">
+                                                Running in the background — you can go to the next step anytime.
+                                            </span>
+                                        ) : null}
+                                    </div>
+                                    <WizardSequencePreview
+                                        contacts={genContacts}
+                                        sequences={genSequences}
+                                        isGenerating={genRunning}
+                                        generationComplete={genComplete}
+                                        progress={genProgress}
+                                        contactCount={wizardUpload?.contactCount}
+                                        selectedProducts={selectedProducts}
+                                        sequenceHasLinkedin={sequenceHasLinkedin}
+                                        genPhase={genPhase}
+                                    />
+                                </>
+                            ) : (
+                                <p className="text-sm text-slate-500">Select at least one product to edit prompts.</p>
+                            )}
+                        </div>
                     ) : (
                         <div className="space-y-6">
                             <PlaceholderStep
@@ -333,23 +796,41 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
                                         <p className="font-semibold text-slate-900">{campaignName || '—'}</p>
                                     </div>
                                     <div>
-                                        <span className="text-slate-500">Prospects (estimate)</span>
+                                        <span className="text-slate-500">Prospects</span>
                                         <p className="font-semibold text-slate-900">
-                                            {estimatedContacts > 0
-                                                ? estimatedContacts.toLocaleString()
-                                                : prospectFile
-                                                  ? 'Calculating…'
+                                            {wizardUpload?.contactCount != null
+                                                ? Number(wizardUpload.contactCount).toLocaleString()
+                                                : estimatedContacts > 0
+                                                  ? estimatedContacts.toLocaleString()
                                                   : '—'}
                                         </p>
                                     </div>
                                     <div className="sm:col-span-2">
                                         <span className="text-slate-500">File</span>
-                                        <p className="font-medium text-slate-800">{prospectFile?.name || '—'}</p>
+                                        <p className="font-medium text-slate-800">
+                                            {wizardUpload?.name || prospectFile?.name || '—'}
+                                        </p>
                                     </div>
+                                    {wizardUpload?.fileId ? (
+                                        <div className="sm:col-span-2">
+                                            <span className="text-slate-500">Generation file ID</span>
+                                            <p className="break-all font-mono text-xs text-slate-700">
+                                                {wizardUpload.fileId}
+                                            </p>
+                                        </div>
+                                    ) : null}
                                     <div className="sm:col-span-2">
                                         <span className="text-slate-500">Sequence</span>
                                         <p className="font-medium text-slate-800">
-                                            {sequenceSteps.length} step{sequenceSteps.length !== 1 ? 's' : ''} configured
+                                            {sequenceSteps.length} step{sequenceSteps.length !== 1 ? 's' : ''}{' '}
+                                            configured
+                                        </p>
+                                    </div>
+                                    <div className="sm:col-span-2">
+                                        <span className="text-slate-500">Generated rows</span>
+                                        <p className="font-medium text-slate-800">
+                                            {genSequences.length}
+                                            {genRunning ? ' (still generating…)' : genComplete ? ' (complete)' : ''}
                                         </p>
                                     </div>
                                 </div>
@@ -394,7 +875,9 @@ export default function CreateCampaignWizard({ open, onOpenChange, onComplete })
                             >
                                 {step === 1
                                     ? 'Continue to Sequence'
-                                    : `Continue to ${STEPS[step]?.label ?? 'next'}`}
+                                    : step === 3
+                                      ? 'Continue to Review & Launch'
+                                      : `Continue to ${STEPS[step]?.label ?? 'next'}`}
                                 <ArrowRight className="ml-2 h-4 w-4" />
                             </Button>
                         ) : null}

frontend/src/components/prompts/PromptEditor.jsx

@@ -5,7 +5,7 @@ import { Textarea } from "@/components/ui/textarea";
 import { Tabs, TabsList, TabsTrigger, TabsContent } from "@/components/ui/tabs";
 import { motion, AnimatePresence } from 'framer-motion';
 
-const DEFAULT_TEMPLATES = {
+export const DEFAULT_TEMPLATES = {
     'Accounts Payable Automation': `🔒 SYSTEM PROMPT (DO NOT MODIFY)
 
 You are an expert B2B outbound copywriter writing cold emails that feel like internal work conversations, not marketing.
@@ -780,7 +780,7 @@ Best,
 {{sender_name}}`,
 };
 
-const LINKEDIN_DEFAULT_TEMPLATES = {
+export const LINKEDIN_DEFAULT_TEMPLATES = {
     'Accounts Payable Automation': `🔒 LINKEDIN SYSTEM PROMPT (DO NOT MODIFY)
 
 You are an expert B2B LinkedIn copywriter. Write short, human DMs and connection notes for AP / finance professionals at North American mid-market companies.

frontend/src/components/sequences/SequenceCard.jsx

@@ -1,4 +1,4 @@
-import React, { useState } from 'react';
+import React, { useMemo, useState } from 'react';
 import { User, Building2, Mail, ChevronDown, ChevronUp, Copy, CheckCircle2 } from 'lucide-react';
 import { Button } from "@/components/ui/button";
 import { Badge } from "@/components/ui/badge";
@@ -11,7 +11,34 @@ export default function SequenceCard({ contact, index }) {
 
     const emails = contact.emails || [];
     const linkedin = contact.linkedin || [];
-    const firstEmail = emails[0] || contact;
+    const firstEmail = emails[0] ||
+        linkedin[0] || {
+            firstName: contact.firstName,
+            lastName: contact.lastName,
+            company: contact.company,
+            email: contact.email,
+            product: contact.product,
+        };
+
+    const mergedTimeline = useMemo(() => {
+        const parts = [
+            ...(emails || []).map((m, i) => ({
+                kind: 'email',
+                stepOrder: m.stepOrder,
+                data: m,
+                key: `e-${m.stepOrder ?? 'x'}-${m.emailNumber ?? i}`,
+            })),
+            ...(linkedin || []).map((m, i) => ({
+                kind: 'linkedin',
+                stepOrder: m.stepOrder,
+                data: m,
+                key: `l-${m.stepOrder ?? 'x'}-${m.emailNumber ?? i}`,
+            })),
+        ];
+        const hasOrder = parts.some((p) => p.stepOrder != null);
+        if (!hasOrder) return null;
+        return [...parts].sort((a, b) => (a.stepOrder ?? 1e9) - (b.stepOrder ?? 1e9));
+    }, [emails, linkedin]);
     
     const handleCopy = (emailContent, emailNum) => {
         navigator.clipboard.writeText(emailContent);
@@ -82,89 +109,174 @@ export default function SequenceCard({ contact, index }) {
                     className="border-t border-slate-100"
                 >
                     <div className="px-5 py-4 bg-slate-50/50 space-y-4">
-                        {emails.map((email, emailIdx) => (
-                            <div key={`e-${emailIdx}`} className="bg-white rounded-lg border border-slate-200 p-4">
-                                <div className="flex items-center justify-between mb-3">
-                                    <div className="flex items-center gap-2">
-                                        <h5 className="text-sm font-medium text-slate-600">
-                                            Email {email.emailNumber || emailIdx + 1}
-                                        </h5>
-                                        {emails.length > 1 && (
-                                            <Badge variant="outline" className="text-xs">
-                                                {email.emailNumber || emailIdx + 1} of {emails.length}
-                                            </Badge>
-                                        )}
-                                    </div>
-                                    <Button
-                                        variant="ghost"
-                                        size="sm"
-                                        onClick={(e) => {
-                                            e.stopPropagation();
-                                            handleCopy(email.emailContent, email.emailNumber || emailIdx + 1);
-                                        }}
-                                        className="h-8 text-slate-500 hover:text-violet-600"
+                        {mergedTimeline ? (
+                            mergedTimeline.map((item, idx) => {
+                                const copyId =
+                                    item.kind === 'email'
+                                        ? item.data.emailNumber || idx + 1
+                                        : `li-${item.data.emailNumber || idx + 1}`;
+                                const isLi = item.kind === 'linkedin';
+                                return (
+                                    <div
+                                        key={item.key}
+                                        className={`rounded-lg border p-4 shadow-sm ${
+                                            isLi
+                                                ? 'border-sky-200 bg-white'
+                                                : 'border-slate-200 bg-white'
+                                        }`}
                                     >
-                                        {copiedEmailNum === (email.emailNumber || emailIdx + 1) ? (
-                                            <>
-                                                <CheckCircle2 className="h-4 w-4 mr-1 text-green-500" />
-                                                Copied!
-                                            </>
-                                        ) : (
-                                            <>
-                                                <Copy className="h-4 w-4 mr-1" />
-                                                Copy
-                                            </>
+                                        <div className="mb-3 flex items-center justify-between">
+                                            <div className="flex flex-wrap items-center gap-2">
+                                                <Badge
+                                                    variant="outline"
+                                                    className={
+                                                        isLi ? 'border-sky-200 text-sky-800' : 'text-slate-700'
+                                                    }
+                                                >
+                                                    {isLi ? 'LinkedIn' : 'Gmail'}
+                                                </Badge>
+                                                <h5
+                                                    className={`text-sm font-medium ${
+                                                        isLi ? 'text-sky-800' : 'text-slate-600'
+                                                    }`}
+                                                >
+                                                    {isLi
+                                                        ? `Message ${item.data.emailNumber || idx + 1}`
+                                                        : `Email ${item.data.emailNumber || idx + 1}`}
+                                                </h5>
+                                            </div>
+                                            <Button
+                                                variant="ghost"
+                                                size="sm"
+                                                onClick={(e) => {
+                                                    e.stopPropagation();
+                                                    handleCopy(item.data.emailContent, copyId);
+                                                }}
+                                                className={`h-8 text-slate-500 ${
+                                                    isLi ? 'hover:text-sky-600' : 'hover:text-violet-600'
+                                                }`}
+                                            >
+                                                {copiedEmailNum === copyId ? (
+                                                    <>
+                                                        <CheckCircle2 className="mr-1 h-4 w-4 text-green-500" />
+                                                        Copied!
+                                                    </>
+                                                ) : (
+                                                    <>
+                                                        <Copy className="mr-1 h-4 w-4" />
+                                                        Copy
+                                                    </>
+                                                )}
+                                            </Button>
+                                        </div>
+                                        {!isLi && (
+                                            <div className="mb-3 border-b border-slate-100 pb-3">
+                                                <span className="text-xs uppercase tracking-wide text-slate-400">
+                                                    Subject
+                                                </span>
+                                                <p className="mt-1 text-sm font-medium text-slate-800">
+                                                    {item.data.subject}
+                                                </p>
+                                            </div>
                                         )}
-                                    </Button>
-                                </div>
-                                <div className="mb-3 pb-3 border-b border-slate-100">
-                                    <span className="text-xs text-slate-400 uppercase tracking-wide">Subject</span>
-                                    <p className="text-sm font-medium text-slate-800 mt-1">{email.subject}</p>
-                                </div>
-                                <div className="text-sm text-slate-700 whitespace-pre-wrap leading-relaxed">
-                                    {email.emailContent}
-                                </div>
-                            </div>
-                        ))}
-                        {linkedin.map((msg, liIdx) => (
-                            <div
-                                key={`li-${liIdx}`}
-                                className="bg-white rounded-lg border border-sky-200 p-4 shadow-sm"
-                            >
-                                <div className="flex items-center justify-between mb-3">
-                                    <h5 className="text-sm font-medium text-sky-800">
-                                        LinkedIn — Message {msg.emailNumber || liIdx + 1}
-                                    </h5>
-                                    <Button
-                                        variant="ghost"
-                                        size="sm"
-                                        onClick={(e) => {
-                                            e.stopPropagation();
-                                            handleCopy(
-                                                msg.emailContent,
-                                                `li-${msg.emailNumber || liIdx + 1}`
-                                            );
-                                        }}
-                                        className="h-8 text-slate-500 hover:text-sky-600"
+                                        <div className="whitespace-pre-wrap text-sm leading-relaxed text-slate-700">
+                                            {item.data.emailContent}
+                                        </div>
+                                    </div>
+                                );
+                            })
+                        ) : (
+                            <>
+                                {emails.map((email, emailIdx) => (
+                                    <div key={`e-${emailIdx}`} className="rounded-lg border border-slate-200 bg-white p-4">
+                                        <div className="mb-3 flex items-center justify-between">
+                                            <div className="flex items-center gap-2">
+                                                <h5 className="text-sm font-medium text-slate-600">
+                                                    Email {email.emailNumber || emailIdx + 1}
+                                                </h5>
+                                                {emails.length > 1 && (
+                                                    <Badge variant="outline" className="text-xs">
+                                                        {email.emailNumber || emailIdx + 1} of {emails.length}
+                                                    </Badge>
+                                                )}
+                                            </div>
+                                            <Button
+                                                variant="ghost"
+                                                size="sm"
+                                                onClick={(e) => {
+                                                    e.stopPropagation();
+                                                    handleCopy(
+                                                        email.emailContent,
+                                                        email.emailNumber || emailIdx + 1
+                                                    );
+                                                }}
+                                                className="h-8 text-slate-500 hover:text-violet-600"
+                                            >
+                                                {copiedEmailNum === (email.emailNumber || emailIdx + 1) ? (
+                                                    <>
+                                                        <CheckCircle2 className="mr-1 h-4 w-4 text-green-500" />
+                                                        Copied!
+                                                    </>
+                                                ) : (
+                                                    <>
+                                                        <Copy className="mr-1 h-4 w-4" />
+                                                        Copy
+                                                    </>
+                                                )}
+                                            </Button>
+                                        </div>
+                                        <div className="mb-3 border-b border-slate-100 pb-3">
+                                            <span className="text-xs uppercase tracking-wide text-slate-400">
+                                                Subject
+                                            </span>
+                                            <p className="mt-1 text-sm font-medium text-slate-800">{email.subject}</p>
+                                        </div>
+                                        <div className="whitespace-pre-wrap text-sm leading-relaxed text-slate-700">
+                                            {email.emailContent}
+                                        </div>
+                                    </div>
+                                ))}
+                                {linkedin.map((msg, liIdx) => (
+                                    <div
+                                        key={`li-${liIdx}`}
+                                        className="rounded-lg border border-sky-200 bg-white p-4 shadow-sm"
                                     >
-                                        {copiedEmailNum === `li-${msg.emailNumber || liIdx + 1}` ? (
-                                            <>
-                                                <CheckCircle2 className="h-4 w-4 mr-1 text-green-500" />
-                                                Copied!
-                                            </>
-                                        ) : (
-                                            <>
-                                                <Copy className="h-4 w-4 mr-1" />
-                                                Copy
-                                            </>
-                                        )}
-                                    </Button>
-                                </div>
-                                <div className="text-sm text-slate-700 whitespace-pre-wrap leading-relaxed">
-                                    {msg.emailContent}
-                                </div>
-                            </div>
-                        ))}
+                                        <div className="mb-3 flex items-center justify-between">
+                                            <h5 className="text-sm font-medium text-sky-800">
+                                                LinkedIn — Message {msg.emailNumber || liIdx + 1}
+                                            </h5>
+                                            <Button
+                                                variant="ghost"
+                                                size="sm"
+                                                onClick={(e) => {
+                                                    e.stopPropagation();
+                                                    handleCopy(
+                                                        msg.emailContent,
+                                                        `li-${msg.emailNumber || liIdx + 1}`
+                                                    );
+                                                }}
+                                                className="h-8 text-slate-500 hover:text-sky-600"
+                                            >
+                                                {copiedEmailNum === `li-${msg.emailNumber || liIdx + 1}` ? (
+                                                    <>
+                                                        <CheckCircle2 className="mr-1 h-4 w-4 text-green-500" />
+                                                        Copied!
+                                                    </>
+                                                ) : (
+                                                    <>
+                                                        <Copy className="mr-1 h-4 w-4" />
+                                                        Copy
+                                                    </>
+                                                )}
+                                            </Button>
+                                        </div>
+                                        <div className="whitespace-pre-wrap text-sm leading-relaxed text-slate-700">
+                                            {msg.emailContent}
+                                        </div>
+                                    </div>
+                                ))}
+                            </>
+                        )}
                     </div>
                 </motion.div>
             )}

frontend/src/context/GeneratorWorkflowContext.jsx

@@ -8,59 +8,10 @@ import React, {
     useState,
 } from 'react';
 import { apiFetch } from '@/lib/api';
+import { mergeSequenceIntoContacts } from '@/lib/mergeSequenceIntoContacts';
 
 const GeneratorWorkflowContext = createContext(null);
 
-function applySequenceToContacts(prev, sequence) {
-    const ch = sequence.channel || 'email';
-    const existingContact = prev.find(
-        (c) =>
-            c.firstName === sequence.firstName &&
-            c.lastName === sequence.lastName &&
-            c.email === sequence.email
-    );
-    const step = {
-        emailNumber: sequence.emailNumber || 1,
-        subject: sequence.subject,
-        emailContent: sequence.emailContent,
-        channel: ch,
-    };
-    let updatedContacts;
-    if (existingContact) {
-        if (ch === 'linkedin') {
-            if (!existingContact.linkedin) existingContact.linkedin = [];
-            if (!existingContact.linkedin.some((e) => e.emailNumber === step.emailNumber)) {
-                existingContact.linkedin.push(step);
-            }
-        } else {
-            if (!existingContact.emails) existingContact.emails = [];
-            if (!existingContact.emails.some((e) => e.emailNumber === step.emailNumber)) {
-                existingContact.emails.push(step);
-            }
-        }
-        updatedContacts = [...prev];
-    } else {
-        const base = {
-            id: sequence.id,
-            firstName: sequence.firstName,
-            lastName: sequence.lastName,
-            email: sequence.email,
-            company: sequence.company,
-            title: sequence.title,
-            product: sequence.product,
-            emails: [],
-            linkedin: [],
-        };
-        if (ch === 'linkedin') {
-            base.linkedin = [step];
-        } else {
-            base.emails = [step];
-        }
-        updatedContacts = [...prev, base];
-    }
-    return updatedContacts;
-}
-
 export function GeneratorWorkflowProvider({ children }) {
     const [step, setStep] = useState(1);
     const [uploadedFile, setUploadedFile] = useState(null);
@@ -141,13 +92,18 @@ export function GeneratorWorkflowProvider({ children }) {
                 if (data.type === 'sequence') {
                     const seq = data.sequence;
                     setSequences((prev) => {
-                        const sig = `${seq.id}-${seq.emailNumber}-${seq.channel || 'email'}`;
-                        if (prev.some((s) => `${s.id}-${s.emailNumber}-${s.channel || 'email'}` === sig)) {
+                        const sig = `${seq.id}-${seq.emailNumber}-${seq.channel || 'email'}-${seq.stepOrder ?? ''}`;
+                        if (
+                            prev.some(
+                                (s) =>
+                                    `${s.id}-${s.emailNumber}-${s.channel || 'email'}-${s.stepOrder ?? ''}` === sig
+                            )
+                        ) {
                             return prev;
                         }
                         return [...prev, seq];
                     });
-                    setContacts((prev) => applySequenceToContacts(prev, seq));
+                    setContacts((prev) => mergeSequenceIntoContacts(prev, seq));
                 } else if (data.type === 'progress') {
                     if (typeof data.progress === 'number') setProgress(data.progress);
                 } else if (data.type === 'phase') {
@@ -223,14 +179,20 @@ export function GeneratorWorkflowProvider({ children }) {
                                 subject: seq.subject,
                                 emailContent: seq.emailContent,
                                 channel: ch,
+                                stepOrder: seq.stepOrder,
                             };
+                            const dedupe = (e) =>
+                                e.stepOrder != null
+                                    ? `ord-${e.stepOrder}-${ch}`
+                                    : `${ch}-${e.emailNumber}`;
+                            const rowKey = dedupe(row);
                             const c = byContact.get(key);
                             if (ch === 'linkedin') {
-                                if (!c.linkedin.some((e) => e.emailNumber === row.emailNumber)) {
+                                if (!c.linkedin.some((e) => dedupe(e) === rowKey)) {
                                     c.linkedin.push(row);
                                 }
                             } else {
-                                if (!c.emails.some((e) => e.emailNumber === row.emailNumber)) {
+                                if (!c.emails.some((e) => dedupe(e) === rowKey)) {
                                     c.emails.push(row);
                                 }
                             }
@@ -240,9 +202,12 @@ export function GeneratorWorkflowProvider({ children }) {
                         setSequences(list);
                         setContacts(arr);
                         if (status.total_contacts > 0) {
-                            const exp = status.has_linkedin_prompts
-                                ? status.total_contacts * 2
-                                : status.total_contacts;
+                            const exp =
+                                status.campaign_sequence_actions && status.total_contacts > 0
+                                    ? status.total_contacts * status.campaign_sequence_actions
+                                    : status.has_linkedin_prompts
+                                      ? status.total_contacts * 2
+                                      : status.total_contacts;
                             setProgress(
                                 Math.min(100, ((status.completed_count || 0) / exp) * 100)
                             );

frontend/src/lib/mergeSequenceIntoContacts.js

@@ -0,0 +1,71 @@
+/**
+ * Merge one generated sequence row (email or LinkedIn) into grouped contacts for previews.
+ * When stepOrder is present (campaign wizard), dedupe by stepOrder + channel so merged timelines stay stable.
+ */
+export function mergeSequenceIntoContacts(prev, sequence) {
+    const ch = sequence.channel || 'email';
+    const existingContact = prev.find(
+        (c) =>
+            c.firstName === sequence.firstName &&
+            c.lastName === sequence.lastName &&
+            c.email === sequence.email
+    );
+    const stepOrder =
+        sequence.stepOrder != null && sequence.stepOrder !== undefined ? sequence.stepOrder : null;
+    const step = {
+        emailNumber: sequence.emailNumber || 1,
+        subject: sequence.subject,
+        emailContent: sequence.emailContent,
+        channel: ch,
+        stepOrder,
+    };
+    const dedupeKey =
+        stepOrder != null ? `ord-${stepOrder}-${ch}` : `${ch}-${step.emailNumber}`;
+
+    let updatedContacts;
+    if (existingContact) {
+        if (ch === 'linkedin') {
+            if (!existingContact.linkedin) existingContact.linkedin = [];
+            if (
+                !existingContact.linkedin.some((e) => {
+                    const k =
+                        e.stepOrder != null ? `ord-${e.stepOrder}-${ch}` : `${ch}-${e.emailNumber}`;
+                    return k === dedupeKey;
+                })
+            ) {
+                existingContact.linkedin.push(step);
+            }
+        } else {
+            if (!existingContact.emails) existingContact.emails = [];
+            if (
+                !existingContact.emails.some((e) => {
+                    const k =
+                        e.stepOrder != null ? `ord-${e.stepOrder}-${ch}` : `${ch}-${e.emailNumber}`;
+                    return k === dedupeKey;
+                })
+            ) {
+                existingContact.emails.push(step);
+            }
+        }
+        updatedContacts = [...prev];
+    } else {
+        const base = {
+            id: sequence.id,
+            firstName: sequence.firstName,
+            lastName: sequence.lastName,
+            email: sequence.email,
+            company: sequence.company,
+            title: sequence.title,
+            product: sequence.product,
+            emails: [],
+            linkedin: [],
+        };
+        if (ch === 'linkedin') {
+            base.linkedin = [step];
+        } else {
+            base.emails = [step];
+        }
+        updatedContacts = [...prev, base];
+    }
+    return updatedContacts;
+}