update

backend/app/main.py

@@ -442,29 +442,44 @@ async def push_to_smartlead(request: SmartleadPushRequest, db: Session = Depends
                     failed_count += 1
                     continue
                 
-                # Build lead object - Smartlead API doesn't allow "company", "title", or custom variables when adding leads
-                # We'll add leads first, then try to update them with custom variables separately
+                # Build lead object - Try including custom variables as direct fields with capitalized names
+                # Smartlead sequences use {{Subject_1}}, {{Body_1}} (capitalized), so we need to match that
                 lead = {
                     "email": email,
                     "first_name": first_name,
                     "last_name": last_name
                 }
                 
-                # Store custom variables separately to update leads after adding
+                # Add custom variables as direct fields with capitalized names to match sequence variables
+                # Smartlead may accept these if they match the variable names in sequences exactly
+                for i in range(1, request.steps_count + 1):
+                    if i in contact.get('subjects', {}):
+                        subject = contact['subjects'][i]
+                        subject_str = safe_str(subject) if subject else ""
+                        if subject_str:
+                            # Use capitalized name to match {{Subject_1}} in sequences
+                            lead[f'Subject_{i}'] = subject_str
+                    if i in contact.get('bodies', {}):
+                        body = contact['bodies'][i]
+                        body_str = safe_str(body) if body else ""
+                        if body_str:
+                            # Use capitalized name to match {{Body_1}} in sequences
+                            lead[f'Body_{i}'] = body_str
+                
+                # Store lead with custom vars for potential update if direct fields don't work
                 custom_vars = {}
                 for i in range(1, request.steps_count + 1):
                     if i in contact.get('subjects', {}):
                         subject = contact['subjects'][i]
                         subject_str = safe_str(subject) if subject else ""
                         if subject_str:
-                            custom_vars[f'subject_{i}'] = subject_str
+                            custom_vars[f'Subject_{i}'] = subject_str  # Capitalized
                     if i in contact.get('bodies', {}):
                         body = contact['bodies'][i]
                         body_str = safe_str(body) if body else ""
                         if body_str:
-                            custom_vars[f'body_{i}'] = body_str
+                            custom_vars[f'Body_{i}'] = body_str  # Capitalized
                 
-                # Store lead with custom vars for later update
                 leads.append({
                     "lead_data": lead,
                     "custom_vars": custom_vars,

backend/app/smartlead_client.py

@@ -262,8 +262,8 @@ class SmartleadClient:
             
             sequences.append({
                 "seq_number": i,  # Required by Smartlead API (not "step")
-                "subject": f"{{{{subject_{i}}}}}",  # Double braces escape to produce {{subject_1}}, etc.
-                "email_body": f"Hi {{{{first_name}}}},\n\n{{{{body_{i}}}}}\n\n",  # Produces: Hi {{first_name}},\n\n{{body_1}}\n\n
+                "subject": f"{{{{Subject_{i}}}}}",  # Double braces escape to produce {{Subject_1}}, etc. (capitalized)
+                "email_body": f"Hi {{{{first_name}}}},\n\n{{{{Body_{i}}}}}\n\n",  # Produces: Hi {{first_name}},\n\n{{Body_1}}\n\n (capitalized)
                 "seq_delay_details": {
                     "delay_in_days": delay_days  # Required by Smartlead API
                 }