update

backend/app/main.py

@@ -443,30 +443,37 @@ async def push_to_smartlead(request: SmartleadPushRequest, db: Session = Depends
                     continue
                 
                 # Build lead object - Smartlead API doesn't allow "company" or "title" fields
-                # Smartlead requires customFields (camelCase) with custom fields defined at campaign level
+                # 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
                 lead = {
                     "email": email,
                     "first_name": first_name,
                     "last_name": last_name
                 }
                 
-                # Build customFields object (camelCase) - fields must match campaign custom field definitions
-                customFields = {}
+                # 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):
                     if i in contact.get('subjects', {}):
                         subject = contact['subjects'][i]
                         subject_str = safe_str(subject) if subject else ""
                         if subject_str:
-                            customFields[f'subject_{i}'] = subject_str
+                            custom_vars_data[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:
-                            customFields[f'body_{i}'] = body_str
+                            custom_vars_data[f'body_{i}'] = body_str
                 
-                # Only add customFields if we have any
-                if customFields:
-                    lead["customFields"] = customFields
+                # 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'
+                }
                 
                 leads.append(lead)
                 
@@ -478,16 +485,22 @@ 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, batch)
+                response = client.add_leads_to_campaign(campaign_id, clean_batch)
                 # TODO: Parse response to get added/skipped counts
-                added_count += len(batch)
+                added_count += len(clean_batch)
             except Exception as e:
                 # Mark batch as failed
-                for lead in batch:
+                for lead in clean_batch:
                     errors.append({
                         "email": lead.get('email', 'unknown'),
                         "error": str(e)
@@ -503,6 +516,16 @@ 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."
+            )
+        
         return {
             "run_id": run_id,
             "campaign_id": campaign_id,
@@ -513,7 +536,8 @@ async def push_to_smartlead(request: SmartleadPushRequest, db: Session = Depends
             "skipped": skipped_count,
             "failed": failed_count,
             "errors": errors[:10],  # Return first 10 errors
-            "status": "completed"
+            "status": "completed",
+            "warning": warning_message
         }
         
     except HTTPException: