Add application files

BUGFIX_SUMMARY.md

@@ -0,0 +1,136 @@
+# Bug Fix Summary - WebSearchService Integration
+
+## 🐛 Issue
+
+```
+❌ Error: WebSearchService.search() got an unexpected keyword argument 'num_results'
+```
+
+## 🔍 Root Cause
+
+The `B2BSalesAgent` class was using incorrect parameter names and missing `await` keywords when calling the asynchronous `WebSearchService.search()` method.
+
+### Problems Identified:
+
+1. **Wrong parameter name**: Used `num_results` instead of `max_results`
+2. **Missing await**: Didn't use `await` for async method calls
+3. **Wrong field names**: Used `'snippet'` and `'link'` instead of `'body'` and `'url'`
+
+## ✅ Fixes Applied
+
+### 1. Parameter Name Corrections (4 instances)
+
+**Before:**
+```python
+results = self.web_search.search(query, num_results=5)
+```
+
+**After:**
+```python
+results = await self.web_search.search(query, max_results=5)
+```
+
+**Files affected:**
+- `app.py` lines 431, 447, 457, 475, 495
+
+### 2. Field Name Corrections
+
+**Before:**
+```python
+client_profile['website'] = result['link']  # ❌ Wrong
+snippet = result.get('snippet', '')         # ❌ Wrong
+```
+
+**After:**
+```python
+client_profile['website'] = result['url']   # ✅ Correct
+body = result.get('body', '')               # ✅ Correct
+```
+
+## 📋 WebSearchService Return Format
+
+The `WebSearchService.search()` method returns results with these keys:
+
+```python
+{
+    'title': 'Result title',
+    'body': 'Result snippet/description',  # NOT 'snippet'
+    'url': 'https://example.com',          # NOT 'link'
+    'source': 'example.com'
+}
+```
+
+## 🔧 Complete Change List
+
+### `app.py` - B2BSalesAgent class
+
+1. **Line 431** - `research_client()`:
+   - ✅ Changed `num_results=5` → `max_results=5`
+   - ✅ Added `await`
+
+2. **Line 443** - `research_client()`:
+   - ✅ Changed `result.get('link')` → `result.get('url')`
+
+3. **Line 447** - `research_client()`:
+   - ✅ Changed `num_results=3` → `max_results=3`
+   - ✅ Added `await`
+
+4. **Line 457** - `find_prospects()`:
+   - ✅ Changed `num_results=num_prospects * 2` → `max_results=num_prospects * 2`
+   - ✅ Added `await`
+
+5. **Lines 463-464** - `find_prospects()`:
+   - ✅ Changed `result.get('link')` → `result.get('url')`
+   - ✅ Changed `result.get('snippet')` → `result.get('body')`
+
+6. **Line 475** - `research_prospect()`:
+   - ✅ Changed `num_results=5` → `max_results=5`
+   - ✅ Added `await`
+
+7. **Line 487** - `research_prospect()`:
+   - ✅ Changed `result.get('snippet')` → `result.get('body')`
+
+8. **Line 495** - `find_contacts()`:
+   - ✅ Changed `num_results=5` → `max_results=5`
+   - ✅ Added `await`
+
+9. **Lines 501, 510** - `find_contacts()`:
+   - ✅ Changed `result.get('snippet')` → `result.get('body')`
+   - ✅ Changed `result.get('link')` → `result.get('url')`
+
+## ✅ Verification
+
+All fixes have been applied and syntax verified:
+
+```bash
+✅ python -m py_compile app.py  # No errors
+```
+
+## 🚀 Status
+
+**RESOLVED** - The B2B Sales Agent now correctly integrates with WebSearchService.
+
+The application should now work without errors when:
+1. Running the B2B Sales pipeline
+2. Researching client companies
+3. Finding prospects
+4. Finding contacts
+5. Generating emails
+
+## 🧪 Testing Checklist
+
+After deploying these fixes, verify:
+
+- [ ] B2B Sales pipeline runs without errors
+- [ ] Client company research completes
+- [ ] Prospects are discovered
+- [ ] Contacts are found at prospect companies
+- [ ] Emails are generated successfully
+- [ ] AI Reply Handler simulation works
+- [ ] No "unexpected keyword argument" errors
+
+---
+
+**Fixed by:** Claude Code AI Assistant
+**Date:** 2025-11-16
+**Files Modified:** `app.py` (9 changes)

app.py

@@ -428,7 +428,7 @@ class B2BSalesAgent:
     async def research_client(self, client_name: str):
         """Step 1: Research the CLIENT company"""
         query = f"{client_name} company what they offer products services target customers"
-        results = self.web_search.search(query, num_results=5)
+        results = await self.web_search.search(query, max_results=5)
 
         client_profile = {
             "name": client_name,
@@ -440,11 +440,11 @@ class B2BSalesAgent:
         }
 
         for result in results:
-            if not client_profile['website'] and result.get('link'):
-                client_profile['website'] = result['link']
+            if not client_profile['website'] and result.get('url'):
+                client_profile['website'] = result['url']
 
         offering_query = f"{client_name} products services features benefits"
-        offering_results = self.web_search.search(offering_query, num_results=3)
+        offering_results = await self.web_search.search(offering_query, max_results=3)
 
         client_profile['summary'] = f"Research on {client_name} compiled from web search"
         return client_profile
@@ -454,14 +454,14 @@ class B2BSalesAgent:
         client_name = client_profile['name']
         prospect_query = f"companies that could use {client_name} potential customers businesses"
 
-        results = self.web_search.search(prospect_query, num_results=num_prospects * 2)
+        results = await self.web_search.search(prospect_query, max_results=num_prospects * 2)
 
         prospects = []
         for result in results[:num_prospects]:
             prospect = {
                 "name": result.get('title', 'Unknown Company'),
-                "domain": result.get('link', ''),
-                "snippet": result.get('snippet', ''),
+                "domain": result.get('url', ''),
+                "snippet": result.get('body', ''),
                 "industry": "",
                 "size": "Unknown"
             }
@@ -472,7 +472,7 @@ class B2BSalesAgent:
     async def research_prospect(self, prospect_name: str):
         """Step 3: Research a PROSPECT company"""
         query = f"{prospect_name} company business model challenges pain points"
-        results = self.web_search.search(query, num_results=5)
+        results = await self.web_search.search(query, max_results=5)
 
         prospect_profile = {
             "name": prospect_name,
@@ -484,30 +484,30 @@ class B2BSalesAgent:
         }
 
         for result in results:
-            snippet = result.get('snippet', '')
-            prospect_profile['pain_points'].append(snippet)
+            body = result.get('body', '')
+            prospect_profile['pain_points'].append(body)
 
         return prospect_profile
 
     async def find_contacts(self, prospect_name: str, prospect_domain: str):
         """Step 4: Find decision-maker contacts at PROSPECT company"""
         query = f"{prospect_name} CEO VP director contact linkedin"
-        results = self.web_search.search(query, num_results=5)
+        results = await self.web_search.search(query, max_results=5)
 
         contacts = []
         titles_to_find = ["CEO", "VP", "Director", "Head of", "Chief"]
 
         for result in results:
-            snippet = result.get('snippet', '')
+            body = result.get('body', '')
             title_result = result.get('title', '')
 
             for title_keyword in titles_to_find:
-                if title_keyword in snippet or title_keyword in title_result:
+                if title_keyword in body or title_keyword in title_result:
                     contact = {
                         "name": "Contact Name (from search)",
                         "title": title_keyword,
                         "company": prospect_name,
-                        "linkedin": result.get('link', ''),
+                        "linkedin": result.get('url', ''),
                         "email": f"contact@{prospect_domain}" if prospect_domain else "unknown"
                     }
                     contacts.append(contact)