update

backend/app/main.py

@@ -443,37 +443,28 @@ async def push_to_smartlead(request: SmartleadPushRequest, db: Session = Depends
                     continue
                 
                 # Build lead object - Smartlead API doesn't allow "company" or "title" fields
-                # NOTE: Smartlead API appears to reject customFields/custom_variables in lead payload
-                # Custom fields may need to be defined in Smartlead UI first, or via a different API endpoint
-                # For now, we'll add leads with basic info only
-                # The custom variables (subject_1, body_1, etc.) may need to be handled differently
+                # Try passing custom variables as direct top-level fields (not nested)
+                # Smartlead sequences use {{subject_1}}, {{body_1}}, etc. - these should be passed as direct fields
                 lead = {
                     "email": email,
                     "first_name": first_name,
                     "last_name": last_name
                 }
                 
-                # Store custom variables separately for potential future use
-                # These would need to be added via Smartlead UI or a different API method
-                custom_vars_data = {}
-                for i in range(1, 11):
+                # Add custom variables as direct top-level fields on the lead object
+                # Smartlead sequences use {{subject_1}}, {{body_1}}, etc. - pass values as direct fields
+                # Only include fields up to steps_count to match the campaign sequences
+                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_data[f'subject_{i}'] = subject_str
+                            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:
-                            custom_vars_data[f'body_{i}'] = body_str
-                
-                # Store in a comment/metadata field for reference (won't be sent to API)
-                # TODO: Find correct Smartlead API method to add custom variables per lead
-                lead['_metadata'] = {
-                    'custom_vars': custom_vars_data,
-                    'note': 'Custom variables need to be added via Smartlead UI or API after lead creation'
-                }
+                            lead[f'body_{i}'] = body_str
                 
                 leads.append(lead)
                 
@@ -485,22 +476,16 @@ async def push_to_smartlead(request: SmartleadPushRequest, db: Session = Depends
                 failed_count += 1
         
         # Batch add leads (chunk in batches of 50)
-        # Remove _metadata before sending to API
         batch_size = 50
         for i in range(0, len(leads), batch_size):
             batch = leads[i:i + batch_size]
-            # Clean batch - remove internal _metadata field
-            clean_batch = []
-            for lead in batch:
-                clean_lead = {k: v for k, v in lead.items() if k != '_metadata'}
-                clean_batch.append(clean_lead)
             try:
-                response = client.add_leads_to_campaign(campaign_id, clean_batch)
+                response = client.add_leads_to_campaign(campaign_id, batch)
                 # TODO: Parse response to get added/skipped counts
-                added_count += len(clean_batch)
+                added_count += len(batch)
             except Exception as e:
                 # Mark batch as failed
-                for lead in clean_batch:
+                for lead in batch:
                     errors.append({
                         "email": lead.get('email', 'unknown'),
                         "error": str(e)
@@ -516,15 +501,7 @@ async def push_to_smartlead(request: SmartleadPushRequest, db: Session = Depends
         run.completed_at = datetime.utcnow()
         db.commit()
         
-        # Warning message about custom variables
-        warning_message = None
-        if added_count > 0:
-            warning_message = (
-                "Leads were added successfully, but custom variables (subject_1, body_1, etc.) "
-                "could not be set via API. These need to be added manually in Smartlead UI, or "
-                "the campaign sequences may not work correctly. Please check Smartlead documentation "
-                "for the correct method to add custom variables per lead."
-            )
+        # No warning needed - custom variables are now passed as direct fields
         
         return {
             "run_id": run_id,