leadpipe-mcp
AI-powered lead qualification engine. Ingest leads from any source, auto-enrich with company data, score 0-100 using weighted AI rules, and export to HubSpot, Pipedrive, Google Sheets, CSV, or JSON. 8 MCP tools + 3 resources.
README
LeadPipe MCP
AI-powered lead qualification engine for the Model Context Protocol
LeadPipe ingests leads from any source, enriches them with company data, scores them 0-100 using configurable AI rules, and exports qualified leads to your CRM — all through the MCP protocol.
Features
- Lead ingestion from webhooks, forms, APIs, or CSV — single or batch (up to 100)
- Auto-enrichment with company data: industry, size, country, tech stack (via Hunter.io or domain heuristics)
- AI scoring engine (0-100) with 6 weighted dimensions + custom rules
- CRM export to HubSpot, Pipedrive, Google Sheets, CSV, or JSON
- Pipeline analytics with real-time stats, score distribution, conversion rates
- Configurable scoring weights, high-value titles/industries, custom rules
- 8 MCP tools + 3 MCP resources covering the full lead lifecycle
Quick Start
Install from MCPize Marketplace
- Search for LeadPipe MCP on mcpize.com
- Click Install and select your subscription tier
- Tools and resources are automatically available in any MCP-compatible client (Cursor, VS Code, etc.)
Build from Source
git clone https://github.com/enzoemir1/leadpipe-mcp.git
cd leadpipe-mcp
npm ci
npm run build
Add to your MCP client config:
{
"mcpServers": {
"leadpipe": {
"command": "node",
"args": ["path/to/leadpipe-mcp/dist/index.js"]
}
}
}
Tools
lead_ingest
Add a single lead to the pipeline.
{
"email": "jane@acme.com",
"first_name": "Jane",
"last_name": "Smith",
"job_title": "VP of Engineering",
"company_name": "Acme Corp",
"company_domain": "acme.com",
"source": "website_form",
"tags": ["demo-request"]
}
lead_batch_ingest
Add 1-100 leads at once. Duplicates are automatically skipped.
{
"leads": [
{ "email": "lead1@corp.com", "job_title": "CEO" },
{ "email": "lead2@startup.io", "job_title": "CTO" }
]
}
lead_enrich
Enrich a lead with company data using the email domain.
{ "lead_id": "uuid-of-lead" }
Returns: company name, industry, size, country, tech stack, LinkedIn URL.
lead_score
Calculate a qualification score (0-100). Leads scoring 60+ are marked qualified.
{ "lead_id": "uuid-of-lead" }
Returns score + detailed breakdown across all 6 dimensions.
lead_search
Search and filter leads with pagination.
{
"query": "acme",
"status": "qualified",
"min_score": 60,
"limit": 20,
"offset": 0
}
lead_export
Export leads to CRM or file format.
{
"target": "hubspot",
"min_score": 60
}
Targets: hubspot, pipedrive, google_sheets, csv, json
pipeline_stats
Get pipeline analytics. No input required.
Returns: total leads, status/source breakdown, average score, score distribution, qualified rate, leads today/week/month.
config_scoring
View or update scoring configuration.
{
"job_title_weight": 0.30,
"high_value_titles": ["ceo", "cto", "vp", "founder"],
"custom_rules": [
{
"field": "company_industry",
"operator": "equals",
"value": "fintech",
"points": 15,
"description": "Bonus for fintech companies"
}
]
}
Resources
| Resource | Description |
|---|---|
leads://recent |
The 50 most recently added leads |
leads://pipeline |
Pipeline summary with status counts, scores, conversion rates |
leads://config |
Current scoring engine configuration |
Scoring Engine
Leads are scored 0-100 using a weighted average of 6 dimensions:
| Dimension | Default Weight | How It Works |
|---|---|---|
| Job Title | 25% | C-level/Founder: 100, VP/Director: 85, Manager: 65, Senior: 50, Junior: 15 |
| Company Size | 20% | Preferred sizes (11-50, 51-200, 201-500): 90, others scaled accordingly |
| Industry | 20% | High-value industries (SaaS, fintech, etc.): 90, others: 40 |
| Engagement | 15% | Phone provided, full name, tags, source type (landing page > CSV) |
| Recency | 10% | Today: 100, last week: 75, last month: 35, 3+ months: 5 |
| Custom Rules | 10% | User-defined rules with -50 to +50 points each |
Formula: score = sum(dimension_score * weight)
Leads with score >= 60 are qualified. Below 60 are disqualified.
CRM Integration
HubSpot
Set the HUBSPOT_API_KEY environment variable with your HubSpot private app access token.
export HUBSPOT_API_KEY="pat-xxx-xxx"
Pipedrive
Set the PIPEDRIVE_API_KEY environment variable.
export PIPEDRIVE_API_KEY="xxx"
Google Sheets
Set GOOGLE_SHEETS_CREDENTIALS with your service account JSON.
CSV / JSON
No configuration needed. Export returns data directly.
Enrichment
LeadPipe extracts the domain from the lead's email and looks up company data:
- Hunter.io (if
HUNTER_API_KEYis set) — returns organization, industry, country, tech stack - Domain heuristics — maps known domains to company data
- Freemail detection — gmail.com, yahoo.com, etc. are flagged (no company enrichment)
Pricing
| Tier | Price | Leads/month | Features |
|---|---|---|---|
| Free | $0 | 50 | Basic scoring, webhook intake |
| Pro | $20/mo | 500 | AI scoring, enrichment, email notifications |
| Business | $40/mo | 5,000 | CRM sync, pipeline analytics, custom rules |
Available on the MCPize Marketplace.
Development
npm run dev # Hot reload development
npm run build # Production build
npm test # Run unit tests
npm run inspect # Open MCP Inspector
License
MIT License. See LICENSE for details.
Built by Automatia BCN.
推荐服务器
Baidu Map
百度地图核心API现已全面兼容MCP协议,是国内首家兼容MCP协议的地图服务商。
Playwright MCP Server
一个模型上下文协议服务器,它使大型语言模型能够通过结构化的可访问性快照与网页进行交互,而无需视觉模型或屏幕截图。
Magic Component Platform (MCP)
一个由人工智能驱动的工具,可以从自然语言描述生成现代化的用户界面组件,并与流行的集成开发环境(IDE)集成,从而简化用户界面开发流程。
Audiense Insights MCP Server
通过模型上下文协议启用与 Audiense Insights 账户的交互,从而促进营销洞察和受众数据的提取和分析,包括人口统计信息、行为和影响者互动。
VeyraX
一个单一的 MCP 工具,连接你所有喜爱的工具:Gmail、日历以及其他 40 多个工具。
graphlit-mcp-server
模型上下文协议 (MCP) 服务器实现了 MCP 客户端与 Graphlit 服务之间的集成。 除了网络爬取之外,还可以将任何内容(从 Slack 到 Gmail 再到播客订阅源)导入到 Graphlit 项目中,然后从 MCP 客户端检索相关内容。
Kagi MCP Server
一个 MCP 服务器,集成了 Kagi 搜索功能和 Claude AI,使 Claude 能够在回答需要最新信息的问题时执行实时网络搜索。
e2b-mcp-server
使用 MCP 通过 e2b 运行代码。
Neon MCP Server
用于与 Neon 管理 API 和数据库交互的 MCP 服务器
Exa MCP Server
模型上下文协议(MCP)服务器允许像 Claude 这样的 AI 助手使用 Exa AI 搜索 API 进行网络搜索。这种设置允许 AI 模型以安全和受控的方式获取实时的网络信息。