mcp-crm 1.0.0

Enterprise CRM MCP Server — unified access to Salesforce, HubSpot, Zoho CRM, and Pipedrive with contacts, companies, deals, activities, and pipeline management
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

//! Unified CRM types shared across all backends.
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Contact {
    pub id: String,
    pub first_name: Option<String>,
    pub last_name: Option<String>,
    pub email: Option<String>,
    pub phone: Option<String>,
    pub company_id: Option<String>,
    pub company_name: Option<String>,
    pub title: Option<String>,
    pub backend: String,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Company {
    pub id: String,
    pub name: String,
    pub domain: Option<String>,
    pub industry: Option<String>,
    pub phone: Option<String>,
    pub city: Option<String>,
    pub country: Option<String>,
    pub backend: String,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Deal {
    pub id: String,
    pub name: String,
    pub stage: Option<String>,
    pub pipeline: Option<String>,
    pub amount: Option<f64>,
    pub currency: Option<String>,
    pub contact_id: Option<String>,
    pub company_id: Option<String>,
    pub close_date: Option<String>,
    pub probability: Option<f64>,
    pub status: Option<String>,
    pub backend: String,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Activity {
    pub id: String,
    pub activity_type: String,
    pub subject: Option<String>,
    pub body: Option<String>,
    pub contact_id: Option<String>,
    pub deal_id: Option<String>,
    pub done: bool,
    pub due_date: Option<String>,
    pub backend: String,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Pipeline {
    pub id: String,
    pub name: String,
    pub stages: Vec<PipelineStage>,
    pub backend: String,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PipelineStage {
    pub id: String,
    pub name: String,
    pub order: u32,
    pub deal_count: Option<u32>,
    pub total_value: Option<f64>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Note {
    pub id: String,
    pub content: String,
    pub contact_id: Option<String>,
    pub company_id: Option<String>,
    pub deal_id: Option<String>,
    pub created_at: Option<String>,
    pub backend: String,
}

/// Backend trait — each CRM implements this.
#[async_trait::async_trait]
pub trait CrmBackend: Send + Sync {
    fn name(&self) -> &str;

    // Contacts
    async fn list_contacts(&self, limit: u32) -> anyhow::Result<Vec<Contact>>;
    async fn get_contact(&self, id: &str) -> anyhow::Result<Contact>;
    async fn create_contact(&self, first_name: &str, last_name: &str, email: Option<&str>, phone: Option<&str>, company_id: Option<&str>) -> anyhow::Result<Contact>;
    async fn update_contact(&self, id: &str, first_name: Option<&str>, last_name: Option<&str>, email: Option<&str>, phone: Option<&str>) -> anyhow::Result<Contact>;
    async fn search_contacts(&self, query: &str, limit: u32) -> anyhow::Result<Vec<Contact>>;

    // Companies
    async fn list_companies(&self, limit: u32) -> anyhow::Result<Vec<Company>>;
    async fn get_company(&self, id: &str) -> anyhow::Result<Company>;
    async fn create_company(&self, name: &str, domain: Option<&str>, industry: Option<&str>) -> anyhow::Result<Company>;
    async fn update_company(&self, id: &str, name: Option<&str>, domain: Option<&str>, industry: Option<&str>) -> anyhow::Result<Company>;

    // Deals
    async fn list_deals(&self, limit: u32) -> anyhow::Result<Vec<Deal>>;
    async fn get_deal(&self, id: &str) -> anyhow::Result<Deal>;
    async fn create_deal(&self, name: &str, amount: Option<f64>, stage: Option<&str>, contact_id: Option<&str>, company_id: Option<&str>) -> anyhow::Result<Deal>;
    async fn update_deal(&self, id: &str, name: Option<&str>, amount: Option<f64>, stage: Option<&str>, close_date: Option<&str>) -> anyhow::Result<Deal>;
    async fn move_deal_stage(&self, id: &str, stage: &str) -> anyhow::Result<Deal>;

    // Activities
    async fn list_activities(&self, contact_id: Option<&str>, deal_id: Option<&str>, limit: u32) -> anyhow::Result<Vec<Activity>>;
    async fn create_activity(&self, activity_type: &str, subject: &str, body: Option<&str>, contact_id: Option<&str>, deal_id: Option<&str>) -> anyhow::Result<Activity>;

    // Pipelines
    async fn list_pipelines(&self) -> anyhow::Result<Vec<Pipeline>>;
    async fn get_pipeline_summary(&self, pipeline_id: Option<&str>) -> anyhow::Result<Vec<Pipeline>>;

    // Notes
    async fn list_notes(&self, contact_id: Option<&str>, deal_id: Option<&str>, limit: u32) -> anyhow::Result<Vec<Note>>;
    async fn create_note(&self, content: &str, contact_id: Option<&str>, company_id: Option<&str>, deal_id: Option<&str>) -> anyhow::Result<Note>;
}