Integrate DataEnrichmentManager into outreach_agent - add enrichment to contact validation

outreach_agent.py

@@ -2,17 +2,19 @@ import logging
 from typing import Dict, Any, Optional, List, Callable
 # Import lead_scoring_agent for lead scoring integration
 from lead_scoring_agent import score_lead
+from data_enrichment import DataEnrichmentManager
 
 class OutreachAgent:
     """
     OutreachAgent handles lead intake, message tailoring, and multi-channel delivery.
     Integrates lead_scoring_agent to score leads at intake for prioritization and routing.
     """
-    def __init__(self, channel_handlers: Optional[Dict[str, Callable]]=None):
-        self.logger = logging.getLogger("OutreachAgent")
+    def __init__(self, username: str, channel_handlers: Optional[Dict[str, Callable]]=None):        self.logger = logging.getLogger("OutreachAgent")
         self.lead_assets = {}
         self.analytics = []
         self.channel_handlers = channel_handlers or {}
+        self.username = username
+        self.enrichment_manager = DataEnrichmentManager(username)
     
     def intake_lead(self, lead_profile: Dict[str, Any]) -> Dict[str, Any]:
         """
@@ -35,6 +37,18 @@ class OutreachAgent:
     def validate_and_enrich_profile(self, profile: Dict[str, Any]) -> Dict[str, Any]:
         # Enrich with historical, persona, engagements, etc.
         # Preserve scoring metadata from lead_scoring_agent
+                
+        # ENRICHMENT STEP: Use DataEnrichmentManager to enrich profile with 14 APIs
+        try:
+            enriched_data = self.enrichment_manager.enrich_contact_full(profile)
+            if enriched_data:
+                # Merge enriched data into profile (preserve existing fields)
+                for key, value in enriched_data.items():
+                    if key not in profile or not profile[key]:  # Only update if field is missing
+                        profile[key] = value
+                self.logger.info(f"Profile enriched with {len(enriched_data)} data sources")
+        except Exception as e:
+            self.logger.warning(f"Enrichment failed: {e}. Continuing with available data.")
         required_fields = ['persona', 'channel_fit']
         for field in required_fields:
             if field not in profile: